feat: fetch transaction delta where applicable in app

Signed-off-by: Brandon McAnsh <git@bmcreations.dev>

Author: bmc08gt

api/src/main/java/com/getcode/model/Chat.kt

@@ -110,7 +110,7 @@ sealed interface Verb {
 
 data class ChatMessage(
     val id: ID,
-    val cursor: Cursor?,
+    val cursor: Cursor,
     val dateMillis: Long,
     val contents: List<MessageContent>
 )

api/src/main/java/com/getcode/network/HistoryController.kt

@@ -6,6 +6,7 @@ import androidx.paging.PagingConfig
 import androidx.paging.PagingData
 import androidx.paging.PagingSource
 import androidx.paging.cachedIn
+import androidx.paging.map
 import com.getcode.ed25519.Ed25519.KeyPair
 import com.getcode.manager.SessionManager
 import com.getcode.model.Chat
@@ -31,6 +32,7 @@ import kotlinx.coroutines.flow.asStateFlow
 import kotlinx.coroutines.flow.catch
 import kotlinx.coroutines.flow.collect
 import kotlinx.coroutines.flow.filterNotNull
+import kotlinx.coroutines.flow.lastOrNull
 import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.update
 import kotlinx.coroutines.reactive.asFlow
@@ -62,17 +64,18 @@ class HistoryController @Inject constructor(
     private val pagerMap = mutableMapOf<ID, PagingSource<Cursor, ChatMessage>>()
     private val chatFlows = mutableMapOf<ID, Flow<PagingData<ChatMessage>>>()
 
-    private fun chatMessagePager(chatId: ID) = Pager(
-        PagingConfig(pageSize = 20)
-    ) {
+    private val pagingConfig = PagingConfig(pageSize = 20)
+
+    private fun chatMessagePager(chatId: ID) = Pager(pagingConfig) {
         pagerMap[chatId] ?: ChatMessagePagingSource(client, owner()!!, chatId).also {
             pagerMap[chatId] = it
         }
     }
 
-    fun chatFlow(chatId: ID) = chatFlows[chatId] ?: chatMessagePager(chatId).flow.cachedIn(GlobalScope).also {
-        chatFlows[chatId] = it
-    }
+    fun chatFlow(chatId: ID) =
+        chatFlows[chatId] ?: chatMessagePager(chatId).flow.cachedIn(GlobalScope).also {
+            chatFlows[chatId] = it
+        }
 
     val unreadCount = chats
         .filterNotNull()
@@ -95,6 +98,12 @@ class HistoryController @Inject constructor(
             owner = owner,
             afterId = latestTransaction.id.toByteArray()
         )
+
+        fetchChats()
+
+        pagerMap.entries.onEach { (id, pagingSource) ->
+            pagingSource.invalidate()
+        }
     }
 
     @SuppressLint("CheckResult")

app/src/main/java/com/getcode/view/main/getKin/GetKinSheetViewModel.kt

@@ -7,6 +7,7 @@ import com.getcode.manager.TopBarManager
 import com.getcode.model.KinAmount
 import com.getcode.model.PrefsBool
 import com.getcode.network.BalanceController
+import com.getcode.network.HistoryController
 import com.getcode.network.client.Client
 import com.getcode.network.client.fetchPaymentHistoryDelta
 import com.getcode.network.client.requestFirstKinAirdrop
@@ -29,6 +30,7 @@ import kotlinx.coroutines.flow.launchIn
 import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.mapNotNull
 import kotlinx.coroutines.flow.onEach
+import kotlinx.coroutines.launch
 import kotlinx.coroutines.reactive.asFlow
 import java.util.concurrent.TimeUnit
 import javax.inject.Inject
@@ -41,6 +43,7 @@ class GetKinSheetViewModel @Inject constructor(
     private val client: Client,
     private val networkObserver: NetworkConnectivityListener,
     private val resources: ResourceHelper,
+    private val historyController: HistoryController,
 ) : BaseViewModel2<GetKinSheetViewModel.State, GetKinSheetViewModel.Event>(
     initialState = State(),
     updateStateForEvent = updateStateForEvent
@@ -121,12 +124,8 @@ class GetKinSheetViewModel @Inject constructor(
                 }
             )
             .flatMapLatest {
-                Completable.concatArray(
-                    balanceController.fetchBalance(),
-                    client.fetchPaymentHistoryDelta(owner = SessionManager.getKeyPair()!!)
-                        .ignoreElement()
-                ).toFlowable<Any>().asFlow()
-            }
+                Completable.concatArray(balanceController.fetchBalance()).toFlowable<Any>().asFlow()
+            }.onEach { historyController.fetchDelta() }
             .launchIn(viewModelScope)
 
         eventFlow

app/src/main/java/com/getcode/view/main/home/HomeViewModel.kt

@@ -45,7 +45,6 @@ import com.getcode.network.client.RemoteSendException
 import com.getcode.network.client.awaitEstablishRelationship
 import com.getcode.network.client.cancelRemoteSend
 import com.getcode.network.client.fetchLimits
-import com.getcode.network.client.fetchPaymentHistoryDelta
 import com.getcode.network.client.receiveRemoteSuspend
 import com.getcode.network.client.sendRemotely
 import com.getcode.network.client.sendRequestToReceiveBill
@@ -304,12 +303,12 @@ class HomeViewModel @Inject constructor(
                     Completable.concatArray(
                         balanceController.fetchBalance(),
                         client.fetchLimits(isForce = true),
-                        client.fetchPaymentHistoryDelta(owner).ignoreElement()
                     )
                 }
                 .subscribe({
                     cancelSend(PresentationStyle.Pop)
                     vibrator.vibrate()
+                    viewModelScope.launch { historyController.fetchDelta() }
                 }, {
                     ErrorUtils.handleError(it)
                     cancelSend(style = PresentationStyle.Slide)
@@ -535,12 +534,13 @@ class HomeViewModel @Inject constructor(
         }
     }
 
-    private fun attemptPayment(payload: CodePayload, request: DeepLinkPaymentRequest? = null) = viewModelScope.launch {
-        val (amount, p) = paymentRepository.attemptRequest(payload) ?: return@launch
-        BottomBarManager.clear()
+    private fun attemptPayment(payload: CodePayload, request: DeepLinkPaymentRequest? = null) =
+        viewModelScope.launch {
+            val (amount, p) = paymentRepository.attemptRequest(payload) ?: return@launch
+            BottomBarManager.clear()
 
-        presentRequest(amount = amount, payload = p, request = request)
-    }
+            presentRequest(amount = amount, payload = p, request = request)
+        }
 
     fun presentRequest(
         amount: KinAmount,
@@ -835,10 +835,9 @@ class HomeViewModel @Inject constructor(
                 Completable.concatArray(
                     balanceController.fetchBalance(),
                     client.fetchLimits(isForce = true),
-                    client.fetchPaymentHistoryDelta(organizer.ownerKeyPair).ignoreElement()
                 )
             }
-            .subscribe({ }, {
+            .subscribe({ viewModelScope.launch { historyController.fetchDelta() } }, {
                 scannedRendezvous.remove(payload.rendezvous.publicKey)
                 ErrorUtils.handleError(it)
             })