From f004d81d3be9ff40830efb66c200a7a6552d72d0 Mon Sep 17 00:00:00 2001 From: mo khan Date: Mon, 9 Feb 2015 18:43:30 -0700 Subject: extract method to convert the event hash. --- app/workers/event_intake.rb | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) (limited to 'app/workers') 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 -- cgit v1.2.3