diff --git a/packages/backend/src/queue/processors/deliver.ts b/packages/backend/src/queue/processors/deliver.ts index 7518a3ca9..a718fe291 100644 --- a/packages/backend/src/queue/processors/deliver.ts +++ b/packages/backend/src/queue/processors/deliver.ts @@ -36,24 +36,26 @@ export default async (job: Bull.Job) => { logger.debug(`delivering ${latest}`); } - let i = undefined; - - if ( - ["Create", "Update"].includes(job.data.content.type) - && job.data.content.object.type === "Note" - ) { - const obj = job.data.content.object; - const patchSrcContent = shouldPatchText(obj.source.content); - if (patchSrcContent) { - i = await registerOrFetchInstanceDoc(host); - if (shouldPatchText(obj.content)) - obj.content = patchText(obj.content, i); - if (shouldPatchText(obj._misskey_content)) - obj._misskey_content = patchText(obj._misskey_content, i); - if (patchSrcContent) - obj.source.content = patchText(obj.source.content, i); - } - } + let i = undefined; + + if ( + ["Create", "Update"].includes(job.data.content.type) + && job.data.content.object.type === "Note" + && job.data.content.object.content + ) { + const obj = job.data.content.object; + const patchSrcContent = shouldPatchText(obj.source.content); + if (patchSrcContent) { + i = await registerOrFetchInstanceDoc(host); + if (shouldPatchText(obj.content)) + obj.content = patchText(obj.content, i); + if (shouldPatchText(obj._misskey_content)) + obj._misskey_content = patchText(obj._misskey_content, i); + if (patchSrcContent) + obj.source.content = patchText(obj.source.content, i); + } + } + await request(job.data.user, job.data.to, job.data.content);