prehistoric-systems/omnivore
1
0
Fork 0
mirror of https://github.com/omnivore-app/omnivore.git synced 2026-03-11 08:54:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Publish delete event

Browse source
This commit is contained in:
Hongbo Wu 2022-07-07 12:31:46 +08:00
parent 94d8891c06
commit 41f43b54ab
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
packages/api/src/elastic/pages.ts
View file

@ -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