Sha256: 2bd64df288ca7f8be23f3ba80cba92ca4ca5743e6c645ba6e13a3e01f7f58109
Contents?: true
Size: 634 Bytes
Versions: 22
Compression:
Stored size: 634 Bytes
Contents
module Spree
module Webhooks
module Subscribers
class QueueRequests
prepend Spree::ServiceModule::Base
def call(event_name:, webhook_payload_body:, **options)
filtered_subscribers(event_name, webhook_payload_body, options).each do |subscriber|
Spree::Webhooks::Subscribers::MakeRequestJob.perform_later(
webhook_payload_body, event_name, subscriber
)
end
end
private
def filtered_subscribers(event_name, _, _)
Spree::Webhooks::Subscriber.active.with_urls_for(event_name)
end
end
end
end
end
Version data entries
22 entries across 22 versions & 3 rubygems