publish command to agent queue to analzye file.

1 files changed, 5 insertions, 6 deletions

diff --git a/app/workers/cloud_queries.rb b/app/workers/cloud_queries.rb
index e351152..3f4c6e1 100644
--- a/app/workers/cloud_queries.rb
+++ b/app/workers/cloud_queries.rb
@@ -12,12 +12,11 @@ class CloudQueries
     disposition = Disposition.find_by(fingerprint: fingerprint)
 
     if disposition.nil?
-      # publish command to fetch file from agent
-      #publish(JSON.generate({
-        #command: :request_analysis,
-        #agent_id: attributes["agent_id"],
-        #fingerprint: fingerprint,
-      #}), to_queue: "worker.commands")
+      publish(JSON.generate({
+        command: :request_analysis,
+        agent_id: attributes["agent_id"],
+        fingerprint: fingerprint,
+      }), routing_key: "malwer.agents.#{attributes["agent_id"]}")
     end
 
     ack!