prosody
d370fea67264
core/presencemanager.lua

Find changesets by keywords by author, files, the commit message, revision number or hash, or revset expression.

Software / code / prosody

Comparison

core/presencemanager.lua @ 322:d370fea67264

Fix for broadcasting presence of available resources to newly approved contact
author Waqas Hussain <waqas20@gmail.com>
date Mon, 17 Nov 2008 10:24:47 +0500
parent 321:31fe15ce6fac
child 323:7c9d2cabd245
comparison
equal deleted inserted replaced
321:31fe15ce6fac 322:d370fea67264
11 local rostermanager = require "core.rostermanager"; 11 local rostermanager = require "core.rostermanager";
12 local sessionmanager = require "core.sessionmanager"; 12 local sessionmanager = require "core.sessionmanager";
13 13
14 module "presencemanager" 14 module "presencemanager"
15 15
16 function send_presence_of_available_resources(user, host, jid, recipient_session) 16 function send_presence_of_available_resources(user, host, jid, recipient_session, core_route_stanza)
17 local h = hosts[host]; 17 local h = hosts[host];
18 local count = 0; 18 local count = 0;
19 if h and h.type == "local" then 19 if h and h.type == "local" then
20 local u = h.sessions[user]; 20 local u = h.sessions[user];
21 if u then 21 if u then
22 for k, session in pairs(u.sessions) do 22 for k, session in pairs(u.sessions) do
23 local pres = session.presence; 23 local pres = session.presence;
24 if pres then 24 if pres then
25 pres.attr.to = jid; 25 pres.attr.to = jid;
26 pres.attr.from = session.full_jid; 26 pres.attr.from = session.full_jid;
27 recipient_session.send(pres); 27 core_route_stanza(recipient_session, pres);
28 pres.attr.to = nil; 28 pres.attr.to = nil;
29 pres.attr.from = nil; 29 pres.attr.from = nil;
30 count = count + 1; 30 count = count + 1;
31 end 31 end
32 end 32 end
59 -- 2. roster_push () 59 -- 2. roster_push ()
60 -- 3. send_presence_of_available_resources 60 -- 3. send_presence_of_available_resources
61 if rostermanager.subscribed(node, host, to_bare) then 61 if rostermanager.subscribed(node, host, to_bare) then
62 rostermanager.roster_push(node, host, to_bare); 62 rostermanager.roster_push(node, host, to_bare);
63 core_route_stanza(origin, stanza); 63 core_route_stanza(origin, stanza);
64 send_presence_of_available_resources(node, host, to_bare, origin); 64 send_presence_of_available_resources(node, host, to_bare, origin, core_route_stanza);
65 end 65 end
66 elseif stanza.attr.type == "unsubscribed" then 66 elseif stanza.attr.type == "unsubscribed" then
67 -- 1. route stanza 67 -- 1. route stanza
68 -- 2. roster push (subscription = none or to) 68 -- 2. roster push (subscription = none or to)
69 if rostermanager.unsubscribed(node, host, to_bare) then 69 if rostermanager.unsubscribed(node, host, to_bare) then
79 local st_from, st_to = stanza.attr.from, stanza.attr.to; 79 local st_from, st_to = stanza.attr.from, stanza.attr.to;
80 stanza.attr.from, stanza.attr.to = from_bare, to_bare; 80 stanza.attr.from, stanza.attr.to = from_bare, to_bare;
81 log("debug", "inbound presence "..stanza.attr.type.." from "..from_bare.." for "..to_bare); 81 log("debug", "inbound presence "..stanza.attr.type.." from "..from_bare.." for "..to_bare);
82 if stanza.attr.type == "probe" then 82 if stanza.attr.type == "probe" then
83 if rostermanager.is_contact_subscribed(node, host, from_bare) then 83 if rostermanager.is_contact_subscribed(node, host, from_bare) then
84 if 0 == send_presence_of_available_resources(node, host, from_bare, origin) then 84 if 0 == send_presence_of_available_resources(node, host, from_bare, origin, core_route_stanza) then
85 -- TODO send last recieved unavailable presence (or we MAY do nothing, which is fine too) 85 -- TODO send last recieved unavailable presence (or we MAY do nothing, which is fine too)
86 end 86 end
87 else 87 else
88 core_route_stanza(origin, st.presence({from=to_bare, to=from_bare, type="unsubscribed"})); 88 core_route_stanza(origin, st.presence({from=to_bare, to=from_bare, type="unsubscribed"}));
89 end 89 end