Feature: support for uploading GZIP bundles of patient data

Author: Dtphelan1

.gitignore

@@ -28,3 +28,6 @@ yarn-error.log*
 
 # https://github.com/facebook/create-react-app/issues/6560
 src/*.d.ts
+
+# Local data directory
+data/

package-lock.json

@@ -58,6 +58,7 @@
     "morgan": "~1.9.1",
     "node-jose": "^2.0.0",
     "nodemon": "^2.0.7",
+    "pako": "^2.1.0",
     "prop-types": "^15.7.2",
     "query-string": "^6.13.8",
     "react": "^18.0.0",

package.json

@@ -15,7 +15,7 @@ app.use(express.json());
 app.use(bodyParser.json({ type: ['application/json', 'application/fhir+json'] }));
 
 // Routes for collections
-Object.values(collections).forEach(collectionName => {
+Object.values(collections).forEach((collectionName) => {
   app.use(`/collection/${collectionName}`, genericController(collectionName));
 });
 

src/App.js

@@ -20,16 +20,16 @@ function isMatch(object, attrs) {
 }
 
 function getHandler(collectionName, req, res) {
-  const result = db.select(collectionName, row => isMatch(row, req.query));
+  const result = db.select(collectionName, (row) => isMatch(row, req.query));
   res.send(result);
 }
 
 function updateHandler(collectionName, req, res) {
   const changedItem = req.body;
-  if (req.query.id) db.upsert(collectionName, changedItem, r => r.id === req.query.id);
+  if (req.query.id) db.upsert(collectionName, changedItem, (r) => r.id === req.query.id);
   else if (req.query.fullUrl) {
     const fullUrl = base64url.decode(req.query.fullUrl);
-    db.upsert(collectionName, changedItem, r => r.fullUrl === fullUrl);
+    db.upsert(collectionName, changedItem, (r) => r.fullUrl === fullUrl);
   } else {
     res.send('Must include id or fullUrl').status(StatusCodes.BAD_REQUEST);
     return;
@@ -40,10 +40,10 @@ function updateHandler(collectionName, req, res) {
 
 function deleteHandler(collectionName, req, res) {
   if (req.query.id) {
-    db.delete(collectionName, r => r.id === req.query.id);
+    db.delete(collectionName, (r) => r.id === req.query.id);
   } else if (req.query.fullUrl) {
     const fullUrl = base64url.decode(req.query.fullUrl);
-    db.delete(collectionName, r => r.fullUrl === fullUrl);
+    db.delete(collectionName, (r) => r.fullUrl === fullUrl);
   } else {
     res.send('Must include id or fullUrl').status(StatusCodes.BAD_REQUEST);
     return;

src/handlers/crudHandler.js

@@ -14,5 +14,5 @@ module.exports = {
   PAYERS: 'payers',
   PROCEDURES: 'procedures',
   PROVIDERS: 'providers',
-  SUPPLIES: 'supplies'
+  SUPPLIES: 'supplies',
 };

src/storage/collections.js

@@ -4,14 +4,14 @@ const debugConsole = require('debug');
 const { v4: uuidv4 } = require('uuid');
 
 function debug(location) {
-  return message => {
+  return (message) => {
     const logger = debugConsole(location);
     logger(message);
     const log = {
       id: uuidv4(),
       timestamp: Date.now(),
       message: message,
-      location: location
+      location: location,
     };
     db.insert(LOGS, log);
   };
@@ -25,7 +25,7 @@ function error(location) {
       id: uuidv4(),
       timestamp: Date.now(),
       error: error,
-      location: location
+      location: location,
     };
     db.insert(ERRORS, log);
 
@@ -34,7 +34,7 @@ function error(location) {
       timestamp: Date.now(),
       notif: notif || error,
       viewed: false,
-      type: 'error'
+      type: 'error',
     };
     db.insert(NOTIFICATIONS, notification);
   };
@@ -46,7 +46,7 @@ function storeRequest(request) {
     timestamp: Date.now(),
     url: request.url,
     body: request.body,
-    headers: request.headers
+    headers: request.headers,
   };
   db.insert(REQUESTS, log);
 }