@healthcare-interoperability/fhir-query-mongo-store

MongoDB-specific query builder for FHIR resources, built on top of fhir-query-store.

@healthcare-interoperability/fhir-query-mongo-store provides MongoDB-compatible query generation utilities for storing and updating FHIR resources using bulk operations. It extends the generic FHIR query framework provided by @healthcare-interoperability/fhir-query-store, enabling support for real-world healthcare integration workflows and storage patterns.

Features

• 🔁 Supports FHIR Bundles (type collection, transaction, etc.)
• ⚙️ Converts FHIR resources into bulkWrite-ready MongoDB update queries
• 🧠 Optimized for idempotent operations using updateOne with upsert
• 📦 Handles integration IDs and task-based processing
• 🧩 Built for composability and subclassing

Installation

npm install @healthcare-interoperability/fhir-query-mongo-store

Usage

import { FHIRMongoBundleProcessor } from '@healthcare-interoperability/fhir-query-mongo-store';

const bundle = {
  resourceType: 'Bundle',
  type: 'collection',
  entry: [/* array of FHIR resources */]
};

const processor = new FHIRMongoBundleProcessor(bundle)
  .setIntegrationId('your-integration-id');

const queries = processor.query();

// `queries` is an object keyed by resource type, each with an array of MongoDB operations
// e.g. { Patient: [ { updateOne: { filter, update, upsert: true } } ] }

API

FHIRMongoBundleProcessor

Processes a FHIR bundle and generates MongoDB-compatible update queries.

Constructor

new FHIRMongoBundleProcessor(bundle)

• bundle: A valid FHIR Bundle or single resource.

.setIntegrationId(integrationId)

Sets an integration ID to associate with all processed queries.

.query()

Returns an object where each key is a FHIR resource type (e.g., "Patient") and the value is an array of MongoDB update queries ready for bulkWrite.

Related Packages

• @healthcare-interoperability/fhir-query-store: Generic FHIR query generation framework used as the base for MongoDB and other data stores.

License

MIT