From d1f091556e55696172b27906d42afdf08f323fc5 Mon Sep 17 00:00:00 2001 From: Rishi Ghan Date: Tue, 11 May 2021 09:49:32 -0700 Subject: [PATCH] =?UTF-8?q?=F0=9F=93=95=20Testing=20call=20against=20cover?= =?UTF-8?q?s?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/client/workers/extractCovers.worker.ts | 4 ++-- src/server/route/routes/importComics.routes.ts | 14 ++++---------- 2 files changed, 6 insertions(+), 12 deletions(-) diff --git a/src/client/workers/extractCovers.worker.ts b/src/client/workers/extractCovers.worker.ts index ba5fb7a..14abebd 100644 --- a/src/client/workers/extractCovers.worker.ts +++ b/src/client/workers/extractCovers.worker.ts @@ -12,8 +12,8 @@ export const greet = async ( ): Promise => { const targetOptions = { sourceFolder: path, - extractTarget: "all", - targetExtractionFolder: "./userdata/expanded", + extractTarget: "cover", + targetExtractionFolder: "./userdata/covers", extractionMode: "bulk", }; diff --git a/src/server/route/routes/importComics.routes.ts b/src/server/route/routes/importComics.routes.ts index 329ec4f..1f2b42a 100644 --- a/src/server/route/routes/importComics.routes.ts +++ b/src/server/route/routes/importComics.routes.ts @@ -23,8 +23,8 @@ router.route("/getComicCovers").post(async (req: Request, res: Response) => { typeof req.body.extractionOptions === "object" ? req.body.extractionOptions : {}; - const foo = await axios({ - url: "http://localhost:3853/api/import/getComicCovers", + const comicBookCoversData = await axios({ + url: "http://localhost:3000/api/import/getComicCovers", method: "POST", data: { extractionOptions: req.body.extractionOptions, @@ -37,9 +37,6 @@ router.route("/getComicCovers").post(async (req: Request, res: Response) => { read() {}, }); - // We create the stream transform using through2 library.. - // We instruct it to handle objects, buffer size and transform function, - // that is, we convert our object to text to be able to send it through the stream response, which does not handle objects.. const ndjsonStream = through2( { objectMode: true, highWaterMark: 1 }, (data, enc, cb) => { @@ -47,11 +44,8 @@ router.route("/getComicCovers").post(async (req: Request, res: Response) => { }, ); - // console.log(ndjsonStream); - // Through pipe we do a double addressing, our reading stream goes through the transformation - // to finally go through the stream response.. stream.pipe(ndjsonStream).pipe(res); - stream.push({ source1: foo.data }); + stream.push({ data: comicBookCoversData.data }); stream.push(null); }); @@ -60,7 +54,7 @@ router.route("/walkFolder").post(async (req: Request, res: Response) => { typeof req.body.basePathToWalk === "string" ? req.body.basePathToWalk : ""; const walkedFolders = await axios .request({ - url: "http://localhost:3853/api/import/walkFolders", + url: "http://localhost:3000/api/import/walkFolders", method: "POST", data: { basePathToWalk,