mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-03 21:27:38 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Working presence!

Browse source
This commit is contained in:
matthew 2008-08-24 04:34:01 +00:00
parent 78739d9638
commit b7e9b10cce
3 changed files with 43 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

48
core/stanza_dispatch.lua
View file

@ -39,6 +39,7 @@ function init_stanza_dispatcher(session)
-- Authentication successful!
session.username = username;
session.resource = resource;
session.full_jid = username.."@"..session.host.."/"..session.resource;
if not hosts[session.host].sessions[username] then
hosts[session.host].sessions[username] = { sessions = {} };
end
@ -97,25 +98,40 @@ function init_stanza_dispatcher(session)
end
elseif stanza.name == "presence" then
if session.roster then
local initial_presence = not session.last_presence;
session.last_presence = stanza;
-- Broadcast presence and probes
local broadcast = st.presence({ from = session.username.."@"..session.host.."/"..session.resource });
local probe = st.presence { from = broadcast.attr.from, type = "probe" };
local broadcast = st.presence({ from = session.full_jid, type = stanza.attr.type });
--local probe = st.presence { from = broadcast.attr.from, type = "probe" };
for child in stanza:children() do
broadcast:tag(child.name, child.attr);
for child in stanza:childtags() do
broadcast:text(tostring(child));
end
for contact in pairs(session.roster) do
broadcast.attr.to = contact;
send_to(contact, broadcast);
--local host = jid.host(contact);
--if hosts[host] and hosts[host].type == "local" then
--local node, host = jid.split(contact);
--if host[host].sessions[node]
--local pres = st.presence { from = con
--else
-- probe.attr.to = contact;
-- send_to(contact, probe);
--end
for contact_jid in pairs(session.roster) do
broadcast.attr.to = contact_jid;
send_to(contact_jid, broadcast);
if initial_presence then
print("Initital presence");
local node, host = jid.split(contact_jid);
if hosts[host] and hosts[host].type == "local" then
local contact = hosts[host].sessions[node]
if contact then
local pres = st.presence { to = session.full_jid };
for resource, contact_session in pairs(contact.sessions) do
if contact_session.last_presence then
pres.tags = contact_session.last_presence.tags;
pres.attr.from = contact_session.full_jid;
send(pres);
end
end
end
--FIXME: Do we send unavailable if they are offline?
else
probe.attr.to = contact;
send_to(contact, probe);
end
end
end
-- Probe for our contacts' presence

2
main.lua
View file

@ -132,6 +132,8 @@ function handler(conn, data, err)
session.parser = lxp.new(session.xml_handlers, ":");
function session.disconnect(err)
hosts[session.host].sessions[session.username] = nil;
session = nil;
print("Disconnected: "..err);
end
end

9
util/stanza.lua
View file

@ -67,6 +67,15 @@ function stanza_mt:children()
if v then return v; end
end, self, i;
end
function stanza_mt:childtags()
local i = 0;
return function (a)
i = i + 1
local v = self.tags[i]
if v then return v; end
end, self.tags[1], i;
end
function stanza_mt.__tostring(t)