summaryrefslogtreecommitdiff
path: root/src/queue/processors/db/delete-account.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue/processors/db/delete-account.ts')
-rw-r--r--src/queue/processors/db/delete-account.ts94
1 files changed, 0 insertions, 94 deletions
diff --git a/src/queue/processors/db/delete-account.ts b/src/queue/processors/db/delete-account.ts
deleted file mode 100644
index e54f38e35e..0000000000
--- a/src/queue/processors/db/delete-account.ts
+++ /dev/null
@@ -1,94 +0,0 @@
-import * as Bull from 'bull';
-import { queueLogger } from '../../logger';
-import { DriveFiles, Notes, UserProfiles, Users } from '@/models/index';
-import { DbUserDeleteJobData } from '@/queue/types';
-import { Note } from '@/models/entities/note';
-import { DriveFile } from '@/models/entities/drive-file';
-import { MoreThan } from 'typeorm';
-import { deleteFileSync } from '@/services/drive/delete-file';
-import { sendEmail } from '@/services/send-email';
-
-const logger = queueLogger.createSubLogger('delete-account');
-
-export async function deleteAccount(job: Bull.Job<DbUserDeleteJobData>): Promise<string | void> {
- logger.info(`Deleting account of ${job.data.user.id} ...`);
-
- const user = await Users.findOne(job.data.user.id);
- if (user == null) {
- return;
- }
-
- { // Delete notes
- let cursor: Note['id'] | null = null;
-
- while (true) {
- const notes = await Notes.find({
- where: {
- userId: user.id,
- ...(cursor ? { id: MoreThan(cursor) } : {})
- },
- take: 100,
- order: {
- id: 1
- }
- });
-
- if (notes.length === 0) {
- break;
- }
-
- cursor = notes[notes.length - 1].id;
-
- await Notes.delete(notes.map(note => note.id));
- }
-
- logger.succ(`All of notes deleted`);
- }
-
- { // Delete files
- let cursor: DriveFile['id'] | null = null;
-
- while (true) {
- const files = await DriveFiles.find({
- where: {
- userId: user.id,
- ...(cursor ? { id: MoreThan(cursor) } : {})
- },
- take: 10,
- order: {
- id: 1
- }
- });
-
- if (files.length === 0) {
- break;
- }
-
- cursor = files[files.length - 1].id;
-
- for (const file of files) {
- await deleteFileSync(file);
- }
- }
-
- logger.succ(`All of files deleted`);
- }
-
- { // Send email notification
- const profile = await UserProfiles.findOneOrFail(user.id);
- if (profile.email && profile.emailVerified) {
- sendEmail(profile.email, 'Account deleted',
- `Your account has been deleted.`,
- `Your account has been deleted.`);
- }
- }
-
- // soft指定されている場合は物理削除しない
- if (job.data.soft) {
- // nop
- } else {
- await Users.delete(job.data.user.id);
- }
-
- return 'Account deleted';
-}