feat: Implemented fineract client sdk

build-logic/convention/src/main/kotlin/org/mifos/Badging.kt

@@ -19,7 +19,7 @@ import org.gradle.api.tasks.OutputFile
 import org.gradle.api.tasks.PathSensitive
 import org.gradle.api.tasks.PathSensitivity
 import org.gradle.api.tasks.TaskAction
-import org.gradle.internal.extensions.stdlib.capitalized
+import org.gradle.configurationcache.extensions.capitalized
 import org.gradle.kotlin.dsl.register
 import org.gradle.language.base.plugins.LifecycleBasePlugin
 import org.gradle.process.ExecOperations

core/data/src/main/java/com/mifos/core/data/di/DataModule.kt

@@ -49,18 +49,15 @@ import com.mifos.core.data.repository.SearchRepository
 import com.mifos.core.data.repository.SignatureRepository
 import com.mifos.core.data.repository.SurveyListRepository
 import com.mifos.core.data.repository.SurveySubmitRepository
-import com.mifos.core.data.repositoryImp.ActivateRepositoryImp
 import com.mifos.core.data.repositoryImp.CenterDetailsRepositoryImp
 import com.mifos.core.data.repositoryImp.CenterListRepositoryImp
 import com.mifos.core.data.repositoryImp.ChargeDialogRepositoryImp
 import com.mifos.core.data.repositoryImp.CheckerInboxRepositoryImp
 import com.mifos.core.data.repositoryImp.CheckerInboxTasksRepositoryImp
 import com.mifos.core.data.repositoryImp.ClientChargeRepositoryImp
 import com.mifos.core.data.repositoryImp.ClientIdentifierDialogRepositoryImp
-import com.mifos.core.data.repositoryImp.ClientIdentifiersRepositoryImp
 import com.mifos.core.data.repositoryImp.CreateNewCenterRepositoryImp
 import com.mifos.core.data.repositoryImp.CreateNewGroupRepositoryImp
-import com.mifos.core.data.repositoryImp.DataTableDataRepositoryImp
 import com.mifos.core.data.repositoryImp.DataTableListRepositoryImp
 import com.mifos.core.data.repositoryImp.DataTableRepositoryImp
 import com.mifos.core.data.repositoryImp.DataTableRowDialogRepositoryImp
@@ -89,6 +86,9 @@ import com.mifos.core.data.repositoryImp.SearchRepositoryImp
 import com.mifos.core.data.repositoryImp.SignatureRepositoryImp
 import com.mifos.core.data.repositoryImp.SurveyListRepositoryImp
 import com.mifos.core.data.repositoryImp.SurveySubmitRepositoryImp
+import com.mifos.core.data.repository_imp.ActivateRepositoryImp
+import com.mifos.core.data.repository_imp.ClientIdentifiersRepositoryImp
+import com.mifos.core.data.repository_imp.DataTableDataRepositoryImp
 import dagger.Binds
 import dagger.Module
 import dagger.hilt.InstallIn

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

@@ -1,12 +1,3 @@
-/*
- * 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.core.data.pagingSource
 
 import androidx.paging.PagingSource
@@ -27,7 +18,7 @@ class CenterListPagingSource(private val dataManagerCenter: DataManagerCenter) :
     override fun getRefreshKey(state: PagingState<Int, Center>): Int? {
         return state.anchorPosition?.let { position ->
             state.closestPageToPosition(position)?.prevKey?.plus(10) ?: state.closestPageToPosition(
-                position,
+                position
             )?.nextKey?.minus(10)
         }
     }
@@ -43,43 +34,21 @@ class CenterListPagingSource(private val dataManagerCenter: DataManagerCenter) :
             LoadResult.Page(
                 data = centerListWithSync,
                 prevKey = if (position <= 0) null else position - 10,
-                nextKey = if (position >= totalCenters) null else position + 10,
+                nextKey = if (position >= totalCenters) null else position + 10
             )
         } catch (e: Exception) {
             LoadResult.Error(e)
         }
     }
 
-    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 {
+
             dataManagerCenter.allDatabaseCenters
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribeOn(Schedulers.io())
@@ -100,9 +69,10 @@ class CenterListPagingSource(private val dataManagerCenter: DataManagerCenter) :
         }
     }
 
+
     private fun getCenterListWithSync(
         centerList: List<Center>,
-        centerDbList: List<Center>,
+        centerDbList: List<Center>
     ): List<Center> {
         if (centerDbList.isNotEmpty()) {
             centerList.forEach { center ->
@@ -115,4 +85,4 @@ class CenterListPagingSource(private val dataManagerCenter: DataManagerCenter) :
         }
         return centerList
     }
-}
+}

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

@@ -1,20 +1,10 @@
-/*
- * 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.core.data.pagingSource
 
 import androidx.paging.PagingSource
 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
@@ -27,13 +17,13 @@ import kotlin.coroutines.suspendCoroutine
  */
 
 class ClientListPagingSource(
-    private val dataManagerClient: DataManagerClient,
+    private val dataManagerClient: DataManagerClient
 ) : PagingSource<Int, Client>() {
 
     override fun getRefreshKey(state: PagingState<Int, Client>): Int? {
         return state.anchorPosition?.let { position ->
             state.closestPageToPosition(position)?.prevKey?.plus(10) ?: state.closestPageToPosition(
-                position,
+                position
             )?.nextKey?.minus(10)
         }
     }
@@ -49,31 +39,16 @@ class ClientListPagingSource(
             LoadResult.Page(
                 data = clientListWithSync,
                 prevKey = if (position <= 0) null else position - 10,
-                nextKey = if (position >= totalClients) null else position + 10,
+                nextKey = if (position >= totalClients) null else position + 10
             )
         } catch (e: Exception) {
             LoadResult.Error(e)
         }
     }
 
     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> {
@@ -98,7 +73,7 @@ class ClientListPagingSource(
 
     private fun getClientListWithSync(
         clientList: List<Client>,
-        clientDbList: List<Client>,
+        clientDbList: List<Client>
     ): List<Client> {
         if (clientDbList.isNotEmpty()) {
             clientList.forEach { client ->
@@ -111,4 +86,4 @@ class ClientListPagingSource(
         }
         return clientList
     }
-}
+}

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

@@ -1,18 +1,9 @@
-/*
- * 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.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
 
 /**
@@ -21,18 +12,19 @@ import rx.Observable
 
 interface ActivateRepository {
 
-    fun activateClient(
+    suspend fun activateClient(
         clientId: Int,
-        clientActivate: ActivatePayload?,
-    ): Observable<PostClientsClientIdResponse>
+        clientActivate: ActivatePayload?
+    ): PostClientsClientIdResponse
 
-    fun activateCenter(
+    suspend fun activateCenter(
         centerId: Int,
-        activatePayload: ActivatePayload?,
-    ): Observable<PostCentersCenterIdResponse>
+        activatePayload: ActivatePayload?
+    ): PostCentersCenterIdResponse
 
     fun activateGroup(
         groupId: Int,
-        activatePayload: ActivatePayload?,
+        activatePayload: ActivatePayload?
     ): Observable<GenericResponse>
-}
+
+}

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

@@ -1,12 +1,3 @@
-/*
- * 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.core.data.repository
 
 import com.mifos.core.objects.accounts.ClientAccounts
@@ -24,7 +15,8 @@ interface ClientDetailsRepository {
 
     fun deleteClientImage(clientId: Int): Observable<ResponseBody>
 
-    fun getClientAccounts(clientId: Int): Observable<ClientAccounts>
+    suspend fun getClientAccounts(clientId: Int): ClientAccounts
+
+    suspend fun getClient(clientId: Int): Client
 
-    fun getClient(clientId: Int): Observable<Client>
-}
+}

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

@@ -12,14 +12,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,

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

@@ -1,27 +1,17 @@
-/*
- * 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.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>
-}
+        identifierId: Int
+    ): DeleteClientsClientIdIdentifiersIdentifierIdResponse
+}

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

@@ -25,9 +25,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

@@ -19,7 +19,7 @@ import rx.Observable
  */
 interface CreateNewGroupRepository {
 
-    fun offices(): Observable<List<Office>>
+    suspend fun offices(): List<Office>
 
     fun createGroup(groupPayload: GroupPayload): Observable<SaveResponse>
 }