From f35e3ccbe0260375785a57277fa66e0b847ba87c Mon Sep 17 00:00:00 2001 From: Rishi Ghan Date: Wed, 15 Nov 2023 16:02:07 -0600 Subject: [PATCH] =?UTF-8?q?=E2=9D=8C=20Removed=20useless=20code?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/socket.service.ts | 84 -------------------------------------- 1 file changed, 84 deletions(-) diff --git a/services/socket.service.ts b/services/socket.service.ts index 8b0f52d..02a40cd 100644 --- a/services/socket.service.ts +++ b/services/socket.service.ts @@ -28,90 +28,6 @@ export default class SocketService extends Service { call: { whitelist: ["socket.*"], }, - - // async (data) => { - // console.log("uldas", data); - // switch (data.type) { - // case "RESUME_SESSION": - // console.log("Attempting to resume session..."); - // try { - // const sessionRecord = await Session.find({ - // sessionId: data.session.sessionId, - // }); - // // 1. Check for sessionId's existence, and a match - // if ( - // sessionRecord.length !== 0 && - // sessionRecord[0].sessionId === - // data.session.sessionId - // ) { - // // 2. Find if the queue has active jobs - // const jobs: JobType = await this.broker.call( - // "jobqueue.getJobCountsByType", - // {} - // ); - // const { active } = jobs; - // - // if (active > 0) { - // // 3. Get job counts - // const completedJobCount = - // await pubClient.get( - // "completedJobCount" - // ); - // const failedJobCount = await pubClient.get( - // "failedJobCount" - // ); - // - // // 4. Send the counts to the active socket.io session - // await this.broker.call("socket.broadcast", { - // namespace: "/", - // event: "action", - // args: [ - // { - // type: "RESTORE_JOB_COUNTS_AFTER_SESSION_RESTORATION", - // completedJobCount, - // failedJobCount, - // queueStatus: "running", - // }, - // ], - // }); - // } - // } - // } catch (err) { - // throw new MoleculerError( - // err, - // 500, - // "SESSION_ID_NOT_FOUND", - // { - // data: data.session.sessionId, - // } - // ); - // } - // - // break; - // - // case "LS_SET_QUEUE_STATUS": - // console.log(data); - // await this.broker.call( - // "jobqueue.toggle", - // { action: data.data.queueAction }, - // {} - // ); - // break; - // case "LS_SINGLE_IMPORT": - // console.info("AirDC++ finished a download -> "); - // console.log(data); - // await this.broker.call( - // "library.importDownloadedComic", - // { bundle: data }, - // {} - // ); - // break; - // // uncompress archive events - // case "COMICBOOK_EXTRACTION_SUCCESS": - // console.log(data); - // return data; - // } - // }, }, }, },