From 7bcc17694d8042f697102835b9030788b61bef0a Mon Sep 17 00:00:00 2001
From: Rishi Ghan <rishi.ghan@gmail.com>
Date: Thu, 13 May 2021 15:10:11 -0700
Subject: [PATCH] Custom alias for JSON streaming

---
 services/import.service.ts | 47 ++++++++++++++++++++------------------
 1 file changed, 25 insertions(+), 22 deletions(-)

diff --git a/services/import.service.ts b/services/import.service.ts
index c70b40d..372235a 100644
--- a/services/import.service.ts
+++ b/services/import.service.ts
@@ -52,30 +52,33 @@ export default class ProductsService extends Service {
 								);
 							},
 						},
-						getComicCovers: {
-							rest: "POST /getComicCovers",
-							params: {
-								extractionOptions: "object",
-								walkedFolders: "array",
-							},
-							async handler(
-								ctx: Context<{
-									extractionOptions: IExtractionOptions;
-									walkedFolders: IFolderData[];
-								}>
-							) {
-								const readStream = fs.createReadStream(
-									"./userdata/comicBooksForImport.js"
-								);
-								const comicBooksForImport = await getCovers(
-									ctx.params.extractionOptions,
-									ctx.params.walkedFolders
-								);
-								readStream.pipe(comicBooksForImport);
-							},
+						// getComicCovers: {
+						// 	rest: "POST /getComicCovers",
+						// 	params: {
+						// 		extractionOptions: "object",
+						// 		walkedFolders: "array",
+						// 	},
+						// 	async handler(
+						// 		ctx: Context<{
+						// 			extractionOptions: IExtractionOptions;
+						// 			walkedFolders: IFolderData[];
+						// 		}>
+						// 	) {
+						//
+						// 	},
+						// },
+					},
+					methods: {
+						getComicCovers(extractionConfiguration) {
+							return (req, res) => (err) => {
+								if (err) {
+									this.logger.warn("Halkat mard", err);
+									this.sendError(req, res, err);
+									return;
+								}
+							};
 						},
 					},
-					methods: {},
 				},
 				schema
 			)