Method sendMessage

packages/runtime/src/session-manager.ts:2039–2069

* Send a user message and stream back normalized events. The caller * (desktop main) is expected to forward the events to the renderer over * the IPC bridge. * * Runtime v2 bridge: SessionManager remains the public facade; RuntimeKernel * owns AgentRun/AiSdkFlow/RuntimeRunner orchestr

(
    sessionId: string,
    input: UserMessageInput,
    options: TurnStartOptions = {},
  )

   * owns AgentRun/AiSdkFlow/RuntimeRunner orchestration and ledger recording.
   */
  async *sendMessage(
    sessionId: string,
    input: UserMessageInput,
    options: TurnStartOptions = {},
  ): AsyncIterable<SessionEvent> {
    if (input.origin?.kind === 'legacy_automation') {
      throw new Error('Live Turn cannot use removed Automation authority');
    }
    const repair = input.agentId ? undefined : this.runtimeLedgerRepair;
    const admitTurn = repair
      ? async () => {
          await this.ensureTranscriptLedger(sessionId, repair, 'compatibility');
          return (await options.admitTurn?.()) ?? 'admitted';
        }
      : options.admitTurn;
    const sourceText = sessionTitleSource(input);
    const onRunStarted = this.deps.generateSessionTitle
      ? async (runId: string, header: SessionHeader) => {
          await options.onRunStarted?.(runId, header);
          if (
            !header.connectionLocked &&
            !header.titleIsManual &&
            header.name === DEFAULT_SESSION_NAME &&
            sourceText
          ) {
            void this.generateTitleInBackground(sessionId, header, sourceText);
          }
        }
      : options.onRunStarted;
    yield* this.runtimeKernel.startTurn(sessionId, input, { ...options, admitTurn, onRunStarted });
  }

  private async generateTitleInBackground(
    sessionId: string,