-
Notifications
You must be signed in to change notification settings - Fork 1
/
server.js
77 lines (64 loc) · 2.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
const http = require('http')
const crypto = require('crypto')
const logger = (...message) => {
process.env.DEBUG && console.log(...message)
}
const chatRoomAuth = {}
const handleRequest = (request, response) => {
const method = request.method.toLowerCase()
if (method !== 'get') {
response.writeHead(405)
response.end()
}
logger('Request: %s', request.url)
if (request.url === '/ping') {
response.end('pong')
} else if (request.url === '/status') {
response.end(JSON.stringify({
rooms: Object.keys(chatRoomAuth).length
}))
} else {
response.writeHead(404)
response.end()
}
}
const connectionHandler = (socket, io) => {
const getUsers = (roomName) => {
return Object.keys(io.sockets.adapter.rooms[roomName].sockets).map((id) => { return {id} })
}
socket.on('signal', payload => {
logger('signal: %s, payload: %o', socket.id, payload)
io.to(payload.userId).emit('signal', {
userId: socket.id,
signal: payload.signal
})
})
socket.on('ready', (roomName, password) => {
if (socket.room) socket.leave(socket.room)
if (chatRoomAuth[roomName] && chatRoomAuth[roomName].auth) {
if (chatRoomAuth[roomName].auth !== crypto.createHash('md5').update(password).digest("hex")) {
socket.emit('exception', { errorMessage: 'NOT_AUTHENTICATED' })
return
}
} else {
chatRoomAuth[roomName] = {}
chatRoomAuth[roomName]['auth'] = crypto.createHash('md5').update(password).digest("hex")
}
logger('Cache: %s', JSON.stringify(chatRoomAuth))
socket.room = roomName
socket.join(roomName)
socket.room = roomName
let users = getUsers(roomName)
logger('ready: %s, room: %s, users: %o', socket.id, roomName, users)
io.to(roomName).emit('users', {
initiator: socket.id,
users
})
})
}
const herokuDomain = process.env.HEROKUAPP_DOMAIN || 'scytale-server'
const server = http.createServer(handleRequest)
const io = require('socket.io')(server)
io.origins('http://localhost:* https://'+ herokuDomain +'.herokuapp.com:*')
io.on('connection', socket => connectionHandler(socket, io))
server.listen(process.env.PORT || '4000')