mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-04 21:57:45 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

mod_storage_sql: Implement archive summary API

Browse source
This commit is contained in:
Kim Alvefur 2019-02-25 15:51:55 +01:00
parent 582fa3f46f
commit a32b5ceb45
1 changed files with 35 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

35
plugins/mod_storage_sql.lua
View file

@ -419,6 +419,41 @@ function archive_store:find(username, query)
end, total;
end
function archive_store:summary(username, query)
query = query or {};
local user,store = username,self.store;
local ok, result = engine:transaction(function()
local sql_query = [[
SELECT DISTINCT "with", COUNT(*)
FROM "prosodyarchive"
WHERE %s
GROUP BY "with"
ORDER BY "sort_id" %s%s;
]];
local args = { host, user or "", store, };
local where = { "\"host\" = ?", "\"user\" = ?", "\"store\" = ?", };
archive_where(query, args, where);
archive_where_id_range(query, args, where);
if query.limit then
args[#args+1] = query.limit;
end
sql_query = sql_query:format(t_concat(where, " AND "), query.reverse
and "DESC" or "ASC", query.limit and " LIMIT ?" or "");
return engine:select(sql_query, unpack(args));
end);
if not ok then return ok, result end
local summary = {};
for row in result do
local with, count = row[1], row[2];
summary[with] = count;
end
return summary;
end
function archive_store:delete(username, query)
query = query or {};
local user,store = username,self.store;