X-Git-Url: https://git.enpas.org/?a=blobdiff_plain;f=core%2Frostermanager.lua;h=867add2c1889b4b268f899f9f7c4fd93d473a590;hb=5a47bbc758024aa9ae390f6a0a713aa25c11ddd0;hp=7236a006fc0033f09efb36d9a34783d141c7ae69;hpb=a4d1701bd5e08cce7b221200394776a3171ddcac;p=prosody.git diff --git a/core/rostermanager.lua b/core/rostermanager.lua index 7236a006..867add2c 100644 --- a/core/rostermanager.lua +++ b/core/rostermanager.lua @@ -1,4 +1,4 @@ --- Prosody IM v0.3 +-- Prosody IM v0.4 -- Copyright (C) 2008-2009 Matthew Wild -- Copyright (C) 2008-2009 Waqas Hussain -- @@ -15,6 +15,7 @@ local setmetatable = setmetatable; local format = string.format; local loadfile, setfenv, pcall = loadfile, setfenv, pcall; local pairs, ipairs = pairs, ipairs; +local tostring = tostring; local hosts = hosts; @@ -54,10 +55,11 @@ function remove_from_roster(session, jid) end function roster_push(username, host, jid) - if jid ~= "pending" and hosts[host] and hosts[host].sessions[username] and hosts[host].sessions[username].roster then + local roster = jid and jid ~= "pending" and hosts[host] and hosts[host].sessions[username] and hosts[host].sessions[username].roster; + if roster then local item = hosts[host].sessions[username].roster[jid]; local stanza = st.iq({type="set"}); - stanza:tag("query", {xmlns = "jabber:iq:roster"}); + stanza:tag("query", {xmlns = "jabber:iq:roster", ver = tostring(roster[false].version or "1") }); if item then stanza:tag("item", {jid = jid, subscription = item.subscription, name = item.name, ask = item.ask}); for group in pairs(item.groups) do @@ -85,6 +87,7 @@ function load_roster(username, host) if not roster then log("debug", "load_roster: loading for new user: "..username.."@"..host); roster = datamanager.load(username, host, "roster") or {}; + if not roster[false] then roster[false] = { }; end hosts[host].sessions[username].roster = roster; end return roster; @@ -97,8 +100,11 @@ end function save_roster(username, host) log("debug", "save_roster: saving roster for "..username.."@"..host); if hosts[host] and hosts[host].sessions[username] and hosts[host].sessions[username].roster then + local roster = hosts[host].sessions[username].roster; + roster[false].version = (roster[false].version or 1) + 1; return datamanager.store(username, host, "roster", hosts[host].sessions[username].roster); end + log("warn", "save_roster: user had no roster to save"); return nil; end @@ -218,6 +224,10 @@ function subscribed(username, host, jid) if is_contact_pending_in(username, host, jid) then local roster = load_roster(username, host); local item = roster[jid]; + if not item then -- FIXME should roster item be auto-created? + item = {subscription = "none", groups = {}}; + roster[jid] = item; + end if item.subscription == "none" then item.subscription = "from"; else -- subscription == to @@ -271,4 +281,4 @@ end]] -return _M; \ No newline at end of file +return _M;