| // Generated by CoffeeScript 1.12.7 |
| (function() { |
| var GenericApp, execute_request, fake_response, fs, http, querystring, url, utils; |
| |
| url = require('url'); |
| |
| querystring = require('querystring'); |
| |
| fs = require('fs'); |
| |
| http = require('http'); |
| |
| utils = require('./utils'); |
| |
| execute_request = function(app, funs, req, res, data) { |
| var fun, results, x; |
| try { |
| results = []; |
| while (funs.length > 0) { |
| fun = funs.shift(); |
| req.last_fun = fun; |
| results.push(data = app[fun](req, res, data, req.next_filter)); |
| } |
| return results; |
| } catch (error1) { |
| x = error1; |
| if (typeof x === 'object' && 'status' in x) { |
| if (x.status === 0) { |
| return; |
| } else if ('handle_' + x.status in app) { |
| app['handle_' + x.status](req, res, x); |
| } else { |
| app['handle_error'](req, res, x); |
| } |
| } else { |
| app['handle_error'](req, res, x); |
| } |
| return app['log_request'](req, res, true); |
| } |
| }; |
| |
| fake_response = function(req, res) { |
| var headers; |
| headers = { |
| 'Connection': 'close' |
| }; |
| res.writeHead = function(status, user_headers) { |
| var k, r, x; |
| if (user_headers == null) { |
| user_headers = {}; |
| } |
| r = []; |
| r.push('HTTP/' + req.httpVersion + ' ' + status + ' ' + http.STATUS_CODES[status]); |
| utils.objectExtend(headers, user_headers); |
| for (k in headers) { |
| r.push(k + ': ' + headers[k]); |
| } |
| r = r.concat(['', '']); |
| try { |
| res.write(r.join('\r\n')); |
| } catch (error1) { |
| x = error1; |
| } |
| try { |
| return res.end(); |
| } catch (error1) { |
| x = error1; |
| } |
| }; |
| return res.setHeader = function(k, v) { |
| return headers[k] = v; |
| }; |
| }; |
| |
| exports.generateHandler = function(app, dispatcher) { |
| return function(req, res, head) { |
| var allowed_methods, found, funs, i, j, l, len, m, method, path, ref, row; |
| if (typeof res.writeHead === "undefined") { |
| fake_response(req, res); |
| } |
| utils.objectExtend(req, url.parse(req.url, true)); |
| req.start_date = new Date(); |
| found = false; |
| allowed_methods = []; |
| for (j = 0, len = dispatcher.length; j < len; j++) { |
| row = dispatcher[j]; |
| method = row[0], path = row[1], funs = row[2]; |
| if (path.constructor !== Array) { |
| path = [path]; |
| } |
| m = req.pathname.match(path[0]); |
| if (!m) { |
| continue; |
| } |
| if (!req.method.match(new RegExp(method))) { |
| allowed_methods.push(method); |
| continue; |
| } |
| for (i = l = 1, ref = path.length; 1 <= ref ? l < ref : l > ref; i = 1 <= ref ? ++l : --l) { |
| req[path[i]] = m[i]; |
| } |
| funs = funs.slice(0); |
| funs.push('log_request'); |
| req.next_filter = function(data) { |
| return execute_request(app, funs, req, res, data); |
| }; |
| req.next_filter(head); |
| found = true; |
| break; |
| } |
| if (!found) { |
| if (allowed_methods.length !== 0) { |
| app['handle_405'](req, res, allowed_methods); |
| } else { |
| app['handle_404'](req, res); |
| } |
| app['log_request'](req, res, true); |
| } |
| }; |
| }; |
| |
| exports.GenericApp = GenericApp = (function() { |
| function GenericApp() {} |
| |
| GenericApp.prototype.handle_404 = function(req, res, x) { |
| if (res.finished) { |
| return x; |
| } |
| res.writeHead(404, {}); |
| res.end(); |
| return true; |
| }; |
| |
| GenericApp.prototype.handle_405 = function(req, res, methods) { |
| res.writeHead(405, { |
| 'Allow': methods.join(', ') |
| }); |
| res.end(); |
| return true; |
| }; |
| |
| GenericApp.prototype.handle_error = function(req, res, x) { |
| if (res.finished) { |
| return x; |
| } |
| if (typeof x === 'object' && 'status' in x) { |
| res.writeHead(x.status, {}); |
| res.end(x.message || ""); |
| } else { |
| try { |
| res.writeHead(500, {}); |
| res.end("500 - Internal Server Error"); |
| } catch (error1) { |
| x = error1; |
| } |
| this.log('error', 'Exception on "' + req.method + ' ' + req.href + '" in filter "' + req.last_fun + '":\n' + (x.stack || x)); |
| } |
| return true; |
| }; |
| |
| GenericApp.prototype.log_request = function(req, res, data) { |
| var td; |
| td = (new Date()) - req.start_date; |
| this.log('info', req.method + ' ' + req.url + ' ' + td + 'ms ' + (res.finished ? res.statusCode : '(unfinished)')); |
| return data; |
| }; |
| |
| GenericApp.prototype.log = function(severity, line) { |
| return console.log(line); |
| }; |
| |
| GenericApp.prototype.expose_html = function(req, res, content) { |
| if (res.finished) { |
| return content; |
| } |
| if (!res.getHeader('Content-Type')) { |
| res.setHeader('Content-Type', 'text/html; charset=UTF-8'); |
| } |
| return this.expose(req, res, content); |
| }; |
| |
| GenericApp.prototype.expose_json = function(req, res, content) { |
| if (res.finished) { |
| return content; |
| } |
| if (!res.getHeader('Content-Type')) { |
| res.setHeader('Content-Type', 'application/json'); |
| } |
| return this.expose(req, res, JSON.stringify(content)); |
| }; |
| |
| GenericApp.prototype.expose = function(req, res, content) { |
| if (res.finished) { |
| return content; |
| } |
| if (content && !res.getHeader('Content-Type')) { |
| res.setHeader('Content-Type', 'text/plain'); |
| } |
| if (content) { |
| res.setHeader('Content-Length', content.length); |
| } |
| res.writeHead(res.statusCode); |
| res.end(content, 'utf8'); |
| return true; |
| }; |
| |
| GenericApp.prototype.serve_file = function(req, res, filename, next_filter) { |
| var a; |
| a = function(error, content) { |
| if (error) { |
| res.writeHead(500); |
| res.end("can't read file"); |
| } else { |
| res.setHeader('Content-length', content.length); |
| res.writeHead(res.statusCode, res.headers); |
| res.end(content, 'utf8'); |
| } |
| return next_filter(true); |
| }; |
| fs.readFile(filename, a); |
| throw { |
| status: 0 |
| }; |
| }; |
| |
| GenericApp.prototype.cache_for = function(req, res, content) { |
| var exp; |
| res.cache_for = res.cache_for || 365 * 24 * 60 * 60; |
| res.setHeader('Cache-Control', 'public, max-age=' + res.cache_for); |
| exp = new Date(); |
| exp.setTime(exp.getTime() + res.cache_for * 1000); |
| res.setHeader('Expires', exp.toGMTString()); |
| return content; |
| }; |
| |
| GenericApp.prototype.h_no_cache = function(req, res, content) { |
| res.setHeader('Cache-Control', 'no-store, no-cache, no-transform, must-revalidate, max-age=0'); |
| return content; |
| }; |
| |
| GenericApp.prototype.expect_form = function(req, res, _data, next_filter) { |
| var data; |
| data = new Buffer(0); |
| req.on('data', (function(_this) { |
| return function(d) { |
| return data = utils.buffer_concat(data, new Buffer(d, 'binary')); |
| }; |
| })(this)); |
| req.on('end', (function(_this) { |
| return function() { |
| var q; |
| data = data.toString('utf-8'); |
| switch ((req.headers['content-type'] || '').split(';')[0]) { |
| case 'application/x-www-form-urlencoded': |
| q = querystring.parse(data); |
| break; |
| case 'text/plain': |
| case '': |
| q = data; |
| break; |
| default: |
| _this.log('error', "Unsupported content-type " + req.headers['content-type']); |
| q = void 0; |
| } |
| return next_filter(q); |
| }; |
| })(this)); |
| throw { |
| status: 0 |
| }; |
| }; |
| |
| GenericApp.prototype.expect_xhr = function(req, res, _data, next_filter) { |
| var data; |
| data = new Buffer(0); |
| req.on('data', (function(_this) { |
| return function(d) { |
| return data = utils.buffer_concat(data, new Buffer(d, 'binary')); |
| }; |
| })(this)); |
| req.on('end', (function(_this) { |
| return function() { |
| var q; |
| data = data.toString('utf-8'); |
| switch ((req.headers['content-type'] || '').split(';')[0]) { |
| case 'text/plain': |
| case 'T': |
| case 'application/json': |
| case 'application/xml': |
| case '': |
| case 'text/xml': |
| q = data; |
| break; |
| default: |
| _this.log('error', 'Unsupported content-type ' + req.headers['content-type']); |
| q = void 0; |
| } |
| return next_filter(q); |
| }; |
| })(this)); |
| throw { |
| status: 0 |
| }; |
| }; |
| |
| return GenericApp; |
| |
| })(); |
| |
| }).call(this); |