summaryrefslogtreecommitdiff
path: root/app/workers
diff options
context:
space:
mode:
authormo khan <mo@mokhan.ca>2015-02-02 22:19:05 -0700
committermo khan <mo@mokhan.ca>2015-02-02 22:19:05 -0700
commita203ecad6c996665d503d11474ca5981b5621abd (patch)
tree87bc4f144aff5db37e5a7ca771acf8fd7c4276e4 /app/workers
parenta71b8dc0743a769b861b91d693230b0b88961b79 (diff)
parse event as json.g
Diffstat (limited to 'app/workers')
-rw-r--r--app/workers/events_worker.rb8
1 files changed, 6 insertions, 2 deletions
diff --git a/app/workers/events_worker.rb b/app/workers/events_worker.rb
index 491ce87..fc3df31 100644
--- a/app/workers/events_worker.rb
+++ b/app/workers/events_worker.rb
@@ -1,9 +1,13 @@
+require 'json'
+
class EventsWorker
include Sneakers::Worker
from_queue "dashboard.events", env: nil
- def work(raw_post)
- Event.create!(raw_post)
+ def work(event_json)
+ logger.info event_json
+ event = Event.create!(JSON.parse(event_json))
+ logger.info("Create Event: #{event.id}")
ack!
end
end