Contents

require 'appsignal'

# The base class for all jobs that should be performed in the context of a
# particular Shop's API session. The first argument to any job inheriting from
# this class must be the domain of the relevant store, so that the appropriate
# Shop model can be fetched and the temporary API session created.

class DiscoApp::ShopJob < ApplicationJob

  queue_as :default

  before_perform { |job| find_shop(job) }
  before_enqueue { |job| find_shop(job) }

  around_enqueue { |job, block| shop_context(job, block) }
  around_perform { |job, block| shop_context(job, block) }

  private

    def find_shop(job)
      @shop ||= job.arguments.first.is_a?(DiscoApp::Shop) ? job.arguments.first : DiscoApp::Shop.find_by!(shopify_domain: job.arguments.first)
    end

    def shop_context(job, block)
      Appsignal.tag_request(
        shop_id: @shop.id,
        shopify_domain: @shop.shopify_domain
      )
      
      @shop.with_api_context { block.call(job.arguments) }
    end

end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
disco_app-0.16.1.pre.sidekiq.pre.6.pre.release	app/jobs/disco_app/shop_job.rb
disco_app-0.16.1	app/jobs/disco_app/shop_job.rb