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

mod_mam: Implement extended MAM metadata query

Browse source
This commit is contained in:
Kim Alvefur 2020-11-30 23:42:13 +01:00
parent af189d8103
commit 9e5dbb4217
2 changed files with 49 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

36
plugins/mod_mam/mod_mam.lua
View file

@ -229,6 +229,41 @@ module:hook("iq-set/self/"..xmlns_mam..":query", function(event)
return true; return true;
end); end);
module:hook("iq-get/self/"..xmlns_mam..":metadata", function (event)
local origin, stanza = event.origin, event.stanza;
local reply = st.reply(stanza):tag("metadata", { xmlns = xmlns_mam });
do
local first = archive:find(origin.username, { limit = 1 });
if not first then
origin.send(st.error_reply(stanza, "cancel", "internal-server-error"));
return true;
end
local id, _, when = first();
if id then
reply:tag("start", { id = id, timestamp = timestamp(when) }):up();
end
end
do
local last = archive:find(origin.username, { limit = 1, reverse = true });
if not last then
origin.send(st.error_reply(stanza, "cancel", "internal-server-error"));
return true;
end
local id, _, when = last();
if id then
reply:tag("end", { id = id, timestamp = timestamp(when) }):up();
end
end
origin.send(reply);
return true;
end);
local function has_in_roster(user, who) local function has_in_roster(user, who)
local roster = rm_load_roster(user, host); local roster = rm_load_roster(user, host);
module:log("debug", "%s has %s in roster? %s", user, who, roster[who] and "yes" or "no"); module:log("debug", "%s has %s in roster? %s", user, who, roster[who] and "yes" or "no");
@ -522,7 +557,6 @@ module:hook("message/full", message_handler, 0);
local advertise_extended = module:get_option_boolean("mam_advertise_extend", false); local advertise_extended = module:get_option_boolean("mam_advertise_extend", false);
-- TODO before-id, after-id -- TODO before-id, after-id
-- TODO ids -- TODO ids
-- TODO archive metadata query
-- TODO delete feature flag option -- TODO delete feature flag option
module:hook("account-disco-info", function(event) module:hook("account-disco-info", function(event)

14
spec/scansion/mam_extended.scs
View file

@ -36,6 +36,20 @@ Romeo sends:
<body>U there?</body> <body>U there?</body>
</message> </message>
# Metadata
Romeo sends:
<iq type="get" id="mamextmeta">
<metadata xmlns="urn:xmpp:mam:2"/>
</iq>
Romeo receives:
<iq type="result" id="mamextmeta">
<metadata xmlns="urn:xmpp:mam:2">
<start timestamp="2008-08-22T21:09:04Z" xmlns="urn:xmpp:mam:2" id="{scansion:any}"/>
<end timestamp="2008-08-22T21:09:04Z" xmlns="urn:xmpp:mam:2" id="{scansion:any}"/>
</metadata>
</iq>
Romeo sends: Romeo sends:
<iq type="set" id="mamquery1"> <iq type="set" id="mamquery1">
<query xmlns="urn:xmpp:mam:2" queryid="q1"/> <query xmlns="urn:xmpp:mam:2" queryid="q1"/>