s3util-rs 1.4.0

use anyhow::{Context, Result};
use tracing::info;

use s3util_rs::config::ClientConfig;
use s3util_rs::config::args::put_bucket_cors::PutBucketCorsArgs;
use s3util_rs::input::json::CorsConfigurationJson;
use s3util_rs::storage::s3::api;

/// Runtime entry for
/// `s3util put-bucket-cors s3://<BUCKET> <CONFIG_FILE|->`.
///
/// Reads the configuration JSON from a file path or stdin (`-`), parses it
/// into a `CorsConfigurationJson` mirror struct (AWS-CLI input shape),
/// converts to the SDK type, and issues `PutBucketCors`. Exits silently on
/// success.
pub async fn run_put_bucket_cors(
    args: PutBucketCorsArgs,
    client_config: ClientConfig,
) -> Result<()> {
    let bucket = args
        .bucket_name()
        .map_err(|e| anyhow::anyhow!("{}", e.trim_end()))?;

    let config_arg = args
        .cors_configuration
        .as_deref()
        .ok_or_else(|| anyhow::anyhow!("cors-configuration source required"))?;

    let body = if config_arg == "-" {
        let mut buf = String::new();
        std::io::Read::read_to_string(&mut std::io::stdin(), &mut buf)?;
        buf
    } else {
        std::fs::read_to_string(config_arg)
            .with_context(|| format!("reading cors configuration from {config_arg}"))?
    };

    let parsed: CorsConfigurationJson =
        serde_json::from_str(&body).with_context(|| format!("parsing JSON from {config_arg}"))?;
    let cfg = parsed.into_sdk()?;

    let client = client_config.create_client().await;
    if args.dry_run {
        info!(bucket = %bucket, "[dry-run] would put bucket CORS configuration.");
        return Ok(());
    }
    api::put_bucket_cors(&client, &bucket, cfg).await?;
    info!(bucket = %bucket, "Bucket CORS configuration set.");
    Ok(())
}