-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathserver.js
More file actions
80 lines (63 loc) · 2.09 KB
/
server.js
File metadata and controls
80 lines (63 loc) · 2.09 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
var express = require('express'),
app = express(),
path = require('path'),
http = require('http').Server(app),
io = require('socket.io')(http),
geoip = require('geoip-lite'),
port = process.env.PORT || 3000,
cookie = require('cookie'),
mongoose = require('mongoose'),
Task = require('./api/models/todoListModel'), //created model loading here
bodyParser = require('body-parser'),
session = require("express-session")({
secret: "my-secret",
resave: true,
saveUninitialized: true
}),
sharedSession = require("express-socket.io-session");
app.use(session);
io.use(sharedSession(session, {
autoSave:true
}));
mongoose.Promise = global.Promise;
// TODO: solve multiple databases promise
var promise = mongoose.connect('mongodb://localhost/Tododb', {
useMongoClient: true
});
app.set('view engine', 'pug');
app.use(express.static(path.join(__dirname, 'views')));
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
var routes = require('./api/routes/todoListRoutes');
routes(app);
var nicknames = [];
function filterNullValues(i) {
return (i!=null);
}
io.on('connection', function(socket){
// TODO: create model for rooms: socket.join('all');
io.sockets.emit('connectCounter', Object.keys(io.sockets.sockets).filter(filterNullValues).length);
socket.on('new user', function(data){
var tmp = {
id: socket.id,
data: data,
geo: geoip.lookup(data.publicIp)
};
nicknames.push(tmp);
updateNicknames(nicknames);
});
function updateNicknames(x){
io.sockets.emit('usernames', x);
}
socket.on('disconnect', function(data){
var index=nicknames.map(function(x){
return x.id;
}).indexOf(socket.id);
nicknames.splice(index,1);
io.sockets.emit('connectCounter', Object.keys(io.sockets.sockets).filter(filterNullValues).length);
updateNicknames(nicknames);
});
});
http.listen(3000, function(){
console.log('*** REST API server run on: http://localhost:' + port);
});