added logging to server
This commit is contained in:
parent
4c7bc1f298
commit
4237c90c65
@ -9,3 +9,5 @@ tokio-stream = "0.1"
|
|||||||
tonic = { version = "0.11", features = ["transport"] }
|
tonic = { version = "0.11", features = ["transport"] }
|
||||||
anyhow = "1.0"
|
anyhow = "1.0"
|
||||||
navka-common = { path = "../common" }
|
navka-common = { path = "../common" }
|
||||||
|
tracing = { version = "0.1", features = ["std"] }
|
||||||
|
tracing-subscriber = "0.3"
|
||||||
|
|||||||
@ -5,6 +5,8 @@ use std::{pin::Pin, sync::Arc};
|
|||||||
use tokio::{fs::OpenOptions, io::AsyncWriteExt};
|
use tokio::{fs::OpenOptions, io::AsyncWriteExt};
|
||||||
use tokio_stream::{wrappers::ReceiverStream, Stream, StreamExt};
|
use tokio_stream::{wrappers::ReceiverStream, Stream, StreamExt};
|
||||||
use tonic::{transport::Server, Request, Response, Status};
|
use tonic::{transport::Server, Request, Response, Status};
|
||||||
|
use tracing::{info, error};
|
||||||
|
use tracing_subscriber::FmtSubscriber;
|
||||||
|
|
||||||
use navka_common::navka::{
|
use navka_common::navka::{
|
||||||
relay_server::{Relay, RelayServer},
|
relay_server::{Relay, RelayServer},
|
||||||
@ -38,7 +40,10 @@ impl Relay for Handler {
|
|||||||
file.write_all(&msg.data).await.map_err(|e| Status::internal(e.to_string()))?;
|
file.write_all(&msg.data).await.map_err(|e| Status::internal(e.to_string()))?;
|
||||||
file.flush().await.ok();
|
file.flush().await.ok();
|
||||||
|
|
||||||
// 2) echo back
|
// 2) structured log (shows hex + length)
|
||||||
|
info!(bytes = ?msg.data, len = msg.data.len(), "HID report received");
|
||||||
|
|
||||||
|
// 3) echo back
|
||||||
tx.send(Ok(msg)).await.ok();
|
tx.send(Ok(msg)).await.ok();
|
||||||
}
|
}
|
||||||
Ok::<_, Status>(())
|
Ok::<_, Status>(())
|
||||||
@ -50,12 +55,14 @@ impl Relay for Handler {
|
|||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main() -> anyhow::Result<()> {
|
async fn main() -> anyhow::Result<()> {
|
||||||
|
let subscriber = FmtSubscriber::builder().with_target(false).finish();
|
||||||
|
tracing::subscriber::set_global_default(subscriber)?;
|
||||||
|
|
||||||
let file = OpenOptions::new()
|
let file = OpenOptions::new()
|
||||||
.write(true)
|
.write(true)
|
||||||
.open("/dev/hidg0")
|
.open("/dev/hidg0")
|
||||||
.await?;
|
.await?;
|
||||||
let hid = Arc::new(tokio::sync::Mutex::new(file));
|
let hid = Arc::new(tokio::sync::Mutex::new(file));
|
||||||
|
|
||||||
let handler = Handler { hid };
|
let handler = Handler { hid };
|
||||||
|
|
||||||
println!("🌐 navka-server listening on 0.0.0.0:50051");
|
println!("🌐 navka-server listening on 0.0.0.0:50051");
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user