Function request

tests/smoke/cjs/tests/files.smoke.test.cjs:8–49

(options, onResponse)

const createCaptureTransport = (buildResponse) => {
  return {
    request(options, onResponse) {
      const chunks = [];

      const req = new Writable({
        write(chunk, _encoding, callback) {
          chunks.push(Buffer.from(chunk));
          callback();
        },
      });

      req.destroyed = false;
      req.setTimeout = () => {};
      req.close = () => {
        req.destroyed = true;
      };

      const originalDestroy = req.destroy.bind(req);
      req.destroy = (...args) => {
        req.destroyed = true;
        return originalDestroy(...args);
      };

      const originalEnd = req.end.bind(req);
      req.end = (...args) => {
        originalEnd(...args);

        const body = Buffer.concat(chunks);
        const response = buildResponse ? buildResponse(body, options) : {};

        const res = new PassThrough();
        res.statusCode = response.statusCode !== undefined ? response.statusCode : 200;
        res.statusMessage = response.statusMessage || 'OK';
        res.headers = response.headers || { 'content-type': 'application/json' };
        res.req = req;

        onResponse(res);
        res.end(response.body || JSON.stringify({ size: body.length }));
      };

      req.on('error', () => {});
      return req;
    },
  };
};