Function request_with_reconnect

atomic-cli/src/commands/agent/owner.rs:835–851

(
    repository: &Path,
    request_body: OwnerRequest,
)

}

fn request_with_reconnect(
    repository: &Path,
    request_body: OwnerRequest,
) -> anyhow::Result<OwnerResponse> {
    start_or_reconnect(repository)?;
    let mut last_error = None;
    for _ in 0..3 {
        match request(repository, request_body.clone()) {
            Ok(response) => return Ok(response),
            Err(error) => {
                last_error = Some(error);
                start_or_reconnect(repository)?;
            }
        }
    }
    Err(last_error.unwrap_or_else(|| anyhow!("database owner request retry exhausted")))
}

fn run_outside_async_runtime<T, F>(operation: F) -> anyhow::Result<T>
where