Sha256: 38ff68a8d1e869a773f83cd366510168399153fd971c60ee1ecb371b8134aa2c
Contents?: true
Size: 1.7 KB
Versions: 7
Compression:
Stored size: 1.7 KB
Contents
module Spree
module Webhooks
class Subscriber < Spree::Webhooks::Base
if defined?(Spree::VendorConcern)
include Spree::VendorConcern
end
has_secure_token :secret_key
has_many :events, inverse_of: :subscriber
validates :url, 'spree/url': true, presence: true
validate :check_uri_path
self.whitelisted_ransackable_attributes = %w[active subscriptions url]
self.whitelisted_ransackable_associations = %w[event]
scope :active, -> { where(active: true) }
scope :inactive, -> { where(active: false) }
before_save :parse_subscriptions
def self.with_urls_for(event)
where(
case ActiveRecord::Base.connection.adapter_name
when 'Mysql2'
["('*' MEMBER OF(subscriptions) OR ? MEMBER OF(subscriptions))", event]
when 'PostgreSQL'
["subscriptions @> '[\"*\"]' OR subscriptions @> ?", [event].to_json]
end
)
end
def self.supported_events
Spree::Base.descendants.
select { |model| model.included_modules.include? Spree::Webhooks::HasWebhooks }.
to_h do |model|
model_name = model.name.demodulize.underscore.to_sym
[model_name, model.supported_webhook_events]
end
end
private
def check_uri_path
uri = begin
URI.parse(url)
rescue URI::InvalidURIError
return false
end
errors.add(:url, 'the URL must have a path') if uri.blank? || uri.path.blank?
end
def parse_subscriptions
return if subscriptions.blank? || subscriptions.is_a?(Array)
self.subscriptions = JSON.parse(subscriptions)
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems