From 245931f6033e9d9042c72b05b0f0e34ba12896a3 Mon Sep 17 00:00:00 2001
From: Jeff Bradberry <jeff.bradberry@gmail.com>
Date: Wed, 4 Sep 2019 16:47:30 -0400
Subject: [PATCH] Debounce when multiple copies of the same webhook event come
 in

---
 awx/api/views/webhooks.py | 32 ++++++++++++++++++++++++--------
 1 file changed, 24 insertions(+), 8 deletions(-)

diff --git a/awx/api/views/webhooks.py b/awx/api/views/webhooks.py
index 65635b033a..31b9755575 100644
--- a/awx/api/views/webhooks.py
+++ b/awx/api/views/webhooks.py
@@ -14,7 +14,7 @@ from rest_framework.response import Response
 from awx.api import serializers
 from awx.api.generics import APIView, GenericAPIView
 from awx.api.permissions import WebhookKeyPermission
-from awx.main.models import JobTemplate, WorkflowJobTemplate
+from awx.main.models import Job, JobTemplate, WorkflowJob, WorkflowJobTemplate
 
 
 logger = logging.getLogger('awx.api.views.webhooks')
@@ -93,20 +93,36 @@ class WebhookReceiverBase(APIView):
 
     @csrf_exempt
     def post(self, request, *args, **kwargs):
-        logger.error(
-            "**************************************\n"
-            "{}\n"
-            "{}\n".format(request.headers, request.data)
+        logger.debug(
+            "headers: {}\n"
+            "data: {}\n".format(request.headers, request.data)
         )
         obj = self.get_object()
         self.check_signature(obj)
 
+        event_type = self.get_event_type()
+        event_guid = self.get_event_guid()
+
+        kwargs = {
+            'webhook_service': obj.webhook_service,
+            'webhook_guid': event_guid,
+        }
+        if WorkflowJob.objects.filter(**kwargs).exists() or Job.objects.filter(**kwargs).exists():
+            # Short circuit if this webhook has already been received and acted upon.
+            logger.debug("Webhook previously received, returning without action.")
+            return Response(status=status.HTTP_202_ACCEPTED)
+
         data = {
-            'tower_webhook_event_type': self.get_event_type(),
-            'tower_webhook_event_guid': self.get_event_guid(),
+            'tower_webhook_event_type': event_type,
+            'tower_webhook_event_guid': event_guid,
             'tower_webhook_payload': request.data,
         }
-        new_job = obj.create_unified_job(extra_vars=json.dumps(data))
+        new_job = obj.create_unified_job(
+            webhook_service=obj.webhook_service,
+            webhook_credential=obj.webhook_credential,
+            webhook_guid=event_guid,
+            extra_vars=json.dumps(data)
+        )
         new_job.signal_start()
 
         return Response(status=status.HTTP_202_ACCEPTED)