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
|
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 function process_to_bare(bare, origin, stanza)
local sessions = 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 sessions then
-- some resources are connected
sessions = sessions.sessions;
if t == "headline" then
for _, session in pairs(sessions) do
if session.presence and session.priority >= 0 then
session.send(stanza);
end
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
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);
|
