forked from mmukhin/psitsmike_example_2
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathapp.js
126 lines (108 loc) · 3.99 KB
/
app.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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
var app = require('express').createServer()
var io = require('socket.io').listen(app);
app.listen(80);
// routing
app.get('/', function (req, res) {
res.sendfile(__dirname + '/index.html');
});
app.get('/style.css', function (req, res) {
res.sendfile(__dirname + '/style.css');
});
app.get('/admin', function(req, res) {
res.sendfile(__dirname + '/admin.html');
});
// usernames which are currently connected to the chat
var usernames = {};
// rooms which are currently available in chat
var rooms = ['bedford'];
// history logging
var log = [];
function quicklog(s) {
nowish = new Date();
log.push(s + ' ' + nowish);
}
io.sockets.on('connection', function (socket) {
// when the client emits 'adduser', this listens and executes
socket.on('adduser', function(username){
// store the username in the socket session for this client
socket.username = username;
// store the room name in the socket session for this client
socket.room = 'bedford';
// add the client's username to the global list
usernames[username] = username;
// send client to a default
socket.join('bedford');
// echo to client they've connected
socket.emit('updatechat', 'SERVER', 'you have connected to ' + socket.room);
// echo to room that a person has connected to their room
socket.broadcast.to(socket.room).emit('updatechat', 'SERVER', username + ' has connected to this room');
socket.emit('updaterooms', rooms, 'bedford');
socket.emit('updateusers', usernames);
socket.broadcast.emit('updateusers', usernames);
logStr = username + ' joined the server at ';
quicklog(logStr);
});
// when the client emits 'sendchat', this listens and executes
socket.on('sendchat', function (data) {
// we tell the client to execute 'updatechat' with 2 parameters
io.sockets.in(socket.room).emit('updatechat', socket.username, data);
});
socket.on('switchRoom', function(newroom){
// leave the current room (stored in session)
socket.leave(socket.room);
// join new room, received as function parameter
socket.join(newroom);
socket.emit('updatechat', 'SERVER', 'you have connected to '+ newroom);
// sent message to OLD room
socket.broadcast.to(socket.room).emit('updatechat', 'SERVER', socket.username+' has left this room');
// update socket session room title
socket.room = newroom;
socket.broadcast.to(newroom).emit('updatechat', 'SERVER', socket.username+' has joined this room');
socket.emit('updaterooms', rooms, newroom);
});
// user creates room
socket.on('createRoom', function(roomName) {
rooms.push(roomName);
io.sockets.emit('addedRoom', rooms, roomName);
});
// TODO: move functionality within this script to separate js file
socket.on('command', function(commandString) {
cmd = commandString.split(' ');
if(cmd[0] == "deleteroom") {
//cool side effect: if you delete a room with people in it
//they still stay in that room, but nobody else can join it :)
roomToDelete = cmd[1];
newList = [];
for(var r in rooms) {
if( rooms[r] != roomToDelete) {
newList.push(rooms[r]);
}
}
rooms = newList;
io.sockets.emit('removedRoom', roomToDelete);
} else if(cmd[0] == 'createroom') {
roomToAdd = cmd[1];
rooms.push(roomToAdd);
io.sockets.emit('addedRoom', rooms, roomToAdd);
} else if(cmd[0] == 'imgurl') {
resource = cmd[1];
data = "<img src='" + cmd[1] + "'/>";
io.sockets.in(socket.room).emit('updatechat', socket.username, data);
}
});
// when the user disconnects.. perform this
socket.on('disconnect', function(){
// remove the username from global usernames list
delete usernames[socket.username];
// update list of users in chat, client-side
io.sockets.emit('updateusers', usernames);
// echo globally that this client has left
socket.broadcast.emit('updatechat', 'SERVER', socket.username + ' has disconnected');
socket.leave(socket.room);
quicklog(socket.username + ' disconnected at ');
});
// functions called from admin url
socket.on('showlog', function() {
socket.emit('showuseractivity', usernames, log);
});
});