diff options
Diffstat (limited to 'data.c')
| -rw-r--r-- | data.c | 17 |
1 files changed, 17 insertions, 0 deletions
| @@ -1384,6 +1384,23 @@ void enqueue_email(snac *snac, char *msg, int retries) | |||
| 1384 | } | 1384 | } |
| 1385 | 1385 | ||
| 1386 | 1386 | ||
| 1387 | void enqueue_message(snac *snac, char *msg) | ||
| 1388 | /* enqueues an output message */ | ||
| 1389 | { | ||
| 1390 | char *id = xs_dict_get(msg, "id"); | ||
| 1391 | xs *ntid = tid(0); | ||
| 1392 | xs *fn = xs_fmt("%s/queue/%s.json", snac->basedir, ntid); | ||
| 1393 | xs *qmsg = xs_dict_new(); | ||
| 1394 | |||
| 1395 | qmsg = xs_dict_append(qmsg, "type", "message"); | ||
| 1396 | qmsg = xs_dict_append(qmsg, "message", msg); | ||
| 1397 | |||
| 1398 | _enqueue_put(fn, qmsg); | ||
| 1399 | |||
| 1400 | snac_debug(snac, 1, xs_fmt("enqueue_message %s", id)); | ||
| 1401 | } | ||
| 1402 | |||
| 1403 | |||
| 1387 | d_char *queue(snac *snac) | 1404 | d_char *queue(snac *snac) |
| 1388 | /* returns a list with filenames that can be dequeued */ | 1405 | /* returns a list with filenames that can be dequeued */ |
| 1389 | { | 1406 | { |