-
Notifications
You must be signed in to change notification settings - Fork 2
/
server.js
113 lines (88 loc) · 2.88 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
111
112
113
#!/usr/bin/env node
var express = require('express');
var app = express();
var path = require("path");
var rooms = {
public: new Set(),
private: new Set()
}
app.use(express.static('public'));
app.get('/', function (req, res) {
res.redirect('/public-0');
})
app.get('/public-:id', function(req , res){
console.log("Serving views/index.html")
res.sendFile('index.html', {root: path.join(__dirname, 'views')});
});
app.get('/private-:id', function(req , res){
console.log("Serving views/index.html")
res.sendFile('index.html', {root: path.join(__dirname, 'views')});
});
app.get('/create-private-room', async function(req, res){
var url = setNamespace('private', await getNewRoomNumber());
res.redirect('/'+url);
});
async function getNewRoomNumber()
{
var token = await random();
while(rooms['private'].has(token))
{
token = await random();
}
return token;
}
async function random()
{
return new Promise(res => {
require('crypto').randomBytes(24, function(err, buffer){
res(buffer.toString('hex'))
});
});
}
var port = process.env.PORT || 8080;
var server = app.listen(port);
var io = require('socket.io')(server);
var positions = {}; // holds position of all mouse cursors
var total = 0;
// io.on('connection', function(socket){
// });
setNamespace("public", 0);
function setNamespace(privacy, id){
if(rooms[privacy].has(id))
{
return;
}
rooms[privacy].add(id);
var namespace = io.of(`/${privacy}-${id}`);
namespace.on('connection', function(socket){
console.log('someone connected');
socket.on('drawing', function(msg){
socket.broadcast.emit('drawing', msg);
});
socket.on('drawing', function(msg){
socket.broadcast.emit('drawing', msg);
});
// assign the socket a numeric id
socket.number = ++total; // socket.id used by socket.io, leave it alone
// send the positions of everyone else
socket.broadcast.emit(positions);
// send updated mouse position to everyone else
socket.on('mouse movement', function (mouse) {
positions[socket.number] = mouse.pos;
socket.broadcast.emit('mouse update', { id: socket.number, pos: mouse.pos });
});
// let everyone else know about the disconnection
socket.on('disconnect', function () {
delete positions[socket.number];
socket.broadcast.emit('mouse disconnect', { id: socket.number });
});
socket.on('chat-message', function(msg){
socket.broadcast.emit('chat-message', msg);
});
});
return `${privacy}-${id}`;
};
var setPublicNamespace = (id)=>setNamespace("private", id);
var setPrivateNamespace = (id)=>setNamespace("public", id);
console.log(`${new Date()}`);
console.log(`Server is listening on port ${port}`);