app/workers/cloud_queries.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

require 'json'

class CloudQueries
  include Sneakers::Worker
  from_queue "worker.queries"

  def work(json)
    logger.info "Query for: #{json.inspect}"
    attributes = JSON.parse(json)

    fingerprint = attributes["data"]["fingerprint"]
    disposition = Disposition.find_by(fingerprint: fingerprint) ||
      Disposition.create!(fingerprint: fingerprint, state: :unknown)
    FingerprintLookupJob.perform_later(fingerprint) if disposition.unknown?

    ack!
  end
end