diff options
| author | Kim Alvefur <zash@zash.se> | 2019-05-27 19:17:12 +0200 |
|---|---|---|
| committer | Kim Alvefur <zash@zash.se> | 2019-05-27 19:17:12 +0200 |
| commit | 0f41a59a9661bdd737ae343567d73bc47a5d5ba6 (patch) | |
| tree | ff8dba22a43f87b20109ab298eb508300dd1ffe9 /plugins/mod_mam/mod_mam.lua | |
| parent | 58b5ba4345e115ac259166cd84b6f8a42d15d0f8 (diff) | |
| parent | 5cc63a416a1552da3259418db96d63af12079651 (diff) | |
| download | prosody-0f41a59a9661bdd737ae343567d73bc47a5d5ba6.tar.gz prosody-0f41a59a9661bdd737ae343567d73bc47a5d5ba6.zip | |
Merge 0.11->trunk
Diffstat (limited to 'plugins/mod_mam/mod_mam.lua')
| -rw-r--r-- | plugins/mod_mam/mod_mam.lua | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/plugins/mod_mam/mod_mam.lua b/plugins/mod_mam/mod_mam.lua index 317ddac1..4e0cf531 100644 --- a/plugins/mod_mam/mod_mam.lua +++ b/plugins/mod_mam/mod_mam.lua @@ -43,7 +43,6 @@ local archive = module:open_store(archive_store, "archive"); local cleanup_after = module:get_option_string("archive_expires_after", "1w"); local cleanup_interval = module:get_option_number("archive_cleanup_interval", 4 * 60 * 60); local archive_item_limit = module:get_option_number("storage_archive_item_limit", archive.caps and archive.caps.quota or 1000); - if not archive.find then error("mod_"..(archive._provided_by or archive.name and "storage_"..archive.name).." does not support archiving\n" .."See https://prosody.im/doc/storage and https://prosody.im/doc/archiving for more information"); @@ -375,9 +374,15 @@ if cleanup_after ~= "never" then -- messages, we collect the union of sets of users from dates that fall -- outside the cleanup range. + local last_date = require "util.cache".new(module:get_option_number("archive_cleanup_date_cache_size", 1000)); function schedule_cleanup(username, date) - cleanup_map:set(date or datestamp(), username, true); + date = date or datestamp(); + if last_date:get(username) == date then return end + local ok = cleanup_map:set(date, username, true); + if ok then + last_date:set(username, date); end + end local cleanup_time = module:measure("cleanup", "times"); cleanup_runner = require "util.async".runner(function () |