Software / code / prosody-modules
Changeset
5695:c74a96dc5d58
mod_storage_s3: Implement iteration of keyvalue keys (users usually)
| author | Kim Alvefur <zash@zash.se> |
|---|---|
| date | Sat, 14 Oct 2023 21:41:01 +0200 |
| parents | 5694:c8322c64a548 |
| children | 5696:b17ba149b7c5 |
| files | mod_storage_s3/mod_storage_s3.lua |
| diffstat | 1 files changed, 19 insertions(+), 1 deletions(-) [+] |
line wrap: on
line diff
--- a/mod_storage_s3/mod_storage_s3.lua Sat Oct 14 21:40:46 2023 +0200 +++ b/mod_storage_s3/mod_storage_s3.lua Sat Oct 14 21:41:01 2023 +0200 @@ -151,7 +151,25 @@ end function keyval:users() - return nil, "not-implemented"; + local bucket_path = url.build_path({ is_absolute = true; bucket; is_directory = true }); + local prefix = url.build_path({ jid.escape(module.host); jid.escape(self.store); is_directory = true }); + local list_result, err = async.wait_for(new_request("GET", bucket_path, { prefix = prefix })) + if err or list_result.code ~= 200 then + return nil, err; + end + local list_bucket_result = xml.parse(list_result.body); + if list_bucket_result:get_child_text("IsTruncated") == "true" then + local max_keys = list_bucket_result:get_child_text("MaxKeys"); + module:log("warn", "Paging truncated results not implemented, max %s %s returned", max_keys, self.store); + end + local keys = array(); + for content in list_bucket_result:childtags("Contents") do + local key = url.parse_path(content:get_child_text("Key")); + keys:push(jid.unescape(key[3])); + end + return function() + return keys:pop(); + end end module:provides("storage", driver);
