# -*- encoding : utf-8 -*-
require 'net/http'
require 'reactor/cm/xml_response'
require 'reactor/cm/xml_multi_request_error'
require 'reactor/cm/xml_markup'
require 'nokogiri'

module Reactor
  module Cm

    class MultiXmlRequest
      def self.timeout
        Reactor::Cm::XmlRequest.timeout
      end

      def self.token(login, instance_secret)
        Digest::MD5.hexdigest(login + instance_secret)
      end

      def self.execute
        access = Configuration::xml_access
        sanity_check(access)
        xml = XmlMarkup.new
        xml2 = nil
        ret = nil
        xml.instruct!
        req = nil
        ret = xml.tag!('cm-payload', 'payload-id' =>'abcabc', 'timestamp' => Time.now.getutc.strftime('%Y%m%d%H%M%S'), 'version' => '6.7.3') do
          xml.tag!('cm-header') do
            xml.tag!('cm-sender', 'sender-id' => access[:id], 'name' => "ruby-simple-client")
            xml.tag!('cm-authentication', 'login' => access[:username], 'token' => token(access[:username],access[:secret]))
          end
          req = self.new(xml).tap do |instance|
            yield instance
          end
        end
        req.execute!(ret)
      end

      def mandatory(&block)
        req_id = self.class.generate_id
        @mandatory << req_id
        @builder.tag!('cm-request', 'request-id' => req_id, 'preclusive' => 'true') do |xml2|
          yield xml2
        end
      end

      def optional(&block)
        req_id = self.class.generate_id
        @optional << req_id
        @builder.tag!('cm-request', 'request-id' => req_id, 'preclusive' => 'false') do |xml2|
          yield xml2
        end
      end

      def execute!(xml)
        access = Configuration::xml_access
        payload = xml

        res = Net::HTTP.new(access[:host], access[:port]).start do |http|
          http.read_timeout = self.class.timeout
          req = Net::HTTP::Post.new('/xml')
          req.body = payload
          http.request(req)
        end

        result = MultiXmlResponse.new(res.body, @mandatory, @optional)
      end

      class << self

        def generate_id
          rand(10000)
        end

        protected

        def sanity_check(access)
          raise Reactor::Cm::MissingCredentials if access[:username].nil? || access[:username].empty?
        end
      end

      protected

      def initialize(builder)
        @builder = builder
        @mandatory = []
        @optional = []
      end

      class MultiXmlResponse
        def initialize(xml, mandatory, optional)
          @xml, @mandatory, @optional = xml, mandatory, optional
          @n = Nokogiri::XML.parse(@xml)
        end

        def assert_success
          first_failed = nil
          @mandatory.any? do |mandatory_id|
            @n.xpath("//cm-response[@request-id='#{mandatory_id}']//cm-code[@numeric='200']").empty? && (first_failed = mandatory_id)
          end && raise(XmlMultiRequestError, @n.xpath("//cm-response[@request-id='#{first_failed}']//cm-code//error/phrase/text()").map(&:to_s).join("\n"))
        end
      end
    end
  end
end