2025-03-07 12:36:03 +07:00
|
|
|
import { WebSocket } from "ws";
|
|
|
|
|
import { wss } from "../app";
|
2025-03-06 18:25:27 +07:00
|
|
|
|
2025-03-07 12:36:03 +07:00
|
|
|
export async function sendWebSocket(data:any){
|
|
|
|
|
wss.clients.forEach((client: any) => {
|
|
|
|
|
if (client.readyState === WebSocket.OPEN) {
|
|
|
|
|
const message = JSON.stringify(data);
|
|
|
|
|
console.log("📤 Sending data to client:", message);
|
|
|
|
|
client.send(message, (err:any) => {
|
|
|
|
|
if (err) {
|
|
|
|
|
console.error("❌ Error sending message:", err);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}
|