feat: Make telegram client

.env.example

@@ -18,3 +18,8 @@ DRY_RUN=1
 # Discord Bot Token (https://discord.com/developers/applications)
 # Required Gateway Intents: Server Members, Message Content, Presence
 DISCORD_TOKEN=
+
+# gramJS needs to be supplied all of these values (regardless of whether you're running a user client or bot)
+TELEGRAM_TOKEN=
+TELEGRAM_API_ID=
+TELEGRAM_API_HASH=

examples/example-telegram.ts

@@ -0,0 +1,178 @@
+import { Orchestrator } from "../packages/core/src/core/orchestrator";
+import { HandlerRole } from "../packages/core/src/core/types";
+import { TelegramClient } from "../packages/core/src/core/io/telegram";
+import { RoomManager } from "../packages/core/src/core/room-manager";
+import { ChromaVectorDB } from "../packages/core/src/core/vector-db";
+import { MessageProcessor } from "../packages/core/src/core/processors/message-processor";
+import { LLMClient } from "../packages/core/src/core/llm-client";
+import { env } from "../packages/core/src/core/env";
+import { LogLevel } from "../packages/core/src/core/types";
+import chalk from "chalk";
+import { defaultCharacter } from "../packages/core/src/core/character";
+import { z } from "zod";
+import readline from "readline";
+import { MongoDb } from "../packages/core/src/core/mongo-db";
+
+
+async function main() {
+    const loglevel = LogLevel.DEBUG;
+
+    // Initialize core dependencies
+    const vectorDb = new ChromaVectorDB("telegram_agent", {
+        chromaUrl: "http://localhost:8000",
+        logLevel: loglevel,
+    });
+
+    await vectorDb.purge(); // Clear previous session data
+
+    const roomManager = new RoomManager(vectorDb);
+
+    const llmClient = new LLMClient({
+        // model: "openrouter:deepseek/deepseek-r1", // Using a supported model
+        model: "openrouter:deepseek/deepseek-r1-distill-llama-70b",
+        temperature: 0.3,
+    });
+
+    // Initialize processor with default character personality
+    const processor = new MessageProcessor(
+        llmClient,
+        defaultCharacter,
+        loglevel
+    );
+    const scheduledTaskDb = new MongoDb(
+        "mongodb://localhost:27017",
+        "myApp",
+        "scheduled_tasks"
+    );
+
+    await scheduledTaskDb.connect();
+    console.log(chalk.green("✅ Scheduled task database connected"));
+
+    await scheduledTaskDb.deleteAll();
+
+    // Initialize core system
+    const core = new Orchestrator(
+        roomManager,
+        vectorDb,
+        [processor],
+        scheduledTaskDb,
+        {
+            level: loglevel,
+            enableColors: true,
+            enableTimestamp: true,
+        }
+    );
+
+    // Set up Telegram bot client with credentials
+    const telegram = new TelegramClient(
+        {
+            bot_token: env.TELEGRAM_TOKEN,
+            api_id: parseInt(env.TELEGRAM_API_ID as string),
+            api_hash: env.TELEGRAM_API_HASH,
+            is_bot: true,
+        },
+        loglevel,
+    );
+
+
+
+    // Set up Telegram user client with credentials
+    // const telegram = new TelegramClient(
+    //     {
+    //         bot_token: env.TELEGRAM_TOKEN,
+    //         api_id: parseInt(env.TELEGRAM_API_ID as string),
+    //         api_hash: env.TELEGRAM_API_HASH,
+    //         is_bot: false,
+    //     },
+    //     loglevel,
+    // );
+
+
+
+    // Register input handler for getting Telegram messages from channel, chat, etc
+    core.registerIOHandler({
+        name: "telegram_channel_scraper",
+        role: HandlerRole.INPUT,
+        handler: async (data: unknown) => {
+            const messageData = data as {
+                chatId: number;
+                limit?: number;
+                offset?: number;
+            };
+            return telegram.createChannelScraper().handler(messageData);
+        },
+        schema: z
+            .object({
+                chatId: z
+                    .number()
+                    .describe("The chat ID to retrieve messages from"),
+                limit: z
+                    .number()
+                    .optional()
+                    .describe("The limit for the number of messages to fetch"),
+                offset: z
+                    .number()
+                    .optional()
+                    .describe("The offset for the messages to fetch"),
+            })
+            .describe(
+                "This is for getting messages from a chat"
+            ),
+    });
+
+
+    // Register output handler for sending Telegram messages from bot or user
+    core.registerIOHandler({
+        name: "telegram_send_message",
+        role: HandlerRole.OUTPUT,
+        handler: async (data: unknown) => {
+            const messageData = data as {
+                content: string;
+                chatId: number;
+            };
+            return telegram.createSendMessageOutput().handler(messageData);
+        },
+        schema: z
+            .object({
+                content: z.string(),
+                chatId: z
+                    .number()
+                    .optional()
+                    .describe("The chat ID for the message"),
+            })
+            .describe(
+                "This is for sending a message."
+            ),
+    });
+
+    // Set up readline interface
+    const rl = readline.createInterface({
+        input: process.stdin,
+        output: process.stdout,
+    });
+
+    // Start the prompt loop
+    console.log(chalk.cyan("🤖 Bot is now running and monitoring Telegram..."));
+    console.log(chalk.cyan("You can type messages in the console."));
+    console.log(chalk.cyan('Type "exit" to quit'));
+
+    // Handle graceful shutdown
+    process.on("SIGINT", async () => {
+        console.log(chalk.yellow("\n\nShutting down..."));
+
+        // Clean up resources
+        telegram.logout();
+        core.removeIOHandler("telegram_channel_scraper");
+        core.removeIOHandler("telegram_send_message");
+        rl.close();
+
+        console.log(chalk.green("✅ Shutdown complete"));
+        process.exit(0);
+    });
+}
+
+// Run the example
+main().catch((error) => {
+    console.error(chalk.red("Fatal error:"), error);
+    process.exit(1);
+});

package.json

@@ -7,6 +7,7 @@
         "twitter": "bun run examples/example-twitter.ts",
         "server": "bun run examples/example-server.ts",
         "discord": "bun run examples/example-discord.ts",
+        "telegram": "bun run examples/example-telegram.ts",
         "api": "bun run examples/example-api.ts",
         "ui": "pnpm --dir clients/example-ui run dev",
         "test": "bun run packages/core",
@@ -21,12 +22,13 @@
         "ajv": "^8.17.1",
         "chalk": "^5.4.1",
         "cors": "^2.8.5",
-        "express": "^4.21.2",
         "discord.js": "^14.17.3",
+        "express": "^4.21.2",
         "lerna": "^8.1.9",
         "mongodb": "^6.12.0",
         "prettier": "^3.4.2",
         "readline": "^1.3.0",
+        "telegram": "^2.26.16",
         "ws": "^8.18.0",
         "zod": "^3.24.1"
     },

packages/core/src/core/env.ts

@@ -12,6 +12,9 @@ const envSchema = z.object({
     OPENROUTER_API_KEY: z.string(),
     GRAPHQL_URL: z.string(),
     DISCORD_TOKEN: z.string(),
+    TELEGRAM_TOKEN: z.string(),
+    TELEGRAM_API_ID: z.string(),
+    TELEGRAM_API_HASH: z.string(),
     WEBSOCKET_URL: z.string().default("ws://localhost:8080"),
     DRY_RUN: z
         .preprocess((val) => val === "1" || val === "true", z.boolean())