From 16838a5ea563899d1e06c757660becf368952ed0 Mon Sep 17 00:00:00 2001 From: Rishi Ghan Date: Wed, 26 Jan 2022 01:59:10 -0800 Subject: [PATCH] =?UTF-8?q?=F0=9F=94=A7=20Auto-watcher-importer=20now=20ba?= =?UTF-8?q?tches=20jobs=20in=20the=20queue?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/api.service.ts | 10 ++++++---- utils/uncompression.utils.ts | 2 -- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/services/api.service.ts b/services/api.service.ts index 503b17f..f5b590f 100644 --- a/services/api.service.ts +++ b/services/api.service.ts @@ -147,10 +147,12 @@ export default class ApiService extends Service { basePathToWalk: path, }); console.log(walkedFolder); - await this.broker.call( - "import.processAndImportToDB", - { walkedFolder } - ); + await this.broker.call("libraryqueue.enqueue", { + fileObject: { + filePath: walkedFolder[0].filePath, + size: walkedFolder[0].fileSize, + }, + }); } else { setTimeout( checkFileCopyComplete, diff --git a/utils/uncompression.utils.ts b/utils/uncompression.utils.ts index aff25fd..c356a94 100644 --- a/utils/uncompression.utils.ts +++ b/utils/uncompression.utils.ts @@ -55,8 +55,6 @@ export const extractCoverFromFile2 = async ( fileObject: any ): Promise => { try { - console.log("ASDASD!@#!#!@#!@#"); - console.log(fileObject); const { filePath, fileSize} = fileObject; const calibre = new Calibre();