diff --git a/src/server/api/endpoints/i/delete-account.ts b/src/server/api/endpoints/i/delete-account.ts index b93ebbe46a32..91c375b50376 100644 --- a/src/server/api/endpoints/i/delete-account.ts +++ b/src/server/api/endpoints/i/delete-account.ts @@ -6,6 +6,7 @@ import { createDeleteNotesJob, createDeleteDriveFilesJob } from '../../../../que import Message from '../../../../models/messaging-message'; import Signin from '../../../../models/signin'; import { doPostSuspend } from '../../../../services/suspend-user'; +import { publishTerminate } from '../../../../services/server-event'; export const meta = { requireCredential: true, @@ -44,6 +45,9 @@ export default define(meta, async (ps, user) => { } }); + // Terminate streaming + publishTerminate(user._id); + Message.remove({ userId: user._id }); Signin.remove({ userId: user._id }); createDeleteNotesJob(user);