Returns a specification to start this module under a supervisor.

See Supervisor.

@spec commit_turn(session_key :: binary(), channel_id :: binary(), run_id :: binary()) ::
  :ok

Commit the current turn: flush pending buffer, clear PresentationState for the :answer surface so the next delta creates a fresh message, and reset internal text accumulators. No-op when full_text is empty or run_id doesn't match.

Used at turn boundaries (model text → tool action) in multi-turn runs so each intermediate answer becomes its own Telegram message instead of overwriting the previous one.

@spec finalize_run(
  session_key :: binary(),
  channel_id :: binary(),
  run_id :: binary(),
  opts :: keyword()
) :: :ok | {:error, term()}

Finalize a run for a session/channel.

Delegates semantic finalization to the channels dispatcher.

@spec flush(session_key :: binary(), channel_id :: binary()) :: :ok

Force flush the coalescer buffer.

@spec handoff_turn(
  session_key :: binary(),
  channel_id :: binary(),
  run_id :: binary(),
  target_surface :: term()
) :: {:ok, binary()} | :noop

Finalize the current answer turn, move its message tracking to another surface, and reset the answer coalescer so the next delta creates a fresh message.

@spec ingest_delta(
  session_key :: binary(),
  channel_id :: binary(),
  run_id :: binary(),
  seq :: non_neg_integer(),
  text :: binary(),
  opts :: keyword()
) :: :ok

Ingest a delta into the coalescer.

Options

• :meta - Optional metadata map, can include :answer_msg_id for edit mode