1require 'json'
 2
 3class EventIntake
 4  include Sneakers::Worker
 5  from_queue "worker.events"
 6
 7  def work(event_json)
 8    logger.info(event_json)
 9    Event.create!(to_hash(event_json))
10    ack!
11  end
12
13  private
14
15  def to_hash(json)
16    JSON.parse(json).tap do |event|
17      event['type'].capitalize!
18    end
19  end
20end