mod_archive: now auto archiving is almost done.
-- Prosody IM
-- Copyright (C) 2010 Dai Zhiwei
--
-- This project is MIT/X11 licensed. Please see the
-- COPYING file in the source package for more information.
--
local st = require "util.stanza";
local dm = require "util.datamanager";
local jid = require "util.jid";
local PREFS_DIR = "archive_prefs";
local ARCHIVE_DIR = "archive";
module:add_feature("urn:xmpp:archive");
module:add_feature("urn:xmpp:archive:auto");
module:add_feature("urn:xmpp:archive:manage");
module:add_feature("urn:xmpp:archive:manual");
module:add_feature("urn:xmpp:archive:pref");
------------------------------------------------------------
-- Utils
------------------------------------------------------------
local function load_prefs(node, host)
return st.deserialize(dm.load(node, host, PREFS_DIR));
end
local function store_prefs(data, node, host)
dm.store(node, host, PREFS_DIR, st.preserialize(data));
end
local function store_msg(msg, node, host, isfrom)
local body = msg:child_with_name("body");
local thread = msg:child_with_name("thread");
local data = dm.list_load(node, host, ARCHIVE_DIR);
local tag = (isfrom and "from") or "to";
if data then
for k, v in ipairs(data) do
-- <chat with='juliet@capulet.com/chamber'
-- start='1469-07-21T02:56:15Z'
-- thread='damduoeg08'
-- subject='She speaks!'
-- version='1'>
-- <from secs='0'><body>Art thou not Romeo, and a Montague?</body></from>
-- <to secs='11'><body>Neither, fair saint, if either thee dislike.</body></to>
-- <from secs='7'><body>How cam'st thou hither, tell me, and wherefore?</body></from>
-- <note utc='1469-07-21T03:04:35Z'>I think she might fancy me.</note>
-- </chat>
local collection = st.deserialize(v);
if collection.attr["thread"] == thread:get_text() then
-- TODO figure out secs
collection:tag(tag, {secs='1'}):add_child(body);
local ver = tonumber(collection.attr["version"]) + 1;
collection.attr["version"] = tostring(ver);
data[k] = collection;
dm.list_store(node, host, ARCHIVE_DIR, st.preserialize(data));
return;
end
end
end
-- not found, create new collection
-- TODO figure out start time
local collection = st.stanza('chat', {with = isfrom and msg.attr.to or msg.attr.from, start='2010-06-01T09:56:15Z', thread=thread:get_text(), version='0'});
collection:tag(tag, {secs='0'}):add_child(body);
dm.list_append(node, host, ARCHIVE_DIR, st.preserialize(collection));
end
------------------------------------------------------------
-- Preferences
------------------------------------------------------------
local function preferences_handler(event)
local origin, stanza = event.origin, event.stanza;
module:log("debug", "-- Enter preferences_handler()");
module:log("debug", "-- pref:\n%s", tostring(stanza));
if stanza.attr.type == "get" then
local data = load_prefs(origin.username, origin.host);
if data then
origin.send(st.reply(stanza):add_child(data));
else
local reply = st.reply(stanza):tag('pref', {xmlns='urn:xmpp:archive'});
reply:tag('default', {otr='concede', save='false', unset='true'}):up();
reply:tag('method', {type='auto', use='concede'}):up();
reply:tag('method', {type='local', use='concede'}):up();
reply:tag('method', {type='manual', use='concede'}):up();
reply:tag('auto', {save='false'}):up();
origin.send(reply);
end
elseif stanza.attr.type == "set" then
local node, host = origin.username, origin.host;
local data = load_prefs(node, host);
if not data then
data = st.stanza('pref', {xmlns='urn:xmpp:archive'});
data:tag('default', {otr='concede', save='false'}):up();
data:tag('method', {type='auto', use='concede'}):up();
data:tag('method', {type='local', use='concede'}):up();
data:tag('method', {type='manual', use='concede'}):up();
data:tag('auto', {save='false'}):up();
end
local elem = stanza.tags[1].tags[1]; -- iq:pref:xxx
if not elem then return false end
-- "default" | "item" | "session" | "method"
elem.attr["xmlns"] = nil; -- TODO why there is an extra xmlns attr?
if elem.name == "default" then
local setting = data:child_with_name(elem.name)
for k, v in pairs(elem.attr) do
setting.attr[k] = v;
end
-- setting.attr["unset"] = nil
elseif elem.name == "item" then
local found = false;
for child in data:children() do
-- TODO bare JID or full JID?
if child.name == elem.name and child.attr["jid"] == elem.attr["jid"] then
for k, v in pairs(elem.attr) do
child.attr[k] = v;
end
found = true;
break;
end
end
if not found then
data:tag(elem.name, elem.attr):up();
end
elseif elem.name == "session" then
local found = false;
for child in data:children() do
if child.name == elem.name and child.attr["thread"] == elem.attr["thread"] then
for k, v in pairs(elem.attr) do
child.attr[k] = v;
end
found = true;
break;
end
end
if not found then
data:tag(elem.name, elem.attr):up();
end
elseif elem.name == "method" then
local newpref = stanza.tags[1]; -- iq:pref
for _, e in ipairs(newpref.tags) do
-- if e.name ~= "method" then continue end
local found = false;
for child in data:children() do
if child.name == "method" and child.attr["type"] == e.attr["type"] then
child.attr["use"] = e.attr["use"];
found = true;
break;
end
end
if not found then
data:tag(e.name, e.attr):up();
end
end
end
store_prefs(data, node, host);
origin.send(st.reply(stanza));
local user = bare_sessions[node.."@"..host];
local push = st.iq({type="set"});
push = push:tag('pref', {xmlns='urn:xmpp:archive'});
if elem.name == "method" then
for child in data:children() do
if child.name == "method" then
push:add_child(child);
end
end
else
push:add_child(elem);
end
push = push:up();
for _, res in pairs(user and user.sessions or NULL) do -- broadcast to all resources
if res.presence then -- to resource
push.attr.to = res.full_jid;
res.send(push);
end
end
end
return true;
end
local function itemremove_handler(event)
local origin, stanza = event.origin, event.stanza;
if stanza.attr.type ~= "set" then
return false;
end
local elem = stanza.tags[1].tags[1];
if not elem or elem.name ~= "item" then
return false;
end
local node, host = origin.username, origin.host;
local data = load_prefs(node, host);
if not data then
return false;
end
for i, child in ipairs(data) do
if child.name == "item" and child.attr["jid"] == elem.attr["jid"] then
table.remove(data, i)
break;
end
end
store_prefs(data, node, host);
origin.send(st.reply(stanza));
return true;
end
local function sessionremove_handler(event)
local origin, stanza = event.origin, event.stanza;
if stanza.attr.type ~= "set" then
return false;
end
local elem = stanza.tags[1].tags[1];
if not elem or elem.name ~= "session" then
return false;
end
local node, host = origin.username, origin.host;
local data = load_prefs(node, host);
if not data then
return false;
end
for i, child in ipairs(data) do
if child.name == "session" and child.attr["thread"] == elem.attr["thread"] then
table.remove(data, i)
break;
end
end
store_prefs(data, node, host);
origin.send(st.reply(stanza));
return true;
end
local function auto_handler(event)
-- event.origin.send(st.error_reply(event.stanza, "cancel", "feature-not-implemented"));
local origin, stanza = event.origin, event.stanza;
if stanza.attr.type ~= "set" then
return false;
end
local elem = stanza.tags[1];
local node, host = origin.username, origin.host;
local data = load_prefs(node, host);
if not data then
return false;
end
local setting = data:child_with_name(elem.name)
for k, v in pairs(elem.attr) do
setting.attr[k] = v;
end
store_prefs(data, node, host);
origin.send(st.reply(stanza));
return true;
end
local function chat_handler(event)
module:log("debug", "-- stanza:\n%s", tostring(event.stanza));
return true;
end
local function list_handler(event)
module:log("debug", "-- stanza:\n%s", tostring(event.stanza));
return true;
end
local function modified_handler(event)
module:log("debug", "-- stanza:\n%s", tostring(event.stanza));
return true;
end
local function remove_handler(event)
module:log("debug", "-- stanza:\n%s", tostring(event.stanza));
return true;
end
local function retrieve_handler(event)
module:log("debug", "-- stanza:\n%s", tostring(event.stanza));
return true;
end
local function save_handler(event)
module:log("debug", "-- stanza:\n%s", tostring(event.stanza));
return true;
end
------------------------------------------------------------
-- Message Handler
------------------------------------------------------------
local function msg_handler(data)
-- TODO if not auto_archive_enabled then return nil;
module:log("debug", "-- Enter msg_handler()");
local origin, stanza = data.origin, data.stanza;
local body = stanza:child_with_name("body");
local thread = stanza:child_with_name("thread");
module:log("debug", "-- msg:\n%s", tostring(stanza));
if body then
module:log("debug", "-- msg body:\n%s", tostring(body));
-- TODO mapping messages and conversations to collections if no thread
if thread then
module:log("debug", "-- msg thread:\n%s", tostring(thread));
-- module:log("debug", "-- msg body text:\n%s", body:get_text());
local from_node, from_host = jid.split(stanza.attr.from);
local to_node, to_host = jid.split(stanza.attr.to);
-- FIXME only archive messages of users on this host
if from_host == "localhost" then
store_msg(stanza, from_node, from_host, true);
end
if to_host == "localhost" then
store_msg(stanza, to_node, to_host, false);
end
end
end
return nil;
end
module:hook("iq/self/urn:xmpp:archive:pref", preferences_handler);
module:hook("iq/self/urn:xmpp:archive:itemremove", itemremove_handler);
module:hook("iq/self/urn:xmpp:archive:sessionremove", sessionremove_handler);
module:hook("iq/self/urn:xmpp:archive:auto", auto_handler);
-- module:hook("iq/self/urn:xmpp:archive:chat", chat_handler);
module:hook("iq/self/urn:xmpp:archive:list", list_handler);
module:hook("iq/self/urn:xmpp:archive:modified", modified_handler);
module:hook("iq/self/urn:xmpp:archive:remove", remove_handler);
module:hook("iq/self/urn:xmpp:archive:retrieve", retrieve_handler);
module:hook("iq/self/urn:xmpp:archive:save", save_handler);
module:hook("message/full", msg_handler, 10);
module:hook("message/bare", msg_handler, 10);