groot/automatisch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: Remove all related records when user is deleted

Browse Source
This commit is contained in:
Faruk AYDIN
2023-08-24 12:56:27 +02:00
committed by Ali BARIN
parent 4b77f2f590
commit 129e6d60e5
1 changed files with 15 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
packages/backend/src/graphql/mutations/delete-current-user.ee.ts
View File

@@ -3,6 +3,8 @@ import Context from '../../types/express/context';
import deleteUserQueue from '../../queues/delete-user.ee'; import deleteUserQueue from '../../queues/delete-user.ee';
import flowQueue from '../../queues/flow'; import flowQueue from '../../queues/flow';
import Flow from '../../models/flow'; import Flow from '../../models/flow';
import Execution from '../../models/execution';
import ExecutionStep from '../../models/execution-step';
const deleteCurrentUser = async ( const deleteCurrentUser = async (
_parent: unknown, _parent: unknown,
@@ -25,14 +27,20 @@ const deleteCurrentUser = async (
} }
} }
await context.currentUser.$query().delete(); const executionIds = (
await context.currentUser
.$relatedQuery('executions')
.select('executions.id')
).map((execution: Execution) => execution.id);
const flowIds = flows.map((flow) => flow.id);
await Flow.query() await ExecutionStep.query().delete().whereIn('execution_id', executionIds);
.whereIn( await context.currentUser.$relatedQuery('executions').delete();
'id', await context.currentUser.$relatedQuery('steps').delete();
flows.map((flow) => flow.id) await Flow.query().whereIn('id', flowIds).delete();
) await context.currentUser.$relatedQuery('connections').delete();
.delete();
await context.currentUser.$query().delete();
const jobName = `Delete user - ${id}`; const jobName = `Delete user - ${id}`;
const jobPayload = { id }; const jobPayload = { id };