Merge pull request #4507 from ElrondNetwork/new-p2p-version

New p2p version
multiversx · Sep 26, 2022 · 70e023f · 70e023f
2 parents 254cfca + 9206bcf
commit 70e023f
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 3 deletions.
diff --git a/go.mod b/go.mod
@@ -11,7 +11,7 @@ require (
 	github.com/ElrondNetwork/elrond-go-core v1.1.20
 	github.com/ElrondNetwork/elrond-go-crypto v1.2.1
 	github.com/ElrondNetwork/elrond-go-logger v1.0.7
-	github.com/ElrondNetwork/elrond-go-p2p v0.0.0-20220922154302-6ae387450717
+	github.com/ElrondNetwork/elrond-go-p2p v1.0.1
 	github.com/ElrondNetwork/elrond-go-storage v1.0.1
 	github.com/ElrondNetwork/elrond-vm-common v1.3.17
 	github.com/beevik/ntp v0.3.0

diff --git a/go.sum b/go.sum
@@ -71,8 +71,8 @@ github.com/ElrondNetwork/elrond-go-logger v1.0.4/go.mod h1:e5D+c97lKUfFdAzFX7rrI
 github.com/ElrondNetwork/elrond-go-logger v1.0.5/go.mod h1:cBfgx0ST/CJx8jrxJSC5aiSrvkGzcnF7sK06RD8mFxQ=
 github.com/ElrondNetwork/elrond-go-logger v1.0.7 h1:Ldl1rVS0RGKc1IsW8jIaGCb6Zwei04gsMvyjL05X6mE=
 github.com/ElrondNetwork/elrond-go-logger v1.0.7/go.mod h1:cBfgx0ST/CJx8jrxJSC5aiSrvkGzcnF7sK06RD8mFxQ=
-github.com/ElrondNetwork/elrond-go-p2p v0.0.0-20220922154302-6ae387450717 h1:FBLNFSb9qgtGvR5TfzqWaJsm5zIvTnbd98B/A7nN6y8=
-github.com/ElrondNetwork/elrond-go-p2p v0.0.0-20220922154302-6ae387450717/go.mod h1:cJWOF4Ek2hBq7LOLS9zMoybuOXblBnWPcsV6dBjsTyc=
+github.com/ElrondNetwork/elrond-go-p2p v1.0.1 h1:1ZwkIL3LVBUt1oPDvl1VKNA3f7muW2D1Wh3AW4YokwY=
+github.com/ElrondNetwork/elrond-go-p2p v1.0.1/go.mod h1:cJWOF4Ek2hBq7LOLS9zMoybuOXblBnWPcsV6dBjsTyc=
 github.com/ElrondNetwork/elrond-go-storage v1.0.1 h1:T5pmTAu97aFNbUPpqxJprBEOs+uWsTaJSbCwY9xWPRA=
 github.com/ElrondNetwork/elrond-go-storage v1.0.1/go.mod h1:Dht8Vt0BJvyUrr+mDSjYo2pu2fIMZfmUa0yznPG9zGw=
 github.com/ElrondNetwork/elrond-vm-common v1.1.0/go.mod h1:w3i6f8uiuRkE68Ie/gebRcLgTuHqvruJSYrFyZWuLrE=

diff --git a/testscommon/p2pmocks/messengerStub.go b/testscommon/p2pmocks/messengerStub.go
@@ -42,6 +42,8 @@ type MessengerStub struct {
 	WaitForConnectionsCalled               func(maxWaitingTime time.Duration, minNumOfPeers uint32)
 	SignCalled                             func(payload []byte) ([]byte, error)
 	VerifyCalled                           func(payload []byte, pid core.PeerID, signature []byte) error
+	BroadcastUsingPrivateKeyCalled         func(topic string, buff []byte, pid core.PeerID, skBytes []byte)
+	SignUsingPrivateKeyCalled              func(skBytes []byte, payload []byte) ([]byte, error)
 }
 
 // ConnectedFullHistoryPeersOnTopic -
@@ -335,6 +337,22 @@ func (ms *MessengerStub) Verify(payload []byte, pid core.PeerID, signature []byt
 	return nil
 }
 
+// BroadcastUsingPrivateKey -
+func (ms *MessengerStub) BroadcastUsingPrivateKey(topic string, buff []byte, pid core.PeerID, skBytes []byte) {
+	if ms.BroadcastUsingPrivateKeyCalled != nil {
+		ms.BroadcastUsingPrivateKeyCalled(topic, buff, pid, skBytes)
+	}
+}
+
+// SignUsingPrivateKey -
+func (ms *MessengerStub) SignUsingPrivateKey(skBytes []byte, payload []byte) ([]byte, error) {
+	if ms.SignUsingPrivateKeyCalled != nil {
+		return ms.SignUsingPrivateKeyCalled(skBytes, payload)
+	}
+
+	return make([]byte, 0), nil
+}
+
 // IsInterfaceNil returns true if there is no value under the interface
 func (ms *MessengerStub) IsInterfaceNil() bool {
 	return ms == nil