Method connect

packages/yalt/src/index.ts:127–171

()

  }

  async connect() {
    this.log("Connecting to tunnel", {
      url: this.url,
      address: this.address,
      socketOptions: this.socketOptions,
    });

    this.socket = new WebSocket(`wss://${this.url}/connect`, [], this.socketOptions);

    this.socket.addEventListener("open", (args) => {
      this.log("Connected to tunnel");
    });

    this.socket.addEventListener("close", (event) => {
      this.log("Disconnected from tunnel", { event: event.code, reason: event.reason });
    });

    this.socket.addEventListener("message", async (event) => {
      const data = JSON.parse(
        typeof event.data === "string" ? event.data : new TextDecoder("utf-8").decode(event.data)
      );

      const message = ServerMessages.safeParse(data);

      if (!message.success) {
        this.log("Received invalid message", { data });
        return;
      }

      switch (message.data.type) {
        case "request": {
          await this.handleRequest(message.data);

          break;
        }
        default: {
          console.error(`Unknown message type: ${message.data.type}`);
        }
      }
    });

    this.socket.addEventListener("error", (event) => {
      this.log("Socket error", { error: event.message });
    });
  }

  private async handleRequest(request: RequestMessage) {
    if (!this.socket) {