validate staking ops

.gitignore

@@ -1,2 +1,4 @@
 rosetta-cli
 bin/
+/.vscode
+/cli-data

pkg/processor/broadcast_storage_handler.go

@@ -31,6 +31,8 @@ import (
 
 var _ modules.BroadcastStorageHandler = (*BroadcastStorageHandler)(nil)
 
+var stakingOpsTypes = []string{"stake", "unstake", "withdraw", "restake"}
+
 // BroadcastStorageHandler is invoked whenever a block is added
 // or removed from block storage so that balance changes
 // can be sent to other functions (ex: reconciler).
@@ -81,7 +83,10 @@ func (h *BroadcastStorageHandler) TransactionConfirmed(
 	}
 
 	if err := h.parser.ExpectedOperations(intent, observed, false, true); err != nil {
-		return fmt.Errorf("confirmed transaction did not match intent: %w", err)
+		errMsg := fmt.Errorf("confirmed transaction did not match intent: %w", err)
+		if !isValidStakingOperation(intent, intentMetadata) {
+			return errMsg
+		}
 	}
 
 	// Validate destination memo if it's needed
@@ -114,6 +119,23 @@ func (h *BroadcastStorageHandler) TransactionConfirmed(
 	return nil
 }
 
+func isValidStakingOperation(intent []*types.Operation, metadata map[string]interface{}) bool {
+	stakingOpsTypes := map[string]bool{
+		"stake":    true,
+		"unstake":  true,
+		"withdraw": true,
+		"restake":  true,
+	}
+
+	if _, found := metadata["validator_src_address"]; found {
+		if len(intent) == 1 {
+			_, found := stakingOpsTypes[intent[0].Type]
+			return found
+		}
+	}
+	return false
+}
+
 // TransactionStale is called when a transaction has not yet been
 // seen on-chain and is considered stale. This occurs when
 // current block height - last broadcast > staleDepth.