LeadMagnet/leadchat
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Move ActionCable Broadcast Calls to sidekiq #154 (#403)

Browse Source 
* Move Pusher Calls to sidekiq

* CR changes

Co-authored-by: Sojan Jose <sojan@pepalo.com>
This commit is contained in:
mbronek7
2020-01-06 18:02:41 +01:00
committed by Sojan Jose
parent 91ace96acd
commit f02d422b6a
2 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/jobs/action_cable_broadcast_job.rb Normal file
View File

@@ -0,0 +1,9 @@
class ActionCableBroadcastJob < ApplicationJob
queue_as :default
def perform(members, event_name, data)
members.each do |member|
ActionCable.server.broadcast(member, event: event_name, data: data)
end
end
end

6
app/listeners/action_cable_listener.rb
View File

@@ -45,9 +45,7 @@ class ActionCableListener < BaseListener
def send_to_members(members, event_name, data) def send_to_members(members, event_name, data)
return if members.blank? return if members.blank?
members.each do |member| ::ActionCableBroadcastJob.perform_later(members, event_name, data)
ActionCable.server.broadcast(member, event: event_name, data: data)
end
end end
def send_to_contact(contact, event_name, message) def send_to_contact(contact, event_name, message)
@@ -55,7 +53,7 @@ class ActionCableListener < BaseListener
return if message.activity? return if message.activity?
return if contact.nil? return if contact.nil?
ActionCable.server.broadcast(contact.pubsub_token, event: event_name, data: message.push_event_data) ::ActionCableBroadcastJob.perform_later([contact.pubsub_token], event_name, message.push_event_data)
end end
def push(pubsub_token, data) def push(pubsub_token, data)