Class TelegramTransport

src/bot/adapters/telegram.ts:14–137

const sleep = (ms: number) => new Promise(r => setTimeout(r, ms));

export class TelegramTransport implements Transport {
  readonly platform = 'telegram' as const;
  readonly maxLen = 4096;
  readonly minEditIntervalMs = 1100; // Telegram allows ~1 edit/s per chat
  private offset = 0;
  private running = false;

  constructor(private token: string) {}

  private async api(method: string, body: unknown): Promise<any> {
    const res = await fetch(`https://api.telegram.org/bot${this.token}/${method}`, {
      method: 'POST',
      headers: { 'content-type': 'application/json' },
      body: JSON.stringify(body),
    });
    return res.json();
  }

  private keyboard(buttons?: Button[][]) {
    if (!buttons) return {};
    return { reply_markup: { inline_keyboard: buttons.map(row => row.map(b => ({ text: b.label, callback_data: b.data }))) } };
  }

  async start(onMessage: (m: Incoming) => void): Promise<void> {
    const me = await this.api('getMe', {});
    if (!me.ok) throw new Error(`Telegram getMe failed: ${me.description ?? 'bad token'}`);
    logger.info('telegram bot online', { username: me.result?.username });
    this.running = true;
    void this.loop(onMessage);
  }

  async stop(): Promise<void> { this.running = false; }

  private async loop(onMessage: (m: Incoming) => void): Promise<void> {
    while (this.running) {
      try {
        const res = await this.api('getUpdates', { offset: this.offset, timeout: 30, allowed_updates: ['message', 'callback_query'] });
        if (!res.ok) { await sleep(2000); continue; }
        for (const u of res.result) {
          this.offset = u.update_id + 1;
          if (u.message?.text) {
            onMessage({ platform: 'telegram', chatId: String(u.message.chat.id), userId: String(u.message.from?.id), userName: u.message.from?.username, text: u.message.text });
          } else if (u.message?.voice || u.message?.audio) {
            // Voice memo → transcribe (local-first) → feed as text. Fire-and-forget so the
            // poll loop keeps flowing; failures reply with a note instead of crashing.
            void this.handleVoice(u.message, onMessage);
          } else if (u.callback_query) {
            const cq = u.callback_query;
            onMessage({ platform: 'telegram', chatId: String(cq.message?.chat?.id), userId: String(cq.from?.id), text: '', callbackData: cq.data, callbackId: cq.id });
          }
        }
      } catch (e: any) {
        logger.warn('telegram poll error', { err: e?.message });
        await sleep(2000);
      }
    }
  }