Implemented fineract sdk

Author: Aditya-gupta99

core/data/src/main/java/com/mifos/core/data/paging_source/CenterListPagingSource.kt

@@ -41,33 +41,10 @@ class CenterListPagingSource(private val dataManagerCenter: DataManagerCenter) :
         }
     }
 
-    private suspend fun getCenterList(position: Int): Pair<List<Center>, Int> =
-        suspendCoroutine { continuation ->
-            try {
-                dataManagerCenter.getCenters(true, position, 10)
-                    .observeOn(AndroidSchedulers.mainThread())
-                    .subscribeOn(Schedulers.io())
-                    .subscribe(object : Subscriber<Page<Center>>() {
-                        override fun onCompleted() {
-                        }
-
-                        override fun onError(exception: Throwable) {
-                            continuation.resumeWithException(exception)
-                        }
-
-                        override fun onNext(center: Page<Center>) {
-                            continuation.resume(
-                                Pair(
-                                    center.pageItems,
-                                    center.totalFilteredRecords
-                                )
-                            )
-                        }
-                    })
-            } catch (exception: Exception) {
-                continuation.resumeWithException(exception)
-            }
-        }
+    private suspend fun getCenterList(position: Int): Pair<List<Center>, Int> {
+        val pagedClient = dataManagerCenter.getCenters(true, position, 10)
+        return Pair(pagedClient.pageItems, pagedClient.totalFilteredRecords)
+    }
 
     private suspend fun getCenterDbList(): List<Center> = suspendCoroutine { continuation ->
         try {

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

@@ -5,7 +5,6 @@ import androidx.paging.PagingState
 import com.mifos.core.network.datamanager.DataManagerClient
 import com.mifos.core.objects.client.Client
 import com.mifos.core.objects.client.Page
-import kotlinx.coroutines.suspendCancellableCoroutine
 import rx.Subscriber
 import rx.android.schedulers.AndroidSchedulers
 import rx.schedulers.Schedulers
@@ -48,24 +47,8 @@ class ClientListPagingSource(
     }
 
     private suspend fun getClientList(position: Int): Pair<List<Client>, Int> {
-        return suspendCancellableCoroutine { continuation ->
-            dataManagerClient.getAllClients(offset = position, 10)
-                .observeOn(AndroidSchedulers.mainThread())
-                .subscribeOn(Schedulers.io())
-                .subscribe(object : Subscriber<Page<Client>>() {
-                    override fun onCompleted() {
-
-                    }
-
-                    override fun onError(e: Throwable) {
-                        continuation.resumeWithException(e)
-                    }
-
-                    override fun onNext(t: Page<Client>) {
-                        continuation.resume(Pair(t.pageItems, t.totalFilteredRecords))
-                    }
-                })
-        }
+        val response = dataManagerClient.getAllClients(position, 10)
+        return Pair(response.pageItems, response.totalFilteredRecords)
     }
 
     private suspend fun getClientDbList(): List<Client> {

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

@@ -2,8 +2,8 @@ package com.mifos.core.data.repository
 
 import com.mifos.core.network.GenericResponse
 import com.mifos.core.objects.client.ActivatePayload
-import org.apache.fineract.client.models.PostCentersCenterIdResponse
-import org.apache.fineract.client.models.PostClientsClientIdResponse
+import org.openapitools.client.models.PostCentersCenterIdResponse
+import org.openapitools.client.models.PostClientsClientIdResponse
 import rx.Observable
 
 /**
@@ -12,15 +12,15 @@ import rx.Observable
 
 interface ActivateRepository {
 
-    fun activateClient(
+    suspend fun activateClient(
         clientId: Int,
         clientActivate: ActivatePayload?
-    ): Observable<PostClientsClientIdResponse>
+    ): PostClientsClientIdResponse
 
-    fun activateCenter(
+    suspend fun activateCenter(
         centerId: Int,
         activatePayload: ActivatePayload?
-    ): Observable<PostCentersCenterIdResponse>
+    ): PostCentersCenterIdResponse
 
     fun activateGroup(
         groupId: Int,

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

@@ -15,8 +15,8 @@ interface ClientDetailsRepository {
 
     fun deleteClientImage(clientId: Int): Observable<ResponseBody>
 
-    fun getClientAccounts(clientId: Int): Observable<ClientAccounts>
+    suspend fun getClientAccounts(clientId: Int): ClientAccounts
 
-    fun getClient(clientId: Int): Observable<Client>
+    suspend fun getClient(clientId: Int): Client
 
 }

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

@@ -3,14 +3,13 @@ package com.mifos.core.data.repository
 import com.mifos.core.objects.noncore.IdentifierCreationResponse
 import com.mifos.core.objects.noncore.IdentifierPayload
 import com.mifos.core.objects.noncore.IdentifierTemplate
-import rx.Observable
 
 /**
  * Created by Aditya Gupta on 16/08/23.
  */
 interface ClientIdentifierDialogRepository {
 
-    fun getClientIdentifierTemplate(clientId: Int): Observable<IdentifierTemplate>
+    suspend fun getClientIdentifierTemplate(clientId: Int): IdentifierTemplate
 
     suspend fun createClientIdentifier(
         clientId: Int, identifierPayload: IdentifierPayload

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

@@ -1,18 +1,17 @@
 package com.mifos.core.data.repository
 
 import com.mifos.core.objects.noncore.Identifier
-import org.apache.fineract.client.models.DeleteClientsClientIdIdentifiersIdentifierIdResponse
-import rx.Observable
+import org.openapitools.client.models.DeleteClientsClientIdIdentifiersIdentifierIdResponse
 
 /**
  * Created by Aditya Gupta on 08/08/23.
  */
 interface ClientIdentifiersRepository {
 
-    fun getClientIdentifiers(clientId: Int): Observable<List<Identifier>>
+    suspend fun getClientIdentifiers(clientId: Int): List<Identifier>
 
-    fun deleteClientIdentifier(
+    suspend fun deleteClientIdentifier(
         clientId: Int,
         identifierId: Int
-    ): Observable<DeleteClientsClientIdIdentifiersIdentifierIdResponse>
+    ): DeleteClientsClientIdIdentifiersIdentifierIdResponse
 }

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

@@ -16,9 +16,9 @@ interface CreateNewClientRepository {
 
     fun clientTemplate(): Observable<ClientsTemplate>
 
-    fun offices(): Observable<List<Office>>
+    suspend fun offices(): List<Office>
 
-    fun getStaffInOffice(officeId: Int): Observable<List<Staff>>
+    suspend fun getStaffInOffice(officeId: Int): List<Staff>
 
     fun createClient(clientPayload: ClientPayload): Observable<Client>
 

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

@@ -1,6 +1,5 @@
 package com.mifos.core.data.repository
 
-import com.mifos.core.datastore.PrefManager
 import com.mifos.core.objects.group.GroupPayload
 import com.mifos.core.objects.organisation.Office
 import com.mifos.core.objects.response.SaveResponse
@@ -11,7 +10,7 @@ import rx.Observable
  */
 interface CreateNewGroupRepository {
 
-    fun offices(): Observable<List<Office>>
+    suspend fun offices(): List<Office>
 
     fun createGroup(groupPayload: GroupPayload): Observable<SaveResponse>
 }

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

@@ -1,8 +1,7 @@
 package com.mifos.core.data.repository
 
 import com.google.gson.JsonArray
-import org.apache.fineract.client.models.DeleteDataTablesDatatableAppTableIdDatatableIdResponse
-import rx.Observable
+import org.openapitools.client.models.DeleteDataTablesDatatableAppTableIdDatatableIdResponse
 
 /**
  * Created by Aditya Gupta on 10/08/23.
@@ -11,10 +10,10 @@ interface DataTableDataRepository {
 
     suspend fun getDataTableInfo(table: String, entityId: Int): JsonArray
 
-    fun deleteDataTableEntry(
-        table: String?,
+    suspend fun deleteDataTableEntry(
+        table: String,
         entity: Int,
         rowId: Int
-    ): Observable<DeleteDataTablesDatatableAppTableIdDatatableIdResponse>
+    ): DeleteDataTablesDatatableAppTableIdDatatableIdResponse
 
 }

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

@@ -1,13 +1,12 @@
 package com.mifos.core.data.repository
 
 import com.mifos.core.objects.noncore.DataTable
-import rx.Observable
 
 /**
  * Created by Aditya Gupta on 08/08/23.
  */
 interface DataTableRepository {
 
-    fun getDataTable(tableName: String?): Observable<List<DataTable>>
+    suspend fun getDataTable(tableName: String?): List<DataTable>
 
 }