stash
This commit is contained in:
parent
283f30faa5
commit
5f5a2f008d
1 changed files with 2 additions and 3 deletions
|
@ -43,8 +43,7 @@ class NotificationDispatcher:
|
||||||
|
|
||||||
@database_sync_to_async
|
@database_sync_to_async
|
||||||
def get_ticket(self, ticket_id):
|
def get_ticket(self, ticket_id):
|
||||||
return IssueThread.objects.filter(id=ticket_id).select_related('event').prefetch_related('state_changes',
|
return IssueThread.objects.filter(id=ticket_id).select_related('event').first()
|
||||||
'assignments').first()
|
|
||||||
|
|
||||||
async def run_forever(self):
|
async def run_forever(self):
|
||||||
# Infinite loop to continuously listen for messages
|
# Infinite loop to continuously listen for messages
|
||||||
|
@ -68,7 +67,7 @@ class NotificationDispatcher:
|
||||||
message = render_notification_new_ticket(ticket) if new else await render_notification_reply_ticket(ticket)
|
message = render_notification_new_ticket(ticket) if new else await render_notification_reply_ticket(ticket)
|
||||||
print("Dispatching message:", message, "with event_id:", event_id)
|
print("Dispatching message:", message, "with event_id:", event_id)
|
||||||
targets = await self.get_notification_targets()
|
targets = await self.get_notification_targets()
|
||||||
#await telegram_notify(message, TELEGRAM_GROUP_CHAT_ID)
|
# await telegram_notify(message, TELEGRAM_GROUP_CHAT_ID)
|
||||||
for target in targets:
|
for target in targets:
|
||||||
if target.channel_type == 'telegram':
|
if target.channel_type == 'telegram':
|
||||||
print("Sending telegram notification to:", target.channel_target)
|
print("Sending telegram notification to:", target.channel_target)
|
||||||
|
|
Loading…
Reference in a new issue