Method handleTelegramMessage

src/runtime/adapters/telegram.ts:99–195

(msg: TelegramBot.Message)

  // -------------------------------------------------------------------------

  private async handleTelegramMessage(msg: TelegramBot.Message) {
    if (!this.bot || !this.agent) return;

    const chatId = msg.chat.id;
    const messageId = msg.message_id;
    const text = (msg.text || msg.caption || "").trim();

    const channelId = `telegram-${chatId}`;
    this.ipcBroadcaster?.broadcastInbound(
      channelId,
      "telegram",
      {
        id: String(msg.from?.id || ""),
        username: msg.from?.username || msg.from?.first_name || "",
      },
      text,
    );

    // --- Extract attachments ---
    const attachments = await this.extractAttachments(msg, channelId);

    // Skip messages with no text and no attachments
    if (!text && attachments.length === 0) return;

    await this.tryAckReaction(chatId, messageId);

    // --- Command handling ---
    if (text) {
      const commandKey = text.split(/\s/)[0].toLowerCase();
      const command = this.resolveTelegramCommand(commandKey);

      if (command) {
        const result = await this.agent.handleCommand(command, channelId);
        await this.sendSafe(chatId, result.message || `/${command} executed.`);
        return;
      }
    }

    // --- Regular message → agent ---
    await this.bot.sendChatAction(chatId, "typing");

    let finalText = "";
    let hasError = false;
    let errorMessage = "";
    const pendingFiles: Array<{ filePath: string; caption?: string }> = [];

    const onEvent = (event: AgentEvent) => {
      switch (event.type) {
        case "text_delta":
          finalText += event.delta;
          break;
        case "file_output":
          pendingFiles.push({
            filePath: event.filePath,
            caption: event.caption,
          });
          break;
      }