Merge pull request #3303 from keep-network/chaosnet-client

Chaosnet support in the client

After adding chaosnet support to the sortition pool, we need to modify the
client to check the chaosnet state before attempting to join the sortition pool.

BetaOperatorPolicy is a JoinPolicy implementation checking chaosnet and beta
operator status. If chaosnet has been deactivated, the operator is allowed to
join the pool. If chaosnet is active and the operator is beta operator,
the operator is allowed to join the pool. If chaosnet is active and the operator
 is not beta operator, the operator is not allowed to join the pool.

The BetaOperatorPolicy is applied both to the random beacon and tbtc.

Author: tomaszslabon

pkg/beacon/beacon.go

@@ -51,7 +51,7 @@ func Initialize(
 			logger,
 			beaconChain,
 			sortition.DefaultStatusCheckTick,
-			sortition.UnconditionalJoinPolicy,
+			sortition.NewBetaOperatorPolicy(beaconChain, logger),
 		)
 		if err != nil {
 			return fmt.Errorf(

pkg/chain/ethereum/beacon.go

@@ -230,6 +230,17 @@ func (bc *BeaconChain) RestoreRewardEligibility() error {
 	return err
 }
 
+// Returns true if the chaosnet phase is active, false otherwise.
+func (bc *BeaconChain) IsChaosnetActive() (bool, error) {
+	return bc.sortitionPool.IsChaosnetActive()
+}
+
+// Returns true if operator is a beta operator, false otherwise.
+// Chaosnet status does not matter.
+func (bc *BeaconChain) IsBetaOperator() (bool, error) {
+	return bc.sortitionPool.IsBetaOperator(bc.key.Address)
+}
+
 // SelectGroup returns the group members for the group generated by
 // the given seed. This function can return an error if the beacon chain's
 // state does not allow for group selection at the moment.
@@ -281,17 +292,17 @@ func (bc *BeaconChain) IsStaleGroup(groupPublicKey []byte) (bool, error) {
 }
 
 // TODO: Implement a real OnDKGStarted event subscription. The current
-//       implementation generates a fake event every 500th block where the
-//       seed is the keccak256 of the block number.
+// implementation generates a fake event every 500th block where the
+// seed is the keccak256 of the block number.
 func (bc *BeaconChain) OnDKGStarted(
 	handler func(event *event.DKGStarted),
 ) subscription.EventSubscription {
 	return bc.mockRandomBeacon.OnDKGStarted(handler)
 }
 
 // TODO: Implement a real SubmitDKGResult action. The current implementation
-//       just creates and pipes the DKG submission event to the handlers
-//       registered in the dkgResultSubmissionHandlers map.
+// just creates and pipes the DKG submission event to the handlers
+// registered in the dkgResultSubmissionHandlers map.
 func (bc *BeaconChain) SubmitDKGResult(
 	participantIndex beaconchain.GroupMemberIndex,
 	dkgResult *beaconchain.DKGResult,
@@ -305,9 +316,9 @@ func (bc *BeaconChain) SubmitDKGResult(
 }
 
 // TODO: Implement a real OnDKGResultSubmitted event subscription. The current
-//       implementation just pipes the DKG submission event generated within
-//       SubmitDKGResult to the handlers registered in the
-//       dkgResultSubmissionHandlers map.
+// implementation just pipes the DKG submission event generated within
+// SubmitDKGResult to the handlers registered in the
+// dkgResultSubmissionHandlers map.
 func (bc *BeaconChain) OnDKGResultSubmitted(
 	handler func(event *event.DKGResultSubmission),
 ) subscription.EventSubscription {
@@ -422,7 +433,7 @@ func (bc *BeaconChain) CurrentRequestGroupPublicKey() ([]byte, error) {
 }
 
 // TODO: Temporary mock that simulates the behavior of the RandomBeacon
-//       contract. Should be removed eventually.
+// contract. Should be removed eventually.
 type mockRandomBeacon struct {
 	blockCounter chain.BlockCounter