diff --git a/packages/backend/src/queue/processors/inbox.ts b/packages/backend/src/queue/processors/inbox.ts index b319fbd38..09a69b25c 100644 --- a/packages/backend/src/queue/processors/inbox.ts +++ b/packages/backend/src/queue/processors/inbox.ts @@ -35,8 +35,11 @@ export default async (job: Bull.Job): Promise => { info["@context"] = undefined; logger.debug(JSON.stringify(info, null, 2)); - if (!signature?.keyId) return `Invalid signature: ${signature}`; - + if (!signature?.keyId) { + const err = `Invalid signature: ${signature}`; + job.moveToFailed({message: err}); + return err; + } //#endregion const host = toPuny(new URL(signature.keyId).hostname);