aboutsummaryrefslogtreecommitdiff
path: root/src/server/Websocket/Websocket.ts
diff options
context:
space:
mode:
authorMohammad Amoush <47069173+mamoush34@users.noreply.github.com>2020-02-08 13:23:00 -0500
committerMohammad Amoush <47069173+mamoush34@users.noreply.github.com>2020-02-08 13:23:00 -0500
commit38d0d467ee4c27709d482bfea7505e3f3729a455 (patch)
treeb885f6f270fd8a913e03d5ad7167d34d19b513c8 /src/server/Websocket/Websocket.ts
parentd3db291c2587bf1284f9d0a8ee7d06fd8ec7a252 (diff)
Ui Update and stream track stoppage added
Diffstat (limited to 'src/server/Websocket/Websocket.ts')
-rw-r--r--src/server/Websocket/Websocket.ts16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/server/Websocket/Websocket.ts b/src/server/Websocket/Websocket.ts
index 96694bf72..30e7d6129 100644
--- a/src/server/Websocket/Websocket.ts
+++ b/src/server/Websocket/Websocket.ts
@@ -47,25 +47,25 @@ export namespace WebSocket {
}
socket.on('message', function (message) {
- log('Client said: ', message);
+ console.log('Client said: ', message);
// for a real app, would be room-only (not broadcast)
socket.broadcast.emit('message', message);
});
socket.on('create or join', function (room) {
- log('Received request to create or join room ' + room);
+ console.log('Received request to create or join room ' + room);
var clientsInRoom = socket.adapter.rooms[room];
var numClients = clientsInRoom ? Object.keys(clientsInRoom.sockets).length : 0;
- log('Room ' + room + ' now has ' + numClients + ' client(s)');
+ console.log('Room ' + room + ' now has ' + numClients + ' client(s)');
if (numClients === 0) {
socket.join(room);
- log('Client ID ' + socket.id + ' created room ' + room);
+ console.log('Client ID ' + socket.id + ' created room ' + room);
socket.emit('created', room, socket.id);
} else if (numClients === 1) {
- log('Client ID ' + socket.id + ' joined room ' + room);
+ console.log('Client ID ' + socket.id + ' joined room ' + room);
socket.in(room).emit('join', room);
socket.join(room);
socket.emit('joined', room, socket.id);
@@ -107,9 +107,9 @@ export namespace WebSocket {
Utils.AddServerHandler(socket, MessageStore.DeleteFields, ids => DeleteFields(socket, ids));
Utils.AddServerHandlerCallback(socket, MessageStore.GetRefField, GetRefField);
Utils.AddServerHandlerCallback(socket, MessageStore.GetRefFields, GetRefFields);
- Utils.AddServerHandler(socket, MessageStore.NotifyRoommates, message => HandleRoommateNotification(socket, message));
- Utils.AddServerHandler(socket, MessageStore.HangUpCall, message => HandleHangUp(socket, message));
- Utils.AddRoomHandler(socket, "create or join", HandleCreateOrJoin);
+ //Utils.AddServerHandler(socket, MessageStore.NotifyRoommates, message => HandleRoommateNotification(socket, message));
+ //Utils.AddServerHandler(socket, MessageStore.HangUpCall, message => HandleHangUp(socket, message));
+ //Utils.AddRoomHandler(socket, "create or join", HandleCreateOrJoin);
disconnect = () => {
socket.broadcast.emit("connection_terminated", Date.now());