Method start

test/harness/capturingHttpProxy.ts:21–130

()

  }

  async start(): Promise<string> {
    const targetUrlObj = new URL(this.targetUrl);
    const isHttps = targetUrlObj.protocol === "https:";

    this.server = http.createServer((req, res) => {
      const chunks: Buffer[] = [];

      req.on("data", (chunk: Buffer) => {
        chunks.push(chunk);
      });

      req.on("end", () => {
        const body = Buffer.concat(chunks).toString("utf8");
        const startTime = Date.now();

        const capturedRequest: CapturedRequest = {
          method: req.method || "GET",
          url: req.url || "/",
          headers: req.headers,
          body,
          startTime,
        };

        const exchange: CapturedExchange = {
          request: capturedRequest,
        };

        this.capturedExchanges.push(exchange);

        // Copy headers but update Host to match target
        const proxyHeaders = { ...req.headers };
        proxyHeaders.host = targetUrlObj.host;
        delete proxyHeaders.connection;

        let responseStatusCode: number | undefined;
        let responseHeaders: http.IncomingHttpHeaders | undefined;
        const responseChunks: Buffer[] = [];
        this.performRequest({
          isHttps,
          requestOptions: {
            hostname: targetUrlObj.hostname,
            port: targetUrlObj.port || (isHttps ? 443 : 80),
            path: req.url,
            method: req.method,
            headers: proxyHeaders,
          },
          body,
          onResponseStart: (statusCode, headers) => {
            responseStatusCode = statusCode;
            responseHeaders = headers;
            res.writeHead(statusCode, responseHeaders);
          },
          onData: (chunk) => {
            responseChunks.push(chunk);
            res.write(chunk);
          },
          onResponseEnd: () => {
            const endTime = Date.now();