-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathindex.js
More file actions
126 lines (110 loc) · 3.52 KB
/
index.js
File metadata and controls
126 lines (110 loc) · 3.52 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
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
const express = require('express');
const app = express();
const http = require('http').Server(app);
const fetch = require('node-fetch');
const io = require('socket.io')(http);
// https://coolors.co/000000-ffffff-494949-7c7a7a-ff5d73
const rooms = {};
app.set('view engine', 'ejs');
app.get('/', (req, res) => {
res.render('pages/index');
});
app.get('/draw', (req, res) => {
res.render('pages/draw');
});
app.use(express.static('public'));
http.listen(8080, () => {
console.log('App is live on 8080.');
});
io.on('connection', (socket) => {
console.log(`${socket.id} has connected`);
socket.on('disconnect', () => {
if(socket.room){
io.to(socket.room).emit('clientCount', numClientsInRoom(socket.room));
}
console.log(`${socket.id} has disconnected`);
})
socket.on('join', room => {
room = room.toLowerCase();
console.log(`${socket.id} has joined room "${room}"`);
socket.join(room);
socket.room = room;
io.to(room).emit('clientCount', numClientsInRoom(room));
})
socket.on('createRoom', passphrase => {
const id = makeId(7);
rooms[id] ={
roomId: id,
passphrase
};
socket.emit('created', JSON.stringify({
roomId: id
}));
socket.join(id);
socket.room = id;
console.log(`${socket.id} has created room "${id}"`);
io.to(id).emit('clientCount', numClientsInRoom(id));
})
socket.on('draw', data => {
if(!socket.room){
socket.disconnect();
return;
}
data = JSON.parse(data);
if(rooms[socket.room] && data.passcode === rooms[socket.room].passphrase){
const jsonRPCRequest = {
jsonrpc: "2.0",
method: "generateIntegers",
params:
{
apiKey: process.env.API_KEY,
n: 1,
min: data.lowerLimit,
max: data.upperLimit,
replacement: true,
base: 10
},
id: 15200
};
fetch("https://api.random.org/json-rpc/2/invoke", {
method: "POST",
headers: {
"content-type": "application/json",
},
body: JSON.stringify(jsonRPCRequest),
}).then((response) => {
if (response.status === 200) {
response.json().then(data => {
if(data.result)
io.to(socket.room).emit('drawResult', data.result.random.data[0])
});
} else if (jsonRPCRequest.id !== undefined) {
console.error('Error');
}
})
}
})
socket.on('startConfetti', () => {
io.emit('confetti', true);
})
})
const numClientsInRoom = (room) => {
if(!io.sockets.adapter.rooms[room])
return;
try{
const clients = io.sockets.adapter.rooms[room].sockets;
return Object.keys(clients).length;
}catch(e){
console.error(e);
}
return 0;
}
const makeId = (length) => {
var result = '';
var characters = 'abcdefghijklmnopqrstuvwxyz0123456789';
var charactersLength = characters.length;
for ( var i = 0; i < length; i++ ) {
result += characters.charAt(Math.floor(Math.random() * charactersLength));
}
return result;
}