Class TelegramAdapter

src/runtime/adapters/telegram.ts:37–441

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

export class TelegramAdapter implements PlatformAdapter, MessageSender {
  readonly name = "telegram";

  private bot: TelegramBot | null = null;
  private agent: IPackAgent | null = null;
  private options: TelegramAdapterOptions;
  private rootDir = "";
  private ipcBroadcaster: IpcBroadcaster | null = null;

  constructor(options: TelegramAdapterOptions) {
    this.options = options;
  }

  async start(ctx: AdapterContext): Promise<void> {
    this.agent = ctx.agent;
    this.rootDir = ctx.rootDir;
    this.ipcBroadcaster = ctx.ipcBroadcaster ?? null;

    this.bot = new TelegramBot(this.options.token, { polling: true });

    this.bot.on("message", (msg) => {
      this.handleTelegramMessage(msg).catch((err) => {
        console.error("[Telegram] Error handling message:", err);
      });
    });

    // Register bot commands with Telegram
    await this.bot.setMyCommands(getTelegramBotCommands());

    const me = await this.bot.getMe();
    console.log(`[TelegramAdapter] Started as @${me.username}`);
  }

  async stop(): Promise<void> {
    if (this.bot) {
      await this.bot.stopPolling();
      this.bot = null;
    }
    console.log("[TelegramAdapter] Stopped");
  }

  // -------------------------------------------------------------------------
  // MessageSender – proactive message sending
  // -------------------------------------------------------------------------

  /**
   * Public method: send a message to a specific Telegram chat.
   * channelId format: telegram-<chatId>
   */
  async sendMessage(channelId: string, text: string): Promise<void> {
    if (!this.bot) throw new Error("[Telegram] Bot not initialized");
    const chatId = Number(channelId.replace("telegram-", ""));
    if (isNaN(chatId)) {
      throw new Error(`[Telegram] Invalid channelId: ${channelId}`);
    }
    await this.sendLongMessage(chatId, text);
  }