app/workers/event_intake.rb


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

require 'json'

class EventIntake
  include Sneakers::Worker
  from_queue "worker.events"

  def work(event_json)
    logger.info(event_json)
    Event.create!(to_hash(event_json))
    ack!
  end

  private

  def to_hash(json)
    JSON.parse(json).tap do |event|
      event['type'].capitalize!
    end
  end
end