From 94c4790bd7357be754b0f094fba4eb91b12dc132 Mon Sep 17 00:00:00 2001 From: default Date: Tue, 31 Jan 2023 20:22:36 +0100 Subject: Unified queue message field names. --- activitypub.c | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'activitypub.c') diff --git a/activitypub.c b/activitypub.c index e52db31..2df5899 100644 --- a/activitypub.c +++ b/activitypub.c @@ -1101,7 +1101,7 @@ void process_queue(snac *snac) if (strcmp(type, "output") == 0) { int status; char *inbox = xs_dict_get(q_item, "inbox"); - char *msg = xs_dict_get(q_item, "object"); + char *msg = xs_dict_get(q_item, "message"); int retries = xs_number_get(xs_dict_get(q_item, "retries")); xs *payload = NULL; int p_size = 0; @@ -1132,10 +1132,13 @@ void process_queue(snac *snac) else if (strcmp(type, "input") == 0) { /* process the message */ - char *msg = xs_dict_get(q_item, "object"); + char *msg = xs_dict_get(q_item, "message"); char *req = xs_dict_get(q_item, "req"); int retries = xs_number_get(xs_dict_get(q_item, "retries")); + if (xs_is_null(msg)) + continue; + if (!process_message(snac, msg, req)) { if (retries > queue_retry_max) snac_log(snac, xs_fmt("process_queue input giving up")); -- cgit v1.2.3