poke disposition in worker.

2 files changed, 17 insertions, 4 deletions

diff --git a/app/workers/events_worker.rb b/app/workers/events_worker.rb
index 3fcb2c8..dc85009 100644
--- a/app/workers/events_worker.rb
+++ b/app/workers/events_worker.rb
@@ -2,10 +2,7 @@ require 'json'
 
 class EventsWorker
   include Sneakers::Worker
-  from_queue "worker.events",
-    threads: 50,
-    prefetch: 50,
-    timeout_job_after: 1
+  from_queue "worker.events"
 
   def work(event_json)
     logger.info event_json
diff --git a/app/workers/poke.rb b/app/workers/poke.rb
new file mode 100644
index 0000000..f7142ff
--- /dev/null
+++ b/app/workers/poke.rb
@@ -0,0 +1,16 @@
+require 'json'
+
+class Poke
+  include Sneakers::Worker
+  from_queue "worker.poke"
+
+  def work(json)
+    attributes = JSON.parse(json)
+
+    disposition = Disposition.find_or_create_by(fingerprint: attributes["fingerprint"])
+    disposition.state = attributes["state"]
+    disposition.save!
+
+    ack!
+  end
+end