aep-agent 0.1.0

Agent-side workflows for the Agent Enrollment Protocol.
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

use aep_core::{AgentStatus, ClaimName, ProblemDetails};
use thiserror::Error;

use crate::PlatformPendingSign;

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub enum InspectErrorCode {
    HttpError,
    InvalidJson,
    InvalidMediaType,
    InvalidRedirect,
    ResponseTooLarge,
    ServiceIdentityMismatch,
    ValidationFailed,
}

#[derive(Debug, Error)]
pub enum AgentError {
    #[error("{0}")]
    InvalidConfiguration(String),
    #[error("{0}")]
    InvalidServiceReference(String),
    #[error("AEP Inspect failed: {message}")]
    Inspect {
        code: InspectErrorCode,
        message: String,
        status: Option<u16>,
    },
    #[error("AEP Service does not advertise {0}")]
    CommandNotAdvertised(String),
    #[error("AEP command failed with HTTP {status}")]
    Command {
        status: u16,
        problem: Option<Box<ProblemDetails>>,
    },
    #[error("AEP Agent cannot satisfy the Service's required Claim Names: {names}")]
    ClaimRequirements {
        missing: Vec<ClaimName>,
        names: String,
    },
    #[error("AEP Agent identity did not become active: {}", status.as_str())]
    EnrollmentState { status: AgentStatus },
    #[error("AEP Status polling timed out")]
    PollingTimeout,
    #[error("AEP Platform signing is pending")]
    PlatformSignPending { pending: Box<PlatformPendingSign> },
    #[error("AEP Platform command failed with HTTP {status}")]
    PlatformCommand {
        status: u16,
        problem: Option<Box<ProblemDetails>>,
    },
    #[error("AEP Service does not advertise a compatible grant type")]
    NoCompatibleGrantType,
    #[error("AEP Service does not advertise a compatible protected-resource authentication method")]
    NoAuthenticationMethod,
    #[error("{0}")]
    Identity(String),
    #[error("{0}")]
    Credential(String),
    #[error("{0}")]
    Store(String),
    #[error("{0}")]
    Transport(String),
    #[error(transparent)]
    Core(#[from] aep_core::CoreError),
    #[error(transparent)]
    Parse(#[from] aep_core::ParseError),
    #[error(transparent)]
    Json(#[from] serde_json::Error),
    #[error(transparent)]
    Url(#[from] url::ParseError),
}

impl AgentError {
    pub(crate) fn claims(missing: Vec<ClaimName>) -> Self {
        let names = missing
            .iter()
            .map(ClaimName::as_str)
            .collect::<Vec<_>>()
            .join(", ");
        Self::ClaimRequirements { missing, names }
    }
}