Method performRequest

test/harness/replayingCapiProxy.ts:173–483

(options: PerformRequestOptions)

  }

  override performRequest(options: PerformRequestOptions): void {
    void iife(async () => {
      const commonResponseHeaders = {
        "x-github-request-id": "some-request-id",
      };

      try {
        // Handle /copilot-user-config endpoint for configuring per-token user responses
        if (
          options.requestOptions.path === "/copilot-user-config" &&
          options.requestOptions.method === "POST"
        ) {
          const config = JSON.parse(options.body!) as {
            token: string;
            response: CopilotUserResponse;
          };
          this.copilotUserByToken.set(config.token, config.response);
          options.onResponseStart(200, {});
          options.onResponseEnd();
          return;
        }

        // Handle /config endpoint for updating proxy configuration
        if (
          options.requestOptions.path === "/config" &&
          options.requestOptions.method === "POST"
        ) {
          await this.updateConfig(JSON.parse(options.body!));
          options.onResponseStart(200, {});
          options.onResponseEnd();
          return;
        }

        // Handle /stop endpoint for stopping the proxy
        if (
          options.requestOptions.path?.startsWith("/stop") &&
          options.requestOptions.method === "POST"
        ) {
          const skipWritingCache = options.requestOptions.path.includes(
            "skipWritingCache=true",
          );
          options.onResponseStart(200, {});
          options.onResponseEnd();
          await this.onStopRequested?.(skipWritingCache);
          await this.stop(skipWritingCache);
          process.exit(0);
        }

        // Handle /exchanges endpoint for retrieving captured exchanges
        if (
          options.requestOptions.path === "/exchanges" &&
          options.requestOptions.method === "GET"
        ) {
          const chatCompletionExchanges = this.exchanges.filter(
            (e) => e.request.url === chatCompletionEndpoint,
          );
          const parsedExchanges = await Promise.all(
            chatCompletionExchanges.map((e) =>