[16144] Added additional check to integration tests.

CDCgov · Nov 21, 2024 · 97b21ad · 97b21ad
1 parent 7f92ba3
commit 97b21ad
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/prime-router/src/test/kotlin/fhirengine/azure/FHIRTranslatorIntegrationTests.kt b/prime-router/src/test/kotlin/fhirengine/azure/FHIRTranslatorIntegrationTests.kt
@@ -209,6 +209,7 @@ class FHIRTranslatorIntegrationTests : Logging {
         assertThat(event.params[ReportStreamEventProperties.RECEIVER_NAME]).isEqualTo("phd.x")
         val enrichments = event.params[ReportStreamEventProperties.ENRICHMENTS] as List<*>
         assertThat(enrichments).hasSize(1)
+        assertThat(enrichments.first()).isEqualTo(receiverSetupData.first().schemaName)
 
         // check action table
         UniversalPipelineTestUtils.checkActionTable(listOf(TaskAction.receive, TaskAction.translate))
@@ -321,6 +322,7 @@ class FHIRTranslatorIntegrationTests : Logging {
         assertThat(event.params[ReportStreamEventProperties.RECEIVER_NAME]).isEqualTo("phd.x")
         val enrichments = event.params[ReportStreamEventProperties.ENRICHMENTS] as List<*>
         assertThat(enrichments).hasSize(1)
+        assertThat(enrichments.first()).isEqualTo(receiverSetupData.first().schemaName)
 
         // check action table
         UniversalPipelineTestUtils.checkActionTable(listOf(TaskAction.receive, TaskAction.translate))
@@ -410,6 +412,7 @@ class FHIRTranslatorIntegrationTests : Logging {
         assertThat(event.params[ReportStreamEventProperties.RECEIVER_NAME]).isEqualTo("phd.x")
         val enrichments = event.params[ReportStreamEventProperties.ENRICHMENTS] as List<*>
         assertThat(enrichments).hasSize(1)
+        assertThat(enrichments.first()).isEqualTo(receiverSetupData.first().schemaName)
 
         // check action table
         UniversalPipelineTestUtils.checkActionTable(listOf(TaskAction.receive, TaskAction.translate))
@@ -509,6 +512,7 @@ class FHIRTranslatorIntegrationTests : Logging {
         assertThat(event.params[ReportStreamEventProperties.RECEIVER_NAME]).isEqualTo("phd.x")
         val enrichments = event.params[ReportStreamEventProperties.ENRICHMENTS] as List<*>
         assertThat(enrichments).hasSize(1)
+        assertThat(enrichments.first()).isEqualTo(receiverSetupData.first().schemaName)
 
         // check action table
         UniversalPipelineTestUtils.checkActionTable(listOf(TaskAction.receive, TaskAction.translate))