From 8cc236daf8e6dedf0356d7fb21045f6d9750ce93 Mon Sep 17 00:00:00 2001
From: syuilo <syuilotan@yahoo.co.jp>
Date: Thu, 7 Mar 2019 23:36:08 +0900
Subject: [PATCH] Clean jobs

---
 src/queue/index.ts | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/src/queue/index.ts b/src/queue/index.ts
index 8912a7abfd..e6c3a7c29f 100644
--- a/src/queue/index.ts
+++ b/src/queue/index.ts
@@ -8,6 +8,7 @@ import { program } from '../argv';
 import processDeliver from './processors/deliver';
 import processInbox from './processors/process-inbox';
 import processDb from './processors/db';
+import { queueLogger } from './logger';
 
 function initializeQueue(name: string) {
 	return new Queue(name, config.redis != null ? {
@@ -124,8 +125,13 @@ export default function() {
 }
 
 export function destroy() {
-	/*
-	queue.destroy().then(n => {
-		queueLogger.succ(`All job removed (${n} jobs)`);
-	});*/
+	deliverQueue.once('cleaned', (jobs, status) => {
+		queueLogger.succ(`[deliver] Cleaned ${jobs.length} ${status} jobs`);
+	});
+	deliverQueue.clean(0, 'wait');
+
+	inboxQueue.once('cleaned', (jobs, status) => {
+		queueLogger.succ(`[inbox] Cleaned ${jobs.length} ${status} jobs`);
+	});
+	inboxQueue.clean(0, 'wait');
 }