s3find 0.16.1

A command line utility to walk an Amazon S3 hierarchy. s3find is an analog of find for Amazon S3.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

use anyhow::Error;
use async_trait::async_trait;

use crate::adapters::aws::CommandS3Client;
use crate::arg::{S3Path, SetPublic};
use crate::command::StreamObject;

use super::RunCommand;

#[inline]
pub(crate) fn generate_s3_url(region: &str, bucket: &str, key: &str) -> String {
    let encoded_key = key
        .split('/')
        .map(|segment| urlencoding::encode(segment).into_owned())
        .collect::<Vec<_>>()
        .join("/");

    match region {
        "us-east-1" => format!("https://{}.s3.amazonaws.com/{}", bucket, encoded_key),
        _ => format!(
            "https://{}.s3-{}.amazonaws.com/{}",
            bucket, region, encoded_key
        ),
    }
}

#[async_trait]
impl RunCommand for SetPublic {
    async fn execute(
        &self,
        client: &dyn CommandS3Client,
        path: &S3Path,
        list: &[StreamObject],
    ) -> Result<(), Error> {
        for stream_obj in list {
            if stream_obj.is_delete_marker {
                continue;
            }

            let key = stream_obj
                .object
                .key
                .as_deref()
                .ok_or(crate::error::FunctionError::ObjectFieldError)?;

            client
                .put_object_acl_public_read(&path.bucket, key, stream_obj.version_id.as_deref())
                .await?;

            let region = client.region().unwrap_or_else(|| "us-east-1".to_string());
            let url = generate_s3_url(&region, &path.bucket, key);
            println!("{} {}", stream_obj.display_key(), url);
        }
        Ok(())
    }
}