From 41f43b54ab97d435eafe7245ca39176da5ac2178 Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Thu, 7 Jul 2022 12:31:46 +0800
Subject: [PATCH] Publish delete event

---
 packages/api/src/elastic/pages.ts | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/packages/api/src/elastic/pages.ts b/packages/api/src/elastic/pages.ts
index 60fd7247e..2b53c9509 100644
--- a/packages/api/src/elastic/pages.ts
+++ b/packages/api/src/elastic/pages.ts
@@ -511,7 +511,8 @@ export const countByCreatedAt = async (
 }
 
 export const deletePagesByParam = async <K extends keyof ParamSet>(
-  param: Record<K, Page[K]>
+  param: Record<K, Page[K]>,
+  ctx: PageContext
 ): Promise<boolean> => {
   try {
     const params = {
@@ -533,7 +534,14 @@ export const deletePagesByParam = async <K extends keyof ParamSet>(
       body: params,
     })
 
-    return body.deleted > 0
+    if (body.deleted > 0) {
+      // * means deleting all pages of the same user
+      await ctx.pubsub.entityDeleted(EntityType.PAGE, '*', ctx.uid)
+
+      return true
+    }
+
+    return false
   } catch (e) {
     console.error('failed to delete pages by param in elastic', e)
     return false