Function request

atomic-cli/src/commands/agent/owner.rs:864–893

Send one request to an already-running owner.

(repository: &Path, request_body: OwnerRequest)

/// Send one request to an already-running owner.
fn request(repository: &Path, request_body: OwnerRequest) -> anyhow::Result<OwnerResponse> {
    let dot_dir = Repository::canonical_dot_dir(repository)?;
    let endpoint = endpoint_name(&dot_dir);
    let frame = RequestFrame {
        version: PROTOCOL_VERSION,
        request_id: Uuid::new_v4().to_string(),
        request: request_body,
    };
    let response = runtime()?.block_on(exchange(&endpoint, &frame))?;
    if response.version != PROTOCOL_VERSION {
        return Err(anyhow!(
            "database owner protocol mismatch: client {}, server {}",
            PROTOCOL_VERSION,
            response.version
        ));
    }
    if response.request_id != frame.request_id {
        return Err(anyhow!(
            "database owner response request id mismatch: sent {}, received {}",
            frame.request_id,
            response.request_id
        ));
    }
    match response.response {
        OwnerResponse::Error { code, message } => {
            Err(anyhow!("database owner request failed [{code}]: {message}"))
        }
        response => Ok(response),
    }
}

fn serve(repository: &Path) -> CliResult<()> {
    let dot_dir = Repository::canonical_dot_dir(repository)?;