Minor fix to dora tcp

Author: haixuanTao

Cargo.lock

@@ -39,6 +39,7 @@ members = [
     "node-hub/dora-mistral-rs",
     "node-hub/dora-rav1e",
     "node-hub/dora-dav1d",
+    "node-hub/dora-tcp",
     "libraries/extensions/ros2-bridge",
     "libraries/extensions/ros2-bridge/msg-gen",
     "libraries/extensions/ros2-bridge/python",

Cargo.toml

@@ -10,3 +10,4 @@ repository.workspace = true
 [dependencies]
 dora-node-api = { workspace = true }
 tokio = { version = "1.45.0", features = ["full"] }
+eyre = "0.6.8"

node-hub/dora-tcp/cargo.toml

@@ -2,16 +2,14 @@
     Basic TCP implementation for streaming events to a TCP Destination
 */
 use dora_node_api::{DoraNode, Event};
+use eyre::Result;
 use tokio::io::AsyncWriteExt;
 use tokio::net::TcpStream;
-use std::error::Error;
-
-
-#[tokio::main]
-async fn main() -> Result<(), Box<dyn Error>> {
 
+pub async fn lib_main() -> Result<()> {
     // NOTE: Hard-coded address
-    let mut stream = TcpStream::connect("localhost:8052").await?;
+    let mut stream =
+        TcpStream::connect(std::env::var("ADDR").unwrap_or("127.0.0.1:8052".to_string())).await?;
 
     let (_, mut events) = DoraNode::init_from_env()?;
 
@@ -22,14 +20,13 @@ async fn main() -> Result<(), Box<dyn Error>> {
                 metadata: _,
                 data,
             } => match id.as_str() {
-                "command" => {
-                    
+                "text" => {
                     // Extract the command
                     let command: &str = (&data).try_into()?;
 
                     // Send the command to the Unity over tcp
                     stream.write_all(command.as_bytes()).await?;
-                },
+                }
                 _ => {}
             },
             _ => {}

node-hub/dora-tcp/src/lib.rs

@@ -0,0 +1,5 @@
+#[tokio::main]
+
+async fn main() -> Result<(), eyre::Error> {
+    dora_tcp::lib_main().await
+}