🚥 Socket.io integration WIP

src/client/actions/fileops.actions.tsx

@@ -1,9 +1,5 @@
 import axios from "axios";
-import fetch, { Response } from "node-fetch";
-import {
-  IExtractionOptions,
-  IFolderData,
-} from "../../server/interfaces/folder.interface";
+import { IFolderData } from "../../server/interfaces/folder.interface";
 import { API_BASE_URI } from "../constants/endpoints";
 
 export async function walkFolder(path: string): Promise<Array<IFolderData>> {
@@ -21,20 +17,3 @@ export async function walkFolder(path: string): Promise<Array<IFolderData>> {
       return data;
     });
 }
-
-export async function extractCoverFromComicBookArchive(
-  extractionOptions: IExtractionOptions,
-  walkedFolders: Array<IFolderData>,
-): Promise<Response> {
-  return await fetch(API_BASE_URI + "getComicCovers", {
-    method: "POST",
-    headers: {
-      Accept: "application/json",
-      "Content-Type": "application/json",
-    },
-    body: JSON.stringify({
-      extractionOptions,
-      walkedFolders,
-    }),
-  });
-}

src/client/workers/extractCovers.worker.ts

@@ -1,13 +1,7 @@
-import {
-  walkFolder,
-  extractCoverFromComicBookArchive,
-} from "../actions/fileops.actions";
-import { IExtractedComicBookCoverFile } from "../../server/interfaces/folder.interface";
-const ndjsonStream = require("can-ndjson-stream");
+import { walkFolder } from "../actions/fileops.actions";
+import { io } from "socket.io-client";
 
-export const greet = async (
-  path: string,
-): Promise<IExtractedComicBookCoverFile[]> => {
+export const greet = async (path: string): Promise<any> => {
   const targetOptions = {
     sourceFolder: path,
     extractTarget: "cover",
@@ -23,19 +17,29 @@ export const greet = async (
     ...targetOptions,
     paginationOptions: pagingConfig,
   };
-  const fileObjects = await walkFolder("./comics");
-  const fetchedResource = await extractCoverFromComicBookArchive(
-    extractionOptions,
-    fileObjects,
-  );
+  const walkedFolders = await walkFolder("./comics");
 
-  const reader = await ndjsonStream(fetchedResource.body).getReader();
-  return reader.read().then(function process({ done, value }) {
-    if (done) {
-      console.log("done");
-      return;
-    }
+  const socket = io("ws://localhost:3000/", {
+    reconnectionDelayMax: 10000,
+  });
 
-    return reader.read().then(process);
+  socket.on("connect", () => {
+    console.log(`connect ${socket.id}`);
+  });
+
+  socket.on("disconnect", () => {
+    console.log(`disconnect`);
+  });
+  socket.emit("call", {
+    action: "getComicCovers",
+    params: {
+      extractionOptions,
+      walkedFolders,
+    },
+    opts: { garam: "pasha" },
+  });
+
+  socket.on("comicBookCoverMetadata", (data) => {
+    console.log(data);
   });
 };

src/server/route/routes/importComics.routes.ts

@@ -1,43 +1,14 @@
 import router from "../router";
 import { Request, Response } from "express";
 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";
-import { io } from "socket.io-client";
-
-const socket = io("ws://localhost:3000/", {
-  reconnectionDelayMax: 10000,
-});
-
-socket.on("connect", () => {
-  console.log(`connect ${socket.id}`);
-});
-
-socket.on("disconnect", () => {
-  console.log(`disconnect`);
-});
 
 router.route("/getComicCovers").post(async (req: Request, res: Response) => {
   typeof req.body.extractionOptions === "object"
     ? req.body.extractionOptions
     : {};
   const { extractionOptions, walkedFolders } = req.body;
-  socket.emit("call", {
-    action: "getComicCovers",
-    params: {
-      extractionOptions,
-      walkedFolders,
-    },
-    opts: { garam: "pasha" },
-  });
-  socket.on("comicBookCoverMetadata", (done) => {
-    console.log(done);
-  });
+
+  // res.sendStatus(200);
   // socket.on("hello", (done) => done);
   res.sendStatus(200);
 });