-
Notifications
You must be signed in to change notification settings - Fork 3
/
Copy pathapp.js
105 lines (89 loc) · 3.85 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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
/**
* Module dependencies.
*/
var express = require('express'),
connect = require('connect'),
cookie = require('cookie'),
app = express(),
server = require('http').createServer(app),
io = require('socket.io').listen(server),
path = require('path'),
port = process.env.PORT || 8080,
sessionStore = new connect.middleware.session.MemoryStore(),
sessionSecret = "some private string",
cookieParser = express.cookieParser(sessionSecret),
SessionSockets = require('session.socket.io'),
sessionSockets = new SessionSockets(io, sessionStore, cookieParser);
// configure express
app.configure(function () {
app.set('port', port);
app.set('views', __dirname + '/views');
app.set('view engine', 'jade');
app.use(express.static(path.join(__dirname, 'public')));
app.use(express.methodOverride());
app.use(express.favicon());
app.use(express.logger('dev'));
app.use(cookieParser);
app.use(express.session({"store": sessionStore }));
app.use(express.json());
app.use(express.urlencoded());
app.use(app.router);
});
/**
* Routing
*/
require('./routes/index.js')(app, sessionStore);
/**
* Configure Sockets
*/
io.set('log level', 2);
io.set('transports', [ 'websocket', 'xhr-polling' ]);
//io.set('close timeout', 10);
io.set('authorization', function (handshakeData, callback) {
if (handshakeData.headers.cookie) {
// Read cookies from handshake headers
var cookies = cookie.parse(handshakeData.headers.cookie);
// We're now able to retrieve session ID
var sessionID;
if (cookies['connect.sid'])
sessionID = connect.utils.parseSignedCookie(cookies['connect.sid'], sessionSecret);
// No session? Refuse connection
if (!sessionID) {
callback('No session', false);
} else {
// On récupère la session utilisateur, et on en extrait son username
sessionStore.get(sessionID, function (err, session) {
if (!err && session && session.user) {
// OK, on accepte la connexion
callback(null, true);
} else {
// Session incomplète, ou non trouvée
callback(err || 'User not authenticated', false);
}
});
}
}
});
//Game controller
var mainCtrl = require('./controllers/main.js'),
gameCtrl = require('./controllers/game.js');
sessionSockets.on('connection', function(err, socket, session){
mainCtrl.connect(socket, session);
// Main
socket.on('disconnect', function() { mainCtrl.disconnect(socket, session); });
socket.on('chat:sendMessage', function(data){ mainCtrl.chatSendMessage(socket, session, data); });
socket.on('lobby:getGameList', function() { mainCtrl.lobbyGetGameList(socket); });
socket.on('library:get', function() { mainCtrl.libraryGet(socket, session); });
socket.on('library:saveDeck', function(data){ mainCtrl.librarySaveDeck(socket, session, data); });
//Game
socket.on('game:create', function(data){ gameCtrl.createGame(socket, session, data); });
socket.on('game:join', function(data){ gameCtrl.joinGame(io, socket, session, data); });
socket.on('game:info', function(data){ gameCtrl.getGameInfo(socket, session, data); });
socket.on('game:quit', function() { gameCtrl.quitGame(socket, session); });
socket.on('game:phase0', function(data){ gameCtrl.phase0Game(io, socket, session, data); });
socket.on('game:phase1', function(data){ gameCtrl.phase1Game(io, socket, session, data); });
socket.on('game:phase2', function(data){ gameCtrl.phase2Game(io, socket, session, data); });
});
//launch server
server.listen(port);
console.log('Express server listening on port ' + port);