From dc4767db274bd11edd50fd6bb3c1add5d27369c4 Mon Sep 17 00:00:00 2001
From: Rishi Ghan <rishi.ghan@gmail.com>
Date: Mon, 25 Apr 2022 20:08:07 -0700
Subject: [PATCH] =?UTF-8?q?=F0=9F=94=A7=20Added=20a=20single=20import=20so?=
 =?UTF-8?q?cket.io=20endpoint?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 services/socket.service.ts | 24 +++++++++++++-----------
 1 file changed, 13 insertions(+), 11 deletions(-)

diff --git a/services/socket.service.ts b/services/socket.service.ts
index d7257f7..7000081 100644
--- a/services/socket.service.ts
+++ b/services/socket.service.ts
@@ -1,15 +1,10 @@
 "use strict";
-import {
-	Service,
-	ServiceBroker,
-	ServiceSchema
-} from "moleculer";
+import { Service, ServiceBroker, ServiceSchema } from "moleculer";
 const SocketIOService = require("moleculer-io");
 const redisAdapter = require("socket.io-redis");
 const redisURL = new URL(process.env.REDIS_URI);
 console.log(redisURL.hostname);
 
-
 export default class SocketService extends Service {
 	// @ts-ignore
 	public constructor(
@@ -56,14 +51,19 @@ export default class SocketService extends Service {
 														{}
 													);
 													break;
-
+												case "LS_SINGLE_IMPORT":
+													console.log(data.data);
+													break;
 											}
-										}
+										},
 									},
 								},
 							},
 							options: {
-								adapter: redisAdapter({ host: redisURL.hostname, port: 6379 })
+								adapter: redisAdapter({
+									host: redisURL.hostname,
+									port: 6379,
+								}),
 							},
 						},
 					},
@@ -71,8 +71,10 @@ export default class SocketService extends Service {
 					actions: {},
 					methods: {},
 					async started() {
-						this.io.on("connection", (data) => console.log("socket.io server initialized."))
-					}
+						this.io.on("connection", (data) =>
+							console.log("socket.io server initialized.")
+						);
+					},
 				},
 				schema
 			)