woop/consensus/consensus_leader_test.go

package consensus

import (
	"harmony-benchmark/crypto"
	"harmony-benchmark/p2p"
	"testing"
)

func TestConstructAnnounceMessage(test *testing.T) {
	leader := p2p.Peer{Ip: "1", Port: "2"}
	validator := p2p.Peer{Ip: "3", Port: "5"}
	consensus := NewConsensus("1", "2", "0", []p2p.Peer{leader, validator}, leader)
	consensus.blockHash = [32]byte{}
	header := consensus.blockHeader
	msg := consensus.constructAnnounceMessage()

	if len(msg) != 1+1+1+4+32+2+4+64+len(header) {
		test.Errorf("Annouce message is not constructed in the correct size: %d", len(msg))
	}
}

func TestConstructChallengeMessage(test *testing.T) {
	leaderPriKey := crypto.Curve.Scalar()
	priKeyInBytes := crypto.Hash("12")
	leaderPriKey.UnmarshalBinary(priKeyInBytes[:]) // use ip:port as unique private key for now. TODO: use real private key
	leaderPubKey := crypto.GetPublicKeyFromScalar(crypto.Curve, leaderPriKey)
	leader := p2p.Peer{Ip: "1", Port: "2", PubKey: leaderPubKey}

	validatorPriKey := crypto.Curve.Scalar()
	priKeyInBytes = crypto.Hash("12")
	validatorPriKey.UnmarshalBinary(priKeyInBytes[:]) // use ip:port as unique private key for now. TODO: use real private key
	validatorPubKey := crypto.GetPublicKeyFromScalar(crypto.Curve, leaderPriKey)
	validator := p2p.Peer{Ip: "3", Port: "5", PubKey: validatorPubKey}

	consensus := NewConsensus("1", "2", "0", []p2p.Peer{leader, validator}, leader)
	consensus.blockHash = [32]byte{}
	consensus.commitments[0] = leaderPubKey
	consensus.commitments[1] = validatorPubKey
	consensus.bitmap.SetKey(leaderPubKey, true)
	consensus.bitmap.SetKey(validatorPubKey, true)

	msg := consensus.constructChallengeMessage()

	if len(msg) != 1+1+1+4+32+2+33+33+32+64 {
		test.Errorf("Annouce message is not constructed in the correct size: %d", len(msg))
	}
}