diff options
Diffstat (limited to 'activitypub.c')
| -rw-r--r-- | activitypub.c | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/activitypub.c b/activitypub.c index 79c20d7..1b89e3c 100644 --- a/activitypub.c +++ b/activitypub.c @@ -282,7 +282,6 @@ d_char *recipient_list(snac *snac, char *msg, int expand_public) int is_msg_public(snac *snac, xs_dict *msg) /* checks if a message is public */ { - int ret = 0; xs *rcpts = recipient_list(snac, msg, 0); return xs_list_in(rcpts, public_address) != -1; @@ -1102,12 +1101,22 @@ void process_user_queue_item(snac *snac, xs_dict *q_item) if (strcmp(type, "message") == 0) { xs_dict *msg = xs_dict_get(q_item, "message"); xs *rcpts = recipient_list(snac, msg, 1); + xs *shibx = inbox_list(); xs_set inboxes; xs_list *p; + xs_str *v; xs_str *actor; xs_set_init(&inboxes); + /* send first to the collected inboxes */ + p = shibx; + while (xs_list_iter(&p, &v)) { + if (xs_set_add(&inboxes, v) == 1) + enqueue_output(snac, msg, v, 0); + } + + /* iterate now the recipients */ p = rcpts; while (xs_list_iter(&p, &actor)) { xs *inbox = get_actor_inbox(snac, actor); |