Refactor message queuing to use NetworkMessenger and Messenger based on configuration
This commit is contained in:
@@ -375,8 +375,11 @@ shared.Commander = {
|
|||||||
print(string.format("[%s] Queuing message", ModuleName))
|
print(string.format("[%s] Queuing message", ModuleName))
|
||||||
shared.dump(msg)
|
shared.dump(msg)
|
||||||
end
|
end
|
||||||
--table.insert(shared.messenger.queue, msg)
|
if Heimdall_Data.config.networkMessenger.enabled then
|
||||||
table.insert(shared.networkMessenger.queue, returnmsg)
|
shared.NetworkMessenger.Enqueue(returnmsg)
|
||||||
|
elseif Heimdall_Data.config.messenger.enabled then
|
||||||
|
shared.Messenger.Enqueue(returnmsg)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -13,6 +13,8 @@ local ModuleName = "NetworkMessenger"
|
|||||||
|
|
||||||
---@class NetworkMessenger
|
---@class NetworkMessenger
|
||||||
shared.NetworkMessenger = {
|
shared.NetworkMessenger = {
|
||||||
|
---@param message Message
|
||||||
|
Enqueue = function(message) table.insert(shared.networkMessenger.queue, message) end,
|
||||||
Init = function()
|
Init = function()
|
||||||
RegisterAddonMessagePrefix(Heimdall_Data.config.addonPrefix)
|
RegisterAddonMessagePrefix(Heimdall_Data.config.addonPrefix)
|
||||||
|
|
||||||
|
|||||||
@@ -121,8 +121,11 @@ shared.Noter = {
|
|||||||
data = channel,
|
data = channel,
|
||||||
message = string.format("[%s][%d] %s: %s", note.source, index, note.date, note.note),
|
message = string.format("[%s][%d] %s: %s", note.source, index, note.date, note.note),
|
||||||
}
|
}
|
||||||
--table.insert(shared.messenger.queue, msg)
|
if Heimdall_Data.config.networkMessenger.enabled then
|
||||||
table.insert(shared.networkMessenger.queue, msg)
|
shared.NetworkMessenger.Enqueue(msg)
|
||||||
|
elseif Heimdall_Data.config.messenger.enabled then
|
||||||
|
shared.Messenger.Enqueue(msg)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
---@param name string
|
---@param name string
|
||||||
---@param args string[]
|
---@param args string[]
|
||||||
|
|||||||
@@ -323,7 +323,11 @@ shared.Whoer = {
|
|||||||
print(string.format("[%s] Queuing channel notification", ModuleName))
|
print(string.format("[%s] Queuing channel notification", ModuleName))
|
||||||
shared.dump(msg)
|
shared.dump(msg)
|
||||||
end
|
end
|
||||||
table.insert(shared.networkMessenger.queue, msg)
|
if Heimdall_Data.config.networkMessenger.enabled then
|
||||||
|
shared.NetworkMessenger.Enqueue(msg)
|
||||||
|
elseif Heimdall_Data.config.messenger.enabled then
|
||||||
|
shared.Messenger.Enqueue(msg)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
--if Heimdall_Data.config.who.doWhisper then
|
--if Heimdall_Data.config.who.doWhisper then
|
||||||
@@ -382,7 +386,11 @@ shared.Whoer = {
|
|||||||
print(string.format("[%s] Queuing channel notification", ModuleName))
|
print(string.format("[%s] Queuing channel notification", ModuleName))
|
||||||
shared.dump(msg)
|
shared.dump(msg)
|
||||||
end
|
end
|
||||||
table.insert(shared.networkMessenger.queue, msg)
|
if Heimdall_Data.config.networkMessenger.enabled then
|
||||||
|
shared.NetworkMessenger.Enqueue(msg)
|
||||||
|
elseif Heimdall_Data.config.messenger.enabled then
|
||||||
|
shared.Messenger.Enqueue(msg)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
--if Heimdall_Data.config.who.doWhisper then
|
--if Heimdall_Data.config.who.doWhisper then
|
||||||
@@ -433,8 +441,11 @@ shared.Whoer = {
|
|||||||
print(string.format("[%s] Queuing channel notification", ModuleName))
|
print(string.format("[%s] Queuing channel notification", ModuleName))
|
||||||
shared.dump(msg)
|
shared.dump(msg)
|
||||||
end
|
end
|
||||||
--table.insert(shared.messenger.queue, msg)
|
if Heimdall_Data.config.networkMessenger.enabled then
|
||||||
table.insert(shared.networkMessenger.queue, msg)
|
shared.NetworkMessenger.Enqueue(msg)
|
||||||
|
elseif Heimdall_Data.config.messenger.enabled then
|
||||||
|
shared.Messenger.Enqueue(msg)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
--if Heimdall_Data.config.who.doWhisper then
|
--if Heimdall_Data.config.who.doWhisper then
|
||||||
|
|||||||
Reference in New Issue
Block a user