ryra_core/
from_protocol.rs

1//! Convert the wire protocol's request payloads ([`ryra_protocol`]) into the
2//! engine's `ops` request types. The protocol crate is deliberately
3//! engine-free, so the mapping lives here, where both types are in scope. Every
4//! field is mirrored by name, so a shape change on either side surfaces as a
5//! compile error.
6
7use ryra_protocol as p;
8
9use crate::Lifecycle;
10use crate::RemoveMode;
11use crate::configure::{ExposureChange, Overrides};
12use crate::ops::{
13    AddRequest, AuthRequested, ConfigureRequest, ExposureRequest, LifecycleRequest, RemoveRequest,
14    UpgradeRequest,
15};
16use crate::registry::service_def::AuthKind;
17
18impl From<p::ExposureRequest> for ExposureRequest {
19    fn from(e: p::ExposureRequest) -> Self {
20        match e {
21            p::ExposureRequest::Loopback => ExposureRequest::Loopback,
22            p::ExposureRequest::Url(u) => ExposureRequest::Url(u),
23            p::ExposureRequest::Tailscale(u) => ExposureRequest::Tailscale(u),
24        }
25    }
26}
27
28impl From<p::AuthKind> for AuthKind {
29    fn from(k: p::AuthKind) -> Self {
30        match k {
31            p::AuthKind::Oidc => AuthKind::Oidc,
32        }
33    }
34}
35
36impl From<p::AuthRequested> for AuthRequested {
37    fn from(a: p::AuthRequested) -> Self {
38        match a {
39            p::AuthRequested::No => AuthRequested::No,
40            p::AuthRequested::Yes => AuthRequested::Yes,
41            p::AuthRequested::Kind(k) => AuthRequested::Kind(k.into()),
42        }
43    }
44}
45
46impl From<p::AddRequest> for AddRequest {
47    fn from(r: p::AddRequest) -> Self {
48        AddRequest {
49            service: r.service,
50            exposure: r.exposure.into(),
51            auth: r.auth.into(),
52            smtp: r.smtp,
53            backup: r.backup,
54            env: r.env,
55            enable_groups: r.enable_groups,
56            choose: r.choose,
57        }
58    }
59}
60
61impl From<p::RemoveMode> for RemoveMode {
62    fn from(m: p::RemoveMode) -> Self {
63        match m {
64            p::RemoveMode::Preserve => RemoveMode::Preserve,
65            p::RemoveMode::Purge => RemoveMode::Purge,
66        }
67    }
68}
69
70impl From<p::RemoveRequest> for RemoveRequest {
71    fn from(r: p::RemoveRequest) -> Self {
72        RemoveRequest {
73            service: r.service,
74            mode: r.mode.into(),
75        }
76    }
77}
78
79impl From<p::Lifecycle> for Lifecycle {
80    fn from(l: p::Lifecycle) -> Self {
81        match l {
82            p::Lifecycle::Start => Lifecycle::Start,
83            p::Lifecycle::Stop => Lifecycle::Stop,
84        }
85    }
86}
87
88impl From<p::LifecycleRequest> for LifecycleRequest {
89    fn from(r: p::LifecycleRequest) -> Self {
90        LifecycleRequest {
91            service: r.service,
92            action: r.action.into(),
93        }
94    }
95}
96
97impl From<p::UpgradeRequest> for UpgradeRequest {
98    fn from(r: p::UpgradeRequest) -> Self {
99        UpgradeRequest {
100            service: r.service,
101            force: r.force,
102        }
103    }
104}
105
106impl From<p::ExposureChange> for ExposureChange {
107    fn from(e: p::ExposureChange) -> Self {
108        match e {
109            p::ExposureChange::Url(u) => ExposureChange::Url(u),
110            p::ExposureChange::Tailscale(u) => ExposureChange::Tailscale(u),
111            p::ExposureChange::Loopback => ExposureChange::Loopback,
112        }
113    }
114}
115
116impl From<p::Overrides> for Overrides {
117    fn from(o: p::Overrides) -> Self {
118        Overrides {
119            exposure: o.exposure.map(Into::into),
120            smtp: o.smtp,
121            backup: o.backup,
122            auth: o.auth,
123            enable_groups: o.enable_groups,
124            disable_groups: o.disable_groups,
125            choose: o.choose,
126            env_overrides: o.env_overrides,
127            reassert_auth: o.reassert_auth,
128        }
129    }
130}
131
132impl From<p::ConfigureRequest> for ConfigureRequest {
133    fn from(r: p::ConfigureRequest) -> Self {
134        ConfigureRequest {
135            service: r.service,
136            changes: r.changes.into(),
137        }
138    }
139}
ryra_core/from_protocol.rs

ryra_core/
from_protocol.rs
