dbm "github.com/vapor/database/leveldb"
"github.com/vapor/errors"
conn "github.com/vapor/p2p/connection"
+ "github.com/vapor/p2p/security"
"github.com/vapor/p2p/signlib"
)
//Test connect self.
func TestFiltersOutItself(t *testing.T) {
- t.Skip("skipping test")
+ t.Skip("due to fail on mac")
dirPath, err := ioutil.TempDir(".", "")
if err != nil {
t.Fatal(err)
testDB := dbm.NewDB("testdb", "leveldb", dirPath)
cfg := *testCfg
+ cfg.DBPath = dirPath
cfg.P2P.ListenAddress = "127.0.1.1:0"
swPrivKey, err := signlib.NewPrivKey()
if err != nil {
s1.Start()
defer s1.Stop()
+ rmdirPath, err := ioutil.TempDir(".", "")
+ if err != nil {
+ t.Fatal(err)
+ }
+ defer os.RemoveAll(rmdirPath)
+
// simulate s1 having a public key and creating a remote peer with the same key
rpCfg := *testCfg
+ rpCfg.DBPath = rmdirPath
rp := &remotePeer{PrivKey: s1.nodePrivKey, Config: &rpCfg}
rp.Start()
defer rp.Stop()
}
func TestDialBannedPeer(t *testing.T) {
- t.Skip("skipping test")
+ t.Skip("due to fail on mac")
dirPath, err := ioutil.TempDir(".", "")
if err != nil {
t.Fatal(err)
testDB := dbm.NewDB("testdb", "leveldb", dirPath)
cfg := *testCfg
+ cfg.DBPath = dirPath
cfg.P2P.ListenAddress = "127.0.1.1:0"
swPrivKey, err := signlib.NewPrivKey()
if err != nil {
s1.Start()
defer s1.Stop()
+ rmdirPath, err := ioutil.TempDir(".", "")
+ if err != nil {
+ t.Fatal(err)
+ }
+ defer os.RemoveAll(rmdirPath)
+
rpCfg := *testCfg
+ rpCfg.DBPath = rmdirPath
remotePrivKey, err := signlib.NewPrivKey()
if err != nil {
t.Fatal(err)
rp := &remotePeer{PrivKey: remotePrivKey, Config: &rpCfg}
rp.Start()
defer rp.Stop()
- s1.AddBannedPeer(rp.addr.IP.String())
- if err := s1.DialPeerWithAddress(rp.addr); errors.Root(err) != ErrConnectBannedPeer {
- t.Fatal(err)
+ for {
+ if ok := s1.security.IsBanned(rp.addr.IP.String(), security.LevelMsgIllegal, "test"); ok {
+ break
+ }
}
-
- s1.delBannedPeer(rp.addr.IP.String())
- if err := s1.DialPeerWithAddress(rp.addr); err != nil {
+ if err := s1.DialPeerWithAddress(rp.addr); errors.Root(err) != security.ErrConnectBannedPeer {
t.Fatal(err)
}
}
func TestDuplicateOutBoundPeer(t *testing.T) {
- t.Skip("skipping test")
+ t.Skip("due to fail on mac")
dirPath, err := ioutil.TempDir(".", "")
if err != nil {
t.Fatal(err)
testDB := dbm.NewDB("testdb", "leveldb", dirPath)
cfg := *testCfg
+ cfg.DBPath = dirPath
cfg.P2P.ListenAddress = "127.0.1.1:0"
swPrivKey, err := signlib.NewPrivKey()
if err != nil {
s1.Start()
defer s1.Stop()
+ rmdirPath, err := ioutil.TempDir(".", "")
+ if err != nil {
+ t.Fatal(err)
+ }
+ defer os.RemoveAll(rmdirPath)
+
rpCfg := *testCfg
+ rpCfg.DBPath = rmdirPath
remotePrivKey, err := signlib.NewPrivKey()
if err != nil {
t.Fatal(err)
}
func TestDuplicateInBoundPeer(t *testing.T) {
- t.Skip("skipping test")
+ t.Skip("due to fail on mac")
dirPath, err := ioutil.TempDir(".", "")
if err != nil {
t.Fatal(err)
testDB := dbm.NewDB("testdb", "leveldb", dirPath)
cfg := *testCfg
+ cfg.DBPath = dirPath
cfg.P2P.ListenAddress = "127.0.1.1:0"
swPrivKey, err := signlib.NewPrivKey()
if err != nil {
}
func TestAddInboundPeer(t *testing.T) {
- t.Skip("skipping test")
+ t.Skip("due to fail on mac")
dirPath, err := ioutil.TempDir(".", "")
if err != nil {
t.Fatal(err)
testDB := dbm.NewDB("testdb", "leveldb", dirPath)
cfg := *testCfg
+ cfg.DBPath = dirPath
cfg.P2P.MaxNumPeers = 2
cfg.P2P.ListenAddress = "127.0.1.1:0"
swPrivKey, err := signlib.NewPrivKey()
}
func TestStopPeer(t *testing.T) {
- t.Skip("skipping test")
+ t.Skip("due to fail on mac")
dirPath, err := ioutil.TempDir(".", "")
if err != nil {
t.Fatal(err)
testDB := dbm.NewDB("testdb", "leveldb", dirPath)
cfg := *testCfg
+ cfg.DBPath = dirPath
cfg.P2P.MaxNumPeers = 2
cfg.P2P.ListenAddress = "127.0.1.1:0"
swPrivKey, err := signlib.NewPrivKey()