diff options
| author | 2022-09-28 20:24:47 +0200 | |
|---|---|---|
| committer | 2022-09-28 20:24:47 +0200 | |
| commit | 51ed24be474c44f687c67ec66dc16e5d5c279e95 (patch) | |
| tree | 2b7e8e6b075401af8aee7e8c87959fd59a18e006 | |
| parent | Process 'Update' + 'Person'. (diff) | |
| download | snac2-51ed24be474c44f687c67ec66dc16e5d5c279e95.tar.gz snac2-51ed24be474c44f687c67ec66dc16e5d5c279e95.tar.xz snac2-51ed24be474c44f687c67ec66dc16e5d5c279e95.zip | |
If an actor cannot be retrieved, move the message back to the queue.
| -rw-r--r-- | activitypub.c | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/activitypub.c b/activitypub.c index ca6bf52..20c734b 100644 --- a/activitypub.c +++ b/activitypub.c | |||
| @@ -574,7 +574,12 @@ void process_message(snac *snac, char *msg, char *req) | |||
| 574 | utype = "(null)"; | 574 | utype = "(null)"; |
| 575 | 575 | ||
| 576 | /* bring the actor */ | 576 | /* bring the actor */ |
| 577 | actor_request(snac, actor, &actor_o); | 577 | if (!valid_status(actor_request(snac, actor, &actor_o))) { |
| 578 | /* error: re-enqueue to try later */ | ||
| 579 | enqueue_input(snac, msg, req); | ||
| 580 | snac_log(snac, xs_fmt("error requesting actor %s -- retry later", actor)); | ||
| 581 | return; | ||
| 582 | } | ||
| 578 | 583 | ||
| 579 | /* check the signature */ | 584 | /* check the signature */ |
| 580 | /* ... */ | 585 | /* ... */ |