#52 Persist status for reconciliation runs

Persists only Pending|Successful status at the moment; failure handling to be introduced.

src/main/kotlin/recce/server/recrun/RecRunRepository.kt

@@ -29,6 +29,7 @@ data class RecRun(
     @DateCreated val createdTime: Instant? = null,
     @DateUpdated var updatedTime: Instant? = null,
     var completedTime: Instant? = null,
+    @Enumerated(EnumType.STRING) var status: RunStatus = RunStatus.Pending,
     @Embedded var summary: MatchStatus? = null
 ) {
     constructor(datasetId: String) : this(null, datasetId)
@@ -43,6 +44,12 @@ data class RecRun(
     }
 }
 
+enum class RunStatus {
+    Pending,
+    Successful,
+    Failed
+}
+
 @Embeddable
 data class MatchStatus(
     var sourceOnly: Int = 0,

src/main/kotlin/recce/server/recrun/RecRunService.kt

@@ -20,7 +20,12 @@ open class RecRunService(
     fun complete(run: RecRun): Mono<RecRun> {
         logger.info { "Summarising results for $run" }
         return recordRepository.countMatchedByKeyRecRunId(run.id!!)
-            .map { run.apply { completedTime = Instant.now(); summary = it } }
+            .map {
+                run.apply {
+                    completedTime = Instant.now(); summary = it
+                    status = RunStatus.Successful
+                }
+            }
             .flatMap(runRepository::update)
             .doOnNext { logger.info { "Run completed for $it" } }
     }

src/main/resources/db/migration/V8__REC_RUN_STATUS.sql

@@ -0,0 +1,12 @@
+ALTER TABLE reconciliation_run
+    ADD COLUMN status VARCHAR(20);
+
+-- noinspection SqlWithoutWhere
+UPDATE reconciliation_run r
+SET status = (
+    SELECT CASE WHEN completed_time IS NOT NULL THEN 'Successful' ELSE 'Failed' END
+    FROM reconciliation_run
+    WHERE id = r.id
+);
+
+ALTER TABLE reconciliation_run ALTER status SET NOT NULL;

src/test/kotlin/recce/server/dataset/DatasetRecServiceIntegrationTest.kt

@@ -115,6 +115,7 @@ class DatasetRecServiceIntegrationTest {
         assertThat(run.createdTime).isNotNull
         assertThat(run.updatedTime).isAfterOrEqualTo(run.createdTime)
         assertThat(run.completedTime).isAfterOrEqualTo(run.createdTime)
+        assertThat(run.status).isEqualTo(RunStatus.Successful)
         assertThat(run.summary).isEqualTo(MatchStatus(1, 2, 2, 0))
         val expectedMeta = DatasetMeta(
             listOf(

src/test/kotlin/recce/server/recrun/RecRunServiceTest.kt

@@ -47,6 +47,7 @@ internal class RecRunServiceTest {
         StepVerifier.create(RecRunService(runRepository, recordRepository).complete(startedRun))
             .assertNext {
                 assertThat(it.completedTime).isAfterOrEqualTo(it.createdTime)
+                assertThat(it.status).isEqualTo(RunStatus.Successful)
                 assertThat(it.summary).isEqualTo(expectedMatchStatus)
             }
             .verifyComplete()