Method run

atomic-cli/src/commands/agent/owner.rs:610–654

(&self)

impl Command for DatabaseOwner {
    fn run(&self) -> CliResult<()> {
        match &self.command {
            OwnerCommand::Start(args) => {
                let response = start_or_reconnect(&args.repository)?;
                print_health(response, args.json)
            }
            OwnerCommand::Ping(args) => {
                let response = request(&args.repository, OwnerRequest::Ping)?;
                print_health(response, args.json)
            }
            OwnerCommand::Reserve(args) => {
                start_or_reconnect(&args.repository)?;
                let response = request(
                    &args.repository,
                    OwnerRequest::ReserveProvenanceTurn {
                        session_id: args.session_id.clone(),
                        turn_number: args.turn,
                        now: args.now,
                    },
                )?;
                print_reservation(response, args.json)
            }
            OwnerCommand::Shutdown(args) => {
                let response = request(&args.repository, OwnerRequest::Shutdown)?;
                let pid = match response {
                    OwnerResponse::ShuttingDown { pid } => pid,
                    other => return Err(unexpected_response("shutdown", other).into()),
                };
                if args.json {
                    println!(
                        "{}",
                        serde_json::json!({
                            "protocol_version": PROTOCOL_VERSION,
                            "pid": pid,
                            "status": "shutting-down"
                        })
                    );
                } else {
                    println!("database owner {pid} is shutting down");
                }
                Ok(())
            }
            OwnerCommand::Serve(args) => serve(&args.repository),
        }
    }
}

fn print_health(response: OwnerResponse, json: bool) -> CliResult<()> {