Method forwardAndWait

npm_modules/cli/src/utils/daemonClient.ts:306–346

(
    _clientId: string,
    msgType: DaemonMsgType,
    body: Record<string, unknown>,
    timeoutMs = 15_000,
  )

  // ── Messages.ts direct-to-device calls ───────────────────────────────────

  private async forwardAndWait(
    _clientId: string,
    msgType: DaemonMsgType,
    body: Record<string, unknown>,
    timeoutMs = 15_000,
  ): Promise<Record<string, unknown>> {
    const msgId = this.nextMsgId();
    const payloadString = JSON.stringify({ type: msgType, requestId: msgId, body });

    const resultPromise = new Promise<Record<string, unknown>>((resolve, reject) => {
      const timer = setTimeout(() => {
        this.payloadListeners.delete(msgId);
        reject(new Error('Timeout waiting for device response. Is the app running?'));
      }, timeoutMs);
      this.payloadListeners.set(msgId, {
        resolve: (v) => { clearTimeout(timer); resolve(v); },
        reject: (e) => { clearTimeout(timer); reject(e); },
      });
    });

    // Send as an event — the device processes payload_from_client events directly.
    // It routes responses back as forward_client_payload requests (handled in dispatchMessage).
    this.socket.write(encodePacket({
      event: {
        payload_from_client: {
          sender_client_id: DIRECT_CLIENT_ID,
          payload_string: payloadString,
        },
      },
    }), (err) => {
      if (err) {
        const listener = this.payloadListeners.get(msgId);
        if (listener) {
          this.payloadListeners.delete(msgId);
          listener.reject(err);
        }
      }
    });

    return resultPromise;
  }

  async listContexts(clientId: string): Promise<RemoteContext[]> {
    const resp = await this.forwardAndWait(clientId, DaemonMsgType.LIST_CONTEXTS_REQUEST, {});