-
Notifications
You must be signed in to change notification settings - Fork 1
/
index.js
87 lines (68 loc) · 2.3 KB
/
index.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
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'),
Audio = require('./api/models/AudioModel'),
Setting = require('./api/models/SettingModel'),
bodyParser = require('body-parser'),
session = require("express-session")({
secret: "my-secret",
resave: true,
saveUninitialized: true
}),
sharedSession = require("express-socket.io-session"),
fileUpload = require('express-fileupload');
app.use(session);
app.use(fileUpload());
io.use(sharedSession(session, {
autoSave:true
}));
mongoose.Promise = global.Promise;
// TODO: solve multiple databases promise
var promise = mongoose.connect('mongodb://localhost/AVdb', {
useMongoClient: true
});
app.set('view engine', 'pug');
app.use(express.static(path.join(__dirname, 'public')));
app.use("/uploads", express.static(path.join(__dirname, 'uploads')));
app.use(bodyParser({uploadDir:'/backup'}));
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
var routes = require('./api/routes/AudioVideoRoutes');
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(port, function(){
console.log('*** AUDIO/VIDEO server run on: http://localhost:' + port);
});