foss/excalidraw-room
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Updating server code to latest implementation (#3)

Browse Source
This commit is contained in:
Edwin Lin 2020-03-09 14:15:59 -07:00 committed by GitHub
parent 01a7c634e4
commit 3fc9c404d4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
index.ts
View File

@ -36,7 +36,7 @@ io.on('connection', socket => {
console.log(`${socket.id} has joined ${roomID}`); console.log(`${socket.id} has joined ${roomID}`);
socket.join(roomID); socket.join(roomID);
if (io.sockets.adapter.rooms[roomID].length <= 1) { if (io.sockets.adapter.rooms[roomID].length <= 1) {
io.to(`${socket.id}`).emit('new-user-first-in-room'); io.to(`${socket.id}`).emit('first-in-room');
} else { } else {
socket.broadcast.to(roomID).emit('new-user', socket.id); socket.broadcast.to(roomID).emit('new-user', socket.id);
} }
@ -45,22 +45,10 @@ io.on('connection', socket => {
io.sockets.adapter.rooms[roomID].length, io.sockets.adapter.rooms[roomID].length,
); );
}); });
socket.on(
'new-user-send-update', socket.on('server-broadcast', (roomID: string, encryptedData: ArrayBuffer, iv: Uint8Array) => {
(socketID: string, encryptedData: ArrayBuffer) => {
console.log(`sending new user update to ${socketID}`);
io.to(`${socketID}`).emit('new-user-receive-update', encryptedData);
},
);
socket.on('send-update', (roomID, encryptedData) => {
console.log(`${socket.id} sends update to ${roomID}`); console.log(`${socket.id} sends update to ${roomID}`);
socket.broadcast.to(roomID).emit('receive-update', encryptedData); socket.broadcast.to(roomID).emit('client-broadcast', encryptedData, iv);
});
socket.on('send-mouse-location', (roomID, pointerCoords) => {
console.log(`${socket.id} sends mouse update to ${roomID}`);
socket.broadcast
.to(roomID)
.emit('receive-mouse-location', socket.id, pointerCoords);
}); });
socket.on('disconnecting', () => { socket.on('disconnecting', () => {