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
|
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];
if sessions then sessions = sessions.sessions; end
if sessions then
-- some resources are online
-- TODO find top resources willing to accept this message
-- TODO then send them each the stanza
else
-- no resources are online
-- 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
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);
|