Sha256: 756ae5dc27f014b1a918a72a69f5cb35d6ba5aee4372c7ba514a26445d038350
Contents?: true
Size: 1016 Bytes
Versions: 7
Compression:
Stored size: 1016 Bytes
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)
return @shop if @shop
@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
7 entries across 7 versions & 1 rubygems