hrms-bangkok/hrms-api-org
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

ws test

Browse source
This commit is contained in:
AdisakKanthawilang 2025-03-07 16:29:28 +07:00
parent e976e51860
commit eabc379adf
1 changed files with 30 additions and 39 deletions
Download patch file Download diff file Expand all files Collapse all files

69
src/app.ts
View file

@ -15,11 +15,29 @@ import { CommandController } from "./controllers/CommandController";
import { ProfileSalaryController } from "./controllers/ProfileSalaryController"; import { ProfileSalaryController } from "./controllers/ProfileSalaryController";
import { WebSocketServer } from "ws"; import { WebSocketServer } from "ws";
import http from "http";
export const wss = new WebSocketServer({ noServer: true,
path: "/api/v1/org-socket",
});
export const wss = new WebSocketServer({ port: 13002, path: "/api/v1/org-socket" });
// การจัดการคำขออัปเกรดจาก HTTP เป็น WebSocket
wss.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");
ws.on("close", () => {
console.log("❌ Client disconnected");
});
ws.on("error", (error: any) => {
console.error("WebSocket error:", error);
});
});
async function main() { async function main() {
await AppDataSource.initialize(); await AppDataSource.initialize();
@ -89,14 +107,14 @@ async function main() {
}); });
// app.listen(APP_PORT, APP_HOST, () => console.log(`Listening on: http://localhost:${APP_PORT}`)); // app.listen(APP_PORT, APP_HOST, () => console.log(`Listening on: http://localhost:${APP_PORT}`));
// app.listen( app.listen(
// APP_PORT, APP_PORT,
// APP_HOST, APP_HOST,
// () => ( () => (
// console.log(`[APP] Application is running on: http://localhost:${APP_PORT}`), console.log(`[APP] Application is running on: http://localhost:${APP_PORT}`),
// console.log(`[APP] Swagger on: http://localhost:${APP_PORT}/api-docs`) console.log(`[APP] Swagger on: http://localhost:${APP_PORT}/api-docs`)
// ), ),
// ); );
async function runMessageQueue() { async function runMessageQueue() {
try { try {
await rabbitmqInit(); await rabbitmqInit();
@ -108,34 +126,7 @@ async function main() {
runMessageQueue(); runMessageQueue();
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);
});
});
wss.on("connection", (ws:any) => {
console.log("✅ Client connected to WebSocket");
ws.on("close", () => {
console.log("❌ Client disconnected");
});
ws.on("error", (error:any) => {
console.error("WebSocket error:", error);
});
});
server.listen(APP_PORT, APP_HOST, () => {
console.log(`[APP] Application is running on: http://localhost:${APP_PORT}`);
console.log(`[APP] Swagger on: http://localhost:${APP_PORT}/api-docs`);
console.log("[APP] HTTP Server is listening on current port");
});
} }
main(); main();