diff --git a/package.json b/package.json index ba76bc8..21beaa1 100644 --- a/package.json +++ b/package.json @@ -40,6 +40,7 @@ "react": "^17.0.1", "react-dom": "^17.0.1", "react-hooks-worker": "^1.0.0", + "request": "^2.88.2", "sharp": "^0.28.1", "socket.io-client": "^4.1.1", "stream-json": "^1.7.1", diff --git a/src/server/route/routes/importComics.routes.ts b/src/server/route/routes/importComics.routes.ts index 6dc51d4..88774b8 100644 --- a/src/server/route/routes/importComics.routes.ts +++ b/src/server/route/routes/importComics.routes.ts @@ -4,6 +4,7 @@ import axios from "axios"; import stream from "stream"; import through2 from "through2"; import hyperquest from "hyperquest"; +import request from "request"; import es from "event-stream"; import JSONStream from "JSONStream"; import oboe from "oboe"; @@ -30,17 +31,15 @@ router.route("/getComicCovers").post(async (req: Request, res: Response) => { typeof req.body.extractionOptions === "object" ? req.body.extractionOptions : {}; - oboe({ + request({ url: "http://localhost:3000/api/import/getComicCovers", method: "POST", + json: true, body: { extractionOptions: req.body.extractionOptions, walkedFolders: req.body.walkedFolders, }, - }).on("node", ".*", (data) => { - console.log(data); - res.write(JSON.stringify(data)); - }); + }).pipe(res); }); router.route("/walkFolder").post(async (req: Request, res: Response) => {