Sha256: 5ef1b090a65b92a05ea7a93722fdb31cda4874f3465abf2dfcf305dd220092ca
Contents?: true
Size: 1.66 KB
Versions: 9
Compression:
Stored size: 1.66 KB
Contents
module Spree
module Webhooks
class Subscriber < Spree::Webhooks::Base
if defined?(Spree::VendorConcern)
include Spree::VendorConcern
end
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
9 entries across 9 versions & 3 rubygems