/** * Telegram getUpdates polling loop. * * One MCP instance is elected as the poller via the file lock. It calls * getUpdates and distributes incoming messages to per-thread JSONL files * through the broker. All other instances are consumers only. */ import type { TelegramClient } from "../telegram.js"; /** * Start the shared dispatcher. * - Ensures directories exist. * - Attempts to acquire the poller lock. * - If acquired, starts a polling loop that writes to per-thread files. * - If not acquired, this instance is a consumer only (reads from thread files). * * Returns: whether this instance became the poller. */ export declare function startDispatcher(telegram: TelegramClient, chatId: string): Promise; //# sourceMappingURL=poller.d.ts.map