From 8f63c6259ad8eb6d26eff2673a29ef469ad8e018 Mon Sep 17 00:00:00 2001
From: default <nobody@localhost>
Date: Tue, 7 Feb 2023 13:19:27 +0100
Subject: [PATCH] Log unexpected q_item types.

---
 activitypub.c | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git a/activitypub.c b/activitypub.c
index e87f6d5..af0a9a1 100644
--- a/activitypub.c
+++ b/activitypub.c
@@ -1126,20 +1126,20 @@ void process_user_queue_item(snac *snac, xs_dict *q_item)
         /* deliver */
         status = send_to_inbox_raw(keyid, seckey, inbox, msg, &payload, &p_size, retries == 0 ? 3 : 8);
 
-        snac_log(snac, xs_fmt("process_queue sent to inbox %s %d", inbox, status));
+        snac_log(snac, xs_fmt("output sent to inbox %s %d", inbox, status));
 
         if (!valid_status(status)) {
             /* error sending; requeue? */
             if (status == 404 || status == 410)
                 /* explicit error: discard */
-                snac_log(snac, xs_fmt("process_queue error %s %d", inbox, status));
+                snac_log(snac, xs_fmt("output error %s %d", inbox, status));
             else
             if (retries > queue_retry_max)
-                snac_log(snac, xs_fmt("process_queue giving up %s %d", inbox, status));
+                snac_log(snac, xs_fmt("output giving up %s %d", inbox, status));
             else {
                 /* requeue */
                 enqueue_output(snac, msg, inbox, retries + 1);
-                snac_log(snac, xs_fmt("process_queue requeue %s #%d", inbox, retries + 1));
+                snac_log(snac, xs_fmt("output requeue %s #%d", inbox, retries + 1));
             }
         }
     }
@@ -1155,14 +1155,16 @@ void process_user_queue_item(snac *snac, xs_dict *q_item)
 
         if (!process_input_message(snac, msg, req)) {
             if (retries > queue_retry_max)
-                snac_log(snac, xs_fmt("process_queue input giving up"));
+                snac_log(snac, xs_fmt("input giving up"));
             else {
                 /* reenqueue */
                 enqueue_input(snac, msg, req, retries + 1);
-                snac_log(snac, xs_fmt("process_queue input requeue #%d", retries + 1));
+                snac_log(snac, xs_fmt("input requeue #%d", retries + 1));
             }
         }
     }
+    else
+        snac_log(snac, xs_fmt("unexpected q_item type '%s'", type));
 }
 
 
@@ -1245,6 +1247,8 @@ void process_queue_item(xs_dict *q_item)
 
         srv_log(xs_dup("purge end"));
     }
+    else
+        srv_log(xs_fmt("unexpected q_item type '%s'", type));
 }