# frozen_string_literal: true

module Sequel
  # Extension for currency-conversion via currency_rates table
  module CurrencyRates
    # Join a rates table
    #
    # @param aliaz [Symbol] alias to be used for joined table
    # @param table [Symbol] table name to join to
    # @param time_column [Symbol] time column by which table is joined
    #
    # @example
    #   Order::Model.with_rates.select(Sequel[:amount].in_usd)
    # @return [Sequel::Dataset] dataset
    def with_rates(
      aliaz = :currency_rates,
      table: table_name,
      rates_table: Sequel[:currency_rates],
      time_column: :created_at
    )
      table = Sequel[table]
      rates = Sequel[aliaz]
      join_expr = table[:currency] =~ rates[:currency]
      join_expr &= rates[:period].pg_range.contains(table[time_column])
      left_join(rates_table.as(aliaz), join_expr)
    end

    # Returns a table name
    #
    # @return [Symbol] table name
    def table_name
      respond_to?(:first_source_alias) ? first_source_alias : super
    end
  end

  module CurrencyRateExchange
    # Exchange column value to a specific currency
    #
    # @param currency [String] currency
    # @param rates_table [Symbol] rates table name
    #
    # @example
    #   Sequel[:amount].exchange_to("EUR", :order_rates)
    # @return [Sequel::SQL::NumericExpression]
    def exchange_to(currency, rates_table = :currency_rates)
      rate = Sequel[rates_table][:rates].pg_jsonb.get_text(currency).cast_numeric(Float)
      self * rate
    end

    # Exchange column value to usd
    #
    # @param opts (see #exchange_to)
    #
    # @example
    #   Sequel[:amount].in_usd
    # @return (see #exchange_to)
    def in_usd(*opts)
      exchange_to("USD", *opts)
    end
  end

  Model.extend(CurrencyRates)
  SQL::GenericExpression.include(CurrencyRateExchange)
  Dataset.register_extension(:currency_rates, CurrencyRates)
end