Sergei Poljanski
33ba7650c3
Crypto options were limited to a hard-coded asset list, with one address per coin in a side table. A payout address now carries everything an invoice needs: ticker, name, QR URI scheme, amount parameter, CoinGecko id, address and an active flag. Any coin can be added, several addresses per ticker are fine, and known tickers fill the QR and rate fields from the built-in templates. The new-invoice form picks a payout address. The invoice snapshots the ticker, address, name, scheme and amount parameter, and the PDF and QR render from that copy, so editing, retiring or deleting a payout entry never changes an issued invoice. "Fetch live" looks up the rate by the payout address's CoinGecko id. Migration 012 keeps the existing rows and backfills both the payout metadata and the snapshots on existing crypto invoices. Assisted-by: Claude:opus-5
58 lines
2 KiB
Ruby
58 lines
2 KiB
Ruby
require 'net/http'
|
|
require 'json'
|
|
require 'uri'
|
|
require 'bigdecimal'
|
|
|
|
# Fetches the current price of a CryptoAsset from CoinGecko (free, no API key).
|
|
#
|
|
# CoinGecko's simple/price supports usd and eur directly. GEL is derived from
|
|
# the invoice's own captured gel_rate (USD->GEL): price_gel = price_usd * gel_rate.
|
|
module CryptoRate
|
|
ENDPOINT = 'https://api.coingecko.com/api/v3/simple/price'.freeze
|
|
SUPPORTED = %w[USD EUR].freeze
|
|
TIMEOUT = 6 # seconds
|
|
|
|
class Error < StandardError; end
|
|
|
|
module_function
|
|
|
|
# Returns a BigDecimal: the price of 1 unit of the CoinGecko asset `id`
|
|
# (a payout address's coingecko field) in `currency`.
|
|
# `gel_rate` (USD->GEL) is required only when currency == 'GEL'.
|
|
def fetch(id, currency, gel_rate: nil)
|
|
raise Error, 'No CoinGecko id set for this payout address; enter the rate by hand.' if id.to_s.empty?
|
|
currency = currency.to_s.upcase
|
|
|
|
if currency == 'GEL'
|
|
raise Error, 'gel_rate required to derive the GEL price' if gel_rate.nil?
|
|
usd = fetch_simple(id, 'usd')
|
|
(usd * BigDecimal(gel_rate.to_s)).round(8)
|
|
elsif SUPPORTED.include?(currency)
|
|
fetch_simple(id, currency.downcase).round(8)
|
|
else
|
|
raise Error, "Unsupported currency: #{currency}"
|
|
end
|
|
end
|
|
|
|
def fetch_simple(id, vs)
|
|
uri = URI(ENDPOINT)
|
|
uri.query = URI.encode_www_form(ids: id, vs_currencies: vs)
|
|
|
|
res = Net::HTTP.start(uri.host, uri.port, use_ssl: true,
|
|
open_timeout: TIMEOUT, read_timeout: TIMEOUT) do |http|
|
|
http.get(uri.request_uri, 'Accept' => 'application/json')
|
|
end
|
|
|
|
raise Error, "CoinGecko HTTP #{res.code}" unless res.is_a?(Net::HTTPSuccess)
|
|
|
|
data = JSON.parse(res.body)
|
|
price = data.dig(id, vs)
|
|
raise Error, "No price for #{id}/#{vs} in response" if price.nil?
|
|
|
|
BigDecimal(price.to_s)
|
|
rescue JSON::ParserError => e
|
|
raise Error, "Bad JSON from CoinGecko: #{e.message}"
|
|
rescue Net::OpenTimeout, Net::ReadTimeout
|
|
raise Error, 'CoinGecko timed out'
|
|
end
|
|
end
|