use std::sync::atomic::Ordering;
use std::sync::Arc;
use std::time::{Duration, SystemTime};

use adw::glib::Object;
use adw::prelude::{ComboRowExt, PreferencesGroupExt};
use adw::subclass::prelude::ObjectSubclassIsExt;
use dbus::blocking::Connection;
use dbus::message::SignalArgs;
use dbus::{Error, Path};
use glib::prelude::Cast;
use glib::property::PropertySet;
use glib::{clone, ControlFlow};
use gtk::glib::Variant;
use gtk::prelude::{ActionableExt, ButtonExt, ListBoxRowExt, WidgetExt};
use gtk::{gio, StringObject};
use re_set_lib::bluetooth::bluetooth_structures::{BluetoothAdapter, BluetoothDevice};
use re_set_lib::signals::{BluetoothDeviceAdded, BluetoothDeviceChanged, BluetoothDeviceRemoved};

use crate::components::base::error_impl::{show_error, ReSetErrorImpl};
use crate::components::base::utils::Listeners;
use crate::components::bluetooth::bluetooth_box_impl;
use crate::components::bluetooth::bluetooth_entry::BluetoothEntry;
use crate::components::utils::{BASE, BLUETOOTH, DBUS_PATH};

use super::bluetooth_event_handlers::{
    device_added_handler, device_changed_handler, device_removed_handler,
};

glib::wrapper! {
    pub struct BluetoothBox(ObjectSubclass<bluetooth_box_impl::BluetoothBox>)
    @extends gtk::Box, gtk::Widget,
    @implements gtk::Accessible, gtk::Buildable, gtk::ConstraintTarget, gtk::Orientable;
}

unsafe impl Send for BluetoothBox {}
unsafe impl Sync for BluetoothBox {}

impl ReSetErrorImpl for BluetoothBox {
    fn error(
        &self,
    ) -> &gtk::subclass::prelude::TemplateChild<crate::components::base::error::ReSetError> {
        &self.imp().error
    }
}

impl BluetoothBox {
    pub fn new(listeners: Arc<Listeners>) -> Arc<Self> {
        let obj: Arc<Self> = Arc::new(Object::builder().build());
        setup_callbacks(listeners, obj)
    }
}

// TODO
// handle bonded -> this means saved but not connected
// handle rssi below x -> don't show device

fn setup_callbacks(
    listeners: Arc<Listeners>,
    bluetooth_box: Arc<BluetoothBox>,
) -> Arc<BluetoothBox> {
    let bluetooth_box_ref = bluetooth_box.clone();
    let listeners_ref = listeners.clone();
    let imp = bluetooth_box.imp();
    imp.reset_switch_initial.set(true);
    imp.reset_visibility.set_activatable(true);
    imp.reset_visibility
        .set_action_name(Some("navigation.push"));
    imp.reset_visibility
        .set_action_target_value(Some(&Variant::from("visibility")));

    imp.reset_bluetooth_main_tab.set_activatable(true);
    imp.reset_bluetooth_main_tab
        .set_action_name(Some("navigation.pop"));

    imp.reset_bluetooth_refresh_button.set_sensitive(false);
    imp.reset_bluetooth_refresh_button
        .connect_clicked(move |button| {
            button.set_sensitive(false);
            listeners
                .bluetooth_scan_requested
                .store(true, Ordering::SeqCst);
        });

    let bluetooth_box_discover = bluetooth_box.clone();
    imp.reset_bluetooth_discoverable_switch
        .connect_active_notify(clone!(@weak imp => move |state| {
            set_bluetooth_adapter_visibility(
                imp.reset_current_bluetooth_adapter.borrow().path.clone(),
                state.is_active(),
                bluetooth_box_discover.clone()
            );
        }));

    let bluetooth_box_pairable = bluetooth_box.clone();
    imp.reset_bluetooth_pairable_switch
        .connect_active_notify(clone!(@weak imp => move |state| {
            set_bluetooth_adapter_pairability(
                imp.reset_current_bluetooth_adapter.borrow().path.clone(),
                state.is_active(),
                bluetooth_box_pairable.clone()
            );
        }));

    imp.reset_bluetooth_switch
        .connect_state_set(move |_, state| {
            bluetooth_enabled_switch_handler(
                state,
                bluetooth_box_ref.clone(),
                listeners_ref.clone(),
            )
        });
    bluetooth_box
}

fn bluetooth_enabled_switch_handler(
    state: bool,
    bluetooth_box_ref: Arc<BluetoothBox>,
    listeners_ref: Arc<Listeners>,
) -> glib::Propagation {
    let imp = bluetooth_box_ref.imp();
    if imp.reset_switch_initial.load(Ordering::SeqCst) {
        return glib::Propagation::Proceed;
    }
    if !state {
        let mut available_devices = imp.available_devices.borrow_mut();
        let mut current_adapter = imp.reset_current_bluetooth_adapter.borrow_mut();
        for entry in available_devices.iter() {
            imp.reset_bluetooth_available_devices.remove(&**entry.1);
        }
        available_devices.clear();

        let mut connected_devices = imp.connected_devices.borrow_mut();
        for entry in connected_devices.iter() {
            imp.reset_bluetooth_connected_devices.remove(&**entry.1);
        }
        connected_devices.clear();

        imp.reset_bluetooth_pairable_switch.set_active(false);
        imp.reset_bluetooth_pairable_switch.set_sensitive(false);
        imp.reset_bluetooth_discoverable_switch.set_active(false);
        imp.reset_bluetooth_discoverable_switch.set_sensitive(false);
        imp.reset_bluetooth_refresh_button.set_sensitive(false);

        listeners_ref
            .bluetooth_listener
            .store(false, Ordering::SeqCst);
        let res = set_adapter_enabled(
            current_adapter.path.clone(),
            false,
            bluetooth_box_ref.clone(),
        );
        if res {
            current_adapter.powered = false;
        }
    } else {
        let restart_ref = bluetooth_box_ref.clone();
        let restart_listener_ref = listeners_ref.clone();
        {
            let imp = bluetooth_box_ref.imp();
            imp.reset_bluetooth_discoverable_switch.set_sensitive(true);
            imp.reset_bluetooth_pairable_switch.set_sensitive(true);
        }
        gio::spawn_blocking(move || {
            let mut current_adapter = restart_ref
                .imp()
                .reset_current_bluetooth_adapter
                .borrow_mut();
            if set_adapter_enabled(current_adapter.path.clone(), true, restart_ref.clone()) {
                current_adapter.powered = true;
                start_bluetooth_listener(restart_listener_ref.clone(), restart_ref.clone());
            }
        });
    }
    glib::Propagation::Proceed
}

pub fn populate_connected_bluetooth_devices(bluetooth_box: Arc<BluetoothBox>) {
    // TODO handle saved devices -> they also exist
    gio::spawn_blocking(move || {
        let ref_box = bluetooth_box.clone();
        let devices = get_connected_devices(ref_box.clone());
        let adapters = get_bluetooth_adapters(ref_box.clone());
        {
            let imp = bluetooth_box.imp();
            let list = imp.reset_model_list.write().unwrap();
            let mut model_index = imp.reset_model_index.write().unwrap();
            let mut map = imp.reset_bluetooth_adapters.write().unwrap();
            if adapters.is_empty() {
                return;
            }
            imp.reset_current_bluetooth_adapter
                .replace(adapters.last().unwrap().clone());
            for (index, adapter) in adapters.into_iter().enumerate() {
                list.append(&adapter.alias);
                map.insert(adapter.alias.clone(), (adapter, index as u32));
                *model_index += 1;
            }
        }
        glib::spawn_future(async move {
            glib::idle_add_once(move || {
                let new_adapter_ref = ref_box.clone();
                let imp = ref_box.imp();

                let list = imp.reset_model_list.read().unwrap();
                imp.reset_bluetooth_adapter.set_model(Some(&*list));
                let map = imp.reset_bluetooth_adapters.read().unwrap();
                let device = imp.reset_current_bluetooth_adapter.borrow();
                if let Some(index) = map.get(&device.alias) {
                    imp.reset_bluetooth_adapter.set_selected(index.1);
                }

                {
                    let current_adapter = imp.reset_current_bluetooth_adapter.borrow();
                    let powered = current_adapter.powered;
                    imp.reset_bluetooth_switch.set_state(powered);
                    imp.reset_bluetooth_switch.set_active(powered);
                    imp.reset_bluetooth_discoverable_switch
                        .set_active(current_adapter.discoverable);
                    imp.reset_bluetooth_pairable_switch
                        .set_active(current_adapter.pairable);
                    imp.reset_switch_initial.set(false);
                }

                imp.reset_bluetooth_adapter
                    .connect_selected_notify(move |dropdown| {
                        select_bluetooth_adapter_handler(dropdown, new_adapter_ref.clone());
                    });

                for device in devices {
                    let path = device.path.clone();
                    let connected = device.connected;
                    let bluetooth_entry = BluetoothEntry::new(device, ref_box.clone());
                    imp.available_devices
                        .borrow_mut()
                        .insert(path, bluetooth_entry.clone());
                    if connected {
                        imp.reset_bluetooth_connected_devices.add(&*bluetooth_entry);
                    } else {
                        imp.reset_bluetooth_available_devices.add(&*bluetooth_entry);
                    }
                }
            });
        });
    });
}

fn select_bluetooth_adapter_handler(
    dropdown: &adw::ComboRow,
    bluetooth_box: Arc<BluetoothBox>,
) -> ControlFlow {
    let imp = bluetooth_box.imp();
    let selected = dropdown.selected_item();
    if selected.is_none() {
        return ControlFlow::Break;
    }
    let selected = selected.unwrap();
    let selected = selected.downcast_ref::<StringObject>().unwrap();
    let selected = selected.string().to_string();
    let device = imp.reset_bluetooth_adapters.read().unwrap();
    let device = device.get(&selected);
    if device.is_none() {
        return ControlFlow::Break;
    }
    set_bluetooth_adapter(device.unwrap().0.path.clone(), bluetooth_box.clone());

    ControlFlow::Continue
}

pub fn start_bluetooth_listener(listeners: Arc<Listeners>, bluetooth_box: Arc<BluetoothBox>) {
    gio::spawn_blocking(move || {
        if listeners.bluetooth_listener.load(Ordering::SeqCst) {
            return;
        }
        let imp = bluetooth_box.imp();

        if !imp.reset_current_bluetooth_adapter.borrow().powered {
            return;
        }

        let device_added_box = bluetooth_box.clone();
        let device_removed_box = bluetooth_box.clone();
        let device_changed_box = bluetooth_box.clone();
        let loop_box = bluetooth_box.clone();

        let conn = Connection::new_session().unwrap();
        let proxy = conn.with_proxy(BASE, DBUS_PATH, Duration::from_millis(1000));
        let res: Result<(), Error> = proxy.method_call(BLUETOOTH, "StartBluetoothListener", ());
        if res.is_err() {
            show_error::<BluetoothBox>(bluetooth_box.clone(), "Failed to start bluetooth listener");
        }
        imp.reset_bluetooth_available_devices
            .set_description(Some("Scanning..."));
        let device_added =
            BluetoothDeviceAdded::match_rule(Some(&BASE.into()), Some(&Path::from(DBUS_PATH)))
                .static_clone();
        let device_removed =
            BluetoothDeviceRemoved::match_rule(Some(&BASE.into()), Some(&Path::from(DBUS_PATH)))
                .static_clone();
        let device_changed =
            BluetoothDeviceChanged::match_rule(Some(&BASE.into()), Some(&Path::from(DBUS_PATH)))
                .static_clone();

        let res = conn.add_match(device_added, move |ir: BluetoothDeviceAdded, _, _| {
            device_added_handler(device_added_box.clone(), ir)
        });
        if res.is_err() {
            println!("fail on bluetooth device add event");
            return;
        }

        let res = conn.add_match(device_removed, move |ir: BluetoothDeviceRemoved, _, _| {
            device_removed_handler(device_removed_box.clone(), ir)
        });
        if res.is_err() {
            println!("fail on bluetooth device remove event");
            return;
        }

        let res = conn.add_match(device_changed, move |ir: BluetoothDeviceChanged, _, _| {
            device_changed_handler(device_changed_box.clone(), ir)
        });
        if res.is_err() {
            println!("fail on bluetooth device remove event");
            return;
        }

        listeners.bluetooth_listener.store(true, Ordering::SeqCst);
        let time = SystemTime::now();
        let listener_active = true;

        bluetooth_listener_loop(
            &conn,
            listeners,
            proxy,
            bluetooth_box,
            loop_box,
            listener_active,
            time,
        );
    });
}

fn bluetooth_listener_loop(
    conn: &Connection,
    listeners: Arc<Listeners>,
    proxy: dbus::blocking::Proxy<'_, &Connection>,
    bluetooth_box: Arc<BluetoothBox>,
    loop_box: Arc<BluetoothBox>,
    mut listener_active: bool,
    mut time: SystemTime,
) {
    loop {
        let _ = conn.process(Duration::from_millis(1000));
        if !listeners.bluetooth_listener.load(Ordering::SeqCst) {
            let res: Result<(), Error> = proxy.method_call(BLUETOOTH, "StopBluetoothListener", ());
            if res.is_err() {
                show_error::<BluetoothBox>(
                    bluetooth_box.clone(),
                    "Failed to stop bluetooth listener",
                );
            }
            loop_box
                .imp()
                .reset_bluetooth_available_devices
                .set_description(None);
            break;
        }
        if listener_active && time.elapsed().unwrap() > Duration::from_millis(10000) {
            listener_active = false;
            let instance_ref = loop_box.clone();
            glib::spawn_future(async move {
                glib::idle_add_once(move || {
                    instance_ref
                        .imp()
                        .reset_bluetooth_refresh_button
                        .set_sensitive(true);
                });
            });
            let res: Result<(), Error> = proxy.method_call(BLUETOOTH, "StopBluetoothScan", ());
            if res.is_err() {
                show_error::<BluetoothBox>(
                    bluetooth_box.clone(),
                    "Failed to stop bluetooth listener",
                );
            }
            loop_box
                .imp()
                .reset_bluetooth_available_devices
                .set_description(None);
        }
        if !listener_active && listeners.bluetooth_scan_requested.load(Ordering::SeqCst) {
            listeners
                .bluetooth_scan_requested
                .store(false, Ordering::SeqCst);
            listener_active = true;
            let res: Result<(), Error> = proxy.method_call(BLUETOOTH, "StartBluetoothListener", ());
            if res.is_err() {
                show_error::<BluetoothBox>(
                    bluetooth_box.clone(),
                    "Failed to start bluetooth listener",
                );
            }
            loop_box
                .imp()
                .reset_bluetooth_available_devices
                .set_description(Some("Scanning..."));
            time = SystemTime::now();
        }
    }
}

fn get_connected_devices(bluetooth_box: Arc<BluetoothBox>) -> Vec<BluetoothDevice> {
    let conn = Connection::new_session().unwrap();
    let proxy = conn.with_proxy(BASE, DBUS_PATH, Duration::from_millis(1000));
    let res: Result<(Vec<BluetoothDevice>,), Error> =
        proxy.method_call(BLUETOOTH, "GetConnectedBluetoothDevices", ());
    if res.is_err() {
        show_error::<BluetoothBox>(
            bluetooth_box.clone(),
            "Failed to get connected bluetooth devices",
        );
        return Vec::new();
    }
    res.unwrap().0
}

fn get_bluetooth_adapters(bluetooth_box: Arc<BluetoothBox>) -> Vec<BluetoothAdapter> {
    let conn = Connection::new_session().unwrap();
    let proxy = conn.with_proxy(BASE, DBUS_PATH, Duration::from_millis(1000));
    let res: Result<(Vec<BluetoothAdapter>,), Error> =
        proxy.method_call(BLUETOOTH, "GetBluetoothAdapters", ());
    if res.is_err() {
        show_error::<BluetoothBox>(bluetooth_box.clone(), "Failed to get bluetooth adapters");
        return Vec::new();
    }
    res.unwrap().0
}

fn set_bluetooth_adapter(path: Path<'static>, bluetooth_box: Arc<BluetoothBox>) {
    let conn = Connection::new_session().unwrap();
    let proxy = conn.with_proxy(BASE, DBUS_PATH, Duration::from_millis(1000));
    let res: Result<(Path<'static>,), Error> =
        proxy.method_call(BLUETOOTH, "SetBluetoothAdapter", (path,));
    if res.is_err() {
        show_error::<BluetoothBox>(bluetooth_box.clone(), "Failed to set bluetooth adapter");
    }
}

fn set_bluetooth_adapter_visibility(
    path: Path<'static>,
    visible: bool,
    bluetooth_box: Arc<BluetoothBox>,
) {
    let conn = Connection::new_session().unwrap();
    let proxy = conn.with_proxy(BASE, DBUS_PATH, Duration::from_millis(1000));
    let res: Result<(bool,), Error> = proxy.method_call(
        BLUETOOTH,
        "SetBluetoothAdapterDiscoverability",
        (path, visible),
    );
    if res.is_err() {
        show_error::<BluetoothBox>(
            bluetooth_box.clone(),
            "Failed to set bluetooth adapter visibility",
        );
    }
}

fn set_bluetooth_adapter_pairability(
    path: Path<'static>,
    visible: bool,
    bluetooth_box: Arc<BluetoothBox>,
) {
    let conn = Connection::new_session().unwrap();
    let proxy = conn.with_proxy(BASE, DBUS_PATH, Duration::from_millis(1000));
    let res: Result<(bool,), Error> =
        proxy.method_call(BLUETOOTH, "SetBluetoothAdapterPairability", (path, visible));
    if res.is_err() {
        show_error::<BluetoothBox>(
            bluetooth_box.clone(),
            "Failed to set bluetooth adapter pairability",
        );
    }
}

fn set_adapter_enabled(
    path: Path<'static>,
    enabled: bool,
    bluetooth_box: Arc<BluetoothBox>,
) -> bool {
    let conn = Connection::new_session().unwrap();
    let proxy = conn.with_proxy(BASE, DBUS_PATH, Duration::from_millis(1000));
    let result: Result<(bool,), Error> =
        proxy.method_call(BLUETOOTH, "SetBluetoothAdapterEnabled", (path, enabled));
    if result.is_err() {
        show_error::<BluetoothBox>(bluetooth_box.clone(), "Failed to enable bluetooth adapter");
        return false;
    }
    result.unwrap().0
}