diff --git a/server/queues/processors/RevisionsProcessor.ts b/server/queues/processors/RevisionsProcessor.ts index 9e252490c..d62ec97c5 100644 --- a/server/queues/processors/RevisionsProcessor.ts +++ b/server/queues/processors/RevisionsProcessor.ts @@ -5,10 +5,14 @@ import { DocumentEvent, RevisionEvent, Event } from "@server/types"; import BaseProcessor from "./BaseProcessor"; export default class RevisionsProcessor extends BaseProcessor { - static applicableEvents: Event["name"][] = ["documents.update.debounced"]; + static applicableEvents: Event["name"][] = [ + "documents.publish", + "documents.update.debounced", + ]; async perform(event: DocumentEvent | RevisionEvent) { switch (event.name) { + case "documents.publish": case "documents.update.debounced": { const document = await Document.findByPk(event.documentId); invariant(document, "Document should exist");