diff --git a/src/app.ts b/src/app.ts index 272b1a1a..fe35775d 100644 --- a/src/app.ts +++ b/src/app.ts @@ -12,15 +12,38 @@ 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 }); + +// export const wss = new WebSocketServer({ +// port: 8080, +// perMessageDeflate: { +// zlibDeflateOptions: { +// // See zlib defaults. +// chunkSize: 1024, +// memLevel: 7, +// level: 3 +// }, +// zlibInflateOptions: { +// chunkSize: 10 * 1024 +// }, +// // Other options settable: +// clientNoContextTakeover: true, // Defaults to negotiated value. +// serverNoContextTakeover: true, // Defaults to negotiated value. +// serverMaxWindowBits: 10, // Defaults to negotiated value. +// // Below options specified as default values. +// concurrencyLimit: 10, // Limits zlib concurrency for perf. +// threshold: 1024 // Size (in bytes) below which messages +// // should not be compressed if context takeover is disabled. +// } +// }); async function main() { await AppDataSource.initialize(); - + const app = express(); - const server = http.createServer(app); + // const server = http.createServer(app); app.use( cors({ @@ -72,24 +95,24 @@ async function main() { }); // การจัดการคำขออัปเกรดจาก 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); - }); - }); + // 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"); + // }); + // }); // app.listen(APP_PORT, APP_HOST, () => console.log(`Listening on: http://localhost:${APP_PORT}`)); - server.listen( + app.listen( APP_PORT, APP_HOST, () => ( @@ -112,7 +135,7 @@ async function main() { // เริ่มเซิร์ฟเวอร์ที่พอร์ตปัจจุบัน - // server.listen(APP_PORT, () => { + // server.listen(8080, () => { // console.log("[APP] HTTP Server is listening on current port"); // }); diff --git a/src/controllers/ReportController.ts b/src/controllers/ReportController.ts index 8e23a95f..ade35489 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") @@ -3565,17 +3565,17 @@ 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 } }); }