// Copyright (C) 2017 Sebastian Dröge <sebastian@centricular.com>
//
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
// option. This file may not be copied, modified, or distributed
// except according to those terms.

use glib;
use glib::{IsA, Cast};
use glib::translate::ToGlibPtr;
use glib::signal::SignalHandlerId;
use glib::object::ObjectExt;

use gobject_ffi;

use std::ffi::CStr;

pub trait GstObjectExtManual {
    fn connect_deep_notify<F: Fn(&Self, &::Object, &str) + Send + Sync + 'static>(
        &self,
        f: F,
    ) -> SignalHandlerId;
}

impl<O: IsA<::Object> + IsA<glib::Object> + glib::value::SetValue> GstObjectExtManual for O {
    fn connect_deep_notify<F: Fn(&Self, &::Object, &str) + Send + Sync + 'static>(
        &self,
        f: F,
    ) -> SignalHandlerId {
        self.connect("deep-notify", false, move |values| {
            let obj: O = values[0]
                .get::<glib::Object>()
                .unwrap()
                .downcast()
                .unwrap();
            let prop_obj: ::Object = values[1].get().unwrap();

            let prop_name = unsafe {
                let pspec = gobject_ffi::g_value_get_param(values[2].to_glib_none().0);
                CStr::from_ptr((*pspec).name).to_str().unwrap()
            };

            f(&obj, &prop_obj, prop_name);

            None
        }).unwrap()
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use prelude::*;
    use std::sync::{Arc, Mutex};

    #[test]
    fn test_deep_notify() {
        ::init().unwrap();

        let bin = ::Bin::new(None);
        let identity = ::ElementFactory::make("identity", "id").unwrap();
        bin.add(&identity).unwrap();

        let notify = Arc::new(Mutex::new(None));
        let notify_clone = notify.clone();
        bin.connect_deep_notify(move |_, id, prop| {
            *notify_clone.lock().unwrap() = Some((id.clone(), String::from(prop)));
        });

        identity.set_property("silent", &false).unwrap();
        assert_eq!(
            *notify.lock().unwrap(),
            Some((identity.upcast::<::Object>(), String::from("silent")))
        );
    }
}