noxy-sdk 2.0.0

Decision Layer SDK for AI agents. Encrypted actionable decisions over gRPC.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

//! Options and helpers for human-in-the-loop decision polling (mirrors Node `decision-outcome`).

use crate::types::NoxyHumanDecisionOutcome;

#[derive(Debug, Clone, Default)]
pub struct SendDecisionAndWaitOptions {
    pub initial_poll_interval_ms: Option<u64>,
    pub max_poll_interval_ms: Option<u64>,
    pub max_wait_ms: Option<u64>,
    pub backoff_multiplier: Option<f64>,
}

#[derive(Debug, Clone)]
pub struct WaitForDecisionOutcomeOptions {
    pub decision_id: String,
    pub identity_id: String,
    pub initial_poll_interval_ms: Option<u64>,
    pub max_poll_interval_ms: Option<u64>,
    pub max_wait_ms: Option<u64>,
    pub backoff_multiplier: Option<f64>,
}

#[derive(Debug)]
pub struct WaitForDecisionOutcomeTimeoutError;

impl std::fmt::Display for WaitForDecisionOutcomeTimeoutError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.write_str("wait_for_decision_outcome exceeded max_wait_ms")
    }
}

impl std::error::Error for WaitForDecisionOutcomeTimeoutError {}

#[derive(Debug)]
pub struct SendDecisionAndWaitNoDecisionIdError;

impl std::fmt::Display for SendDecisionAndWaitNoDecisionIdError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.write_str("send_decision returned no decision_id to poll; check delivery statuses")
    }
}

impl std::error::Error for SendDecisionAndWaitNoDecisionIdError {}

pub fn is_terminal_human_outcome(outcome: NoxyHumanDecisionOutcome) -> bool {
    matches!(
        outcome,
        NoxyHumanDecisionOutcome::Approved
            | NoxyHumanDecisionOutcome::Rejected
            | NoxyHumanDecisionOutcome::Expired
    )
}