Function upsert_function

crates/cargo-lambda-deploy/src/functions.rs:116–175

(
    config: &Deploy,
    name: &str,
    client: &LambdaClient,
    sdk_config: &SdkConfig,
    binary_archive: &BinaryArchive,
    progress: &Progress,
)

#[allow(clippy::too_many_arguments)]
async fn upsert_function(
    config: &Deploy,
    name: &str,
    client: &LambdaClient,
    sdk_config: &SdkConfig,
    binary_archive: &BinaryArchive,
    progress: &Progress,
) -> Result<(String, String)> {
    let current_function = client.get_function().function_name(name).send().await;

    let action = match current_function {
        Ok(fun) => FunctionAction::Update(Box::new(fun)),
        Err(no_fun) if function_doesnt_exist_error(&no_fun) => FunctionAction::Create,
        Err(no_fun) => {
            return Err(no_fun)
                .into_diagnostic()
                .wrap_err("failed to fetch lambda function");
        }
    };

    let s3_client = S3Client::new(sdk_config);

    let (arn, version) = match action {
        FunctionAction::Create => {
            let function_role = match &config.function_config.role {
                None => roles::create(config, sdk_config, progress).await?,
                Some(role) => FunctionRole::from_existing(role.clone()),
            };

            create_function(
                config,
                name,
                client,
                &s3_client,
                binary_archive,
                progress,
                function_role,
            )
            .await?
        }
        FunctionAction::Update(fun) => {
            progress.set_message("deploying function");

            let conf = fun
                .configuration
                .ok_or_else(|| miette::miette!("missing function configuration"))?;

            let function_arn = update_function_config(config, name, client, progress, conf).await?;

            tag_function(client, config.lambda_tags(), function_arn).await?;

            update_function_code(config, name, client, &s3_client, binary_archive, progress).await?
        }
    };

    Ok((
        arn.expect("missing function ARN"),
        version.expect("missing function version"),