mastodon/app/workers/push_update_worker.rb

# 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 = inline_render(account, 'api/v1/statuses/show', status)
    queue_at = (Time.now.to_f * 1000.0).to_i
    ActionCable.server.broadcast("timeline:#{account_id}", type: 'update', timeline: timeline, message: message)
  end
end
By pushing this into a worker we can reduce the amount of time the feed manager using workers eat up a connection 2017-04-04 20:16:53 -07:00			`# 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 = inline_render(account, 'api/v1/statuses/show', status)`
Moving the queue_at into the worker 2017-04-04 20:39:14 -07:00			`queue_at = (Time.now.to_f * 1000.0).to_i`
Replacing the broadcast method with the one defined in the feed manager 2017-04-04 20:36:03 -07:00			`ActionCable.server.broadcast("timeline:#{account_id}", type: 'update', timeline: timeline, message: message)`
By pushing this into a worker we can reduce the amount of time the feed manager using workers eat up a connection 2017-04-04 20:16:53 -07:00			`end`
			`end`