Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

feat(utils): added and updated the bulk-update-patients script #1805

Draft
wants to merge 3 commits into
base: develop
Choose a base branch
from
Draft

feat(utils): added and updated the bulk-update-patients script #1805

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
ec754e4
feat(utils): added and updated the bulk-update-patients script to the…
RamilGaripov Mar 23, 2024
daa6b25
fix(utils): addressed comments
RamilGaripov May 3, 2024
61c9a51
fix(utils): added confirmation messages
RamilGaripov May 3, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
Prev Previous commit
fix(utils): added confirmation messages 
refs. metriport/metriport-internal#1350
  • Loading branch information
@RamilGaripov
RamilGaripov committed May 3, 2024
commit 61c9a51a7784396a30dca729aa6121fe97a3de7d
24 changes: 24 additions & 0 deletions packages/utils/src/bulk-update-patients.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,9 @@ import z from "zod";

dayjs.extend(duration);

const confirmationTime = dayjs.duration(10, "seconds");
const delayTime = confirmationTime.asMilliseconds();

const apiKey = getEnvVarOrFail("API_KEY");
const apiUrl = getEnvVarOrFail("API_URL");
const sqlDBCreds = getEnvVarOrFail("DB_CREDS"); // Must use the read replica
Expand Down Expand Up @@ -67,6 +70,7 @@ async function main() {

try {
const facilities = await metriportAPI.listFacilities();
await displayInitialWarningAndConfirmation(facilities.length);
const patientCQLinks = await getPatientCqLinks(sequelize, cxId);

let totalFacilities = 0;
Expand All @@ -78,6 +82,7 @@ async function main() {
totalFacilities++;
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ditto: can just call facilities.length

const patientsList = await metriportAPI.listPatients(facility.id);

await displayWarningAndConfirmation(facilities.length);
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We should be sending the amount of patients here, no?

If we're sending alarm/note for each facility, we prob should state the facility id an index.

And we should prob do this after we filter the ones created after the date filter, right?

const patientsCreatedAfter = patientsList.filter(
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
patient => new Date(patient.dateCreated!) > targetDate
Expand Down Expand Up @@ -165,4 +170,23 @@ async function updatePatient(patient: PatientDTO, address: Address, facilityId:
);
}

async function displayInitialWarningAndConfirmation(numberFacilities: number) {
const org = await metriportAPI.getOrganization();
if (!org) {
throw new Error("Organization not found");
}
console.log("\n\x1b[31m%s\x1b[0m\n", "---- ATTENTION - THIS IS NOT A SIMULATED RUN ----"); // https://stackoverflow.com/a/41407246/2099911
console.log(
`Updating patients created after ${patientCreatedDate} for organization ${org.name} (${org.id}).\nThere's ${numberFacilities} different facilities. Sleeping ${delayTime} ms before starting.`
);
await sleep(delayTime);
}

async function displayWarningAndConfirmation(numberPatients: number) {
console.log(
`There are a total of ${numberPatients} patients created after ${patientCreatedDate}.\nUpdating patients without links. Sleeping ${delayTime} ms before starting..`
);
await sleep(delayTime);
}

main();