diff --git a/activitypub.c b/activitypub.c index f9144a6..5d54833 100644 --- a/activitypub.c +++ b/activitypub.c @@ -73,3 +73,40 @@ int actor_request(snac *snac, char *actor, d_char **data) return status; } + + +int send_to_inbox(snac *snac, char *inbox, char *msg, d_char **payload, int *p_size) +/* sends a message to an Inbox */ +{ + int status; + d_char *response; + + response = http_signed_request(snac, "POST", inbox, + NULL, msg, strlen(msg), &status, payload, p_size); + + free(response); + + return status; +} + + +int send_to_actor(snac *snac, char *actor, char *msg, d_char **payload, int *p_size) +/* sends a message to an actor */ +{ + int status; + xs *data = NULL; + + /* resolve the actor first */ + status = actor_request(snac, actor, &data); + + if (valid_status(status)) { + char *inbox = xs_dict_get(data, "inbox"); + + if (inbox != NULL) + status = send_to_inbox(snac, inbox, msg, payload, p_size); + else + status = 400; + } + + return status; +} diff --git a/data.c b/data.c index bde23e1..c9ba389 100644 --- a/data.c +++ b/data.c @@ -724,7 +724,7 @@ int actor_get(snac *snac, char *actor, d_char **data) fclose(f); } - status = 110; /* "Response Is Stale" */ + status = 205; /* "205: Reset Content" "110: Response Is Stale" */ } else { /* it's still valid */ diff --git a/snac.h b/snac.h index 76a1afe..a10169e 100644 --- a/snac.h +++ b/snac.h @@ -82,3 +82,5 @@ int webfinger_get_handler(d_char *req, char *q_path, 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);