blob: a1fa68d12bb33255e1d4aaf60822421de81bb4f4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
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 = Disposition.create!(fingerprint: fingerprint, state: :unknown) if disposition.nil?
FingerprintLookupJob.perform_later(fingerprint) if disposition.state == :unknown
ack!
end
end
|
