Reimplement datakick import task

[ferrisoxide]

Reimplement the /lib/tasks/datakick.rake task previously implemented in brocade proper:

# frozen_string_literal: true

require 'csv'
require 'open-uri'
require 'fileutils'

def for_each_item(&)
  filename = File.expand_path(
    'items.csv',
    Rails.root.join('db/seeds/datakick').to_s
  )

  CSV.foreach(filename, headers: true, &)
end

namespace :datakick do # rubocop:disable Metrics/BlockLength
  namespace :download do # rubocop:disable Metrics/BlockLength
    desc 'Download datakick-sourced images and store in db/seeds/datakick'
    task images: :environment do # rubocop:disable Metrics/BlockLength
      base_download_path = Rails.root.join('db/seeds/datakick/images').to_s

      for_each_item do |row| # rubocop:disable Metrics/BlockLength
        if row['Images'].present?
          images = row['Images'].split(',').map(&:strip)
          gtin = row['GTIN-14']

          product_image_path = File.join(base_download_path, gtin)
          FileUtils.mkdir_p(product_image_path)

          images.each do |image|
            filename = File.join(
              product_image_path,
              image.match(%r{https://.*cloudfront.net/(.*)})[1]
            )

            if File.exist?(filename)
              puts "Skipping existing file '#{filename}'"
              next
            end

            puts "Downloading to '#{filename}'"

            begin
              open(image) do |download_file| # rubocop:disable Security/Open
                File.open(filename, 'wb') do |file|
                  file.puts download_file.read
                end
              end
            rescue OpenURI::HTTPError => e
              puts "Cannot download from '#{image}'. Error: #{e.message}"
            end
          end
        end
      end
    end
  end

  namespace :db do # rubocop:disable Metrics/BlockLength
    desc 'Loads datakick-sourced seed data from db/seeds/datakick'
    task seed: :environment do
      for_each_item do |row|
        properties = row
                     .to_h
                     .compact
                     .except('GTIN-14', 'Name', 'Brand Name', 'Images')
                     .transform_keys do |key|
          key
            .remove(/\s\((g|mg)\)\z/)
            .gsub(/\s/, '_')
            .downcase
            .to_sym
        end

        attributes = {
          gtin: row['GTIN-14'],
          gtin_encoding: :gtin_14, # rubocop:disable Naming/VariableNumber
          name: row['Name'],
          brand_name: row['Brand Name'],
          properties:,
          source: 'datakick',
          created_at: DateTime.now.utc,
          updated_at: DateTime.now.utc
        }

        Product.upsert(attributes, unique_by: :gtin) # rubocop:disable Rails/SkipsModelValidations
      end
    end
  end
end