app/sidekiq/income_limits/std_state_import.rb
# frozen_string_literal: true

# rubocop:disable Metrics/MethodLength

require 'net/http'
require 'csv'

module IncomeLimits
  class StdStateImport
    include Sidekiq::Job

    def fetch_csv_data
      csv_url = 'https://sitewide-public-websites-income-limits-data.s3-us-gov-west-1.amazonaws.com/std_state.csv'
      uri = URI(csv_url)
      http = Net::HTTP.new(uri.host, uri.port)
      http.use_ssl = true if uri.scheme == 'https'
      request = Net::HTTP::Get.new(uri.request_uri)
      response = http.request(request)
      response.body if response.code == '200'
    end

    def perform
      ActiveRecord::Base.transaction do
        data = fetch_csv_data
        if data
          CSV.parse(data, headers: true) do |row|
            created = DateTime.strptime(row['CREATED'], '%F %H:%M:%S %z').to_s
            updated = DateTime.strptime(row['UPDATED'], '%F %H:%M:%S %z').to_s if row['UPDATED']
            std_state = StdState.find_or_initialize_by(id: row['ID'].to_i)
            next unless std_state.new_record?

            std_state.assign_attributes(
              id: row['ID'].to_i,
              name: row['NAME'],
              postal_name: row['POSTALNAME'],
              fips_code: row['FIPSCODE'].to_i,
              country_id: row['COUNTRY_ID'].to_i,
              version: row['VERSION'].to_i,
              created:,
              updated:,
              created_by: row['CREATEDBY'],
              updated_by: row['UPDATEDBY']
            )
            std_state.save!
          end
        else
          raise 'Failed to fetch CSV data'
        end
      end
    rescue => e
      ActiveRecord::Base.rollback_transaction
      raise "error: #{e}"
    end
  end
end

# rubocop:enable Metrics/MethodLength
