Filters defined in RFC4791 9.7.1-9.7.5: DRY ingest
[citadel.git] / webcit-ng / server / caldav_reports.c
index 5883c73470bc7d1d306854e9aea75951ab7b478b..f4eb6c06ad14b9bb61580727c4b188a40d21b509 100644 (file)
@@ -16,17 +16,18 @@ enum cr_type {
 // Data type for CalDAV Report Parameters.
 // As we slog our way through the XML we learn what the client is asking for
 // and build up the contents of this data type.
-struct cr_parms {
+struct cr_params {
        int tag_nesting_level;          // not needed, just kept for pretty-printing
        enum cr_type report_type;       // which RFC4791 section 7 REPORT are we generating
        StrBuf *Chardata;               // XML chardata in between tags is built up here
        StrBuf *Hrefs;                  // list of items requested by a `calendar-multiget` REPORT
+       Array *filters;                 // If the query contains a FILTER stanza, the filter criteria are populated here
 };
 
 
 // XML parser callback
 void caldav_xml_start(void *data, const char *el, const char **attr) {
-       struct cr_parms *crp = (struct cr_parms *) data;
+       struct cr_params *crp = (struct cr_params *) data;
 
 #ifdef DEBUG_XML_PARSE
        // logging
@@ -34,13 +35,13 @@ void caldav_xml_start(void *data, const char *el, const char **attr) {
        char indent[256];
        indent[0] = 0;
        for (i=0; i<crp->tag_nesting_level; ++i) {
-               strcat(indent, "··");
+               strcat(indent, "  ");
        }
        syslog(LOG_DEBUG, "%s<%s>", indent, el);
        ++crp->tag_nesting_level;
        indent[0] = 0;
        for (i=0; i<crp->tag_nesting_level; ++i) {
-               strcat(indent, "··");
+               strcat(indent, "  ");
        }
        for (i = 0; attr[i] != NULL; i += 2) {
                syslog(LOG_DEBUG, "%sAttribute '%s' = '%s'", indent, attr[i], attr[i + 1]);
@@ -63,12 +64,36 @@ void caldav_xml_start(void *data, const char *el, const char **attr) {
                crp->report_type = cr_freebusy_query;
        }
 
+       // RFC4791 9.7 create a filter array if this query contains a "CALDAV:filter" stanza
+       else if (!strcasecmp(el, "urn:ietf:params:xml:ns:caldav:filter")) {
+               crp->filters = array_new(SIZ);
+       }
+
+       // Handle the filters defined in RFC4791 9.7.1 through 9.7.5
+       else if (       (       (!strcasecmp(el, "urn:ietf:params:xml:ns:caldav:comp-filter"))
+                               || (!strcasecmp(el, "urn:ietf:params:xml:ns:caldav:prop-filter"))
+                               || (!strcasecmp(el, "urn:ietf:params:xml:ns:caldav:param-filter"))
+                               || (!strcasecmp(el, "urn:ietf:params:xml:ns:caldav:is-not-defined"))
+                               || (!strcasecmp(el, "urn:ietf:params:xml:ns:caldav:text-match"))
+                       )
+                       && (crp->filters)                       // Make sure we actually allocated an array
+       ) {
+               char newfilter[SIZ];
+               int a = 0;
+               int len = snprintf(newfilter, SIZ, &el[23]);    // strip off "urn:ietf:params:xml:ns:caldav:" for our purposes
+               while (attr[a]) {
+                       len += snprintf(&newfilter[len], SIZ-len, "|%s", attr[a++]);    // now save the attributes
+               }
+               array_append(crp->filters, newfilter);
+               syslog(LOG_DEBUG, "%s", newfilter);
+       }
+
 }
 
 
 // XML parser callback
 void caldav_xml_end(void *data, const char *el) {
-       struct cr_parms *crp = (struct cr_parms *) data;
+       struct cr_params *crp = (struct cr_params *) data;
 
        --crp->tag_nesting_level;
 
@@ -78,7 +103,7 @@ void caldav_xml_end(void *data, const char *el) {
        char indent[256];
        indent[0] = 0;
        for (i=0; i<crp->tag_nesting_level; ++i) {
-               strcat(indent, "··");
+               strcat(indent, "  ");
        }
        syslog(LOG_DEBUG, "%s</%s>", indent, el);
        // end logging
@@ -103,7 +128,7 @@ void caldav_xml_end(void *data, const char *el) {
 
 // XML parser callback
 void caldav_xml_chardata(void *data, const XML_Char *s, int len) {
-       struct cr_parms *crp = (struct cr_parms *) data;
+       struct cr_params *crp = (struct cr_params *) data;
 
        char *app = malloc(len+1);
        if (!app) {
@@ -126,7 +151,7 @@ void caldav_xml_chardata(void *data, const XML_Char *s, int len) {
                char indent[256];
                indent[0] = 0;
                for (i=0; i<crp->tag_nesting_level; ++i) {
-                       strcat(indent, "··");
+                       strcat(indent, "  ");
                }
                syslog(LOG_DEBUG, "%s%s", indent, app, len);
        }
@@ -240,14 +265,42 @@ void caldav_report_one_item(struct http_transaction *h, struct ctdlsession *c, S
 }
 
 
+// Called by caldav_apply_filters() to apply ONE filter.
+// Returns 0 if the calendar item does not match the filter.
+// Returns 1 if the calendar item DOES match the filter.
+int caldav_apply_one_filter(void *cal, char *filter) {
+       syslog(LOG_DEBUG, "applying filter: %s", filter);
+       return(1);
+}
+
+
+// Recursive function to apply CalDAV FILTERS to a calendar item.
+// Returns zero if the calendar item was disqualified by a filter, nonzero if the calendar item still qualifies.
+int caldav_apply_filters(void *cal, Array *filters, int index) {
+
+       // Apply *this* filter.
+       if (caldav_apply_one_filter(cal, array_get_element_at(filters, index)) == 0) {
+               return(0);
+       }
+
+       // If we get to this point, the current filter has passed, and we move on to the next one.
+       if (index < array_len(filters)-1) {
+               return(caldav_apply_filters(cal, filters, index+1));
+       }
+
+       // If we got this far, every filter passed, and the calendar item qualifies for output.
+       return(1);
+}
+
+
 // Called by report_the_room_itself() in room_functions.c when a CalDAV REPORT method
 // is requested on a calendar room.  We fire up an XML Parser to decode the request and
 // hopefully produce the correct output.
 void caldav_report(struct http_transaction *h, struct ctdlsession *c) {
-       struct cr_parms crp;
+       struct cr_params crp;
        char buf[1024];
 
-       memset(&crp, 0, sizeof(struct cr_parms));
+       memset(&crp, 0, sizeof(struct cr_params));
 
        XML_Parser xp = XML_ParserCreateNS("UTF-8", ':');
        if (xp == NULL) {
@@ -297,11 +350,12 @@ void caldav_report(struct http_transaction *h, struct ctdlsession *c) {
                                StrBuf *one_item = fetch_ical(c, m);
                                icalcomponent *cal = icalcomponent_new_from_string(ChrPtr(one_item));
 
-                               // qualify will be set to nonzero if this calendar item is a match for the QUERY.
-                               int qualify = 0;
+                               // Does this calendar item qualify for output?
+                               int qualify = 1;
 
-                               // this is a horrible temporary hack to output every item (for now)
-                               qualify = 1;
+                               // If there was a filter stanza, run this calendar item through the filters.
+                               qualify = caldav_apply_filters(cal, crp.filters, 0);
+                               syslog(LOG_DEBUG, "Message %ld does%s qualify", m, (qualify ? "" : " NOT"));
 
                                // Did this calendar item match the query?  If so, output it.
                                if (qualify) {
@@ -340,6 +394,10 @@ void caldav_report(struct http_transaction *h, struct ctdlsession *c) {
                FreeStrBuf(&crp.Hrefs);
                crp.Hrefs = NULL;
        }
+       if (crp.filters) {
+               array_free(crp.filters);
+               crp.filters = NULL;
+       }
 
        StrBufAppendPrintf(ReportOut, "</D:multistatus>\n");            // End the REPORT.