#![allow(clippy::collapsible_if, clippy::new_without_default)]

pub mod common;
mod config;
pub mod controller;
mod dial_device;
mod error;
mod fake_input;

use std::sync::mpsc;

use crate::controller::DialController;
use crate::dial_device::DialDevice;
use crate::error::Result;

use notify_rust::{Hint, Notification, Timeout};
use signal_hook::{iterator::Signals, SIGINT, SIGTERM};

fn main() {
    let (kill_notif_tx, kill_notif_rx) = mpsc::channel::<Option<(String, &'static str)>>();

    let handle = std::thread::spawn(move || {
        let active_notification = Notification::new()
            .hint(Hint::Resident(true))
            .hint(Hint::Category("device".into()))
            .timeout(Timeout::Never)
            .summary("Surface Dial")
            .body("Active!")
            .icon("media-optical") // it should be vaguely circular :P
            .show()
            .expect("failed to send notification");

        let kill_notif = kill_notif_rx.recv();

        active_notification.close();

        let (msg, icon) = match kill_notif {
            Ok(None) => {
                // shutdown immediately
                std::process::exit(1);
            }
            Ok(Some((msg, icon))) => (msg, icon),
            Err(_) => ("Unexpected Error".into(), "dialog-error"),
        };

        Notification::new()
            .hint(Hint::Transient(true))
            .hint(Hint::Category("device".into()))
            .timeout(Timeout::Milliseconds(100))
            .summary("Surface Dial")
            .body(&msg)
            .icon(icon)
            .show()
            .unwrap();

        std::process::exit(1);
    });

    std::thread::spawn({
        let kill_notif_tx = kill_notif_tx.clone();
        move || {
            let signals = Signals::new(&[SIGTERM, SIGINT]).unwrap();
            for sig in signals.forever() {
                eprintln!("received signal {:?}", sig);
                match kill_notif_tx.send(Some(("Terminated!".into(), "dialog-warning"))) {
                    Ok(_) => {}
                    Err(_) => std::process::exit(1),
                }
            }
        }
    });

    if let Err(e) = true_main() {
        println!("{}", e);
    }

    let _ = kill_notif_tx.send(None); // silently shut down
    let _ = handle.join();
}

fn true_main() -> Result<()> {
    println!("Started");

    let cfg = config::Config::from_disk()?;

    let dial = DialDevice::new(std::time::Duration::from_millis(750))?;
    println!("Found the dial");

    let mut controller = DialController::new(
        dial,
        cfg.last_mode,
        vec![
            // Box::new(controller::controls::ScrollMT::new()),
            Box::new(controller::controls::Scroll::new()),
            Box::new(controller::controls::Zoom::new()),
            Box::new(controller::controls::Volume::new()),
            Box::new(controller::controls::Media::new()),
            Box::new(controller::controls::Paddle::new()),
        ],
    );

    controller.run()
}