58 lines
1.2 KiB
Ruby
58 lines
1.2 KiB
Ruby
# 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
|