*/
#include <stdio.h>
+#include <stdlib.h>
#include <string.h>
+#include <glib.h>
#include <json/json.h>
-#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;
+ cache_dir = path_append(home, ".prss/cache");
+ mkdirs(cache_dir, 0777);
+ }
+
+ return cache_dir;
}
-void ttrss_login(const char *url, const char *user, const char *password)
+static void file_set_content(const char *path, const char *content)
{
- 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 ;
- }
+ FILE *fp;
- error = json_object_object_get(content, "error");
- if (error) {
- fprintf(stderr, "Login failed");
- return ;
+ fp = fopen(path, "w");
+ if (fp) {
+ fwrite(content, 1, strlen(content), fp);
+ fclose(fp);
}
+}
- sid = json_object_object_get(content, "session_id");
-
- if (session_id) {
- free(session_id);
- session_id = NULL;
- }
+char *ttrss_get_headline_content(struct headline *h)
+{
+ 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);
+ }
- session_id = strdup(json_object_get_string(sid));
+ g_free(path);
- printf("Session id: %s\n", session_id);
+ return content;
+ }
- json_object_put(rp);
+ return NULL;
}
struct feed **ttrss_get_feeds()
{
- struct json_object *rp, *rq, *content, *jfeed, *j;
- int i, n;
- struct feed **feeds, *feed;
-
- printf("ttrss_get_feeds\n");
-
- 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);
-
- feeds = malloc((n+1) * sizeof(struct feed *));
- 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 = ttrss_get_headlines(feed->id);
-
- feeds[i] = feed;
- }
- feeds[n] = NULL;
- } else {
- feeds = NULL;
- }
-
- json_object_put(rp);
+ return data;
+}
- printf("ttrss_get_feeds ended\n");
+struct headline **ttrss_feed_get_headlines(struct feed *f)
+{
+ if (!f->headlines)
+ ws_update_headlines(f);
- return feeds;
+ return f->headlines;
}
-struct headline **ttrss_get_headlines(int feed_id)
+void ttrss_set_article_unread(int id, int unread)
{
- struct json_object *rp, *rq, *content, *jheadline, *j;
- int i, n;
- struct headline **headlines, *h;
+ struct json_object *rp, *rq;
- printf("ttrss_get_headlines %d\n", feed_id);
+ printf("ttrss_set_article_unread %d %d\n", id, unread);
- 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));
+ 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 = post_json_object(session_url, rq);
+ rp = ws_execute(rq);
json_object_put(rq);
-
- content = json_object_object_get(rp, "content");
-
- 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);
-
- h = malloc(sizeof(struct headline));
-
- j = json_object_object_get(jheadline, "title");
- h->title = strdup(json_object_get_string(j));
-
- j = json_object_object_get(jheadline, "excerpt");
- h->excerpt = strdup(json_object_get_string(j));
-
- j = json_object_object_get(jheadline, "content");
- h->content = strdup(json_object_get_string(j));
-
- j = json_object_object_get(jheadline, "unread");
- h->unread = json_object_get_boolean(j);
-
- headlines[i] = h;
- }
- headlines[n] = NULL;
- } else {
- headlines = NULL;
- }
-
json_object_put(rp);
+}
- printf("ttrss_get_headlines %d end\n", feed_id);
+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);
+}
- return headlines;
+struct headline *ttrss_get_headline(int id)
+{
+ return feeds_get_headline(data, id);
}
projects / prss.git / blobdiff