Medplum

// SPDX-FileCopyrightText: Copyright Orangebot, Inc. and Medplum contributors // SPDX-License-Identifier: Apache-2.0 import { ContentType, createReference, getReferenceString, indexSearchParameterBundle, indexStructureDefinitionBundle, resolveId, } from '@medplum/core'; import type { MedplumClient } from '@medplum/core'; import { SEARCH_PARAMETER_BUNDLE_FILES, readJson } from '@medplum/definitions'; import type { Bundle, List, Patient, SearchParameter } from '@medplum/fhirtypes'; import { MockClient } from '@medplum/mock'; import { handler } from './find-matching-patients'; // start-block importPatientData // import a Bundle of test data from 'patient-data.json' import patientData from './patient-data.json'; // end-block importPatientData interface TestContext { medplum: MedplumClient; } // npm t src/examples/patient-deduplication.test.ts // This test demostrates a automatically linking patients with three matching identifiers describe('Link Patient', async () => { // Load the FHIR definitions to enable search parameter indexing beforeAll(() => { indexStructureDefinitionBundle(readJson('fhir/r4/profiles-types.json') as Bundle); indexStructureDefinitionBundle(readJson('fhir/r4/profiles-resources.json') as Bundle); for (const filename of SEARCH_PARAMETER_BUNDLE_FILES) { indexSearchParameterBundle(readJson(filename) as Bundle<SearchParameter>); } }); // start-block createBatchData // Load the sample data from patient-data.json beforeEach<TestContext>(async (context) => { context.medplum = new MockClient(); await context.medplum.executeBatch(patientData as Bundle); }); test<TestContext>('Created RiskAssessment', async ({ medplum }) => { // Read the patient. The `medplum` mock client has already been pre-populated with test data in `beforeEach` const patients = await medplum.searchResources('Patient', { given: 'Alex' }); await handler(medplum, { bot: { reference: 'Bot/123' }, input: patients?.[0] as Patient, contentType: ContentType.FHIR_JSON, secrets: {}, }); // We expect two risk assessments to be created for the two candidate matches const riskAssessments = await medplum.searchResources('RiskAssessment'); expect(riskAssessments.length).toBe(2); expect(riskAssessments.every((assessment) => resolveId(assessment.subject) === patients[0].id)); }); // end-block createBatchData test<TestContext>('Does not create RiskAssessment due to doNotMatch List', async ({ medplum }) => { // Read two patients that should not be matched const alexSmith = await medplum.searchOne('Patient', { given: 'Alex', gender: 'male' }); const alexisSmith = await medplum.searchOne('Patient', { given: 'Alex', gender: 'female' }); if (!alexSmith || !alexisSmith) { throw new Error('Missing Input Patient'); } // Add each patient to the other's const doNotMatchAlex = (await medplum.searchOne('List', { subject: getReferenceString(alexSmith) })) as List; const doNotMatchAlexis = (await medplum.searchOne('List', { subject: getReferenceString(alexisSmith) })) as List; doNotMatchAlex.entry = [{ item: createReference(alexisSmith) }]; doNotMatchAlexis.entry = [{ item: createReference(alexSmith) }]; await medplum.updateResource(doNotMatchAlex); await medplum.updateResource(doNotMatchAlexis); await handler(medplum, { bot: { reference: 'Bot/123' }, input: alexSmith, contentType: ContentType.FHIR_JSON, secrets: {}, }); const riskAssessment = await medplum.searchResources('RiskAssessment'); expect(riskAssessment.length).toBe(1); expect(riskAssessment?.[0]?.subject?.reference).toBe(getReferenceString(alexSmith)); expect(riskAssessment?.[0]?.basis?.[0]).not.toBe(getReferenceString(alexisSmith)); }); });