From 7e2b9d415878e76d734dbb61083185f508fdd620 Mon Sep 17 00:00:00 2001 From: oliverhnat Date: Sat, 25 Jan 2025 15:12:08 +0100 Subject: [PATCH] feat(disclosures): add support for telegram channel IDs as CSV --- disclosures/financial_disclosure.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/disclosures/financial_disclosure.py b/disclosures/financial_disclosure.py index 3327c15..e34068f 100644 --- a/disclosures/financial_disclosure.py +++ b/disclosures/financial_disclosure.py @@ -12,14 +12,17 @@ load_dotenv() class Disclosures: def __init__( - self, telegram_api_key, telegram_channel, db_name, schema_path, seed_path + self, telegram_api_key, telegram_channels, db_name, schema_path, seed_path ): - self.telegram = Telegram(telegram_api_key, telegram_channel) + self.telegrams = [] + for telegram_channel in telegram_channels.split(","): + self.telegrams.append(Telegram(telegram_api_key, telegram_channel)) self.db = DB(db_name, schema_path, seed_path) async def send_message(self, message, return_value=True): try: - await self.telegram.send_message(message) + for telegram in self.telegrams: + await telegram.send_message(message) return return_value except Exception as e: self.log(f"Error sending message: {e}, message: {message}, return_value: {return_value}")