trabajo-afectivo/lib/sessions/event/broadcast.rb

54 lines
1.8 KiB
Ruby
Raw Permalink Normal View History

# Copyright (C) 2012-2021 Zammad Foundation, http://zammad-foundation.org/
2015-12-09 13:09:37 +00:00
class Sessions::Event::Broadcast < Sessions::Event::Base
=begin
Event module to broadcast messages to all client connections.
To execute this manually, just paste the following into the browser console
App.WebSocket.send({event:'broadcast', recipient: { user_id: [1,2,3]}, data: {some: 'key'}})
=end
2015-12-09 13:09:37 +00:00
def run
# list all current clients
client_list = Sessions.list
client_list.each do |local_client_id, local_client|
2015-12-09 13:09:37 +00:00
if local_client_id == @client_id
log 'info', 'do not send broadcast to it self'
2015-12-09 13:09:37 +00:00
next
end
# broadcast to recipient list
if @payload['recipient']
if @payload['recipient'].class != Hash && @payload['recipient'].class != ActiveSupport::HashWithIndifferentAccess && @payload['recipient'].class != ActionController::Parameters
log 'error', "recipient attribute isn't a hash (#{@payload['recipient'].class}) '#{@payload['recipient'].inspect}'"
elsif !@payload['recipient'].key?('user_id')
log 'error', "need recipient.user_id attribute '#{@payload['recipient'].inspect}'"
elsif @payload['recipient']['user_id'].class != Array
log 'error', "recipient.user_id attribute isn't an array '#{@payload['recipient']['user_id'].inspect}'"
2015-12-09 13:09:37 +00:00
else
@payload['recipient']['user_id'].each do |user_id|
next if local_client[:user]['id'].to_i != user_id.to_i
log 'info', "send broadcast from (#{@client_id}) to (user_id=#{user_id})", local_client_id
websocket_send(local_client_id, @payload['data'])
end
2015-12-09 13:09:37 +00:00
end
# broadcast every client
else
log 'info', "send broadcast from (#{@client_id})", local_client_id
2015-12-09 13:09:37 +00:00
websocket_send(local_client_id, @payload['data'])
end
end
2015-12-09 13:09:37 +00:00
false
end
end