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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

use anyhow::Error;
use async_trait::async_trait;
use aws_sdk_s3::types::Tag;

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

use super::RunCommand;

#[async_trait]
impl RunCommand for SetTags {
    async fn execute(
        &self,
        client: &dyn CommandS3Client,
        path: &S3Path,
        list: &[StreamObject],
    ) -> Result<(), Error> {
        let tags = self
            .tags
            .iter()
            .map(|x| {
                Tag::builder()
                    .key(x.key.clone())
                    .value(x.value.clone())
                    .build()
            })
            .collect::<Result<Vec<_>, _>>()?;

        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_tagging(
                    &path.bucket,
                    key,
                    stream_obj.version_id.as_deref(),
                    tags.clone(),
                )
                .await?;

            println!(
                "tags are set for: s3://{}/{}",
                &path.bucket,
                stream_obj.display_key()
            );
        }
        Ok(())
    }
}

#[async_trait]
impl RunCommand for ListTags {
    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 tags: String = if let Some(ref cached_tags) = stream_obj.tags {
                cached_tags
                    .iter()
                    .map(|x| format!("{}:{}", x.key(), x.value()))
                    .collect::<Vec<String>>()
                    .join(",")
            } else {
                let key = stream_obj
                    .object
                    .key
                    .as_deref()
                    .ok_or(crate::error::FunctionError::ObjectFieldError)?;

                client
                    .get_object_tagging(&path.bucket, key, stream_obj.version_id.as_deref())
                    .await?
                    .into_iter()
                    .map(|x| format!("{}:{}", x.key(), x.value()))
                    .collect::<Vec<String>>()
                    .join(",")
            };

            println!(
                "s3://{}/{} {}",
                &path.bucket,
                stream_obj.display_key(),
                tags,
            );
        }
        Ok(())
    }
}