Merge pull request 'feat(plugins): P5-003 Telegram channel plugin' (#93) from feat/p5-telegram-plugin into main

2026-03-13 17:48:01 +00:00
parent 446a424c1f 02a0d515d9
commit 01e9891243
5 changed files with 383 additions and 1 deletions
--- a/docs/scratchpads/p5-003-telegram-plugin.md
+++ b/docs/scratchpads/p5-003-telegram-plugin.md
@@ -0,0 +1,50 @@
+# Scratchpad — P5-003 Telegram Plugin
+
+## Objective
+
+Implement `@mosaic/telegram-plugin` by matching the established Discord plugin pattern with Telegraf + socket.io-client, add package docs, and pass package typecheck/lint.
+
+## Requirements Source
+
+- docs/PRD.md: Phase 5 remote control / Telegram plugin
+- docs/TASKS.md: P5-003
+- User task brief dated 2026-03-13
+
+## Plan
+
+1. Inspect Discord plugin behavior and package conventions
+2. Add Telegram runtime dependencies if missing
+3. Implement Telegram plugin with matching gateway event flow
+4. Add README usage documentation
+5. Run package typecheck and lint
+6. Run code review and remediate findings
+7. Commit, push, open PR, notify, remove worktree
+
+## TDD Rationale
+
+ASSUMPTION: No existing telegram package test harness or fixture coverage makes package-level TDD
+disproportionate for this plugin scaffold task. Validation will rely on typecheck, lint, and
+manual structural parity with the Discord plugin.
+
+## Risks
+
+- Telegram API typings may differ from Discord’s event shapes and require narrower guards.
+- Socket event payloads may already include `role` in shared gateway expectations.
+
+## Progress Log
+
+- 2026-03-13: Loaded Mosaic/global/repo guidance, mission files, Discord reference implementation, and Telegram package scaffold.
+- 2026-03-13: Added `telegraf` and `socket.io-client` to `@mosaic/telegram-plugin`.
+- 2026-03-13: Implemented Telegram message forwarding, gateway streaming accumulation, response chunking, and package README.
+
+## Verification Evidence
+
+- `pnpm --filter @mosaic/telegram-plugin typecheck` → pass
+- `pnpm --filter @mosaic/telegram-plugin lint` → pass
+- `pnpm typecheck` → pass
+- `pnpm lint` → pass
+
+## Review
+
+- Automated uncommitted review wrapper was invoked for the current delta.
+- Manual review completed against Discord parity, gateway event contracts, and package docs; no additional blockers found.
--- a/plugins/telegram/README.md
+++ b/plugins/telegram/README.md
@@ -0,0 +1,23 @@
+# @mosaic/telegram-plugin
+
+`@mosaic/telegram-plugin` connects a Telegram bot to the Mosaic gateway chat namespace so Telegram chats can participate in the same conversation flow as the web, TUI, and Discord channels.
+
+## Required Environment Variables
+
+- `TELEGRAM_BOT_TOKEN`: Bot token issued by BotFather
+- `TELEGRAM_GATEWAY_URL`: Base URL for the Mosaic gateway, for example `http://localhost:3000`
+
+## What It Does
+
+- Launches a Telegram bot with `telegraf`
+- Connects to `${TELEGRAM_GATEWAY_URL}/chat` with `socket.io-client`
+- Maps Telegram `chat.id` values to Mosaic `conversationId` values
+- Forwards inbound Telegram text messages to the gateway as user messages
+- Buffers `agent:start` / `agent:text` / `agent:end` socket events and sends the completed response back to the Telegram chat
+
+## Getting a Bot Token
+
+1. Open Telegram and start a chat with `@BotFather`
+2. Run `/newbot`
+3. Follow the prompts to name the bot and choose a username
+4. Copy the generated token and assign it to `TELEGRAM_BOT_TOKEN`
--- a/plugins/telegram/package.json
+++ b/plugins/telegram/package.json
@@ -18,5 +18,9 @@
  "devDependencies": {
    "typescript": "^5.8.0",
    "vitest": "^2.0.0"
+  },
+  "dependencies": {
+    "socket.io-client": "^4.8.0",
+    "telegraf": "^4.16.3"
  }
 }
--- a/plugins/telegram/src/index.ts
+++ b/plugins/telegram/src/index.ts
@@ -1 +1,187 @@
-export const VERSION = '0.0.0';
+import { Telegraf } from 'telegraf';
+import { io, type Socket } from 'socket.io-client';
+
+interface TelegramPluginConfig {
+  token: string;
+  gatewayUrl: string;
+}
+
+interface TelegramUser {
+  is_bot?: boolean;
+}
+
+interface TelegramChat {
+  id: number;
+}
+
+interface TelegramTextMessage {
+  chat: TelegramChat;
+  from?: TelegramUser;
+  text: string;
+}
+
+class TelegramPlugin {
+  readonly name = 'telegram';
+
+  private bot: Telegraf;
+  private socket: Socket | null = null;
+  private config: TelegramPluginConfig;
+  /** Map Telegram chat ID → Mosaic conversation ID */
+  private chatConversations = new Map<string, string>();
+  /** Track in-flight responses to avoid duplicate streaming */
+  private pendingResponses = new Map<string, string>();
+
+  constructor(config: TelegramPluginConfig) {
+    this.config = config;
+    this.bot = new Telegraf(this.config.token);
+  }
+
+  async start(): Promise<void> {
+    // Connect to gateway WebSocket
+    this.socket = io(`${this.config.gatewayUrl}/chat`, {
+      transports: ['websocket'],
+    });
+
+    this.socket.on('connect', () => {
+      console.log('[telegram] Connected to gateway');
+    });
+
+    this.socket.on('disconnect', (reason: string) => {
+      console.error(`[telegram] Disconnected from gateway: ${reason}`);
+      this.pendingResponses.clear();
+    });
+
+    this.socket.on('connect_error', (err: Error) => {
+      console.error(`[telegram] Gateway connection error: ${err.message}`);
+    });
+
+    // Handle streaming text from gateway
+    this.socket.on('agent:text', (data: { conversationId: string; text: string }) => {
+      const pending = this.pendingResponses.get(data.conversationId);
+      if (pending !== undefined) {
+        this.pendingResponses.set(data.conversationId, pending + data.text);
+      }
+    });
+
+    // When agent finishes, send the accumulated response
+    this.socket.on('agent:end', (data: { conversationId: string }) => {
+      const text = this.pendingResponses.get(data.conversationId);
+      if (text) {
+        this.pendingResponses.delete(data.conversationId);
+        this.sendToTelegram(data.conversationId, text).catch((err) => {
+          console.error(`[telegram] Error sending response for ${data.conversationId}:`, err);
+        });
+      }
+    });
+
+    this.socket.on('agent:start', (data: { conversationId: string }) => {
+      this.pendingResponses.set(data.conversationId, '');
+    });
+
+    // Set up Telegram message handler
+    this.bot.on('message', (ctx) => {
+      const message = this.getTextMessage(ctx.message);
+      if (message) {
+        this.handleTelegramMessage(message);
+      }
+    });
+
+    await this.bot.launch();
+  }
+
+  async stop(): Promise<void> {
+    this.bot.stop('SIGTERM');
+    this.socket?.disconnect();
+  }
+
+  private handleTelegramMessage(message: TelegramTextMessage): void {
+    // Ignore bot messages
+    if (message.from?.is_bot) return;
+
+    const content = message.text.trim();
+    if (!content) return;
+
+    // Get or create conversation for this Telegram chat
+    const chatId = String(message.chat.id);
+    let conversationId = this.chatConversations.get(chatId);
+    if (!conversationId) {
+      conversationId = `telegram-${chatId}`;
+      this.chatConversations.set(chatId, conversationId);
+    }
+
+    // Send to gateway
+    if (!this.socket?.connected) {
+      console.error(`[telegram] Cannot forward message: not connected to gateway. chat=${chatId}`);
+      return;
+    }
+
+    this.socket.emit('message', {
+      conversationId,
+      content,
+      role: 'user',
+    });
+  }
+
+  private getTextMessage(message: unknown): TelegramTextMessage | null {
+    if (!message || typeof message !== 'object') return null;
+
+    const candidate = message as Partial<TelegramTextMessage>;
+    if (typeof candidate.text !== 'string') return null;
+    if (!candidate.chat || typeof candidate.chat.id !== 'number') return null;
+
+    return {
+      chat: candidate.chat,
+      from: candidate.from,
+      text: candidate.text,
+    };
+  }
+
+  private async sendToTelegram(conversationId: string, text: string): Promise<void> {
+    // Find the Telegram chat for this conversation
+    const chatId = Array.from(this.chatConversations.entries()).find(
+      ([, convId]) => convId === conversationId,
+    )?.[0];
+
+    if (!chatId) {
+      console.error(`[telegram] No chat found for conversation ${conversationId}`);
+      return;
+    }
+
+    // Chunk responses for Telegram's 4096-char limit
+    const chunks = this.chunkText(text, 4000);
+    for (const chunk of chunks) {
+      try {
+        await this.bot.telegram.sendMessage(chatId, chunk);
+      } catch (err) {
+        console.error(`[telegram] Failed to send message to chat ${chatId}:`, err);
+      }
+    }
+  }
+
+  private chunkText(text: string, maxLength: number): string[] {
+    if (text.length <= maxLength) return [text];
+
+    const chunks: string[] = [];
+    let remaining = text;
+
+    while (remaining.length > 0) {
+      if (remaining.length <= maxLength) {
+        chunks.push(remaining);
+        break;
+      }
+
+      // Try to break at a newline
+      let breakPoint = remaining.lastIndexOf('\n', maxLength);
+      if (breakPoint <= 0) breakPoint = maxLength;
+
+      chunks.push(remaining.slice(0, breakPoint));
+      remaining = remaining.slice(breakPoint).trimStart();
+    }
+
+    return chunks;
+  }
+}
+
+export { TelegramPlugin };
+export type { TelegramPluginConfig };
+export const VERSION = '0.0.5';
--- a/pnpm-lock.yaml
+++ b/pnpm-lock.yaml
@@ -449,6 +449,13 @@ importers:
        version: 2.1.9(@types/node@22.19.15)(lightningcss@1.31.1)

  plugins/telegram:
+    dependencies:
+      socket.io-client:
+        specifier: ^4.8.0
+        version: 4.8.3
+      telegraf:
+        specifier: ^4.16.3
+        version: 4.16.3
    devDependencies:
      typescript:
        specifier: ^5.8.0
@@ -2719,6 +2726,9 @@ packages:
  '@tailwindcss/postcss@4.2.1':
    resolution: {integrity: sha512-OEwGIBnXnj7zJeonOh6ZG9woofIjGrd2BORfvE5p9USYKDCZoQmfqLcfNiRWoJlRWLdNPn2IgVZuWAOM4iTYMw==}

+  '@telegraf/types@7.1.0':
+    resolution: {integrity: sha512-kGevOIbpMcIlCDeorKGpwZmdH7kHbqlk/Yj6dEpJMKEQw5lk0KVQY0OLXaCswy8GqlIVLd5625OB+rAntP9xVw==}
+
  '@tokenizer/inflate@0.4.1':
    resolution: {integrity: sha512-2mAv+8pkG6GIZiF1kNg1jAjh27IDxEPKwdGul3snfztFerfPGI1LjDezZp3i7BElXompqEtPmoPx6c2wgtWsOA==}
    engines: {node: '>=18'}
@@ -2901,6 +2911,10 @@ packages:
    resolution: {integrity: sha512-Xfe6rpCTxSxfbswi/W/Pz7zp1WWSNn4A0eW4mLkQUewCrXXtMj31lCg+iQyTkh/CkusZSq9eDflu7tjEDXUY6g==}
    engines: {node: '>=v14.0.0', npm: '>=7.0.0'}

+  abort-controller@3.0.0:
+    resolution: {integrity: sha512-h8lQ8tacZYnR3vNQTgibj+tODHI5/+l06Au2Pcriv/Gmet0eaj4TwWH41sO9wnHDiQsEj19q0drzdWdeAHtweg==}
+    engines: {node: '>=6.5'}
+
  abstract-logging@2.0.1:
    resolution: {integrity: sha512-2BjRTZxTPvheOvGbBslFSYOUkr+SjPtOnrLP33f+VIWLzezQpZcqVg7ja3L4dBXmzzgwT+a029jRx5PCi3JuiA==}

@@ -3103,12 +3117,21 @@ packages:
    resolution: {integrity: sha512-YCEo7KjMlbNlyHhz7zAZNDpIpQbd+wOEHJYezv0nMYTn4x31eIUM2yomNNubclAt63dObUzKHWsBLJ9QcZNSnQ==}
    engines: {node: '>=20.19.0'}

+  buffer-alloc-unsafe@1.1.0:
+    resolution: {integrity: sha512-TEM2iMIEQdJ2yjPJoSIsldnleVaAk1oW3DBVUykyOLsEsFmEc9kn+SFFPz+gl54KQNxlDnAwCXosOS9Okx2xAg==}
+
+  buffer-alloc@1.2.0:
+    resolution: {integrity: sha512-CFsHQgjtW1UChdXgbyJGtnm+O/uLQeZdtbDo8mfUgYXCHSM1wgrVxXm6bSyrUuErEb+4sYVGCzASBRot7zyrow==}
+
  buffer-crc32@0.2.13:
    resolution: {integrity: sha512-VO9Ht/+p3SN7SKWqcrgEzjGbRSJYTx+Q1pTQC0wrWqHx0vpJraQ6GtHx8tvcg1rlK1byhU5gccxgOgj7B0TDkQ==}

  buffer-equal-constant-time@1.0.1:
    resolution: {integrity: sha512-zRpUiDwd/xk6ADqPMATG8vc9VPrkck7T07OIx0gnjmJAnHnTVXNQG3vfvWNuiZIkwu9KrKdA1iJKfsfTVxE6NA==}

+  buffer-fill@1.0.0:
+    resolution: {integrity: sha512-T7zexNBwiiaCOGDg9xNX9PBmjrubblRkENuptryuI64URkXDFum9il/JGL8Lm8wYfAXpredVXXZz7eMHilimiQ==}
+
  buffer-from@1.1.2:
    resolution: {integrity: sha512-E+XQCRwSbaaiChtv6k6Dwgc+bx+Bs6vuKJHHl5kox/BaKbhiXzqQOwK4cO22yElGp2OCmjwVhT3HmxgyPGnJfQ==}

@@ -3528,6 +3551,10 @@ packages:
    resolution: {integrity: sha512-kVscqXk4OCp68SZ0dkgEKVi6/8ij300KBWTJq32P/dYeWTSwK41WyTxalN1eRmA5Z9UU/LX9D7FWSmV9SAYx6g==}
    engines: {node: '>=0.10.0'}

+  event-target-shim@5.0.1:
+    resolution: {integrity: sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ==}
+    engines: {node: '>=6'}
+
  eventemitter3@5.0.4:
    resolution: {integrity: sha512-mlsTRyGaPBjPedk6Bvw+aqbsXDtoAyAzm5MO7JgU+yVRyMQ5O8bD4Kcci7BS85f93veegeCPkL8R4GLClnjLFw==}

@@ -4139,6 +4166,10 @@ packages:
      socks:
        optional: true

+  mri@1.2.0:
+    resolution: {integrity: sha512-tzzskb3bG8LvYGFF/mDTpq3jpI6Q9wc3LEmBaghu+DdCssd1FakN7Bc0hVNmEyGq1bq3RgfkCb3cmQLpNPOroA==}
+    engines: {node: '>=4'}
+
  ms@2.1.3:
    resolution: {integrity: sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==}

@@ -4195,6 +4226,15 @@ packages:
    engines: {node: '>=10.5.0'}
    deprecated: Use your platform's native DOMException instead

+  node-fetch@2.7.0:
+    resolution: {integrity: sha512-c4FRfUm/dbcWZ7U+1Wq0AwCyFL+3nt2bEw05wfxSz+DWpWsitgmSgYmy2dQdWyKC1694ELPqMs/YzUSNozLt8A==}
+    engines: {node: 4.x || >=6.0.0}
+    peerDependencies:
+      encoding: ^0.1.0
+    peerDependenciesMeta:
+      encoding:
+        optional: true
+
  node-fetch@3.3.2:
    resolution: {integrity: sha512-dRB78srN/l6gqWulah9SrxeYnxeddIG30+GOqK/9OlLVyLg3HPnr6SqOWTWOXKRwC2eGYCkZ59NNuSgvSrpgOA==}
    engines: {node: ^12.20.0 || ^14.13.1 || >=16.0.0}
@@ -4258,6 +4298,10 @@ packages:
    resolution: {integrity: sha512-312Id396EbJdvRONlngUx0NydfrIQ5lsYu0znKVUzVvArzEIt08V1qhtyESbGVd1FGX7UKtiFp5uwKZdM8wIuQ==}
    engines: {node: '>=8'}

+  p-timeout@4.1.0:
+    resolution: {integrity: sha512-+/wmHtzJuWii1sXn3HCuH/FTwGhrp4tmJTxSKJbfS+vkipci6osxXM5mY0jUiRzWKMTgUT8l7HFbeSwZAynqHw==}
+    engines: {node: '>=10'}
+
  pac-proxy-agent@7.2.0:
    resolution: {integrity: sha512-TEB8ESquiLMc0lV8vcd5Ql/JAKAoyzHFXaStwjkzpOpC5Yv+pIzLfHvjTSdf3vpa2bMiUQrg9i6276yn8666aA==}
    engines: {node: '>= 14'}
@@ -4528,6 +4572,9 @@ packages:
  safe-buffer@5.2.1:
    resolution: {integrity: sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ==}

+  safe-compare@1.1.4:
+    resolution: {integrity: sha512-b9wZ986HHCo/HbKrRpBJb2kqXMK9CEWIE1egeEvZsYn69ay3kdfl9nG3RyOcR+jInTDf7a86WQ1d4VJX7goSSQ==}
+
  safe-regex2@5.1.0:
    resolution: {integrity: sha512-pNHAuBW7TrcleFHsxBr5QMi/Iyp0ENjUKz7GCcX1UO7cMh+NmVK6HxQckNL1tJp1XAJVjG6B8OKIPqodqj9rtw==}
    hasBin: true
@@ -4536,6 +4583,10 @@ packages:
    resolution: {integrity: sha512-b3rppTKm9T+PsVCBEOUR46GWI7fdOs00VKZ1+9c1EWDaDMvjQc6tUwuFyIprgGgTcWoVHSKrU8H31ZHA2e0RHA==}
    engines: {node: '>=10'}

+  sandwich-stream@2.0.2:
+    resolution: {integrity: sha512-jLYV0DORrzY3xaz/S9ydJL6Iz7essZeAfnAavsJ+zsJGZ1MOnsS52yRjU3uF3pJa/lla7+wisp//fxOwOH8SKQ==}
+    engines: {node: '>= 0.10'}
+
  scheduler@0.23.2:
    resolution: {integrity: sha512-UOShsPwz7NrMUqhR6t0hWjFduvOzbtv7toDH1/hIrfRNIDBnnBWd0CwJTGvTpngVlmwGCdP9/Zl/tVrDqcuYzQ==}

@@ -4713,6 +4764,11 @@ packages:
    resolution: {integrity: sha512-g9ljZiwki/LfxmQADO3dEY1CbpmXT5Hm2fJ+QaGKwSXUylMybePR7/67YW7jOrrvjEgL1Fmz5kzyAjWVWLlucg==}
    engines: {node: '>=6'}

+  telegraf@4.16.3:
+    resolution: {integrity: sha512-yjEu2NwkHlXu0OARWoNhJlIjX09dRktiMQFsM678BAH/PEPVwctzL67+tvXqLCRQQvm3SDtki2saGO9hLlz68w==}
+    engines: {node: ^12.20.0 || >=14.13.1}
+    hasBin: true
+
  thenify-all@1.6.0:
    resolution: {integrity: sha512-RNxQH/qI8/t3thXJDwcstUO4zeqo64+Uy/+sNVRBx4Xn2OX+OZ9oP+iJnNFqplFra2ZUVeKCSa2oVWi3T4uVmA==}
    engines: {node: '>=0.8'}
@@ -4758,6 +4814,9 @@ packages:
    resolution: {integrity: sha512-dRXchy+C0IgK8WPC6xvCHFRIWYUbqqdEIKPaKo/AcTUNzwLTK6AH7RjdLWsEZcAN/TBdtfUw3PYEgPr5VPr6ww==}
    engines: {node: '>=14.16'}

+  tr46@0.0.3:
+    resolution: {integrity: sha512-N3WMsuqV66lT30CrXNbEjx4GEwlow3v6rr4mCcv6prnfwhS01rkgyFdjPNBYd9br7LpXV1+Emh01fHnq2Gdgrw==}
+
  tr46@5.1.1:
    resolution: {integrity: sha512-hdF5ZgjTqgAntKkklYw0R03MG2x/bSzTtkxmIRw/sTNV8YXsCJ1tfLAX23lhxhHJlEf3CRCOCGGWw3vI3GaSPw==}
    engines: {node: '>=18'}
@@ -4935,6 +4994,9 @@ packages:
    resolution: {integrity: sha512-d2JWLCivmZYTSIoge9MsgFCZrt571BikcWGYkjC1khllbTeDlGqZ2D8vD8E/lJa8WGWbb7Plm8/XJYV7IJHZZw==}
    engines: {node: '>= 8'}

+  webidl-conversions@3.0.1:
+    resolution: {integrity: sha512-2JAn3z8AR6rjK8Sm8orRC0h/bcl/DqL7tRPdGZ4I1CjdF+EaMLmYxBHyXuKL849eucPFhvBoxMsflfOb8kxaeQ==}
+
  webidl-conversions@7.0.0:
    resolution: {integrity: sha512-VwddBukDzu71offAQR975unBIGqfKZpM+8ZX6ySk8nYhVoo5CYaZyzt3YBvYtRtO+aoGlqxPg/B87NGVZ/fu6g==}
    engines: {node: '>=12'}
@@ -4943,6 +5005,9 @@ packages:
    resolution: {integrity: sha512-De72GdQZzNTUBBChsXueQUnPKDkg/5A5zp7pFDuQAj5UFoENpiACU0wlCvzpAGnTkj++ihpKwKyYewn/XNUbKw==}
    engines: {node: '>=18'}

+  whatwg-url@5.0.0:
+    resolution: {integrity: sha512-saE57nupxk6v3HY35+jzBwYa0rKSy0XR8JSxZPwgLr7ys0IBzhGviA1/TUGJLmSVqs8pb9AnvICXEuOHLprYTw==}
+
  which@2.0.2:
    resolution: {integrity: sha512-BLI3Tl1TW3Pvl70l3yq3Y64i+awpwXqsGBYWkkqMtnbXgrMD+yj7rhW0kuEDxzJaYXGjEW5ogapKNMEKNMjibA==}
    engines: {node: '>= 8'}
@@ -7525,6 +7590,8 @@ snapshots:
      postcss: 8.5.8
      tailwindcss: 4.2.1

+  '@telegraf/types@7.1.0': {}
+
  '@tokenizer/inflate@0.4.1':
    dependencies:
      debug: 4.4.3
@@ -7757,6 +7824,10 @@ snapshots:

  '@vladfrangu/async_event_emitter@2.4.7': {}

+  abort-controller@3.0.0:
+    dependencies:
+      event-target-shim: 5.0.1
+
  abstract-logging@2.0.1: {}

  accepts@1.3.8:
@@ -7901,10 +7972,19 @@ snapshots:

  bson@7.2.0: {}

+  buffer-alloc-unsafe@1.1.0: {}
+
+  buffer-alloc@1.2.0:
+    dependencies:
+      buffer-alloc-unsafe: 1.1.0
+      buffer-fill: 1.0.0
+
  buffer-crc32@0.2.13: {}

  buffer-equal-constant-time@1.0.1: {}

+  buffer-fill@1.0.0: {}
+
  buffer-from@1.1.2: {}

  cac@6.7.14: {}
@@ -8350,6 +8430,8 @@ snapshots:

  esutils@2.0.3: {}

+  event-target-shim@5.0.1: {}
+
  eventemitter3@5.0.4: {}

  execa@8.0.1:
@@ -8976,6 +9058,8 @@ snapshots:
    optionalDependencies:
      socks: 2.8.7

+  mri@1.2.0: {}
+
  ms@2.1.3: {}

  mz@2.7.0:
@@ -9023,6 +9107,10 @@ snapshots:

  node-domexception@1.0.0: {}

+  node-fetch@2.7.0:
+    dependencies:
+      whatwg-url: 5.0.0
+
  node-fetch@3.3.2:
    dependencies:
      data-uri-to-buffer: 4.0.1
@@ -9082,6 +9170,8 @@ snapshots:
      '@types/retry': 0.12.0
      retry: 0.13.1

+  p-timeout@4.1.0: {}
+
  pac-proxy-agent@7.2.0:
    dependencies:
      '@tootallnate/quickjs-emscripten': 0.23.0
@@ -9366,12 +9456,18 @@ snapshots:

  safe-buffer@5.2.1: {}

+  safe-compare@1.1.4:
+    dependencies:
+      buffer-alloc: 1.2.0
+
  safe-regex2@5.1.0:
    dependencies:
      ret: 0.5.0

  safe-stable-stringify@2.5.0: {}

+  sandwich-stream@2.0.2: {}
+
  scheduler@0.23.2:
    dependencies:
      loose-envify: 1.4.0
@@ -9578,6 +9674,20 @@ snapshots:

  tapable@2.3.0: {}

+  telegraf@4.16.3:
+    dependencies:
+      '@telegraf/types': 7.1.0
+      abort-controller: 3.0.0
+      debug: 4.4.3
+      mri: 1.2.0
+      node-fetch: 2.7.0
+      p-timeout: 4.1.0
+      safe-compare: 1.1.4
+      sandwich-stream: 2.0.2
+    transitivePeerDependencies:
+      - encoding
+      - supports-color
+
  thenify-all@1.6.0:
    dependencies:
      thenify: 3.3.1
@@ -9617,6 +9727,8 @@ snapshots:
      '@tokenizer/token': 0.3.0
      ieee754: 1.2.1

+  tr46@0.0.3: {}
+
  tr46@5.1.1:
    dependencies:
      punycode: 2.3.1
@@ -9771,6 +9883,8 @@ snapshots:

  web-streams-polyfill@3.3.3: {}

+  webidl-conversions@3.0.1: {}
+
  webidl-conversions@7.0.0: {}

  whatwg-url@14.2.0:
@@ -9778,6 +9892,11 @@ snapshots:
      tr46: 5.1.1
      webidl-conversions: 7.0.0

+  whatwg-url@5.0.0:
+    dependencies:
+      tr46: 0.0.3
+      webidl-conversions: 3.0.1
+
  which@2.0.2:
    dependencies:
      isexe: 2.0.0