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); }; }