The pool of threads now process q_items.

Also, the purge is commanded as a q_item.

1 files changed, 8 insertions, 0 deletions

diff --git a/activitypub.c b/activitypub.c
index 42558f4..5aae251 100644
--- a/activitypub.c
+++ b/activitypub.c
@@ -1188,6 +1188,14 @@ void process_queue_item(xs_dict *q_item)
             }
         }
     }
+    else
+    if (strcmp(type, "purge") == 0) {
+        srv_log(xs_dup("purge start"));
+
+        purge_all();
+
+        srv_log(xs_dup("purge end"));
+    }
 }