(t *testing.T)
| 11 | ) |
| 12 | |
| 13 | func TestPeerSetAddGetDel(t *testing.T) { |
| 14 | n1, n2 := newTestP2PNode(t), newTestP2PNode(t) |
| 15 | require.True(t, len(n1.PeerSet.m) == 0) |
| 16 | expected := &lib.PeerInfo{ |
| 17 | Address: &lib.PeerAddress{ |
| 18 | PublicKey: n2.pub, |
| 19 | NetAddress: "pipe", |
| 20 | }, |
| 21 | IsOutbound: true, |
| 22 | IsMustConnect: true, |
| 23 | IsTrusted: true, |
| 24 | Reputation: 10, |
| 25 | } |
| 26 | c1, c2 := net.Pipe() |
| 27 | defer c2.Close() |
| 28 | require.NoError(t, n1.PeerSet.Add(&Peer{PeerInfo: expected, conn: newTestMultiConnMock(t, n2.pub, c1, n1.P2P)})) |
| 29 | require.True(t, len(n1.PeerSet.m) == 1) |
| 30 | got, err := n1.PeerSet.GetPeerInfo(n2.pub) |
| 31 | require.NoError(t, err) |
| 32 | require.Equal(t, *expected, *got) |
| 33 | err = n1.PeerSet.Remove(n2.pub, 0) |
| 34 | require.NoError(t, err) |
| 35 | err = n1.PeerSet.Remove(n2.pub, 0) |
| 36 | require.Error(t, err) |
| 37 | _, err = n1.PeerSet.GetPeerInfo(n2.pub) |
| 38 | require.Error(t, err) |
| 39 | require.True(t, len(n1.PeerSet.m) == 0) |
| 40 | } |
| 41 | |
| 42 | func TestUpdateMustConnects(t *testing.T) { |
| 43 | n1, n2, n3 := newTestP2PNode(t), newTestP2PNode(t), newTestP2PNode(t) |
nothing calls this directly
no test coverage detected