*/
#include <stdio.h>
+#include <stdlib.h>
#include <string.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <unistd.h>
+#include <glib.h>
#include <json/json.h>
#include "http.h"
-#include "ttrss.h"
+#include "io.h"
+#include "log.h"
+#include "ttrss_cache.h"
+#include "ttrss_wsasync.h"
#include "url.h"
-static char *session_id;
-static char *session_url;
-static char *session_user;
-static char *session_pwd;
-
-static int list_length(void **list)
+static struct feed **data;
+char *ttrss_get_headline_content(struct headline *h)
{
- int n;
+ char *content;
- if (!list)
- return 0;
+ content = cache_get(h);
- n = 0;
- while (*list) {
- n++;
- list++;
+ if (content) {
+ log_debug("ttrss_get_headline_content: cache hit");
+ } else {
+ log_debug("ttrss_get_headline_content: cache miss");
+ content = ws_get_article_content(h->id);
+ cache_put(h->id, content);
}
- return n;
+ return content;
}
-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 feed **ttrss_get_feeds()
{
- struct json_object *rq;
-
- rq = json_object_new_object();
-
- ws_request_add_att_str(rq, "op", op);
+ data = ws_update_feeds(data);
- if (session_id)
- ws_request_add_att_str(rq, "sid", session_id);
-
- return rq;
+ return data;
}
-void ws_init(const char *url, const char *user, const char *pwd)
+struct headline **ttrss_feed_get_headlines(struct feed *f)
{
- 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);
-}
+ if (!f->headlines)
+ ws_update_headlines(f);
-struct json_object *ws_reply_get_content(struct json_object *rp)
-{
- return json_object_object_get(rp, "content");
+ return f->headlines;
}
-struct json_object *ws_execute(struct json_object *rq)
+void ttrss_set_article_unread(int id, int unread)
{
- struct json_object *rp, *content;
-
- rp = http_json_get(session_url, rq);
+ log_debug("ttrss_set_article_unread(%d,%d)", id, unread);
- if (rp) {
- content = ws_reply_get_content(rp);
+ ws_async_set_article_unread(id, unread);
- if (content && !json_object_object_get(rp, "error")) {
- json_object_get(content);
- json_object_put(rp);
- return content;
- }
-
- json_object_put(rp);
- }
-
- return NULL;
+ log_debug("ttrss_set_article_unread(%d,%d)", id, unread);
}
-int ws_get_api_version()
+void ttrss_set_config(const char *url, const char *user, const char *pwd)
{
- 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;
+ feeds_free(data);
+ data = NULL;
+ ws_set_config(url, user, pwd);
}
-char *ws_login()
+struct feed *ttrss_get_feed(int id)
{
- 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);
-
- 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;
+ return feeds_get_feed(data, id);
}
-int ws_open_session()
+struct headline *ttrss_get_headline(int id)
{
- 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;
- }
-
- return result;
+ return feeds_get_headline(data, id);
}
-char *ws_get_article_content(int id)
+static void get_article_content_cbk(int id, 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);
+ printf("get_article_content_cbk %d\n", id);
- 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));
- }
-
- json_object_put(rp);
- }
-
- return str;
+ if (content)
+ cache_put(id, content);
}
-int ws_update_headlines(struct feed *feed)
+void ttrs_download_headline_content(struct feed **feeds)
{
- 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);
+ struct feed **fcur;
+ struct headline **hcur;
- rp = ws_execute(rq);
+ log_debug("ttrs_download_headline_content");
- json_object_put(rq);
+ for (fcur = feeds; *fcur; fcur++) {
+ hcur = ttrss_feed_get_headlines(*fcur);
- 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;
- }
+ log_debug("ttrs_download_headline_content(): %s",
+ (*fcur)->title);
- if (!h->title) {
- j = json_object_object_get(jheadline, "title");
- h->title = strdup(json_object_get_string(j));
+ while (hcur && *hcur) {
+ if (!cache_exists(*hcur)) {
+ ws_async_get_article_content
+ ((*hcur)->id, get_article_content_cbk);
}
-
- 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);
- }
- err = 0;
- } else {
- err = 1;
- }
-
- json_object_put(rp);
- return !err;
-}
-
-const char *ttrss_get_headline_content(struct headline *h)
-{
- if (!h->content)
- h->content = ws_get_article_content(h->id);
-
- return h->content;
-}
-
-
-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);
-
- 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;
+ hcur++;
}
- } else {
- feeds = NULL;
}
-
- json_object_put(rp);
-
- printf("ttrss_get_feeds ended\n");
-
- return feeds;
-}
-
-struct headline **ttrss_get_headlines(struct feed *f)
-{
- if (!f->headlines)
- ws_update_headlines(f);
-
- return f->headlines;
-}
-
-void ttrss_set_article_unread(int id, int unread)
-{
- struct json_object *rp, *rq;
-
- printf("ttrss_set_article_unread %d %d\n", id, unread);
-
- 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));
-
- rp = http_json_get(session_url, rq);
-
- json_object_put(rq);
- json_object_put(rp);
}
projects / prss.git / blobdiff