From 322e135ead0031fd166409f8c41de525d2494454 Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Thu, 7 Jul 2022 12:32:55 +0800
Subject: [PATCH] delete this user pages in elastic

---
 packages/api/src/resolvers/user/index.ts | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/packages/api/src/resolvers/user/index.ts b/packages/api/src/resolvers/user/index.ts
index 19ea0ddbe..c39524338 100644
--- a/packages/api/src/resolvers/user/index.ts
+++ b/packages/api/src/resolvers/user/index.ts
@@ -1,13 +1,13 @@
 import {
-  DeleteAccountSuccess,
   DeleteAccountError,
   DeleteAccountErrorCode,
-  MutationDeleteAccountArgs,
+  DeleteAccountSuccess,
   GoogleSignupResult,
   LoginErrorCode,
   LoginResult,
   LogOutErrorCode,
   LogOutResult,
+  MutationDeleteAccountArgs,
   MutationGoogleLoginArgs,
   MutationGoogleSignupArgs,
   MutationLoginArgs,
@@ -39,6 +39,7 @@ import * as jwt from 'jsonwebtoken'
 import { createUser } from '../../services/create_user'
 import { comparePassword, hashPassword } from '../../utils/auth'
 import type { UserData } from '../../datalayer/user/model'
+import { deletePagesByParam } from '../../elastic/pages'
 
 export const updateUserResolver = authorized<
   UpdateUserSuccess,
@@ -365,7 +366,7 @@ export const deleteAccountResolver = authorized<
   DeleteAccountSuccess,
   DeleteAccountError,
   MutationDeleteAccountArgs
->(async (_, { userID }, { models, claims, log, authTrx }) => {
+>(async (_, { userID }, { models, claims, log, authTrx, pubsub }) => {
   const user = await models.user.get(userID)
 
   if (!user) {
@@ -384,6 +385,9 @@ export const deleteAccountResolver = authorized<
     models.user.deleteUser(claims.uid, tx)
   )
 
+  // delete this user's pages in elastic
+  await deletePagesByParam({ userId: userID }, { uid: userID, pubsub })
+
   log.info('Deleting a user account', {
     userID,
     labels: {