1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
local full_sessions = full_sessions;
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 user = bare_sessions[bare];
local t = stanza.attr.type;
if t == "error" then return true; end
if t == "groupchat" then
origin.send(st.error_reply(stanza, "cancel", "service-unavailable"));
return true;
end
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
end
-- no resources are online
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)
-- message to full JID recieved
local origin, stanza = data.origin, data.stanza;
local session = full_sessions[stanza.attr.to];
if session then
-- TODO fire post processing event
session.send(stanza);
return true;
else -- resource not online
return process_to_bare(jid_bare(stanza.attr.to), origin, stanza);
end
end);
module:hook("message/bare", function(data)
-- message to bare JID recieved
local origin, stanza = data.origin, data.stanza;
return process_to_bare(stanza.attr.to or (origin.username..'@'..origin.host), origin, stanza);
end);
|
