aboutsummaryrefslogtreecommitdiffstats
path: root/plugins/mod_mam/fallback_archive.lib.lua
diff options
context:
space:
mode:
authorKim Alvefur <zash@zash.se>2018-10-25 21:59:17 +0200
committerKim Alvefur <zash@zash.se>2018-10-25 21:59:17 +0200
commit7dece5bcba14f2a7625ce0b22e4bb157365f7777 (patch)
treebcabe932b97e8da72d87fc6eb8ac21a9dcac3492 /plugins/mod_mam/fallback_archive.lib.lua
parent8932b4d9c9aabe6f58c0d07831fa08f296c73f08 (diff)
downloadprosody-7dece5bcba14f2a7625ce0b22e4bb157365f7777.tar.gz
prosody-7dece5bcba14f2a7625ce0b22e4bb157365f7777.zip
mod_mam: Remove embedded fallback archive driver (fixes #972)
It was equivalent to mod_storage_memory, which is included as a separate module now.
Diffstat (limited to 'plugins/mod_mam/fallback_archive.lib.lua')
-rw-r--r--plugins/mod_mam/fallback_archive.lib.lua91
1 files changed, 0 insertions, 91 deletions
diff --git a/plugins/mod_mam/fallback_archive.lib.lua b/plugins/mod_mam/fallback_archive.lib.lua
deleted file mode 100644
index 71e65274..00000000
--- a/plugins/mod_mam/fallback_archive.lib.lua
+++ /dev/null
@@ -1,91 +0,0 @@
--- Prosody IM
--- Copyright (C) 2008-2017 Matthew Wild
--- Copyright (C) 2008-2017 Waqas Hussain
--- Copyright (C) 2011-2017 Kim Alvefur
---
--- This project is MIT/X11 licensed. Please see the
--- COPYING file in the source package for more information.
---
--- luacheck: ignore 212/self
-
-local uuid = require "util.uuid".generate;
-local store = module:shared("archive");
-local archive_store = { _provided_by = "mam"; name = "fallback"; };
-
-function archive_store:append(username, key, value, when, with)
- local archive = store[username];
- if not archive then
- archive = { [0] = 0 };
- store[username] = archive;
- end
- local index = (archive[0] or #archive)+1;
- local item = { key = key, when = when, with = with, value = value };
- if not key or archive[key] then
- key = uuid();
- item.key = key;
- end
- archive[index] = item;
- archive[key] = index;
- archive[0] = index;
- return key;
-end
-
-function archive_store:find(username, query)
- local archive = store[username] or {};
- local start, stop, step = 1, archive[0] or #archive, 1;
- local qstart, qend, qwith = -math.huge, math.huge;
- local limit;
-
- if query then
- if query.reverse then
- start, stop, step = stop, start, -1;
- if query.before and archive[query.before] then
- start = archive[query.before] - 1;
- end
- elseif query.after and archive[query.after] then
- start = archive[query.after] + 1;
- end
- qwith = query.with;
- limit = query.limit;
- qstart = query.start or qstart;
- qend = query["end"] or qend;
- end
-
- return function ()
- if limit and limit <= 0 then return end
- for i = start, stop, step do
- local item = archive[i];
- if (not qwith or qwith == item.with) and item.when >= qstart and item.when <= qend then
- if limit then limit = limit - 1; end
- start = i + step; -- Start on next item
- return item.key, item.value, item.when, item.with;
- end
- end
- end
-end
-
-function archive_store:delete(username, query)
- if not query or next(query) == nil then
- -- no specifics, delete everything
- store[username] = nil;
- return true;
- end
- local archive = store[username];
- if not archive then return true; end -- no messages, nothing to delete
-
- local qstart = query.start or -math.huge;
- local qend = query["end"] or math.huge;
- local qwith = query.with;
- store[username] = nil;
- for i = 1, #archive do
- local item = archive[i];
- local when, with = item.when, item.when;
- -- Add things that don't match the query
- if not ((not qwith or qwith == item.with) and item.when >= qstart and item.when <= qend) then
- self:append(username, item.key, item.value, when, with);
- end
- end
- return true;
-end
-
-return archive_store;