feat(logging): add data logging to reporters

RisingStack · Sep 1, 2015 · cefc26d · cefc26d
1 parent 9a3f2ea
commit cefc26d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/lib/collector.js b/lib/collector.js
@@ -14,6 +14,7 @@ var getNamespace = require('continuation-local-storage').getNamespace;
  * @extends events.EventEmitter
  */
 function Collector(options) {
+  debug('collector is initializing...');
   events.EventEmitter.call(this);
 
   this.collectInterval = options.collectInterval;
@@ -32,11 +33,13 @@ function Collector(options) {
   this.formattableLogFile = config.logFilePath + config.logFilePrefix + '%s.log';
 
   this._updateLogFile();
+  debug('collector initialized');
 }
 
 util.inherits(Collector, events.EventEmitter);
 
 Collector.prototype.startCollecting = function () {
+  debug('collector started collecting');
   var _this = this;
   this.intervalId = setInterval(function () {
     if (_this.isSampled && (typeof _this.service !== 'undefined')) {
@@ -47,10 +50,12 @@ Collector.prototype.startCollecting = function () {
 };
 
 Collector.prototype.stopCollecting = function () {
+  debug('collector stopped collecting');
   clearInterval(this.intervalId);
 };
 
 Collector.prototype.setService = function (serviceId) {
+  debug('collector service is set to: ', serviceId);
   this.service = serviceId;
 };
 

diff --git a/lib/reporters/trace.js b/lib/reporters/trace.js
@@ -47,7 +47,9 @@ TraceReporter.prototype.send = function (data, callback) {
       return callback(err);
     });
 
-  req.write(JSON.stringify(data));
+  var payload = JSON.stringify(data);
+  debug('sending data to trace servers: ', payload);
+  req.write(payload);
   req.end();
 };