trabajo-afectivo/lib/push_messages.rb

58 lines
1.2 KiB
Ruby
Raw Permalink Normal View History

# Copyright (C) 2012-2021 Zammad Foundation, http://zammad-foundation.org/
module PushMessages
def self.enabled?
return true if Thread.current[:push_messages].instance_of?(Array)
false
end
def self.init
return true if enabled?
Thread.current[:push_messages] = []
end
def self.send(data)
if !PushMessages.enabled?
Sessions.broadcast(
data[:message],
data[:type],
data[:current_user_id],
)
return true
end
message = { type: 'broadcast', data: data }
Thread.current[:push_messages].push message
end
def self.send_to(user_id, data)
if !PushMessages.enabled?
Sessions.send_to(user_id, data)
return true
end
message = { type: 'send_to', user_id: user_id, data: data }
Thread.current[:push_messages].push message
end
def self.finish
return false if !enabled?
Thread.current[:push_messages].each do |message|
if message[:type] == 'send_to'
Sessions.send_to(message[:user_id], message[:data])
else
Sessions.broadcast(
message[:data][:message],
message[:data][:type],
message[:data][:current_user_id],
)
end
end
Thread.current[:push_messages] = nil
true
end
end