127 lines
3.5 KiB
Ruby
127 lines
3.5 KiB
Ruby
|
# frozen_string_literal: true
|
||
|
|
|
||
|
|
require "json"
|
||
|
|
require "net/http"
|
||
|
|
|
||
|
|
require "provider/adapters/adapter"
|
||
|
|
|
||
|
|
class Provider
|
||
|
|
module Adapters
|
||
|
|
# Central Bank of Kenya daily exchange rates in KES.
|
||
|
|
# Fetches from two WPDataTables endpoints: table 32 (2003-2024) and table 193 (2024+).
|
||
|
|
class CBK < Adapter
|
||
|
|
BASE_URL = "https://www.centralbank.go.ke/wp-admin/admin-ajax.php"
|
||
|
|
CURRENCY_MAP = {
|
||
|
|
"US DOLLAR" => "USD",
|
||
|
|
"STG POUND" => "GBP",
|
||
|
|
"EURO" => "EUR",
|
||
|
|
"JAPANESE YEN" => "JPY",
|
||
|
|
"JPY" => "JPY",
|
||
|
|
"SWISS FRANC" => "CHF",
|
||
|
|
"S FRANC" => "CHF",
|
||
|
|
"CAN DOLLAR" => "CAD",
|
||
|
|
"CAN $" => "CAD",
|
||
|
|
"AUSTRALIAN DOLLAR" => "AUD",
|
||
|
|
"AUSTRALIAN $" => "AUD",
|
||
|
|
"INDIAN RUPEE" => "INR",
|
||
|
|
"IND RUPEE" => "INR",
|
||
|
|
"SWEDISH KRONA" => "SEK",
|
||
|
|
"SW KRONER" => "SEK",
|
||
|
|
"NORWEGIAN KRONE" => "NOK",
|
||
|
|
"NOR KRONER" => "NOK",
|
||
|
|
"DAN KRONER" => "DKK",
|
||
|
|
"CHINESE YUAN" => "CNY",
|
||
|
|
"S. AFRICAN RAND" => "ZAR",
|
||
|
|
"SA RAND" => "ZAR",
|
||
|
|
"AE DIRHAM" => "AED",
|
||
|
|
"UAE DIRHAM" => "AED",
|
||
|
|
"HONGKONG DOLLAR" => "HKD",
|
||
|
|
"SINGAPORE DOLLAR" => "SGD",
|
||
|
|
"SAUDI RIYAL" => "SAR",
|
||
|
|
"USHS" => "UGX",
|
||
|
|
"TSHS" => "TZS",
|
||
|
|
"RWF" => "RWF",
|
||
|
|
"BIF" => "BIF",
|
||
|
|
}.freeze
|
||
|
|
|
||
|
|
def fetch(after: nil, upto: nil)
|
||
|
|
dataset = []
|
||
|
|
|
||
|
|
if after.nil? || after < Date.new(2024, 1, 5)
|
||
|
|
dataset.concat(fetch_table(32))
|
||
|
|
end
|
||
|
|
|
||
|
|
dataset.concat(fetch_table(193))
|
||
|
|
|
||
|
|
dataset = dataset.select { |r| r[:date] >= after } if after
|
||
|
|
dataset = dataset.select { |r| r[:date] <= upto } if upto
|
||
|
|
|
||
|
|
dataset
|
||
|
|
end
|
||
|
|
|
||
|
|
def parse(json)
|
||
|
|
data = json.is_a?(String) ? JSON.parse(json) : json
|
||
|
|
rows = data["data"]
|
||
|
|
return [] unless rows.is_a?(Array)
|
||
|
|
|
||
|
|
rows.filter_map do |row|
|
||
|
|
parse_row(row)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
private
|
||
|
|
|
||
|
|
def fetch_table(table_id)
|
||
|
|
uri = URI("#{BASE_URL}?action=get_wdtable&table_id=#{table_id}")
|
||
|
|
request = Net::HTTP::Post.new(uri)
|
||
|
|
request.set_form_data("draw" => "1", "start" => "0", "length" => "-1")
|
||
|
|
|
||
|
|
response = Net::HTTP.start(uri.hostname, uri.port, use_ssl: true) do |http|
|
||
|
|
http.request(request)
|
||
|
|
end
|
||
|
|
|
||
|
|
parse(response.body)
|
||
|
|
end
|
||
|
|
|
||
|
|
def parse_row(row)
|
||
|
|
date_str, currency_name, *rest = row
|
||
|
|
return unless date_str && currency_name
|
||
|
|
|
||
|
|
date = Date.strptime(date_str.strip, "%d/%m/%Y")
|
||
|
|
iso, cross_rate = resolve_currency(currency_name.strip)
|
||
|
|
return unless iso
|
||
|
|
|
||
|
|
units = parse_units(currency_name)
|
||
|
|
rate_value = Float(rest[0])
|
||
|
|
return if rate_value.zero?
|
||
|
|
|
||
|
|
rate_value /= units if units > 1
|
||
|
|
rate_value = 1.0 / rate_value if cross_rate
|
||
|
|
|
||
|
|
{ date:, base: iso, quote: "KES", rate: rate_value }
|
||
|
|
end
|
||
|
|
|
||
|
|
def resolve_currency(name)
|
||
|
|
upname = name.upcase
|
||
|
|
|
||
|
|
# Check for East African cross-rate patterns like "KES / USHS" or "KEN SHILLING / USHS"
|
||
|
|
if upname.match?(%r{KE[SN][\s/]|KEN SHILLING\s*/})
|
||
|
|
suffix = upname.split("/").last.strip
|
||
|
|
iso = CURRENCY_MAP[suffix]
|
||
|
|
return [iso, true] if iso
|
||
|
|
end
|
||
|
|
|
||
|
|
# Strip unit markers like "(100)" before matching
|
||
|
|
clean = upname.sub(/\s*\(\d+\)\s*$/, "")
|
||
|
|
iso = CURRENCY_MAP[clean] || CURRENCY_MAP.find { |k, _| clean.include?(k) }&.last
|
||
|
|
[iso, false]
|
||
|
|
end
|
||
|
|
|
||
|
|
def parse_units(name)
|
||
|
|
match = name.match(/\((\d+)\)\s*$/)
|
||
|
|
match ? Integer(match[1]) : 1
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|