Method onMessage

src/remote/appServer/client.ts:401–436

(data: WS.RawData)

    await timeoutPromise(
      new Promise<void>((resolve, reject) => {
        const onMessage = (data: WS.RawData) => {
          let message: unknown
          try {
            message = jsonParse(String(data))
          } catch (error) {
            cleanup()
            reject(
              new Error(
                `remote app server at ${this.args.websocketUrl} sent invalid initialize response: ${String(error)}`,
              ),
            )
            return
          }

          if (isJsonRpcResponse(message) && message.id === INITIALIZE_REQUEST_ID) {
            cleanup()
            resolve()
            return
          }
          if (isJsonRpcError(message) && message.id === INITIALIZE_REQUEST_ID) {
            cleanup()
            reject(
              new Error(
                `remote app server at ${this.args.websocketUrl} rejected initialize: ${message.error.message}`,
              ),
            )
            return
          }
          if (isJsonRpcNotification(message)) {
            pendingEvents.push(appServerEventFromNotification(message))
            return
          }
          if (isJsonRpcRequest(message)) {
            pendingEvents.push({ type: 'server_request', request: message })
          }
        }
        const onClose = () => {
          cleanup()
          reject(