# frozen_string_literal: true

require "csv"
require "net/http"

require "provider/adapters/adapter"

class Provider
  module Adapters
    # Bank of Israel. Fetches daily representative exchange rates for 14
    # currencies against the Israeli new shekel (ILS) via the SDMX API.
    # Supports date range queries and full historical backfill.
    class BOI < Adapter
      BASE_URL = "https://edge.boi.gov.il/FusionEdgeServer/sdmx/v2/data/dataflow/BOI.STATISTICS/EXR/1.0/"
      def fetch(after: nil, upto: nil)
        url = URI(BASE_URL)
        url.query = URI.encode_www_form(
          "c[DATA_TYPE]" => "OF00",
          "startperiod" => after.to_s,
          "endperiod" => (upto || Date.today).to_s,
          "format" => "csv",
        )

        response = Net::HTTP.get(url)
        parse(response)
      end

      def parse(csv)
        rows = CSV.parse(csv, headers: true)

        rows.filter_map do |row|
          base = row["BASE_CURRENCY"]
          date_str = row["TIME_PERIOD"]
          rate_str = row["OBS_VALUE"]
          unit_mult = row["UNIT_MULT"]
          next unless base && date_str && rate_str

          rate_value = Float(rate_str)
          # UNIT_MULT is power of 10: 2 means per 100 units, 1 means per 10
          rate_value /= (10**Integer(unit_mult)) if unit_mult && unit_mult != "0"
          next if rate_value.zero?

          date = Date.parse(date_str)
          { date:, base:, quote: "ILS", rate: rate_value }
        end
      end
    end
  end
end