require 'ass_ole/snippets/shared/version'
require 'ass_ole'

module AssOle
  module Snippets
    # Shared Ole snippets
    module Shared
      # Snippet for serialize and deserilize 1C objects to xml
      # @note In external runtime it will be cause of a fail in +InfoBase#rm!+
      #  '... /1Cv8.1CD (Errno::EBUSY)'  because external connection
      #  realy keep alive
      module XMLSerializer
        is_ole_snippet

        # Serialize 1C oject to XML string
        # @param obj [WIN32OLE] 1C object
        # @return [String]
        def to_xml(obj)
          zxml = newObject 'XMLWriter'
          zxml.SetString
          xDTOSerializer.WriteXML zxml, obj
          zxml.close
        end

        # Serialize 1C oject to XML file
        # @param obj [WIN32OLE] 1C object
        # @param xml_file [#path String] target file path
        # @return +xml_file+
        def to_xml_file(obj, xml_file)
          zxml = newObject 'XMLWriter'
          path_ = xml_file.respond_to?(:path) ? xml_file.path : xml_file
          zxml.openFile(real_win_path(path_))
          xDTOSerializer.WriteXML zxml, obj
          xml_file
        ensure
          zxml.close
        end

        # Deserialize 1C object from XML srtring
        # @param xml [String] xml string
        # @return [WIN32OLE] 1C object
        def from_xml(xml)
          zxml = newObject 'XMLReader'
          zxml.SetString xml
          xDTOSerializer.ReadXml zxml
        end

        # Deserialize 1C object from XML file
        # @param xml_file [#path String] path to xml file
        # @return [WIN32OLE] 1C object
        def from_xml_file(xml_file)
          zxml = newObject 'XMLReader'
          path_ = xml_file.respond_to?(:path) ? xml_file.path : xml_file
          zxml.openFile(real_win_path(path_))
          obj = xDTOSerializer.ReadXml zxml
          obj
        ensure
          zxml.close
        end
      end

      # Snippet for worcking with 1C Query object
      module Query
        is_ole_snippet

        # Returns 1C query object
        # @return [WIN32OLE]
        def query(text, temp_tables_manager_ = nil, **params)
          q = newObject('Query', text)
          q.TempTablesManager = temp_tables_manager_ || temp_tables_manager
          params.each do |k, v|
            q.SetParameter(k.to_s, v)
          end
          q
        end

        # Returns 1C TempTablesManager
        # @return [WIN32OLE]
        def temp_tables_manager
          newObject 'TempTablesManager'
        end
      end

      # Do in transaction wrapper
      module Transaction
        is_ole_snippet

        # rubocop:disable Metrics/MethodLength

        # @raise [RuntimeError] if nested transaction
        def do_in_transaction(&block)
          fail ArgumentError, 'Block require' unless block_given?
          fail 'Nested transaction is mindless in 1C runtime' if\
            transactionActive
          begin
            beginTransAction
            r = instance_eval(&block)
            commitTransAction
            r
          rescue StandardError => e
            rollBackTransaction
            raise e
          end
        end

        # rubocop:enable Metrics/MethodLength
      end

      require 'ass_ole/snippets/shared/mapped'
      require 'ass_ole/snippets/shared/array'
      require 'ass_ole/snippets/shared/binary_data'
    end
  end
end