* 02110-1301 USA
*/
+#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <json/json.h>
#include "list.h"
-#include "log.h"
+#include <plog.h>
#include "ttrss_ws.h"
#include "ttrss_wsasync.h"
json_object_put(rp);
cur++;
- usleep(100000);
+ usleep(500000);
}
free(tmp);
}
log_debug("ws_async_set_article_unread(%d,%d) done", id, unread);
}
+
+struct cbk_data {
+ int id;
+ void (*callback)(int id, const char *);
+};
+
+void async_article_content_cbk(struct json_object *rp, void *userdata)
+{
+ struct cbk_data *data;
+
+ data = userdata;
+
+ log_debug("async_article_content_cbk %d\n", data->id);
+
+ if (data->callback)
+ data->callback(data->id, ws_reply_get_article_content(rp));
+
+ free(data);
+}
+
+
+void
+ws_async_get_article_content(int id, void (*callback)(int id, const char *))
+{
+ struct json_object *rq;
+ struct cbk_data *data;
+
+ rq = ws_request_new_get_article_content(id);
+
+ data = malloc(sizeof(struct cbk_data));
+ data->id = id;
+ data->callback = callback;
+
+ add_async_request(rq, async_article_content_cbk, data);
+}