monkee.ch/snac2
1
0
Fork 0
mirror of https://codeberg.org/grunfink/snac2.git synced 2024-11-22 21:35:04 +00:00
Code Issues Projects Releases Packages Wiki Activity

Deleted old output message processing in user queue.

Browse source
This commit is contained in:
default 2023-02-07 13:34:26 +01:00
parent 4cca157641
commit 944bd60e06
1 changed files with 0 additions and 36 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
activitypub.c
View file

@ -1108,42 +1108,6 @@ void process_user_queue_item(snac *snac, xs_dict *q_item)
} }
} }
else else
if (strcmp(type, "output") == 0) {
int status;
xs_str *inbox = xs_dict_get(q_item, "inbox");
xs_str *keyid = xs_dict_get(q_item, "keyid");
xs_str *seckey = xs_dict_get(q_item, "seckey");
xs_dict *msg = xs_dict_get(q_item, "message");
int retries = xs_number_get(xs_dict_get(q_item, "retries"));
xs *payload = NULL;
int p_size = 0;
if (xs_is_null(inbox) || xs_is_null(msg) || xs_is_null(keyid) || xs_is_null(seckey)) {
srv_log(xs_fmt("incomplete output message"));
return;
}
/* deliver */
status = send_to_inbox_raw(keyid, seckey, inbox, msg, &payload, &p_size, retries == 0 ? 3 : 8);
snac_log(snac, xs_fmt("output sent to inbox %s %d", inbox, status));
if (!valid_status(status)) {
/* error sending; requeue? */
if (status == 404 || status == 410)
/* explicit error: discard */
snac_log(snac, xs_fmt("output error %s %d", inbox, status));
else
if (retries > queue_retry_max)
snac_log(snac, xs_fmt("output giving up %s %d", inbox, status));
else {
/* requeue */
enqueue_output(snac, msg, inbox, retries + 1);
snac_log(snac, xs_fmt("output requeue %s #%d", inbox, retries + 1));
}
}
}
else
if (strcmp(type, "input") == 0) { if (strcmp(type, "input") == 0) {
/* process the message */ /* process the message */
xs_dict *msg = xs_dict_get(q_item, "message"); xs_dict *msg = xs_dict_get(q_item, "message");