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 ( - param: Record + param: Record, + ctx: PageContext ): Promise => { try { const params = { @@ -533,7 +534,14 @@ export const deletePagesByParam = async ( 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