You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
63 lines
2.1 KiB
63 lines
2.1 KiB
package drand
|
|
|
|
import (
|
|
protobuf "github.com/golang/protobuf/proto"
|
|
msg_pb "github.com/harmony-one/harmony/api/proto/message"
|
|
nodeconfig "github.com/harmony-one/harmony/internal/configs/node"
|
|
"github.com/harmony-one/harmony/internal/utils"
|
|
"github.com/harmony-one/harmony/p2p/host"
|
|
)
|
|
|
|
// ProcessMessageValidator dispatches messages for the validator to corresponding processors.
|
|
func (dRand *DRand) ProcessMessageValidator(payload []byte) {
|
|
message := &msg_pb.Message{}
|
|
err := protobuf.Unmarshal(payload, message)
|
|
|
|
if err != nil {
|
|
utils.Logger().Error().Interface("dRand", dRand).Err(err).Msg("Failed to unmarshal message payload")
|
|
}
|
|
|
|
switch message.Type {
|
|
case msg_pb.MessageType_DRAND_INIT:
|
|
dRand.processInitMessage(message)
|
|
case msg_pb.MessageType_DRAND_COMMIT:
|
|
// do nothing on the COMMIT message, as it is intended to send to leader
|
|
default:
|
|
utils.Logger().Error().
|
|
Interface("dRand", dRand).
|
|
Uint32("msgType", uint32(message.Type)).
|
|
Msg("Unexpected message type")
|
|
}
|
|
}
|
|
|
|
// ProcessMessageValidator dispatches validator's consensus message.
|
|
func (dRand *DRand) processInitMessage(message *msg_pb.Message) {
|
|
if message.Type != msg_pb.MessageType_DRAND_INIT {
|
|
utils.Logger().Error().
|
|
Uint32("expected", uint32(msg_pb.MessageType_DRAND_INIT)).
|
|
Uint32("got", uint32(message.Type)).
|
|
Msg("Wrong message type received")
|
|
return
|
|
}
|
|
|
|
drandMsg := message.GetDrand()
|
|
|
|
// Verify message signature
|
|
err := verifyMessageSig(dRand.leader.ConsensusPubKey, message)
|
|
if err != nil {
|
|
utils.Logger().Warn().Err(err).Msg("[DRG] Failed to verify the message signature")
|
|
return
|
|
}
|
|
utils.Logger().Debug().Msg("[DRG] verify the message signature Succeeded")
|
|
|
|
// TODO: check the blockHash is the block hash of last block of last epoch.
|
|
blockHash := drandMsg.BlockHash
|
|
copy(dRand.blockHash[:], blockHash[:])
|
|
|
|
rand, proof := dRand.vrf(dRand.blockHash)
|
|
|
|
msgToSend := dRand.constructCommitMessage(rand, proof)
|
|
|
|
// Send the commit message back to leader
|
|
dRand.host.SendMessageToGroups([]nodeconfig.GroupID{nodeconfig.NewGroupIDByShardID(nodeconfig.ShardID(dRand.ShardID))}, host.ConstructP2pMessage(byte(17), msgToSend))
|
|
}
|
|
|