diff options
Diffstat (limited to 'plugins')
| -rw-r--r-- | plugins/mod_message.lua | 58 |
1 files changed, 40 insertions, 18 deletions
diff --git a/plugins/mod_message.lua b/plugins/mod_message.lua index 03e2081d..fc3ecbd7 100644 --- a/plugins/mod_message.lua +++ b/plugins/mod_message.lua @@ -4,9 +4,27 @@ local bare_sessions = bare_sessions; local jid_bare = require "util.jid".bare; local user_exists = require "core.usermanager".user_exists; +local offlinemanager = require "core.offlinemanager"; + +local function select_top_resources(user) + local priority = 0; + local recipients = {}; + for _, session in pairs(user.sessions) do -- find resource with greatest priority + if session.presence then + local p = session.priority; + if p > priority then + priority = p; + recipients = {session}; + elseif p == priority then + t_insert(recipients, session); + end + end + end + return recipients; +end local function process_to_bare(bare, origin, stanza) - local sessions = bare_sessions[bare]; + local user = bare_sessions[bare]; local t = stanza.attr.type; if t == "error" then return true; end @@ -14,31 +32,35 @@ local function process_to_bare(bare, origin, stanza) origin.send(st.error_reply(stanza, "cancel", "service-unavailable")); return true; end - - if sessions then - -- some resources are connected - sessions = sessions.sessions; - - if t == "headline" then - for _, session in pairs(sessions) do + if t == "headline" then + if user then + for _, session in pairs(user.sessions) do if session.presence and session.priority >= 0 then session.send(stanza); end end + end -- current policy is to discard headlines if no recipient is available + return true; + end + -- chat or normal message + if user then -- some resources are connected + local recipients = select_top_resources(user); + if #recipients > 0 then + for i=1,#recipients do + recipients[i].send(stanza); + end return true; end - -- TODO find top resources willing to accept this message - -- TODO then send them each the stanza - return; end -- no resources are online - if t == "headline" then return true; end -- current policy is to discard headlines - -- chat or normal message - -- TODO check if the user exists - -- TODO if it doesn't, return an error reply - -- TODO otherwise, apply the default privacy list - -- TODO and store into offline storage - -- TODO or maybe the offline store can apply privacy lists + local node, host = jid_split(bare); + if user_exists(node, host) then + -- TODO apply the default privacy list + offlinemanager.store(node, host, stanza); + else + origin.send(st.error_reply(stanza, "cancel", "service-unavailable")); + end + return true; end module:hook("message/full", function(data) |