add telegram support

Signed-off-by: Tim Paine <3105306+timkpaine@users.noreply.github.com>

Author: timkpaine

csp_bot/__init__.py

@@ -17,7 +17,7 @@
 from chatom import Channel, Message, User
 
 from .bot import Bot
-from .bot_config import BotConfig, DiscordConfig, SlackConfig, SymphonyConfig
+from .bot_config import BotConfig, DiscordConfig, SlackConfig, SymphonyConfig, TelegramConfig
 from .commands import (
     BaseCommand,
     BaseCommandModel,
@@ -53,6 +53,7 @@
     "DiscordConfig",
     "SlackConfig",
     "SymphonyConfig",
+    "TelegramConfig",
     # Commands
     "BaseCommand",
     "BaseCommandModel",

csp_bot/backends/__init__.py

@@ -10,3 +10,4 @@
 from .discord import *
 from .slack import *
 from .symphony import *
+from .telegram import *

csp_bot/backends/telegram.py

@@ -0,0 +1,31 @@
+"""Telegram backend integration using chatom.
+
+This module provides Telegram-specific types and adapters through chatom.
+"""
+
+__all__ = (
+    "TelegramConfig",
+    "TelegramAdapter",
+    "TelegramMessage",
+    "TelegramUser",
+)
+
+try:
+    from chatom.telegram import (
+        TelegramConfig,
+        TelegramMessage,
+        TelegramUser,
+    )
+    from csp_adapter_telegram import TelegramAdapter
+except ImportError:
+    from chatom import Message as ChatomMessage, User as ChatomUser
+    from pydantic import BaseModel
+
+    class TelegramConfig(BaseModel):
+        """Placeholder when chatom.telegram is not available."""
+
+        pass
+
+    TelegramAdapter = None
+    TelegramMessage = ChatomMessage
+    TelegramUser = ChatomUser

csp_bot/bot.py

@@ -34,6 +34,7 @@
     SlackAdapter,
     SymphonyAdapter,
     SymphonyPresenceStatus,
+    TelegramAdapter,
 )
 from .bot_config import BotConfig
 from .commands import (
@@ -108,6 +109,13 @@ def connect(self, channels: GatewayChannels) -> None:
             self._configs["symphony"] = self.config.symphony
             self._adapters["symphony"] = SymphonyAdapter(self.config.symphony.config)
 
+        # Initialize Telegram
+        if self.config.telegram:
+            if TelegramAdapter is None:
+                raise ImportError("Telegram adapter not installed. Please install csp-adapter-telegram.")
+            self._configs["telegram"] = self.config.telegram
+            self._adapters["telegram"] = TelegramAdapter(self.config.telegram.config)
+
         # Fetch bot info for all backends at startup
         for backend in self._adapters.keys():
             log.info(f"Fetching bot info for {backend}...")
@@ -167,7 +175,7 @@ def connect(self, channels: GatewayChannels) -> None:
             self._adapters["symphony"].publish_presence(presence)
 
         # Set up user access queries
-        for backend in ["symphony", "slack", "discord"]:
+        for backend in ["symphony", "slack", "discord", "telegram"]:
             config = self._configs.get(backend)
             if config and config.user_access_channels:
                 self._update_user_access(backend)

csp_bot/bot_config.py

@@ -13,6 +13,7 @@
     DiscordConfig as ChatomDiscordConfig,
     SlackConfig as ChatomSlackConfig,
     SymphonyConfig as ChatomSymphonyConfig,
+    TelegramConfig as ChatomTelegramConfig,
 )
 
 __all__ = (
@@ -21,6 +22,7 @@
     "DiscordConfig",
     "SlackConfig",
     "SymphonyConfig",
+    "TelegramConfig",
 )
 
 
@@ -89,6 +91,15 @@ class SymphonyConfig(BackendConfig):
     )
 
 
+class TelegramConfig(BackendConfig):
+    """Telegram bot configuration."""
+
+    config: ChatomTelegramConfig = Field(
+        default_factory=ChatomTelegramConfig,
+        description="Chatom Telegram configuration.",
+    )
+
+
 class BotConfig(BaseModel):
     """Main bot configuration.
 
@@ -99,6 +110,7 @@ class BotConfig(BaseModel):
     discord: Optional[DiscordConfig] = None
     slack: Optional[SlackConfig] = None
     symphony: Optional[SymphonyConfig] = None
+    telegram: Optional[TelegramConfig] = None
 
     ratelimit_seconds: float = Field(
         default=1.0,

csp_bot/commands/help.py

@@ -85,6 +85,12 @@ def execute(
             for cmd_key, name, help_text in helps:
                 lines.append(f"| /{cmd_key} | {name} | {help_text} |")
             content = "\n".join(lines)
+        elif command.backend == "telegram":
+            # Telegram uses HTML formatting
+            lines = ["<b>Bot Commands Help</b>", ""]
+            for cmd_key, name, help_text in helps:
+                lines.append(f"/{cmd_key} — <b>{name}</b>: {help_text}")
+            content = "\n".join(lines)
         else:
             # Plain text fallback
             lines = ["Bot Commands Help", ""]

csp_bot/config/gateway/all.yaml

@@ -11,6 +11,8 @@ slack_bot_token: ???
 symphony_bot_name: ???
 symphony_cert: ???
 symphony_key: ???
+telegram_bot_name: ???
+telegram_bot_token: ???
 
 modules:
   bot:
@@ -37,7 +39,13 @@ modules:
           _target_: csp_bot.SymphonyAdapterConfig
           cert_string: ${symphony_cert}
           key_string: ${symphony_key}
+      telegram_config:
+        _target_: csp_bot.TelegramConfig
+        bot_name: ${telegram_bot_name}
+        adapter_config:
+          _target_: csp_bot.TelegramAdapterConfig
+          bot_token: ${telegram_bot_token}
 
 hydra:
   job:
-    name: csp-bot--discord[${discord_bot_name}]-slack[${slack_bot_name}]-symphony[${symphony_bot_name}]
+    name: csp-bot--discord[${discord_bot_name}]-slack[${slack_bot_name}]-symphony[${symphony_bot_name}]-telegram[${telegram_bot_name}]

csp_bot/config/gateway/telegram.yaml

@@ -0,0 +1,23 @@
+# @package _global_
+defaults:
+  - /modules
+  - _self_
+
+bot_name: ???
+bot_token: ???
+
+modules:
+  bot:
+    _target_: csp_bot.Bot
+    config:
+      _target_: csp_bot.BotConfig
+      telegram_config:
+        _target_: csp_bot.TelegramConfig
+        bot_name: ${bot_name}
+        adapter_config:
+          _target_: csp_bot.TelegramAdapterConfig
+          bot_token: ${bot_token}
+
+hydra:
+  job:
+    name: csp-bot-telegram[${bot_name}]

csp_bot/utils.py

@@ -22,7 +22,7 @@
     "Backend",
 )
 
-Backend = Literal["discord", "slack", "symphony"]
+Backend = Literal["discord", "slack", "symphony", "telegram"]
 
 
 def is_valid_url(url: str) -> bool:

pyproject.toml

@@ -18,6 +18,7 @@ keywords = [
     "csp",
     "stream-processing",
     "slack",
+    "telegram",
     "chat",
     "chatbot",
 ]
@@ -58,6 +59,7 @@ develop = [
     "csp-adapter-discord>=0.2,<0.3",
     "csp-adapter-slack>=0.4,<0.5",
     "csp-adapter-symphony>=0.4,<0.5",
+    "csp-adapter-telegram>=0.1,<0.2",
     "hatchling",
     "mdformat",
     "mdformat-tables>=1",