commit ff52f77

New function enqueue_collect_replies().

 1@@ -2914,6 +2914,12 @@ void process_user_queue_item(snac *user, xs_dict *q_item)
 2             }
 3         }
 4     }
 5+    else
 6+    if (strcmp(type, "collect_replies") == 0) {
 7+        const char *post = xs_dict_get(q_item, "message");
 8+
 9+        collect_replies(user, post);
10+    }
11     else
12         snac_log(user, xs_fmt("unexpected user q_item type '%s'", type));
13 }

 1@@ -3576,6 +3576,19 @@ void enqueue_notify_webhook(snac *user, const xs_dict *noti, int retries)
 2 }
 3 
 4 
 5+void enqueue_collect_replies(snac *user, const char *post)
 6+/* enqueues a collect replies request */
 7+{
 8+    xs *qmsg = _new_qmsg("collect_replies", post, 0);
 9+    const char *ntid = xs_dict_get(qmsg, "ntid");
10+    xs *fn = xs_fmt("%s/queue/%s.json", user->basedir, ntid);
11+
12+    qmsg = _enqueue_put(fn, qmsg);
13+
14+    snac_debug(user, 1, xs_fmt("enqueue_collect_replies %s", post));
15+}
16+
17+
18 int was_question_voted(snac *user, const char *id)
19 /* returns true if the user voted in this poll */
20 {

1@@ -731,7 +731,7 @@ int main(int argc, char *argv[])
2     }
3 
4     if (strcmp(cmd, "collect_replies") == 0) { /** **/
5-        collect_replies(&snac, url);
6+        enqueue_collect_replies(&snac, url);
7 
8         return 0;
9     }

1@@ -297,6 +297,7 @@ void enqueue_verify_links(snac *user);
2 void enqueue_actor_refresh(snac *user, const char *actor, int forward_secs);
3 void enqueue_webmention(const xs_dict *msg);
4 void enqueue_notify_webhook(snac *user, const xs_dict *noti, int retries);
5+void enqueue_collect_replies(snac *user, const char *post);
6 
7 int was_question_voted(snac *user, const char *id);
8