123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285 |
- /*!
- * Morgan | Connect - logger
- * Copyright(c) 2010 Sencha Inc.
- * Copyright(c) 2011 TJ Holowaychuk
- * MIT Licensed
- */
- /**
- * Module dependencies.
- */
- var bytes = require('bytes');
- /*!
- * Default log buffer duration.
- */
- var defaultBufferDuration = 1000;
- /**
- * Log requests with the given `options` or a `format` string.
- *
- * See README.md for documentation of options and formatting.
- *
- * @param {String|Function|Object} format or options
- * @return {Function} middleware
- * @api public
- */
- exports = module.exports = function logger(options) {
- if (options && typeof options !== 'object') {
- options = { format: options };
- } else {
- options = options || {};
- }
- // output on request instead of response
- var immediate = options.immediate;
- // check if log entry should be skipped
- var skip = options.skip || function () { return false; };
- // format name
- var fmt = exports[options.format] || options.format || exports.default;
- // compile format
- if ('function' != typeof fmt) fmt = compile(fmt);
- // options
- var stream = options.stream || process.stdout
- , buffer = options.buffer;
- // buffering support
- if (buffer) {
- var realStream = stream
- var buf = []
- var timer = null
- var interval = 'number' == typeof buffer
- ? buffer
- : defaultBufferDuration
- // flush function
- var flush = function(){
- timer = null
- if (buf.length) {
- realStream.write(buf.join(''));
- buf.length = 0;
- }
- }
- // swap the stream
- stream = {
- write: function(str){
- if (timer === null) {
- timer = setTimeout(flush, interval)
- }
- buf.push(str);
- }
- };
- }
- return function logger(req, res, next) {
- req._startAt = process.hrtime();
- req._startTime = new Date;
- req._remoteAddress = req.connection && req.connection.remoteAddress;
- function logRequest(){
- res.removeListener('finish', logRequest);
- res.removeListener('close', logRequest);
- if (skip(req, res)) return;
- var line = fmt(exports, req, res);
- if (null == line) return;
- stream.write(line + '\n');
- };
- // immediate
- if (immediate) {
- logRequest();
- // proxy end to output logging
- } else {
- res.on('finish', logRequest);
- res.on('close', logRequest);
- }
- next();
- };
- };
- /**
- * Compile `fmt` into a function.
- *
- * @param {String} fmt
- * @return {Function}
- * @api private
- */
- function compile(fmt) {
- fmt = fmt.replace(/"/g, '\\"');
- var js = ' return "' + fmt.replace(/:([-\w]{2,})(?:\[([^\]]+)\])?/g, function(_, name, arg){
- return '"\n + (tokens["' + name + '"](req, res, "' + arg + '") || "-") + "';
- }) + '";'
- return new Function('tokens, req, res', js);
- };
- /**
- * Define a token function with the given `name`,
- * and callback `fn(req, res)`.
- *
- * @param {String} name
- * @param {Function} fn
- * @return {Object} exports for chaining
- * @api public
- */
- exports.token = function(name, fn) {
- exports[name] = fn;
- return this;
- };
- /**
- * Define a `fmt` with the given `name`.
- *
- * @param {String} name
- * @param {String|Function} fmt
- * @return {Object} exports for chaining
- * @api public
- */
- exports.format = function(name, fmt){
- exports[name] = fmt;
- return this;
- };
- /**
- * Default format.
- */
- exports.format('default', ':remote-addr - - [:date] ":method :url HTTP/:http-version" :status :res[content-length] ":referrer" ":user-agent"');
- /**
- * Short format.
- */
- exports.format('short', ':remote-addr - :method :url HTTP/:http-version :status :res[content-length] - :response-time ms');
- /**
- * Tiny format.
- */
- exports.format('tiny', ':method :url :status :res[content-length] - :response-time ms');
- /**
- * dev (colored)
- */
- exports.format('dev', function(tokens, req, res){
- var color = 32; // green
- var status = res.statusCode;
- if (status >= 500) color = 31; // red
- else if (status >= 400) color = 33; // yellow
- else if (status >= 300) color = 36; // cyan
- var fn = compile('\x1b[90m:method :url \x1b[' + color + 'm:status \x1b[90m:response-time ms - :res[content-length]\x1b[0m');
- return fn(tokens, req, res);
- });
- /**
- * request url
- */
- exports.token('url', function(req){
- return req.originalUrl || req.url;
- });
- /**
- * request method
- */
- exports.token('method', function(req){
- return req.method;
- });
- /**
- * response time in milliseconds
- */
- exports.token('response-time', function(req, res){
- if (!res._header || !req._startAt) return '';
- var diff = process.hrtime(req._startAt);
- var ms = diff[0] * 1e3 + diff[1] * 1e-6;
- return ms.toFixed(3);
- });
- /**
- * UTC date
- */
- exports.token('date', function(){
- return new Date().toUTCString();
- });
- /**
- * response status code
- */
- exports.token('status', function(req, res){
- return res._header ? res.statusCode : null;
- });
- /**
- * normalized referrer
- */
- exports.token('referrer', function(req){
- return req.headers['referer'] || req.headers['referrer'];
- });
- /**
- * remote address
- */
- exports.token('remote-addr', function(req){
- if (req.ip) return req.ip;
- if (req._remoteAddress) return req._remoteAddress;
- if (req.connection) return req.connection.remoteAddress;
- return undefined;
- });
- /**
- * HTTP version
- */
- exports.token('http-version', function(req){
- return req.httpVersionMajor + '.' + req.httpVersionMinor;
- });
- /**
- * UA string
- */
- exports.token('user-agent', function(req){
- return req.headers['user-agent'];
- });
- /**
- * request header
- */
- exports.token('req', function(req, res, field){
- return req.headers[field.toLowerCase()];
- });
- /**
- * response header
- */
- exports.token('res', function(req, res, field){
- return (res._headers || {})[field.toLowerCase()];
- });
|