Method execute

tools/dfx-orbit/src/args.rs:103–171

A command line tool for interacting with Orbit on the Internet Computer.

(self)

impl DfxOrbitArgs {
    /// A command line tool for interacting with Orbit on the Internet Computer.
    pub async fn execute(self) -> anyhow::Result<()> {
        let logger = init_logger(self.verbose, self.quiet)?;
        trace!(logger, "Calling tool with arguments:\n{:#?}", self);

        let orbit_agent = OrbitExtensionAgent::new()?;

        // We don't need to instanciate a StationAgent to execute this command directly on the orbit agent
        if let DfxOrbitSubcommands::Station(station_args) = self.command {
            station_args.execute(orbit_agent)?;
            return Ok(());
        };

        let config = if let Some(station_name) = self.station {
            orbit_agent.station(&station_name)?
        } else if let Some(station_file) = self.station_file {
            orbit_agent.station_from_path(&station_file)?
        } else {
            orbit_agent
                .default_station()?
                .ok_or_else(|| anyhow::format_err!("No default station specified"))?
        };

        let dfx_orbit = DfxOrbit::new(orbit_agent, config, self.identity, logger).await?;

        match self.command {
            // Nicer display, json optional
            DfxOrbitSubcommands::Me(args) => {
                let ans = dfx_orbit.station.me().await?;
                if args.json {
                    println!("{}", serde_json::to_string_pretty(&ans)?);
                } else {
                    println!("{}", dfx_orbit.display_me(ans)?);
                }
                Ok(())
            }
            DfxOrbitSubcommands::Request(request_args) => {
                let request = dfx_orbit
                    .station
                    .request(request_args.into_request(&dfx_orbit).await?)
                    .await?;
                dfx_orbit.print_create_request_info(&request);

                Ok(())
            }
            DfxOrbitSubcommands::Verify(verify_args) => {
                let request = dfx_orbit
                    .station
                    .review_id(GetRequestInput {
                        request_id: verify_args.request_id.clone(),
                        with_full_info: Some(false),
                    })
                    .await?;

                println!(
                    "{}",
                    dfx_orbit.display_get_request_response(request.clone())?
                );