use rustupolis::tuple;
use rustupolis::tuple::E;
use rustupolis_server::client::Client;

fn main() {
    let mut client = Client::new();
    let server_tcp_name = String::from("TCP_server");
    let server_udp_name = String::from("UDP_server");
    let admin_attribute = String::from("admin");
    let tuple_space_name = String::from("DATA");
    let tuple_space_name_mean = String::from("tuple_space_mean");
    let attribute = String::from("admin");
    let key = "an_example_very_";

    client.connect(
        String::from("127.0.0.1"),
        String::from("9000"),
        String::from("tcp"),
        &server_tcp_name,
        key,
    );
    client.connect(
        String::from("127.0.0.1"),
        String::from("9001"),
        String::from("udp"),
        &server_udp_name,
        key,
    );

    client.create(
        &server_tcp_name,
        vec![attribute.clone()],
        &tuple_space_name,
        &admin_attribute,
    );
    client.create(
        &server_udp_name,
        vec![attribute.clone()],
        &tuple_space_name_mean,
        &admin_attribute,
    );

    client.attach(&server_tcp_name, vec![attribute.clone()], &tuple_space_name);

    client.out(vec![
        tuple![E::str("temp"), E::I(21),],
        tuple![E::str("temp"), E::I(23),],
        tuple![E::str("temp"), E::I(29),],
        tuple![E::str("temp"), E::I(25),],
        tuple![E::str("temp"), E::I(20),],
    ]);

    let mut data = client.in_instr(vec![
        tuple![E::str("temp"), E::Any],
        tuple![E::str("temp"), E::Any],
        tuple![E::str("temp"), E::Any],
        tuple![E::str("temp"), E::Any],
        tuple![E::str("temp"), E::Any],
    ]);
    let mut sum = 0;
    let mut nb_tuple = 0;

    while !data.is_empty() {
        if let E::T(tuple) = data.first() {
            if let E::I(nbr) = tuple.rest().first() {
                sum += nbr;
                nb_tuple += 1;
                data = data.rest();
            }
        }
    }

    let mean:f64 = (sum) as f64 / (nb_tuple) as f64;

    client.in_instr(vec![tuple![E::str("state"),E::Any]]);
    client.out(vec![tuple!(E::str("state"),E::str("state"))]);
    client.in_instr(vec![tuple![E::Any]]);

    client.attach(&server_udp_name, vec![attribute.clone()], &tuple_space_name_mean);

    client.out(vec![tuple!(E::D(mean))])
}