From c934987b14dc2b0c362f2d13e0664ab275aca522 Mon Sep 17 00:00:00 2001
From: syuilo <syuilotan@yahoo.co.jp>
Date: Thu, 7 Mar 2019 23:07:21 +0900
Subject: Resolve #4444

---
 src/queue/processors/delete-notes.ts | 55 ------------------------------------
 1 file changed, 55 deletions(-)
 delete mode 100644 src/queue/processors/delete-notes.ts

(limited to 'src/queue/processors/delete-notes.ts')

diff --git a/src/queue/processors/delete-notes.ts b/src/queue/processors/delete-notes.ts
deleted file mode 100644
index 13c6042b16..0000000000
--- a/src/queue/processors/delete-notes.ts
+++ /dev/null
@@ -1,55 +0,0 @@
-import * as bq from 'bee-queue';
-import * as mongo from 'mongodb';
-
-import { queueLogger } from '../logger';
-import Note from '../../models/note';
-import deleteNote from '../../services/note/delete';
-import User from '../../models/user';
-
-const logger = queueLogger.createSubLogger('delete-notes');
-
-export async function deleteNotes(job: bq.Job, done: any): Promise<void> {
-	logger.info(`Deleting notes of ${job.data.user._id} ...`);
-
-	const user = await User.findOne({
-		_id: new mongo.ObjectID(job.data.user._id.toString())
-	});
-
-	let deletedCount = 0;
-	let ended = false;
-	let cursor: any = null;
-
-	while (!ended) {
-		const notes = await Note.find({
-			userId: user._id,
-			...(cursor ? { _id: { $gt: cursor } } : {})
-		}, {
-			limit: 100,
-			sort: {
-				_id: 1
-			}
-		});
-
-		if (notes.length === 0) {
-			ended = true;
-			if (job.reportProgress) job.reportProgress(100);
-			break;
-		}
-
-		cursor = notes[notes.length - 1]._id;
-
-		for (const note of notes) {
-			await deleteNote(user, note, true);
-			deletedCount++;
-		}
-
-		const total = await Note.count({
-			userId: user._id,
-		});
-
-		if (job.reportProgress) job.reportProgress(deletedCount / total);
-	}
-
-	logger.succ(`All notes (${deletedCount}) of ${user._id} has been deleted.`);
-	done();
-}
-- 
cgit v1.2.3-freya