rsincron 0.0.6

use std::{
    ffi::OsString,
    process::Command,
    sync::{Arc, RwLock, RwLockWriteGuard},
    thread,
    time::Duration,
};

use clap::Parser;
use figment::{
    providers::{Format, Toml},
    Figment,
};
use futures::TryStreamExt;
use inotify::Event;
use log::{debug, info};
use rsincronlib::{
    handler::{FailedWatches, Handler},
    handler_config::HandlerConfig,
};

#[derive(Parser)]
#[command(author, version, about, long_about = None)]
struct Args {
    #[arg(
        short,
        long,
        default_value_t = format!(
            "{}/.config/rsincron.toml",
            std::env::var("HOME")
                .expect("HOME envvar is not set: exiting")))
    ]
    config: String,
}

fn expand_variables(
    input: &str,
    filename: &str,
    path: &str,
    mask_text: &str,
    mask_bits: &str,
) -> String {
    let mut formatted = String::new();
    let mut dollar = false;
    for c in input.chars() {
        if c == '$' {
            if !dollar {
                dollar = true;
            } else {
                formatted.push(c);
                dollar = false;
            }
        } else {
            if dollar {
                match c {
                    '#' => formatted.push_str(filename),
                    '@' => formatted.push_str(path),
                    '%' => formatted.push_str(mask_text),
                    '&' => formatted.push_str(mask_bits),
                    _ => formatted.push(c),
                }
                dollar = false;
            } else {
                formatted.push(c);
            }
        }
    }
    formatted
}

async fn process_event<'a>(
    mut handler: RwLockWriteGuard<'a, Handler>,
    event: Option<Event<OsString>>,
) {
    let Some(event) = event else {
        return;
    };

    let (path, mask, command, watch_config) =
        handler.active_watches.get(&event.wd).unwrap().clone();

    let filename = match event.name {
        Some(string) => string.to_str().unwrap_or_default().to_owned(),
        _ => String::default(),
    };

    if watch_config.recursive {
        handler.recursive_add_watch((
            path.to_owned(),
            mask.to_owned(),
            command.clone(),
            watch_config,
        ));
    }

    let masks = format!("{:?}", event.mask)
        .split(" | ")
        .map(|f| format!("IN_{f}"))
        .collect::<Vec<String>>()
        .join(",");

    info!("watch event: {masks} for {path} {filename}");
    let command = expand_variables(
        &command,
        &filename,
        &path.to_string(),
        &masks,
        &event.mask.bits().to_string(),
    );

    let _ = Command::new("bash").arg("-c").arg(command).spawn();
}

#[async_std::main]
async fn main() {
    let args = Args::parse();

    let config: HandlerConfig = Figment::new()
        .join(Toml::file(args.config))
        .extract()
        .unwrap();

    config
        .dispatch_log()
        .expect("failed to set up logging: exiting");

    let poll_time = config.recursive_watch_poll_time;
    let handler = Arc::new(RwLock::new(config.setup().unwrap()));
    {
        let handler = handler.clone();
        thread::spawn(move || loop {
            thread::sleep(Duration::from_secs(poll_time));
            debug!("watch health check");

            let Ok(mut lock) = handler.write() else {
                continue;
            };

            lock.failed_watches = lock
                .failed_watches
                .clone()
                .drain()
                .filter(|watch| lock.add_watch(watch.clone(), None).is_err())
                .collect::<FailedWatches>();
        });
    }

    // TODO: evaluate these two .unwrap() calls
    let mut event_stream = handler.write().unwrap().get_event_stream();
    while let Ok(event) = event_stream.try_next().await {
        let lock = handler.write();

        process_event(lock.unwrap(), event).await;
    }
}