From 32126602fd772d5cd374bacc9320593e6307c7a0 Mon Sep 17 00:00:00 2001
From: Tom Moor <tom.moor@gmail.com>
Date: Tue, 14 Dec 2021 17:21:11 -0800
Subject: [PATCH] fix: Duplicate notification for publish event, closes #2757

---
 server/queues/processors/revisions.test.ts | 20 +-------------------
 server/queues/processors/revisions.ts      |  1 -
 2 files changed, 1 insertion(+), 20 deletions(-)

diff --git a/server/queues/processors/revisions.test.ts b/server/queues/processors/revisions.test.ts
index 4d50765bd..514594b36 100644
--- a/server/queues/processors/revisions.test.ts
+++ b/server/queues/processors/revisions.test.ts
@@ -6,25 +6,7 @@ import RevisionsService from "./revisions";
 const Revisions = new RevisionsService();
 beforeEach(() => flushdb());
 beforeEach(jest.resetAllMocks);
-describe("documents.publish", () => {
-  test("should create a revision", async () => {
-    const document = await buildDocument();
-    // @ts-expect-error ts-migrate(2345) FIXME: Argument of type '{ name: "documents.publish"; doc... Remove this comment to see the full error message
-    await Revisions.on({
-      name: "documents.publish",
-      documentId: document.id,
-      collectionId: document.collectionId,
-      teamId: document.teamId,
-      actorId: document.createdById,
-    });
-    const amount = await Revision.count({
-      where: {
-        documentId: document.id,
-      },
-    });
-    expect(amount).toBe(1);
-  });
-});
+
 describe("documents.update.debounced", () => {
   test("should create a revision", async () => {
     const document = await buildDocument();
diff --git a/server/queues/processors/revisions.ts b/server/queues/processors/revisions.ts
index 772a10f49..9c0389aa4 100644
--- a/server/queues/processors/revisions.ts
+++ b/server/queues/processors/revisions.ts
@@ -6,7 +6,6 @@ import { DocumentEvent, RevisionEvent } from "../../types";
 export default class RevisionsProcessor {
   async on(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");