ncpdp endpoint implimentation

Author: smalho01

.env

@@ -12,6 +12,7 @@ VSAC_API_KEY = changeMe
 WHITELIST = *
 SERVER_NAME = CodeX REMS Administrator Prototype
 FULL_RESOURCE_IN_APP_CONTEXT = false
+DOCKERED_EHR_CONTAINER_NAME = false
 
 #Frontend Vars
 FRONTEND_PORT=9090

README.md

@@ -118,6 +118,8 @@ Following are a list of modifiable paths:
 | WHITELIST       | `http://localhost, http://localhost:3005`  | List of valid URLs for CORS. Should include any URLs the server accesses for resources.                                     |
 | SERVER_NAME     | `CodeX REMS Administrator Prototype`       | Name of the server that is returned in the card source.                                                                     |
 | FULL_RESOURCE_IN_APP_CONTEXT     | 'false'       | If true, the entire order resource will be included in the appContext, otherwise only a reference will be.                                                                     |
+| DOCKERED_EHR_CONTAINER_NAME     | ''       | String of the EHR container name for local docker networking communication                              |
+
 | FRONTEND_PORT            | `9080`                                             | Port that the frontend  server should run on, change if there are conflicts with port usage.                   |
 | VITE_REALM | `ClientFhirServer` | Keycloak realm for frontend authentication. |
 | VITE_AUTH | `http://localhost:8180` | Keycloak authentication server URL for frontend. |

src/config.ts

@@ -41,7 +41,8 @@ export default {
   fhirServerConfig: {
     auth: {
       // This server's URI
-      resourceServer: env.get('RESOURCE_SERVER').required().asUrlString()
+      resourceServer: env.get('RESOURCE_SERVER').required().asUrlString(),
+      dockered_ehr_container_name: env.get('DOCKERED_EHR_CONTAINER_NAME').asString()
       //
       // if you use this strategy, you need to add the corresponding env vars to docker-compose
       //

src/lib/communication.ts

@@ -143,14 +143,21 @@ export async function sendCommunicationToEHR(
     };
 
     // Determine EHR endpoint: use originatingFhirServer if available, otherwise default
-    const ehrEndpoint =
+    let ehrEndpoint =
       remsCase.originatingFhirServer || config.fhirServerConfig?.auth?.resourceServer;
 
     if (!ehrEndpoint) {
       logger.warn('No EHR endpoint configured, Communication not sent');
       return;
     }
 
+    if (config.fhirServerConfig.auth.dockered_ehr_container_name) {
+      const originalEhrEndpoint = ehrEndpoint;
+      ehrEndpoint = originalEhrEndpoint.replace(/localhost/g, config.fhirServerConfig.auth.dockered_ehr_container_name)
+            .replace(/127\.0\.0\.1/g, config.fhirServerConfig.auth.dockered_ehr_container_name);
+      logger.info(`Running locally in Docker, converting EHR url from ${originalEhrEndpoint} to ${ehrEndpoint}`);
+    }
+
     // Send Communication to EHR
     logger.info(`Sending Communication to EHR: ${ehrEndpoint}`);
 

src/lib/winston.ts

@@ -16,26 +16,30 @@ const applicationTransports = [];
 const transportConsole = new transports.Console({
   level: logConfig.level,
   format: winston.format.combine(
-    winston.format.prettyPrint(),
-    winston.format.json(),
-    winston.format.splat()
+    winston.format.timestamp(),
+    winston.format.json()
   )
 });
 
 applicationTransports.push(transportConsole);
+
 if (logConfig.directory) {
   const transportDailyFile = new transports.DailyRotateFile({
     filename: path.join(logConfig.directory, 'application-%DATE%.log'),
     datePattern: 'YYYY-MM-DD-HH',
     level: logging.level,
     zippedArchive: true,
-    maxSize: '20m'
+    maxSize: '20m',
+    format: winston.format.combine(
+      winston.format.timestamp(),
+      winston.format.json()
+    )
   });
   applicationTransports.push(transportDailyFile);
 }
+
 // Add a default application logger
 container.add('application', {
-  format: format.combine(format.timestamp(), format.logstash()),
   transports: applicationTransports
 });
 
@@ -44,4 +48,4 @@ container.add('application', {
  * @static
  * @summary Logging container for the application
  */
-export default container;
+export default container;