(io: SocketIOServer)
| 4 | |
| 5 | // Function to initialize socket.io server and define event handlers |
| 6 | export const initializeSocket = (io: SocketIOServer) => { |
| 7 | io.on("connection", (socket: Socket) => { |
| 8 | logger.info("New client connected", socket.id); |
| 9 | |
| 10 | socket.on("command", async (data: any, callback: Function) => { |
| 11 | await handleCommand(socket, data, callback); |
| 12 | }); |
| 13 | |
| 14 | socket.on("devicePrepare", async (data: any, callback: Function) => { |
| 15 | await handleDevicePrepare(socket, data, callback); |
| 16 | }); |
| 17 | |
| 18 | socket.on("disconnect", async (reason) => { |
| 19 | logger.info(`Client disconnected ${socket.id}: ${reason}`); |
| 20 | await handleDestroy(socket); |
| 21 | }); |
| 22 | |
| 23 | socket.on("error", async (error: Error) => { |
| 24 | logger.info(`[error] client error`); |
| 25 | logger.info(error); |
| 26 | await handleDestroy(socket); |
| 27 | }); |
| 28 | |
| 29 | socket.on("connect_error", (err) => { |
| 30 | logger.info(`Connect Error: ${err.message}`); |
| 31 | }); |
| 32 | }); |
| 33 | |
| 34 | io.on("error", (error: Error) => { |
| 35 | logger.error("socker error occured"); |
| 36 | logger.error(error); |
| 37 | io.removeAllListeners(); |
| 38 | }); |
| 39 | |
| 40 | io.on("disconnect", (error: Error) => { |
| 41 | logger.error("socket disconnected"); |
| 42 | logger.error(error); |
| 43 | }); |
| 44 | }; |
no test coverage detected