Support Telegram topics/threads (#463)

* feature: telegram topic/threads

* feature: telegram topic/threads, linting prettier fix

* feature: telegram topic/threads, linting prettier fix

* feature: telegram topic/threads, linting prettier fix

* support env var

---------

Co-authored-by: Charlie Laabs <[email protected]>

Author: bobweasel

Readme.md

@@ -58,6 +58,7 @@ The config file is stored in the mounted `/usr/app/config` volume and can be nam
       "apiUrl": "https://api.telegram.org",
       "token": "644739147:AAGMPo-Jz3mKRnHRTnrPEDi7jUF1vqNOD5k",
       "chatId": "-987654321",
+      "topic": 5,
     },
     {
       "type": "apprise",

src/common/config/classes.ts

@@ -207,6 +207,15 @@ export class TelegramConfig extends NotifierConfig {
   @IsNotEmpty()
   chatId: string;
 
+  /**
+   * Identifier for the topic/thread to send the messages
+   * @example 5
+   * @env TELEGRAM_TOPIC
+   */
+  @IsInt()
+  @IsOptional()
+  topic?: number;
+
   /**
    * Custom TELEGRAM server URL
    * @default https://api.telegram.org
@@ -1074,11 +1083,12 @@ export class AppConfig {
     }
 
     // Use environment variables to fill telegram notification config if present
-    const { TELEGRAM_TOKEN, TELEGRAM_CHAT_ID } = process.env;
+    const { TELEGRAM_TOKEN, TELEGRAM_CHAT_ID, TELEGRAM_TOPIC } = process.env;
     if (TELEGRAM_TOKEN && TELEGRAM_CHAT_ID) {
       const telegram = new TelegramConfig();
       telegram.token = TELEGRAM_TOKEN;
       telegram.chatId = TELEGRAM_CHAT_ID;
+      telegram.topic = TELEGRAM_TOPIC ? parseInt(TELEGRAM_TOPIC, 10) : undefined;
       this.notifiers ??= [];
       if (!this.notifiers.some((notifConfig) => notifConfig instanceof TelegramConfig)) {
         this.notifiers.push(telegram);

src/notifiers/telegram.ts

@@ -33,6 +33,7 @@ export class TelegramNotifier extends NotifierService {
       text: escapedMessage,
       disable_web_page_preview: true,
       parse_mode: 'MarkdownV2',
+      ...(this.config.topic ? { message_thread_id: this.config.topic } : {}),
     };
 
     L.trace({ jsonPayload }, 'Sending json payload');