[PATCH proxmox-backup 5/5] report: list the accessible s3 buckets

[Erik Fastermann <e.fastermann@proxmox.com>]

This shows whether the configured credentials still work, whether the
endpoint is reachable and which buckets are reported.

Implemented as a report function rather than as a command to set a
timeout and query the endpoints concurrently.

Signed-off-by: Erik Fastermann <e.fastermann@proxmox.com>
---
 src/server/report.rs | 78 +++++++++++++++++++++++++++++++++++++-------
 1 file changed, 67 insertions(+), 11 deletions(-)

diff --git a/src/server/report.rs b/src/server/report.rs
index b123c1fa9..a454b52bc 100644
--- a/src/server/report.rs
+++ b/src/server/report.rs
@@ -1,5 +1,14 @@
+use std::fmt::Write;
+use std::time::Duration;
+
+use futures::future::join_all;
+
 use proxmox_system_report::{FileGroup, FunctionMapping, StaticArgsCommandSpec};
 
+use crate::api2::config::s3::list_buckets;
+
+const S3_LIST_BUCKETS_TIMEOUT: Duration = Duration::from_secs(5);
+
 fn project_files() -> Vec<FileGroup> {
     vec![
         ("Datastores", vec!["/etc/proxmox-backup/datastore.cfg"]),
@@ -53,19 +62,66 @@ fn project_commands() -> Vec<StaticArgsCommandSpec> {
     ]
 }
 
-fn project_function_calls() -> Vec<FunctionMapping> {
-    vec![("Datastores", || {
-        let config = match pbs_config::datastore::config() {
-            Ok((config, _digest)) => config,
-            _ => return String::from("could not read datastore config"),
+fn s3_buckets() -> String {
+    let config = match pbs_config::s3::config() {
+        Ok((config, _digest)) => config,
+        Err(err) => return format!("*error*: could not read s3 config: {err:#}"),
+    };
+    if config.order.is_empty() {
+        return String::from("*note*: no s3 endpoints configured");
+    }
+
+    let listings = proxmox_async::runtime::block_on(async {
+        join_all(
+            config
+                .order
+                .iter()
+                .map(|id| tokio::time::timeout(S3_LIST_BUCKETS_TIMEOUT, list_buckets(id.clone()))),
+        )
+        .await
+    });
+
+    let mut out = String::new();
+
+    for (id, listing) in config.order.iter().zip(listings) {
+        writeln!(out, "\n###### {id}").unwrap();
+
+        match listing {
+            Ok(Ok(buckets)) if buckets.is_empty() => {
+                writeln!(out, "*note*: endpoint reported no buckets").unwrap()
+            }
+            Ok(Ok(buckets)) => buckets
+                .into_iter()
+                .for_each(|bucket| writeln!(out, "- {}", bucket.name).unwrap()),
+            Ok(Err(err)) => writeln!(out, "*error*: {err:#}").unwrap(),
+            Err(_timeout) => writeln!(
+                out,
+                "*error*: timed out after {} seconds",
+                S3_LIST_BUCKETS_TIMEOUT.as_secs(),
+            )
+            .unwrap(),
         };
+    }
+
+    out
+}
 
-        let mut list = Vec::new();
-        for store in config.sections.keys() {
-            list.push(store.as_str());
-        }
-        format!("```\n{}\n```", list.join(", "))
-    })]
+fn project_function_calls() -> Vec<FunctionMapping> {
+    vec![
+        ("Datastores", || {
+            let config = match pbs_config::datastore::config() {
+                Ok((config, _digest)) => config,
+                _ => return String::from("could not read datastore config"),
+            };
+
+            let mut list = Vec::new();
+            for store in config.sections.keys() {
+                list.push(store.as_str());
+            }
+            format!("```\n{}\n```", list.join(", "))
+        }),
+        ("S3 Buckets", s3_buckets),
+    ]
 }
 
 pub fn generate_report() -> String {
-- 
2.47.3