refactor(rust): add localhost contstructor for StaticHostnamePort

build-trust · Jan 16, 2025 · c207225 · c207225
1 parent 2733b3f
commit c207225
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 8 deletions.
diff --git a/implementations/rust/ockam/ockam_command/src/kafka/mod.rs b/implementations/rust/ockam/ockam_command/src/kafka/mod.rs
@@ -11,15 +11,11 @@ pub(crate) mod outlet;
 pub(crate) mod producer;
 pub(crate) mod util;
 
-const KAFKA_DEFAULT_BOOTSTRAP_ADDRESS: StaticHostnamePort =
-    StaticHostnamePort::new("127.0.0.1", 9092);
+const KAFKA_DEFAULT_BOOTSTRAP_ADDRESS: StaticHostnamePort = StaticHostnamePort::localhost(9092);
 const KAFKA_DEFAULT_PROJECT_ROUTE: &str = "/project/default";
-const KAFKA_DEFAULT_CONSUMER_SERVER: StaticHostnamePort =
-    StaticHostnamePort::new("127.0.0.1", 4000);
-const KAFKA_DEFAULT_INLET_BIND_ADDRESS: StaticHostnamePort =
-    StaticHostnamePort::new("127.0.0.1", 4000);
-const KAFKA_DEFAULT_PRODUCER_SERVER: StaticHostnamePort =
-    StaticHostnamePort::new("127.0.0.1", 5000);
+const KAFKA_DEFAULT_CONSUMER_SERVER: StaticHostnamePort = StaticHostnamePort::localhost(4000);
+const KAFKA_DEFAULT_INLET_BIND_ADDRESS: StaticHostnamePort = StaticHostnamePort::localhost(4000);
+const KAFKA_DEFAULT_PRODUCER_SERVER: StaticHostnamePort = StaticHostnamePort::localhost(5000);
 
 fn kafka_default_outlet_addr() -> String {
     DefaultAddress::KAFKA_OUTLET.to_string()

diff --git a/implementations/rust/ockam/ockam_transport_core/src/hostname_port.rs b/implementations/rust/ockam/ockam_transport_core/src/hostname_port.rs
@@ -21,6 +21,13 @@ impl StaticHostnamePort {
     pub const fn new(hostname: &'static str, port: u16) -> Self {
         Self { hostname, port }
     }
+
+    pub const fn localhost(port: u16) -> Self {
+        Self {
+            hostname: "127.0.0.1",
+            port,
+        }
+    }
 }
 
 impl TryFrom<StaticHostnamePort> for HostnamePort {