-
Notifications
You must be signed in to change notification settings - Fork 0
/
app.js
91 lines (75 loc) · 2.37 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
'use strict';
process.env.NODE_ENV = process.env.NODE_ENV || 'development';
const express = require('express'),
bodyParser = require('body-parser'),
morgan = require('morgan'),
compress = require('compression'),
cors = require('cors'),
path = require('path'),
os = require('os'),
port = process.env.PORT || 3000;
const app = express();
if (process.env.NODE_ENV === 'development') {
app.use(morgan('dev'));
} else if (process.env.NODE_ENV === 'production') {
app.use(compress());
}
app.use(cors());
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
/*app.get('/client', (req, res) => {
res.sendFile(path.join(__dirname, 'client/index.html'));
});
app.use(express.static(path.join(__dirname, './client')));*/
app.get('/client', (req, res) => {
res.send('Client endpoint');
});
app.get('/', (req, res) => {
res.send('Ok');
//res.end();
});
app.get('*', (req, res) => {
res.send('Ok');
//res.end();
});
const server = app.listen(port, () => {
console.log(`Server listening on port ${port}`);
});
const io = require('socket.io')(server);
let initiator = {
connected: false,
id: ''
};
let connections = 0;
io.on('connection', socket => {
connections++;
let isInitiator = 'jumas2017';
let room = socket.handshake.query.room;
if (room === isInitiator) {
console.log('Initiator connected...');
initiator.connected = true;
initiator.id = socket.id;
socket.emit('initiator', { initiatorID: initiator.id });
socket.broadcast.emit('client', { hasInitiator: initiator.connected, initiatorID: initiator.id });
} else {
console.log('Client connected...');
socket.emit('client', { hasInitiator: initiator.connected, initiatorID: initiator.id });
if (initiator.connected) {
io.to(initiator.id).emit('ready', socket.id);
}
}
socket.on('message', message => {
socket.broadcast.emit('message', { message: message, id: socket.id });
});
socket.on('disconnect', () => {
connections--;
if (socket.id === initiator.id) {
console.log('Initiator disconnected...');
initiator.connected = false;
initiator.id = '';
socket.broadcast.emit('noInitiator');
} else {
console.log('Client disconnected...');
}
});
});