refactor(core): migrate from dbflow to room for client

core/data/src/main/java/com/mifos/core/data/pagingSource/ClientChargesPagingSource.kt

@@ -11,9 +11,9 @@ package com.mifos.core.data.pagingSource
 
 import androidx.paging.PagingSource
 import androidx.paging.PagingState
-import com.mifos.core.entity.client.Charges
+import com.mifos.room.entities.client.Charges
 import com.mifos.core.network.datamanager.DataManagerCharge
-import com.mifos.core.objects.clients.Page
+import com.mifos.room.entities.client.Page
 import kotlinx.coroutines.suspendCancellableCoroutine
 import rx.Subscriber
 import rx.android.schedulers.AndroidSchedulers

core/data/src/main/java/com/mifos/core/data/pagingSource/ClientListPagingSource.kt

@@ -11,9 +11,9 @@ package com.mifos.core.data.pagingSource
 
 import androidx.paging.PagingSource
 import androidx.paging.PagingState
-import com.mifos.core.entity.client.Client
+import com.mifos.room.entities.client.Client
 import com.mifos.core.network.datamanager.DataManagerClient
-import com.mifos.core.objects.clients.Page
+import com.mifos.room.entities.client.Page
 import rx.Subscriber
 import rx.android.schedulers.AndroidSchedulers
 import rx.schedulers.Schedulers

core/data/src/main/java/com/mifos/core/data/repository/ClientChargeRepository.kt

@@ -10,7 +10,7 @@
 package com.mifos.core.data.repository
 
 import androidx.paging.PagingData
-import com.mifos.core.entity.client.Charges
+import com.mifos.room.entities.client.Charges
 import kotlinx.coroutines.flow.Flow
 
 /**

core/data/src/main/java/com/mifos/core/data/repository/ClientDetailsRepository.kt

@@ -9,20 +9,20 @@
  */
 package com.mifos.core.data.repository
 
-import com.mifos.core.entity.client.Client
+import com.mifos.room.entities.client.Client
 import com.mifos.room.entities.accounts.ClientAccounts
 import okhttp3.MultipartBody
 import okhttp3.ResponseBody
-import rx.Observable
+import kotlinx.coroutines.flow.Flow
 
 /**
  * Created by Aditya Gupta on 06/08/23.
  */
 interface ClientDetailsRepository {
 
-    fun uploadClientImage(id: Int, file: MultipartBody.Part?): Observable<ResponseBody>
+    fun uploadClientImage(id: Int, file: MultipartBody.Part?): Flow<ResponseBody>
 
-    fun deleteClientImage(clientId: Int): Observable<ResponseBody>
+    fun deleteClientImage(clientId: Int): Flow<ResponseBody>
 
     suspend fun getClientAccounts(clientId: Int): ClientAccounts
 

core/data/src/main/java/com/mifos/core/data/repository/ClientIdentifierDialogRepository.kt

@@ -9,9 +9,9 @@
  */
 package com.mifos.core.data.repository
 
-import com.mifos.core.objects.noncoreobjects.IdentifierCreationResponse
-import com.mifos.core.objects.noncoreobjects.IdentifierPayload
-import com.mifos.core.objects.noncoreobjects.IdentifierTemplate
+import com.mifos.room.entities.noncore.IdentifierCreationResponse
+import com.mifos.room.entities.noncore.IdentifierPayload
+import com.mifos.room.entities.noncore.IdentifierTemplate
 
 /**
  * Created by Aditya Gupta on 16/08/23.

core/data/src/main/java/com/mifos/core/data/repository/ClientIdentifiersRepository.kt

@@ -9,7 +9,7 @@
  */
 package com.mifos.core.data.repository
 
-import com.mifos.core.objects.noncoreobjects.Identifier
+import com.mifos.room.entities.noncore.Identifier
 import org.openapitools.client.models.DeleteClientsClientIdIdentifiersIdentifierIdResponse
 
 /**

core/data/src/main/java/com/mifos/core/data/repository/ClientListRepository.kt

@@ -10,10 +10,9 @@
 package com.mifos.core.data.repository
 
 import androidx.paging.PagingData
-import com.mifos.core.entity.client.Client
-import com.mifos.core.objects.clients.Page
+import com.mifos.room.entities.client.Client
+import com.mifos.room.entities.client.Page
 import kotlinx.coroutines.flow.Flow
-import rx.Observable
 
 /**
  * Created by Aditya Gupta on 08/08/23.
@@ -22,5 +21,5 @@ interface ClientListRepository {
 
     fun getAllClients(): Flow<PagingData<Client>>
 
-    fun allDatabaseClients(): Observable<Page<Client>>
+    fun allDatabaseClients(): Flow<Page<Client>>
 }

core/data/src/main/java/com/mifos/core/data/repository/CreateNewClientRepository.kt

@@ -9,27 +9,27 @@
  */
 package com.mifos.core.data.repository
 
-import com.mifos.core.entity.client.Client
-import com.mifos.core.entity.client.ClientPayload
-import com.mifos.core.entity.organisation.Office
-import com.mifos.core.entity.organisation.Staff
-import com.mifos.core.entity.templates.clients.ClientsTemplate
+import com.mifos.room.entities.client.Client
+import com.mifos.room.entities.client.ClientPayload
+import com.mifos.room.entities.organisation.Office
+import com.mifos.room.entities.organisation.Staff
+import com.mifos.room.entities.templates.clients.ClientsTemplate
 import okhttp3.MultipartBody
 import okhttp3.ResponseBody
-import rx.Observable
+import kotlinx.coroutines.flow.Flow
 
 /**
  * Created by Aditya Gupta on 10/08/23.
  */
 interface CreateNewClientRepository {
 
-    fun clientTemplate(): Observable<ClientsTemplate>
+    fun clientTemplate(): Flow<ClientsTemplate>
 
     suspend fun offices(): List<Office>
 
     suspend fun getStaffInOffice(officeId: Int): List<Staff>
 
-    fun createClient(clientPayload: ClientPayload): Observable<Client>
+    fun createClient(clientPayload: ClientPayload): Flow<Client>
 
-    fun uploadClientImage(id: Int, file: MultipartBody.Part?): Observable<ResponseBody>
+    fun uploadClientImage(id: Int, file: MultipartBody.Part?): Flow<ResponseBody>
 }

core/data/src/main/java/com/mifos/core/data/repositoryImp/ClientChargeRepositoryImp.kt

@@ -14,16 +14,17 @@ import androidx.paging.PagingConfig
 import androidx.paging.PagingData
 import com.mifos.core.data.pagingSource.ClientChargesPagingSource
 import com.mifos.core.data.repository.ClientChargeRepository
-import com.mifos.core.entity.client.Charges
+import com.mifos.room.entities.client.Charges
 import com.mifos.core.network.datamanager.DataManagerCharge
 import kotlinx.coroutines.flow.Flow
 import javax.inject.Inject
 
 /**
  * Created by Aditya Gupta on 08/08/23.
  */
-class ClientChargeRepositoryImp @Inject constructor(private val dataManagerCharge: DataManagerCharge) :
-    ClientChargeRepository {
+class ClientChargeRepositoryImp @Inject constructor(
+    private val dataManagerCharge: DataManagerCharge,
+    ) : ClientChargeRepository {
 
     override fun getClientCharges(
         clientId: Int,

core/data/src/main/java/com/mifos/core/data/repositoryImp/ClientDetailsRepositoryImp.kt

@@ -10,25 +10,26 @@
 package com.mifos.core.data.repositoryImp
 
 import com.mifos.core.data.repository.ClientDetailsRepository
-import com.mifos.core.entity.client.Client
+import com.mifos.room.entities.client.Client
 import com.mifos.core.network.datamanager.DataManagerClient
 import com.mifos.room.entities.accounts.ClientAccounts
+import kotlinx.coroutines.flow.Flow
 import okhttp3.MultipartBody
 import okhttp3.ResponseBody
-import rx.Observable
 import javax.inject.Inject
 
 /**
  * Created by Aditya Gupta on 06/08/23.
  */
-class ClientDetailsRepositoryImp @Inject constructor(private val dataManagerClient: DataManagerClient) :
-    ClientDetailsRepository {
+class ClientDetailsRepositoryImp @Inject constructor(
+    private val dataManagerClient: DataManagerClient,
+    ) : ClientDetailsRepository {
 
-    override fun uploadClientImage(id: Int, file: MultipartBody.Part?): Observable<ResponseBody> {
+    override fun uploadClientImage(id: Int, file: MultipartBody.Part?): Flow<ResponseBody> {
         return dataManagerClient.uploadClientImage(id, file)
     }
 
-    override fun deleteClientImage(clientId: Int): Observable<ResponseBody> {
+    override fun deleteClientImage(clientId: Int): Flow<ResponseBody> {
         return dataManagerClient.deleteClientImage(clientId)
     }
 

core/data/src/main/java/com/mifos/core/data/repositoryImp/ClientIdentifierDialogRepositoryImp.kt

@@ -11,16 +11,17 @@ package com.mifos.core.data.repositoryImp
 
 import com.mifos.core.data.repository.ClientIdentifierDialogRepository
 import com.mifos.core.network.datamanager.DataManagerClient
-import com.mifos.core.objects.noncoreobjects.IdentifierCreationResponse
-import com.mifos.core.objects.noncoreobjects.IdentifierPayload
-import com.mifos.core.objects.noncoreobjects.IdentifierTemplate
+import com.mifos.room.entities.noncore.IdentifierCreationResponse
+import com.mifos.room.entities.noncore.IdentifierPayload
+import com.mifos.room.entities.noncore.IdentifierTemplate
 import javax.inject.Inject
 
 /**
  * Created by Aditya Gupta on 16/08/23.
  */
-class ClientIdentifierDialogRepositoryImp @Inject constructor(private val dataManagerClient: DataManagerClient) :
-    ClientIdentifierDialogRepository {
+class ClientIdentifierDialogRepositoryImp @Inject constructor(
+    private val dataManagerClient: DataManagerClient,
+    ) : ClientIdentifierDialogRepository {
 
     override suspend fun getClientIdentifierTemplate(clientId: Int): IdentifierTemplate {
         return dataManagerClient.getClientIdentifierTemplate(clientId)

core/data/src/main/java/com/mifos/core/data/repositoryImp/ClientIdentifiersRepositoryImp.kt

@@ -11,15 +11,16 @@ package com.mifos.core.data.repositoryImp
 
 import com.mifos.core.data.repository.ClientIdentifiersRepository
 import com.mifos.core.network.datamanager.DataManagerClient
-import com.mifos.core.objects.noncoreobjects.Identifier
+import com.mifos.room.entities.noncore.Identifier
 import org.openapitools.client.models.DeleteClientsClientIdIdentifiersIdentifierIdResponse
 import javax.inject.Inject
 
 /**
  * Created by Aditya Gupta on 08/08/23.
  */
-class ClientIdentifiersRepositoryImp @Inject constructor(private val dataManagerClient: DataManagerClient) :
-    ClientIdentifiersRepository {
+class ClientIdentifiersRepositoryImp @Inject constructor(
+    private val dataManagerClient: DataManagerClient,
+    ) : ClientIdentifiersRepository {
 
     override suspend fun getClientIdentifiers(clientId: Int): List<Identifier> {
         return dataManagerClient.getClientIdentifiers(clientId)

core/data/src/main/java/com/mifos/core/data/repositoryImp/ClientListRepositoryImp.kt

@@ -14,11 +14,10 @@ import androidx.paging.PagingConfig
 import androidx.paging.PagingData
 import com.mifos.core.data.pagingSource.ClientListPagingSource
 import com.mifos.core.data.repository.ClientListRepository
-import com.mifos.core.entity.client.Client
+import com.mifos.room.entities.client.Client
 import com.mifos.core.network.datamanager.DataManagerClient
-import com.mifos.core.objects.clients.Page
+import com.mifos.room.entities.client.Page
 import kotlinx.coroutines.flow.Flow
-import rx.Observable
 import javax.inject.Inject
 
 /**
@@ -39,7 +38,7 @@ class ClientListRepositoryImp @Inject constructor(
         ).flow
     }
 
-    override fun allDatabaseClients(): Observable<Page<Client>> {
+    override fun allDatabaseClients(): Flow<Page<Client>> {
         return dataManagerClient.allDatabaseClients
     }
 }

core/data/src/main/java/com/mifos/core/data/repositoryImp/CreateNewClientRepositoryImp.kt

@@ -18,9 +18,9 @@ import com.mifos.core.entity.templates.clients.ClientsTemplate
 import com.mifos.core.network.datamanager.DataManagerClient
 import com.mifos.core.network.datamanager.DataManagerOffices
 import com.mifos.core.network.datamanager.DataManagerStaff
+import kotlinx.coroutines.flow.Flow
 import okhttp3.MultipartBody
 import okhttp3.ResponseBody
-import rx.Observable
 import javax.inject.Inject
 
 /**
@@ -32,7 +32,7 @@ class CreateNewClientRepositoryImp @Inject constructor(
     private val dataManagerStaff: DataManagerStaff,
 ) : CreateNewClientRepository {
 
-    override fun clientTemplate(): Observable<ClientsTemplate> {
+    override fun clientTemplate(): Flow<ClientsTemplate> {
         return dataManagerClient.clientTemplate
     }
 
@@ -44,11 +44,11 @@ class CreateNewClientRepositoryImp @Inject constructor(
         return dataManagerStaff.getStaffInOffice(officeId)
     }
 
-    override fun createClient(clientPayload: ClientPayload): Observable<Client> {
+    override fun createClient(clientPayload: ClientPayload): Flow<Client> {
         return dataManagerClient.createClient(clientPayload)
     }
 
-    override fun uploadClientImage(id: Int, file: MultipartBody.Part?): Observable<ResponseBody> {
+    override fun uploadClientImage(id: Int, file: MultipartBody.Part?): Flow<ResponseBody> {
         return dataManagerClient.uploadClientImage(id, file)
     }
 }

core/database/src/main/java/com/mifos/room/entities/client/ActivatePayload.kt

@@ -0,0 +1,25 @@
+/*
+ * Copyright 2024 Mifos Initiative
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/.
+ *
+ * See https://github.com/openMF/android-client/blob/master/LICENSE.md
+ */
+package com.mifos.room.entities.client
+
+import android.os.Parcelable
+import kotlinx.parcelize.Parcelize
+
+/**
+ * Created by Rajan Maurya on 09/02/17.
+ */
+@Parcelize
+data class ActivatePayload(
+    val activationDate: String? = null,
+
+    val dateFormat: String? = "dd MMMM YYYY",
+
+    val locale: String? = "en",
+) : Parcelable

core/database/src/main/java/com/mifos/room/entities/client/Page.kt

@@ -0,0 +1,19 @@
+/*
+ * Copyright 2024 Mifos Initiative
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/.
+ *
+ * See https://github.com/openMF/android-client/blob/master/LICENSE.md
+ */
+package com.mifos.room.entities.client
+
+/**
+ * Created by ishankhanna on 09/02/14.
+ */
+data class Page<T>(
+    val totalFilteredRecords: Int = 0,
+
+    val pageItems: List<T> = ArrayList(),
+)

core/database/src/main/java/com/mifos/room/entities/noncore/DocumentType.kt

@@ -0,0 +1,30 @@
+/*
+ * Copyright 2024 Mifos Initiative
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/.
+ *
+ * See https://github.com/openMF/android-client/blob/master/LICENSE.md
+ */
+package com.mifos.room.entities.noncore
+
+import android.os.Parcelable
+import kotlinx.parcelize.Parcelize
+
+/**
+ * Created by ishankhanna on 03/07/14.
+ */
+@Parcelize
+data class DocumentType(
+    val id: Int? = null,
+    val name: String? = null,
+
+    val active: Boolean? = null,
+
+    val mandatory: Boolean? = null,
+
+    val description: String? = null,
+
+    val position: Int? = null,
+) : Parcelable

core/database/src/main/java/com/mifos/room/entities/noncore/Identifier.kt

@@ -0,0 +1,31 @@
+/*
+ * Copyright 2024 Mifos Initiative
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/.
+ *
+ * See https://github.com/openMF/android-client/blob/master/LICENSE.md
+ */
+package com.mifos.room.entities.noncore
+
+import android.os.Parcelable
+import kotlinx.parcelize.Parcelize
+
+/**
+ * Created by ishankhanna on 03/07/14.
+ */
+@Parcelize
+data class Identifier(
+    val id: Int? = null,
+
+    val clientId: Int? = null,
+
+    val documentKey: String? = null,
+
+    val documentType: DocumentType? = null,
+
+    val description: String? = null,
+
+    val status: String? = null,
+) : Parcelable