aboutsummaryrefslogtreecommitdiffstats
path: root/plugins/mod_pubsub
diff options
context:
space:
mode:
authorKim Alvefur <zash@zash.se>2017-10-08 01:56:44 +0200
committerKim Alvefur <zash@zash.se>2017-10-08 01:56:44 +0200
commit4d75ff22170f3cd0e8c61082bb195435fe8cbe3c (patch)
tree35b5956d36b156d01f4c8591eaaec21d3127464a /plugins/mod_pubsub
parent72a554f9152e3a84a089f7c4fc40d5e320fced1c (diff)
downloadprosody-4d75ff22170f3cd0e8c61082bb195435fe8cbe3c.tar.gz
prosody-4d75ff22170f3cd0e8c61082bb195435fe8cbe3c.zip
mod_pep_plus, mod_pubsub: Store node content in separate archive stores
Diffstat (limited to 'plugins/mod_pubsub')
-rw-r--r--plugins/mod_pubsub/pubsub.lib.lua12
1 files changed, 4 insertions, 8 deletions
diff --git a/plugins/mod_pubsub/pubsub.lib.lua b/plugins/mod_pubsub/pubsub.lib.lua
index 5e09dab3..06615284 100644
--- a/plugins/mod_pubsub/pubsub.lib.lua
+++ b/plugins/mod_pubsub/pubsub.lib.lua
@@ -331,7 +331,7 @@ local function simple_itemstore(archive, config, user, node, expose_publisher)
local get_set = {};
function get_set:items()
local store = self.store;
- local data, err = archive:find(user, { with = node });
+ local data, err = archive:find(user);
if not data then
module:log("error", "Unable to get items: %s", err);
return true;
@@ -349,7 +349,6 @@ local function simple_itemstore(archive, config, user, node, expose_publisher)
function get_set:get(key)
local store = self.store;
local data, err = archive:find(user, {
- with = node;
key = key;
});
if not data then
@@ -370,12 +369,9 @@ local function simple_itemstore(archive, config, user, node, expose_publisher)
if value ~= nil then
local publisher = value.attr.publisher;
local payload = value.tags[1];
- data, err = archive:append(user, key, payload, time_now(), node);
+ data, err = archive:append(user, key, payload, time_now(), publisher);
else
- data, err = archive:delete(user, {
- key = key;
- with = node;
- });
+ data, err = archive:delete(user, { key = key; });
end
if not data then
module:log("error", "Unable to set item: %s", err);
@@ -384,7 +380,7 @@ local function simple_itemstore(archive, config, user, node, expose_publisher)
return data;
end
function get_set:clear()
- return archive:delete(user, { with = node });
+ return archive:delete(user);
end
return setmetatable(get_set, archive);
end