Function diagnostics_channel

benchmark/diagnostics_channel/http.js:67–96

()

}

function diagnostics_channel() {
  const als = new AsyncLocalStorage();
  const times = [];

  const start = dc.channel('http.server.request.start');
  const finish = dc.channel('http.server.response.finish');

  function onStart(req) {
    als.enterWith({
      url: req.url,
      start: process.hrtime.bigint(),
    });
  }

  function onFinish(res) {
    times.push({
      ...als.getStore(),
      statusCode: res.statusCode,
      end: process.hrtime.bigint(),
    });
  }

  start.subscribe(onStart);
  finish.subscribe(onFinish);

  return () => {
    start.unsubscribe(onStart);
    finish.unsubscribe(onFinish);
  };
}