X-Git-Url: https://git.wpitchoune.net/gitweb/?p=prss.git;a=blobdiff_plain;f=src%2Fttrss.c;h=164dcdd4818a91e5554b3f33546a9cf45f6e7086;hp=78884c1e37ba807391f6e6abc0e7ae8d376a4cd8;hb=a9e8584fe0ea41c0c680b6e8c64d547d0a3d4d99;hpb=a7e89c999775c195f8b7759f4c283fcedb041a9e diff --git a/src/ttrss.c b/src/ttrss.c index 78884c1..164dcdd 100644 --- a/src/ttrss.c +++ b/src/ttrss.c @@ -18,169 +18,121 @@ */ #include +#include #include +#include #include -#include "phttp.h" -#include "ttrss.h" +#include "http.h" +#include "io.h" +#include "ttrss_ws.h" #include "url.h" -static char *session_id; -static char *session_url; +static struct feed **data; +static char *cache_dir; -static struct json_object *create_op(const char *op) +static const char *get_cache_dir() { - struct json_object *j; + char *home; - j = json_object_new_object(); - json_object_object_add(j, "op", json_object_new_string(op)); + if (!cache_dir) { + home = getenv("HOME"); - if (session_id && strcmp(op, "login")) - json_object_object_add(j, - "sid", - json_object_new_string(session_id)); + if (!home) + return NULL; - return j; -} - -void ttrss_login(const char *url, const char *user, const char *password) -{ - struct json_object *content, *rp, *error, *sid, *rq; - char *tmp; - - 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); - - - rq = create_op("login"); - json_object_object_add(rq, "user", json_object_new_string(user)); - json_object_object_add(rq, - "password", - json_object_new_string(password)); - - rp = post_json_object(session_url, rq); - json_object_put(rq); - - content = json_object_object_get(rp, "content"); - if (!content) { - fprintf(stderr, "Login failed: no content"); - return ; + cache_dir = path_append(home, ".prss/cache"); + mkdirs(cache_dir, 0777); } - error = json_object_object_get(content, "error"); - if (error) { - fprintf(stderr, "Login failed"); - return ; - } + return cache_dir; +} - sid = json_object_object_get(content, "session_id"); +static void file_set_content(const char *path, const char *content) +{ + FILE *fp; - if (session_id) { - free(session_id); - session_id = NULL; + fp = fopen(path, "w"); + if (fp) { + fwrite(content, 1, strlen(content), fp); + fclose(fp); } - - session_id = strdup(json_object_get_string(sid)); - - printf("Session id: %s\n", session_id); - - json_object_put(rp); } -struct feed **ttrss_get_feeds() +const char *ttrss_get_headline_content(struct headline *h) { - struct json_object *rp, *rq, *content, *jfeed, *j; - int i, n; - struct feed **feeds, *feed; - - rq = create_op("getFeeds"); - - rp = post_json_object(session_url, rq); - json_object_put(rq); - - content = json_object_object_get(rp, "content"); - - if (content) { - n = json_object_array_length(content); + const char *cache_dir; + char *path, *content; - feeds = malloc((n+1) * sizeof(struct feed *)); - for (i = 0; i < n; i++) { - jfeed = json_object_array_get_idx(content, i); + if (!h->content) { + cache_dir = get_cache_dir(); + if (cache_dir) { + path = g_strdup_printf("%s/%d", cache_dir, h->id); - feed = malloc(sizeof(struct feed)); + content = file_get_content(path); - j = json_object_object_get(jfeed, "title"); - feed->title = strdup(json_object_get_string(j)); + if (content) { + h->content = content; + } else { + h->content = ws_get_article_content(h->id); - j = json_object_object_get(jfeed, "feed_url"); - feed->url = strdup(json_object_get_string(j)); + if (h->content) + file_set_content(path, h->content); + } - j = json_object_object_get(jfeed, "id"); - feed->id = json_object_get_int(j); - - feed->headlines = ttrss_get_headlines(feed->id); - - feeds[i] = feed; + g_free(path); } - feeds[n] = NULL; - } else { - feeds = NULL; } - json_object_put(rp); - - return feeds; + return h->content; } -struct headline **ttrss_get_headlines(int feed_id) +struct feed **ttrss_get_feeds() { - struct json_object *rp, *rq, *content, *jheadline, *j; - int i, n; - struct headline **headlines, *h; - - rq = create_op("getHeadlines"); - json_object_object_add(rq, "feed_id", json_object_new_int(feed_id)); - json_object_object_add(rq, "show_excerpt", json_object_new_boolean(1)); - json_object_object_add(rq, "show_content", json_object_new_boolean(1)); + data = ws_update_feeds(data); - rp = post_json_object(session_url, rq); + return data; +} - json_object_put(rq); +struct headline **ttrss_feed_get_headlines(struct feed *f) +{ + if (!f->headlines) + ws_update_headlines(f); - content = json_object_object_get(rp, "content"); + return f->headlines; +} - if (content) { - n = json_object_array_length(content); - headlines = malloc((n+1)*sizeof(struct headline *)); - for (i = 0; i < n; i++) { - jheadline = json_object_array_get_idx(content, i); +void ttrss_set_article_unread(int id, int unread) +{ + struct json_object *rp, *rq; - h = malloc(sizeof(struct headline)); + printf("ttrss_set_article_unread %d %d\n", id, unread); - j = json_object_object_get(jheadline, "title"); - h->title = strdup(json_object_get_string(j)); + rq = ws_request_new("updateArticle"); + json_object_object_add(rq, "article_ids", json_object_new_int(id)); + json_object_object_add(rq, "field", json_object_new_int(2)); + json_object_object_add(rq, "mode", json_object_new_int(unread)); - j = json_object_object_get(jheadline, "excerpt"); - h->excerpt = strdup(json_object_get_string(j)); + rp = ws_execute(rq); - j = json_object_object_get(jheadline, "content"); - h->content = strdup(json_object_get_string(j)); + json_object_put(rq); + json_object_put(rp); +} - headlines[i] = h; - } - headlines[n] = NULL; - } else { - headlines = NULL; - } +void ttrss_set_config(const char *url, const char *user, const char *pwd) +{ + feeds_free(data); + data = NULL; + ws_init(url, user, pwd); +} - json_object_put(rp); +struct feed *ttrss_get_feed(int id) +{ + return feeds_get_feed(data, id); +} - return headlines; +struct headline *ttrss_get_headline(int id) +{ + return feeds_get_headline(data, id); }