Sha256: c594fb6eacc230b5321b57ea8b570e4d71844b4ad82c9b7142fa2a22b3c6d8c6

Contents?: true

Size: 1.89 KB

Versions: 3

Compression:

Stored size: 1.89 KB

Contents

# coding: utf-8

require 'savon'

require 'libis/tools/xml_document'
require_relative 'http_error'
require_relative 'soap_error'

module Libis
  module Services

    module SoapClient
      attr_reader :client

      def configure(wsdl, options = {})
        opts = {
            wsdl: wsdl,
            raise_errors: false,
            soap_version: 1,
            filters: [:password],
            pretty_print_xml: true,
        }.merge options

        @client = Savon.client(opts) { yield if block_given? }
      end

      def operations
        @client.operations
      end

      def request(method, message = {}, call_options = {}, parse_options = {})
        response = client.call(method, message: message) do |locals|
          call_options.each do |key, value|
            locals.send(key, value)
          end
        end

        return yield(response) if block_given?
        parse_result(response, parse_options)

      rescue IOError, EOFError, Errno::ECONNRESET, Errno::ECONNABORTED, Errno::EPIPE => e
        debug "Exception: #{e.class.name} '#{e.message}'"
        unless (tries ||= 0) > 2; sleep(5 ** tries); tries += 1; retry; end
        raise Libis::Services::ServiceError, "Persistent network error: #{e.class.name} '#{e.message}'"
      rescue Net::ReadTimeout, Timeout::Error => e
        debug "Exception: #{e.class.name} '#{e.message}'"
        unless (tries ||= 0) > 1; sleep(5 ** tries); tries += 1; retry; end
        raise Libis::Services::ServiceError, "Network timeout error: #{e.class.name} '#{e.message}'"
      end

      protected

      def parse_result(response, options = {})
        raise SoapError.new response.soap_fault.to_hash if response.soap_fault?
        raise HttpError.new response.http_error.to_hash if response.http_error?
        self.result_parser(response.body, options)
      end

      def result_parser(response, options = {})
        response
      end

    end

  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
libis-services-0.1.11 lib/libis/services/soap_client.rb
libis-services-0.1.10 lib/libis/services/soap_client.rb
libis-services-0.1.9 lib/libis/services/soap_client.rb