bstein/lesavka
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

server fix

Browse Source
This commit is contained in:
Brad Stein 2025-06-23 21:22:02 -05:00
parent 8a1610ce92
commit 9442430453
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server/src/main.rs
View File

@ -2,15 +2,14 @@
// sever/src/main.rs // sever/src/main.rs
#![forbid(unsafe_code)] #![forbid(unsafe_code)]
use anyhow::Context; use futures_util::{Stream, StreamExt};
use futures_util::Stream;
use std::{pin::Pin, sync::Arc, time::Duration}; use std::{pin::Pin, sync::Arc, time::Duration};
use tokio::{fs::{File, OpenOptions}, io::AsyncWriteExt, sync::Mutex}; use tokio::{fs::{OpenOptions}, io::AsyncWriteExt, sync::Mutex};
use tokio_stream::{wrappers::ReceiverStream}; use tokio_stream::{wrappers::ReceiverStream};
use tonic::{transport::Server, Request, Response, Status}; use tonic::{transport::Server, Request, Response, Status};
use tracing::{error, info, trace, warn}; use tracing::{info, trace};
use tracing_subscriber::{fmt, EnvFilter}; use tracing_subscriber::{fmt, EnvFilter};
use udev::{Enumerator, MonitorBuilder}; use udev::{MonitorBuilder};
use lesavka_server::{video, usb_reset}; use lesavka_server::{video, usb_reset};
@ -43,7 +42,7 @@ fn list_gc311_devices() -> anyhow::Result<Vec<String>> {
async fn monitor_gc311_disconnect() -> anyhow::Result<()> { async fn monitor_gc311_disconnect() -> anyhow::Result<()> {
let mut mon = MonitorBuilder::new()? let mut mon = MonitorBuilder::new()?
.match_subsystem("usb")? .match_subsystem("usb")?
.match_property("PRODUCT", "7ca/3311/*")? // vendor: 0x07ca, device 0x3311 .match_attribute("PRODUCT", "7ca/3311/*")? // vendor: 0x07ca, device 0x3311
.listen()?; .listen()?;
while let Some(ev) = mon.next() { while let Some(ev) = mon.next() {