lib/arii/sqldetector.rb in arii-1.2.1 vs lib/arii/sqldetector.rb in arii-1.2.2
- old
+ new
@@ -13,13 +13,13 @@
public
##
# == Detect the changes
#
def detect object
- ARII::Config.log.debug(self.class.name) {"Monitoring #{object[:host]}"}
+ ARII::Config.log.debug(self.class.name) { "Monitoring #{object[:host]}" }
begin
- @client = Mysql2::Client.new(:host => object[:host], :username => object[:username] , :password => object[:password] , :database => object[:database])
+ @client = Mysql2::Client.new(:host => object[:host], :username => object[:username], :password => object[:password], :database => object[:database])
@client.query(object[:query]).each(:symbolize_keys => false) do |row|
unless object[:cache].nil? then
@response = Cashier.verify row[object[:cache]], object, row, object[:seed]
else
@response = Cashier.verify row["id"], object, row, object[:seed]
@@ -33,23 +33,23 @@
end
end
# The actual processing
#
if @cache[:cache][:status] == 100 then
- ARII::Config.log.info(self.class.name) {"Not on cache, generating payload"}
+ ARII::Config.log.info(self.class.name) { "Not on cache, generating payload" }
# add row data to payload from selectors (key => key, value => column name)
payload = Hash.new
object[:selectors].each do |selector|
- selector.each do |k,v|
+ selector.each do |k, v|
payload[k] = row[v]
end
end
# add payload object to payloads list
@payloads.push payload
end
end
rescue Exception => e
- ARII::Config.log.error(self.class.name) {"Processing error: #{e}"}
+ ARII::Config.log.error(self.class.name) { "Processing error: #{e}" }
end
@cache[:templates]
end
end
end