Function retrieve_upload_data

src/upload/uploader.rs:128–187

(
    orchestrator: &Orchestrator,
    api_client: &CodSpeedAPIClient,
    upload_metadata: &UploadMetadata,
)

}

async fn retrieve_upload_data(
    orchestrator: &Orchestrator,
    api_client: &CodSpeedAPIClient,
    upload_metadata: &UploadMetadata,
) -> Result<UploadData> {
    let mut upload_request = REQUEST_CLIENT
        .post(orchestrator.config.upload_url.clone())
        .json(&upload_metadata);
    if let Some(token) = api_client.token() {
        upload_request = upload_request.header("Authorization", token.to_owned());
    }

    let response = upload_request.send().await;

    match response {
        Ok(response) => {
            if !response.status().is_success() {
                let status = response.status();
                let text = response.text().await?;
                let mut error_message = serde_json::from_str::<UploadError>(&text)
                    .map(|body| body.error)
                    .unwrap_or(text);
                if status == StatusCode::UNAUTHORIZED {
                    let additional_message = match upload_metadata.run_environment {
                        RunEnvironment::GithubActions => {
                            "Check that the workflow is correctly authenticated. View more at https://codspeed.io/docs/integrations/ci/github-actions/configuration#authentication"
                        }
                        RunEnvironment::GitlabCi => {
                            "Check that the CI job is correctly authenticated. View more at https://codspeed.io/docs/integrations/ci/gitlab-ci/configuration#authentication"
                        }
                        RunEnvironment::Buildkite => {
                            "Check that CODSPEED_TOKEN is set and has the correct value"
                        }
                        RunEnvironment::Local => {
                            "Run `codspeed auth login` to authenticate the CLI"
                        }
                    };
                    error_message.push_str(&format!("\n\n{additional_message}"));
                }

                debug!(
                    "Check that owner and repository are correct (case-sensitive!): {}/{}",
                    upload_metadata.run_environment_metadata.owner,
                    upload_metadata.run_environment_metadata.repository
                );

                bail!(
                    "Failed to retrieve upload data: {}\n  -> {} {}",
                    status,
                    style("Reason:").bold(),
                    // we have to manually apply the style to the error message, because nesting styles is not supported by the console crate: https://github.com/console-rs/console/issues/106
                    style(error_message).red()
                );
            }

            Ok(response.json().await?)
        }
        Err(err) => Err(err.into()),