chore: update relay and influxdb-inlet output to be consistent with t…

…he tcp-inlet
build-trust · Jan 6, 2025 · 59e69c2 · 59e69c2
1 parent 7225929
commit 59e69c2
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/implementations/rust/ockam/ockam_command/src/influxdb/inlet/create.rs b/implementations/rust/ockam/ockam_command/src/influxdb/inlet/create.rs
@@ -111,29 +111,29 @@ impl Command for InfluxDBCreateCommand {
             .add_inlet_created_event(&opts, &node_name, &inlet_status)
             .await?;
 
-        let created_message = fmt_ok!(
-            "Created a new InfluxDB Inlet in the Node {} bound to {}\n",
+        let created_message = format!(
+            "Created a new InfluxDB Inlet in the Node {} bound to {}",
             color_primary(&node_name),
-            color_primary(&self.tcp_inlet.from)
+            color_primary(self.tcp_inlet.from.to_string()),
         );
 
         let plain = if self.tcp_inlet.no_connection_wait {
-            created_message + &fmt_log!("It will automatically connect to the TCP Outlet at {} as soon as it is available",
+            fmt_ok!("{created_message}\n")
+                + &fmt_log!("It will automatically connect to the InfluxDB Outlet at {} as soon as it is available\n",
                 color_primary(&self.tcp_inlet.to)
             )
         } else if inlet_status.status == ConnectionStatus::Up {
-            created_message
+            fmt_ok!("{created_message}\n")
                 + &fmt_log!(
-                    "sending traffic to the TCP Outlet at {}",
+                    "sending traffic to the TCP Outlet at {}\n",
                     color_primary(&self.tcp_inlet.to)
                 )
         } else {
-            fmt_warn!(
-                "A InfluxDB Inlet was created in the Node {} bound to {} but failed to connect to the TCP Outlet at {}\n",
-                color_primary(&node_name),
-                 color_primary(self.tcp_inlet.from.to_string()),
+            fmt_warn!("{created_message}\n")
+                + &fmt_log!(
+                "but failed to connect to the TCP Outlet at {}\n",
                 color_primary(&self.tcp_inlet.to)
-            ) + &fmt_info!("It will retry to connect automatically")
+            ) + &fmt_info!("It will automatically connect to the InfluxDB Outlet as soon as it is available\n")
         };
 
         opts.terminal

diff --git a/implementations/rust/ockam/ockam_command/src/relay/create.rs b/implementations/rust/ockam/ockam_command/src/relay/create.rs
@@ -169,7 +169,7 @@ impl Command for CreateCommand {
                         let at = color_primary(&at);
                         let node = color_primary(format!("/node/{}", &node.node_name()));
                         fmt_warn!("A relay was created at {node} but failed to connect to {at}\n")
-                            + &fmt_info!("It will retry to connect automatically")
+                            + &fmt_info!("It will automatically connect to the Relay as soon as it is available")
                     };
                     opts.terminal
                         .stdout()