Derive vm_name frm TLS name at registration

Signed-off-by: Alexander V. Nikolaev <[email protected]>

src/admin/entry.rs

@@ -92,9 +92,11 @@ impl RegistryEntry {
     }
 }
 
-impl TryFrom<pb::RegistryRequest> for RegistryEntry {
-    type Error = anyhow::Error;
-    fn try_from(req: pb::RegistryRequest) -> Result<Self, Self::Error> {
+impl RegistryEntry {
+    pub fn try_from_request(
+        req: pb::RegistryRequest,
+        vm_name: String,
+    ) -> Result<Self, anyhow::Error> {
         let ty = UnitType::try_from(req.r#type)?;
         let status = req
             .state
@@ -114,7 +116,7 @@ impl TryFrom<pb::RegistryRequest> for RegistryEntry {
             r#type: ty,
             placement: Placement::Endpoint {
                 endpoint,
-                vm: "bogus".into(),
+                vm: vm_name,
             },
         })
     }

src/admin/server.rs

@@ -18,6 +18,7 @@ use crate::systemd_api::client::SystemDClient;
 use crate::types::*;
 use crate::utils::naming::*;
 use crate::utils::tonic::*;
+use crate::utils::x509::SecurityInfo;
 use givc_client::endpoint::{EndpointConfig, TlsConfig};
 use givc_common::query::*;
 
@@ -360,10 +361,15 @@ impl pb::admin_service_server::AdminService for AdminService {
         &self,
         request: tonic::Request<RegistryRequest>,
     ) -> std::result::Result<tonic::Response<pb::RegistryResponse>, tonic::Status> {
-        let req = request.into_inner();
+        let vm_name = request
+            .extensions()
+            .get::<SecurityInfo>()
+            .map(move |si| si.hostname().unwrap_or("bogus, no hostname in cert".into()))
+            .unwrap_or("bogus: no TLS".into());
 
+        let req = request.into_inner();
         info!("Registering service {:?}", req);
-        let entry = RegistryEntry::try_from(req)
+        let entry = RegistryEntry::try_from_request(req, vm_name)
             .map_err(|e| Status::new(Code::InvalidArgument, format!("{e}")))?;
         let mut notify = None;
 

src/utils/x509.rs

@@ -33,8 +33,8 @@ impl SecurityInfo {
         !self.enabled || self.dns_names.iter().any(|hn| hostname == hn)
     }
 
-    pub fn hostname(self) -> Option<String> {
-        self.dns_names.into_iter().next()
+    pub fn hostname(&self) -> Option<String> {
+        self.dns_names.iter().next().map(ToOwned::to_owned)
     }
 }