bet

examples/berad/pkg/state-transition/interfaces.go

@@ -93,6 +93,9 @@ type ReadOnlyBeaconState[
 	ValidatorIndexByCometBFTAddress(
 		cometBFTAddress []byte,
 	) (math.ValidatorIndex, error)
+	ValidatorIndexByPubkey(
+		crypto.BLSPubkey,
+	) (math.ValidatorIndex, error)
 }
 
 // WriteOnlyBeaconState is the interface for a write-only beacon state.
@@ -106,6 +109,7 @@ type WriteOnlyBeaconState[
 
 	DecreaseBalance(math.ValidatorIndex, math.Gwei) error
 	IncreaseBalance(math.ValidatorIndex, math.Gwei) error
+	SetBalance(math.ValidatorIndex, math.Gwei) error
 	SetEth1DepositIndex(uint64) error
 	SetFork(ForkT) error
 	SetGenesisValidatorsRoot(root common.Root) error

examples/berad/pkg/state-transition/state_processor_staking.go

@@ -270,10 +270,21 @@ func (sp *StateProcessor[
 func (sp *StateProcessor[
 	_, _, _, BeaconStateT, _, _, _, _, _, _, _, _, _, _, _, _,
 ]) processForcedWithdrawals(
-	_ BeaconStateT,
-	_ transition.ValidatorUpdates,
+	st BeaconStateT,
+	valUpdates transition.ValidatorUpdates,
 ) error {
-	// TODO: Implement this function.
+	// Process the forced withdrawals.
+	for _, valUpdate := range valUpdates {
+		idx, err := st.ValidatorIndexByPubkey(valUpdate.Pubkey)
+		if err != nil {
+			return err
+		}
+
+		// Set the validator's effective balance to 0.
+		if err = st.SetBalance(idx, 0); err != nil {
+			return err
+		}
+	}
 	return nil
 }
 

mod/storage/pkg/beacondb/registry.go

@@ -50,7 +50,7 @@ func (kv *KVStore[
 	BeaconBlockHeaderT, Eth1DataT, ExecutionPayloadHeaderT,
 	ForkT, ValidatorT, ValidatorsT,
 ]) AddValidatorBartio(val ValidatorT) error {
-	// Get the ne
+	// Get the next validator index from the sequence.
 	idx, err := kv.validatorIndex.Next(kv.ctx)
 	if err != nil {
 		return err