diff options
Diffstat (limited to 'app/workers')
| -rw-r--r-- | app/workers/cloud_queries.rb | 2 | ||||
| -rw-r--r-- | app/workers/event_intake.rb | 4 |
2 files changed, 4 insertions, 2 deletions
diff --git a/app/workers/cloud_queries.rb b/app/workers/cloud_queries.rb index fbbe5c4..a1fa68d 100644 --- a/app/workers/cloud_queries.rb +++ b/app/workers/cloud_queries.rb @@ -11,7 +11,7 @@ class CloudQueries fingerprint = attributes["data"]["fingerprint"] disposition = Disposition.find_by(fingerprint: fingerprint) - Disposition.create!(fingerprint: fingerprint, state: :unknown) if disposition.nil? + disposition = Disposition.create!(fingerprint: fingerprint, state: :unknown) if disposition.nil? FingerprintLookupJob.perform_later(fingerprint) if disposition.state == :unknown ack! diff --git a/app/workers/event_intake.rb b/app/workers/event_intake.rb index 7e70497..79be810 100644 --- a/app/workers/event_intake.rb +++ b/app/workers/event_intake.rb @@ -6,7 +6,9 @@ class EventIntake def work(event_json) logger.info event_json - event = Event.create!(JSON.parse(event_json)) + json = JSON.parse(event_json) + json['type'] = json['type'].capitalize + event = Event.create!(json) logger.info("Create Event: #{event.id}") ack! end |