refactored get_bucket_encryption

Author: HJLebbink

.github/workflows/rust.yml

@@ -20,12 +20,11 @@ jobs:
     - name: Build
       run: |
         cargo fmt --all -- --check
-        cargo clippy --all-targets --all-features -- -A clippy::result_large_err -A clippy::type_complexity -A clippy::too_many_arguments
+        cargo clippy --all-targets --all-features
         cargo build --bins --examples --tests --benches --verbose
 
     - name: Run tests
       run: |
-        truncate --size=6M asiaphotos-2015.zip
         ./tests/start-server.sh
         export SERVER_ENDPOINT=localhost:9000
         export ACCESS_KEY=minioadmin

examples/common.rs

@@ -0,0 +1,48 @@
+use minio::s3::args::{BucketExistsArgs, MakeBucketArgs};
+use minio::s3::creds::StaticProvider;
+use minio::s3::http::BaseUrl;
+use minio::s3::{Client, ClientBuilder};
+
+#[allow(dead_code)]
+pub fn create_client_on_play() -> Result<Client, Box<dyn std::error::Error + Send + Sync>> {
+    let base_url = "https://play.min.io".parse::<BaseUrl>()?;
+    log::info!("Trying to connect to MinIO at: `{:?}`", base_url);
+
+    let static_provider = StaticProvider::new(
+        "Q3AM3UQ867SPQQA43P2F",
+        "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG",
+        None,
+    );
+
+    let client = ClientBuilder::new(base_url.clone())
+        .provider(Some(Box::new(static_provider)))
+        .build()?;
+    Ok(client)
+}
+
+pub async fn create_bucket_if_not_exists(
+    bucket_name: &str,
+    client: &Client,
+) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
+    // Check 'bucket_name' bucket exist or not.
+    let exists: bool = client
+        .bucket_exists(&BucketExistsArgs::new(bucket_name).unwrap())
+        .await
+        .unwrap();
+
+    // Make 'bucket_name' bucket if not exist.
+    if !exists {
+        client
+            .make_bucket(&MakeBucketArgs::new(bucket_name).unwrap())
+            .await
+            .unwrap();
+    };
+    Ok(())
+}
+
+#[allow(dead_code)]
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
+    // dummy code just to prevent an error because files in examples need to have a main
+    Ok(())
+}

examples/file_downloader.rs

@@ -1,27 +1,30 @@
-use minio::s3::args::{BucketExistsArgs, MakeBucketArgs};
+// MinIO Rust Library for Amazon S3 Compatible Cloud Storage
+// Copyright 2025 MinIO, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+mod common;
+
+use crate::common::{create_bucket_if_not_exists, create_client_on_play};
 use minio::s3::builders::ObjectContent;
-use minio::s3::client::ClientBuilder;
-use minio::s3::creds::StaticProvider;
-use minio::s3::http::BaseUrl;
 use minio::s3::types::S3Api;
+use minio::s3::Client;
 use std::path::Path;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
     env_logger::init(); // Note: set environment variable RUST_LOG="INFO" to log info and higher
-
-    let base_url = "https://play.min.io".parse::<BaseUrl>()?;
-    log::info!("Trying to connect to MinIO at: `{:?}`", base_url);
-
-    let static_provider = StaticProvider::new(
-        "Q3AM3UQ867SPQQA43P2F",
-        "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG",
-        None,
-    );
-
-    let client = ClientBuilder::new(base_url.clone())
-        .provider(Some(Box::new(static_provider)))
-        .build()?;
+    let client: Client = create_client_on_play()?;
 
     let bucket_name: &str = "file-download-rust-bucket";
     let object_name: &str = "cat.png";
@@ -30,19 +33,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
     let filename: &Path = Path::new("./examples/cat.png");
     let download_path: &str = &format!("/tmp/downloads/{object_name}");
 
-    // Check 'bucket_name' bucket exist or not.
-    let exists: bool = client
-        .bucket_exists(&BucketExistsArgs::new(bucket_name).unwrap())
-        .await
-        .unwrap();
-
-    // Make 'bucket_name' bucket if not exist.
-    if !exists {
-        client
-            .make_bucket(&MakeBucketArgs::new(bucket_name).unwrap())
-            .await
-            .unwrap();
-    }
+    create_bucket_if_not_exists(bucket_name, &client).await?;
 
     if filename.exists() {
         log::info!("File '{}' exists.", &filename.to_str().unwrap());
@@ -64,10 +55,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
 
     let get_object = client.get_object(bucket_name, object_name).send().await?;
 
-    get_object
-        .content
-        .to_file(&Path::new(download_path))
-        .await?;
+    get_object.content.to_file(Path::new(download_path)).await?;
 
     log::info!("Object '{object_name}' is successfully downloaded to file '{download_path}'.");
 

examples/file_uploader.rs

@@ -12,46 +12,20 @@
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
+mod common;
 
-use minio::s3::args::{BucketExistsArgs, MakeBucketArgs};
+use crate::common::{create_bucket_if_not_exists, create_client_on_play};
 use minio::s3::builders::ObjectContent;
-use minio::s3::client::ClientBuilder;
-use minio::s3::creds::StaticProvider;
-use minio::s3::http::BaseUrl;
+use minio::s3::Client;
 use std::path::Path;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
     env_logger::init(); // Note: set environment variable RUST_LOG="INFO" to log info and higher
-
-    let base_url = "https://play.min.io".parse::<BaseUrl>()?;
-    log::info!("Trying to connect to MinIO at: `{:?}`", base_url);
-
-    let static_provider = StaticProvider::new(
-        "Q3AM3UQ867SPQQA43P2F",
-        "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG",
-        None,
-    );
-
-    let client = ClientBuilder::new(base_url.clone())
-        .provider(Some(Box::new(static_provider)))
-        .build()?;
+    let client: Client = create_client_on_play()?;
 
     let bucket_name: &str = "file-upload-rust-bucket";
-
-    // Check 'bucket_name' bucket exist or not.
-    let exists: bool = client
-        .bucket_exists(&BucketExistsArgs::new(bucket_name).unwrap())
-        .await
-        .unwrap();
-
-    // Make 'bucket_name' bucket if not exist.
-    if !exists {
-        client
-            .make_bucket(&MakeBucketArgs::new(bucket_name).unwrap())
-            .await
-            .unwrap();
-    }
+    create_bucket_if_not_exists(bucket_name, &client).await?;
 
     // File we are going to upload to the bucket
     let filename: &Path = Path::new("./examples/cat.png");

examples/get_bucket_encryption.rs

@@ -0,0 +1,35 @@
+// MinIO Rust Library for Amazon S3 Compatible Cloud Storage
+// Copyright 2025 MinIO, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+use crate::common::{create_bucket_if_not_exists, create_client_on_play};
+use minio::s3::builders::GetBucketEncryption;
+use minio::s3::Client;
+
+mod common;
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
+    env_logger::init(); // Note: set environment variable RUST_LOG="INFO" to log info and higher
+    let client: Client = create_client_on_play()?;
+
+    let bucket_name: &str = "encryption-rust-bucket";
+    create_bucket_if_not_exists(bucket_name, &client).await?;
+
+    let be: GetBucketEncryption = client.get_bucket_encryption(bucket_name)?;
+
+    log::info!("{:?}", be);
+
+    Ok(())
+}

examples/get_bucket_versioning.rs

@@ -0,0 +1,35 @@
+// MinIO Rust Library for Amazon S3 Compatible Cloud Storage
+// Copyright 2025 MinIO, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+mod common;
+
+use crate::common::{create_bucket_if_not_exists, create_client_on_play};
+use minio::s3::builders::GetBucketVersioning;
+use minio::s3::Client;
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
+    env_logger::init(); // Note: set environment variable RUST_LOG="INFO" to log info and higher
+    let client: Client = create_client_on_play()?;
+
+    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)?;
+
+    log::info!("{:?}", bv);
+
+    Ok(())
+}

examples/object_prompt.rs

@@ -13,7 +13,9 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use minio::s3::args::{BucketExistsArgs, MakeBucketArgs};
+mod common;
+
+use crate::common::create_bucket_if_not_exists;
 use minio::s3::builders::{ObjectContent, ObjectPrompt};
 use minio::s3::client::ClientBuilder;
 use minio::s3::creds::StaticProvider;
@@ -25,35 +27,19 @@ use std::path::Path;
 async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
     env_logger::init(); // Note: set environment variable RUST_LOG="INFO" to log info and higher
 
-    let base_url = "https://play.min.io".parse::<BaseUrl>()?;
+    //Note: object prompt is not supported on play.min.io, you will need point to AIStor
+    let base_url = "http://localhost:9000".parse::<BaseUrl>()?;
     log::info!("Trying to connect to MinIO at: `{:?}`", base_url);
 
-    let static_provider = StaticProvider::new(
-        "Q3AM3UQ867SPQQA43P2F",
-        "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG",
-        None,
-    );
+    let static_provider = StaticProvider::new("admin", "admin", None);
 
     let client = ClientBuilder::new(base_url.clone())
         .provider(Some(Box::new(static_provider)))
         .ignore_cert_check(Some(true))
         .build()?;
 
     let bucket_name: &str = "object-prompt-rust-bucket";
-
-    // Check 'bucket_name' bucket exist or not.
-    let exists: bool = client
-        .bucket_exists(&BucketExistsArgs::new(bucket_name).unwrap())
-        .await
-        .unwrap();
-
-    // Make 'bucket_name' bucket if not exist.
-    if !exists {
-        client
-            .make_bucket(&MakeBucketArgs::new(bucket_name).unwrap())
-            .await
-            .unwrap();
-    }
+    create_bucket_if_not_exists(bucket_name, &client).await?;
 
     // File we are going to upload to the bucket
     let filename: &Path = Path::new("./examples/cat.png");

src/s3/args.rs

@@ -1318,9 +1318,6 @@ impl<'a> ComposeObjectArgs<'a> {
 /// Argument for [delete_bucket_encryption()](crate::s3::client::Client::delete_bucket_encryption) API
 pub type DeleteBucketEncryptionArgs<'a> = BucketArgs<'a>;
 
-/// Argument for [get_bucket_encryption()](crate::s3::client::Client::get_bucket_encryption) API
-pub type GetBucketEncryptionArgs<'a> = BucketArgs<'a>;
-
 #[derive(Clone, Debug)]
 /// Argument for [set_bucket_encryption()](crate::s3::client::Client::set_bucket_encryption) API
 pub struct SetBucketEncryptionArgs<'a> {

src/s3/builders.rs

@@ -15,17 +15,23 @@
 
 //! Argument builders for [minio::s3::client::Client](crate::s3::client::Client) APIs
 
-mod buckets;
+mod bucket_common;
+mod get_bucket_encryption;
+mod get_bucket_versioning;
 mod get_object;
+mod list_buckets;
 mod list_objects;
 mod listen_bucket_notification;
 mod object_content;
 mod object_prompt;
 mod put_object;
 mod remove_objects;
 
-pub use buckets::*;
+pub use bucket_common::*;
+pub use get_bucket_encryption::*;
+pub use get_bucket_versioning::*;
 pub use get_object::*;
+pub use list_buckets::*;
 pub use list_objects::*;
 pub use listen_bucket_notification::*;
 pub use object_content::*;