commit f0ef1d4

Reworked enqueue_message().

 1@@ -1396,20 +1396,16 @@ void enqueue_email(snac *snac, xs_str *msg, int retries)
 2 }
 3 
 4 
 5-void enqueue_message(snac *snac, char *msg)
 6+void enqueue_message(snac *snac, xs_dict *msg)
 7 /* enqueues an output message */
 8 {
 9-    char *id = xs_dict_get(msg, "id");
10-    xs *ntid = tid(0);
11-    xs *fn   = xs_fmt("%s/queue/%s.json", snac->basedir, ntid);
12-    xs *qmsg = xs_dict_new();
13-
14-    qmsg = xs_dict_append(qmsg, "type",    "message");
15-    qmsg = xs_dict_append(qmsg, "message", msg);
16+    xs *qmsg   = _new_qmsg("message", msg, 0);
17+    char *ntid = xs_dict_get(qmsg, "ntid");
18+    xs *fn     = xs_fmt("%s/queue/%s.json", snac->basedir, ntid);
19 
20     qmsg = _enqueue_put(fn, qmsg);
21 
22-    snac_debug(snac, 0, xs_fmt("enqueue_message %s", id));
23+    snac_debug(snac, 0, xs_fmt("enqueue_message %s", xs_dict_get(msg, "id")));
24 }
25 
26