Sha256: 7d00aedd82d7c7088199fbbf8b32fc383ad88a63cc57538960d88454ec2f1ea0
Contents?: true
Size: 1.65 KB
Versions: 15
Compression:
Stored size: 1.65 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 ImportExperienceItems
def self.run(zone, client: FlowcommerceSpree.client, organization: ORGANIZATION)
new(zone, client: client, organization: organization).run
end
def run
page_size = 100
offset = 0
items = []
total = 0
while offset == 0 || items.length != 0
# show current list size
@logger.info "\nGetting items: #{@experience_key.green}, rows #{offset} - #{offset + page_size}"
begin
items = @client.experiences
.get_items(@organization, experience: @experience_key, limit: page_size, offset: offset)
rescue Io::Flow::V0::HttpClient::PreconditionException => e
@logger.info "flow.io API error: #{e.message}"
break
end
offset += page_size
log_str = +''
items.each do |item|
total += 1
item_hash = item.to_hash
next unless (variant = Spree::Variant.find_by(sku: item_hash.delete(:number)))
variant.flow_import_item(item_hash, experience_key: @experience_key)
log_str << "#{variant.sku}, "
end
@logger.info log_str
end
@logger.info "\nData for #{total.to_s.green} products was imported."
end
private
def initialize(zone, client:, organization:)
@client = client
@experience_key = zone.flow_io_experience
@logger = client.instance_variable_get(:@http_handler).logger
@organization = organization
@zone = zone
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems