RMQLoggerJS

This is a helper package for integrating logger to a rabbitmq enabled micro-service , thus allowing for logging to console or a remote service which parses and forwards the requests to a provisoned ElasticSearch.

Although this is primaraily a typescript module , you can use it in vanialla nodejs applications as well.

Usage - apigateway express app integration

import  RMQLogger  from  "rmqlogger";
import Api from "rmqlogger";

let  rmqLogger  =  new  RMQLogger();
rmqLogger.init(rabbitmqConf);

//Usage in express
...
app.use(apiAcessLogger);
...
//
function apiAcessLogger(req: any, res: any, next: any) {
  let dto = new Api();
  dto.Ip = req.connection.ip;
  dto.Url = req.url;
  dto.Method = req.method
  dto.Headers = req.headers;
  dto.Request = req.body;
  var oldSend = res.json;
  
  res.json = function (data: any) {
    if (data == false) {
      data = { response: false };
    }
    dto.StatusCode = res.statusCode;
    dto.Timestamp = new Date().toISOString();
    dto.Response = data;
    oldSend.apply(res, arguments);
    //
    rmqLogger.api(dto);
    console.log("Log Sent.")
  }
  next();
}

The rabbitmqConf parameter required by init() function is a JSON object which is as follows.

"rabbitmq": {
     "url": "amqp://user:passwd@localhost:5672",
     "app": "apigateway",
     "console" : false,
     "rmqExchangename" : "log-aggregator"
}

The url property is the url of your rabbitmq server ( not the managment url) and the app property provides a uniqe name to your service which is later used to identify the service and create queue names accordingly. The rmqExchangename is used to publish log events to the log-aggregator service which consumes this messages and forwards to ES much like logstash. The console flag if true prints all the logs to console else sends to Elasticsearch.