-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathsocket.js
More file actions
63 lines (50 loc) · 1.32 KB
/
socket.js
File metadata and controls
63 lines (50 loc) · 1.32 KB
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
var server = require('http').Server();
var io = require('socket.io')(server);
var Redis = require('ioredis');
var redis = new Redis();
var nickList = [];
server.listen(3000);
io.on('connect', function(socket) {
socket.on('user-connect', function(user) {
if(isConnected(socket)) {
socket.emit('message-internal', "already connected");
return;
}
socket.nick = user.nick;
socket.channel = user.channel;
nickList.push(user.nick);
// tell the user they've been connected and
// tell what their info is
socket.emit('user-sync', {
nick: user.nick,
channel: user.channel
});
});
socket.on('user-exists', function(nick) {
if(! isConnected(socket, true)) {
return;
}
var isHere = nickList.indexOf(nick) > -1;
socket.emit('user-here', {
nick: nick,
result: isHere
});
});
socket.on('user-tell', function(message) {
socket.emit('message-internal', message);
});
socket.on('message-send', function(message) {
if(! isConnected(socket, true)) {
return;
}
io.emit('message-retrieve', message);
});
});
function isConnected(socket, shouldInform) {
var isConnected = socket.nick && socket.channel;
if(shouldInform == true && ! isConnected) {
socket.emit('message-internal', "not yet connected.");
socket.emit('message-internal', "/help for more info.");
}
return isConnected
}