about summary refs log tree commit diff
path: root/app/workers
diff options
context:
space:
mode:
authorEugen Rochko <eugen@zeonfederated.com>2017-04-05 19:29:46 +0200
committerEugen Rochko <eugen@zeonfederated.com>2017-04-05 19:29:46 +0200
commitd755ce96da00cee1c8e51204cf5ede79764f4fb9 (patch)
treea3215ee386cca3da0df7cafb91e06c1e841fa7af /app/workers
parent29ffe1cad3f473c7b6c0b651d065f8ed9373d37e (diff)
parentc9ebd5d19fccaabd1192f5e61537251c2c2d782e (diff)
Merge branch 'broadcast-to-worker' of https://github.com/krainboltgreene/mastodon into krainboltgreene-broadcast-to-worker
Diffstat (limited to 'app/workers')
-rw-r--r--app/workers/push_update_worker.rb22
1 files changed, 22 insertions, 0 deletions
diff --git a/app/workers/push_update_worker.rb b/app/workers/push_update_worker.rb
new file mode 100644
index 000000000..166a9b449
--- /dev/null
+++ b/app/workers/push_update_worker.rb
@@ -0,0 +1,22 @@
+# frozen_string_literal: true
+
+class PushUpdateWorker
+  include Sidekiq::Worker
+
+  def perform(timeline, account_id, status_id)
+    account = Account.find(account_id)
+    status  = Status.find(status_id)
+    
+    message = Rabl::Renderer.new(
+      'api/v1/statuses/show', 
+      status, 
+      view_path: 'app/views', 
+      format: :json, 
+      scope: InlineRablScope.new(account)
+    )
+
+    Redis.current.publish("timeline:#{account.id}", Oj.dump({ event: :update, payload: message, queued_at: (Time.now.to_f * 1000.0).to_i }))
+  rescue ActiveRecord::RecordNotFound
+    true
+  end
+end