From ecd5d155fc5da042fe5b10da4fdab870956083ce Mon Sep 17 00:00:00 2001
From: Rishi Ghan <rishi.ghan@gmail.com>
Date: Sat, 4 Dec 2021 09:34:33 -0800
Subject: [PATCH] =?UTF-8?q?=E2=9E=BF=20Added=20concurrency=20of=2030=20to?=
 =?UTF-8?q?=20import=20queue?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 services/api.service.ts          | 4 ++--
 services/import.service.ts       | 1 +
 services/libraryqueue.service.ts | 1 +
 3 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/services/api.service.ts b/services/api.service.ts
index dd45544..931bd36 100644
--- a/services/api.service.ts
+++ b/services/api.service.ts
@@ -99,15 +99,15 @@ export default class ApiService extends Service {
 					console.log("Client connected via websocket!");
 
 					client.on("action", async (action) => {
+						console.log("ACCCCCTION", action);
 						switch (action.type) {
 							case "LS_IMPORT":
 								// 1. Send task to queue
-								const result = await this.broker.call(
+								await this.broker.call(
 									"import.newImport",
 									action.data,
 									{}
 								);
-								client.emit("LS_COVER_EXTRACTED", result);
 								break;
 						}
 					});
diff --git a/services/import.service.ts b/services/import.service.ts
index 16228b8..56efdba 100644
--- a/services/import.service.ts
+++ b/services/import.service.ts
@@ -80,6 +80,7 @@ export default class ImportService extends Service {
 								}>
 							) {
 								// 1. Walk the Source folder
+								
 								klaw(path.resolve(COMICS_DIRECTORY))
 									// 1.1 Filter on .cb* extensions
 									.pipe(
diff --git a/services/libraryqueue.service.ts b/services/libraryqueue.service.ts
index 144346b..bc3a6ca 100644
--- a/services/libraryqueue.service.ts
+++ b/services/libraryqueue.service.ts
@@ -28,6 +28,7 @@ export default class LibraryQueueService extends Service {
 					hooks: {},
 					queues: {
 						"process.import": {
+							concurrency: 30,
 							async process(job: SandboxedJob) {
 								console.info("New job received!", job.data);
 								console.info(`Processing queue...`);