feat: allow "global" webhooks (matching all consumers and providers) to be triggered by pact or verification publication

Author: bethesque

lib/pact_broker/webhooks/repository.rb

@@ -66,7 +66,8 @@ def find_for_pact pact
       def find_by_consumer_and_or_provider consumer, provider
         find_by_consumer_and_provider(consumer, provider) +
           find_by_consumer_and_provider(nil, provider) +
-          find_by_consumer_and_provider(consumer, nil)
+          find_by_consumer_and_provider(consumer, nil) +
+          find_by_consumer_and_provider(nil, nil)
       end
 
       def find_by_consumer_and_provider consumer, provider
@@ -84,7 +85,8 @@ def find_for_pact_and_event_name pact, event_name
       def find_by_consumer_and_or_provider_and_event_name consumer, provider, event_name
         find_by_consumer_and_provider_and_event_name(consumer, provider, event_name) +
           find_by_consumer_and_provider_and_event_name(nil, provider, event_name) +
-          find_by_consumer_and_provider_and_event_name(consumer, nil, event_name)
+          find_by_consumer_and_provider_and_event_name(consumer, nil, event_name) +
+          find_by_consumer_and_provider_and_event_name(nil, nil, event_name)
       end
 
       def find_by_consumer_and_provider_and_event_name consumer, provider, event_name

lib/pact_broker/webhooks/service.rb

@@ -94,7 +94,7 @@ def self.find_by_consumer_and_provider consumer, provider
       end
 
       def self.trigger_webhooks pact, verification, event_name
-        webhooks = webhook_repository.find_by_consumer_and_provider_and_event_name pact.consumer, pact.provider, event_name
+        webhooks = webhook_repository.find_by_consumer_and_or_provider_and_event_name pact.consumer, pact.provider, event_name
 
         if webhooks.any?
           run_later(webhooks, pact, verification, event_name)

spec/lib/pact_broker/webhooks/repository_spec.rb

@@ -365,12 +365,14 @@ module Webhooks
               .create_webhook(uuid: '3', events: [{ name: 'something_else_happened' }])
               .create_consumer_webhook(uuid: '4', events: [{ name: 'something_happened' }])
               .create_provider_webhook(uuid: '5', events: [{ name: 'something_happened' }])
+              .create_global_webhook(uuid: '6', events: [{ name: 'something_happened' }])
+              .create_global_webhook(uuid: '7', events: [{ name: 'something_else_happened' }])
           end
 
           subject { Repository.new.find_for_pact_and_event_name(td.pact, 'something_happened') }
 
           it "returns an array of webhooks" do
-            expect(subject.collect(&:uuid).sort).to eq ['1', '2', '4', '5']
+            expect(subject.collect(&:uuid).sort).to eq ['1', '2', '4', '5', '6']
           end
         end
       end

spec/lib/pact_broker/webhooks/service_spec.rb

@@ -39,15 +39,15 @@ module Webhooks
         let(:triggered_webhook) { instance_double(PactBroker::Webhooks::TriggeredWebhook) }
 
         before do
-          allow_any_instance_of(PactBroker::Webhooks::Repository).to receive(:find_by_consumer_and_provider_and_event_name).and_return(webhooks)
+          allow_any_instance_of(PactBroker::Webhooks::Repository).to receive(:find_by_consumer_and_or_provider_and_event_name).and_return(webhooks)
           allow_any_instance_of(PactBroker::Webhooks::Repository).to receive(:create_triggered_webhook).and_return(triggered_webhook)
           allow(Job).to receive(:perform_in)
         end
 
         subject { Service.trigger_webhooks pact, verification, PactBroker::Webhooks::WebhookEvent::CONTRACT_CONTENT_CHANGED }
 
         it "finds the webhooks" do
-          expect_any_instance_of(PactBroker::Webhooks::Repository).to receive(:find_by_consumer_and_provider_and_event_name).with(consumer, provider, PactBroker::Webhooks::WebhookEvent::DEFAULT_EVENT_NAME)
+          expect_any_instance_of(PactBroker::Webhooks::Repository).to receive(:find_by_consumer_and_or_provider_and_event_name).with(consumer, provider, PactBroker::Webhooks::WebhookEvent::DEFAULT_EVENT_NAME)
           subject
         end
 

spec/support/test_data_builder.rb

@@ -261,6 +261,10 @@ def create_webhook parameters = {}
     self
   end
 
+  def create_global_webhook parameters = {}
+    create_webhook(parameters.merge(consumer: nil, provider: nil))
+  end
+
   def create_provider_webhook parameters = {}
     create_webhook(parameters.merge(consumer: nil))
   end