From e9afd7cd13d2e11e8602f6508bbea5e76db7018e Mon Sep 17 00:00:00 2001 From: default Date: Sat, 24 Sep 2022 11:54:35 +0200 Subject: [PATCH] More work. --- activitypub.c | 24 +++++++++++++----------- httpd.c | 5 ----- 2 files changed, 13 insertions(+), 16 deletions(-) diff --git a/activitypub.c b/activitypub.c index cede02c..976222a 100644 --- a/activitypub.c +++ b/activitypub.c @@ -156,6 +156,7 @@ d_char *msg_collection(snac *snac, char *id) d_char *msg_update(snac *snac, char *object) +/* creates an Update message */ { xs *id = xs_fmt("%s/Update", xs_dict_get(object, "id")); d_char *msg = msg_base(snac, "Update", id, snac->actor, ""); @@ -331,31 +332,32 @@ int activitypub_post_handler(d_char *req, char *q_path, xs_str_in(i_ctype, "application/ld+json") == -1) return 0; + /* decode the message */ + xs *msg = xs_json_loads(payload); + + if (msg == NULL) { + srv_log(xs_fmt("activitypub_post_handler JSON error %s", q_path)); + status = 400; + } + + /* get the user and path */ xs *l = xs_split_n(q_path, "/", 2); char *uid; if (xs_list_len(l) != 3 || strcmp(xs_list_get(l, 2), "inbox") != 0) { /* strange q_path */ - srv_log(xs_fmt("activitypub_post_handler unsupported path %s", q_path)); + srv_debug(1, xs_fmt("activitypub_post_handler unsupported path %s", q_path)); return 404; } uid = xs_list_get(l, 1); if (!user_open(&snac, uid)) { /* invalid user */ - srv_log(xs_fmt("activitypub_post_handler bad user %s", uid)); + srv_debug(1, xs_fmt("activitypub_post_handler bad user %s", uid)); return 404; } - /* decode */ - xs *msg = xs_json_loads(payload); - - if (msg && xs_dict_get(msg, "actor") && xs_dict_get(msg, "type")) - enqueue_input(&snac, msg, req); - else { - srv_log(xs_fmt("activitypub_post_handler JSON error %s", q_path)); - status = 400; - } + enqueue_input(&snac, msg, req); user_free(&snac); diff --git a/httpd.c b/httpd.c index 20ba763..8e40d55 100644 --- a/httpd.c +++ b/httpd.c @@ -106,11 +106,6 @@ void httpd_connection(int rs) req = xs_httpd_request(f, &payload, &p_size); - { - xs *j = xs_json_dumps_pp(req, 4); - printf("%s\n", j); - } - req_hdrs = xs_dict_get(req, "headers"); method = xs_dict_get(req_hdrs, "method");