diff --git a/net/secureservice/secureservice.go b/net/secureservice/secureservice.go index 4c62bcdb..4487e9bc 100644 --- a/net/secureservice/secureservice.go +++ b/net/secureservice/secureservice.go @@ -53,7 +53,9 @@ type secureService struct { } func (s *secureService) Init(a *app.App) (err error) { - s.protoVersion = ProtoVersion + if s.protoVersion == 0 { + s.protoVersion = ProtoVersion + } account := a.MustComponent(commonaccount.CName).(commonaccount.Service) peerKey, err := account.Account().PeerKey.Raw() if err != nil { diff --git a/net/secureservice/secureservice_test.go b/net/secureservice/secureservice_test.go index 6aee985d..86735f66 100644 --- a/net/secureservice/secureservice_test.go +++ b/net/secureservice/secureservice_test.go @@ -57,7 +57,7 @@ func TestHandshake(t *testing.T) { func TestHandshakeIncompatibleVersion(t *testing.T) { nc := testnodeconf.GenNodeConfig(2) - fxS := newFixture(t, nc, nc.GetAccountService(0), 0) + fxS := newFixture(t, nc, nc.GetAccountService(0), 1) defer fxS.Finish(t) sc, cc := net.Pipe() @@ -72,7 +72,7 @@ func TestHandshakeIncompatibleVersion(t *testing.T) { ar.ctx, ar.err = fxS.SecureInbound(ctx, sc) resCh <- ar }() - fxC := newFixture(t, nc, nc.GetAccountService(1), 1) + fxC := newFixture(t, nc, nc.GetAccountService(1), 2) defer fxC.Finish(t) _, err := fxC.SecureOutbound(ctx, cc) require.Equal(t, handshake.ErrIncompatibleVersion, err)