Merge pull request #651 from OpenFn/feature/971-satusehat-examples

satusehat: add job examples

Author: josephjclark

adaptors/library/jobs/satusehat-create-condition.js

@@ -0,0 +1,91 @@
+// Map diagnosis objects from commcare into Condition resources
+
+fn(state => {
+  state.conditions = state.visit.diagnosis.map(diagnosis => {
+    const diagnosisName = diagnosis.fields.name;
+    const code = diagnosis.fields['icd_10_code'];
+
+    return {
+      resourceType: 'Condition',
+      clinicalStatus: {
+        coding: [
+          {
+            system: 'http://terminology.hl7.org/CodeSystem/condition-clinical',
+            code: 'active',
+            display: 'Active',
+          },
+        ],
+      },
+      verificationStatus: {
+        coding: [
+          {
+            system:
+              'http://terminology.hl7.org/CodeSystem/condition-ver-status',
+            code: 'confirmed',
+            display: 'Confirmed',
+          },
+        ],
+      },
+      category: [
+        {
+          coding: [
+            {
+              system:
+                'http://terminology.hl7.org/CodeSystem/condition-category',
+              code: 'encounter-diagnosis',
+              display: 'Encounter Diagnosis',
+            },
+          ],
+        },
+      ],
+      subject: {
+        reference: `Patient/${state.patient.ihs_number}`,
+        display: state.patient.full_name,
+      },
+      encounter: {
+        reference: `Encounter/${state.encounterId}`,
+        display:
+          state.patient.full_name +
+          "'s " +
+          state.visit.properties.visit_type +
+          ' on ' +
+          state.visit.properties.visit_date,
+      },
+      code: {
+        coding: [
+          {
+            system: 'http://hl7.org/fhir/sid/icd-10',
+            code: code,
+            display: diagnosisName,
+          },
+        ],
+      },
+      bodySite: [
+        {
+          coding: [
+            {
+              system: 'http://snomed.info/sct',
+              code: '74262004',
+              display: 'Oral cavity structure',
+            },
+          ],
+        },
+      ],
+      recorder: {
+        reference: state.encounter.resource.participant[0].individual.reference,
+      },
+      onsetDateTime: state.visit.visit_date,
+      recordedDate: state.visit.visit_date,
+    };
+  });
+  return state;
+});
+
+// Post our condition resources to Satusehat
+post('Condition', $.conditions);
+
+fn(state => {
+  //  Store the newly created resources, created by the server, into state for the next step
+  state.conditions = state.data;
+  return state;
+});

adaptors/library/jobs/satusehat-create-encounter.js

@@ -0,0 +1,102 @@
+// Create an encounter in Satusehat based on an incoming Commcare visit
+
+fn(state => {
+  state.encounterId = util.uuid();
+
+  state.encounter = {
+    id: state.encounterId,
+    resourceType: 'Encounter',
+    identifier: [
+      {
+        system: `http://sys-ids.kemkes.go.id/encounter/${state.visit.organizationId}`,
+        value: state.visit.case_id,
+      },
+    ],
+    status: 'arrived',
+    class: {
+      system: 'http://terminology.hl7.org/CodeSystem/v3-ActCode',
+      code: 'AMB',
+      display: 'ambulatory',
+    },
+    subject: {
+      reference: 'Patient/P00805884304',
+      display: 'Elizabeth Dior',
+    },
+    participant: [
+      {
+        type: [
+          {
+            coding: [
+              {
+                system:
+                  'http://terminology.hl7.org/CodeSystem/v3-ParticipationType',
+                code: 'ATND',
+                display: 'attender',
+              },
+            ],
+          },
+        ],
+        individual: {
+          reference: `Practitioner/N10000001`,
+          display: 'Voigt',
+        },
+      },
+    ],
+    period: {
+      start: state.visit.visit_date,
+      end: state.visit.visit_date,
+    },
+
+    location: [
+      {
+        location: {
+          reference: `Location/574d5ffd-2dc2-453b-a787-d1c63cc89ae4`,
+          display: `PLKB`,
+        },
+        extension: [
+          {
+            url: 'https://fhir.kemkes.go.id/r4/StructureDefinition/ServiceClass',
+            extension: [
+              {
+                url: 'value',
+                valueCodeableConcept: {
+                  coding: [
+                    {
+                      system:
+                        'http://terminology.kemkes.go.id/CodeSystem/locationServiceClass-Outpatient',
+                      code: 'reguler',
+                      display: 'Kelas Reguler',
+                    },
+                  ],
+                },
+              },
+            ],
+          },
+        ],
+      },
+    ],
+    statusHistory: [
+      {
+        status: 'arrived',
+        period: {
+          start: state.visit.visit_date,
+          end: state.visit.visit_date,
+        },
+      },
+    ],
+    serviceProvider: {
+      reference: `Organization/${state.visit.organizationId}`,
+    },
+  };
+
+  return state;
+});
+
+// Post our encounter resources to Satusehat
+post('Encounter', $.encounter);
+
+fn(state => {
+  //  Store the newly created resources, created by the server, into state for the next step
+  state.encounter = state.data;
+  return state;
+});

adaptors/library/jobs/satusehat-create-medication.js

@@ -0,0 +1,71 @@
+// Create medication in Satusehat based on an incoming Commcare visit
+
+fn(state => {
+  // state.visit is a Commcare Visit record
+  const properties = state.visit.properties;
+  const medicineKeys = Object.keys(properties).filter(
+    key =>
+      key.startsWith('prescription_') &&
+      !key.includes('_amount') &&
+      !key.includes('_instruction') &&
+      !key.includes('_dose')
+  );
+
+  const medicationId = util.uuid();
+
+  // Map medication data for each relevant key
+  state.medication = medicineKeys.map(item => {
+    return {
+      resourceType: 'Medication',
+      id: state => medicationId,
+      meta: {
+        profile: [
+          'https://fhir.kemkes.go.id/r4/StructureDefinition/Medication',
+        ],
+      },
+      identifier: [
+        {
+          system: `http://sys-ids.kemkes.go.id/medication/${state.visit.satusehatId}`,
+          use: 'usual',
+          value: item.fields['Nama'],
+        },
+      ],
+      code: {
+        coding: [
+          {
+            system: 'http://sys-ids.kemkes.go.id/kfa',
+            code: item.fields['kfa_codes'],
+            display: item.fields['Nama'],
+          },
+        ],
+      },
+      status: 'active',
+      extension: [
+        {
+          url: 'https://fhir.kemkes.go.id/r4/StructureDefinition/MedicationType',
+          valueCodeableConcept: {
+            coding: [
+              {
+                system:
+                  'http://terminology.kemkes.go.id/CodeSystem/medication-type',
+                code: 'NC',
+                display: 'Non-compound',
+              },
+            ],
+          },
+        },
+      ],
+    };
+  });
+
+  return state;
+});
+
+// Post our medication resources to Satusehat
+post('Medication', $.medication);
+
+fn(state => {
+  //  Store the newly created resources, created by the server, into state for the next step
+  state.medication = state.data;
+  return state;
+});