ashish
/
broadcast
1
0
Fork 0
Code Issues 3 Pull Requests Packages Projects Releases Wiki Activity

Another bugfix

This commit is contained in:
Ashish D'Souza 2023-11-22 19:36:40 -06:00
parent a3b2e0e22c
commit 9ed37905c8
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ntfy_router/src/router.py
View File

@ -49,7 +49,7 @@ class NtfyRouter:
self._rabbitmq_publisher.send_notification(user='ashish', priority='high', **notification_args) self._rabbitmq_publisher.send_notification(user='ashish', priority='high', **notification_args)
elif topic in self._formatters['call']: elif topic in self._formatters['call']:
call_args = {call_arg: self._formatters['call'][topic][call_arg](topic=topic, title=title, message=message) for call_arg in self._formatters['call'][topic]} call_args = {call_arg: self._formatters['call'][topic][call_arg](topic=topic, title=title, message=message) for call_arg in self._formatters['call'][topic]}
self._rabbitmq_publisher.send_call(user='ashish', **call_args) self._rabbitmq_publisher.send_call(**call_args)
async def start(self, rabbitmq_host: str, rabbitmq_port: int): async def start(self, rabbitmq_host: str, rabbitmq_port: int):
self._ntfy_subscriber = NtfySubscriber([topic for message_type in self._formatters for topic in self._formatters[message_type]]) self._ntfy_subscriber = NtfySubscriber([topic for message_type in self._formatters for topic in self._formatters[message_type]])