Method submitAndWait

packages/server-e2e/src/client.ts:607–630

* Submit a prompt and wait for its terminal event. `waitFor` defaults to * the synthesized `prompt.completed` event (broadcast after `turn.ended` * lands for the same prompt). Returns `prompt_id` and the matching frame.

(
    sid: string,
    input: PromptSubmitInput,
    opts: SubmitAndWaitOptions = {},
  )

   * lands for the same prompt). Returns `prompt_id` and the matching frame.
   */
  async submitAndWait(
    sid: string,
    input: PromptSubmitInput,
    opts: SubmitAndWaitOptions = {},
  ): Promise<{ prompt_id: string; user_message_id: string; finalFrame: AnyFrame }> {
    const ws = this._requireWs();
    const waitFor = opts.waitFor ?? 'prompt.completed';
    const timeoutMs = opts.timeoutMs ?? DEFAULT_FRAME_TIMEOUT_MS;

    // POST the prompt FIRST — without `prompt_id` we have nothing to match on.
    // The WS layer queues every frame from the moment we open, so any events
    // that arrive between this POST and the `waitForFrame` below are still
    // there to be matched (they're drained from the queue, not dropped).
    const submit = await this.http.submitPrompt(sid, fillPromptDefaults(input));

    const finalFrame = await ws.waitForFrame((f) => {
      if (f.type !== waitFor) return false;
      const payload = (f.payload as { promptId?: string; prompt_id?: string } | undefined) ?? {};
      const pid = payload.promptId ?? payload.prompt_id;
      return pid === submit.prompt_id;
    }, timeoutMs);

    return { prompt_id: submit.prompt_id, user_message_id: submit.user_message_id, finalFrame };
  }

  /**
   * Stateful-session companion to `submitAndWait` — POSTs `body` verbatim