From 0d62afe2e3424a6467db5b4083816d1cdc3ab663 Mon Sep 17 00:00:00 2001 From: Claudemir Todo Bom Date: Thu, 11 Jul 2024 20:26:53 -0300 Subject: [PATCH] backend/src/libs/socket.ts: prettier --- backend/src/libs/socket.ts | 121 +++++++++++++++++++++---------------- 1 file changed, 70 insertions(+), 51 deletions(-) diff --git a/backend/src/libs/socket.ts b/backend/src/libs/socket.ts index c610ed7e..474c1c8a 100644 --- a/backend/src/libs/socket.ts +++ b/backend/src/libs/socket.ts @@ -1,12 +1,12 @@ import { Server as SocketIO } from "socket.io"; import { instrument } from "@socket.io/admin-ui"; import { Server } from "http"; +import { verify } from "jsonwebtoken"; import AppError from "../errors/AppError"; import { logger } from "../utils/logger"; import User from "../models/User"; import Queue from "../models/Queue"; import Ticket from "../models/Ticket"; -import { verify } from "jsonwebtoken"; import authConfig from "../config/auth"; import { CounterManager } from "./counter"; @@ -20,20 +20,18 @@ export const initIO = (httpServer: Server): SocketIO => { }); if (process.env.SOCKET_ADMIN && JSON.parse(process.env.SOCKET_ADMIN)) { - User.findByPk(1).then( - (adminUser) => { - instrument(io, { - auth: { - type: "basic", - username: adminUser.email, - password: adminUser.passwordHash - }, - mode: "development", - }); - } - ); - } - + User.findByPk(1).then(adminUser => { + instrument(io, { + auth: { + type: "basic", + username: adminUser.email, + password: adminUser.passwordHash + }, + mode: "development" + }); + }); + } + io.on("connection", async socket => { logger.info("Client Connected"); const { token } = socket.handshake.query; @@ -69,7 +67,7 @@ export const initIO = (httpServer: Server): SocketIO => { socket.join(`company-${user.companyId}-mainchannel`); socket.join(`user-${user.id}`); - + if (user.super) { socket.join("super"); } @@ -79,24 +77,31 @@ export const initIO = (httpServer: Server): SocketIO => { return; } Ticket.findByPk(ticketId).then( - (ticket) => { - if (ticket && ticket.companyId === user.companyId - && (ticket.userId === user.id || user.profile === "admin")) { + ticket => { + if ( + ticket && + ticket.companyId === user.companyId && + (ticket.userId === user.id || user.profile === "admin") + ) { const c = counters.incrementCounter(`ticket-${ticketId}`); if (c === 1) { socket.join(ticketId); } - logger.debug(`joinChatbox[${c}]: Channel: ${ticketId} by user ${user.id}`) + logger.debug( + `joinChatbox[${c}]: Channel: ${ticketId} by user ${user.id}` + ); } else { - logger.info(`Invalid attempt to join channel of ticket ${ticketId} by user ${user.id}`) + logger.info( + `Invalid attempt to join channel of ticket ${ticketId} by user ${user.id}` + ); } }, - (error) => { + error => { logger.error(error, `Error fetching ticket ${ticketId}`); } ); }); - + socket.on("leaveChatBox", async (ticketId: string) => { if (!ticketId || ticketId === "undefined") { return; @@ -108,69 +113,83 @@ export const initIO = (httpServer: Server): SocketIO => { socket.leave(ticketId); } - logger.debug(`leaveChatbox[${c}]: Channel: ${ticketId} by user ${user.id}`) + logger.debug( + `leaveChatbox[${c}]: Channel: ${ticketId} by user ${user.id}` + ); }); - socket.on("joinNotification", async () => { + socket.on("joinNotification", async () => { const c = counters.incrementCounter("notification"); if (c === 1) { - if (user.profile === "admin") { - socket.join(`company-${user.companyId}-notification`); - } else { - user.queues.forEach((queue) => { - logger.debug(`User ${user.id} of company ${user.companyId} joined queue ${queue.id} channel.`); - socket.join(`queue-${queue.id}-notification`); - }); - } - } + if (user.profile === "admin") { + socket.join(`company-${user.companyId}-notification`); + } else { + user.queues.forEach(queue => { + logger.debug( + `User ${user.id} of company ${user.companyId} joined queue ${queue.id} channel.` + ); + socket.join(`queue-${queue.id}-notification`); + }); + } + } logger.debug(`joinNotification[${c}]: User: ${user.id}`); - }); - - socket.on("leaveNotification", async () => { + }); + + socket.on("leaveNotification", async () => { const c = counters.decrementCounter("notification"); if (c === 0) { if (user.profile === "admin") { socket.leave(`company-${user.companyId}-notification`); } else { - user.queues.forEach((queue) => { - logger.debug(`User ${user.id} of company ${user.companyId} leaved queue ${queue.id} channel.`); + user.queues.forEach(queue => { + logger.debug( + `User ${user.id} of company ${user.companyId} leaved queue ${queue.id} channel.` + ); socket.leave(`queue-${queue.id}-notification`); }); } } logger.debug(`leaveNotification[${c}]: User: ${user.id}`); }); - - socket.on("joinTickets", (status: string) => { + + socket.on("joinTickets", (status: string) => { if (counters.incrementCounter(`status-${status}`) === 1) { if (user.profile === "admin") { - logger.debug(`Admin ${user.id} of company ${user.companyId} joined ${status} tickets channel.`); + logger.debug( + `Admin ${user.id} of company ${user.companyId} joined ${status} tickets channel.` + ); socket.join(`company-${user.companyId}-${status}`); } else if (status === "pending") { - user.queues.forEach((queue) => { - logger.debug(`User ${user.id} of company ${user.companyId} joined queue ${queue.id} pending tickets channel.`); + user.queues.forEach(queue => { + logger.debug( + `User ${user.id} of company ${user.companyId} joined queue ${queue.id} pending tickets channel.` + ); socket.join(`queue-${queue.id}-pending`); }); } else { logger.debug(`User ${user.id} cannot subscribe to ${status}`); } - } - }); - + } + }); + socket.on("leaveTickets", (status: string) => { if (counters.decrementCounter(`status-${status}`) === 0) { if (user.profile === "admin") { - logger.debug(`Admin ${user.id} of company ${user.companyId} leaved ${status} tickets channel.`); + logger.debug( + `Admin ${user.id} of company ${user.companyId} leaved ${status} tickets channel.` + ); socket.leave(`company-${user.companyId}-${status}`); } else if (status === "pending") { - user.queues.forEach((queue) => { - logger.debug(`User ${user.id} of company ${user.companyId} leaved queue ${queue.id} pending tickets channel.`); + user.queues.forEach(queue => { + logger.debug( + `User ${user.id} of company ${user.companyId} leaved queue ${queue.id} pending tickets channel.` + ); socket.leave(`queue-${queue.id}-pending`); }); } } }); - + socket.emit("ready"); return io; });