about summary refs log tree commit diff
path: root/app/workers/push_update_worker.rb
diff options
context:
space:
mode:
authorDavid Yip <yipdw@member.fsf.org>2017-11-17 17:40:00 -0600
committerDavid Yip <yipdw@member.fsf.org>2017-11-17 17:40:00 -0600
commit1ab12ba38ebd42be93b63b7cf0d3c6a81060b741 (patch)
tree3899389c63c16e33dd48fadb270d3259a7c15b67 /app/workers/push_update_worker.rb
parent6f8ccbfcdf7fd8ca651d1583a608e96b25a09e25 (diff)
parent24cafd73a2b644025e9aeaadf4fed46dd3ecea4d (diff)
Merge remote-tracking branch 'origin/master' into merge-upstream
Diffstat (limited to 'app/workers/push_update_worker.rb')
-rw-r--r--app/workers/push_update_worker.rb11
1 files changed, 6 insertions, 5 deletions
diff --git a/app/workers/push_update_worker.rb b/app/workers/push_update_worker.rb
index 697cbd6a6..d76d73d96 100644
--- a/app/workers/push_update_worker.rb
+++ b/app/workers/push_update_worker.rb
@@ -3,12 +3,13 @@
 class PushUpdateWorker
   include Sidekiq::Worker
 
-  def perform(account_id, status_id)
-    account = Account.find(account_id)
-    status  = Status.find(status_id)
-    message = InlineRenderer.render(status, account, :status)
+  def perform(account_id, status_id, timeline_id = nil)
+    account     = Account.find(account_id)
+    status      = Status.find(status_id)
+    message     = InlineRenderer.render(status, account, :status)
+    timeline_id = "timeline:#{account.id}" if timeline_id.nil?
 
-    Redis.current.publish("timeline:#{account.id}", Oj.dump(event: :update, payload: message, queued_at: (Time.now.to_f * 1000.0).to_i))
+    Redis.current.publish(timeline_id, Oj.dump(event: :update, payload: message, queued_at: (Time.now.to_f * 1000.0).to_i))
   rescue ActiveRecord::RecordNotFound
     true
   end