mirror of
https://gitea.mueller.network/extern/django-helpdesk.git
synced 2024-11-25 01:13:31 +01:00
65 lines
2.0 KiB
Python
65 lines
2.0 KiB
Python
import requests
|
|
import requests.exceptions
|
|
import logging
|
|
from django.dispatch import receiver
|
|
|
|
from . import settings
|
|
from .signals import new_ticket_done, update_ticket_done
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
def notify_followup_webhooks(followup):
|
|
urls = settings.HELPDESK_GET_FOLLOWUP_WEBHOOK_URLS()
|
|
if not urls:
|
|
return
|
|
|
|
# Serialize the ticket associated with the followup
|
|
from .serializers import TicketSerializer
|
|
ticket = followup.ticket
|
|
ticket.set_custom_field_values()
|
|
serialized_ticket = TicketSerializer(ticket).data
|
|
|
|
# Prepare the data to send
|
|
data = {
|
|
'ticket': serialized_ticket,
|
|
'queue_slug': ticket.queue.slug,
|
|
'followup_id': followup.id
|
|
}
|
|
|
|
for url in urls:
|
|
try:
|
|
requests.post(url, json=data, timeout=settings.HELPDESK_WEBHOOK_TIMEOUT)
|
|
except requests.exceptions.Timeout:
|
|
logger.error('Timeout while sending followup webhook to %s', url)
|
|
|
|
# listener is loaded via app.py HelpdeskConfig.ready()
|
|
@receiver(update_ticket_done)
|
|
def notify_followup_webhooks_receiver(sender, followup, **kwargs):
|
|
notify_followup_webhooks(followup)
|
|
|
|
|
|
def send_new_ticket_webhook(ticket):
|
|
urls = settings.HELPDESK_GET_NEW_TICKET_WEBHOOK_URLS()
|
|
if not urls:
|
|
return
|
|
# Serialize the ticket
|
|
from .serializers import TicketSerializer
|
|
ticket.set_custom_field_values()
|
|
serialized_ticket = TicketSerializer(ticket).data
|
|
|
|
# Prepare the data to send
|
|
data = {
|
|
'ticket': serialized_ticket,
|
|
'queue_slug': ticket.queue.slug
|
|
}
|
|
|
|
for url in urls:
|
|
try:
|
|
requests.post(url, json=data, timeout=settings.HELPDESK_WEBHOOK_TIMEOUT)
|
|
except requests.exceptions.Timeout:
|
|
logger.error('Timeout while sending new ticket webhook to %s', url)
|
|
|
|
# listener is loaded via app.py HelpdeskConfig.ready()
|
|
@receiver(new_ticket_done)
|
|
def send_new_ticket_webhook_receiver(sender, ticket, **kwargs):
|
|
send_new_ticket_webhook(ticket) |