Revert "Compilation fix for weather stuff."
[monky] / src / weather.c
index 7c3380c..671d526 100644 (file)
@@ -1,4 +1,5 @@
-/*
+/* -*- mode: c; c-basic-offset: 4; tab-width: 4; indent-tabs-mode: t -*-
+ *
  * Conky, a system monitor, based on torsmo
  *
  * Please see COPYING for details
  * You should have received a copy of the GNU General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  *
- */
-
-/*
- * TODO: Add weather forecast info from weather.com
+ * vim: ts=4 sw=4 noet ai cindent syntax=c
  *
  */
 
 #include "logging.h"
 #include "weather.h"
 #include "temphelper.h"
+#include "ccurl_thread.h"
 #include <time.h>
 #include <ctype.h>
 #ifdef MATH
 #include <math.h>
 #endif /* MATH */
-#include <curl/curl.h>
-#include <curl/types.h>
-#include <curl/easy.h>
 #ifdef XOAP
 #include <libxml/parser.h>
+#include <libxml/xpath.h>
+
+/* Xpath expressions for XOAP xml parsing */
+#define NUM_XPATH_EXPRESSIONS_CC 8
+const char *xpath_expression_cc[NUM_XPATH_EXPRESSIONS_CC] = {
+       "/weather/cc/lsup", "/weather/cc/tmp", "/weather/cc/t",
+       "/weather/cc/bar/r", "/weather/cc/wind/s", "/weather/cc/wind/d",
+       "/weather/cc/hmid", "/weather/cc/icon"
+};
+
+#define NUM_XPATH_EXPRESSIONS_DF 8
+const char *xpath_expression_df[NUM_XPATH_EXPRESSIONS_DF] = {
+       "/weather/dayf/day[*]/hi", "/weather/dayf/day[*]/low",
+       "/weather/dayf/day[*]/part[1]/icon", "/weather/dayf/day[*]/part[1]/t",
+       "/weather/dayf/day[*]/part[1]/wind/s","/weather/dayf/day[*]/part[1]/wind/d",
+       "/weather/dayf/day[*]/part[1]/ppcp", "/weather/dayf/day[*]/part[1]/hmid"
+};
 #endif /* XOAP */
 
 /* Possible sky conditions */
@@ -63,57 +76,17 @@ const char *WC_CODES[NUM_WC_CODES] = {
        "FC", "PO", "SQ", "SS", "DS"
 };
 
-typedef struct location_ {
-       char *uri;
-       int last_update;
-       PWEATHER data;
-       timed_thread *p_timed_thread;
-       struct location_ *next;
-} location;
-
-static location *locations_head = 0;
-
-location *find_location(char *uri)
-{
-       location *tail = locations_head;
-       location *new = 0;
-       while (tail) {
-               if (tail->uri &&
-                               strcmp(tail->uri, uri) == EQUAL) {
-                       return tail;
-               }
-               tail = tail->next;
-       }
-       if (!tail) { // new location!!!!!!!
-               new = malloc(sizeof(location));
-               memset(new, 0, sizeof(location));
-               new->uri = strndup(uri, text_buffer_size);
-               tail = locations_head;
-               while (tail && tail->next) {
-                       tail = tail->next;
-               }
-               if (!tail) {
-                       // omg the first one!!!!!!!
-                       locations_head = new;
-               } else {
-                       tail->next = new;
-               }
-       }
-       return new;
-}
+static ccurl_location_t *locations_head_cc = 0;
+#ifdef XOAP
+static ccurl_location_t *locations_head_df = 0;
+#endif
 
-void free_weather_info(void)
+void weather_free_info(void)
 {
-       location *tail = locations_head;
-       location *last = 0;
-
-       while (tail) {
-               if (tail->uri) free(tail->uri);
-               last = tail;
-               tail = tail->next;
-               free(last);
-       }
-       locations_head = 0;
+       ccurl_free_locations(&locations_head_cc);
+#ifdef XOAP
+       ccurl_free_locations(&locations_head_df);
+#endif
 }
 
 int rel_humidity(int dew_point, int air) {
@@ -129,73 +102,140 @@ int rel_humidity(int dew_point, int air) {
 }
 
 #ifdef XOAP
-//TODO: Lets get rid of the recursion
-static void parse_cc(PWEATHER *res, xmlNodePtr cc)
+static void parse_df(PWEATHER_FORECAST *res, xmlXPathContextPtr xpathCtx)
 {
-
-       xmlNodePtr cur = NULL;
-
-       for (cur = cc; cur; cur = cur->next) {
-               if (cur->type == XML_ELEMENT_NODE) {
-                       if (!xmlStrcmp(cur->name, (const xmlChar *) "lsup")) {
-                               strncpy(res->lastupd, (char *)cur->children->content, 31);
-                       } else if       (!xmlStrcmp(cur->name, (const xmlChar *) "tmp")) {
-                               res->temp = atoi((char *)cur->children->content);
-                       } else if (!xmlStrcmp(cur->name, (const xmlChar *) "t")) {
-                               if(res->xoap_t[0] == '\0') {
-                                       strncpy(res->xoap_t, (char *)cur->children->content, 31);
-                               }
-                       } else if (!xmlStrcmp(cur->name, (const xmlChar *) "r")) {
-                               res->bar = atoi((char *)cur->children->content);
-                       } else if (!xmlStrcmp(cur->name, (const xmlChar *) "s")) {
-                               res->wind_s = atoi((char *)cur->children->content);
-                       } else if (!xmlStrcmp(cur->name, (const xmlChar *) "d")) {
-                               if (isdigit((char)cur->children->content[0])) {
-                                       res->wind_d = atoi((char *)cur->children->content);
+       int i, j, k;
+       char *content;
+       xmlXPathObjectPtr xpathObj;
+
+       for (i = 0; i < NUM_XPATH_EXPRESSIONS_DF; i++) {
+               xpathObj = xmlXPathEvalExpression((xmlChar *)xpath_expression_df[i], xpathCtx);
+               if (xpathObj != NULL) {
+                       xmlNodeSetPtr nodes = xpathObj->nodesetval;
+                       k = 0;
+                       for (j = 0; j < nodes->nodeNr; ++j) {
+                               if (nodes->nodeTab[j]->type == XML_ELEMENT_NODE) {
+                                       content = (char *)xmlNodeGetContent(nodes->nodeTab[k]);
+                                       switch(i) {
+                                       case 0:
+                                               res->hi[k] = atoi(content);
+                                               break;
+                                       case 1:
+                                               res->low[k] = atoi(content);
+                                               break;
+                                       case 2:
+                                               strncpy(res->icon[k], content, 2);
+                                       case 3:
+                                               strncpy(res->xoap_t[k], content, 31);
+                                               break;
+                                       case 4:
+                                               res->wind_s[k] = atoi(content);
+                                               break;
+                                       case 5:
+                                               res->wind_d[k] = atoi(content);
+                                               break;
+                                       case 6:
+                                               res->ppcp[k] = atoi(content);
+                                               break;
+                                       case 7:
+                                               res->hmid[k] = atoi(content);
+                                       }
+                                       xmlFree(content);
+                                       if (++k == FORECAST_DAYS) break;
                                }
-                       } else if (!xmlStrcmp(cur->name, (const xmlChar *) "hmid")) {
-                               res->hmid = atoi((char *)cur->children->content);
                        }
+                       xmlXPathFreeObject(xpathObj);
                }
-               parse_cc(res, cur->children);
        }
        return;
 }
 
-static void parse_weather_xml(PWEATHER *res, const char *data)
+static void parse_weather_forecast_xml(PWEATHER_FORECAST *res, const char *data)
 {
        xmlDocPtr doc;
-       xmlNodePtr cur;
+       xmlXPathContextPtr xpathCtx;
 
        if (!(doc = xmlReadMemory(data, strlen(data), "", NULL, 0))) {
-               ERR("weather: can't read xml data");
+               NORM_ERR("weather_forecast: can't read xml data");
                return;
        }
 
-       cur = xmlDocGetRootElement(doc);
-
-       while(cur) {
-               if (cur->type == XML_ELEMENT_NODE) {
-                       if (!xmlStrcmp(cur->name, (const xmlChar *) "weather")) {
-                               cur = cur->children;
-                               while (cur != NULL) {
-                                       if (cur->type == XML_ELEMENT_NODE) {
-                                               if (!xmlStrcmp(cur->name, (const xmlChar *) "cc")) {
-                                                       parse_cc(res, cur->children);
-                                                       xmlFreeDoc(doc);
-                                                       return;
-                                               }
-                                       }
-                                       cur = cur->next;
-                               }
+       xpathCtx = xmlXPathNewContext(doc);
+       if(xpathCtx == NULL) {
+               NORM_ERR("weather_forecast: unable to create new XPath context");
+               xmlFreeDoc(doc);
+               return;
+       }
+
+       parse_df(res, xpathCtx);
+       xmlXPathFreeContext(xpathCtx);
+       xmlFreeDoc(doc);
+       return;
+}
+
+static void parse_cc(PWEATHER *res, xmlXPathContextPtr xpathCtx)
+{
+       int i;
+       char *content;
+       xmlXPathObjectPtr xpathObj;
+
+       for (i = 0; i < NUM_XPATH_EXPRESSIONS_CC; i++) {
+               xpathObj = xmlXPathEvalExpression((xmlChar *)xpath_expression_cc[i], xpathCtx);
+               if ((xpathObj != NULL) && (xpathObj->nodesetval->nodeTab[0]->type == XML_ELEMENT_NODE)) {
+                       content = (char *)xmlNodeGetContent(xpathObj->nodesetval->nodeTab[0]);
+                       switch(i) {
+                       case 0:
+                               strncpy(res->lastupd, content, 31);
+                               break;
+                       case 1:
+                               res->temp = atoi(content);
+                               break;
+                       case 2:
+                               strncpy(res->xoap_t, content, 31);
+                               break;
+                       case 3:
+                               res->bar = atoi(content);
+                               break;
+                       case 4:
+                               res->wind_s = atoi(content);
+                               break;
+                       case 5:
+                               res->wind_d = atoi(content);
+                           break;
+                       case 6:
+                               res->hmid = atoi(content);
+                               break;
+                       case 7:
+                               strncpy(res->icon, content, 2);
                        }
+                       xmlFree(content);
                }
-               cur = cur->next;
+               xmlXPathFreeObject(xpathObj);
+       }
+       return;
+}
+
+static void parse_weather_xml(PWEATHER *res, const char *data)
+{
+       xmlDocPtr doc;
+       xmlXPathContextPtr xpathCtx;
+
+       if (!(doc = xmlReadMemory(data, strlen(data), "", NULL, 0))) {
+               NORM_ERR("weather: can't read xml data");
+               return;
+       }
+
+       xpathCtx = xmlXPathNewContext(doc);
+       if(xpathCtx == NULL) {
+               NORM_ERR("weather: unable to create new XPath context");
+               xmlFreeDoc(doc);
+               return;
        }
 
-       ERR("weather: incorrect xml data");
+       parse_cc(res, xpathCtx);
+       xmlXPathFreeContext(xpathCtx);
        xmlFreeDoc(doc);
-       return ;
+       return;
 }
 #endif /* XOAP */
 
@@ -489,9 +529,24 @@ static inline void parse_token(PWEATHER *res, char *token) {
        }
 }
 
-static void parse_weather(PWEATHER *res, const char *data)
+#ifdef XOAP
+void parse_weather_forecast(void *result, const char *data)
+{
+       PWEATHER_FORECAST *res = (PWEATHER_FORECAST*)result;
+       /* Reset results */
+       memset(res, 0, sizeof(PWEATHER_FORECAST));
+
+       //Check if it is an xml file
+       if ( strncmp(data, "<?xml ", 6) == 0 ) {
+               parse_weather_forecast_xml(res, data);
+       }
+}
+#endif /* XOAP */
+
+void parse_weather(void *result, const char *data)
 {
-       //Reset results
+       PWEATHER *res = (PWEATHER*)result;
+       /* Reset results */
        memset(res, 0, sizeof(PWEATHER));
 
 #ifdef XOAP
@@ -532,60 +587,85 @@ static void parse_weather(PWEATHER *res, const char *data)
        }
 }
 
-void fetch_weather_info(location *curloc)
-{
-       CURL *curl = NULL;
-       CURLcode res;
-
-       // curl temps
-       struct MemoryStruct chunk;
-
-       chunk.memory = NULL;
-       chunk.size = 0;
-
-       curl = curl_easy_init();
-       if (curl) {
-               curl_easy_setopt(curl, CURLOPT_URL, curloc->uri);
-               curl_easy_setopt(curl, CURLOPT_NOPROGRESS, 1);
-               curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, WriteMemoryCallback);
-               curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void *) &chunk);
-               curl_easy_setopt(curl, CURLOPT_USERAGENT, "conky-weather/1.0");
-
-               res = curl_easy_perform(curl);
-               if (chunk.size) {
-                       timed_thread_lock(curloc->p_timed_thread);
-                       parse_weather(&curloc->data, chunk.memory);
-                       timed_thread_unlock(curloc->p_timed_thread);
-                       free(chunk.memory);
-               } else {
-                       ERR("weather: no data from server");
-               }
-
-               curl_easy_cleanup(curl);
-       }
-
-       return;
+void wind_deg_to_dir(char *p, int p_max_size, int wind_deg) {
+       if ((wind_deg >= 349) || (wind_deg < 12)) {
+               strncpy(p, "N", p_max_size);
+       } else if (wind_deg < 33) {
+               strncpy(p, "NNE", p_max_size);
+       } else if (wind_deg < 57) {
+               strncpy(p, "NE", p_max_size);
+       } else if (wind_deg < 79) {
+               strncpy(p, "ENE", p_max_size);
+       } else if (wind_deg < 102) {
+               strncpy(p, "E", p_max_size);
+       } else if (wind_deg < 124) {
+               strncpy(p, "ESE", p_max_size);
+       } else if (wind_deg < 147) {
+               strncpy(p, "SE", p_max_size);
+       } else if (wind_deg < 169) {
+               strncpy(p, "SSE", p_max_size);
+       } else if (wind_deg < 192) {
+               strncpy(p, "S", p_max_size);
+       } else if (wind_deg < 214) {
+               strncpy(p, "SSW", p_max_size);
+       } else if (wind_deg < 237) {
+               strncpy(p, "SW", p_max_size);
+       } else if (wind_deg < 259) {
+               strncpy(p, "WSW", p_max_size);
+       } else if (wind_deg < 282) {
+                       strncpy(p, "W", p_max_size);
+       } else if (wind_deg < 304) {
+               strncpy(p, "WNW", p_max_size);
+       } else if (wind_deg < 327) {
+               strncpy(p, "NW", p_max_size);
+       } else if (wind_deg < 349) {
+               strncpy(p, "NNW", p_max_size);
+       };
 }
 
-void *weather_thread(void *) __attribute__((noreturn));
-
-void init_thread(location *curloc, int interval)
+#ifdef XOAP
+void weather_forecast_process_info(char *p, int p_max_size, char *uri, unsigned int day, char *data_type, int interval)
 {
-       curloc->p_timed_thread =
-               timed_thread_create(&weather_thread,
-                               (void *)curloc, interval * 1000000);
+       PWEATHER_FORECAST *data;
+
+       ccurl_location_t *curloc = ccurl_find_location(&locations_head_df, uri);
        if (!curloc->p_timed_thread) {
-               ERR("weather: error creating timed thread");
+               curloc->result = malloc(sizeof(PWEATHER_FORECAST));
+               memset(curloc->result, 0, sizeof(PWEATHER_FORECAST));
+               curloc->process_function = &parse_weather_forecast;
+               ccurl_init_thread(curloc, interval);
+               if (!curloc->p_timed_thread) {
+                       NORM_ERR("error setting up weather_forecast thread");
+               }
        }
-       timed_thread_register(curloc->p_timed_thread,
-                       &curloc->p_timed_thread);
-       if (timed_thread_run(curloc->p_timed_thread)) {
-               ERR("weather: error running timed thread");
+
+       timed_thread_lock(curloc->p_timed_thread);
+       data = (PWEATHER_FORECAST*)curloc->result;
+       if (strcmp(data_type, "hi") == EQUAL) {
+               temp_print(p, p_max_size, data->hi[day], TEMP_CELSIUS);
+       } else if (strcmp(data_type, "low") == EQUAL) {
+               temp_print(p, p_max_size, data->low[day], TEMP_CELSIUS);
+       } else if (strcmp(data_type, "icon") == EQUAL) {
+               strncpy(p, data->icon[day], p_max_size);
+       } else if (strcmp(data_type, "forecast") == EQUAL) {
+               strncpy(p, data->xoap_t[day], p_max_size);
+       } else if (strcmp(data_type, "wind_speed") == EQUAL) {
+               snprintf(p, p_max_size, "%d", data->wind_s[day]);
+       } else if (strcmp(data_type, "wind_dir") == EQUAL) {
+               wind_deg_to_dir(p, p_max_size, data->wind_d[day]);
+       } else if (strcmp(data_type, "wind_dir_DEG") == EQUAL) {
+               snprintf(p, p_max_size, "%d", data->wind_d[day]);
+       } else if (strcmp(data_type, "humidity") == EQUAL) {
+               snprintf(p, p_max_size, "%d", data->hmid[day]);
+       } else if (strcmp(data_type, "precipitation") == EQUAL) {
+               snprintf(p, p_max_size, "%d", data->ppcp[day]);
        }
-}
 
+       timed_thread_unlock(curloc->p_timed_thread);
+}
+#endif /* XOAP */
 
-void process_weather_info(char *p, int p_max_size, char *uri, char *data_type, int interval)
+void weather_process_info(char *p, int p_max_size, char *uri, char *data_type, int interval)
 {
        static const char *wc[] = {
                "", "drizzle", "rain", "hail", "soft hail",
@@ -593,96 +673,143 @@ void process_weather_info(char *p, int p_max_size, char *uri, char *data_type, i
                "mist", "dust", "sand", "funnel cloud tornado",
                "dust/sand", "squall", "sand storm", "dust storm"
        };
+       PWEATHER *data;
 
-       location *curloc = find_location(uri);
-       if (!curloc->p_timed_thread) init_thread(curloc, interval);
+       ccurl_location_t *curloc = ccurl_find_location(&locations_head_cc, uri);
+       if (!curloc->p_timed_thread) {
+               curloc->result = malloc(sizeof(PWEATHER));
+               memset(curloc->result, 0, sizeof(PWEATHER));
+               curloc->process_function = &parse_weather;
+               ccurl_init_thread(curloc, interval);
+               if (!curloc->p_timed_thread) {
+                       NORM_ERR("error setting up weather thread");
+               }
+       }
 
        timed_thread_lock(curloc->p_timed_thread);
+       data = (PWEATHER*)curloc->result;
        if (strcmp(data_type, "last_update") == EQUAL) {
-               strncpy(p, curloc->data.lastupd, p_max_size);
+               strncpy(p, data->lastupd, p_max_size);
        } else if (strcmp(data_type, "temperature") == EQUAL) {
-               temp_print(p, p_max_size, curloc->data.temp, TEMP_CELSIUS);
+               temp_print(p, p_max_size, data->temp, TEMP_CELSIUS);
        } else if (strcmp(data_type, "cloud_cover") == EQUAL) {
 #ifdef XOAP
-               if (curloc->data.xoap_t[0] != '\0') {
-                       strncpy(p, curloc->data.xoap_t, p_max_size);
+               if (data->xoap_t[0] != '\0') {
+                       strncpy(p, data->xoap_t, p_max_size);
                } else
 #endif /* XOAP */
-                       if (curloc->data.cc == 0) {
+                       if (data->cc == 0) {
                                strncpy(p, "", p_max_size);
-                       } else if (curloc->data.cc < 3) {
+                       } else if (data->cc < 3) {
                                strncpy(p, "clear", p_max_size);
-                       } else if (curloc->data.cc < 5) {
+                       } else if (data->cc < 5) {
                                strncpy(p, "partly cloudy", p_max_size);
-                       } else if (curloc->data.cc == 5) {
+                       } else if (data->cc == 5) {
                                strncpy(p, "cloudy", p_max_size);
-                       } else if (curloc->data.cc == 6) {
+                       } else if (data->cc == 6) {
                                strncpy(p, "overcast", p_max_size);
-                       } else if (curloc->data.cc == 7) {
+                       } else if (data->cc == 7) {
                                strncpy(p, "towering cumulus", p_max_size);
                        } else  {
                                strncpy(p, "cumulonimbus", p_max_size);
                        }
+#ifdef XOAP
+       } else if (strcmp(data_type, "icon") == EQUAL) {
+               strncpy(p, data->icon, p_max_size);
+#endif /* XOAP */
        } else if (strcmp(data_type, "pressure") == EQUAL) {
-               snprintf(p, p_max_size, "%d", curloc->data.bar);
+               snprintf(p, p_max_size, "%d", data->bar);
        } else if (strcmp(data_type, "wind_speed") == EQUAL) {
-               snprintf(p, p_max_size, "%d", curloc->data.wind_s);
+               snprintf(p, p_max_size, "%d", data->wind_s);
        } else if (strcmp(data_type, "wind_dir") == EQUAL) {
-               if ((curloc->data.wind_d >= 349) || (curloc->data.wind_d < 12)) {
-                       strncpy(p, "N", p_max_size);
-               } else if (curloc->data.wind_d < 33) {
-                       strncpy(p, "NNE", p_max_size);
-               } else if (curloc->data.wind_d < 57) {
-                       strncpy(p, "NE", p_max_size);
-               } else if (curloc->data.wind_d < 79) {
-                       strncpy(p, "ENE", p_max_size);
-               } else if (curloc->data.wind_d < 102) {
-                       strncpy(p, "E", p_max_size);
-               } else if (curloc->data.wind_d < 124) {
-                       strncpy(p, "ESE", p_max_size);
-               } else if (curloc->data.wind_d < 147) {
-                       strncpy(p, "SE", p_max_size);
-               } else if (curloc->data.wind_d < 169) {
-                       strncpy(p, "SSE", p_max_size);
-               } else if (curloc->data.wind_d < 192) {
-                       strncpy(p, "S", p_max_size);
-               } else if (curloc->data.wind_d < 214) {
-                       strncpy(p, "SSW", p_max_size);
-               } else if (curloc->data.wind_d < 237) {
-                       strncpy(p, "SW", p_max_size);
-               } else if (curloc->data.wind_d < 259) {
-                       strncpy(p, "WSW", p_max_size);
-               } else if (curloc->data.wind_d < 282) {
-                       strncpy(p, "W", p_max_size);
-               } else if (curloc->data.wind_d < 304) {
-                       strncpy(p, "WNW", p_max_size);
-               } else if (curloc->data.wind_d < 327) {
-                       strncpy(p, "NW", p_max_size);
-               } else if (curloc->data.wind_d < 349) {
-                       strncpy(p, "NNW", p_max_size);
-               };
+               wind_deg_to_dir(p, p_max_size, data->wind_d);
        } else if (strcmp(data_type, "wind_dir_DEG") == EQUAL) {
-               snprintf(p, p_max_size, "%d", curloc->data.wind_d);
+               snprintf(p, p_max_size, "%d", data->wind_d);
 
        } else if (strcmp(data_type, "humidity") == EQUAL) {
-               snprintf(p, p_max_size, "%d", curloc->data.hmid);
+               snprintf(p, p_max_size, "%d", data->hmid);
        } else if (strcmp(data_type, "weather") == EQUAL) {
-               strncpy(p, wc[curloc->data.wc], p_max_size);
+               strncpy(p, wc[data->wc], p_max_size);
        }
 
        timed_thread_unlock(curloc->p_timed_thread);
 }
 
-void *weather_thread(void *arg)
-{
-       location *curloc = (location*)arg;
+#ifdef XOAP
 
-       while (1) {
-               fetch_weather_info(curloc);
-               if (timed_thread_test(curloc->p_timed_thread, 0)) {
-                       timed_thread_exit(curloc->p_timed_thread);
+/* xoap suffix for weather from weather.com */
+static char *xoap_cc = NULL;
+static char *xoap_df = NULL;
+
+/*
+ * TODO: make the xoap keys file readable from the config file
+ *       make the keys directly readable from the config file
+ *       make the xoap keys file giveable as a command line option
+ */
+void load_xoap_keys(void)
+{
+       FILE *fp;
+       char *par  = (char *) malloc(11 * sizeof(char));
+       char *key  = (char *) malloc(17 * sizeof(char));
+       char *xoap = (char *) malloc(64 * sizeof(char));
+
+       to_real_path(xoap, XOAP_FILE);
+       fp = fopen(xoap, "r");
+       if (fp != NULL) {
+               if (fscanf(fp, "%10s %16s", par, key) == 2) {
+                       xoap_cc = (char *) malloc(128 * sizeof(char));
+                       xoap_df = (char *) malloc(128 * sizeof(char));
+
+                       strcpy(xoap_cc, "?cc=*&link=xoap&prod=xoap&par=");
+                       strcat(xoap_cc, par);
+                       strcat(xoap_cc, "&key=");
+                       strcat(xoap_cc, key);
+                       strcat(xoap_cc, "&unit=m");
+
+                       /* TODO: Use FORECAST_DAYS instead of 5 */
+                       strcpy(xoap_df, "?dayf=5&link=xoap&prod=xoap&par=");
+                       strcat(xoap_df, par);
+                       strcat(xoap_df, "&key=");
+                       strcat(xoap_df, key);
+                       strcat(xoap_df, "&unit=m");
                }
+               fclose(fp);
        }
-       /* never reached */
+       free(par);
+       free(key);
+       free(xoap);
 }
+#endif /* XOAP */
+
+int process_weather_uri(char *uri, char *locID, int dayf)
+{
+       /* locID MUST BE upper-case */
+       char *tmp_p = locID;
+       while (*tmp_p) {
+               *tmp_p = toupper(*tmp_p);
+               tmp_p++;
+       }
 
+       /* Construct complete uri */
+#ifdef XOAP
+       if (strstr(uri, "xoap.weather.com")) {
+               if ((dayf == 0) && (xoap_cc != NULL)) {
+                       strcat(uri, locID);
+                       strcat(uri, xoap_cc);
+               } else if ((dayf == 1) && (xoap_df != NULL)) {
+                       strcat(uri, locID);
+                       strcat(uri, xoap_df);
+               } else {
+                       free(uri);
+                       uri = NULL;
+               }
+       } else 
+#endif /* XOAP */
+       if (strstr(uri, "weather.noaa.gov")) {
+               strcat(uri, locID);
+               strcat(uri, ".TXT");
+       } else  if (!strstr(uri, "localhost") && !strstr(uri, "127.0.0.1")) {
+               return -1;
+       }
+       return 0;
+}