Sha256: 0194d458d7800f8f1b2f429750ab804a02bcbe2d72dbba62a9c588bbf6d95098
Contents?: true
Size: 1.83 KB
Versions: 10
Compression:
Stored size: 1.83 KB
Contents
module DiscoApp::Concerns::SynchroniseWebhooksJob
extend ActiveSupport::Concern
COMMON_WEBHOOKS = [:'app/uninstalled', :'shop/update']
# Ensure the webhooks registered with our shop are the same as those listed
# in our application configuration.
def perform(_shop)
# Register any webhooks that haven't been registered yet.
(expected_topics - current_topics).each do |topic|
with_verbose_output(topic) do
ShopifyAPI::Webhook.create(
topic: topic,
address: webhooks_url,
format: 'json',
)
end
end
# Remove any extraneous topics.
current_webhooks.each do |webhook|
unless expected_topics.include?(webhook.topic.to_sym)
ShopifyAPI::Webhook.delete(webhook.id)
end
end
# Ensure webhook addresses are current.
current_webhooks.each do |webhook|
unless webhook.address == webhooks_url
webhook.address = webhooks_url
webhook.save
end
end
end
private
# Get the full list of expected webhook topics.
def expected_topics
COMMON_WEBHOOKS + (DiscoApp.configuration.webhook_topics || [])
end
# Return a list of currently registered topics.
def current_topics
current_webhooks.map(&:topic).map(&:to_sym)
end
# Return a list of current registered webhooks.
def current_webhooks
@current_webhooks ||= ShopifyAPI::Webhook.find(:all)
end
# Return the absolute URL to the webhooks endpoint.
def webhooks_url
DiscoApp::Engine.routes.url_helpers.webhooks_url
end
def with_verbose_output(topic)
print "\n#{topic}"
shopify_response = yield
if shopify_response.errors.blank?
print " - registered successfully\n"
else
print " - not registered\n"
puts shopify_response.errors.messages
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems