-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathindex.js
117 lines (99 loc) · 3.32 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
const express = require('express');
const app = express();
const server = require('http').createServer(app);
const PORT = process.env.PORT || 5000;
const path = require('path');
const io = require('socket.io')(server);
let socketList = {};
//for deployment
if (process.env.NODE_ENV === 'production') {
app.use(express.static(path.join(__dirname, 'teams-clone', 'build')))
app.get('/*', (req, res) => {
res.sendFile(path.join(__dirname, 'teams-clone', 'build', 'index.html'));
});
}
// Route
app.get('/ping', (req, res) => {
res
.send({
success: true,
})
.status(200);
});
// Socket
io.on('connection', (socket) => {
console.log(`New User connected: ${socket.id}`);
socket.on('disconnect', () => {
socket.disconnect();
console.log('User disconnected!');
});
socket.on('BE-check-user', ({ roomId, userName }) => {
let error = false;
io.sockets.in(roomId).clients((err, clients) => {
clients.forEach((client) => {
if (socketList[client] == userName) {
error = true;
}
});
socket.emit('FE-error-user-exist', { error });
});
});
/**
* Join Room
*/
socket.on('BE-join-room', ({ roomId, userName }) => {
// Socket Join RoomName
socket.join(roomId);
socketList[socket.id] = { userName, video: true, audio: true };
// Set User List
io.sockets.in(roomId).clients((err, clients) => {
try {
const users = [];
clients.forEach((client) => {
// Add User List
users.push({ userId: client, info: socketList[client] });
});
socket.broadcast.to(roomId).emit('FE-user-join', users);
// io.sockets.in(roomId).emit('FE-user-join', users);
} catch (e) {
io.sockets.in(roomId).emit('FE-error-user-exist', { err: true });
}
});
});
socket.on('BE-call-user', ({ userToCall, from, signal }) => {
io.to(userToCall).emit('FE-receive-call', {
signal,
from,
info: socketList[socket.id],
});
});
socket.on('BE-accept-call', ({ signal, to }) => {
io.to(to).emit('FE-call-accepted', {
signal,
answerId: socket.id,
});
});
socket.on('BE-send-message', ({ roomId, msg, sender }) => {
io.sockets.in(roomId).emit('FE-receive-message', { msg, sender });
});
socket.on('BE-leave-room', ({ roomId, leaver }) => {
delete socketList[socket.id];
socket.broadcast
.to(roomId)
.emit('FE-user-leave', { userId: socket.id, userName: [socket.id] });
io.sockets.sockets[socket.id].leave(roomId);
});
socket.on('BE-toggle-camera-audio', ({ roomId, switchTarget }) => {
if (switchTarget === 'video') {
socketList[socket.id].video = !socketList[socket.id].video;
} else {
socketList[socket.id].audio = !socketList[socket.id].audio;
}
socket.broadcast
.to(roomId)
.emit('FE-toggle-camera', { userId: socket.id, switchTarget });
});
});
server.listen(PORT, () => {
console.log(`listening to server on ${PORT}`);
});