SSCS-10722 Pass case ID to migration steps.

Author: dattipoeHMCTS

modules/processor/src/main/java/uk/gov/hmcts/reform/migration/CaseMigrationProcessor.java

@@ -164,7 +164,7 @@ private void updateCase(String authorisation, Long id, Map<String, Object> data,
         totalCases++;
 
         try {
-            var migratedData = dataMigrationService.migrate(data);
+            var migratedData = dataMigrationService.migrate(data, id);
             if (!dryRun) {
                 coreCaseDataService.update(
                     authorisation,

modules/processor/src/main/java/uk/gov/hmcts/reform/migration/service/DataMigrationService.java

@@ -8,5 +8,5 @@
 public interface DataMigrationService<T> {
     Predicate<CaseDetails> accepts();
 
-    T migrate(Map<String, Object> data);
+    T migrate(Map<String, Object> data, Long id);
 }

modules/processor/src/test/java/uk/gov/hmcts/reform/migration/CaseMigrationProcessorTest.java

@@ -74,7 +74,7 @@ public void shouldProcessASingleCaseAndMigrationIsSuccessful() {
     public void shouldProcessASingleCaseAndMigrationIsFailed() {
         when(coreCaseDataService.fetchOne(USER_TOKEN, CASE_ID)).thenReturn(caseDetails1);
         when(dataMigrationService.accepts()).thenReturn(candidate -> true);
-        when(dataMigrationService.migrate(caseDetails1.getData())).thenReturn(caseDetails1.getData());
+        when(dataMigrationService.migrate(caseDetails1.getData(), caseDetails1.getId())).thenReturn(caseDetails1.getData());
         when(coreCaseDataService.update(USER_TOKEN, caseDetails1.getId().toString(), EVENT_ID, EVENT_SUMMARY, EVENT_DESCRIPTION, caseDetails1.getData())).thenThrow(new RuntimeException("Internal server error"));
         caseMigrationProcessor.processSingleCase(USER_TOKEN, CASE_ID, false);
         verify(coreCaseDataService, times(1)).fetchOne(USER_TOKEN, CASE_ID);
@@ -89,9 +89,9 @@ public void shouldProcessAllTheCandidateCases_whenOneCaseFailed() {
         mockDataUpdate(caseDetails1);
         mockDataUpdate(caseDetails2);
         when(dataMigrationService.accepts()).thenReturn(candidate -> true);
-        when(dataMigrationService.migrate(caseDetails1.getData())).thenReturn(caseDetails1.getData());
-        when(dataMigrationService.migrate(caseDetails2.getData())).thenReturn(caseDetails2.getData());
-        when(dataMigrationService.migrate(caseDetails3.getData())).thenReturn(caseDetails3.getData());
+        when(dataMigrationService.migrate(caseDetails1.getData(), caseDetails1.getId())).thenReturn(caseDetails1.getData());
+        when(dataMigrationService.migrate(caseDetails2.getData(), caseDetails2.getId())).thenReturn(caseDetails2.getData());
+        when(dataMigrationService.migrate(caseDetails3.getData(), caseDetails3.getId())).thenReturn(caseDetails3.getData());
         when(coreCaseDataService.update(USER_TOKEN, caseDetails3.getId().toString(), EVENT_ID, EVENT_SUMMARY, EVENT_DESCRIPTION, caseDetails3.getData())).thenThrow(new RuntimeException("Internal server error"));
         caseMigrationProcessor.processAllCases(USER_TOKEN, USER_ID, false);
         assertThat(caseMigrationProcessor.getFailedCases(), contains(1113L));
@@ -103,9 +103,9 @@ public void shouldProcessAllTheCandidateCases_whenTwoCasesFailed() {
         mockDataFetch(caseDetails1, caseDetails2, caseDetails3);
         mockDataUpdate(caseDetails1);
         when(dataMigrationService.accepts()).thenReturn(candidate -> true);
-        when(dataMigrationService.migrate(caseDetails1.getData())).thenReturn(caseDetails1.getData());
-        when(dataMigrationService.migrate(caseDetails2.getData())).thenReturn(caseDetails2.getData());
-        when(dataMigrationService.migrate(caseDetails3.getData())).thenReturn(caseDetails3.getData());
+        when(dataMigrationService.migrate(caseDetails1.getData(), caseDetails1.getId())).thenReturn(caseDetails1.getData());
+        when(dataMigrationService.migrate(caseDetails2.getData(), caseDetails2.getId())).thenReturn(caseDetails2.getData());
+        when(dataMigrationService.migrate(caseDetails3.getData(), caseDetails3.getId())).thenReturn(caseDetails3.getData());
         when(coreCaseDataService.update(USER_TOKEN, caseDetails2.getId().toString(), EVENT_ID, EVENT_SUMMARY, EVENT_DESCRIPTION, caseDetails2.getData())).thenThrow(new RuntimeException("Internal server error"));
         when(coreCaseDataService.update(USER_TOKEN, caseDetails3.getId().toString(), EVENT_ID, EVENT_SUMMARY, EVENT_DESCRIPTION, caseDetails3.getData())).thenThrow(new RuntimeException("Internal server error"));
         caseMigrationProcessor.processAllCases(USER_TOKEN, USER_ID, false);