Function createRunRenderer

packages/bot-telegram/src/event-renderer.ts:49–359

(args: CreateRunRendererArgs)

 * stream that has real partial content.
 */
export function createRunRenderer(args: CreateRunRendererArgs): RunRenderer {
  const interruptEventNames =
    args.interruptEventNames ?? new Set<string>(["on_interrupt"]);
  const showToolStatus = args.showToolStatus ?? true;

  /** Per-AG-UI-message accumulated text (we accumulate deltas locally). */
  const buffers = new Map<string, string>();
  /** Per-AG-UI-message text stream. Lazily created on first content. */
  const streams = new Map<string, ChunkedEditStream>();
  /** Per-tool-call status message id so we can edit it on END. */
  const toolStatusIds = new Map<string, number>();
  /**
   * Once a stream has been finalised (via TEXT_MESSAGE_END or markInterrupted)
   * we drop it. Late-arriving events for the same messageId are ignored.
   */
  const finalised = new Set<string>();
  /**
   * Set when the caller intentionally aborted the run (a new turn arrived for
   * the same conversation). Suppresses the RUN_ERROR notice and stops
   * accepting further AG-UI events — the `_(interrupted)_` marker conveys the
   * state visually.
   */
  let aborted = false;

  /** Tool calls observed in this run, in event order. */
  const capturedToolCalls: CapturedToolCall[] = [];

  /** Interrupt observed via a matching `onCustomEvent`; read after runAgent. */
  let pendingInterrupt: CapturedInterrupt | undefined;

  const ensureStream = (messageId: string): ChunkedEditStream | undefined => {
    if (finalised.has(messageId)) return undefined;
    let s = streams.get(messageId);
    if (!s) {
      s = new ChunkedEditStream({
        postPlaceholder: args.postPlaceholder,
        editAt: args.editAt,
        transform: telegramHtml,
      });
      streams.set(messageId, s);
    }
    return s;
  };

  /**
   * BEST-EFFORT cleanup of tool-status placeholders that were posted on START
   * but never resolved by an END (the run ended/errored/was interrupted while
   * the tool call was still in flight). Edits each remaining placeholder to a
   * terminal marker so the stale `🔧 using <tool>…` line doesn't linger. This
   * is not a hard guarantee: each `editAt` can fail (message too old, deleted,
   * not-modified, flood-wait) and on failure it is caught + logged, NOT
   * retried — so a placeholder can still end up stranded if Telegram rejects
   * the edit. `terminal` is the marker each placeholder is edited to (e.g.
   * `✅` on finish, `⚠️ … (cancelled)` on error/interrupt).
   */
  const drainToolStatuses = async (
    terminal: (toolName: string) => string,
  ): Promise<void> => {