-
Notifications
You must be signed in to change notification settings - Fork 30
/
server.js
110 lines (94 loc) · 3.14 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
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
var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var Redis = require('ioredis');
var redis = new Redis();
var users = [];
var groups = [];
http.listen(8005, function () {
console.log('Listening to port 8005');
});
redis.subscribe('private-channel', function() {
console.log('subscribed to private channel');
});
redis.subscribe('group-channel', function() {
console.log('subscribed to group channel');
});
redis.on('message', function(channel, message) {
message = JSON.parse(message);
console.log(message);
if (channel == 'private-channel') {
let data = message.data.data;
let receiver_id = data.receiver_id;
let event = message.event;
io.to(`${users[receiver_id]}`).emit(channel + ':' + message.event, data);
}
if (channel == 'group-channel') {
let data = message.data.data;
if (data.type == 2) {
let socket_id = getSocketIdOfUserInGroup(data.sender_id, data.group_id);
let socket = io.sockets.connected[socket_id];
socket.broadcast.to('group'+data.group_id).emit('groupMessage', data);
}
}
});
io.on('connection', function (socket) {
socket.on("user_connected", function (user_id) {
users[user_id] = socket.id;
io.emit('updateUserStatus', users);
console.log("user connected "+ user_id);
});
socket.on('disconnect', function() {
var i = users.indexOf(socket.id);
users.splice(i, 1, 0);
io.emit('updateUserStatus', users);
console.log(users);
});
socket.on('joinGroup', function(data) {
data['socket_id'] = socket.id;
if (groups[data.group_id]) {
console.log("group already exist");
var userExist = checkIfUserExistInGroup(data.user_id, data.group_id);
if (!userExist) {
groups[data.group_id].push(data);
socket.join(data.room);
} else {
var index = groups[data.group_id].map(function(o) {
return o.user_id;
}).indexOf(data.user_id);
groups[data.group_id].splice(index,1);
groups[data.group_id].push(data);
socket.join(data.room);
}
} else {
console.log("nwe group");
groups[data.group_id] = [data];
socket.join(data.room);
}
console.log('socket-id: '+ socket.id+' - user-id: '+data.user_id);
console.log(groups);
});
});
function checkIfUserExistInGroup(user_id, group_id) {
var group = groups[group_id];
var exist = false;
if (groups.length > 0) {
for (var i = 0; i < group.length; i++) {
if (group[i]['user_id'] == user_id) {
exist = true;
break;
}
}
}
return exist;
}
function getSocketIdOfUserInGroup(user_id, group_id) {
var group = groups[group_id];
if (groups.length > 0) {
for (var i = 0; i < group.length; i++) {
if (group[i]['user_id'] == user_id) {
return group[i]['socket_id'];
}
}
}
}