From 5792ef5d24bd58f5c74a37c43d80720c46a6758a Mon Sep 17 00:00:00 2001
From: default <nobody@localhost>
Date: Sun, 25 Sep 2022 07:58:25 +0200
Subject: [PATCH] Process 'Create' messages (untested).

---
 activitypub.c | 36 +++++++++++++++++++++++++++++++++---
 snac.h        |  1 +
 2 files changed, 34 insertions(+), 3 deletions(-)

diff --git a/activitypub.c b/activitypub.c
index ec1d820..a6fa645 100644
--- a/activitypub.c
+++ b/activitypub.c
@@ -173,22 +173,51 @@ d_char *msg_update(snac *snac, char *object)
 void process_message(snac *snac, char *msg, char *req)
 /* processes an ActivityPub message from the input queue */
 {
-    /* they exist, were checked previously */
-    char *actor = xs_dict_get(msg, "actor");
-    char *type  = xs_dict_get(msg, "type");
+    /* actor and type exist, were checked previously */
+    char *actor  = xs_dict_get(msg, "actor");
+    char *type   = xs_dict_get(msg, "type");
+
+    char *object, *utype;
+
+    object = xs_dict_get(msg, "object");
+    if (object != NULL && xs_type(object) == XSTYPE_SOD)
+        utype = xs_dict_get(object, "type");
+    else
+        utype = "(null)";
 
     /* check the signature */
     /* ... */
 
+/*
     if (strcmp(type, "Follow") == 0) {
     }
     else
     if (strcmp(type, "Undo") == 0) {
     }
     else
+*/
     if (strcmp(type, "Create") == 0) {
+        if (strcmp(utype, "Note") == 0) {
+            if (is_muted(snac, actor))
+                snac_log(snac, xs_fmt("ignored 'Note' from muted actor %s", actor));
+            else {
+                char *id          = xs_dict_get(object, "id");
+                char *in_reply_to = xs_dict_get(object, "inReplyTo");
+
+                if (in_reply_to != NULL) {
+                    /* recursively download ancestors */
+                    /* ... */
+                }
+
+                snac_log(snac, xs_fmt("new 'Note' %s %s", actor, id));
+                timeline_add(snac, id, msg, in_reply_to);
+            }
+        }
+        else
+            snac_debug(snac, 1, xs_fmt("ignored 'Create' for object type '%s'", utype));
     }
     else
+/*
     if (strcmp(type, "Accept") == 0) {
     }
     else
@@ -201,6 +230,7 @@ void process_message(snac *snac, char *msg, char *req)
     if (strcmp(type, "Delete") == 0) {
     }
     else
+*/
         snac_debug(snac, 1, xs_fmt("process_message type '%s' ignored", type));
 }
 
diff --git a/snac.h b/snac.h
index c91186f..e499f6e 100644
--- a/snac.h
+++ b/snac.h
@@ -55,6 +55,7 @@ d_char *timeline_find(snac *snac, char *id);
 void timeline_del(snac *snac, char *id);
 d_char *timeline_get(snac *snac, char *fn);
 d_char *timeline_list(snac *snac);
+void timeline_add(snac *snac, char *id, char *msg, char *parent);
 
 int following_add(snac *snac, char *actor, char *msg);
 int following_del(snac *snac, char *actor);