Method handleRequest

packages/yalt/src/index.ts:173–229

(request: RequestMessage)

  }

  private async handleRequest(request: RequestMessage) {
    if (!this.socket) {
      throw new Error("Socket is not connected");
    }

    const url = new URL(request.url);
    // Construct the original url to be the same as the request URL but with a different hostname and using http instead of https
    const originalUrl = new URL(
      `${this.https ? "https" : "http"}://${this.address}${url.pathname}${url.search}${url.hash}`
    );

    let response: Response | null = null;

    this.log("Sending local request", {
      originalUrl: originalUrl.href,
      requestId: request.id,
      headers: request.headers,
    });

    try {
      const agent = new https.Agent({
        rejectUnauthorized: false, // Ignore self-signed certificates
      });
      response = await fetch(originalUrl.href, {
        method: request.method,
        headers: stripHeaders(request.headers),
        body: request.body,
        ...(this.https && { agent }),
      });
    } catch (error) {
      if (error instanceof Error) {
        this.log("Error sending local request", {
          error: error.message,
          name: error.name,
          stack: error.stack,
          requestId: request.id,
          cause: "cause" in error ? error.cause : undefined,
        });
      } else {
        this.log("Error sending local request", { error, requestId: request.id });
      }

      // Return a 502 response
      response = new Response(
        JSON.stringify({
          message: `Could not connect to ${originalUrl.href}. Make sure you are running your local app server`,
        }),
        { status: 502, headers: { "Content-Type": "application/json" } }
      );
    }

    try {
      await this.sendResponse(request.id, response, this.socket);
    } catch (error) {
      console.error(error);
    }
  }