diff options
author | Kim Alvefur <zash@zash.se> | 2017-10-08 23:59:13 +0200 |
---|---|---|
committer | Kim Alvefur <zash@zash.se> | 2017-10-08 23:59:13 +0200 |
commit | 85cfe97696f3482296cc846cb55ed226144c1aab (patch) | |
tree | 58e3332fbf4107c395d331ed0fd967c74807565d | |
parent | 85d9a523172228d2051dc77f33bd717fec07857d (diff) | |
download | prosody-85cfe97696f3482296cc846cb55ed226144c1aab.tar.gz prosody-85cfe97696f3482296cc846cb55ed226144c1aab.zip |
mod_pep_plus: Keep track of nodes, and restore them when later
-rw-r--r-- | plugins/mod_pep_plus.lua | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/plugins/mod_pep_plus.lua b/plugins/mod_pep_plus.lua index c848221b..52f6b66d 100644 --- a/plugins/mod_pep_plus.lua +++ b/plugins/mod_pep_plus.lua @@ -22,6 +22,9 @@ local hash_map = {}; local host = module.host; +local known_nodes_map = module:open_store("pep", "map"); +local known_nodes = module:open_store("pep"); + function module.save() return { services = services }; end @@ -40,6 +43,7 @@ end local function simple_itemstore(username) return function (config, node) module:log("debug", "new simple_itemstore(%q, %q)", username, node); + known_nodes_map:set(username, node, true); local archive = module:open_store("pep_"..node, "archive"); return lib_pubsub.simple_itemstore(archive, config, username, node, false); end @@ -186,6 +190,18 @@ function get_pep_service(username) normalize_jid = jid_bare; }); + local nodes, err = known_nodes:get(username); + if nodes then + module:log("debug", "Restoring nodes for user %s", username); + for node in pairs(nodes) do + module:log("debug", "Restoring node %q", node); + service:create(node, true); + end + elseif err then + module:log("error", "Could not restore nodes for %s: %s", username, err); + else + module:log("debug", "No known nodes"); + end services[username] = service; module:add_item("pep-service", { service = service, jid = user_bare }); return service; |