use a single topic exchange instead of multiple fanout exchanges.

1 files changed, 2 insertions, 15 deletions

diff --git a/app/workers/cloud_queries.rb b/app/workers/cloud_queries.rb
index e944142..fbbe5c4 100644
--- a/app/workers/cloud_queries.rb
+++ b/app/workers/cloud_queries.rb
@@ -11,21 +11,8 @@ class CloudQueries
     fingerprint = attributes["data"]["fingerprint"]
     disposition = Disposition.find_by(fingerprint: fingerprint)
 
-    publish(JSON.generate({
-      name: :scanned,
-      agent_id: attributes["agent_id"],
-      data: attributes["data"]
-    }), to_queue: "worker.events")
-
-    if disposition.nil?
-      #publish(JSON.generate({
-      #command: :request_analysis,
-      #agent_id: attributes["agent_id"],
-      #fingerprint: fingerprint,
-      #}), routing_key: "malwer.commands")
-      Disposition.create!(fingerprint: fingerprint, state: :unknown)
-      FingerprintLookupJob.perform_later(fingerprint)
-    end
+    Disposition.create!(fingerprint: fingerprint, state: :unknown) if disposition.nil?
+    FingerprintLookupJob.perform_later(fingerprint) if disposition.state == :unknown
 
     ack!
   end