chore(pools): update activity feed on successful bid and resolution of a pool

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

Author: bmc08gt

apps/flipcash/shared/payments/build.gradle.kts

@@ -50,6 +50,7 @@ dependencies {
     implementation(Libs.androidx_localbroadcastmanager)
 
     implementation(project(":apps:flipcash:core"))
+    implementation(project(":apps:flipcash:shared:activityfeed"))
     implementation(project(":libs:messaging"))
     implementation(project(":ui:components"))
     implementation(project(":ui:resources"))

apps/flipcash/shared/payments/src/main/kotlin/com/flipcash/app/payments/internal/InternalPoolBidDelegate.kt

@@ -1,5 +1,6 @@
 package com.flipcash.app.payments.internal
 
+import com.flipcash.app.activityfeed.ActivityFeedCoordinator
 import com.flipcash.app.core.pools.Pool
 import com.flipcash.app.payments.delegates.PoolBidDelegate
 import com.flipcash.services.user.UserManager
@@ -19,6 +20,7 @@ internal class InternalPoolBidDelegate @Inject constructor(
     private val exchange: Exchange,
     private val transactionController: TransactionController,
     private val userManager: UserManager,
+    private val activityFeedCoordinator: ActivityFeedCoordinator,
 ): PoolBidDelegate {
     override suspend fun payForBid(
         pool: Pool,
@@ -50,6 +52,7 @@ internal class InternalPoolBidDelegate @Inject constructor(
             source = userManager.accountCluster!!,
         ).map { it.id.bytes }.onSuccess {
             // update balance on successful bid payment
+            activityFeedCoordinator.fetchSinceLatest()
             balanceController.subtract(localizedAmount)
             onSuccess(it)
         }.onFailure {

apps/flipcash/shared/payments/src/main/kotlin/com/flipcash/app/payments/internal/InternalPoolResolveDelegate.kt

@@ -1,5 +1,6 @@
 package com.flipcash.app.payments.internal
 
+import com.flipcash.app.activityfeed.ActivityFeedCoordinator
 import com.flipcash.app.core.pools.Pool
 import com.flipcash.app.core.pools.PoolBet
 import com.flipcash.app.core.pools.PoolBetOutcome
@@ -33,6 +34,7 @@ class InternalPoolResolveDelegate @Inject constructor(
     private val userManager: UserManager,
     private val accountController: AccountController,
     private val exchange: Exchange,
+    private val activityFeedCoordinator: ActivityFeedCoordinator,
 ) : PoolResolveDelegate {
     override suspend fun resolvePool(
         pool: Pool,
@@ -83,6 +85,8 @@ class InternalPoolResolveDelegate @Inject constructor(
             if (balanceIncrement != null) {
                 balanceController.add(balanceIncrement)
             }
+            // update balance on successful bid payment
+            activityFeedCoordinator.fetchSinceLatest()
             onSuccess(it)
         }.onFailure {
             onError(it)