Only queue webhooks for events we're listening to

app/controllers/pay/webhooks/braintree_controller.rb

@@ -15,6 +15,8 @@ def create
       private
 
       def queue_event(event)
+        return unless Pay::Webhooks.delegator.listening?("braintree.#{event.kind}")
+
         record = Pay::Webhook.create(
           processor: :braintree,
           event_type: event.kind,

app/controllers/pay/webhooks/paddle_controller.rb

@@ -15,6 +15,8 @@ def create
       private
 
       def queue_event(event)
+        return unless Pay::Webhooks.delegator.listening?("paddle.#{params[:alert_name]}")
+
         record = Pay::Webhook.create(processor: :paddle, event_type: params[:alert_name], event: event)
         Pay::Webhooks::ProcessJob.perform_later(record)
       end

app/controllers/pay/webhooks/stripe_controller.rb

@@ -16,6 +16,8 @@ def create
       private
 
       def queue_event(event)
+        return unless Pay::Webhooks.delegator.listening?("stripe.#{event.type}")
+
         record = Pay::Webhook.create(processor: :stripe, event_type: event.type, event: event)
         Pay::Webhooks::ProcessJob.perform_later(record)
       end

lib/pay/webhooks/delegator.rb

@@ -35,6 +35,10 @@ def instrument(event:, type:)
         backend.instrument name_with_namespace(type), event
       end
 
+      def listening?(type)
+        backend.notifier.listening? name_with_namespace(type)
+      end
+
       # Strips down to event data only
       class NotificationAdapter
         def initialize(subscriber)

test/pay/webhooks/delegator_test.rb

@@ -62,6 +62,12 @@ def call(event)
     assert_equal 2, results.length
   end
 
+  test "listening?" do
+    refute delegator.listening?("example.test_event")
+    delegator.subscribe "example.test_event", ->(event) {}
+    assert delegator.listening?("example.test_event")
+  end
+
   private
 
   attr_reader :delegator