[ERSSUP-80439]-[JW/AP/DW]-[Finalise OAS and sandbox of R4 download endpoint]-[FV]

Author: francisco-videira-nhs

grep

@@ -0,0 +1,9 @@
+<AssignMessage async="false" continueOnError="false" enabled="true" name="AssignMessage.AddBaseUrlHeader">
+    <Set>
+        <Headers>
+            <Header name="x-ers-sandbox-baseurl">https://{request.header.Host}/{proxy.basepath}</Header>
+        </Headers>
+    </Set>
+    <IgnoreUnresolvedVariables>false</IgnoreUnresolvedVariables>
+    <AssignTo createNew="false"/>
+</AssignMessage>

proxies/sandbox/apiproxy/policies/AssignMessage.AddBaseUrlHeader.xml

@@ -7,8 +7,12 @@
         <Response/>
     </PostFlow>
     <PreFlow name="PreFlow">
-        <Request/>
-        <Response></Response>
+        <Request>
+            <Step>
+                <Name>AssignMessage.AddBaseUrlHeader</Name>
+            </Step>
+        </Request>
+        <Response/>
     </PreFlow>
     <HTTPTargetConnection>{{ HOSTED_TARGET_CONNECTION }}</HTTPTargetConnection>
 </TargetEndpoint>

proxies/sandbox/apiproxy/targets/sandbox.xml

@@ -1,6 +1,6 @@
 FROM node:18.3.0-alpine3.14
 
-ENV npm_config_cache /home/node/app/.npm
+ENV npm_config_cache=/home/node/app/.npm
 
 WORKDIR /app
 

sandbox/Dockerfile

@@ -10,10 +10,12 @@ const addCommonHeaders = function (request, response) {
     response.headers = {}
   }
 
-  if (request.headers["x-correlation-id"]) {
-    response.headers["X-Correlation-ID"] = request.headers["x-correlation-id"]
+  if (!request.path.includes("ObjectStore")) {
+    if (request.headers["x-correlation-id"]) {
+      response.headers["X-Correlation-ID"] = request.headers["x-correlation-id"]
+    }
+    response.headers["X-Request-ID"] = '58621d65-d5ad-4c3a-959f-0438e355990e-1'
   }
-  response.headers["X-Request-ID"] = '58621d65-d5ad-4c3a-959f-0438e355990e-1'
 }
 
 const preResponse = function (request, h) {

sandbox/src/app.js

@@ -0,0 +1,17 @@
+/**
+ * @file validationUtil.js
+ * @description Provides utility functions.
+ */
+
+function isValidUuid(string) {
+    return /^[0-9A-F]{8}-[0-9A-F]{4}-[4][0-9A-F]{3}-[89AB][0-9A-F]{3}-[0-9A-F]{12}$/i.test(string);
+  }
+
+function hasLegacyPrefix(string) {
+    return string.startsWith('att-');
+}
+
+module.exports = {
+    isValidUuid,
+    hasLegacyPrefix,
+};

sandbox/src/mocks/r4/retrieveAttachment/example_attachment.pdf

@@ -42,8 +42,13 @@ const retrieveOboUsers = require('./r4/retrieveOboUsers')
 const retrieveHealthcareService = require('./r4/retrieveHealthcareService')
 const searchForHealthcareServices = require('./r4/searchForHealthcareServices')
 const searchServiceRequest = require('./r4/searchServiceRequest')
-const retrieveBinary = require('./r4/retrieveBinary')
-const retrieveBinaryHelper = require('./r4/retrieveBinaryHelper')
+const retrieveAttachmentR4 = require('./r4/retrieveAttachment')
+
+/**
+ * Services
+ */
+const objectStore = require('../services/objectStore')
+
 
 const routes = [].concat(
   getStatus,
@@ -83,8 +88,8 @@ const routes = [].concat(
   retrieveAdviceAndGuidanceOverviewPdf,
   searchServiceRequest,
   createAdviceAndGuidance,
-  retrieveBinary,
-  retrieveBinaryHelper
+  retrieveAttachmentR4,
+  objectStore
 )
 
 module.exports = routes

sandbox/src/routes/common/validationUtil.js

@@ -0,0 +1,33 @@
+const businessFunctionValidator = require('../../services/businessFunctionValidator')
+const validationUtil = require('../common/validationUtil')
+
+module.exports = [
+  /**
+   * Sandbox implementation for Retrieve attachment A042 (R4) endpoint
+   */
+  {
+    method: 'GET',
+    path: '/FHIR/R4/Binary/{binaryId}',
+    handler: (request, h) => {
+
+      const allowedBusinessFunctions = ["REFERRING_CLINICIAN", "REFERRING_CLINICIAN_ADMIN", "SERVICE_PROVIDER_CLINICIAN", "SERVICE_PROVIDER_CLINICIAN_ADMIN"];
+      
+      const validationResult = businessFunctionValidator.validateBusinessFunction(request, h, allowedBusinessFunctions);
+      if (validationResult) {
+        return validationResult;
+      }
+
+      const binaryId = request.params.binaryId;
+      const objectStore = "/ObjectStore/d497bbe3-f88b-45f1-b3d4-9c563e4c0f5f";
+      const location = request.headers['x-ers-sandbox-baseurl'] + objectStore;
+
+      if ((validationUtil.hasLegacyPrefix(binaryId) || validationUtil.isValidUuid(binaryId)) && request.method === 'get') {
+        const response = h.response().code(307);
+        response.headers["Location"] = location;
+        return response;
+      } else {
+        return h.file('r4/R4-SandboxErrorOutcome.json').code(400);
+      }
+    }
+  }
+]