Contents

#require 'helper'
#require 'cashier'
require 'open-uri'
#require 'raven'
#require 'slog'

module I2X

  # = XMLDetector
  #
  # Detect changes in XML files (uses XPath).
  #
  class XMLDetector < Detector

    public
    ##
    # == Detect the changes
    #
    def detect object
      begin
        if object[:uri] == '' then
          @doc = Nokogiri::XML(object[:content])
        else
          @doc = Nokogiri::XML(open(object[:uri]))
        end
        @doc.remove_namespaces!
        @doc.xpath(object[:query]).each do |element|
          element.xpath(object[:cache]).each do |c|
            @cache = Cashier.verify c.content, object, c.content, object[:seed]
          end

          ##
          # If not on cache, add to payload for processing
          #
          if @cache[:status] == 100 then

            # add row data to payload from selectors (key => key, value => column name)
            payload = Hash.new
            JSON.parse(object[:selectors]).each do |selector|

              selector.each do |k,v|
                element.xpath(v).each do |el|
                  payload[k] = el.content
                end
              end
            end
            # add payload object to payloads list
            @payloads.push payload

          end
        end
      end
    rescue Exception => e
      
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
i2x-0.0.6	lib/i2x/xmldetector.rb
i2x-0.0.5	lib/i2x/xmldetector.rb
i2x-0.0.4	lib/i2x/xmldetector.rb