Added receiver for results + some more fixes

CDCgov · Sep 6, 2024 · acd90b8 · acd90b8
1 parent 01e4a7b
commit acd90b8
Showing 1 changed file with 27 additions and 3 deletions.
diff --git a/prime-router/settings/STLTs/Flexion/flexion.yml b/prime-router/settings/STLTs/Flexion/flexion.yml
@@ -159,7 +159,7 @@
       topic: "etor-ti"
       customerStatus: "active"
       jurisdictionalFilter:
-        - "Bundle.entry.resource.ofType(MessageHeader).event.code = 'O21'"  # OML_O21
+        - "(Bundle.entry.resource.ofType(MessageHeader).event.code = 'O01') or (Bundle.entry.resource.ofType(MessageHeader).event.code = 'O21')"  # ORM_O01 or OML_O21
         - "Bundle.entry.resource.ofType(MessageHeader).meta.tag.where(system = 'http://localcodes.org/ETOR').code = 'ETOR'"  # required to avoid looping issue
         - "Bundle.entry.resource.ofType(MessageHeader).destination.receiver.resolve().identifier.where(value = 'simulated-lab-id').exists()"  # receiver routing filter
       qualityFilter:
@@ -179,11 +179,12 @@
         port: 22
         filePath: "./upload"
         credentialName: null # use "DEFAULT-SFTP" if running locally
-    - name: "automated-staging-test-receiver"
+    - name: "automated-staging-test-receiver-orders"
       organizationName: "flexion"
       topic: "etor-ti"
       customerStatus: "active"
       jurisdictionalFilter:
+        - "(Bundle.entry.resource.ofType(MessageHeader).event.code = 'O01') or (Bundle.entry.resource.ofType(MessageHeader).event.code = 'O21')"  # ORM_O01 or OML_O21
         - "Bundle.entry.resource.ofType(MessageHeader).meta.tag.where(system = 'http://localcodes.org/ETOR').code = 'ETOR'"  # required to avoid looping issue
         - "Bundle.entry.resource.ofType(MessageHeader).destination.receiver.resolve().identifier.where(value = 'automated-staging-test-receiver-id').exists()"  # receiver routing filter
       qualityFilter:
@@ -199,5 +200,28 @@
         useBatchHeaders: false
       transport:
         type: "BLOBSTORE"
-        storageName: "cdctiautomatedstg"
+        storageName: "cdctiautomated"
+        containerName: "automated"
+    - name: "automated-staging-test-receiver-results"
+      organizationName: "flexion"
+      topic: "etor-ti"
+      customerStatus: "active"
+      jurisdictionalFilter:
+        - "Bundle.entry.resource.ofType(MessageHeader).event.code = 'R01'"  # ORU_R01
+        - "Bundle.entry.resource.ofType(MessageHeader).meta.tag.where(system = 'http://localcodes.org/ETOR').code = 'ETOR'"  # required to avoid looping issue
+        - "Bundle.entry.resource.ofType(MessageHeader).destination.receiver.resolve().identifier.where(value = 'automated-staging-test-receiver-id').exists()"  # receiver routing filter
+      qualityFilter:
+        - "true"
+      timing:
+        operation: "MERGE"
+        numberPerDay: 1440 # Every minute
+        initialTime: "00:00"
+      translation:
+        type: "HL7"
+        schemaName: "classpath:/metadata/hl7_mapping/ORU_R01/ORU_R01-base.yml"
+        useTestProcessingMode: false
+        useBatchHeaders: false
+      transport:
+        type: "BLOBSTORE"
+        storageName: "cdctiautomated"
         containerName: "automated"