push_conversation_worker.rb 551 B

12345678910111213141516
  1. # frozen_string_literal: true
  2. class PushConversationWorker
  3. include Sidekiq::Worker
  4. include Redisable
  5. def perform(conversation_account_id)
  6. conversation = AccountConversation.find(conversation_account_id)
  7. message = InlineRenderer.render(conversation, conversation.account, :conversation)
  8. timeline_id = "timeline:direct:#{conversation.account_id}"
  9. redis.publish(timeline_id, Oj.dump(event: :conversation, payload: message, queued_at: (Time.now.to_f * 1000.0).to_i))
  10. rescue ActiveRecord::RecordNotFound
  11. true
  12. end
  13. end