# frozen_string_literal: true

module Binance
  class Spot
    # This module includes all spot public endpoints, including:
    # - server time
    # - kline
    # - ticker
    # - trades
    # - orderbook
    # - etc
    # @see https://binance-docs.github.io/apidocs/spot/en/#market-data-endpoints
    module Market
      # Test Connectivity
      #
      # GET /api/v3/ping
      #
      # @see https://binance-docs.github.io/apidocs/spot/en/#test-connectivity
      def ping
        @session.public_request(path: '/api/v3/ping')
      end

      # Check Server Time
      #
      # GET /api/v3/time
      #
      # @see https://binance-docs.github.io/apidocs/spot/en/#check-server-time
      def time
        @session.public_request(path: '/api/v3/time')
      end

      # Exchange Information
      #
      # GET /api/v3/exchangeInfo
      #
      # @option kwargs [string] :symbol
      # @option kwargs [string] :symbols
      # @see https://binance-docs.github.io/apidocs/spot/en/#exchange-information
      def exchange_info(symbol: nil, symbols: nil)
        if symbols.is_a?(Array)
          symbols = symbols.map { |v| "%22#{v}%22" }.join(',')
          symbols = "%5B#{symbols}%5D"
        end
        @session.public_request(
          path: '/api/v3/exchangeInfo',
          params:
            {
              symbol: symbol,
              symbols: symbols
            }
        )
      end

      # Order Book
      #
      # GET /api/v3/depth
      #
      # @param symbol [String] the symbol
      # @param kwargs [Hash]
      # @option kwargs [Integer] :limit Default 100; max 1000. Valid limits:[5, 10, 20, 50, 100, 500, 1000, 5000]
      # @see https://binance-docs.github.io/apidocs/spot/en/#order-book
      def depth(symbol:, **kwargs)
        Binance::Utils::Validation.require_param('symbol', symbol)

        @session.public_request(
          path: '/api/v3/depth',
          params: kwargs.merge(symbol: symbol)
        )
      end

      # Recent Trades List
      #
      # GET /api/v3/trades
      #
      # @param symbol [String] the symbol
      # @param kwargs [Hash]
      # @option kwargs [Integer] :limit  Default 500; max 1000.
      # @see https://binance-docs.github.io/apidocs/spot/en/#recent-trades-list
      def trades(symbol:, **kwargs)
        Binance::Utils::Validation.require_param('symbol', symbol)

        @session.public_request(
          path: '/api/v3/trades',
          params: kwargs.merge(symbol: symbol)
        )
      end

      # Old Trade Lookup
      #
      # X-MBX-APIKEY required
      #
      # GET /api/v3/historicalTrades
      #
      # @param symbol [String] the symbol
      # @param kwargs [Hash]
      # @option kwargs [Integer] :limit Default 500; max 1000.
      # @option kwargs [Integer] :fromId Trade id to fetch from. Default gets most recent trades.
      # @see https://binance-docs.github.io/apidocs/spot/en/#old-trade-lookup-market_data
      def historical_trades(symbol:, **kwargs)
        Binance::Utils::Validation.require_param('symbol', symbol)

        @session.public_request(
          path: '/api/v3/historicalTrades',
          params: kwargs.merge(symbol: symbol)
        )
      end

      # Compressed/Aggregate Trades List
      #
      # Get compressed, aggregate trades. Trades that fill at the time, from the same order, with the same price will have the quantity aggregated.
      #
      # GET /api/v3/aggTrades
      #
      # @param symbol [String] the symbol
      # @param kwargs [Hash]
      # @option kwargs [Integer] :startTime Timestamp in ms to get aggregate trades from INCLUSIVE.
      # @option kwargs [Integer] :endTime Timestamp in ms to get aggregate trades until INCLUSIVE.
      # @option kwargs [Integer] :fromId Trade id to fetch from. Default gets most recent trades.
      # @option kwargs [Integer] :limit Default 500; max 1000.
      # @see https://binance-docs.github.io/apidocs/spot/en/#compressed-aggregate-trades-list
      def agg_trades(symbol:, **kwargs)
        Binance::Utils::Validation.require_param('symbol', symbol)

        @session.public_request(
          path: '/api/v3/aggTrades',
          params: kwargs.merge(symbol: symbol)
        )
      end

      # Kline/Candlestick Data
      #
      # Kline/candlestick bars for a symbol.
      # Klines are uniquely identified by their open time.
      #
      # GET /api/v3/klines
      #
      # @param symbol [String] the symbol
      # @param interval [String] interval
      # @param kwargs [Hash]
      # @option kwargs [Integer] :startTime Timestamp in ms to get aggregate trades from INCLUSIVE.
      # @option kwargs [Integer] :endTime Timestamp in ms to get aggregate trades until INCLUSIVE.
      # @option kwargs [Integer] :limit Default 500; max 1000.
      # @see https://binance-docs.github.io/apidocs/spot/en/#kline-candlestick-data
      def klines(symbol:, interval:, **kwargs)
        Binance::Utils::Validation.require_param('symbol', symbol)
        Binance::Utils::Validation.require_param('interval', interval)

        @session.public_request(
          path: '/api/v3/klines',
          params: kwargs.merge(
            symbol: symbol,
            interval: interval
          )
        )
      end

      # Current Average Price
      #
      # Current average price for a symbol.
      #
      # GET /api/v3/avgPrice
      #
      # @param symbol [String] the symbol
      # @see https://binance-docs.github.io/apidocs/spot/en/#current-average-price
      def avg_price(symbol:)
        Binance::Utils::Validation.require_param('symbol', symbol)

        @session.public_request(
          path: '/api/v3/avgPrice',
          params: { symbol: symbol }
        )
      end

      # 24hr Ticker Price Change Statistics
      #
      # 24 hour rolling window price change statistics. Careful when accessing this with no symbol.
      #
      # GET /api/v3/ticker/24hr
      #
      # @param symbol [String] the symbol
      # @see https://binance-docs.github.io/apidocs/spot/en/#24hr-ticker-price-change-statistics
      def ticker_24hr(symbol: nil)
        @session.public_request(
          path: '/api/v3/ticker/24hr',
          params: { symbol: symbol }
        )
      end

      # Symbol Price Ticker
      #
      # Latest price for a symbol or symbols.
      #
      # GET /api/v3/ticker/price
      #
      # @param symbol [String] the symbol
      # @see https://binance-docs.github.io/apidocs/spot/en/#symbol-price-ticker
      def ticker_price(symbol: nil)
        @session.public_request(
          path: '/api/v3/ticker/price',
          params: { symbol: symbol }
        )
      end

      # Symbol Order Book Ticker
      #
      # Best price/qty on the order book for a symbol or symbols.
      #
      # GET /api/v3/ticker/bookTicker
      #
      # @param symbol [String] the symbol
      # @see https://binance-docs.github.io/apidocs/spot/en/#symbol-order-book-ticker
      def book_ticker(symbol: nil)
        @session.public_request(
          path: '/api/v3/ticker/bookTicker',
          params: { symbol: symbol }
        )
      end

      # Symbol Order Book Ticker
      #
      # Best price/qty on the order book for a symbol or symbols.
      #
      # GET /api/v3/ticker/bookTicker
      #
      # @param symbol [String] the symbol
      # @see https://binance-docs.github.io/apidocs/spot/en/#symbol-order-book-ticker
      def ticker(symbol: nil, symbols: nil, windowSize: '1d')
        raise Binance::DuplicatedParametersError.new('symbol', 'symbols') unless symbols.nil? || symbol.nil?

        params = { symbol: symbol.upcase } if symbol

        if symbols
          symbols = symbols.map { |s| "\"#{s}\"" }.join(',')
          params = { symbols: "\[#{symbols}\]".upcase }
        end

        params[:windowSize] = windowSize

        @session.public_request(
          path: '/api/v3/ticker',
          params: params
        )
      end
    end
  end
end