use std::collections::HashMap;

use futures::{executor::block_on_stream, prelude::*};

use xpc_connection::{Message, XpcConnection};

#[test]
fn it_connects_to_bleud() {
    let mut xpc_connection = XpcConnection::new("com.apple.blued\0");

    let mut blocking_stream = block_on_stream(xpc_connection.connect().take(2));

    let message = Message::Dictionary({
        let mut dictionary = HashMap::new();
        dictionary.insert("kCBMsgId\0".to_string(), Message::Int64(1));
        dictionary.insert(
            "kCBMsgArgs\0".to_string(),
            Message::Dictionary({
                let mut temp = HashMap::new();
                temp.insert("kCBMsgArgAlert\0".to_string(), Message::Int64(1));
                temp.insert(
                    "kCBMsgArgName\0".to_string(),
                    Message::String("rust\0".to_string()),
                );
                temp
            }),
        );
        dictionary
    });

    // Can get data while the channel is open
    xpc_connection.send_message(message.clone());
    println!("Got data! {:?}", blocking_stream.next().unwrap());

    // Can't get data when the channel is closed by dropping `xpc_connection`
    xpc_connection.send_message(message);
    drop(xpc_connection);
    assert!(blocking_stream.next().is_none());
}