use super::*;

macro_rules! reset_nodes {
  ($layer:ident<$rt: ident> ($kind:literal, $expr: expr)) => {
    paste::paste! {
      #[test]
      fn [< test_ $rt:snake _ $kind:snake _reset_nodes >]() {
        use std::net::SocketAddr;

        [< $rt:snake _run >](async move {
          let mut t1_opts = NetTransportOptions::<SmolStr, _, $layer<[< $rt:camel Runtime >]>>::with_stream_layer_options("reset_nodes_node_1".into(), $expr);
          t1_opts.add_bind_address(next_socket_addr_v4(0));

          let t1 = NetTransport::<_, SocketAddrResolver<[< $rt:camel Runtime >]>, _, Lpe<_, _>, [< $rt:camel Runtime >]>::new(t1_opts).await.unwrap();
          let t1_opts = Options::lan();

          let mut addr: SocketAddr = "127.0.0.1:7969".parse().unwrap();
          addr.set_port(t1.advertise_address().port());
          let n1 = Node::new(
            "node1".into(),
            addr,
          );

          let mut addr: SocketAddr = "127.0.0.2:7969".parse().unwrap();
          addr.set_port(t1.advertise_address().port());
          let n2 = Node::new(
            "node2".into(),
            addr,
          );

          let mut addr: SocketAddr = "127.0.0.3:7969".parse().unwrap();
          addr.set_port(t1.advertise_address().port());
          let n3 = Node::new(
            "node3".into(),
            addr,
          );

          reset_nodes(t1, t1_opts, n1, n2, n3).await;
        });
      }
    }
  };
}

test_mods!(reset_nodes);