# HG changeset patch
# User syn@syn.im
# Date 1409508834 -7200
# Node ID e82592ed744b413c48e9b71e4e7cec920ccdd6c1
# Parent  d1836dfa4ae4d2456a267f197b5fef95d69c7005
mod_mam_archive: Applying @vstakhov 's patch (https://gist.github.com/vstakhov/306ea813a38021dcf3d4).
Fixing SQLite-related bugs, to-from bugs, rst compatibility, etc. Thanks Vsevolod!

diff -r d1836dfa4ae4 -r e82592ed744b mod_mam_archive/mod_mam_archive.lua
--- a/mod_mam_archive/mod_mam_archive.lua	Tue Aug 26 16:15:31 2014 +0200
+++ b/mod_mam_archive/mod_mam_archive.lua	Sun Aug 31 20:13:54 2014 +0200
@@ -9,6 +9,7 @@
 local jid_bare = require "util.jid".bare;
 local jid_prep = require "util.jid".prep;
 local date_parse = require "util.datetime".parse;
+local date_format = require "util.datetime".datetime;
 
 local st = require "util.stanza";
 local archive_store = "archive2";
@@ -16,6 +17,7 @@
 local global_default_policy = module:get_option("default_archive_policy", false);
 local default_max_items, max_max_items = 20, module:get_option_number("max_archive_query_results", 50);
 local conversation_interval = tonumber(module:get_option_number("archive_conversation_interval", 86400));
+local resolve_relative_path = require "core.configmanager".resolve_relative_path;
 
 -- Feature discovery
 local xmlns_archive = "urn:xmpp:archive"
@@ -30,10 +32,6 @@
 module:add_feature("http://jabber.org/protocol/rsm");
 -- --------------------------------------------------
 
-local function date_format(s)
-    return os.date("%Y-%m-%dT%H:%M:%SZ", s);
-end
-
 local function prefs_to_stanza(prefs)
     local prefstanza = st.stanza("pref", { xmlns="urn:xmpp:archive" });
     local default = prefs[false] ~= nil and prefs[false] or global_default_policy;
@@ -265,6 +263,7 @@
     local count = err;
 
     local chat = reply:tag("chat", {xmlns=xmlns_archive, with=qwith, start=date_format(qstart), version=count});
+    local first, last;
 
     module:log("debug", "Count "..count);
     for id, item, when in data do
@@ -273,10 +272,13 @@
         end
         module:log("debug", tostring(item));
 
-        local tag = jid_bare(item.attr["from"]) == jid_bare(origin.full_jid) and "from" or "to";
+        local tag = jid_bare(item.attr["from"]) == jid_bare(origin.full_jid) and "to" or "from";
         tag = chat:tag(tag, {secs = when - qstart});
         tag:add_child(item:get_child("body")):up();
+        if not first then first = id; end
+        last = id;
     end
+    reply:add_child(rsm.generate{ first = first, last = last, count = count })
 
     origin.send(reply);
     return true;