fix(flipcash/persistence): allow activity feed item amount rate to be inferred

drop messages table and refetch

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

Author: bmc08gt

apps/flipcash/core/src/main/kotlin/com/flipcash/app/core/feed/ActivityFeedMessage.kt

@@ -1,5 +1,8 @@
 package com.flipcash.app.core.feed
 
+import androidx.compose.runtime.derivedStateOf
+import androidx.compose.runtime.getValue
+import androidx.compose.runtime.remember
 import com.getcode.opencode.model.core.ID
 import com.getcode.opencode.model.financial.LocalFiat
 import com.getcode.solana.keys.PublicKey
@@ -14,7 +17,18 @@ data class ActivityFeedMessage(
     val timestamp: Instant,
     val state: MessageState,
     val metadata: MessageMetadata?
-)
+) {
+    val isTransaction: Boolean
+        get() = amount != null
+
+    val canCancel: Boolean
+        get() {
+            metadata ?: return false
+            val metadata =
+                (metadata as? MessageMetadata.SentUsdc) ?: return false
+            return metadata.canCancel
+        }
+}
 
 enum class MessageState {
     UNKNOWN,

apps/flipcash/shared/activityfeed/src/main/kotlin/com/flipcash/app/activityfeed/ActivityFeedCoordinator.kt

@@ -86,7 +86,7 @@ class ActivityFeedCoordinator @Inject constructor(
             queryOptions = QueryOptions(
                 limit = count,
                 token = latest?.id,
-                descending = false
+                descending = latest == null,
             )
         ).onSuccess { dataSource.upsert(it) }.map { Unit }
     }

apps/flipcash/shared/persistence/db/schemas/com.flipcash.app.persistence.FlipcashDatabase/2.json

@@ -0,0 +1,74 @@
+{
+  "formatVersion": 1,
+  "database": {
+    "version": 2,
+    "identityHash": "6f0e1586aaf4ec500c89b06fb990e7f2",
+    "entities": [
+      {
+        "tableName": "messages",
+        "createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`idBase58` TEXT NOT NULL, `text` TEXT NOT NULL, `amountUsdc` INTEGER, `amountNative` INTEGER, `nativeCurrency` TEXT, `rate` REAL, `state` TEXT NOT NULL, `timestamp` INTEGER NOT NULL, `metadata` TEXT, PRIMARY KEY(`idBase58`))",
+        "fields": [
+          {
+            "fieldPath": "idBase58",
+            "columnName": "idBase58",
+            "affinity": "TEXT",
+            "notNull": true
+          },
+          {
+            "fieldPath": "text",
+            "columnName": "text",
+            "affinity": "TEXT",
+            "notNull": true
+          },
+          {
+            "fieldPath": "amountUsdc",
+            "columnName": "amountUsdc",
+            "affinity": "INTEGER"
+          },
+          {
+            "fieldPath": "amountNative",
+            "columnName": "amountNative",
+            "affinity": "INTEGER"
+          },
+          {
+            "fieldPath": "nativeCurrency",
+            "columnName": "nativeCurrency",
+            "affinity": "TEXT"
+          },
+          {
+            "fieldPath": "rate",
+            "columnName": "rate",
+            "affinity": "REAL"
+          },
+          {
+            "fieldPath": "state",
+            "columnName": "state",
+            "affinity": "TEXT",
+            "notNull": true
+          },
+          {
+            "fieldPath": "timestamp",
+            "columnName": "timestamp",
+            "affinity": "INTEGER",
+            "notNull": true
+          },
+          {
+            "fieldPath": "metadata",
+            "columnName": "metadata",
+            "affinity": "TEXT"
+          }
+        ],
+        "primaryKey": {
+          "autoGenerate": false,
+          "columnNames": [
+            "idBase58"
+          ]
+        }
+      }
+    ],
+    "setupQueries": [
+      "CREATE TABLE IF NOT EXISTS room_master_table (id INTEGER PRIMARY KEY,identity_hash TEXT)",
+      "INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(42, '6f0e1586aaf4ec500c89b06fb990e7f2')"
+    ]
+  }
+}

apps/flipcash/shared/persistence/db/src/main/kotlin/com/flipcash/app/persistence/FlipcashDatabase.kt

@@ -1,9 +1,13 @@
 package com.flipcash.app.persistence
 
 import android.content.Context
+import androidx.room.AutoMigration
 import androidx.room.Database
 import androidx.room.Room
 import androidx.room.RoomDatabase
+import androidx.room.migration.AutoMigrationSpec
+import androidx.room.migration.Migration
+import androidx.sqlite.db.SupportSQLiteDatabase
 import com.flipcash.app.persistence.dao.MessageDao
 import com.flipcash.app.persistence.entities.MessageEntity
 import com.getcode.utils.TraceType
@@ -15,13 +19,22 @@ import org.kin.sdk.base.tools.subByteArray
     entities = [
         MessageEntity::class
     ],
-    version = 1,
+    autoMigrations = [
+        AutoMigration(from = 1, to = 2, spec = FlipcashDatabase.Migration1To2::class),
+    ],
+    version = 2,
 )
 //@TypeConverters(Converters::class)
 abstract class FlipcashDatabase : RoomDatabase() {
 
     abstract fun messageDao(): MessageDao
 
+    class Migration1To2 : Migration(1, 2), AutoMigrationSpec {
+        override fun migrate(db: SupportSQLiteDatabase) {
+            db.execSQL("DELETE FROM messages")
+        }
+    }
+
     companion object {
         private var instance: FlipcashDatabase? = null
         fun requireInstance() = requireNotNull(instance)

apps/flipcash/shared/persistence/sources/src/main/kotlin/com/flipcash/app/persistence/sources/mapper/NotificationToEntityMapper.kt

@@ -26,8 +26,8 @@ class SingleNotificationToEntityMapper @Inject constructor(
 
         val (usdc, native, currency, fx) = from.amount?.let { amount ->
             AmountHolder(
-                usdc = amount.usdc.quarks.toLong(),
-                native = amount.converted.quarks.toLong(),
+                usdc = amount.usdc.quarks,
+                native = amount.converted.quarks,
                 currency = amount.converted.currencyCode.name,
                 fx = amount.rate.fx
             )

apps/flipcash/shared/persistence/sources/src/main/kotlin/com/flipcash/app/persistence/sources/mediator/FeedRemoteMediator.kt

@@ -19,8 +19,6 @@ class FeedRemoteMediator(
     private val dataSource: MessageDataSource,
 ): RemoteMediator<Int, MessageEntity>() {
 
-    private var lastResult = listOf<ActivityFeedNotification>()
-
     override suspend fun initialize(): InitializeAction {
         return InitializeAction.SKIP_INITIAL_REFRESH
     }
@@ -44,21 +42,14 @@ class FeedRemoteMediator(
 
             val queryOptions = QueryOptions(
                 token = loadKey,
-                limit = state.config.pageSize
+                limit = state.config.pageSize,
             )
 
             val notifications = controller.queryNotificationsFor(
                 ActivityFeedType.TransactionHistory,
                 queryOptions
             ).getOrNull().orEmpty()
 
-            if (notifications.isEmpty() || lastResult.any { it.id == notifications.firstOrNull()?.id.orEmpty() }) {
-                lastResult = emptyList()
-                return MediatorResult.Success(true)
-            }
-
-            lastResult = notifications
-
             withContext(Dispatchers.IO) {
                 if (loadType == LoadType.REFRESH) {
                     dataSource.clear()

services/flipcash/src/main/kotlin/com/flipcash/services/internal/domain/ActivityFeedMessageMapper.kt

@@ -25,7 +25,6 @@ internal class ActivityFeedMessageMapper @Inject constructor(
                 LocalFiat(
                     usdc = Fiat(quarks = it.quarks),
                     converted = Fiat(fiat = it.nativeAmount, currencyCode = CurrencyCode.tryValueOf(it.currency) ?: CurrencyCode.USD),
-                    rate = Rate.ignore
                 )
             },
             timestamp = Instant.fromEpochSeconds(from.ts.seconds, 0),