Struct NoxyAgentClient 

pub struct NoxyAgentClient { /* private fields */ }

Implementations

impl NoxyAgentClient

pub async fn send_decision<T>( &self, identity_address: NoxyIdentityAddress, actionable_decision: &T, ) -> Result<Vec<NoxyDeliveryOutcome>, Box<dyn Error + Send + Sync>>

where T: Serialize,

Route an actionable decision to all devices registered for the identity. Uses one client-generated decision_id (UUID) for the whole batch so every device shares the same logical decision.

pub async fn get_decision_outcome( &self, decision_id: &str, identity_id: &str, ) -> Result<NoxyGetDecisionOutcomeResponse, Status>

Single poll for human-in-the-loop resolution.

pub async fn wait_for_decision_outcome( &self, options: WaitForDecisionOutcomeOptions, ) -> Result<NoxyGetDecisionOutcomeResponse, Box<dyn Error + Send + Sync>>

Poll GetDecisionOutcome with exponential backoff until terminal outcome or pending == false.

pub async fn send_decision_and_wait_for_outcome<T>( &self, identity_address: NoxyIdentityAddress, actionable_decision: &T, options: Option<SendDecisionAndWaitOptions>, ) -> Result<NoxyGetDecisionOutcomeResponse, Box<dyn Error + Send + Sync>>

where T: Serialize,

[send_decision] then [wait_for_decision_outcome] using the first delivery with a non-empty decision_id.

Examples found in repository

examples/basic.rs (line 38)

async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let auth_token = std::env::var("NOXY_APP_TOKEN").expect("NOXY_APP_TOKEN must be set");
    let target_address = std::env::var("NOXY_TARGET_ADDRESS").expect("NOXY_TARGET_ADDRESS must be set");

    let config = NoxyConfig {
        endpoint: NOXY_ENDPOINT.to_string(),
        auth_token,
        decision_ttl_seconds: 3600,
    };

    let client = init_noxy_agent_client(config).await?;

    let quota = client.get_quota().await?;
    println!(
        "Quota: {} / {} remaining (status: {:?})",
        quota.quota_remaining, quota.quota_total, quota.status
    );

    let actionable = serde_json::json!({
        "kind": "propose_tool_call",
        "tool": "transfer_funds",
        "args": { "to": "0x000000000000000000000000000000000000dEaD", "amountWei": "1" },
        "title": "[RUST] Transfer 1 wei to the burn address",
        "summary": "[RUST] The agent is requesting approval to send 1 wei to the burn address.",
    });

    println!("Routing decision to {}...", target_address);
    let resolution = client
        .send_decision_and_wait_for_outcome(target_address, &actionable, None)
        .await?;

    println!(
        "Outcome: {:?}, pending: {}",
        resolution.outcome, resolution.pending
    );
    if resolution.outcome == NoxyHumanDecisionOutcome::Approved {
        println!("User approved — continue agent loop.");
    }

    Ok(())
}

pub async fn get_quota(&self) -> Result<NoxyGetQuotaResponse, Status>

Examples found in repository

examples/basic.rs (line 22)

async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let auth_token = std::env::var("NOXY_APP_TOKEN").expect("NOXY_APP_TOKEN must be set");
    let target_address = std::env::var("NOXY_TARGET_ADDRESS").expect("NOXY_TARGET_ADDRESS must be set");

    let config = NoxyConfig {
        endpoint: NOXY_ENDPOINT.to_string(),
        auth_token,
        decision_ttl_seconds: 3600,
    };

    let client = init_noxy_agent_client(config).await?;

    let quota = client.get_quota().await?;
    println!(
        "Quota: {} / {} remaining (status: {:?})",
        quota.quota_remaining, quota.quota_total, quota.status
    );

    let actionable = serde_json::json!({
        "kind": "propose_tool_call",
        "tool": "transfer_funds",
        "args": { "to": "0x000000000000000000000000000000000000dEaD", "amountWei": "1" },
        "title": "[RUST] Transfer 1 wei to the burn address",
        "summary": "[RUST] The agent is requesting approval to send 1 wei to the burn address.",
    });

    println!("Routing decision to {}...", target_address);
    let resolution = client
        .send_decision_and_wait_for_outcome(target_address, &actionable, None)
        .await?;

    println!(
        "Outcome: {:?}, pending: {}",
        resolution.outcome, resolution.pending
    );
    if resolution.outcome == NoxyHumanDecisionOutcome::Approved {
        println!("User approved — continue agent loop.");
    }

    Ok(())
}