Added EnqueueDeposits

berachain · Feb 9, 2025 · 07334a4 · 07334a4
1 parent 6f79037
commit 07334a4
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/state-transition/core/state_processor_staking.go b/state-transition/core/state_processor_staking.go
@@ -62,6 +62,12 @@ func (sp *StateProcessor) processOperations(
 		); err != nil {
 			return err
 		}
+	} else {
+		// If we're not validating the deposits, we want to add the deposits to our Deposit Store to keep it up to date.
+		err := sp.ds.EnqueueDeposits(ctx.ConsensusCtx(), deposits)
+		if err != nil {
+			return err
+		}
 	}
 
 	for _, dep := range deposits {
@@ -80,7 +86,6 @@ func (sp *StateProcessor) processDeposit(st *state.StateDB, dep *ctypes.Deposit)
 	if err != nil {
 		return err
 	}
-
 	if err = st.SetEth1DepositIndex(eth1DepositIndex + 1); err != nil {
 		return err
 	}

diff --git a/storage/deposit/store.go b/storage/deposit/store.go
@@ -121,7 +121,7 @@ func (kv *KVStore) GetDepositsByIndex(
 	return deposits, nil
 }
 
-// EnqueueDeposits pushes multiple deposits to the queue.
+// EnqueueDeposits pushes multiple deposits to the queue. EnqueueDeposits is idempotent.
 func (kv *KVStore) EnqueueDeposits(ctx context.Context, deposits []*ctypes.Deposit) error {
 	kv.mu.Lock()
 	defer kv.mu.Unlock()