: adds payload to send to connected clients
This commit is contained in:
@@ -9,19 +9,21 @@ export class RestWebSocket {
|
||||
const router = express.Router();
|
||||
|
||||
router.post("/broadcast", (req: Request, res: Response) => {
|
||||
const message: string = req.body.message;
|
||||
const payload: string = JSON.stringify(req.body.payload);
|
||||
|
||||
this.webSocketServer.broadcast(message);
|
||||
console.log(payload);
|
||||
|
||||
this.webSocketServer.broadcast(payload);
|
||||
|
||||
res.status(200).send("Broadcast erfolgreich.");
|
||||
});
|
||||
|
||||
router.post("/send-message", (req, res) => {
|
||||
const message = req.body.message;
|
||||
const payload = JSON.stringify(req.body.payload);
|
||||
const users: Array<string> = req.body.users;
|
||||
|
||||
users.forEach((user) =>
|
||||
this.webSocketServer.sendMessageToUser(user, message),
|
||||
this.webSocketServer.sendMessageToUser(user, payload),
|
||||
);
|
||||
|
||||
res.status(200).send("OK");
|
||||
|
||||
+1
-1
@@ -40,7 +40,7 @@ export class ExtendedWebSocketServer {
|
||||
public broadcast(message: string) {
|
||||
this.wss.clients.forEach((client) => {
|
||||
if (client.readyState === WebSocket.OPEN) {
|
||||
client.send(message);
|
||||
client.send(message, { binary: false });
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user