class BCB

# File lib/eba/bcb.rb, line 22
def initialize(path_to_ca_certificate)
        @ca = path_to_ca_certificate
        @attempts = 0
        connect_to_service()
end

# File lib/eba/bcb.rb, line 28
def connect_to_service()
        @service = Savon.client({wsdl: "https://www3.bcb.gov.br/wssgs/services/FachadaWSSGS?wsdl",
                                                                                                         ssl_ca_cert_file: @ca,
                                                                                                         headers: {'Accept-Encoding' => 'gzip, deflate'}})
end

# File lib/eba/bcb.rb, line 106
def get_all_data_for_array(array_of_codes, min_date, max_date = Time.now.strftime('%d/%m/%Y').to_s, slice_size=50)
        result = nil
        data_collection = []

        # This request has a limit of series he can get at a time, thus
        # it's way simpler to break a composite requests in various smaller
        # requests. The Data_bcb class serves as a way to organize such data
        # and allow the developer to easily identify which series each data
        # object pertains.

        if slice_size > 50 then
                slice_size = 50
        end

        array_of_codes.each_slice(50).to_a.each do |array|
                hash = hash_by_periodicity(array)

                hash.each do |periodicity, array|
                        code_x_data = {}

                        array.each do |data|
                                code_x_data[data.pk] = data
                        end

                        scry_for_interval(min_date, max_date, code_x_data).each do |data|
                                data_collection << data
                        end
                end
        end

        data_collection
end

# File lib/eba/bcb.rb, line 69
def get_last_value(series_code)
        begin
                response = @service.call(:get_ultimo_valor_xml, message: {in0: "#{series_code}"})
        rescue HTTP::ConnectionError => e
                puts "BCB Warning: hangup from source trying to get last value. Waiting and trying again."
                sleep(1)

                return get_last_value(series_code)

        rescue OpenSSL::SSL::SSLError => e
                puts "BCB Warning: hangup from source trying to get last value. Waiting and trying again."
                sleep(1)

                return get_last_value(series_code)

        rescue Exception => e
                puts "BCB ERROR: #{e.message}\n#{e.backtrace}\n#{e.class}"
                return Data_bcb.invalid_data()
        end

        response = response.to_hash[:get_ultimo_valor_xml_response][:get_ultimo_valor_xml_return].sub("&", 
                                                                                                                                                                                                                                                                                                                                                                                        "-_1532_-")
        xmlResult = Nokogiri::XML(response)

        # As it's a brazillian database it's column identifications are in portuguese,
        # the translation for the fields, in order, are:
        # NOME = NAME
        # PERIODICIDADE = PERIODICITY
        # UNIDADE = UNIT
        # DIA = DAY
        # MES = MONTH
        # ANO = YEAR
        # VALOR = VALUe
        build_bcb_data(xmlResult) 
end

# File lib/eba/bcb.rb, line 50
def hash_by_periodicity(array_of_codes)
        last_values = hash_last_value_with_code(array_of_codes)
        purged_array_of_codes = purge_invalid_series(array_of_codes, last_values)
        result = {}

        purged_array_of_codes.each do |code|
                dado = last_values[code]

                if not result.key? dado.periodicity then
                        result[dado.periodicity] = []
                end

                result[dado.periodicity] << dado
        end

        return result
end

# File lib/eba/bcb.rb, line 40
def hash_last_value_with_code(array_of_codes)
        result = {}
        
        array_of_codes.each do |code|
                result[code] = get_last_value(code)
        end

        result
end

# File lib/eba/bcb.rb, line 36
def list_operations()
        return @service.operations
end

# File lib/eba/bcb.rb, line 139
def scry_for_interval(min_date, max_date, code_x_data)
        dc = []

        # Build the  message from the start of the historical series
        message = {in0: {long: code_x_data.keys}, 
                              in1: min_date, 
                              in2: max_date}

        result = send_message(message)

        if result != nil then
                result.css("SERIE").each do |serie|
                        extract_an_item(serie, code_x_data, dc)
                end

                if dc.size == 0 && code_x_data.keys.size > 0 then
                        result.css("SERIE").each do |serie|
                                extract_an_item(serie, code_x_data, dc)
                        end
                end
        end

        dc
end

# File lib/eba/bcb.rb, line 164
def send_message(message)
        result = nil

        # try and catch, as some series can be discontinued or a code may be broken
        begin
                response = @service.call(:get_valores_series_xml, message: message)  
                result = Nokogiri::XML(response.to_hash[:get_valores_series_xml_response][:get_valores_series_xml_return])
        rescue HTTP::ConnectionError => e
                puts "BCB Warning: hangup from source trying to get all data. Waiting and trying again."
                sleep(1)

                result = send_message(message)

        rescue OpenSSL::SSL::SSLError => e
                puts "BCB Warning: hangup from source trying to get last value. Waiting and trying again."
                sleep(1)

                result = sent_message(message)

        rescue Exception => erro
                result = nil
        end
        
        result
end