feat(event-paths): add path based event reporting with CollectorTransactionRaw 1.1.0 support

Author: dszakallas

.eslintrc.yml

@@ -1,8 +1,25 @@
+parserOptions:
+  ecmaVersion: 5
+  sourceType: script
 env:
   node: true
   mocha: true
 extends: standard
 rules:
-  no-unused-expressions: off
-  node/no-deprecated-api: off
-  standard/no-callback-literal: off
+  no-unused-expressions:
+  - off
+  node/no-deprecated-api:
+  - off
+  standard/no-callback-literal:
+  - off
+  strict:
+  - error
+  - safe
+  consistent-this:
+  - error
+  - self
+  no-multiple-empty-lines:
+  - error
+  - max: 1
+    maxEOF: 0
+    maxBOF: 0

example/app.js

@@ -1,4 +1,4 @@
-// index.js
+'use strict'
 var trace = require('@risingstack/trace')
 
 var app = require('express')()

example/config/trace.config.js

@@ -1,18 +1,19 @@
 /**
  * Your Trace configuration file
  */
+'use strict'
 
- module.exports = {
-   serviceName: 'your-awesome-app',
-   apiKey: 'KEEP.ME.SECRET',
-   ignoreHeaders: {
-     'user-agent': ['007']
-   },
-   ignorePaths: [
-     '/healtcheck'
-   ],
-   ignoreStatusCodes: [
-     401,
-     403
-   ]
- }
+module.exports = {
+  serviceName: 'your-awesome-app',
+  apiKey: 'KEEP.ME.SECRET',
+  ignoreHeaders: {
+    'user-agent': ['007']
+  },
+  ignorePaths: [
+    '/healtcheck'
+  ],
+  ignoreStatusCodes: [
+    401,
+    403
+  ]
+}

lib/agent/agent.js

@@ -1,3 +1,4 @@
+'use strict'
 var Timer = require('./timer')
 
 function Agent (name, interval, task) {
@@ -27,6 +28,6 @@ Agent.prototype.stop = function (callback) {
 
 Agent.prototype.initialize = function () { }
 
-Agent.prototype.destruct = function () { this.stop() }
+Agent.prototype.destruct = function (callback) { this.stop(callback) }
 
 module.exports = Agent

lib/agent/util/FakeStream.mock.js renamed to lib/agent/api/FakeStream.mock.js

@@ -1,3 +1,4 @@
+'use strict'
 var stream = require('stream')
 var util = require('util')
 

lib/agent/api/bufferStream.js

@@ -1,3 +1,4 @@
+'use strict'
 var https = require('https')
 var url = require('url')
 var util = require('util')
@@ -246,27 +247,27 @@ CollectorApi.prototype.sendDependencies = function (dependencies) {
 
 CollectorApi.prototype.getService = function (cb) {
   var opts = url.parse(this.COLLECTOR_API_SERVICE)
-  var _this = this
+  var self = this
   cb = cb || function () {}
 
   var payload = JSON.stringify({
-    name: _this.serviceName,
+    name: self.serviceName,
     version: '2',
     collector: {
-      language: _this.collectorLanguage,
+      language: self.collectorLanguage,
       version: libPackage.version
     },
     runtime: {
-      name: _this.system.processName,
-      version: _this.system.processVersion,
-      pid: _this.system.processId
+      name: self.system.processName,
+      version: self.system.processVersion,
+      pid: self.system.processId
     },
     machine: {
-      arch: _this.system.osArch,
-      platform: _this.system.osPlatform,
-      release: _this.system.osRelease,
-      hostname: _this.system.hostname,
-      cpus: _this.system.cpus
+      arch: self.system.osArch,
+      platform: self.system.osPlatform,
+      release: self.system.osRelease,
+      hostname: self.system.hostname,
+      cpus: self.system.cpus
     }
   })
   var req = https.request({
@@ -287,13 +288,13 @@ CollectorApi.prototype.getService = function (cb) {
     res.pipe(bl(function (err, resBuffer) {
       var response
 
-      var retryInterval = _this.baseRetryInterval
+      var retryInterval = self.baseRetryInterval
 
       if (err) {
         debug.error('getService', err)
         return setTimeout(function () {
           debug.warn('getService', format('Retrying with %d ms', retryInterval))
-          _this.getService()
+          self.getService()
         }, retryInterval)
       }
 
@@ -307,7 +308,7 @@ CollectorApi.prototype.getService = function (cb) {
         debug.error('getService', 'Service responded with ' + res.statusCode)
         return setTimeout(function () {
           debug.warn('getService', format('Retrying with %d ms', retryInterval))
-          _this.getService(cb)
+          self.getService(cb)
         }, retryInterval)
       }
 
@@ -317,7 +318,7 @@ CollectorApi.prototype.getService = function (cb) {
         return
       }
 
-      _this.serviceKey = response.key
+      self.serviceKey = response.key
       cb(null, response.key)
     }))
   })

lib/agent/api/index.js

@@ -1,8 +1,9 @@
+'use strict'
 var util = require('util')
 var url = require('url')
 var https = require('https')
-var FakeReadable = require('../util').FakeStream.FakeReadable
-var FakeWritable = require('../util').FakeStream.FakeWritable
+var FakeReadable = require('./FakeStream.mock').FakeReadable
+var FakeWritable = require('./FakeStream.mock').FakeWritable
 var CollectorApi = require('./')
 
 var expect = require('chai').expect

lib/agent/api/index.spec.js

@@ -1,3 +1,4 @@
+'use strict'
 var debug = require('../../utils/debug')('agent:control')
 
 var inherits = require('util').inherits
@@ -19,19 +20,19 @@ function Control (options) {
 inherits(Control, Agent)
 
 Control.prototype.getUpdates = function () {
-  var _this = this
+  var self = this
   this.collectorApi.getUpdates({
-    latestCommandId: _this.latestCommandId
+    latestCommandId: self.latestCommandId
   }, function (err, result) {
     if (err) {
       return debug.error('getUpdates', err)
     }
 
-    _this.latestCommandId = result.latestCommandId
+    self.latestCommandId = result.latestCommandId
 
     result.commands = result.commands || []
     result.commands.forEach(function (command) {
-      _this.controlBus.emit(command.command, command)
+      self.controlBus.emit(command.command, command)
     })
   })
 }

lib/agent/control/control.js

@@ -1,3 +1,4 @@
+'use strict'
 var expect = require('chai').expect
 
 var Control = require('./')