Implement echo requests

Author: monorkin

lib/croatia/fiscalizer.rb

@@ -104,10 +104,13 @@ def echo(message)
     request = Net::HTTP::Post.new(endpoint).tap do |req|
       req.body = soap_message.to_s
       req.content_type = "text/xml; charset=UTF-8"
-      req["User-Agent"] = USER_AGENT
     end
 
-    response = with_http_client { |client| client.request(request) }
+    response = execute_request(request)
+
+    unwrap_response(response) do |resp|
+      Parser.parse_echo_response(resp.body)
+    end
   end
 
   def fiscalize(invoice:, message_id: SecureRandom.uuid)
@@ -199,4 +202,27 @@ def is_a_file_path?(path)
     def with_http_client(&block)
       self.class.with_http_client_for(host: host, port: port, credential: credential, &block)
     end
+
+    def execute_request(request)
+      request["User-Agent"] ||= USER_AGENT
+      with_http_client { |client| client.request(request) }
+    end
+
+    def unwrap_response(response, expected: [ Net::HTTPSuccess ], &block)
+      if expected.any? { |status| response.is_a?(status) || response.code.to_i == status }
+        return block.call(response)
+      end
+
+      Result.new.tap do |result|
+        result.add_error(
+          code: nil,
+          message: "Server responded with unexpected status",
+          description: :server_error,
+          details: {
+            statgus: response.code,
+            body: response.body
+          }
+        )
+      end
+    end
 end

lib/croatia/fiscalizer/parser.rb

@@ -0,0 +1,23 @@
+# frozen_string_literal: true
+
+module Croatia::Fiscalizer::Parser
+  NAMESPACES = {
+    "soap" => "http://schemas.xmlsoap.org/soap/envelope/"
+  }.freeze
+
+  class << self
+    def parse_echo_response(body)
+      document = Nokogiri::XML(body)
+      response = document.at_xpath("//soap:Envelope/soap:Body/echoResponse", NAMESPACES)
+      result = Croatia::Fiscalizer::Result.new(data: response&.text)
+
+      if fault = document.at_xpath("//soap:Fault/detail", NAMESPACES)
+        code = fault.at_xpath("errorCode")&.text
+        message = fault.at_xpath("errorMessage")&.text
+        result.add_error(code: code, message: message)
+      end
+
+      result
+    end
+  end
+end

lib/croatia/fiscalizer/result.rb

@@ -0,0 +1,31 @@
+# frozen_string_literal: true
+
+class Croatia::Fiscalizer::Result
+  Error = Data.define(:code, :message, :description, :details)
+
+  attr_reader :message_id, :timestamp, :data, :errors
+
+  def initialize(message_id: nil, timestamp: nil, data: nil, errors: nil)
+    @message_id = message_id
+    @timestamp = timestamp
+    @data = data
+    @errors = errors || []
+  end
+
+  def success?
+    errors.empty?
+  end
+
+  alias_method :ok?, :success?
+
+  def failure?
+    !success?
+  end
+
+  alias_method :error?, :failure?
+
+  def add_error(code:, message:, descriptions: nil)
+    description = descriptions[code] if descriptions
+    errors << Error.new(code: code, message: message, description: description)
+  end
+end