lesavka/server/src/main.rs

//! navka-server — receive HidReport and write to /dev/hidg0
// main.rs
#![forbid(unsafe_code)]

use std::{pin::Pin, sync::Arc};
use tokio::{fs::{File, OpenOptions}, io::AsyncWriteExt, sync::Mutex};
use tokio_stream::{wrappers::ReceiverStream, Stream, StreamExt};
use tonic::{transport::Server, Request, Response, Status};
use tracing::{info, error};

use navka_common::navka::{
    relay_server::{Relay, RelayServer},
    hid_report,
    HidReport,
};

struct Handler {
    kb: Arc<Mutex<File>>,
    ms: Arc<Mutex<File>>,
}

#[tonic::async_trait]
impl Relay for Handler {
    type StreamStream =
        Pin<Box<dyn Stream<Item = Result<HidReport, Status>> + Send + 'static>>;

    async fn stream(
        &self,
        request: Request<tonic::Streaming<HidReport>>,
    ) -> Result<Response<Self::StreamStream>, Status> {
        let mut in_stream = request.into_inner();
        let kb = self.kb.clone();
        let ms = self.ms.clone();
        let (tx, rx) = tokio::sync::mpsc::channel(32);

        tokio::spawn(async move {
            while let Some(msg) = in_stream.next().await.transpose()? {
                match msg.kind {
                    Some(hid_report::Kind::KeyboardReport(ref v)) if v.len() == 8 => {
                        kb.lock().await.write_all(v).await?;
                    }
                    Some(hid_report::Kind::MouseReport(ref v)) if v.len() == 4 => {
                        ms.lock().await.write_all(v).await?;
                    }
                    _ => {
                        let bad_len = match &msg.kind {
                            Some(hid_report::Kind::KeyboardReport(v)) => v.len(),
                            Some(hid_report::Kind::MouseReport(v))    => v.len(),
                            _                                                => 0,
                        };
                        error!("bad {:?} packet len={}", msg.kind, bad_len); 
                        continue;
                    }
                }
                info!("HID report forwarded");
                let _ = tx.send(Ok(msg)).await;
            }
            Ok::<_, Status>(())
        });

        Ok(Response::new(Box::pin(ReceiverStream::new(rx))))
    }
}

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    tracing_subscriber::fmt::init();

    let kb = OpenOptions::new()
        .write(true)
        .read(true)
        .custom_flags(libc::O_NONBLOCK)
        .open("/dev/hidg0")
        .await?;

    let ms = OpenOptions::new()
        .write(true)
        .read(true)
        .custom_flags(libc::O_NONBLOCK)
        .open("/dev/hidg1")
        .await?;

    let handler = Handler {
        kb: Arc::new(Mutex::new(kb)),
        ms: Arc::new(Mutex::new(ms)),
    };

    println!("🌐 navka-server listening on 0.0.0.0:50051");
    Server::builder()
        .add_service(RelayServer::new(handler))
        .serve(([0, 0, 0, 0], 50051).into())
        .await?;
    Ok(())
}