From 78f7c1b59585057f6f45eee5455b23a369ea500d Mon Sep 17 00:00:00 2001
From: Rishi Ghan <rishi.ghan@gmail.com>
Date: Sun, 7 Jan 2024 22:13:02 -0500
Subject: [PATCH] =?UTF-8?q?=F0=9F=A4=90=20Added=20uncompression=20event?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 services/jobqueue.service.ts | 11 +++++++++++
 services/library.service.ts  | 13 +++++++++----
 2 files changed, 20 insertions(+), 4 deletions(-)

diff --git a/services/jobqueue.service.ts b/services/jobqueue.service.ts
index eea9f84..190b330 100644
--- a/services/jobqueue.service.ts
+++ b/services/jobqueue.service.ts
@@ -352,6 +352,17 @@ export default class JobQueueService extends Service {
 					console.log(
 						`Uncompression Job ID ${ctx.params.id} completed.`
 					);
+					const job = await this.job(ctx.params.id);
+					await this.broker.call("socket.broadcast", {
+						namespace: "/",
+						event: "LS_UNCOMPRESSION_JOB_COMPLETE",
+						args: [
+							{
+								uncompressedArchive: job.returnvalue,
+							},
+						],
+					});
+					return job.returnvalue;
 				},
 				// use the `${QUEUE_NAME}.QUEUE_EVENT` scheme
 				async "enqueue.async.active"(ctx: Context<{ id: Number }>) {
diff --git a/services/library.service.ts b/services/library.service.ts
index 4aa3dab..ce198d8 100644
--- a/services/library.service.ts
+++ b/services/library.service.ts
@@ -80,14 +80,19 @@ export default class ImportService extends Service {
 				},
 				walkFolders: {
 					rest: "POST /walkFolders",
-					params: {
-						basePathToWalk: "string",
-					},
-					async handler(ctx: Context<{ basePathToWalk: string }>) {
+					params: {},
+					async handler(
+						ctx: Context<{
+							basePathToWalk: string;
+							extensions: string[];
+						}>
+					) {
+						console.log(ctx.params);
 						return await walkFolder(ctx.params.basePathToWalk, [
 							".cbz",
 							".cbr",
 							".cb7",
+							...ctx.params.extensions,
 						]);
 					},
 				},