Create processValidationFailure method

rskj-core/src/main/java/co/rsk/peg/BridgeStorageProvider.java

@@ -31,6 +31,8 @@
 import org.ethereum.config.blockchain.upgrades.ActivationConfig;
 import org.ethereum.core.Repository;
 import org.ethereum.vm.DataWord;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.spongycastle.util.encoders.Hex;
 
 /**
@@ -40,6 +42,7 @@
  * @author Oscar Guindzberg
  */
 public class BridgeStorageProvider {
+    private static final Logger logger = LoggerFactory.getLogger(BridgeStorageProvider.class);
 
     // Dummy value to use when saving key only indexes
     private static final byte TRUE_VALUE = (byte) 1;
@@ -679,6 +682,33 @@ private void saveSvpSpendTxWaitingForSignatures() {
         );
     }
 
+    public void clearSvpValues() {
+        if (svpFundTxHashUnsigned != null) {
+            logger.warn("[clearSvpValues] Fund tx change {} was never registered.", svpFundTxHashUnsigned);
+            setSvpFundTxHashUnsigned(null);
+        }
+
+        if (svpFundTxSigned != null) {
+            logger.warn("[clearSvpValues] Spend tx was never created. Fund tx hash: {}", svpFundTxSigned.getHash());
+            setSvpFundTxSigned(null);
+        }
+
+        if (svpSpendTxWaitingForSignatures != null) {
+            Keccak256 rskCreationHash = svpSpendTxWaitingForSignatures.getKey();
+            BtcTransaction svpSpendTx = svpSpendTxWaitingForSignatures.getValue();
+
+            logger.warn("[clearSvpValues] Spend tx {} was not fully signed. Rsk creation hash: {}.",
+                svpSpendTx.getHash(), rskCreationHash);
+            setSvpSpendTxWaitingForSignatures(null);
+            setSvpSpendTxHashUnsigned(null);
+        }
+
+        if (svpSpendTxHashUnsigned != null) {
+            logger.warn("[clearSvpValues] Spend tx {} was not registered.", svpSpendTxHashUnsigned);
+            setSvpSpendTxHashUnsigned(null);
+        }
+    }
+
     public void save() {
         saveBtcTxHashesAlreadyProcessed();
 

rskj-core/src/main/java/co/rsk/peg/BridgeSupport.java

@@ -1017,6 +1017,22 @@ private void logUpdateCollections(Transaction rskTx) {
         eventLogger.logUpdateCollections(sender);
     }
 
+    protected void processSVPFailure(Federation proposedFederation) {
+        eventLogger.logCommitFederationFailure(rskExecutionBlock, proposedFederation);
+        logger.warn("[processSVPFailure] Proposed federation validation failed at block {}, so svp values will be cleared.", rskExecutionBlock.getNumber());
+
+        clearProposedFederation();
+        clearSvpValues();
+    }
+
+    private void clearProposedFederation() {
+        federationSupport.clearProposedFederation();
+    }
+
+    private void clearSvpValues() {
+        provider.clearSvpValues();
+    }
+
     private boolean svpIsOngoing() {
         return federationSupport.getProposedFederation()
             .map(Federation::getCreationBlockNumber)

rskj-core/src/main/java/co/rsk/peg/federation/FederationSupport.java

@@ -125,6 +125,8 @@ public interface FederationSupport {
      */
     Optional<byte[]> getProposedFederatorPublicKeyOfType(int index, FederationMember.KeyType keyType);
 
+    void clearProposedFederation();
+
     int voteFederationChange(
         Transaction tx,
         ABICallSpec callSpec,

rskj-core/src/main/java/co/rsk/peg/federation/FederationSupportImpl.java

@@ -398,6 +398,11 @@ public Optional<Instant> getProposedFederationCreationTime() {
             .map(Federation::getCreationTime);
     }
 
+    @Override
+    public void clearProposedFederation() {
+        provider.setProposedFederation(null);
+    }
+
     @Override
     public int voteFederationChange(Transaction tx, ABICallSpec callSpec, SignatureCache signatureCache, BridgeEventLogger eventLogger) {
         String calledFunction = callSpec.getFunction();

rskj-core/src/test/java/co/rsk/peg/BridgeStorageProviderTest.java

@@ -1162,6 +1162,82 @@ void getSvpSpendTxWaitingForSignatures_whenEntryIsCached_shouldReturnTheCachedEn
         }
     }
 
+    @Nested
+    @TestInstance(TestInstance.Lifecycle.PER_CLASS)
+    @Tag("clear svp values tests")
+    class ClearSvpValuesTests {
+        private BridgeStorageProvider bridgeStorageProvider;
+
+        @BeforeEach
+        void setup() {
+            Repository repository = createRepository();
+            bridgeStorageProvider = createBridgeStorageProvider(repository, mainnetBtcParams, activationsAllForks);
+        }
+
+        @Test
+        void clearSvpValues_whenFundTxHashUnsigned_shouldClearValue() {
+            // arrange
+            Sha256Hash svpFundTxHashUnsigned = BitcoinTestUtils.createHash(1);
+            bridgeStorageProvider.setSvpFundTxHashUnsigned(svpFundTxHashUnsigned);
+
+            // act
+            bridgeStorageProvider.clearSvpValues();
+
+            // assert
+            assertNoSVPValues();
+        }
+
+        @Test
+        void clearSvpValues_whenFundTxSigned_shouldClearValue() {
+            // arrange
+            BtcTransaction svpFundTxSigned = new BtcTransaction(mainnetBtcParams);
+            bridgeStorageProvider.setSvpFundTxSigned(svpFundTxSigned);
+
+            // act
+            bridgeStorageProvider.clearSvpValues();
+
+            // assert
+            assertNoSVPValues();
+        }
+
+        @Test
+        void clearSvpValues_whenSpendTxWFS_shouldClearSpendTxValues() {
+            // arrange
+            Keccak256 svpSpendTxCreationHash = RskTestUtils.createHash(1);
+            BtcTransaction svpSpendTx = new BtcTransaction(mainnetBtcParams);
+            Map.Entry<Keccak256, BtcTransaction> svpSpendTxWFS = new AbstractMap.SimpleEntry<>(svpSpendTxCreationHash, svpSpendTx);
+            bridgeStorageProvider.setSvpSpendTxWaitingForSignatures(svpSpendTxWFS);
+
+            // act
+            bridgeStorageProvider.clearSvpValues();
+
+            // assert
+            assertNoSVPValues();
+        }
+
+        @Test
+        void clearSvpValues_whenSpendTxHashUnsigned_shouldClearValue() {
+            // arrange
+            Keccak256 svpSpendTxCreationHash = RskTestUtils.createHash(1);
+            BtcTransaction svpSpendTx = new BtcTransaction(mainnetBtcParams);
+            Map.Entry<Keccak256, BtcTransaction> svpSpendTxWFS = new AbstractMap.SimpleEntry<>(svpSpendTxCreationHash, svpSpendTx);
+            bridgeStorageProvider.setSvpSpendTxWaitingForSignatures(svpSpendTxWFS);
+
+            // act
+            bridgeStorageProvider.clearSvpValues();
+
+            // assert
+            assertNoSVPValues();
+        }
+
+        private void assertNoSVPValues() {
+            assertFalse(bridgeStorageProvider.getSvpFundTxHashUnsigned().isPresent());
+            assertFalse(bridgeStorageProvider.getSvpFundTxSigned().isPresent());
+            assertFalse(bridgeStorageProvider.getSvpSpendTxWaitingForSignatures().isPresent());
+            assertFalse(bridgeStorageProvider.getSvpSpendTxHashUnsigned().isPresent());
+        }
+    }
+
     @Test
     void getReleaseRequestQueue_before_rskip_146_activation() throws IOException {
         Repository repositoryMock = mock(Repository.class);