Extract Fields From FHIR Bundle

etor/src/main/java/gov/hhs/cdc/trustedintermediary/etor/orders/Order.java

@@ -11,4 +11,14 @@ public interface Order<T> {
     String getFhirResourceId();
 
     String getPatientId();
+
+    String getPlacerOrderNumber();
+
+    String getSendingApplicationDetails();
+
+    String getSendingFacilityDetails();
+
+    String getReceivingApplicationDetails();
+
+    String getReceivingFacilityId();
 }

etor/src/main/java/gov/hhs/cdc/trustedintermediary/etor/results/Result.java

@@ -9,4 +9,14 @@ public interface Result<T> {
     T getUnderlyingResult();
 
     String getFhirResourceId();
+
+    String getPlacerOrderNumber();
+
+    String getSendingApplicationId();
+
+    String getSendingFacilityId();
+
+    String getReceivingApplicationId();
+
+    String getReceivingFacilityId();
 }

etor/src/main/java/gov/hhs/cdc/trustedintermediary/external/hapi/HapiOrder.java

@@ -1,9 +1,17 @@
 package gov.hhs.cdc.trustedintermediary.external.hapi;
 
 import gov.hhs.cdc.trustedintermediary.etor.orders.Order;
+import java.util.Arrays;
+import java.util.Objects;
+import java.util.stream.Collectors;
 import org.hl7.fhir.r4.model.Bundle;
+import org.hl7.fhir.r4.model.Extension;
 import org.hl7.fhir.r4.model.Identifier;
+import org.hl7.fhir.r4.model.MessageHeader;
+import org.hl7.fhir.r4.model.Organization;
 import org.hl7.fhir.r4.model.Patient;
+import org.hl7.fhir.r4.model.Reference;
+import org.hl7.fhir.r4.model.StringType;
 
 /**
  * A concrete implementation of a {@link Order} that uses the Hapi FHIR bundle as its underlying
@@ -42,4 +50,170 @@ public String getPatientId() {
                 .findFirst()
                 .orElse("");
     }
+
+    @Override
+    public String getPlacerOrderNumber() {
+        return null;
+    }
+
+    @Override
+    public String getSendingApplicationDetails() {
+        return HapiHelper.resourcesInBundle(innerOrder, MessageHeader.class)
+                .filter(Objects::nonNull)
+                .findFirst()
+                .map(
+                        messageHeader -> {
+                            String namespaceId = null;
+                            String universalId = null;
+                            String universalIdType = null;
+                            String endpoint = messageHeader.getSource().getEndpoint();
+
+                            for (Extension extension : messageHeader.getSource().getExtension()) {
+                                if ("https://reportstream.cdc.gov/fhir/StructureDefinition/namespace-id"
+                                        .equals(extension.getUrl())) {
+                                    namespaceId =
+                                            Objects.toString(
+                                                    extension.getValue().primitiveValue(), "");
+                                } else if ("https://reportstream.cdc.gov/fhir/StructureDefinition/universal-id"
+                                        .equals(extension.getUrl())) {
+                                    universalId =
+                                            Objects.toString(
+                                                    extension.getValue().primitiveValue(), "");
+                                } else if ("https://reportstream.cdc.gov/fhir/StructureDefinition/universal-id-type"
+                                        .equals(extension.getUrl())) {
+                                    universalIdType =
+                                            Objects.toString(
+                                                    extension.getValue().primitiveValue(), "");
+                                }
+                            }
+
+                            return concatenateWithCaret(
+                                    namespaceId, universalId, universalIdType, endpoint);
+                        })
+                .orElse("");
+    }
+
+    @Override
+    public String getSendingFacilityDetails() {
+        String organizationReference =
+                HapiHelper.resourcesInBundle(innerOrder, MessageHeader.class)
+                        .map(MessageHeader::getSender)
+                        .filter(Objects::nonNull)
+                        .map(Reference::getReference)
+                        .filter(Objects::nonNull)
+                        .findFirst()
+                        .orElse(null);
+
+        if (organizationReference == null || organizationReference.isEmpty()) {
+            return "";
+        }
+
+        // Extract from Organization/{id}
+        String orgId =
+                organizationReference.contains("/")
+                        ? organizationReference.split("/")[1]
+                        : organizationReference;
+
+        return HapiHelper.resourcesInBundle(innerOrder, Organization.class)
+                .filter(org -> orgId.equals(org.getIdElement().getIdPart()))
+                .findFirst()
+                .map(
+                        org -> {
+                            String facilityName = "", identifierValue = "", typeCode = "";
+
+                            for (Identifier identifier : org.getIdentifier()) {
+                                String extensionValue =
+                                        identifier.getExtension().stream()
+                                                .filter(
+                                                        ext ->
+                                                                "https://reportstream.cdc.gov/fhir/StructureDefinition/hl7v2Field"
+                                                                        .equals(ext.getUrl()))
+                                                .findFirst()
+                                                .map(
+                                                        ext ->
+                                                                ((StringType) ext.getValue())
+                                                                        .getValue())
+                                                .orElse("");
+
+                                // HD.1: namespace id
+                                if ("HD.1".equals(extensionValue)) {
+                                    facilityName = identifier.getValue();
+                                } else if ("HD.2,HD.3".equals(extensionValue)) {
+                                    identifierValue = identifier.getValue();
+                                    // HD.2: universal Id, HD.3: universal id type
+                                    typeCode =
+                                            identifier.getType() != null
+                                                            && !identifier
+                                                                    .getType()
+                                                                    .getCoding()
+                                                                    .isEmpty()
+                                                    ? identifier
+                                                            .getType()
+                                                            .getCoding()
+                                                            .get(0)
+                                                            .getCode()
+                                                    : "";
+                                }
+                            }
+
+                            return concatenateWithCaret(facilityName, identifierValue, typeCode);
+                        })
+                .orElse("");
+    }
+
+    @Override
+    public String getReceivingApplicationDetails() {
+        return HapiHelper.resourcesInBundle(innerOrder, MessageHeader.class)
+                .filter(Objects::nonNull)
+                .findFirst()
+                .flatMap(
+                        messageHeader ->
+                                messageHeader.getDestination().stream()
+                                        .filter(Objects::nonNull)
+                                        .findFirst())
+                .map(
+                        destination -> {
+                            String name = Objects.toString(destination.getName(), "");
+                            String universalId =
+                                    destination.getExtension().stream()
+                                            .filter(
+                                                    ext ->
+                                                            "https://reportstream.cdc.gov/fhir/StructureDefinition/universal-id"
+                                                                    .equals(ext.getUrl()))
+                                            .findFirst()
+                                            .map(
+                                                    ext ->
+                                                            Objects.toString(
+                                                                    ext.getValue().primitiveValue(),
+                                                                    ""))
+                                            .orElse("");
+                            String universalIdType =
+                                    destination.getExtension().stream()
+                                            .filter(
+                                                    ext ->
+                                                            "https://reportstream.cdc.gov/fhir/StructureDefinition/universal-id-type"
+                                                                    .equals(ext.getUrl()))
+                                            .findFirst()
+                                            .map(
+                                                    ext ->
+                                                            Objects.toString(
+                                                                    ext.getValue().primitiveValue(),
+                                                                    ""))
+                                            .orElse("");
+
+                            return concatenateWithCaret(name, universalId, universalIdType);
+                        })
+                .orElse("");
+    }
+
+    @Override
+    public String getReceivingFacilityId() {
+        return null;
+    }
+
+    private String concatenateWithCaret(String... values) {
+        return Arrays.stream(values)
+                .filter(Objects::nonNull) // Ensure null values are ignored
+                .collect(Collectors.joining("^"));
+    }
 }

etor/src/main/java/gov/hhs/cdc/trustedintermediary/external/hapi/HapiResult.java

@@ -2,6 +2,9 @@
 
 import gov.hhs.cdc.trustedintermediary.etor.results.Result;
 import org.hl7.fhir.r4.model.Bundle;
+import org.hl7.fhir.r4.model.Identifier;
+import org.hl7.fhir.r4.model.MessageHeader;
+import org.hl7.fhir.r4.model.ServiceRequest;
 
 /** Filler concrete implementation of a {@link Result} using the Hapi FHIR library */
 public class HapiResult implements Result<Bundle> {
@@ -21,4 +24,48 @@ public Bundle getUnderlyingResult() {
     public String getFhirResourceId() {
         return innerResult.getId();
     }
+
+    @Override
+    public String getPlacerOrderNumber() {
+        return HapiHelper.resourcesInBundle(innerResult, ServiceRequest.class)
+                .flatMap(serviceRequest -> serviceRequest.getIdentifier().stream())
+                .filter(
+                        identifier ->
+                                identifier
+                                        .getType()
+                                        .hasCoding(
+                                                "http://terminology.hl7.org/CodeSystem/v2-0203",
+                                                "PLAC"))
+                .map(Identifier::getValue)
+                .findFirst()
+                .orElse("");
+    }
+
+    @Override
+    public String getSendingApplicationId() {
+        return HapiHelper.resourcesInBundle(innerResult, MessageHeader.class)
+                .flatMap(header -> header.getSource().getExtension().stream())
+                .filter(
+                        extension ->
+                                "https://reportstream.cdc.gov/fhir/StructureDefinition/namespace-id"
+                                        .equals(extension.getUrl()))
+                .map(extension -> extension.getValue().toString())
+                .findFirst()
+                .orElse("");
+    }
+
+    @Override
+    public String getSendingFacilityId() {
+        return null;
+    }
+
+    @Override
+    public String getReceivingApplicationId() {
+        return null;
+    }
+
+    @Override
+    public String getReceivingFacilityId() {
+        return null;
+    }
 }

etor/src/test/groovy/gov/hhs/cdc/trustedintermediary/OrderMock.groovy

@@ -10,25 +10,61 @@ class OrderMock<T> implements Order<T> {
     private String fhirResourceId
     private String patientId
     private T underlyingOrders
+    private String placerOrderNumber
+    private String sendingApplicationId
+    private String sendingFacilityId
+    private String receivingApplicationId
+    private String receivingFacilityId
 
-    OrderMock(String fhirResourceId, String patientId, T underlyingOrders) {
+    OrderMock(String fhirResourceId, String patientId, T underlyingOrders, String placerOrderNumber, String sendingApplicationId, String sendingFacilityId,
+    String receivingApplicationId, String receivingFacilityId) {
         this.fhirResourceId = fhirResourceId
         this.patientId = patientId
         this.underlyingOrders = underlyingOrders
+        this.placerOrderNumber = placerOrderNumber
+        this.sendingApplicationId = sendingApplicationId
+        this.sendingFacilityId = sendingFacilityId
+        this.receivingApplicationId = receivingApplicationId
+        this.receivingFacilityId = receivingFacilityId
     }
 
     @Override
     T getUnderlyingOrder() {
-        return underlyingOrders
+        return this.underlyingOrders
     }
 
     @Override
     String getFhirResourceId() {
-        return fhirResourceId
+        return this.fhirResourceId
     }
 
     @Override
     String getPatientId() {
         return patientId
     }
+
+    @Override
+    String getPlacerOrderNumber() {
+        return this.placerOrderNumber
+    }
+
+    @Override
+    String getSendingApplicationDetails() {
+        return this.sendingApplicationId
+    }
+
+    @Override
+    String getSendingFacilityDetails() {
+        return this.sendingFacilityId
+    }
+
+    @Override
+    String getReceivingApplicationDetails() {
+        return this.receivingApplicationId
+    }
+
+    @Override
+    String getReceivingFacilityId() {
+        return this.receivingFacilityId
+    }
 }