diff options
Diffstat (limited to 'activitypub.c')
| -rw-r--r-- | activitypub.c | 35 |
1 files changed, 23 insertions, 12 deletions
diff --git a/activitypub.c b/activitypub.c index 82230ff..44b5ba2 100644 --- a/activitypub.c +++ b/activitypub.c @@ -133,24 +133,35 @@ int send_to_inbox(snac *snac, char *inbox, char *msg, d_char **payload, int *p_s } -int send_to_actor(snac *snac, char *actor, char *msg, d_char **payload, int *p_size) -/* sends a message to an actor */ +d_char *get_actor_inbox(snac *snac, char *actor) +/* gets an actor's inbox */ { - int status; xs *data = NULL; + char *v = NULL; - /* resolve the actor first */ - status = actor_request(snac, actor, &data); - - if (valid_status(status)) { - char *inbox = xs_dict_get(data, "inbox"); + if (valid_status(actor_request(snac, actor, &data))) { + /* try first endpoints/sharedInbox */ + if ((v = xs_dict_get(data, "endpoints"))) + v = xs_dict_get(v, "sharedInbox"); - if (inbox != NULL) - status = send_to_inbox(snac, inbox, msg, payload, p_size); - else - status = 400; + /* try then the regular inbox */ + if (xs_is_null(v)) + v = xs_dict_get(data, "inbox"); } + return xs_is_null(v) ? NULL : xs_dup(v); +} + + +int send_to_actor(snac *snac, char *actor, char *msg, d_char **payload, int *p_size) +/* sends a message to an actor */ +{ + int status = 400; + xs *inbox = get_actor_inbox(snac, actor); + + if (!xs_is_null(inbox)) + status = send_to_inbox(snac, inbox, msg, payload, p_size); + snac_log(snac, xs_fmt("send_to_actor %s %d", actor, status)); return status; |