diff options
| -rw-r--r-- | activitypub.c | 62 | ||||
| -rw-r--r-- | httpd.c | 3 | ||||
| -rw-r--r-- | snac.h | 4 |
3 files changed, 67 insertions, 2 deletions
diff --git a/activitypub.c b/activitypub.c index d470e10..7c302bb 100644 --- a/activitypub.c +++ b/activitypub.c @@ -156,13 +156,73 @@ void process_queue(snac *snac) } +int activitypub_get_handler(d_char *req, char *q_path, + char **body, int *b_size, char **ctype) +{ + int status = 200; + char *headers = xs_dict_get(req, "headers"); + char *accept = xs_dict_get(headers, "accept"); + snac snac; + xs *msg = xs_dict_new(); + + if (xs_str_in(accept, "application/activity+json") == -1 && + xs_str_in(accept, "application/ld+json") == -1) + return 0; + + xs *l = xs_split_n(q_path, "/", 2); + char *uid, *p_path; + + uid = xs_list_get(l, 1); + if (!user_open(&snac, uid)) { + /* invalid user */ + srv_log(xs_fmt("activitypub_get_handler bad user %s", uid)); + return 404; + } + + p_path = xs_list_get(l, 2); + + if (p_path == NULL) { + /* if there was no component after the user, it's an actor request */ + } + else + if (strcmp(p_path, "outbox") == 0) { + } + else + if (strcmp(p_path, "followers") == 0 || strcmp(p_path, "following") == 0) { + xs *id = xs_fmt("%s/%s", snac.actor, p_path); + + msg = xs_dict_append(msg, "@context", "https:/" "/www.w3.org/ns/activitystreams"); + msg = xs_dict_append(msg, "attributedTo", snac.actor); + msg = xs_dict_append(msg, "id", id); + msg = xs_dict_append(msg, "orderedItems", xs_list_new()); + msg = xs_dict_append(msg, "totalItems", xs_number_new(0)); + msg = xs_dict_append(msg, "type", "OrderedCollection"); + } + else + if (xs_startswith(p_path, "p/")) { + } + else + status = 404; + + if (status == 200) { + *body = xs_json_dumps_pp(msg, 4); + *b_size = strlen(*body); + } + + user_free(&snac); + + return status; +} + + int activitypub_post_handler(d_char *req, char *q_path, d_char *payload, int p_size, char **body, int *b_size, char **ctype) /* processes an input message */ { int status = 200; - char *i_ctype = xs_dict_get(req, "content-type"); + char *headers = xs_dict_get(req, "headers"); + char *i_ctype = xs_dict_get(headers, "content-type"); snac snac; if (xs_str_in(i_ctype, "application/activity+json") == -1 && @@ -131,6 +131,9 @@ void httpd_connection(int rs) if (status == 0) status = webfinger_get_handler(req, q_path, &body, &b_size, &ctype); + + if (status == 0) + status = activitypub_get_handler(req, q_path, &body, &b_size, &ctype); } else if (strcmp(method, "POST") == 0) { @@ -78,13 +78,15 @@ void httpd(void); int webfinger_request(char *qs, char **actor, char **user); int webfinger_get_handler(d_char *req, char *q_path, - char **body, int *b_size, char **ctype); + char **body, int *b_size, char **ctype); int activitypub_request(snac *snac, char *url, d_char **data); int actor_request(snac *snac, char *actor, d_char **data); int send_to_inbox(snac *snac, char *inbox, char *msg, d_char **payload, int *p_size); int send_to_actor(snac *snac, char *actor, char *msg, d_char **payload, int *p_size); void process_queue(snac *snac); +int activitypub_get_handler(d_char *req, char *q_path, + char **body, int *b_size, char **ctype); int activitypub_post_handler(d_char *req, char *q_path, char *payload, int p_size, char **body, int *b_size, char **ctype); |