X-Git-Url: https://git.wpitchoune.net/gitweb/?p=prss.git;a=blobdiff_plain;f=src%2Fttrss.c;h=cc7a3699d5d91b9d5ddf3338675609b4c3a7448f;hp=92285198f055f8b63cf942d690afec4068ca0f3c;hb=cc1552eda67ca81b48eb611535719f4548c00c9c;hpb=c228345525be4912e6b5acec7525dc056313f315 diff --git a/src/ttrss.c b/src/ttrss.c index 9228519..cc7a369 100644 --- a/src/ttrss.c +++ b/src/ttrss.c @@ -18,370 +18,80 @@ */ #include +#include #include +#include #include #include "http.h" -#include "ttrss.h" +#include "io.h" +#include "ttrss_ws.h" #include "url.h" -static char *session_id; -static char *session_url; -static char *session_user; -static char *session_pwd; +static struct feed **data; +static char *cache_dir; -static int list_length(void **list) +static const char *get_cache_dir() { - int n; + char *home; - if (!list) - return 0; + if (!cache_dir) { + home = getenv("HOME"); - n = 0; - while (*list) { - n++; - list++; - } - - return n; -} - -static void **list_add(void **list, void *item) -{ - int n; - void **result; - - n = list_length(list); - - result = malloc((n + 1 + 1) * sizeof(void *)); - - if (list) - memcpy(result, list, n * sizeof(void *)); - - result[n] = item; - result[n + 1] = NULL; - - return result; -} - -struct headline ** -headlines_add(struct headline **list, struct headline *h) -{ - return (struct headline **)list_add((void **)list, (void *)h); -} - -struct headline *feed_get_headline(struct feed *feed, int id) -{ - struct headline **headlines; - - headlines = feed->headlines; - if (headlines) - while (*headlines) { - if ((*headlines)->id == id) - return *headlines; - headlines++; - } - - return NULL; -} - -void ws_request_add_att_str(json_object *rq, const char *k, const char *str) -{ - json_object_object_add(rq, k, json_object_new_string(str)); -} - -void ws_request_add_att_int(json_object *rq, const char *k, int v) -{ - json_object_object_add(rq, k, json_object_new_int(v)); -} - -struct json_object *ws_request_new(const char *op) -{ - struct json_object *rq; - - rq = json_object_new_object(); - - ws_request_add_att_str(rq, "op", op); - - if (session_id) - ws_request_add_att_str(rq, "sid", session_id); - - return rq; -} - -void ws_init(const char *url, const char *user, const char *pwd) -{ - char *tmp; - - if (session_id) - session_id = NULL; - - if (session_user) - free(session_user); - session_user = strdup(user); - - if (session_pwd) - free(session_pwd); - session_pwd = strdup(pwd); - - if (session_url) - free(session_url); - - tmp = url_normalize(url); - session_url = malloc(strlen(tmp) + strlen("/api/") + 1); - strcpy(session_url, tmp); - strcat(session_url, "/api/"); - free(tmp); -} - -struct json_object *ws_reply_get_content(struct json_object *rp) -{ - return json_object_object_get(rp, "content"); -} - -struct json_object *ws_execute(struct json_object *rq) -{ - struct json_object *rp, *content; - - rp = http_json_get(session_url, rq); - - if (rp) { - content = ws_reply_get_content(rp); - - if (content && !json_object_object_get(rp, "error")) { - json_object_get(content); - json_object_put(rp); - return content; - } - - json_object_put(rp); - } - - return NULL; -} - -int ws_get_api_version() -{ - struct json_object *rp, *rq; - int v; - - rq = ws_request_new("getApiLevel"); - - rp = ws_execute(rq); - - json_object_put(rq); - - if (rp) { - v = json_object_get_int(json_object_object_get(rp, "level")); - - json_object_put(rp); - } else { - v = 0; - } - - return v; -} - -char *ws_login() -{ - struct json_object *rq, *rp, *j; - char *str; - - rq = ws_request_new("login"); - ws_request_add_att_str(rq, "user", session_user); - ws_request_add_att_str(rq, "password", session_pwd); + if (!home) + return NULL; - rp = ws_execute(rq); - json_object_put(rq); - - if (rp) { - j = json_object_object_get(rp, "session_id"); - str = strdup(json_object_get_string(j)); - - json_object_put(rp); - } else { - str = NULL; - } - - return str; -} - -int ws_open_session() -{ - int version, result; - - if (session_id) - free(session_id); - - session_id = ws_login(); - - if (session_id) { - version = ws_get_api_version(); - printf("API version: %d\n", version); - - if (version > 0) { - result = 1; - } else { - free(session_id); - session_id = NULL; - result = 0; - } - } else { - result = 0; + cache_dir = path_append(home, ".prss/cache"); + mkdirs(cache_dir, 0777); } - return result; + return cache_dir; } -char *ws_get_article_content(int id) +static void file_set_content(const char *path, const char *content) { - struct json_object *rp, *rq, *content, *item; - char *str; - - rq = ws_request_new("getArticle"); - ws_request_add_att_int(rq, "article_id", id); - - rp = ws_execute(rq); - - json_object_put(rq); - - str = NULL; - - if (rp) { - item = json_object_array_get_idx(rp, 0); - - if (item) { - content = json_object_object_get(item, "content"); - str = strdup(json_object_get_string(content)); - } + FILE *fp; - json_object_put(rp); + fp = fopen(path, "w"); + if (fp) { + fwrite(content, 1, strlen(content), fp); + fclose(fp); } - - return str; } -int ws_update_headlines(struct feed *feed) +const char *ttrss_get_headline_content(struct headline *h) { - struct json_object *rp, *rq, *jheadline, *j; - int i, n, err, hid; - struct headline *h, **tmp; - - rq = ws_request_new("getHeadlines"); - ws_request_add_att_int(rq, "feed_id", feed->id); - - rp = ws_execute(rq); - - json_object_put(rq); - - if (rp) { - n = json_object_array_length(rp); - for (i = 0; i < n; i++) { - jheadline = json_object_array_get_idx(rp, i); - - j = json_object_object_get(jheadline, "id"); - hid = json_object_get_int(j); - h = feed_get_headline(feed, hid); - - if (!h) { - h = malloc(sizeof(struct headline)); - h->id = hid; - h->excerpt = NULL; - h->content = NULL; - h->title = NULL; - h->url = NULL; - - tmp = headlines_add(feed->headlines, h); - if (feed->headlines) - free(feed->headlines); - feed->headlines = tmp; - } - - if (!h->title) { - j = json_object_object_get(jheadline, "title"); - h->title = strdup(json_object_get_string(j)); - } - - if (!h->url) { - j = json_object_object_get(jheadline, "link"); - h->url = strdup(json_object_get_string(j)); - } - - j = json_object_object_get(jheadline, "unread"); - h->unread = json_object_get_boolean(j); + const char *cache_dir; + char *path, *content; + + cache_dir = get_cache_dir(); + if (cache_dir) { + path = g_strdup_printf("%s/%d", cache_dir, h->id); + + content = file_get_content(path); + + if (!content) { + content = ws_get_article_content(h->id); + file_set_content(path, content); } - err = 0; - } else { - err = 1; - } - json_object_put(rp); - return !err; -} + g_free(path); -const char *ttrss_get_headline_content(struct headline *h) -{ - if (!h->content) - h->content = ws_get_article_content(h->id); + return content; + } - return h->content; + return NULL; } struct feed **ttrss_get_feeds() { - struct json_object *rp, *rq, *content, *jfeed, *j; - int i, n; - struct feed **feeds, *feed, **tmp; - - printf("ttrss_get_feeds\n"); - - rq = ws_request_new("getFeeds"); - - rp = http_json_get(session_url, rq); - json_object_put(rq); - - content = json_object_object_get(rp, "content"); - - if (content) { - n = json_object_array_length(content); - - feeds = NULL; - for (i = 0; i < n; i++) { - jfeed = json_object_array_get_idx(content, i); - - feed = malloc(sizeof(struct feed)); - - j = json_object_object_get(jfeed, "title"); - feed->title = strdup(json_object_get_string(j)); - - j = json_object_object_get(jfeed, "feed_url"); - feed->url = strdup(json_object_get_string(j)); - - j = json_object_object_get(jfeed, "id"); - feed->id = json_object_get_int(j); + data = ws_update_feeds(data); - j = json_object_object_get(jfeed, "unread"); - feed->unread = json_object_get_int(j); - - feed->headlines = NULL; - - tmp = (struct feed **)list_add((void **)feeds, feed); - free(feeds); - feeds = tmp; - } - } else { - feeds = NULL; - } - - json_object_put(rp); - - printf("ttrss_get_feeds ended\n"); - - return feeds; + return data; } -struct headline **ttrss_get_headlines(struct feed *f) +struct headline **ttrss_feed_get_headlines(struct feed *f) { if (!f->headlines) ws_update_headlines(f); @@ -400,8 +110,25 @@ void ttrss_set_article_unread(int id, int unread) json_object_object_add(rq, "field", json_object_new_int(2)); json_object_object_add(rq, "mode", json_object_new_int(unread)); - rp = http_json_get(session_url, rq); + rp = ws_execute(rq); json_object_put(rq); json_object_put(rp); } + +void ttrss_set_config(const char *url, const char *user, const char *pwd) +{ + feeds_free(data); + data = NULL; + ws_init(url, user, pwd); +} + +struct feed *ttrss_get_feed(int id) +{ + return feeds_get_feed(data, id); +} + +struct headline *ttrss_get_headline(int id) +{ + return feeds_get_headline(data, id); +}