Sha256: d912cbfda3affad9c2a74cec75607d6357baabf56fe33a10409c8577002f9bb1
Contents?: true
Size: 1.04 KB
Versions: 11
Compression:
Stored size: 1.04 KB
Contents
# frozen_string_literal: true
module SolidusBactracs
module Api
class SyncShipmentsJob < ApplicationJob
queue_as :default
def perform(shipments)
shipments = select_shipments(shipments)
return if shipments.empty?
sync_shipments(shipments)
# Verify bactracs sync
shipments.each { |shipment| VerifyBactracsSyncWorker.perform_async(shipment.id) }
rescue RateLimitedError => e
self.class.set(wait: e.retry_in).perform_later
rescue StandardError => e
SolidusBactracs.config.error_handler.call(e, {})
end
private
def select_shipments(shipments)
shipments.select do |shipment|
if ThresholdVerifier.call(shipment)
true
else
::Spree::Event.fire(
'solidus_bactracs.api.sync_skipped',
shipment: shipment,
)
false
end
end
end
def sync_shipments(shipments)
BatchSyncer.from_config.call(shipments)
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems