WIP

Author: HJLebbink

examples/get_bucket_versioning.rs

@@ -15,9 +15,11 @@
 
 mod common;
 
+use minio::s3::args::SetBucketVersioningArgs;
 use crate::common::{create_bucket_if_not_exists, create_client_on_play};
-use minio::s3::builders::GetBucketVersioning;
 use minio::s3::Client;
+use minio::s3::response::{GetBucketVersioningResponse, SetBucketVersioningResponse};
+use minio::s3::types::S3Api;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
@@ -27,9 +29,37 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
     let bucket_name: &str = "versioning-rust-bucket";
     create_bucket_if_not_exists(bucket_name, &client).await?;
 
-    let bv: GetBucketVersioning = client.get_bucket_versioning(bucket_name);
+    let resp: GetBucketVersioningResponse =
+        client.get_bucket_versioning(bucket_name).send().await?;
+    log::info!(
+        "versioning before: status={:?}, mfa_delete={:?}",
+        resp.status,
+        resp.mfa_delete
+    );
 
-    log::info!("{:?}", bv);
+    let _resp: SetBucketVersioningResponse = client
+        .set_bucket_versioning(&SetBucketVersioningArgs::new(bucket_name, true).unwrap()).await?;
+
+    let resp: GetBucketVersioningResponse =
+        client.get_bucket_versioning(bucket_name).send().await?;
+
+    log::info!(
+        "versioning after setting to true: status={:?}, mfa_delete={:?}",
+        resp.status,
+        resp.mfa_delete
+    );
+
+    let _resp: SetBucketVersioningResponse = client
+        .set_bucket_versioning(&SetBucketVersioningArgs::new(bucket_name, false).unwrap()).await?;
+
+    let resp: GetBucketVersioningResponse =
+        client.get_bucket_versioning(bucket_name).send().await?;
+
+    log::info!(
+        "versioning after setting to false: status={:?}, mfa_delete={:?}",
+        resp.status,
+        resp.mfa_delete
+    );
 
     Ok(())
 }

tests/tests.rs

@@ -1268,7 +1268,7 @@ impl ClientTest {
             .send()
             .await
             .unwrap();
-        assert!(resp.status.unwrap_or_default());
+        assert_eq!(resp.status, Some(true));
 
         self.client
             .set_bucket_versioning(&SetBucketVersioningArgs::new(&bucket_name, false).unwrap())
@@ -1281,7 +1281,7 @@ impl ClientTest {
             .send()
             .await
             .unwrap();
-        assert!(!resp.status.unwrap_or_default());
+        assert_eq!(resp.status, Some(false));
 
         self.client
             .remove_bucket(&RemoveBucketArgs::new(&bucket_name).unwrap())