From c85eee85e94a6059efda1ac1ee3a0b3e59be17d1 Mon Sep 17 00:00:00 2001 From: Paul Campbell Date: Sun, 30 Jun 2024 20:10:56 +0100 Subject: [PATCH] refactor: file-watcher doesn't debug log on each loop --- crates/file-watcher-actor/src/lib.rs | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/crates/file-watcher-actor/src/lib.rs b/crates/file-watcher-actor/src/lib.rs index 7663147..fce74a5 100644 --- a/crates/file-watcher-actor/src/lib.rs +++ b/crates/file-watcher-actor/src/lib.rs @@ -3,7 +3,6 @@ use actix::prelude::*; use actix::Recipient; use inotify::{EventMask, Inotify, WatchMask}; use std::{path::PathBuf, time::Duration}; -use tracing::{debug, info}; const CHECK_INTERVAL: Duration = Duration::from_secs(1); @@ -22,7 +21,6 @@ pub enum Error { } pub struct FileWatcher { - path: PathBuf, inotify: Inotify, recipient: Recipient, run_interval: Option, @@ -31,11 +29,10 @@ impl FileWatcher { pub fn new(path: PathBuf, recipient: Recipient) -> Result { let inotify = Inotify::init()?; inotify.watches().add( - path.clone(), + path, WatchMask::MODIFY | WatchMask::CREATE | WatchMask::DELETE | WatchMask::ATTRIB, )?; Ok(Self { - path, inotify, recipient, run_interval: None, @@ -46,7 +43,7 @@ impl Actor for FileWatcher { type Context = Context; fn started(&mut self, ctx: &mut Self::Context) { - info!("Starting file watcher actor"); + tracing::info!("Starting file watcher actor"); self.run_interval .replace(ctx.run_interval(CHECK_INTERVAL, |_act, ctx| { ctx.notify(WatchFile); @@ -58,11 +55,10 @@ impl Handler for FileWatcher { type Result = (); fn handle(&mut self, _msg: WatchFile, _ctx: &mut Self::Context) -> Self::Result { - debug!("Watching {} for activity...", self.path.display()); let mut buffer = [0u8; 4096]; if let Ok(mut events) = self.inotify.read_events(&mut buffer) { if events.any(|event| event.mask.contains(EventMask::MODIFY)) { - info!("File modified"); + tracing::info!("File modified"); self.recipient.do_send(FileUpdated); }; }