Method open

src/remote/appServer/client.ts:347–387

()

  }

  private async open(): Promise<void> {
    const headers: Record<string, string> = { ...(this.args.headers ?? {}) }
    if (this.args.authToken) {
      headers.Authorization = `Bearer ${this.args.authToken}`
    }
    const ws = new WS(this.args.websocketUrl, { headers })
    this.ws = ws

    await timeoutPromise(
      new Promise<void>((resolve, reject) => {
        ws.once('open', () => resolve())
        ws.once('error', reject)
        ws.once('close', () =>
          reject(
            new Error(
              `remote app server at ${this.args.websocketUrl} closed before open`,
            ),
          ),
        )
      }),
      this.args.connectTimeoutMs,
      `timed out connecting to remote app server at ${this.args.websocketUrl}`,
    )

    const pendingEvents = await this.initialize(ws)
    ws.on('message', data => this.handleRawMessage(String(data)))
    ws.on('close', (_code, reason) => {
      const text = reason?.toString() || 'connection closed'
      this.close(`remote app server at ${this.args.websocketUrl} disconnected: ${text}`)
    })
    ws.on('error', error => {
      this.close(
        `remote app server at ${this.args.websocketUrl} transport failed: ${error.message}`,
      )
    })
    ws.send(jsonStringify({ method: 'initialized' } satisfies ClientNotification))

    for (const event of pendingEvents) {
      this.enqueueEvent(event)
    }
  }

  private async initialize(ws: WS): Promise<RemoteAppServerEvent[]> {
    const pendingEvents: RemoteAppServerEvent[] = []