Feat: Pushed updates related to changes in the hive.go (#314)

go.mod

@@ -10,7 +10,7 @@ require (
 	github.com/googollee/go-engine.io v1.4.3-0.20190924125625-798118fc0dd2
 	github.com/googollee/go-socket.io v1.4.3-0.20191204093753-683f8725b6d0
 	github.com/gorilla/websocket v1.4.1
-	github.com/iotaledger/hive.go v0.0.0-20200326163241-4aa5b4d3b5b0
+	github.com/iotaledger/hive.go v0.0.0-20200328153852-4d06dcf6bf29
 	github.com/iotaledger/iota.go v1.0.0-beta.14
 	github.com/labstack/echo v3.3.10+incompatible
 	github.com/labstack/gommon v0.3.0 // indirect

go.sum

@@ -130,8 +130,8 @@ github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T
 github.com/hpcloud/tail v1.0.0 h1:nfCOvKYfkgYP8hkirhJocXT2+zOD8yUNjXaWfTlyFKI=
 github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
 github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
-github.com/iotaledger/hive.go v0.0.0-20200326163241-4aa5b4d3b5b0 h1:ADYgndjbLPrCxxoCfHItxb6RjB3dzFxHlQ+mrqk16g8=
-github.com/iotaledger/hive.go v0.0.0-20200326163241-4aa5b4d3b5b0/go.mod h1:4sloxRutRhCuXgAgtOu1ZxVM95Na+ovK9MRDEQGZlzw=
+github.com/iotaledger/hive.go v0.0.0-20200328153852-4d06dcf6bf29 h1:rKw/dp9FnM15e4lzEYwcpxX1lHE0Q06XeIgPskzF9vA=
+github.com/iotaledger/hive.go v0.0.0-20200328153852-4d06dcf6bf29/go.mod h1:4sloxRutRhCuXgAgtOu1ZxVM95Na+ovK9MRDEQGZlzw=
 github.com/iotaledger/iota.go v1.0.0-beta.9/go.mod h1:F6WBmYd98mVjAmmPVYhnxg8NNIWCjjH8VWT9qvv3Rc8=
 github.com/iotaledger/iota.go v1.0.0-beta.14 h1:Oeb28MfBuJEeXcGrLhTCJFtbsnc8y1u7xidsAmiOD5A=
 github.com/iotaledger/iota.go v1.0.0-beta.14/go.mod h1:F6WBmYd98mVjAmmPVYhnxg8NNIWCjjH8VWT9qvv3Rc8=

packages/binary/messagelayer/message/message.go

@@ -261,7 +261,9 @@ func (transaction *Message) UnmarshalObjectStorageValue(data []byte) (err error,
 	if transaction.branchTransactionId, err = ParseId(marshalUtil); err != nil {
 		return
 	}
-	// TODO PARSE PUBLIC KEY
+	if transaction.issuerPublicKey, err = ed25519.ParsePublicKey(marshalUtil); err != nil {
+		return
+	}
 	if transaction.issuingTime, err = marshalUtil.ReadTime(); err != nil {
 		return
 	}
@@ -271,7 +273,9 @@ func (transaction *Message) UnmarshalObjectStorageValue(data []byte) (err error,
 	if transaction.payload, err = payload.Parse(marshalUtil); err != nil {
 		return
 	}
-	// TODO PARSE SIGNATURE
+	if transaction.signature, err = ed25519.ParseSignature(marshalUtil); err != nil {
+		return
+	}
 
 	// return the number of bytes we processed
 	consumedBytes = marshalUtil.ReadOffset()

packages/gossip/neighbor_test.go

@@ -131,7 +131,7 @@ func newTestPeer(name string, conn net.Conn) *peer.Peer {
 	var publicKey ed25519.PublicKey
 	copy(publicKey[:], name)
 
-	return peer.NewPeer(identity.NewIdentity(publicKey), net.IPv4zero, services)
+	return peer.NewPeer(identity.New(publicKey), net.IPv4zero, services)
 }
 
 func newPipe() (net.Conn, net.Conn, func()) {

plugins/autopeering/autopeering.go

@@ -171,7 +171,7 @@ func parseEntryNodes() (result []*peer.Peer, err error) {
 		services := service.New()
 		services.Update(service.PeeringKey, addr.Network(), addr.Port)
 
-		result = append(result, peer.NewPeer(identity.NewIdentity(publicKey), addr.IP, services))
+		result = append(result, peer.NewPeer(identity.New(publicKey), addr.IP, services))
 	}
 
 	return result, nil