Function onRunErrorEvent

packages/bot-telegram/src/event-renderer.ts:275–307

({ event })

    // ── 5. Errors ─────────────────────────────────────────────────────
    async onRunErrorEvent({ event }) {
      // Don't post a notice if we're the ones aborting; the `_(interrupted)_`
      // marker on the partial reply is the user-visible signal in that case.
      if (aborted) return;
      // Drain any in-flight text streams so partial replies are finalized
      // rather than left dangling (a _thinking…_ or partial message that
      // never resolves). Mirror the flush from onRunFinishedEvent.
      const tasks: Promise<void>[] = [];
      for (const [id, stream] of Array.from(streams.entries())) {
        tasks.push(
          stream
            .finish()
            .catch((e) =>
              console.error("[bot-telegram] stream finalize failed:", e),
            ),
        );
        streams.delete(id);
        finalised.add(id);
      }
      buffers.clear();
      await Promise.all(tasks);
      // Clean up any tool-status placeholders whose END never arrived before
      // the error — mark them cancelled rather than leaving "🔧 using <tool>…"
      // orphaned in the chat.
      await drainToolStatuses((tool) => `⚠️ ${tool} (cancelled)`);
      try {
        await args.postPlaceholder(
          telegramHtml(`⚠️ Agent error: ${event.message ?? "unknown error"}`),
        );
      } catch (err) {
        console.error("[telegram-renderer] error notice failed:", err);
      }
    },
  };

  return {