[pdm-devel] [PATCH datacenter-manager 1/8] pdm-api-types: move RemoteUpid to its own module

Lukas Wagner l.wagner at proxmox.com
Tue Nov 11 11:50:52 CET 2025


lib.rs re-exports all public member of the new remote_upid module, so
for callers this change is non-breaking.

Signed-off-by: Lukas Wagner <l.wagner at proxmox.com>
---
 lib/pdm-api-types/src/lib.rs         | 91 ++-------------------------
 lib/pdm-api-types/src/remote_upid.rs | 93 ++++++++++++++++++++++++++++
 2 files changed, 97 insertions(+), 87 deletions(-)
 create mode 100644 lib/pdm-api-types/src/remote_upid.rs

diff --git a/lib/pdm-api-types/src/lib.rs b/lib/pdm-api-types/src/lib.rs
index ee4dfb2b..ad52372e 100644
--- a/lib/pdm-api-types/src/lib.rs
+++ b/lib/pdm-api-types/src/lib.rs
@@ -1,13 +1,11 @@
 //! Basic API types used by most of the PDM code.
 
 use std::collections::HashMap;
-use std::fmt;
 
-use anyhow::{bail, Error};
 use const_format::concatcp;
 use serde::{Deserialize, Serialize};
 
-use proxmox_schema::api_types::{DNS_NAME_STR, IPRE_BRACKET_STR, PORT_REGEX_STR, SAFE_ID_REGEX};
+use proxmox_schema::api_types::{DNS_NAME_STR, IPRE_BRACKET_STR, PORT_REGEX_STR};
 use proxmox_schema::{
     api, const_regex, ApiStringFormat, ApiType, ArraySchema, IntegerSchema, ReturnType, Schema,
     StringSchema, Updater,
@@ -23,6 +21,9 @@ pub use node_config::*;
 mod metric_collection;
 pub use metric_collection::*;
 
+mod remote_upid;
+pub use remote_upid::*;
+
 mod proxy;
 pub use proxy::HTTP_PROXY_SCHEMA;
 
@@ -410,90 +411,6 @@ impl ConfigurationState {
 serde_plain::derive_display_from_serialize!(ConfigurationState);
 serde_plain::derive_fromstr_from_deserialize!(ConfigurationState);
 
-pub const REMOTE_UPID_SCHEMA: Schema = StringSchema::new("A remote UPID")
-    .min_length("C!UPID:N:12345678:12345678:12345678:::".len())
-    .schema();
-
-#[derive(Clone, Debug, Eq, PartialEq, Hash)]
-pub struct RemoteUpid {
-    remote: String,
-    /// This is usually a pve upid, but may also be a pbs upid, they have distinct formats.
-    pub upid: String,
-}
-
-impl RemoteUpid {
-    pub fn remote(&self) -> &str {
-        &self.remote
-    }
-
-    pub fn into_remote(self) -> String {
-        self.remote
-    }
-}
-
-impl ApiType for RemoteUpid {
-    const API_SCHEMA: Schema = REMOTE_UPID_SCHEMA;
-}
-
-impl TryFrom<(String, String)> for RemoteUpid {
-    type Error = Error;
-
-    fn try_from((remote, upid): (String, String)) -> Result<Self, Error> {
-        if !SAFE_ID_REGEX.is_match(&remote) {
-            bail!("bad remote id in remote upid");
-        }
-        Ok(Self { remote, upid })
-    }
-}
-
-impl TryFrom<(String, &str)> for RemoteUpid {
-    type Error = Error;
-
-    fn try_from((remote, upid): (String, &str)) -> Result<Self, Error> {
-        if !SAFE_ID_REGEX.is_match(&remote) {
-            bail!("bad remote id in remote upid");
-        }
-        Ok(Self {
-            remote,
-            upid: upid.to_string(),
-        })
-    }
-}
-
-impl TryFrom<(&str, &str)> for RemoteUpid {
-    type Error = Error;
-
-    fn try_from((remote, upid): (&str, &str)) -> Result<Self, Error> {
-        if !SAFE_ID_REGEX.is_match(remote) {
-            bail!("bad remote id in remote upid");
-        }
-        Ok(Self {
-            remote: remote.to_string(),
-            upid: upid.to_string(),
-        })
-    }
-}
-
-impl std::str::FromStr for RemoteUpid {
-    type Err = Error;
-
-    fn from_str(s: &str) -> Result<Self, Error> {
-        match s.find('!') {
-            None => bail!("missing '!' separator in remote upid"),
-            Some(pos) => (&s[..pos], &s[(pos + 1)..]).try_into(),
-        }
-    }
-}
-
-impl fmt::Display for RemoteUpid {
-    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
-        write!(f, "{}!{}", self.remote, self.upid)
-    }
-}
-
-serde_plain::derive_deserialize_from_fromstr!(RemoteUpid, "valid remote upid");
-serde_plain::derive_serialize_from_display!(RemoteUpid);
-
 fn limit_default() -> u64 {
     50
 }
diff --git a/lib/pdm-api-types/src/remote_upid.rs b/lib/pdm-api-types/src/remote_upid.rs
new file mode 100644
index 00000000..bf7c1797
--- /dev/null
+++ b/lib/pdm-api-types/src/remote_upid.rs
@@ -0,0 +1,93 @@
+use std::fmt;
+
+use anyhow::{bail, Error};
+
+use proxmox_schema::api_types::SAFE_ID_REGEX;
+use proxmox_schema::{ApiType, Schema, StringSchema};
+
+pub const REMOTE_UPID_SCHEMA: Schema = StringSchema::new("A remote UPID")
+    .min_length("C!UPID:N:12345678:12345678:12345678:::".len())
+    .schema();
+
+#[derive(Clone, Debug, Eq, PartialEq, Hash)]
+pub struct RemoteUpid {
+    remote: String,
+    /// This is usually a pve upid, but may also be a pbs upid, they have distinct formats.
+    pub upid: String,
+}
+
+impl RemoteUpid {
+    pub fn remote(&self) -> &str {
+        &self.remote
+    }
+
+    pub fn into_remote(self) -> String {
+        self.remote
+    }
+}
+
+impl ApiType for RemoteUpid {
+    const API_SCHEMA: Schema = REMOTE_UPID_SCHEMA;
+}
+
+impl TryFrom<(String, String)> for RemoteUpid {
+    type Error = Error;
+
+    fn try_from((remote, upid): (String, String)) -> Result<Self, Error> {
+        if !SAFE_ID_REGEX.is_match(&remote) {
+            bail!("bad remote id in remote upid");
+        }
+
+        Ok(Self { remote, upid })
+    }
+}
+
+impl TryFrom<(String, &str)> for RemoteUpid {
+    type Error = Error;
+
+    fn try_from((remote, upid): (String, &str)) -> Result<Self, Error> {
+        if !SAFE_ID_REGEX.is_match(&remote) {
+            bail!("bad remote id in remote upid");
+        }
+
+        Ok(Self {
+            remote,
+            upid: upid.to_string(),
+        })
+    }
+}
+
+impl TryFrom<(&str, &str)> for RemoteUpid {
+    type Error = Error;
+
+    fn try_from((remote, upid): (&str, &str)) -> Result<Self, Error> {
+        if !SAFE_ID_REGEX.is_match(remote) {
+            bail!("bad remote id in remote upid");
+        }
+
+        Ok(Self {
+            remote: remote.to_string(),
+            upid: upid.to_string(),
+        })
+    }
+}
+
+impl std::str::FromStr for RemoteUpid {
+    type Err = Error;
+
+    fn from_str(s: &str) -> Result<Self, Error> {
+        match s.find('!') {
+            None => bail!("missing '!' separator in remote upid"),
+            Some(pos) => (&s[..pos], &s[(pos + 1)..]).try_into(),
+        }
+    }
+}
+
+impl fmt::Display for RemoteUpid {
+    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
+        write!(f, "{}!{}", self.remote, self.upid)
+    }
+}
+
+serde_plain::derive_deserialize_from_fromstr!(RemoteUpid, "valid remote upid");
+serde_plain::derive_serialize_from_display!(RemoteUpid);
-- 
2.47.3





More information about the pdm-devel mailing list