110 lines
4.3 KiB
JavaScript
110 lines
4.3 KiB
JavaScript
const config = require('../config');
|
|
const { createBusRequest } = require('../utils/busAuth');
|
|
const { default: axios } = require('axios');
|
|
|
|
|
|
const INDICE_ATENCION_URL = config.bus.documentRegistryUrl;
|
|
|
|
const LOCAL_URL = "https://federador.qa-bus-interoperabilidad.svc.cluster.local:8080/fhir/DocumentReference";
|
|
|
|
function maskPrivateURL(patientId) {
|
|
return patientId.replace(LOCAL_URL, INDICE_ATENCION_URL);
|
|
}
|
|
|
|
async function fetchDocumentReference(token, id) {
|
|
const request = createBusRequest(token);
|
|
const response = await request.get(
|
|
URL.parse(id, INDICE_ATENCION_URL)
|
|
);
|
|
return response;
|
|
}
|
|
|
|
/**
|
|
* Posts a DocumentReference to the document registry
|
|
* (POST /fhir/DocumentReference).
|
|
* @param {string} documentRegistryUrl - Base URL of the document registry service.
|
|
* @param {string} token - Bearer access token.
|
|
* @param {object} documentReference - FHIR DocumentReference resource to register.
|
|
* @returns {Promise<object>} The created DocumentReference resource returned by the registry.
|
|
* @todo Agregar system http://federador.msal.gob.ar/uri para armar el identificador del custodian: http://federador.msal.gob.ar/uri|<custodianId>
|
|
*/
|
|
async function postDocumentReference(token, documentReference) {
|
|
const request = createBusRequest(token);
|
|
const response = await request.post(
|
|
URL.parse(INDICE_ATENCION_URL),
|
|
documentReference
|
|
);
|
|
response.headers['location'] = maskPrivateURL(response.headers['location']);
|
|
return response;
|
|
}
|
|
/**
|
|
* Searches DocumentReferences in the document registry by patient subject identifier
|
|
* (GET /fhir/DocumentReference?subject=system|value).
|
|
* @param {string} documentRegistryUrl - Base URL of the document registry service.
|
|
* @param {string} token - Bearer access token.
|
|
* @param {string} subjectSystem - Identifier system of the patient.
|
|
* @param {string} subjectValue - Identifier value of the patient.
|
|
* @returns {Promise<object>} FHIR Bundle (searchset) with matching DocumentReferences.
|
|
*/
|
|
async function searchDocumentReferenceBySubject(token, subjectSystem, subjectValue) {
|
|
const request = createBusRequest(token);
|
|
const response = await request.get(
|
|
URL.parse(INDICE_ATENCION_URL),
|
|
{
|
|
params: { subject: `${subjectSystem}|${subjectValue}` },
|
|
}
|
|
);
|
|
return response;
|
|
}
|
|
|
|
/**
|
|
* Searches DocumentReferences in the document registry by patient internal ID
|
|
* (GET /fhir/DocumentReference?patient=value).
|
|
* @param {string} documentRegistryUrl - Base URL of the document registry service.
|
|
* @param {string} token - Bearer access token.
|
|
* @param {string} patientId - Internal patient ID in the document registry.
|
|
* @returns {Promise<object>} FHIR Bundle (searchset) with matching DocumentReferences.
|
|
*/
|
|
async function searchDocumentReferenceByPatient(token, patientId) {
|
|
const request = createBusRequest(token);
|
|
const response = await request.get(
|
|
URL.parse(INDICE_ATENCION_URL),
|
|
{
|
|
params: { subject: patientId },
|
|
}
|
|
);
|
|
return response;
|
|
}
|
|
|
|
/**
|
|
* Searches DocumentReferences in the document registry filtered by subject, custodian and type
|
|
* (GET /fhir/DocumentReference?subject=...&custodian=...&type=...).
|
|
* @param {string} documentRegistryUrl - Base URL of the document registry service.
|
|
* @param {string} token - Bearer access token.
|
|
* @param {{ system: string, value: string }} subject - Patient identifier (TokenParam).
|
|
* @param {{ system: string, value: string }} custodian - Custodian identifier (TokenParam).
|
|
* @param {{ system: string, value: string }} type - Document type (TokenParam, e.g. { system: 'http://loinc.org', value: '60591-5' }).
|
|
* @returns {Promise<object>} FHIR Bundle (searchset) with matching DocumentReferences.
|
|
*/
|
|
async function searchDocumentReference(token, subject, custodian, type) {
|
|
const request = createBusRequest(token);
|
|
const response = await request.get(
|
|
URL.parse(INDICE_ATENCION_URL),
|
|
{
|
|
params: {
|
|
subject: `${subject.system}|${subject.value}`,
|
|
custodian: `${custodian.system}|${custodian.value}`,
|
|
type: `${type.system}|${type.value}`,
|
|
},
|
|
});
|
|
return response;
|
|
}
|
|
|
|
module.exports = {
|
|
fetchDocumentReference,
|
|
postDocumentReference,
|
|
searchDocumentReferenceBySubject,
|
|
searchDocumentReferenceByPatient,
|
|
searchDocumentReference,
|
|
};
|