-
Notifications
You must be signed in to change notification settings - Fork 0
/
index.js
65 lines (49 loc) · 1.4 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
const app = require('http').createServer(handler);
const io = require("socket.io")(app, {
cors: {
origin: "http://localhost:9000",
methods: ["GET", "POST"],
// allowedHeaders: ["my-custom-header"],
credentials: true
}
});
const PORT = 8080;
let users = [];
app.listen(PORT);
function handler(req, res) {
res.writeHead(200);
res.end('Socket.io running!');
}
io.on('connection', socket => {
let activeUser = {};
socket.emit('users update', users);
socket.on('message', msg => {
console.info(`New message: ${msg}`);
io.emit('message', msg);
});
socket.on('login', user => {
console.info(`User login: ${user.username}`);
users = users.concat(user);
activeUser = user;
io.emit('login', user);
io.emit('users update', users);
});
socket.on('logout', user => {
console.info(`User logout: ${user.username}`);
users = users.filter(listUser => listUser.username !== user.username);
activeUser = {};
io.emit('logout', user);
io.emit('users update', users);
});
socket.on('disconnect', () => {
if (activeUser && activeUser.username) {
console.info(`User disconnected: ${activeUser.username}`);
users = users.filter(
listUser => listUser.username !== activeUser.username
);
io.emit('logout', activeUser);
io.emit('users update', users);
}
});
});
console.info(`Socket.io started in port ${PORT}`);