1 files changed, 86 insertions, 0 deletions
diff --git a/crates/common/tedge_config/src/models/connect_url.rs b/crates/common/tedge_config/src/models/connect_url.rs
new file mode 100644
index 00000000..79f15629
--- /dev/null
+++ b/crates/common/tedge_config/src/models/connect_url.rs
@@ -0,0 +1,86 @@
+use std::convert::TryFrom;
+use url::Host;
+
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize, Eq, PartialEq)]
+#[serde(try_from = "String", into = "String")]
+pub struct ConnectUrl {
+    input: String,
+    host: Host,
+}
+
+#[derive(thiserror::Error, Debug)]
+#[error(
+    "Provided URL: '{input}' contains scheme or port.
+         Provided URL should contain only domain, eg: 'subdomain.cumulocity.com'."
+)]
+pub struct InvalidConnectUrl {
+    input: String,
+    error: url::ParseError,
+}
+
+impl TryFrom<String> for ConnectUrl {
+    type Error = InvalidConnectUrl;
+
+    fn try_from(input: String) -> Result<Self, Self::Error> {
+        match Host::parse(&input) {
+            Ok(host) => Ok(Self { input, host }),
+            Err(error) => Err(InvalidConnectUrl { input, error }),
+        }
+    }
+}
+
+impl TryFrom<&str> for ConnectUrl {
+    type Error = InvalidConnectUrl;
+
+    fn try_from(input: &str) -> Result<Self, Self::Error> {
+        ConnectUrl::try_from(input.to_string())
+    }
+}
+
+impl ConnectUrl {
+    pub fn as_str(&self) -> &str {
+        self.input.as_str()
+    }
+}
+
+impl From<ConnectUrl> for String {
+    fn from(val: ConnectUrl) -> Self {
+        val.input
+    }
+}
+
+impl From<ConnectUrl> for Host {
+    fn from(val: ConnectUrl) -> Self {
+        val.host
+    }
+}
+
+#[test]
+fn connect_url_from_string_should_return_err_provided_address_with_port() {
+    let input = "test.address.com:8883";
+
+    assert!(ConnectUrl::try_from(input).is_err());
+}
+
+#[test]
+fn connect_url_from_string_should_return_err_provided_address_with_scheme_http() {
+    let input = "http://test.address.com";
+
+    assert!(ConnectUrl::try_from(input).is_err());
+}
+
+#[test]
+fn connect_url_from_string_should_return_err_provided_address_with_port_and_http() {
+    let input = "http://test.address.com:8883";
+
+    assert!(ConnectUrl::try_from(input).is_err());
+}
+
+#[test]
+fn connect_url_from_string_should_return_string() -> Result<(), crate::TEdgeConfigError> {
+    let input = "test.address.com";
+    let expected = "test.address.com";
+
+    assert_eq!(&ConnectUrl::try_from(input)?.as_str(), &expected);
+    Ok(())
+}