fix: traceId

lib/requests/index.js

@@ -4,7 +4,8 @@ const {
  ForceDestroy
 } = require('./errors');
 
-let cc = 0;
+let traceIdCounter = 0;
+
 const createRequest = ({
  timeout,
  match,
@@ -13,10 +14,12 @@ const createRequest = ({
  config = {},
  counter,
  tag,
+ traceId,
  waitTime
 }) => {
  const request = {
  tag,
+ traceId,
  idx: counter,
  // consist of previous request meta that needs to be matched against
  match,
@@ -75,7 +78,8 @@ const Request = ({
  meta: {
  method,
  direction,
- config
+ config,
+ traceId = ++traceIdCounter
  } = {}
  } = {},
  timeout
@@ -88,6 +92,7 @@ const Request = ({
  direction,
  config,
  counter,
+ traceId,
  tag,
  waitTime
  });
@@ -128,4 +133,4 @@ const Request = ({
  return o;
 };
 
-module.exports = Request;
+module.exports = Request;

tests/unit/test.requests.js

@@ -48,14 +48,20 @@ tap.test('Request', async(t) => {
  const rq = reqPool.add({
  timeout: (e) => e,
  packet: {
- match: {idx: ++idx, tag: tag1}
+ match: {idx: ++idx, tag: tag1},
+ meta: {traceId: -1}
  }
  });
  tt.same(
  rq.idx > 0,
  true,
  'index should be greater than 0'
  );
+ tt.same(
+ rq.traceId,
+ -1,
+ 'trace id should be same as passed'
+ );
  tt.same(
  rq.config,
  {waitTime: defaultWaitTime},