Skip to content

Commit

Permalink
feat<ServiceLogger>: added function to log external services calls
Browse files Browse the repository at this point in the history
  • Loading branch information
@manujvieira
manujvieira committed Sep 22, 2016
1 parent 411bcfc commit abe11b5
Show file tree
Hide file tree
Showing 2 changed files with 133 additions and 28 deletions.
152 changes: 128 additions & 24 deletions lib/index.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,9 @@ var uuid = require('uuid');
var Logger = function Logger(service, options) {

var _options = options || {},
_service = service || 'mrs';
_service = service || 'mrs';

this.init = function(options, service){
this.init = function (options, service) {
require('winston-logstash');
var _options = options || {};
this._service = options.service || 'mrs';
Expand All @@ -19,7 +19,7 @@ var Logger = function Logger(service, options) {
host: _options.host || 'localhost',
localhost: _options.host || 'localhost',
level: _options.level || 'silly',
max_connect_retries:-1
max_connect_retries: -1
}),
new (winston.transports.Console)({
colorize: true,
Expand All @@ -29,40 +29,40 @@ var Logger = function Logger(service, options) {
});
};

this.log = function(title, message, source, method, level){
this.log = function (title, message, source, method, level) {
var _this = this;
var msg = {
title: title,
message: message || {}
};
var src = source || '';
var mtd = method || '';
_this.logger.log(level, {message: msg, service: _service, source: src, method: mtd}, function(){
_this.logger.log(level, {message: msg, service: _service, source: src, method: mtd}, function () {

} );
});
};

this.debug = function(title, message, source, method) {
this.debug = function (title, message, source, method) {
this.log(title, message, source, method, 'debug');
};

this.verbose = function(title, message, source, method) {
this.verbose = function (title, message, source, method) {
this.log(title, message, source, method, 'verbose');
};

this.info = function(title, message, source, method) {
this.info = function (title, message, source, method) {
this.log(title, message, source, method, 'info');
};

this.warn = function(title, message, source, method) {
this.warn = function (title, message, source, method) {
this.log(title, message, source, method, 'warn');
};

this.error = function(title, message, source, method) {
this.error = function (title, message, source, method) {
this.log(title, message, source, method, 'error');
};

this.errorcallback = function(message, callback, source, method) {
this.errorcallback = function (message, callback, source, method) {
var _this = this;
_this.logger.log('error', {message: message, service: _service, source: source, method: method}, callback);
};
Expand All @@ -71,8 +71,8 @@ var Logger = function Logger(service, options) {

Logger.instance = null;

Logger.getInstance = function(){
if(this.instance === null)
Logger.getInstance = function () {
if (this.instance === null)
this.instance = new Logger();
return this.instance;
};
Expand All @@ -92,26 +92,26 @@ var Metric = function Metric() {
expressWinston.requestWhitelist.push('stack');


this.set = function(status, url, duration, callback) {
this.set = function (status, url, duration, callback) {
var _this = this;
var message = {status: status, url: url, duration:duration};
_this.metric.log('info',{message: message}, callback);
var message = {status: status, url: url, duration: duration};
_this.metric.log('info', {message: message}, callback);
};

this.getRequestId = function(){
this.getRequestId = function () {
return uuid.v4();
};
this.init = function(options, service){
this.init = function (options, service) {
require('winston-logstash');
var _options = options || {};
this._service = service || 'mrs';
this.transports= [
this.transports = [
new (winston.transports.Logstash)({
port: _options.port || 28778,
node_name: _options.node_name || 'mrs-metric',
host: _options.host || 'localhost',
localhost: _options.host || 'localhost',
max_connect_retries:-1
max_connect_retries: -1
}),
new (winston.transports.Console)({
colorize: true,
Expand All @@ -122,7 +122,7 @@ var Metric = function Metric() {
transports: this.transports
});

this.specialMdd = function(req, res, next){
this.specialMdd = function (req, res, next) {
var info = winston.exception.getAllInfo("");
req.date = info.date;
req.process = info.process;
Expand All @@ -146,11 +146,115 @@ var Metric = function Metric() {

Metric.instance = null;

Metric.getInstance = function(){
if(this.instance === null)
Metric.getInstance = function () {
if (this.instance === null)
this.instance = new Metric();
return this.instance;
};


var ServiceLogger = function ServiceLogger(options, service, host) {

var _options = options || {},
_service = service || 'mrs',
_host = host || 'localhost',
_client = '',
_protocol = '';

this.init = function (options, service, host) {
var Elasticsearch = require('winston-elasticsearch');

this._options = options || {};
this._service = service || 'mrs';
this._host = host || 'localhost';

this.logger = new (winston.Logger)({
transports: [
new Elasticsearch({
index: this._options.index || '',
clientOpts: {
host: this._options.host || ''
},
messageType: this._options.type || '',
transformer: function (logData) {
const transformed = {};
transformed.uuid = logData.meta.uuid;
transformed.message = logData.meta.message;
transformed['time'] = new Date().toISOString();
transformed.host = logData.meta.host || '';
transformed.client = logData.meta.client || '';
transformed.service = logData.meta.service || 'mrs';
transformed.orgCode = logData.meta.orgCode;
transformed.appCode = logData.meta.appCode;
transformed.method = logData.meta.method;
transformed.protocol = logData.meta.protocol || '';
transformed.url = logData.meta.url || '';
transformed.request = logData.meta.request || '';
transformed.request_header = logData.meta.request_header || '';
transformed.request_body = logData.meta.request_body || '';
transformed.request_time = logData.meta.request_time || undefined;
transformed.response_body = logData.meta.response_body || '';
transformed.response_time = logData.meta.response_time || undefined;
transformed.status = logData.meta.status || '';
transformed.elapsed_time = logData.meta.elapsed_time || '';
//transformed.fields = logData.meta;
return transformed;
}
})
]
});
};

this.logRequest = function (uuid, options) {

this.logger.info({
uuid: uuid,
message: "req",
host: this._host,
client: this._client,
protocol: this._protocol,
service: this._service,
orgCode: options.orgCode,
appCode: options.appCode,
method: options.method,
url: options.url,
request: JSON.stringify(options),
request_time: new Date().toISOString()
});
};

this.logResponse = function (uuid, request, response, status, elapsed_time) {

this.logger.info({
uuid: uuid,
message: "resp",
host: this._host,
client: this._client,
protocol: request.uri.protocol,
service: this._service,
orgCode: request.orgCode,
appCode: request.appCode,
method: request.method,
url: request.href || '',
request_header: JSON.stringify(request.headers),
request_body: JSON.stringify(request.body),
response_body: JSON.stringify(response),
response_time: new Date().toISOString(),
status: status,
elapsed_time: elapsed_time
});
}
}

ServiceLogger.instance = null;

ServiceLogger.getInstance = function () {
if (this.instance === null)
this.instance = new ServiceLogger();
return this.instance;
};


module.exports.ServiceLogger = ServiceLogger.getInstance();
module.exports.Logger = Logger.getInstance();
module.exports.Metric = Metric.getInstance();
9 changes: 5 additions & 4 deletions package.json
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "mrs-node-logger",
"version": "1.0.2",
"version": "1.1.0",
"description": "nodejs logging logstash",
"main": "index.js",
"scripts": {
Expand All @@ -11,9 +11,10 @@
},
"license": "ISC",
"dependencies": {
"winston": "^1.0.0",
"winston-logstash": "^0.2.11",
"express-winston":"0.3.1",
"winston": "^1.0.0",
"winston-elasticsearch": "^0.4.0",
"winston-logstash": "^0.2.11",
"express-winston":"0.3.1",
"uuid":"^2.0.1"
}
}

0 comments on commit abe11b5

Please sign in to comment.