refactor: FM-321 move orb relay client

Cargo.toml

@@ -20,6 +20,7 @@ members = [
   "mcu-interface",
   "mcu-util",
   "qr-link",
+  "relay-client",
   "security-utils",
   "seek-camera/sys",
   "seek-camera/wrapper",
@@ -95,6 +96,7 @@ orb-build-info.path = "build-info"
 orb-const-concat.path = "const-concat"
 orb-header-parsing.path = "header-parsing"
 orb-mcu-interface.path = "mcu-interface"
+orb-relay-client.path = "relay-client"
 orb-security-utils.path = "security-utils"
 orb-slot-ctrl.path = "slot-ctrl"
 orb-telemetry.path = "telemetry"
@@ -106,6 +108,11 @@ seek-camera.path = "seek-camera/wrapper"
 git = "https://github.com/worldcoin/orb-messages"
 rev = "787ab78581b705af0946bcfe3a0453b64af2193f"
 
+[workspace.dependencies.orb-relay-messages]
+git = "https://github.com/worldcoin/orb-relay-messages.git"
+rev = "f1c73751200ea9df7f1712ec203c7882f30f60f4"
+features = ["client"]
+
 [workspace.dependencies.nusb]
 git = "https://github.com/kevinmehall/nusb"
 rev = "3ec3508324cdd01ca288b91ddcb2f92fd6a6f813"

relay-client/Cargo.toml

@@ -0,0 +1,20 @@
+[package]
+name = "orb-relay-client"
+version = "0.1.0"
+edition.workspace = true
+publish = false
+
+[dependencies]
+clap = { version = "4", features = ["derive"] }
+eyre.workspace = true
+json5 = "0.4"
+orb-relay-messages.workspace = true
+orb-security-utils = { workspace = true, features = ["reqwest"] }
+rand = "0.8"
+serde_json.workspace = true
+sha2 = "0.10"
+tokio-stream.workspace = true
+tokio-util.workspace = true
+tokio.workspace = true
+tracing-subscriber = "0.3"
+tracing.workspace = true

relay-client/src/bin/decode-msg.rs

@@ -0,0 +1,39 @@
+use clap::Parser;
+use eyre::{eyre, Result};
+use orb_relay_client::debug_any;
+use orb_relay_messages::prost_types::Any;
+use serde_json::Value;
+
+#[derive(Parser, Debug)]
+struct Args {
+    #[arg()]
+    json: String,
+}
+
+fn main() -> Result<()> {
+    let args = Args::parse();
+    println!("{}", decode_payload(&args.json)?);
+    Ok(())
+}
+
+fn decode_payload(json: &str) -> Result<String> {
+    println!("json: {}", json);
+    let v: Value = json5::from_str(json)?;
+    let any = Any {
+        type_url: v["type_url"]
+            .as_str()
+            .ok_or_else(|| eyre!("Invalid type_url"))?
+            .to_string(),
+        value: v["value"]
+            .as_array()
+            .ok_or_else(|| eyre!("Invalid value"))?
+            .iter()
+            .map(|n| {
+                n.as_u64()
+                    .ok_or_else(|| eyre!("Invalid number"))
+                    .map(|n| n as u8)
+            })
+            .collect::<Result<_>>()?,
+    };
+    Ok(debug_any(&Some(any)))
+}