-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathserver.js
61 lines (60 loc) · 1.75 KB
/
server.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
var app = require("express")();
var http = require("http").Server(app);
var io = require("socket.io")(http);
var groupIds = {};
var users = {};
const addToGroup = (groupId, username, socket) => {
if (groupIds[groupId] === undefined)
groupIds[groupId] = [{ username, socket }];
else groupIds[groupId].push({ username, socket });
};
const removeFromGroup = id => {
var groupId = users[id].groupId;
if (!groupId) return;
if (!groupIds[groupId]) return;
groupIds[groupId] = groupIds[groupId].filter(
member => member.socket.id !== id
);
if (!groupIds[groupId].length) delete groupIds[groupId];
};
io.on("connection", socket => {
socket.on("disconnect", () => {
if (!users[socket.id]) return;
var groupId = users[socket.id].groupId;
removeFromGroup(socket.id);
if (groupIds[groupId])
groupIds[groupId].forEach(member => {
member.socket.emit("message", {
info: true,
username: "chat-bot",
value: users[socket.id].username + " has left the chat"
});
});
delete users[socket.id];
});
socket.on("join", ({ groupId, username }) => {
users[socket.id] = { groupId, username };
socket.emit("message", {
info: true,
username: "chat-bot",
value: "You have joined the chat"
});
if (groupIds[groupId] !== undefined)
groupIds[groupId].forEach(member => {
member.socket.emit("message", {
info: true,
username: "chat-bot",
value: username + " has joined the chat"
});
});
addToGroup(groupId, username, socket);
});
socket.on("send", ({ groupId, value, username }) => {
if (!!!groupIds[groupId]) addToGroup(groupId, username, socket);
groupIds[groupId].forEach(member => {
if (member.socket.id !== socket.id)
member.socket.emit("message", { value, username });
});
});
});
http.listen(8080);