From 427f7341fa5db23b9e67a1d1035bb3dc12d35f40 Mon Sep 17 00:00:00 2001
From: default
Date: Fri, 16 Dec 2022 07:09:25 +0100
Subject: New function enqueue_message().

---
 data.c | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

(limited to 'data.c')

diff --git a/data.c b/data.c
index cdffc02..60e5f5d 100644
--- a/data.c
+++ b/data.c
@@ -1384,6 +1384,23 @@ void enqueue_email(snac *snac, char *msg, int retries)
 }
 
 
+void enqueue_message(snac *snac, char *msg)
+/* enqueues an output message */
+{
+    char *id = xs_dict_get(msg, "id");
+    xs *ntid = tid(0);
+    xs *fn   = xs_fmt("%s/queue/%s.json", snac->basedir, ntid);
+    xs *qmsg = xs_dict_new();
+
+    qmsg = xs_dict_append(qmsg, "type",    "message");
+    qmsg = xs_dict_append(qmsg, "message", msg);
+
+    _enqueue_put(fn, qmsg);
+
+    snac_debug(snac, 1, xs_fmt("enqueue_message %s", id));
+}
+
+
 d_char *queue(snac *snac)
 /* returns a list with filenames that can be dequeued */
 {
-- 
cgit v1.2.3