SIMPLEMOB-4 Add effect to fetch complete medical records (#5726)

siddh1004 · web-flow · commit 20e66f3aa5a9 · 2026-02-05T13:17:31.000+05:30
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -4,7 +4,8 @@
 
 ### Internal
 
--Update `ci-checks.yml` & `story-link-check.sh` to verify valid jira reference
+- Update `ci-checks.yml` & `story-link-check.sh` to verify valid jira reference
+- Add effect to fetch complete medical records
 
 ## 2026.02.02
 
diff --git a/app/src/main/java/org/simple/clinic/bloodsugar/BloodSugarMeasurement.kt b/app/src/main/java/org/simple/clinic/bloodsugar/BloodSugarMeasurement.kt
@@ -99,6 +99,12 @@ data class BloodSugarMeasurement(
       ORDER BY recordedAt DESC
     """)
     fun allBloodSugars(patientUuid: UUID): Observable<List<BloodSugarMeasurement>>
+    @Query("""
+      SELECT * FROM BloodSugarMeasurements
+      WHERE patientUuid == :patientUuid AND deletedAt IS NULL
+      ORDER BY recordedAt DESC
+    """)
+    fun allBloodSugarsImmediate(patientUuid: UUID): List<BloodSugarMeasurement>
 
     @Query("""
       SELECT * FROM BloodSugarMeasurements
diff --git a/app/src/main/java/org/simple/clinic/medicalhistory/MedicalHistory.kt b/app/src/main/java/org/simple/clinic/medicalhistory/MedicalHistory.kt
@@ -24,6 +24,7 @@ import org.simple.clinic.medicalhistory.MedicalHistoryQuestion.IsOnDiabetesTreat
 import org.simple.clinic.medicalhistory.MedicalHistoryQuestion.IsOnHypertensionTreatment
 import org.simple.clinic.medicalhistory.MedicalHistoryQuestion.IsSmoking
 import org.simple.clinic.medicalhistory.MedicalHistoryQuestion.IsUsingSmokelessTobacco
+import org.simple.clinic.medicalhistory.sync.MedicalHistoryPayload
 import org.simple.clinic.patient.PatientUuid
 import org.simple.clinic.patient.SyncStatus
 import java.time.Instant
@@ -114,6 +115,28 @@ data class MedicalHistory(
     return copy(cholesterol = cholesterol)
   }
 
+  fun toPayload(): MedicalHistoryPayload {
+    return MedicalHistoryPayload(
+        uuid = uuid,
+        patientUuid = patientUuid,
+        diagnosedWithHypertension = diagnosedWithHypertension,
+        isOnTreatmentForHypertension = isOnHypertensionTreatment,
+        isOnDiabetesTreatment = isOnDiabetesTreatment,
+        hasHadHeartAttack = hasHadHeartAttack,
+        hasHadStroke = hasHadStroke,
+        hasHadKidneyDisease = hasHadKidneyDisease,
+        hasDiabetes = diagnosedWithDiabetes,
+        hasHypertension = diagnosedWithHypertension,
+        isSmoking = isSmoking,
+        isUsingSmokelessTobacco = isUsingSmokelessTobacco,
+        cholesterol = cholesterol,
+        hypertensionDiagnosedAt = hypertensionDiagnosedAt,
+        diabetesDiagnosedAt = diabetesDiagnosedAt,
+        createdAt = createdAt,
+        updatedAt = updatedAt,
+        deletedAt = deletedAt)
+  }
+
   @Dao
   interface RoomDao {
 
diff --git a/app/src/main/java/org/simple/clinic/medicalhistory/sync/MedicalHistorySync.kt b/app/src/main/java/org/simple/clinic/medicalhistory/sync/MedicalHistorySync.kt
@@ -35,30 +35,7 @@ class MedicalHistorySync @Inject constructor(
   }
 
   private fun toRequest(histories: List<MedicalHistory>): MedicalHistoryPushRequest {
-    val payloads = histories
-        .map {
-          it.run {
-            MedicalHistoryPayload(
-                uuid = uuid,
-                patientUuid = patientUuid,
-                diagnosedWithHypertension = diagnosedWithHypertension,
-                isOnTreatmentForHypertension = isOnHypertensionTreatment,
-                isOnDiabetesTreatment = isOnDiabetesTreatment,
-                hasHadHeartAttack = hasHadHeartAttack,
-                hasHadStroke = hasHadStroke,
-                hasHadKidneyDisease = hasHadKidneyDisease,
-                hasDiabetes = diagnosedWithDiabetes,
-                hasHypertension = diagnosedWithHypertension,
-                isSmoking = isSmoking,
-                isUsingSmokelessTobacco = isUsingSmokelessTobacco,
-                cholesterol = cholesterol,
-                hypertensionDiagnosedAt = hypertensionDiagnosedAt,
-                diabetesDiagnosedAt = diabetesDiagnosedAt,
-                createdAt = createdAt,
-                updatedAt = updatedAt,
-                deletedAt = deletedAt)
-          }
-        }
+    val payloads = histories.map { it.toPayload() }
     return MedicalHistoryPushRequest(payloads)
   }
 }
diff --git a/app/src/main/java/org/simple/clinic/overdue/Appointment.kt b/app/src/main/java/org/simple/clinic/overdue/Appointment.kt
@@ -51,6 +51,23 @@ data class Appointment(
     val creationFacilityUuid: UUID?
 ) : Parcelable {
 
+  fun toPayload(): AppointmentPayload {
+    return AppointmentPayload(
+        uuid = uuid,
+        patientUuid = patientUuid,
+        facilityUuid = facilityUuid,
+        creationFacilityUuid = creationFacilityUuid,
+        date = scheduledDate,
+        status = status,
+        cancelReason = cancelReason,
+        remindOn = remindOn,
+        agreedToVisit = agreedToVisit,
+        appointmentType = appointmentType,
+        createdAt = createdAt,
+        updatedAt = updatedAt,
+        deletedAt = deletedAt)
+  }
+
   fun wasCancelledBecauseOfInvalidPhoneNumber(): Boolean = status == Status.Cancelled && cancelReason == AppointmentCancelReason.InvalidPhoneNumber
 
   sealed class Status : Parcelable {
diff --git a/app/src/main/java/org/simple/clinic/overdue/AppointmentSync.kt b/app/src/main/java/org/simple/clinic/overdue/AppointmentSync.kt
@@ -33,26 +33,7 @@ class AppointmentSync @Inject constructor(
   }
 
   private fun toRequest(appointments: List<Appointment>): AppointmentPushRequest {
-    val payloads = appointments
-        .map {
-          it.run {
-            AppointmentPayload(
-                uuid = uuid,
-                patientUuid = patientUuid,
-                facilityUuid = facilityUuid,
-                creationFacilityUuid = creationFacilityUuid,
-                date = scheduledDate,
-                status = status,
-                cancelReason = cancelReason,
-                remindOn = remindOn,
-                agreedToVisit = agreedToVisit,
-                appointmentType = appointmentType,
-                createdAt = createdAt,
-                updatedAt = updatedAt,
-                deletedAt = deletedAt)
-          }
-        }
-        .toList()
+    val payloads = appointments.map { it.toPayload() }
     return AppointmentPushRequest(payloads)
   }
 }
diff --git a/app/src/main/java/org/simple/clinic/patient/PatientPhoneNumber.kt b/app/src/main/java/org/simple/clinic/patient/PatientPhoneNumber.kt
@@ -12,6 +12,7 @@ import androidx.room.PrimaryKey
 import androidx.room.Query
 import io.reactivex.Flowable
 import kotlinx.parcelize.Parcelize
+import org.simple.clinic.patient.sync.PatientPhoneNumberPayload
 import java.time.Instant
 import java.util.UUID
 
@@ -47,6 +48,18 @@ data class PatientPhoneNumber(
     val deletedAt: Instant?
 ) : Parcelable {
 
+  fun toPayload(): PatientPhoneNumberPayload {
+    return PatientPhoneNumberPayload(
+        uuid = uuid,
+        number = number,
+        type = phoneType,
+        active = active,
+        createdAt = createdAt,
+        updatedAt = updatedAt,
+        deletedAt = deletedAt
+    )
+  }
+
   fun withNumber(number: String): PatientPhoneNumber =
       copy(number = number)
 
diff --git a/app/src/main/java/org/simple/clinic/patient/PatientRepository.kt b/app/src/main/java/org/simple/clinic/patient/PatientRepository.kt
@@ -13,7 +13,7 @@ import org.simple.clinic.facility.Facility
 import org.simple.clinic.medicalhistory.Answer
 import org.simple.clinic.overdue.Appointment.AppointmentType.Manual
 import org.simple.clinic.overdue.Appointment.Status.Scheduled
-import org.simple.clinic.patient.Answer.*
+import org.simple.clinic.patient.Answer.Unanswered
 import org.simple.clinic.patient.PatientSearchCriteria.Name
 import org.simple.clinic.patient.PatientSearchCriteria.NumericCriteria
 import org.simple.clinic.patient.SyncStatus.DONE
@@ -741,6 +741,31 @@ class PatientRepository @Inject constructor(
     }
   }
 
+  fun fetchCompleteMedicalRecord(): List<CompleteMedicalRecord> {
+    val patientProfiles = database.patientDao().allPatientProfiles()
+    return patientProfiles.map { patientProfile ->
+      val patientUuid = patientProfile.patientUuid
+      val medicalHistory = database.medicalHistoryDao().historyForPatientImmediate(patientUuid)
+      val appointments = database.appointmentDao().getAllAppointmentsForPatient(patientUuid)
+      val bloodPressures = database.bloodPressureDao().allBloodPressuresRecordedSinceImmediate(
+          patientUuid,
+          Instant.EPOCH
+      )
+      val bloodSugars = database.bloodSugarDao().allBloodSugarsImmediate(patientUuid)
+
+      val prescribedDrugs = database.prescriptionDao().forPatientImmediate(patientUuid)
+
+      CompleteMedicalRecord(
+          patient = patientProfile,
+          medicalHistory = medicalHistory,
+          appointments = appointments,
+          bloodPressures = bloodPressures,
+          bloodSugars = bloodSugars,
+          prescribedDrugs = prescribedDrugs
+      )
+    }
+  }
+
   fun addIdentifiersToPatient(
       patientUuid: UUID,
       businessIds: List<BusinessId>
diff --git a/app/src/main/java/org/simple/clinic/patient/sync/PatientSync.kt b/app/src/main/java/org/simple/clinic/patient/sync/PatientSync.kt
@@ -38,9 +38,8 @@ class PatientSync @Inject constructor(
   private fun toRequest(patients: List<PatientProfile>): PatientPushRequest {
     return PatientPushRequest(
         patients.map { (patient, address, phoneNumbers, businessIds) ->
-          val numberPayloads = phoneNumbers
-              .map(::phoneNumberPayload)
-              .let { payloads -> if (payloads.isEmpty()) null else payloads }
+          val numberPayloads = phoneNumbers.map { it.toPayload() }
+              .let { payloads -> payloads.ifEmpty { null } }
 
           val businessIdPayloads = businessIds
               .map { it.toPayload() }
@@ -71,17 +70,4 @@ class PatientSync @Inject constructor(
         }
     )
   }
-
-  private fun phoneNumberPayload(phoneNumber: PatientPhoneNumber): PatientPhoneNumberPayload {
-    return phoneNumber.run {
-      PatientPhoneNumberPayload(
-          uuid = uuid,
-          number = number,
-          type = phoneType,
-          active = active,
-          createdAt = createdAt,
-          updatedAt = updatedAt,
-          deletedAt = deletedAt)
-    }
-  }
 }
diff --git a/app/src/main/java/org/simple/clinic/settings/SettingsEffect.kt b/app/src/main/java/org/simple/clinic/settings/SettingsEffect.kt
@@ -1,5 +1,7 @@
 package org.simple.clinic.settings
 
+import org.simple.clinic.scanid.ScanSimpleIdEffect
+
 sealed class SettingsEffect
 
 data object LoadUserDetailsEffect : SettingsEffect()
@@ -23,3 +25,6 @@ data object ShowConfirmLogoutDialog : SettingsViewEffect()
 data object RestartApp : SettingsViewEffect()
 
 data object GoBack : SettingsViewEffect()
+
+data object FetchCompleteMedicalRecords : SettingsEffect()
+
diff --git a/app/src/main/java/org/simple/clinic/settings/SettingsEffectHandler.kt b/app/src/main/java/org/simple/clinic/settings/SettingsEffectHandler.kt
@@ -8,6 +8,7 @@ import dagger.assisted.AssistedInject
 import io.reactivex.ObservableTransformer
 import org.simple.clinic.appupdate.AppUpdateState
 import org.simple.clinic.appupdate.CheckAppUpdateAvailability
+import org.simple.clinic.patient.PatientRepository
 import org.simple.clinic.storage.DatabaseEncryptor
 import org.simple.clinic.user.UserSession
 import org.simple.clinic.util.filterAndUnwrapJust
@@ -16,6 +17,7 @@ import org.simple.clinic.util.scheduler.SchedulersProvider
 class SettingsEffectHandler @AssistedInject constructor(
     private val userSession: UserSession,
     private val settingsRepository: SettingsRepository,
+    private val patientRepository: PatientRepository,
     private val schedulersProvider: SchedulersProvider,
     private val appVersionFetcher: AppVersionFetcher,
     private val appUpdateAvailability: CheckAppUpdateAvailability,
@@ -39,6 +41,7 @@ class SettingsEffectHandler @AssistedInject constructor(
       .addConsumer(SettingsViewEffect::class.java, viewEffectsConsumer::accept)
       .addTransformer(LogoutUser::class.java, logoutUser())
       .addTransformer(LoadDatabaseEncryptionStatus::class.java, loadDatabaseEncryptionStatus())
+      .addTransformer(FetchCompleteMedicalRecords::class.java, fetchCompleteMedicalRecords())
       .build()
 
   private fun loadDatabaseEncryptionStatus(): ObservableTransformer<LoadDatabaseEncryptionStatus, SettingsEvent> {
@@ -97,4 +100,13 @@ class SettingsEffectHandler @AssistedInject constructor(
           }
     }
   }
+
+  private fun fetchCompleteMedicalRecords(): ObservableTransformer<FetchCompleteMedicalRecords, SettingsEvent> {
+    return ObservableTransformer { effects ->
+      effects
+          .observeOn(schedulersProvider.io())
+          .map { patientRepository.fetchCompleteMedicalRecord() }
+          .map(::MedicalRecordsFetched)
+    }
+  }
 }
diff --git a/app/src/main/java/org/simple/clinic/settings/SettingsEvent.kt b/app/src/main/java/org/simple/clinic/settings/SettingsEvent.kt
@@ -1,5 +1,7 @@
 package org.simple.clinic.settings
 
+import org.simple.clinic.patient.CompleteMedicalRecord
+import org.simple.clinic.scanid.ScanSimpleIdEvent
 import org.simple.clinic.user.UserSession
 import org.simple.clinic.widgets.UiEvent
 
@@ -32,3 +34,7 @@ data object BackClicked : SettingsEvent() {
 }
 
 data class DatabaseEncryptionStatusLoaded(val isDatabaseEncrypted: Boolean) : SettingsEvent()
+
+data class MedicalRecordsFetched(
+    val completeMedicalRecords: List<CompleteMedicalRecord>
+) : SettingsEvent()
diff --git a/app/src/main/java/org/simple/clinic/settings/SettingsUpdate.kt b/app/src/main/java/org/simple/clinic/settings/SettingsUpdate.kt
@@ -26,6 +26,8 @@ class SettingsUpdate : Update<SettingsModel, SettingsEvent, SettingsEffect> {
       is DatabaseEncryptionStatusLoaded -> next(
           model.databaseEncryptionStatusLoaded(isDatabaseEncrypted = event.isDatabaseEncrypted)
       )
+
+      is MedicalRecordsFetched -> noChange()
     }
   }
 
diff --git a/app/src/test/java/org/simple/clinic/settings/SettingsEffectHandlerTest.kt b/app/src/test/java/org/simple/clinic/settings/SettingsEffectHandlerTest.kt
@@ -1,20 +1,23 @@
 package org.simple.clinic.settings
 
+import io.reactivex.Observable
+import io.reactivex.Single
+import org.junit.After
+import org.junit.Test
 import org.mockito.kotlin.doReturn
 import org.mockito.kotlin.mock
 import org.mockito.kotlin.verify
-import org.mockito.kotlin.verifyNoMoreInteractions
 import org.mockito.kotlin.verifyNoInteractions
+import org.mockito.kotlin.verifyNoMoreInteractions
 import org.mockito.kotlin.whenever
-import io.reactivex.Observable
-import io.reactivex.Single
-import org.junit.After
-import org.junit.Test
 import org.simple.clinic.TestData
 import org.simple.clinic.appupdate.AppUpdateState
 import org.simple.clinic.appupdate.AppUpdateState.ShowAppUpdate
 import org.simple.clinic.appupdate.CheckAppUpdateAvailability
 import org.simple.clinic.mobius.EffectHandlerTestCase
+import org.simple.clinic.patient.PatientRepository
+import org.simple.clinic.patient.businessid.Identifier
+import org.simple.clinic.patient.businessid.Identifier.IdentifierType.BpPassport
 import org.simple.clinic.storage.DatabaseEncryptor
 import org.simple.clinic.user.User
 import org.simple.clinic.user.UserSession
@@ -33,9 +36,12 @@ class SettingsEffectHandlerTest {
   private val checkAppUpdateAvailability = mock<CheckAppUpdateAvailability>()
   private val databaseEncryptor = mock<DatabaseEncryptor>()
 
+  private val patientRepository = mock<PatientRepository>()
+
   private val effectHandler = SettingsEffectHandler(
       userSession = userSession,
       settingsRepository = settingsRepository,
+      patientRepository = patientRepository,
       schedulersProvider = TrampolineSchedulersProvider(),
       appVersionFetcher = appVersionFetcher,
       appUpdateAvailability = checkAppUpdateAvailability,
@@ -212,4 +218,27 @@ class SettingsEffectHandlerTest {
 
     testCase.assertOutgoingEvents(DatabaseEncryptionStatusLoaded(isDatabaseEncrypted = true))
   }
+
+  @Test
+  fun `when fetch complete medical records effect is received, then fetch all medical records`() {
+    //given
+    val identifier = Identifier("4f1cea37-70ff-498e-bd09-ad0ca75628ff", BpPassport)
+    val commonIdentifier = TestData.businessId(identifier = identifier)
+    val patientUuid1 = TestData.patientProfile(patientUuid = UUID.fromString("0b78c024-f527-4306-9e20-6ae6d7251e9b"), businessId = commonIdentifier)
+    val patientUuid2 = TestData.patientProfile(patientUuid = UUID.fromString("47fdb968-9512-4e50-b95f-cc83c6de4b0a"), businessId = commonIdentifier)
+
+    val completeMedicalRecord = TestData.completeMedicalRecord(patient = patientUuid1)
+    val completeMedicalRecord2 = TestData.completeMedicalRecord(patient = patientUuid2)
+
+    val medicalRecords = listOf(completeMedicalRecord, completeMedicalRecord2)
+
+    whenever(patientRepository.fetchCompleteMedicalRecord()) doReturn medicalRecords
+
+    // when
+    testCase.dispatch(FetchCompleteMedicalRecords)
+
+    // then
+    testCase.assertOutgoingEvents(MedicalRecordsFetched(medicalRecords))
+    verifyNoMoreInteractions(uiActions)
+  }
 }
