Create Rust-based openai api proxy server in node hub

Cargo.toml

@@ -33,6 +33,7 @@ members = [
     "node-hub/dora-record",
     "node-hub/dora-rerun",
     "node-hub/terminal-print",
+    "node-hub/openai-proxy-server",
     "libraries/extensions/ros2-bridge",
     "libraries/extensions/ros2-bridge/msg-gen",
     "libraries/extensions/ros2-bridge/python",

examples/openai-server/dataflow-rust.yml

@@ -0,0 +1,16 @@
+nodes:
+  - id: dora-openai-server
+    build: cargo build -p dora-openai-proxy-server --release
+    path: ../../target/release/dora-openai-proxy-server
+    outputs:
+      - chat_completion_request
+    inputs:
+      completion_reply: dora-echo/echo
+
+  - id: dora-echo
+    build: pip install -e ../../node-hub/dora-echo
+    path: dora-echo
+    inputs:
+      echo: dora-openai-server/chat_completion_request
+    outputs:
+      - echo

node-hub/openai-proxy-server/Cargo.toml

@@ -0,0 +1,27 @@
+[package]
+name = "dora-openai-proxy-server"
+version.workspace = true
+edition = "2021"
+documentation.workspace = true
+description.workspace = true
+license.workspace = true
+repository.workspace = true
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+tokio = { version = "1.36.0", features = ["full"] }
+dora-node-api = { workspace = true, features = ["tracing"] }
+eyre = "0.6.8"
+chrono = "0.4.31"
+tracing = "0.1.27"
+serde = { version = "1.0.130", features = ["derive"] }
+serde_json = "1.0.68"
+url = "2.2.2"
+indexmap = { version = "2.6.0", features = ["serde"] }
+hyper = { version = "0.14", features = ["full"] }
+thiserror = "1.0.37"
+uuid = { version = "1.10", features = ["v4"] }
+mime_guess = "2.0.4"
+futures = "0.3.31"
+tokio-stream = "0.1.11"