1require 'json'
 2
 3class CloudQueries
 4  include Sneakers::Worker
 5  from_queue "worker.queries"
 6
 7  def work(json)
 8    logger.info "Query for: #{json.inspect}"
 9    attributes = JSON.parse(json)
10
11    fingerprint = attributes["data"]["fingerprint"]
12    disposition = Disposition.find_by(fingerprint: fingerprint)
13
14    disposition = Disposition.create!(fingerprint: fingerprint, state: :unknown) if disposition.nil?
15    FingerprintLookupJob.perform_later(fingerprint) if disposition.state == :unknown
16
17    ack!
18  end
19end