add listen to watch filesystem.

2 files changed, 9 insertions, 8 deletions

diff --git a/app/controllers/agents/files_controller.rb b/app/controllers/agents/files_controller.rb
index 9afd766..1d711e2 100644
--- a/app/controllers/agents/files_controller.rb
+++ b/app/controllers/agents/files_controller.rb
@@ -12,7 +12,7 @@ module Agents
       @file = Disposition.find_by(fingerprint: params[:id])
       Publisher.publish("queries", {
         fingerprint: params[:id],
-        data: params
+        payload: params[:payload]
       })
     end
 
diff --git a/app/workers/cloud_queries.rb b/app/workers/cloud_queries.rb
index 35102b5..00e6bd2 100644
--- a/app/workers/cloud_queries.rb
+++ b/app/workers/cloud_queries.rb
@@ -7,13 +7,14 @@ class CloudQueries
   def work(json)
     logger.info "Query for: #{json.inspect}"
     attributes = JSON.parse(json)
-    fingerprint = attributes["fingerprint"]
-    disposition = Disposition.find_by(fingerprint: fingerprint)
-    if disposition.present?
-      logger.info("#{disposition.state} disposition for: #{fingerprint}")
-    else
-      logger.info("Unknown disposition for: #{fingerprint}")
-    end
+    #fingerprint = attributes["fingerprint"]
+    #disposition = Disposition.find_by(fingerprint: fingerprint)
+
+    #if disposition.present?
+      #logger.info("#{disposition.state} disposition for: #{fingerprint}")
+    #else
+      #logger.info("Unknown disposition for: #{fingerprint}")
+    #end
 
     ack!
   end