auv-core 0.0.22

Domain-facing local and remote operation interface for AUV
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

use crate::{discovery, profile};

/// Resolved, non-secret context inherited by an AUV plugin invocation.
///
/// This value is passed inline through `AUV_CONTEXT`. It intentionally stores
/// only stable references; credentials are resolved by the selected client
/// profile and must never be serialized into this process contract.
#[derive(Clone, Debug, Default, PartialEq, Eq, serde::Deserialize, serde::Serialize)]
pub struct AuvContext {
  #[serde(default, skip_serializing_if = "Option::is_none")]
  pub device_id: Option<String>,
  #[serde(default, skip_serializing_if = "Option::is_none")]
  pub device_name: Option<String>,
  #[serde(default, skip_serializing_if = "Option::is_none")]
  pub run_id: Option<String>,
  #[serde(default, skip_serializing_if = "Option::is_none")]
  pub daemon_endpoint: Option<String>,
  #[serde(default, skip_serializing_if = "Option::is_none")]
  pub config_profile: Option<String>,
  #[serde(default, skip_serializing_if = "Option::is_none")]
  pub invocation_id: Option<String>,
}

impl AuvContext {
  pub fn from_env() -> Result<Self, ContextError> {
    let value = std::env::var("AUV_CONTEXT").map_err(ContextError::Environment)?;
    serde_json::from_str(&value).map_err(ContextError::Decode)
  }
}

#[derive(Debug, thiserror::Error)]
pub enum ContextError {
  #[error("AUV_CONTEXT is unavailable or is not valid Unicode: {0}")]
  Environment(std::env::VarError),
  #[error("AUV_CONTEXT is not valid JSON: {0}")]
  Decode(serde_json::Error),
  #[error("could not resolve an AUV daemon endpoint from the context or local discovery")]
  EndpointNotDiscovered,
  #[error("context daemon endpoint {context:?} does not match paired Device profile endpoint {profile:?}")]
  ProfileEndpointMismatch { context: String, profile: String },
  #[error(transparent)]
  Profile(#[from] profile::ProfileError),
  #[error(transparent)]
  Identity(#[from] crate::resource::IdentityError),
  #[error("paired daemon ListDevices failed: {0}")]
  RemoteDeviceList(crate::error::ClientError),
  #[error("paired daemon did not expose configured canonical Device ID {0:?}")]
  CanonicalDeviceMissing(String),
  #[error("Device selection {selector:?} is ambiguous across local and paired profiles; candidate IDs: {candidate_ids}")]
  DeviceSelectionAmbiguous {
    selector: String,
    candidate_ids: String,
  },
  #[error("Device selection does not match the local daemon or a paired Device profile")]
  DeviceNotConfigured,
  #[error("Run {0:?} was not found on the local daemon or any configured paired Device")]
  RunNotFound(String),
  #[error("Run {run_id:?} exists on more than one daemon: {locations}")]
  RunAmbiguous { run_id: String, locations: String },
  #[error("failed to look up Run on {location}: {error}")]
  RunLookup {
    location: String,
    error: crate::error::ClientError,
  },
  #[error(transparent)]
  Discovery(#[from] discovery::DiscoveryError),
  #[error("failed to connect to AUV API server: {0}")]
  Connect(String),
  #[error("failed to connect to paired AUV API server: {0}")]
  PairedConnect(String),
}

#[cfg(test)]
#[path = "context_test.rs"]
mod tests;