From ad6d694c51b862c393955216a29e8999530ae4b7 Mon Sep 17 00:00:00 2001 From: AdisakKanthawilang Date: Tue, 4 Mar 2025 18:25:31 +0700 Subject: [PATCH] comment websocket --- src/app.ts | 46 ++++++++++++++--------------- src/controllers/ReportController.ts | 28 +++++++++--------- 2 files changed, 37 insertions(+), 37 deletions(-) diff --git a/src/app.ts b/src/app.ts index a1506e2c..9d14ce21 100644 --- a/src/app.ts +++ b/src/app.ts @@ -12,9 +12,9 @@ import { RegisterRoutes } from "./routes"; import { OrganizationController } from "./controllers/OrganizationController"; import logMiddleware from "./middlewares/logs"; import { CommandController } from "./controllers/CommandController"; -import { WebSocketServer } from "ws"; -import http from "http"; -export const wss = new WebSocketServer({ noServer: true }); +// import { WebSocketServer } from "ws"; +// import http from "http"; +// export const wss = new WebSocketServer({ noServer: true }); async function main() { await AppDataSource.initialize(); @@ -90,30 +90,30 @@ async function main() { runMessageQueue(); - // สร้างเซิร์ฟเวอร์ HTTP - const server = http.createServer(app); + // // สร้างเซิร์ฟเวอร์ HTTP + // const server = http.createServer(app); - // การจัดการคำขออัปเกรดจาก HTTP เป็น WebSocket - server.on("upgrade", (request:any, socket:any, head:any) => { - console.log("🔹 Handling upgrade request..."); - wss.handleUpgrade(request, socket, head, (ws:any) => { - console.log("🔹 WebSocket connection established"); - wss.emit("connection", ws, request); - }); - }); + // // การจัดการคำขออัปเกรดจาก HTTP เป็น WebSocket + // server.on("upgrade", (request:any, socket:any, head:any) => { + // console.log("🔹 Handling upgrade request..."); + // wss.handleUpgrade(request, socket, head, (ws:any) => { + // console.log("🔹 WebSocket connection established"); + // wss.emit("connection", ws, request); + // }); + // }); - wss.on("connection", (ws:any) => { - console.log("✅ Client connected to WebSocket"); + // wss.on("connection", (ws:any) => { + // console.log("✅ Client connected to WebSocket"); - ws.on("close", () => { - console.log("❌ Client disconnected"); - }); - }); + // ws.on("close", () => { + // console.log("❌ Client disconnected"); + // }); + // }); - // เริ่มเซิร์ฟเวอร์ที่พอร์ต 5000 - server.listen(APP_PORT, () => { - console.log("✅ HTTP Server is listening on port 5000"); - }); + // // เริ่มเซิร์ฟเวอร์ที่พอร์ต 5000 + // server.listen(APP_PORT, () => { + // console.log("✅ HTTP Server is listening on port 5000"); + // }); } diff --git a/src/controllers/ReportController.ts b/src/controllers/ReportController.ts index 6452fbfd..dbe9805f 100644 --- a/src/controllers/ReportController.ts +++ b/src/controllers/ReportController.ts @@ -31,8 +31,8 @@ import { Profile } from "../entities/Profile"; import { viewRegistryOfficer } from "../entities/view/viewRegistryOfficer"; import { viewRegistryEmployee } from "../entities/view/viewRegistryEmployee"; import { EmployeeTempPosMaster } from "../entities/EmployeeTempPosMaster"; -import { WebSocket } from "ws"; -import { wss } from "../app"; +// import { WebSocket } from "ws"; +// import { wss } from "../app"; @Route("api/v1/org/report") @Tags("Report") @@ -3516,19 +3516,19 @@ export class ReportController extends Controller { } // console.log(">>",data); - wss.clients.forEach((client: any) => { - if (client.readyState === WebSocket.OPEN) { - const message = JSON.stringify({ template: "report2", reportName: "report2", data: { data } }); - console.log("📤 Sending data to client:", message); - client.send(message, (err:any) => { - if (err) { - console.error("❌ Error sending message:", err); - } - }); - } - }); + // wss.clients.forEach((client: any) => { + // if (client.readyState === WebSocket.OPEN) { + // const message = JSON.stringify({ template: "report2", reportName: "report2", data: { data } }); + // console.log("📤 Sending data to client:", message); + // client.send(message, (err:any) => { + // if (err) { + // console.error("❌ Error sending message:", err); + // } + // }); + // } + // }); - // return new HttpSuccess({ template: "report2", reportName: "report2", data: { data } }); + return new HttpSuccess({ template: "report2", reportName: "report2", data: { data } }); } /**