Client add charge (#2533)

Co-authored-by: Shreyash16b <shreyashborde@gmail.com>

Author: Arinyadav1

core/data/src/commonMain/kotlin/com/mifos/core/data/di/RepositoryModule.kt

@@ -13,10 +13,9 @@ import com.mifos.core.common.network.MifosDispatchers
 import com.mifos.core.data.repository.ActivateRepository
 import com.mifos.core.data.repository.CenterDetailsRepository
 import com.mifos.core.data.repository.CenterListRepository
-import com.mifos.core.data.repository.ChargeDialogRepository
+import com.mifos.core.data.repository.ChargeRepository
 import com.mifos.core.data.repository.CheckerInboxRepository
 import com.mifos.core.data.repository.CheckerInboxTasksRepository
-import com.mifos.core.data.repository.ClientChargeRepository
 import com.mifos.core.data.repository.ClientDetailsEditRepository
 import com.mifos.core.data.repository.ClientDetailsRepository
 import com.mifos.core.data.repository.ClientIdentifiersRepository
@@ -76,10 +75,9 @@ import com.mifos.core.data.repository.SyncSavingsAccountTransactionRepository
 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.ChargeRepositoryImp
 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.ClientDetailsEditRepositoryImpl
 import com.mifos.core.data.repositoryImp.ClientDetailsRepositoryImp
 import com.mifos.core.data.repositoryImp.ClientIdentifiersRepositoryImp
@@ -152,7 +150,7 @@ val RepositoryModule = module {
     // Client
     singleOf(::ClientDetailsRepositoryImp) bind ClientDetailsRepository::class
     singleOf(::ClientListRepositoryImp) bind ClientListRepository::class
-    singleOf(::ClientChargeRepositoryImp) bind ClientChargeRepository::class
+    singleOf(::ChargeRepositoryImp) bind ChargeRepository::class
     singleOf(::ClientIdentifiersRepositoryImp) bind ClientIdentifiersRepository::class
     singleOf(::CreateNewClientRepositoryImp) bind CreateNewClientRepository::class
     singleOf(::ClientDetailsEditRepositoryImpl) bind ClientDetailsEditRepository::class
@@ -201,7 +199,6 @@ val RepositoryModule = module {
 
     // Others
     singleOf(::ActivateRepositoryImp) bind ActivateRepository::class
-    singleOf(::ChargeDialogRepositoryImp) bind ChargeDialogRepository::class
     singleOf(::CheckerInboxRepositoryImp) bind CheckerInboxRepository::class
     singleOf(::CheckerInboxTasksRepositoryImp) bind CheckerInboxTasksRepository::class
     singleOf(::DataTableDataRepositoryImp) bind DataTableDataRepository::class

core/data/src/commonMain/kotlin/com/mifos/core/data/pagingSource/ClientChargesPagingSource.kt

@@ -16,7 +16,8 @@ import com.mifos.room.entities.client.ChargesEntity
 import kotlinx.coroutines.flow.first
 
 class ClientChargesPagingSource(
-    private val clientId: Int,
+    private val resourceType: String,
+    private val resourceId: Int,
     private val dataManagerCharge: DataManagerCharge,
 ) :
     PagingSource<Int, ChargesEntity>() {
@@ -33,7 +34,7 @@ class ClientChargesPagingSource(
     override suspend fun load(params: LoadParams<Int>): LoadResult<Int, ChargesEntity> {
         val position = params.key ?: 0
         return try {
-            val (clientChargesList, totalCharges) = getClientChargeList(clientId, position)
+            val (clientChargesList, totalCharges) = getListOfPagingCharges(resourceType, resourceId, position)
 
             LoadResult.Page(
                 data = clientChargesList,
@@ -45,12 +46,14 @@ class ClientChargesPagingSource(
         }
     }
 
-    private suspend fun getClientChargeList(
-        clientId: Int,
+    private suspend fun getListOfPagingCharges(
+        resourceType: String,
+        resourceId: Int,
         position: Int,
     ): Pair<List<ChargesEntity>, Int> {
-        val page = dataManagerCharge.getClientCharges(
-            clientId = clientId,
+        val page = dataManagerCharge.getListOfPagingCharges(
+            resourceType = resourceType,
+            resourceId = resourceId,
             offset = position,
             limit = 10,
         ).first()

core/data/src/commonMain/kotlin/com/mifos/core/data/repository/ChargeDialogRepository.kt

@@ -0,0 +1,67 @@
+/*
+ * 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 androidx.paging.PagingData
+import com.mifos.core.common.utils.DataState
+import com.mifos.core.model.objects.clients.ChargeCreationResponse
+import com.mifos.core.model.objects.clients.Page
+import com.mifos.core.model.objects.payloads.ChargesPayload
+import com.mifos.core.model.objects.template.client.ChargeTemplate
+import com.mifos.room.entities.client.ChargesEntity
+import kotlinx.coroutines.flow.Flow
+
+/**
+ * Created by Aditya Gupta on 08/08/23.
+ */
+interface ChargeRepository {
+
+    fun getListOfPagingCharges(
+        resourceType: String,
+        resourceId: Int,
+    ): Flow<PagingData<ChargesEntity>>
+
+    suspend fun getChargeTemplate(resourceType: String, resourceId: Int): ChargeTemplate
+
+    suspend fun createCharges(
+        resourceType: String,
+        resourceId: Int,
+        payload: ChargesPayload,
+    ): ChargeCreationResponse
+
+    suspend fun deleteCharge(
+        resourceId: Int,
+        resourceType: String,
+        chargeId: Int,
+    ): Flow<DataState<Unit>>
+
+    suspend fun updateCharge(
+        resourceId: Int,
+        resourceType: String,
+        chargeId: Int,
+        payload: ChargesPayload,
+    ): Flow<DataState<Unit>>
+
+    fun getListOfClientCharges(
+        resourceType: String,
+        resourceId: Int,
+    ): Flow<DataState<Page<ChargesEntity>>>
+
+    fun getListOfOtherAccountCharge(
+        resourceType: String,
+        resourceId: Int,
+    ): Flow<DataState<List<ChargesEntity>>>
+
+    fun getCharge(
+        resourceType: String,
+        resourceId: Int,
+        chargeId: Int,
+    ): Flow<DataState<ChargesEntity>>
+}

core/data/src/commonMain/kotlin/com/mifos/core/data/repository/ChargeRepository.kt

@@ -0,0 +1,122 @@
+/*
+ * 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.repositoryImp
+
+import androidx.paging.Pager
+import androidx.paging.PagingConfig
+import androidx.paging.PagingData
+import com.mifos.core.common.utils.DataState
+import com.mifos.core.common.utils.asDataStateFlow
+import com.mifos.core.data.pagingSource.ClientChargesPagingSource
+import com.mifos.core.data.repository.ChargeRepository
+import com.mifos.core.model.objects.clients.ChargeCreationResponse
+import com.mifos.core.model.objects.clients.Page
+import com.mifos.core.model.objects.payloads.ChargesPayload
+import com.mifos.core.model.objects.template.client.ChargeTemplate
+import com.mifos.core.network.datamanager.DataManagerCharge
+import com.mifos.room.entities.client.ChargesEntity
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.flow
+
+class ChargeRepositoryImp(
+    private val dataManagerCharge: DataManagerCharge,
+) : ChargeRepository {
+
+    override fun getListOfPagingCharges(
+        resourceType: String,
+        resourceId: Int,
+    ): Flow<PagingData<ChargesEntity>> {
+        return Pager(
+            config = PagingConfig(
+                pageSize = 10,
+            ),
+            pagingSourceFactory = {
+                ClientChargesPagingSource(resourceType, resourceId, dataManagerCharge)
+            },
+        ).flow
+    }
+
+    override suspend fun getChargeTemplate(resourceType: String, resourceId: Int): ChargeTemplate {
+        return dataManagerCharge.getChargeTemplate(resourceType, resourceId)
+    }
+
+    override suspend fun createCharges(
+        resourceType: String,
+        resourceId: Int,
+        payload: ChargesPayload,
+    ): ChargeCreationResponse {
+        return dataManagerCharge.createCharges(
+            resourceId = resourceId,
+            resourceType = resourceType,
+            payload = payload,
+        )
+    }
+
+    override suspend fun deleteCharge(
+        resourceId: Int,
+        resourceType: String,
+        chargeId: Int,
+    ): Flow<DataState<Unit>> {
+        return flow {
+            emit(
+                dataManagerCharge.deleteCharge(
+                    resourceId = resourceId,
+                    resourceType = resourceType,
+                    chargeId = chargeId,
+                ),
+            )
+        }.asDataStateFlow()
+    }
+
+    override suspend fun updateCharge(
+        resourceId: Int,
+        resourceType: String,
+        chargeId: Int,
+        payload: ChargesPayload,
+    ): Flow<DataState<Unit>> {
+        return flow {
+            emit(
+                dataManagerCharge.updateCharge(
+                    resourceId = resourceId,
+                    resourceType = resourceType,
+                    chargeId = chargeId,
+                    payload = payload,
+                ),
+            )
+        }.asDataStateFlow()
+    }
+
+    override fun getListOfClientCharges(
+        resourceType: String,
+        resourceId: Int,
+    ): Flow<DataState<Page<ChargesEntity>>> {
+        return dataManagerCharge.getListOfClientCharges(resourceType, resourceId).asDataStateFlow()
+    }
+
+    override fun getListOfOtherAccountCharge(
+        resourceType: String,
+        resourceId: Int,
+    ): Flow<DataState<List<ChargesEntity>>> {
+        return dataManagerCharge.getListOfOtherAccountCharge(resourceType, resourceId)
+            .asDataStateFlow()
+    }
+
+    override fun getCharge(
+        resourceType: String,
+        resourceId: Int,
+        chargeId: Int,
+    ): Flow<DataState<ChargesEntity>> {
+        return dataManagerCharge.getCharge(
+            resourceId = resourceId,
+            resourceType = resourceType,
+            chargeId = chargeId,
+        ).asDataStateFlow()
+    }
+}