Sha256: 5cfa551d07b5217cb33a1687adfe4a57d1d2e749bcb8f511320f075f9b0b9d56
Contents?: true
Size: 1.46 KB
Versions: 15
Compression:
Stored size: 1.46 KB
Contents
# frozen_string_literal: true
module FlowcommerceSpree
# A service object to import the data for product variants belonging to a flow.io Experience
class ImportItem
def self.run(variant, client: FlowcommerceSpree.client, organization: ORGANIZATION)
new(variant, client: client, organization: organization).run
end
def run
@client.experiences.get(@organization, status: 'active').each do |experience|
experience_key = experience.key
zone = Spree::Zones::Product.find_by(name: experience_key.titleize)
next unless zone
import_data(zone)
end
end
private
def initialize(variant, client:, organization:)
@client = client
@logger = client.instance_variable_get(:@http_handler).logger
@organization = organization
@variant = variant
end
def import_data(zone)
experience_key = zone.flow_io_experience
item = begin
@client.experiences.get_items_by_number(@organization, @variant.sku, experience: experience_key)
rescue Io::Flow::V0::HttpClient::PreconditionException, Io::Flow::V0::HttpClient::ServerError => e
@logger.info "flow.io API error: #{e.message}"
end
return unless item
item_hash = item.to_hash
@variant.flow_import_item(item_hash, experience_key: @experience_key)
@logger.info "[#{@variant.sku}][#{experience_key}] Variant experience imported successfully."
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems