From 9442430453073147ad23f11a1e6ed72713dc3e76 Mon Sep 17 00:00:00 2001
From: Brad Stein <brad.stein@gmail.com>
Date: Mon, 23 Jun 2025 21:22:02 -0500
Subject: [PATCH] server fix

---
 server/src/main.rs | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/server/src/main.rs b/server/src/main.rs
index ebc0f87..4b40105 100644
--- a/server/src/main.rs
+++ b/server/src/main.rs
@@ -2,15 +2,14 @@
 // sever/src/main.rs
 #![forbid(unsafe_code)]
 
-use anyhow::Context;
-use futures_util::Stream;
+use futures_util::{Stream, StreamExt};
 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 tonic::{transport::Server, Request, Response, Status};
-use tracing::{error, info, trace, warn};
+use tracing::{info, trace};
 use tracing_subscriber::{fmt, EnvFilter};
-use udev::{Enumerator, MonitorBuilder};
+use udev::{MonitorBuilder};
 
 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<()> {
     let mut mon = MonitorBuilder::new()?
         .match_subsystem("usb")?
-        .match_property("PRODUCT", "7ca/3311/*")? // vendor: 0x07ca, device 0x3311
+        .match_attribute("PRODUCT", "7ca/3311/*")? // vendor: 0x07ca, device 0x3311
         .listen()?;
 
     while let Some(ev) = mon.next() {