From e144c9dd5f3ce105b0ab794bd84951f76ffd006c Mon Sep 17 00:00:00 2001
From: Rishi Ghan <rishi.ghan@gmail.com>
Date: Thu, 17 Mar 2022 17:05:58 -0700
Subject: [PATCH] =?UTF-8?q?=E2=8F=AF=20Added=20pause/resume=20control=20me?=
 =?UTF-8?q?thod=20for=20bullmq?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 services/api.service.ts          |  4 ++--
 services/libraryqueue.service.ts | 24 ++++++++++++++++++++----
 utils/uncompression.utils.ts     |  1 +
 3 files changed, 23 insertions(+), 6 deletions(-)

diff --git a/services/api.service.ts b/services/api.service.ts
index cfab6f8..78a4303 100644
--- a/services/api.service.ts
+++ b/services/api.service.ts
@@ -104,9 +104,9 @@ export default class ApiService extends Service {
 									{}
 								);
 								break;
-							case "LS_PAUSE_IMPORT_QUEUE":
+							case "LS_TOGGLE_IMPORT_QUEUE":
 								console.log("lol")
-								await this.broker.call("queue.pauseImportQueue", action.data);
+								await this.broker.call("queue.toggleImportQueue", action.data, {});
 								break;
 						}
 					});
diff --git a/services/libraryqueue.service.ts b/services/libraryqueue.service.ts
index 8bac697..baf8c74 100644
--- a/services/libraryqueue.service.ts
+++ b/services/libraryqueue.service.ts
@@ -153,12 +153,28 @@ export default class QueueService extends Service {
 						});
 					},
 				},
-				pauseImportQueue: {
+				toggleImportQueue: {
 					rest: "POST /pauseImportQueue",
 					params: {},
-					handler: async (ctx: Context<{}>) => {
-						return await this.getQueue("process.import").resume();
-					}
+					handler: async (ctx: Context<{ action: string }>) => {
+						console.log(ctx.params);
+						switch (ctx.params.action) {
+							case "pause":
+								const foo = await this.getQueue(
+									"process.import"
+								).pause();
+								console.log(foo);
+								break;
+							case "resume":
+								const soo = await this.getQueue(
+									"process.import"
+								).resume();
+								console.log(soo);
+								break;
+							default:
+								console.log("Unrecognized queue action.");
+						}
+					},
 				},
 				unarchiveComicBook: {
 					rest: "POST /unarchiveComicBook",
diff --git a/utils/uncompression.utils.ts b/utils/uncompression.utils.ts
index 5d48e82..249bf42 100644
--- a/utils/uncompression.utils.ts
+++ b/utils/uncompression.utils.ts
@@ -155,6 +155,7 @@ export const extractComicInfoXMLFromRar = async (
 				// orchestrate result
 				console.log("ASDAsd");
 				resolve({
+					filePath,
 					name: fileNameWithoutExtension,
 					extension,
 					containedIn: targetDirectory,