-void rss_do_fetching(char *url, char *rooms) {
- struct rss_item ri;
- XML_Parser xp;
-
- CURL *curl;
- CURLcode res;
- char errmsg[1024] = "";
-
- CtdlLogPrintf(CTDL_DEBUG, "Fetching RSS feed <%s>\n", url);
-
- curl = curl_easy_init();
- if (!curl) {
- CtdlLogPrintf(CTDL_ALERT, "Unable to initialize libcurl.\n");
- return;
- }
-
- xp = XML_ParserCreateNS("UTF-8", ':');
- if (!xp) {
- CtdlLogPrintf(CTDL_ALERT, "Cannot create XML parser!\n");
- curl_easy_cleanup(curl);
- return;
- }
-
- curl_easy_setopt(curl, CURLOPT_URL, url);
- curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, 0);
- curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, 0);
- curl_easy_setopt(curl, CURLOPT_WRITEDATA, xp);
- curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, rss_libcurl_callback);
- curl_easy_setopt(curl, CURLOPT_ERRORBUFFER, errmsg);
- curl_easy_setopt(curl, CURLOPT_FOLLOWLOCATION, 1);
-#ifdef CURLOPT_HTTP_CONTENT_DECODING
- curl_easy_setopt(curl, CURLOPT_HTTP_CONTENT_DECODING, 1);
- curl_easy_setopt(curl, CURLOPT_ENCODING, "");
-#endif
- curl_easy_setopt(curl, CURLOPT_USERAGENT, CITADEL);
- curl_easy_setopt(curl, CURLOPT_TIMEOUT, 180); /* die after 180 seconds */
- if (!IsEmptyStr(config.c_ip_addr)) {
- curl_easy_setopt(curl, CURLOPT_INTERFACE, config.c_ip_addr);
- }
-
- memset(&ri, 0, sizeof(struct rss_item));
- ri.roomlist = rooms;
- XML_SetElementHandler(xp, rss_xml_start, rss_xml_end);
- XML_SetCharacterDataHandler(xp, rss_xml_chardata);
- XML_SetUserData(xp, &ri);
-
- if (CtdlThreadCheckStop())
+int rss_do_fetching(rss_aggregator *RSSAggr)
+{
+ AsyncIO *IO = &RSSAggr->IO;
+ rss_item *ri;
+ time_t now;
+
+ now = time(NULL);
+
+ if ((RSSAggr->next_poll != 0) && (now < RSSAggr->next_poll))
+ return 0;
+
+ ri = (rss_item*) malloc(sizeof(rss_item));
+ memset(ri, 0, sizeof(rss_item));
+ RSSAggr->Item = ri;
+
+ if (! InitcURLIOStruct(&RSSAggr->IO,
+ RSSAggr,
+ "Citadel RSS Client",
+ RSSAggregator_FinishHttp,
+ RSSAggregator_Terminate,
+ RSSAggregator_TerminateDB,
+ RSSAggregator_ShutdownAbort))