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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
/*
* kyle's nodejs server
*
* by default app.settings.env is set to 'development' (process.env.ENV_VARIABLE)
* $ NODE_ENV=production node app.js
*
* ToDo:
* - redis for active users
* - load from db once, and refetch when necessary
* - if (verbose) log; can choose to use process.env and/or app.settings.env
* - jsdoc?
*
*/
var util = require('util');
var crypto = require('crypto')
var path = require('path');
var http = require('http');
var express = require('express');
var io = require('socket.io');
var RedisStore = require('connect-redis')(express);
var db = require('./mydb.js');
var myplatform = require('./router/myplatform.js');
var user = require('./router/user.js');
var index = require('./router/index.js');
var app = express(); /* return function accepting req/res */
var server = http.createServer(app); /* this method takes in a function/callback that it feeds with req/res on 'request' event */
var sio = io.listen(server);
function deadend(req, res, next) {
util.log('[deadend] couldn\'t serve, requested path: ' + req.url);
/* collect possible info here */
/* if (critical_wrong) then; throw new Error('da fuck this entity is doing!'); */
res.send(404, 'page not found\n');
}
function error_handler(err, req, res, next) { /* error handling, arity of 4 */
console.error(err.stack);
res.send(500, 'something broke!\n');
}
/* delete req.session.user on close connection? */
function restrict(req, res, next) {
if (req.session.user)
{
util.log('[restrict] granted ' + req.session.user);
next();
}
else
{
util.log('[restrict] blocked access');
res.send(401, 'access restricted\n');
/* res.redirect(/login); */
}
}
app.configure(function() {
app.set('views', __dirname + '/views');
app.set('view engine', 'jade'); /* no need to specify .jade extension */
app.set('view options', { pretty: true }); /* avoid html source all in on line or so */
app.use(express.logger('dev'));
app.use(express.favicon());
app.use(express.compress()); /* gzip */
app.use(express.bodyParser()); /* creates req.body which req.param() uses */
app.use(express.cookieParser()); /* req.session.* can be populated with user defined vars */
app.use(express.session({ secret: "keyboard cat", store: new RedisStore() })); /* populates req.session */
app.use(app.router); /* when there's no match, we go static file handling below */
app.use(require('stylus').middleware(__dirname + '/public'));
app.use(express.static(path.join(__dirname, 'public'))); /* GET /stylesheets/style.css */
app.use(deadend); /* we get here if we couldn't serve */
app.use(error_handler); /* is this correct? */
});
app.get('/', index.root);
app.get('/create', user.create_get);
app.post('/create', user.create_post);
app.get('/login', user.login_get);
app.post('/login', user.login_post);
//app.all('*', auth.check); /* not applicable, I want router list to hit the end in case auth fails */
app.get('/sys/:id([a-z]+)', restrict, myplatform.system);
server.listen(8081, function() {
util.log(util.format('[server] listening on port %d in %s mode', this.address().port, app.settings.env));
})
.on('error', function(e) {
util.log('[server] failed creating server, errno: ' + e.errno);
})
.on('close', function() {
util.log('[server] server shutdown');
})
.on('clientError', function(exception) {
util.log('[server] ' + exception);
})
.on('connection', function(socket) {
/* socket.myid = crypto.createHash('md5').update(socket.remoteAddress + ':' + socket.remotePort).digest('hex'); */
socket.myip = socket.remoteAddress;
socket.myport = socket.remotePort;
util.log('[server] new node connection from ' + socket.remoteAddress + ':' + socket.remotePort);
socket.on('close', function() {
/* delete connected_clients */
util.log('[server] client ' + this.myip + ':' + this.myport + ' closed node connection\n');
});
});
sio.sockets.on('connection', function(socket) {
var endpoint = socket.manager.handshaken[socket.id].address;
/* socket.myid = crypto.createHash('md5').update(socket.remoteAddress + ':' + socket.remotePort).digest('hex'); */
/* user defined fields */
socket.myip = endpoint.address;
socket.myport = endpoint.port;
util.log('[server] new socket.io connection from ' + endpoint.address + ':' + endpoint.port);
/* after client logs in, expect him to emit 'login' event, emit should contain tag name and 'logged in' check should be done */
socket.on('login', function(tag) {
var client = null;
if ((client = get_connected_client(tag)) != undefined) {
util.log('[socket.io] ' + tag + ' is active');
client.tag.iosocket = socket;
}
});
socket.on('disconnect', function() {
/* delete connected_clients */
util.log('[server] client ' + this.myip + ':' + this.myport + ' disconnected from socket.io connection\n');
});
});
|
