Contents

module DiscoApp::Concerns::SynchroniseWebhooksJob

  extend ActiveSupport::Concern

  COMMON_WEBHOOKS = [:'app/uninstalled', :'shop/update'].freeze

  # 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|
      ShopifyAPI::Webhook.delete(webhook.id) unless expected_topics.include?(webhook.topic.to_sym)
    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

2 entries across 2 versions & 1 rubygems

Version	Path
disco_app-0.17.0	app/jobs/disco_app/concerns/synchronise_webhooks_job.rb
disco_app-0.18.0	app/jobs/disco_app/concerns/synchronise_webhooks_job.rb