extract method to convert the event hash.

1 files changed, 10 insertions, 5 deletions

diff --git a/app/workers/event_intake.rb b/app/workers/event_intake.rb
index 79be810..a4cbf67 100644
--- a/app/workers/event_intake.rb
+++ b/app/workers/event_intake.rb
@@ -5,11 +5,16 @@ class EventIntake
   from_queue "worker.events"
 
   def work(event_json)
-    logger.info event_json
-    json = JSON.parse(event_json)
-    json['type'] = json['type'].capitalize
-    event = Event.create!(json)
-    logger.info("Create Event: #{event.id}")
+    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