2011-11-18 23:17:41 +08:00
|
|
|
var http = require('http');
|
|
|
|
var url = require('url');
|
2011-11-19 05:54:16 +08:00
|
|
|
var fs = require('fs');
|
2011-11-18 23:17:41 +08:00
|
|
|
|
2011-11-19 04:44:28 +08:00
|
|
|
var winston = require('winston');
|
2011-11-24 02:14:18 +08:00
|
|
|
var connect = require('connect');
|
2011-11-19 04:44:28 +08:00
|
|
|
|
2011-11-19 04:51:38 +08:00
|
|
|
var DocumentHandler = require('./lib/document_handler');
|
2011-11-19 04:44:28 +08:00
|
|
|
|
2011-11-19 05:57:23 +08:00
|
|
|
// Load the configuration and set some defaults
|
2011-11-19 05:54:16 +08:00
|
|
|
var config = JSON.parse(fs.readFileSync('config.js', 'utf8'));
|
2011-11-19 05:57:23 +08:00
|
|
|
config.port = config.port || 7777;
|
|
|
|
config.host = config.host || 'localhost';
|
2011-11-19 05:54:16 +08:00
|
|
|
|
2011-11-19 06:26:25 +08:00
|
|
|
// Set up the logger
|
|
|
|
if (config.logging) {
|
|
|
|
try {
|
|
|
|
winston.remove(winston.transports.Console);
|
|
|
|
} catch(er) { }
|
|
|
|
var detail, type;
|
|
|
|
for (var i = 0; i < config.logging.length; i++) {
|
|
|
|
detail = config.logging[i];
|
|
|
|
type = detail.type;
|
|
|
|
delete detail.type;
|
|
|
|
winston.add(winston.transports[type], detail);
|
|
|
|
}
|
|
|
|
}
|
2011-11-18 23:17:41 +08:00
|
|
|
|
2011-11-19 07:04:24 +08:00
|
|
|
// build the store from the config on-demand - so that we don't load it
|
|
|
|
// for statics
|
2011-11-22 11:03:50 +08:00
|
|
|
if (!config.storage) {
|
|
|
|
config.storage = { type: 'file' };
|
|
|
|
}
|
|
|
|
if (!config.storage.type) {
|
|
|
|
config.storage.type = 'file';
|
|
|
|
}
|
|
|
|
var Store = require('./lib/' + config.storage.type + '_document_store');
|
|
|
|
var preferredStore = new Store(config.storage);
|
2011-11-18 23:17:41 +08:00
|
|
|
|
2011-11-22 22:22:37 +08:00
|
|
|
// Send the static documents into the preferred store, skipping expirations
|
|
|
|
for (var name in config.documents) {
|
|
|
|
var path = config.documents[name];
|
|
|
|
fs.readFile(path, 'utf8', function(err, data) {
|
|
|
|
if (data && !err) {
|
|
|
|
preferredStore.set(name, data, function(cb) {
|
|
|
|
winston.info('loaded static document', { name: name, path: path });
|
|
|
|
}, true);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
winston.warn('failed to load static document', { name: name, path: path });
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
// Configure the document handler
|
|
|
|
var documentHandler = new DocumentHandler({
|
|
|
|
store: preferredStore,
|
|
|
|
maxLength: config.maxLength,
|
|
|
|
keyLength: config.keyLength
|
|
|
|
});
|
|
|
|
|
2011-11-24 02:14:18 +08:00
|
|
|
// Set the server up with a static cache
|
|
|
|
connect.createServer(
|
2011-11-24 05:34:22 +08:00
|
|
|
// First look for api calls
|
2011-11-24 02:14:18 +08:00
|
|
|
connect.router(function(app) {
|
|
|
|
// add documents
|
|
|
|
app.post('/documents', function(request, response, next) {
|
|
|
|
return documentHandler.handlePost(request, response);
|
|
|
|
});
|
|
|
|
// get documents
|
|
|
|
app.get('/documents/:id', function(request, response, next) {
|
2011-11-24 04:45:28 +08:00
|
|
|
return documentHandler.handleGet(request.params.id, response);
|
2011-11-24 02:14:18 +08:00
|
|
|
});
|
|
|
|
}),
|
|
|
|
// Otherwise, static
|
|
|
|
connect.static(__dirname + '/static', { maxAge: config.staticMaxAge }),
|
2011-11-24 05:34:22 +08:00
|
|
|
// Then we can loop back - and everything else should be a token,
|
|
|
|
// so route it back to /index.html
|
2011-11-24 02:14:18 +08:00
|
|
|
connect.router(function(app) {
|
|
|
|
app.get('/:id', function(request, response, next) {
|
2011-11-24 05:34:22 +08:00
|
|
|
request.url = request.originalUrl = '/index.html';
|
2011-11-24 02:14:18 +08:00
|
|
|
next();
|
|
|
|
});
|
|
|
|
}),
|
2011-11-24 05:34:22 +08:00
|
|
|
// And then let static take over
|
2011-11-24 02:14:18 +08:00
|
|
|
connect.static(__dirname + '/static', { maxAge: config.staticMaxAge })
|
|
|
|
).listen(config.port, config.host);
|
2011-11-19 05:57:23 +08:00
|
|
|
|
2011-11-19 05:58:21 +08:00
|
|
|
winston.info('listening on ' + config.host + ':' + config.port);
|