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
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
var express = require('express');
var app = express();
var session = require('express-session');
var http = require('http').Server(app);
var io = require('socket.io')(http);
var sharp = require('sharp');
const ChatSingleton = require('./chat');
const Chat = ChatSingleton.instance;
let connect_sid = Date.now();
app.use(session({
secret: 'keyboard cat',
resave: true,
saveUninitialized: true,
cookie: { secure: false }
}));
app.get('/', function (req, res) {
console.log(new Date().getTime() + ":[get: /]");
//connect_sid = req.sessionID;
console.log('connect_sid', connect_sid);
res.sendFile(__dirname + '/public/index.html');
});
app.get('/customer', function (req, res) {
console.log(new Date().getTime() + ":[get: /customer]");
//connect_sid = req.sessionID;
console.log('connect_sid', connect_sid);
res.sendFile(__dirname + '/public/customer.html');
});
app.get('/operator', function (req, res) {
console.log(new Date().getTime() + ":[get: /]");
//connect_sid = req.sessionID;
console.log('connect_sid', connect_sid);
res.sendFile(__dirname + '/public/operator.html');
});
app.use(express.static('public'));
http.listen(3001, function () {
console.log('listening on *:3001');
});
io.on('connection', (socket) => {
const EVENTS = Chat.EVENTS;
const ROLES = Chat.ROLES;
const DEFAULT_ROOMS = Chat.DEFAULT_ROOMS;
let event = '';
event = Chat.event(EVENTS.CONNECTION.OPEN);
io.emit(event.type, event.data);
// create user and send updates
socket.on(EVENTS.CONNECTION.OPEN, (data) => {
console.log('CONNECTION:OPEN', data, connect_sid);
// create new user
Chat.createUser(connect_sid, data.name, data.role);
console.log('user', Chat.getUser(connect_sid));
// join user own room
socket.join(Chat.getUser(connect_sid).room);
// join operators room if role is operator
if (Chat.getUser(connect_sid).role === ROLES.OPERATOR) {
socket.join(DEFAULT_ROOMS.OPERATORS);
}
// send customers updated list to operators
event = Chat.event(EVENTS.CUSTOMERS.LIST.UPDATE, Chat.getUsersByRole(ROLES.CUSTOMER));
io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);
// send operators updated list to operators
event = Chat.event(EVENTS.OPERATORS.LIST.UPDATE, Chat.getUsersByRole(ROLES.OPERATOR));
io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);
// send rooms updated list to operators
event = Chat.event(EVENTS.ROOMS.LIST.UPDATE, Chat.rooms);
io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);
});
// join room
socket.on(EVENTS.ROOM.JOIN, (data) => {
const ownerRoom = Chat.getUser(connect_sid).joinOwnerRoom(data.user);
socket.join(ownerRoom);
event = Chat.event(EVENTS.ROOM.JOIN, ownerRoom);
io.to(ownerRoom).emit(event.type, event.data);
console.log('join room', Chat.getUser(connect_sid).name, event.data);
});
// send text message
socket.on(EVENTS.SEND.MESSAGE, (data) => {
const room = Chat.getUser(connect_sid).role === ROLES.CUSTOMER ? Chat.getUser(connect_sid).room : data.room;
const message = Chat.message(data, room);
event = Chat.event(EVENTS.SEND.MESSAGE, message);
io.to(room).emit(event.type, event.data);
console.log('sendMessage', event);
});
socket.on('disconnect', () => {
console.log('disconnect', connect_sid);
if (!Chat.getUser(connect_sid)) {
return
}
const userRole = Chat.getUser(connect_sid).role;
Chat.deleteUser(Chat.getUser(connect_sid));
// send operators updated list to operators
if (userRole === ROLES.OPERATOR) {
event = Chat.event(EVENTS.OPERATORS.LIST.UPDATE, Chat.getUsersByRole(ROLES.OPERATOR));
io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);
}
// send customers updated list to operators
if (userRole === ROLES.CUSTOMER) {
event = Chat.event(EVENTS.CUSTOMERS.LIST.UPDATE, Chat.getUsersByRole(ROLES.CUSTOMER));
io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);
}
});
});
|