vnfmarket/src/main/webapp/vnfmarket/node_modules/log4js/lib/appenders/gelf.js

   1 "use strict";
   2 var zlib = require('zlib');
   3 var layouts = require('../layouts');
   4 var levels = require('../levels');
   5 var dgram = require('dgram');
   6 var util = require('util');
   7 var debug = require('../debug')('GELF Appender');
   8
   9 var LOG_EMERG=0;    // system is unusable
  10 var LOG_ALERT=1;    // action must be taken immediately
  11 var LOG_CRIT=2;     // critical conditions
  12 var LOG_ERR=3;      // error conditions
  13 var LOG_ERROR=3;    // because people WILL typo
  14 var LOG_WARNING=4;  // warning conditions
  15 var LOG_NOTICE=5;   // normal, but significant, condition
  16 var LOG_INFO=6;     // informational message
  17 var LOG_DEBUG=7;    // debug-level message
  18
  19 var levelMapping = {};
  20 levelMapping[levels.ALL] = LOG_DEBUG;
  21 levelMapping[levels.TRACE] = LOG_DEBUG;
  22 levelMapping[levels.DEBUG] = LOG_DEBUG;
  23 levelMapping[levels.INFO] = LOG_INFO;
  24 levelMapping[levels.WARN] = LOG_WARNING;
  25 levelMapping[levels.ERROR] = LOG_ERR;
  26 levelMapping[levels.FATAL] = LOG_CRIT;
  27
  28 var client;
  29
  30 /**
  31  * GELF appender that supports sending UDP packets to a GELF compatible server such as Graylog
  32  *
  33  * @param layout a function that takes a logevent and returns a string (defaults to none).
  34  * @param host - host to which to send logs (default:localhost)
  35  * @param port - port at which to send logs to (default:12201)
  36  * @param hostname - hostname of the current host (default:os hostname)
  37  * @param facility - facility to log to (default:nodejs-server)
  38  */
  39  /* jshint maxstatements:21 */
  40 function gelfAppender (layout, host, port, hostname, facility) {
  41   var config, customFields;
  42   if (typeof(host) === 'object') {
  43     config = host;
  44     host = config.host;
  45     port = config.port;
  46     hostname = config.hostname;
  47     facility = config.facility;
  48     customFields = config.customFields;
  49   }
  50
  51   host = host || 'localhost';
  52   port = port || 12201;
  53   hostname = hostname || require('os').hostname();
  54   layout = layout || layouts.messagePassThroughLayout;
  55
  56   var defaultCustomFields = customFields || {};
  57
  58   if(facility) {
  59     defaultCustomFields._facility = facility;
  60   }
  61
  62   client = dgram.createSocket("udp4");
  63
  64   process.on('exit', function() {
  65     if (client) client.close();
  66   });
  67
  68   /**
  69    * Add custom fields (start with underscore )
  70    * - if the first object passed to the logger contains 'GELF' field,
  71    *   copy the underscore fields to the message
  72    * @param loggingEvent
  73    * @param msg
  74    */
  75   function addCustomFields(loggingEvent, msg){
  76
  77     /* append defaultCustomFields firsts */
  78     Object.keys(defaultCustomFields).forEach(function(key) {
  79       // skip _id field for graylog2, skip keys not starts with UNDERSCORE
  80       if (key.match(/^_/) && key !== "_id") {
  81         msg[key] = defaultCustomFields[key];
  82       }
  83     });
  84
  85     /* append custom fields per message */
  86     var data = loggingEvent.data;
  87     if (!Array.isArray(data) || data.length === 0) return;
  88     var firstData = data[0];
  89
  90     if (!firstData.GELF) return; // identify with GELF field defined
  91     // Remove the GELF key, some gelf supported logging systems drop the message with it
  92     delete firstData.GELF;
  93     Object.keys(firstData).forEach(function(key) {
  94       // skip _id field for graylog2, skip keys not starts with UNDERSCORE
  95       if (key.match(/^_/) || key !== "_id") {
  96         msg[key] = firstData[key];
  97       }
  98     });
  99
 100     /* the custom field object should be removed, so it will not be looged by the later appenders */
 101     loggingEvent.data.shift();
 102   }
 103
 104   function preparePacket(loggingEvent) {
 105     var msg = {};
 106     addCustomFields(loggingEvent, msg);
 107     msg.short_message = layout(loggingEvent);
 108
 109     msg.version="1.1";
 110     msg.timestamp = msg.timestamp || new Date().getTime() / 1000; // log should use millisecond
 111     msg.host = hostname;
 112     msg.level = levelMapping[loggingEvent.level || levels.DEBUG];
 113     return msg;
 114   }
 115
 116   function sendPacket(packet) {
 117     client.send(packet, 0, packet.length, port, host, function(err) {
 118       if (err) { console.error(err); }
 119     });
 120   }
 121
 122   return function(loggingEvent) {
 123     var message = preparePacket(loggingEvent);
 124     zlib.gzip(new Buffer(JSON.stringify(message)), function(err, packet) {
 125       if (err) {
 126         console.error(err.stack);
 127       } else {
 128         if (packet.length > 8192) {
 129           debug("Message packet length (" + packet.length + ") is larger than 8k. Not sending");
 130         } else {
 131           sendPacket(packet);
 132         }
 133       }
 134     });
 135   };
 136 }
 137
 138 function configure(config) {
 139   var layout;
 140   if (config.layout) {
 141     layout = layouts.layout(config.layout.type, config.layout);
 142   }
 143   return gelfAppender(layout, config);
 144 }
 145
 146 function shutdown(cb) {
 147   if (client) {
 148     client.close(cb);
 149     client = null;
 150   }
 151 }
 152
 153 exports.appender = gelfAppender;
 154 exports.configure = configure;
 155 exports.shutdown = shutdown;