Function peer_connect

api/src/tests.rs:953–990

()

#[test(tokio::test)]
async fn peer_connect() {
    let node_id = NodeKey::random().id();
    let network = Network::InMemory;
    let mut mock_p2p_svc = MockP2PService::new();
    let addresses = vec![
        "/ip4/127.0.0.1/tcp/4101/p2p/12D3KooWPFGbRHWfDaWt5MFFeqAHBBq3v5BqeJ4X7pmn2V1t6uNs",
        "/ip4/127.0.0.1/udp/4111/quic-v1",
    ];
    let addrs = addresses
        .iter()
        .map(|addr| addr.parse())
        .collect::<Result<Vec<_>, _>>()
        .unwrap();
    mock_p2p_svc
        .expect_peer_connect()
        .once()
        .with(predicate::eq(addrs))
        .returning(|_| Ok(()));
    let server = create_test_server(
        node_id,
        network,
        MockAccessInterestStoreTest::new(),
        Arc::new(MockEventStoreTest::new()),
        mock_p2p_svc,
        None,
    );
    let result = server
        .peers_post(
            &addresses.into_iter().map(ToOwned::to_owned).collect(),
            &Context,
        )
        .await
        .unwrap();
    expect![[r#"
        Success
    "#]]
    .assert_debug_eq(&result);
}
#[test(tokio::test)]
async fn peer_connect_no_peer_id() {
    let node_id = NodeKey::random().id();