s7cmd 1.3.1

Reliable, flexible, and fast command-line tool for Amazon S3
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

// Vendored from s3util-rs@1.5.2 src/bin/s3util/cli/rename.rs
use anyhow::Result;
use tracing::info;

use s3util_rs::config::ClientConfig;
use s3util_rs::config::args::rename::RenameArgs;
use s3util_rs::storage::s3::api::{self, HeadError, RenameObjectConditions};

use super::ExitStatus;

pub async fn run_rename(args: RenameArgs, client_config: ClientConfig) -> Result<ExitStatus> {
    let (src_bucket, src_key) = args
        .source_bucket_key()
        .map_err(|e| anyhow::anyhow!("{}", e.trim_end()))?;
    let (_, dst_key) = args
        .target_bucket_key()
        .map_err(|e| anyhow::anyhow!("{}", e.trim_end()))?;

    let client = client_config.create_client().await;

    if args.dry_run {
        info!(
            source = %format!("s3://{src_bucket}/{src_key}"),
            target = %format!("s3://{src_bucket}/{dst_key}"),
            "[dry-run] would rename object."
        );
        return Ok(ExitStatus::Success);
    }

    match api::rename_object(
        &client,
        &src_bucket,
        &src_key,
        &dst_key,
        RenameObjectConditions {
            source_if_match: args.source_if_match.as_deref(),
            source_if_none_match: args.source_if_none_match.as_deref(),
            destination_if_match: args.target_if_match.as_deref(),
            destination_if_none_match: args.target_if_none_match.as_deref(),
        },
    )
    .await
    {
        Ok(_) => {
            info!(
                source = %format!("s3://{src_bucket}/{src_key}"),
                target = %format!("s3://{src_bucket}/{dst_key}"),
                "Object renamed."
            );
            Ok(ExitStatus::Success)
        }
        Err(HeadError::BucketNotFound) => {
            Err(anyhow::anyhow!("bucket s3://{src_bucket} not found"))
        }
        Err(HeadError::NotFound) => Err(anyhow::anyhow!(
            "object s3://{src_bucket}/{src_key} not found"
        )),
        Err(HeadError::Other(e)) => Err(e),
    }
}