diff options
| author | Kim Alvefur <zash@zash.se> | 2017-10-08 01:56:44 +0200 |
|---|---|---|
| committer | Kim Alvefur <zash@zash.se> | 2017-10-08 01:56:44 +0200 |
| commit | b4129893d907d7524b61c31d2574f58945118ed4 (patch) | |
| tree | 35b5956d36b156d01f4c8591eaaec21d3127464a /plugins/mod_pubsub | |
| parent | 2572082717a2bd675cfed0c18d362d56b90346c1 (diff) | |
| download | prosody-b4129893d907d7524b61c31d2574f58945118ed4.tar.gz prosody-b4129893d907d7524b61c31d2574f58945118ed4.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.lua | 12 |
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 |