client: use HidReport.data instead of report

client/src/main.rs

@@ -1,32 +1,37 @@
-use evdev::{Device, InputEventKind};
+use anyhow::Result;
-use navka_common::navka::{relay_client::RelayClient, HidReport};
+use navka_common::navka::HidReport;
-use tonic::transport::Channel;
+use navka_common::navka::relay_client::RelayClient;
-
+use tokio::sync::mpsc;
-const KEYBOARD: &str = "/dev/input/event4";        // adjust
+use tokio_stream::wrappers::ReceiverStream;
-const NAVKA_IP: &str = "192.168.42.253:4000";
+use tonic::{Request, transport::Channel};
 
 #[tokio::main]
-async fn main() -> anyhow::Result<()> {
+async fn main() -> Result<()> {
-    // open evdev
+    // 1) connect to the navka-server gRPC endpoint
-    let mut dev = Device::open(KEYBOARD)?;
+    let channel = Channel::from_static("http://127.0.0.1:50051").connect().await?;
+    let mut client = RelayClient::new(channel);
 
-    // connect to navka
+    // 2) create an mpsc channel that we can push HID reports into
-    let channel = Channel::from_shared(format!("http://{NAVKA_IP}"))?
+    let (tx_request, rx_request) = mpsc::channel::<HidReport>(32);
-        .connect().await?;
+    let outbound = ReceiverStream::new(rx_request);
-    let (mut tx, _rx) = RelayClient::new(channel).stream().await?.into_inner();
 
-    loop {
+    // 3) start the bi-directional stream (note the REQUIRED argument)
-        for ev in dev.fetch_events()? {
+    let response = client.stream(Request::new(outbound)).await?;
-            if let InputEventKind::Key(code) = ev.kind() {
+    let mut inbound = response.into_inner();      // Streaming<HidReport>
-                // simple map: only letters a-z for PoC
+
-                let usage = match code.0 {
+    // 4) demo: send “press A”, wait 100 ms, send “release”
-                    30..=55 => (code.0 - 26) as u8,     // HID usage 0x04..0x1d
+    tokio::spawn(async move {
-                    _ => continue,
+        let press_a = HidReport { data: vec![0x00,0x00,0x04,0,0,0,0,0] };
-                };
+        let release = HidReport { data: vec![0x00; 8] };
-                let mut buf = [0u8; 8];
+
-                buf[2] = if ev.value() == 1 { usage } else { 0 };
+        tx_request.send(press_a).await.ok();
-                tx.send(HidReport { data: buf.to_vec() }).await?;
+        tokio::time::sleep(std::time::Duration::from_millis(100)).await;
-            }
+        tx_request.send(release).await.ok();
-        }
+    });
+
+    // 5) print anything the server echoes back
+    while let Some(msg) = inbound.message().await? {
+        println!("🔄 got report from server: {:?}", msg.data);
     }
+    Ok(())
 }