Contents

# frozen_string_literal: true

require 'pp'
require 'set'
require 'json'
require 'bigdecimal'
require 'net/http'

module Mcoin
  module Market
    # :nodoc:
    class Base
      attr_reader :results

      def initialize
        @pairs = Set.new
        @results = []
        @retries = 0
      end

      def watch(type, currency)
        @pairs.add({ type: type.to_s.upcase, currency: currency.to_s.upcase })
      end

      def name
        self.class.name.split('::').last
      end

      def fetch
        @results = []
        establish_connection do |http|
          @pairs.each do |pair|
            uri = URI(format(self.class.const_get(:ENDPOINT), pair))
            request = Net::HTTP::Get.new(uri)
            @results << [pair, JSON.parse(http.request(request)&.body)]
          end
        end
        self
      rescue JSON::ParserError
        return self if @retries >= 3
        @retries += 1
        retry
      end

      def to_ticker
        @results.map do |pair, response|
          build_ticker(pair, response)
        end
      end

      def establish_connection(&block)
        @base_uri ||= URI(format(self.class.const_get(:ENDPOINT), type: '', currency: ''))
        use_ssl = @base_uri.scheme == 'https'
        Net::HTTP.start(@base_uri.host, @base_uri.port, use_ssl: use_ssl) do |http|
          yield http
        end
      end

      private

      def build_ticker(_pair, _response)
        raise NotImplementedError
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
mcoin-0.6.1	lib/mcoin/market/base.rb
mcoin-0.6.0	lib/mcoin/market/base.rb