chore: disable clippy checks on fsevents

crates/turborepo-filewatch/src/cookie_jar.rs

@@ -24,7 +24,7 @@
     #[error("filewatching encountered errors: {0}")]
     NotifyError(#[from] NotifyError),
     #[error("filewatching has closed, cannot watch cookies")]
     Closed,
 }
 
 #[derive(Debug, Error)]
@@ -41,7 +41,7 @@
 
 type CookieResponse = Result<(), WatchError>;
 
 pub struct CookieJar {
     root: AbsoluteSystemPathBuf,
     serial: AtomicUsize,
     timeout: Duration,
@@ -55,12 +55,12 @@
 
 #[derive(Default)]
 struct Watches {
     closed: bool,
     cookies: HashMap<PathBuf, oneshot::Sender<CookieResponse>>,
 }
 
 impl CookieJar {
     pub fn new(
         root: &AbsoluteSystemPath,
         timeout: Duration,
         file_events: broadcast::Receiver<Result<Event, NotifyError>>,
@@ -109,7 +109,7 @@
     }
 }
 
 async fn watch_cookies(
     root: AbsoluteSystemPathBuf,
     watches: Arc<Mutex<Watches>>,
     mut file_events: broadcast::Receiver<Result<Event, NotifyError>>,
@@ -130,7 +130,7 @@
                                     .expect("Non-absolute path from filewatching");
                                 if root.relation_to_path(abs_path) == PathRelation::Parent {
                                     if let Some(responder) = watches.cookies.remove(&path) {
-                                        if let Err(_) = responder.send(Ok(())) {
+                                        if responder.send(Ok(())).is_err() {
                                             // Note that cookie waiters will time out if they don't get a
                                             // response, so we don't necessarily
                                             // need to panic here, although we could decide to do that in the
@@ -151,7 +151,7 @@
                         let resp = if is_closing { WatchError::Closed } else { e };
                         let mut watches = watches.lock().expect("mutex poisoned");
                         for (_, sender) in watches.cookies.drain() {
-                            if let Err(_) = sender.send(Err(resp.clone())) {
+                            if sender.send(Err(resp.clone())).is_err() {
                                 // Note that cookie waiters will time out if they don't get a response, so
                                 // we don't necessarily need to panic here, although
                                 // we could decide to do that in the future.
@@ -171,7 +171,7 @@
 
 // result flattening is an unstable feature, so add a manual helper to do so.
 // This version is for unwrapping events coming from filewatching
 fn flatten_event(
     event: Result<Result<Event, NotifyError>, broadcast::error::RecvError>,
 ) -> Result<Event, WatchError> {
     Ok(event??)

crates/turborepo-filewatch/src/lib.rs

@@ -1,3 +1,4 @@
+#![deny(clippy::all)]
 #![feature(assert_matches)]
 
 use std::{
@@ -33,6 +34,7 @@ use {
 
 mod cookie_jar;
 #[cfg(target_os = "macos")]
+#[allow(clippy::all)]
 mod fsevent;
 
 #[cfg(not(target_os = "macos"))]
@@ -90,7 +92,7 @@ impl FileSystemWatcher {
         let watcher = run_watcher(&watch_root, send_file_events).unwrap();
         let (exit_ch, exit_signal) = tokio::sync::oneshot::channel();
         // Ensure we are ready to receive new events, not events for existing state
-        futures::executor::block_on(wait_for_cookie(&root, &mut recv_file_events))?;
+        futures::executor::block_on(wait_for_cookie(root, &mut recv_file_events))?;
         tokio::task::spawn(watch_events(
             watcher,
             watch_root,
@@ -149,7 +151,7 @@ async fn watch_events(
                         {
                             if event.kind == EventKind::Create(CreateKind::Folder) {
                                 for new_path in &event.paths {
-                                    if let Err(err) = manually_add_recursive_watches(&new_path, &mut watcher, Some(&broadcast_sender)) {
+                                    if let Err(err) = manually_add_recursive_watches(new_path, &mut watcher, Some(&broadcast_sender)) {
                                         warn!("encountered error watching filesystem {}", err);
                                         break 'outer;
                                     }
@@ -233,7 +235,7 @@ fn watch_parents(root: &AbsoluteSystemPath, watcher: &mut Backend) -> Result<(),
 
 #[cfg(not(feature = "manual_recursive_watch"))]
 fn watch_recursively(root: &AbsoluteSystemPath, watcher: &mut Backend) -> Result<(), WatchError> {
-    watcher.watch(&root.as_std_path(), RecursiveMode::Recursive)?;
+    watcher.watch(root.as_std_path(), RecursiveMode::Recursive)?;
     Ok(())
 }