Run tests against local FHIR server

docker-compose.yml

@@ -0,0 +1,29 @@
+version: '3.7'
+
+services:
+  fhir:
+    container_name: fhir
+    image: "hapiproject/hapi:latest"
+    ports:
+      - "8080:8080"
+    configs:
+      - source: hapi
+        target: /app/config/application.yaml
+    depends_on:
+      - db
+    environment:
+      JVM_OPTS: "-Xms2g -Xms2g"
+
+  db:
+    image: postgres
+    restart: always
+    environment:
+      POSTGRES_PASSWORD: admin
+      POSTGRES_USER: admin
+      POSTGRES_DB: hapi
+    volumes:
+      - ./hapi.postgress.data:/var/lib/postgresql/data
+
+configs:
+  hapi:
+     file: ./hapi.application.yaml

hapi.application.yaml

@@ -0,0 +1,13 @@
+spring:
+  datasource:
+    url: 'jdbc:postgresql://db:5432/hapi'
+    username: admin
+    password: admin
+    driverClassName: org.postgresql.Driver
+  jpa:
+    properties:
+      hibernate.dialect: ca.uhn.fhir.jpa.model.dialect.HapiFhirPostgres94Dialect
+      hibernate.search.enabled: false
+  hapi:
+    fhir:
+      reuse_cached_search_results_millis: -1

jest.config.js

@@ -1,3 +1,3 @@
 module.exports = {
-  testPathIgnorePatterns: ['dist/*', 'tests/*']
+  roots: ['<rootDir>/src']
 };

jest.integration.js

@@ -1,6 +1,6 @@
 module.exports = {
   globalSetup: './tests/setup.ts',
   globalTeardown: './tests/teardown.ts',
-  testPathIgnorePatterns: ['dist/*'],
-  testMatch: ['<rootDir>/tests/**/*.test.ts']
+  testTimeout: 30000,
+  roots: ['<rootDir>/tests']
 };

package.json

@@ -49,7 +49,7 @@
     "url": "git+https://github.com/Outburn-IL/fume-community.git"
   },
   "dependencies": {
-    "axios": "^1.1.3",
+    "axios": "^1.6.7",
     "cors": "^2.8.5",
     "csvtojson": "^2.0.10",
     "dotenv": "^16.4.1",
@@ -80,6 +80,7 @@
     "cross-env": "^7.0.3",
     "detect-indent": "^7.0.1",
     "detect-newline": "^4.0.1",
+    "docker-compose": "^0.24.6",
     "eslint": "^8.28.0",
     "eslint-config-standard-with-typescript": "^23.0.0",
     "eslint-plugin-import": "^2.26.0",

src/helpers/cache/simpleCache.test.ts

@@ -70,4 +70,14 @@ describe('SimpleCache', () => {
     const res = cache.getDict();
     expect(res).toEqual({ key: 'apple', key3: 'banana' });
   });
+
+  test('populate with undefined clears cache', async () => {
+    const cache = new SimpleCache();
+    cache.set('key', 'value');
+    cache.set('key2', 'value2');
+
+    cache.populate(undefined as any);
+    const res = cache.getDict();
+    expect(res).toEqual({});
+  });
 });

src/helpers/cache/simpleCache.ts

@@ -32,7 +32,7 @@ export class SimpleCache<T> implements ICache<T> {
   }
 
   populate (dict: Record<string, T>) {
-    this.cache = dict;
+    this.cache = dict || {};
   }
 
   getDict () {

src/helpers/conformance/recacheFromServer.ts

@@ -63,22 +63,26 @@ export const getAliasResource = async () => {
     return undefined;
   };
   let resource;
-  const aliasResourceSearch = await getFhirClient().search('ConceptMap', { context: 'http://codes.fume.health|fume', name: 'FumeAliases' });
-  if (typeof aliasResourceSearch === 'object' && aliasResourceSearch.resourceType === 'Bundle' && typeof aliasResourceSearch.total === 'number') {
-    if (aliasResourceSearch.total === 1) {
-      logger.info(`Alias resource found: ${aliasResourceSearch.entry[0].fullUrl as string}`);
-      resource = aliasResourceSearch.entry[0].resource;
-    } else {
-      if (aliasResourceSearch.total === 0) {
-        logger.info('Alias resource not found');
-        resource = {};
+  try {
+    const aliasResourceSearch = await getFhirClient().search('ConceptMap', { context: 'http://codes.fume.health|fume', name: 'FumeAliases' });
+    if (typeof aliasResourceSearch === 'object' && aliasResourceSearch.resourceType === 'Bundle' && typeof aliasResourceSearch.total === 'number') {
+      if (aliasResourceSearch.total === 1) {
+        logger.info(`Alias resource found: ${aliasResourceSearch.entry[0].fullUrl as string}`);
+        resource = aliasResourceSearch.entry[0].resource;
       } else {
-        logger.error('Multiple alias resources found on server!');
+        if (aliasResourceSearch.total === 0) {
+          logger.info('Alias resource not found');
+          resource = {};
+        } else {
+          logger.error('Multiple alias resources found on server!');
+        }
       }
-    }
-  } else {
-    logger.error('Error fetching alias resource!');
-  };
+    } else {
+      logger.error('Error fetching alias resource!');
+    };
+  } catch (e) {
+    resource = {};
+  }
   return resource;
 };
 
@@ -146,5 +150,6 @@ export const recacheFromServer = async (): Promise<boolean> => {
     logger.error(e);
     return false;
   };
+
   return true;
 };

src/helpers/fhirFunctions/translateCode.ts

@@ -6,13 +6,15 @@ import { getLogger } from '../logger';
 
 export const translateCode = async (input: string, tableId: string) => {
   const { tables } = getCache();
-  // fork: os
   try {
     let map = tables.get(tableId);
     if (map === undefined) {
       getLogger().info(`Table ${tableId} not cached, trying to fetch from server...`);
-      map = (await getTable(tableId))[tableId];
-      tables.set(tableId, map);
+      const table = await getTable(tableId);
+      if (table) {
+        map = table[tableId];
+        tables.set(tableId, map);
+      }
     };
 
     const mapFiltered = map[input];

tests/config.ts

@@ -0,0 +1,2 @@
+export const LOCAL_FHIR_SERVER_BASE = 'http://localhost:8080';
+export const LOCAL_FHIR_API = `${LOCAL_FHIR_SERVER_BASE}/fhir`;