feat(contacts): add join timestamp and sort feed by recency

apps/flipcash/features/direct-send/src/main/kotlin/com/flipcash/app/directsend/internal/SendFlowViewModel.kt

@@ -290,6 +290,9 @@ internal class SendFlowViewModel @Inject constructor(
                     !unknown.displayName.contains(searchString, ignoreCase = true)) {
                     return@mapNotNull null
                 }
+                if (unknown.e164.isNotEmpty()) {
+                    recentsE164s += unknown.e164
+                }
                 unknown
             }
 
@@ -301,18 +304,23 @@ internal class SendFlowViewModel @Inject constructor(
                 chatId = chatId,
                 lastActivity = summary.metadata.lastActivity,
             )
-        }.sortedWith(
-            compareByDescending<ContactListItem.ContactRow> { it.lastActivity }
-                .thenBy(String.CASE_INSENSITIVE_ORDER) { it.contact.displayName }
-        )
+        }
 
-        // On Flipcash — contacts that haven't chatted yet
+        // On Flipcash — contacts that haven't chatted yet, use joinedAt as their sort timestamp
         val flipcashRows = filtered
             .filter { it.e164 in contactState.flipcashE164s && it.e164 !in recentsE164s }
-            .sortedWith(compareBy(String.CASE_INSENSITIVE_ORDER) { it.displayName })
-            .map { ContactListItem.ContactRow(contact = it, isOnFlipcash = true) }
+            .map { contact ->
+                ContactListItem.ContactRow(
+                    contact = contact,
+                    isOnFlipcash = true,
+                    lastActivity = contactState.joinedAtByE164[contact.e164],
+                )
+            }
 
-        val flipcashCombined = (recentRows + flipcashRows)
+        val flipcashCombined = (recentRows + flipcashRows).sortedWith(
+            compareByDescending<ContactListItem.ContactRow> { it.lastActivity }
+                .thenBy(String.CASE_INSENSITIVE_ORDER) { it.contact.displayName }
+        )
 
         val excludedE164s = recentsE164s + contactState.flipcashE164s
         val other = filtered

apps/flipcash/features/userflags/src/main/kotlin/com/flipcash/app/userflags/internal/UserFlagsViewModel.kt

@@ -142,4 +142,5 @@ private fun ResolvedUserFlags.editableEntries(): List<EditableEntry<*>> = listOf
     EditableEntry(Field.WithdrawalFeeAmount, withdrawalFeeAmount),
     EditableEntry(Field.PreferredUsdcOnRampLiquidityPool, usdcOnRampLiquidityPool),
     EditableEntry(Field.MinimumHolderAmountForLeaderboard, minimumHolderAmountForLeaderboard),
+    EditableEntry(Field.RequireCoinbaseEmailVerification, requireCoinbaseEmailVerification),
 )

apps/flipcash/shared/chat/src/main/kotlin/com/flipcash/shared/chat/internal/delegates/EventStreamDelegate.kt

@@ -227,10 +227,7 @@ class EventStreamDelegate @Inject constructor(
         val lastMsg = if (resolvedMessages.isNotEmpty()) {
             trace(tag = TAG, message = "Upserting ${resolvedMessages.size} messages for $chatId", type = TraceType.Process)
             messageDataSource.upsert(chatId, resolvedMessages)
-            resolvedMessages.maxByOrNull { it.messageId }?.also { msg ->
-                metadataDataSource.updateLastMessageId(chatId, msg.messageId)
-                metadataDataSource.updateLastActivity(chatId, msg.timestamp.toEpochMilliseconds())
-            }
+            resolvedMessages.maxByOrNull { it.messageId }
         } else null
 
         // Advance event sequence cursor — gap-aware
@@ -252,6 +249,9 @@ class EventStreamDelegate @Inject constructor(
             memberDataSource.updatePointers(chatId, pointer)
         }
 
+        // Process metadata updates before message-derived fields so that a
+        // FullRefresh (which replaces the entire entity) doesn't overwrite
+        // the lastActivity/lastMessageId set from the incoming message.
         for (metaUpdate in update.metadataUpdates) {
             when (metaUpdate) {
                 is MetadataUpdate.FullRefresh -> {
@@ -271,6 +271,14 @@ class EventStreamDelegate @Inject constructor(
             }
         }
 
+        // Update lastMessageId and lastActivity AFTER metadata updates so that
+        // incoming message timestamps always take precedence over a potentially
+        // stale FullRefresh.
+        lastMsg?.let { msg ->
+            metadataDataSource.updateLastMessageId(chatId, msg.messageId)
+            metadataDataSource.updateLastActivity(chatId, msg.timestamp.toEpochMilliseconds())
+        }
+
         // --- Process reaction updates ---
 
         if (update.reactionUpdates.isNotEmpty()) {

apps/flipcash/shared/contacts/src/main/kotlin/com/flipcash/app/contacts/ContactCoordinator.kt

@@ -61,6 +61,7 @@ import kotlinx.coroutines.launch
 import javax.inject.Inject
 import javax.inject.Singleton
 import kotlin.collections.map
+import kotlin.time.Instant
 import kotlin.collections.mapValues
 
 
@@ -98,6 +99,7 @@ class ContactCoordinator @Inject constructor(
         val contacts: Map<String, DeviceContact> = emptyMap(),
         val flipcashE164s: Set<String> = emptySet(),
         val dmChatIds: Map<String, String> = emptyMap(),
+        val joinedAtByE164: Map<String, Instant> = emptyMap(),
         val syncState: SyncState = SyncState.Idle,
         val hasEverSynced: Boolean = false,
         val hasDiscoveredFlipcashContacts: Boolean = false,
@@ -370,12 +372,16 @@ class ContactCoordinator @Inject constructor(
         val dmChatIds = mappings
             .filter { it.dmChatId.isNotEmpty() }
             .associate { it.e164 to it.dmChatId }
+        val joinedAtByE164 = mappings
+            .filter { it.joinedAtEpochSeconds > 0 }
+            .associate { it.e164 to Instant.fromEpochSeconds(it.joinedAtEpochSeconds) }
 
         _state.update {
             it.copy(
                 contacts = contacts,
                 flipcashE164s = flipcashE164s,
                 dmChatIds = dmChatIds,
+                joinedAtByE164 = joinedAtByE164,
                 hasEverSynced = true,
                 hasDiscoveredFlipcashContacts = hasDiscoveredFlipcashContacts,
             )
@@ -551,12 +557,21 @@ class ContactCoordinator @Inject constructor(
                     }
                 }
                 val dmChatIds = mutableMapOf<String, String>()
+                val joinedAts = mutableMapOf<String, Instant>()
                 entries.forEach { entry ->
+                    contactDataSource.updateJoinedAt(entry.phoneNumber, entry.joinedAt.epochSeconds)
+                    joinedAts[entry.phoneNumber] = entry.joinedAt
                     val chatIdStr = entry.dmChatId?.toString() ?: return@forEach
                     contactDataSource.updateDmChatId(entry.phoneNumber, chatIdStr)
                     dmChatIds[entry.phoneNumber] = chatIdStr
                 }
-                _state.update { it.copy(flipcashE164s = flipcashE164s, dmChatIds = it.dmChatIds + dmChatIds) }
+                _state.update {
+                    it.copy(
+                        flipcashE164s = flipcashE164s,
+                        dmChatIds = it.dmChatIds + dmChatIds,
+                        joinedAtByE164 = it.joinedAtByE164 + joinedAts,
+                    )
+                }
                 trace(tag = TAG, message = "Found ${flipcashE164s.size} contacts on Flipcash", type = TraceType.Process)
             }?.onFailure { error ->
                 when (error) {

apps/flipcash/shared/onramp/coinbase/build.gradle.kts

@@ -23,6 +23,7 @@ dependencies {
     implementation(libs.kotlinx.coroutines.play.services)
     implementation(project(":libs:messaging"))
     implementation(project(":apps:flipcash:shared:featureflags"))
+    implementation(project(":apps:flipcash:shared:userflags"))
     implementation(project(":apps:flipcash:shared:web"))
     api(project(":libs:network:coinbase:onramp"))
     implementation(project(":libs:network:jwt"))

apps/flipcash/shared/onramp/coinbase/src/main/kotlin/com/flipcash/app/onramp/CoinbaseOnRampController.kt

@@ -29,6 +29,7 @@ import com.getcode.opencode.model.transactions.SwapFundingSource
 import com.getcode.solana.keys.Mint
 import com.getcode.solana.keys.base58
 import com.flipcash.app.onramp.internal.CoinbaseOnRampWebError
+import com.flipcash.app.userflags.UserFlagsCoordinator
 import com.getcode.utils.CodeServerError
 import com.getcode.utils.ErrorUtils
 import com.getcode.utils.NotifiableError
@@ -54,8 +55,8 @@ import javax.inject.Inject
 
 sealed class PurchaseGate : Throwable() {
     data class WebViewWarning(val channel: WebViewChannel) : PurchaseGate()
-    data object GooglePayNotSupported : PurchaseGate()
-    data object GooglePayNoPaymentMethod : PurchaseGate()
+    class GooglePayNotSupported : PurchaseGate()
+    class GooglePayNoPaymentMethod : PurchaseGate()
 }
 
 typealias OrderWithPaymentLink = Pair<String, OnRampPurchaseResponse.PaymentLink>
@@ -76,6 +77,7 @@ class CoinbaseOnRampController @Inject constructor(
     private val transactionController: TransactionOperations,
     private val googlePayReadiness: GooglePayReadiness,
     private val webViewChannelDetector: WebViewChannelDetector,
+    private val userFlags: UserFlagsCoordinator,
 ) {
 
     private val _state = MutableStateFlow<CoinbaseOnRampState>(CoinbaseOnRampState.Idle)
@@ -115,8 +117,8 @@ class CoinbaseOnRampController @Inject constructor(
 
     suspend fun checkPurchaseGates(): Result<Unit> {
         when (googlePayReadiness.check()) {
-            GooglePayReadiness.Status.NotSupported -> return Result.failure(PurchaseGate.GooglePayNotSupported)
-            GooglePayReadiness.Status.NoPaymentMethod -> return Result.failure(PurchaseGate.GooglePayNoPaymentMethod)
+            GooglePayReadiness.Status.NotSupported -> return Result.failure(PurchaseGate.GooglePayNotSupported())
+            GooglePayReadiness.Status.NoPaymentMethod -> return Result.failure(PurchaseGate.GooglePayNoPaymentMethod())
             GooglePayReadiness.Status.Ready -> Unit
         }
 
@@ -231,8 +233,8 @@ class CoinbaseOnRampController @Inject constructor(
 
         val destination = destinationForToken(owner, token)
 
-        val email = userManager.profile?.verifiedEmailAddress
         val phone = userManager.profile?.verifiedPhoneNumber
+        val email = resolveEmail(phone)
 
         if (email == null || phone == null) {
             return Result.failure(
@@ -276,8 +278,8 @@ class CoinbaseOnRampController @Inject constructor(
 
         val destination = destinationForToken(owner, token)
 
-        val email = userManager.profile?.verifiedEmailAddress
         val phone = userManager.profile?.verifiedPhoneNumber
+        val email = resolveEmail(phone)
 
         if (email == null || phone == null) {
             return Result.failure(
@@ -339,6 +341,16 @@ class CoinbaseOnRampController @Inject constructor(
         )
     }
 
+    private fun resolveEmail(phone: String?): String? {
+        val verified = userManager.profile?.verifiedEmailAddress
+        if (verified != null) return verified
+
+        val requireEmail = userFlags.resolvedFlags.value.requireCoinbaseEmailVerification.effectiveValue
+        if (!requireEmail && phone != null) return "[email protected]"
+
+        return null
+    }
+
     private fun destinationForToken(owner: AccountCluster, token: Token): String {
         return if (token.address == Mint.usdf) {
             owner.depositAddressFor(token).base58()
@@ -379,9 +391,7 @@ class CoinbaseOnRampController @Inject constructor(
                 )
                 when (error) {
                     is GetJwtError.EmailVerificationRequired -> Result.failure(
-                        OnRampAuthError.VerificationRequired(
-                            email = true
-                        )
+                        OnRampAuthError.VerificationRequired(email = true)
                     )
 
                     is GetJwtError.PhoneVerificationRequired -> Result.failure(