@@ -3,6 +3,7 @@ package com.getcode.network
33import androidx.lifecycle.Lifecycle
44import androidx.lifecycle.LifecycleEventObserver
55import androidx.lifecycle.LifecycleOwner
6+ import com.getcode.analytics.AnalyticsService
67import com.getcode.manager.SessionManager
78import com.getcode.model.CodePayload
89import com.getcode.model.PrefsBool
@@ -11,6 +12,8 @@ import com.getcode.model.TipMetadata
1112import com.getcode.model.TwitterUser
1213import com.getcode.network.client.Client
1314import com.getcode.network.client.fetchTwitterUser
15+ import com.getcode.network.repository.BetaFlagsRepository
16+ import com.getcode.network.repository.BetaOptions
1417import com.getcode.network.repository.PrefRepository
1518import com.getcode.network.repository.TwitterUserFetchError
1619import com.getcode.network.repository.base58
@@ -24,6 +27,7 @@ import kotlinx.coroutines.flow.SharingStarted
2427import kotlinx.coroutines.flow.StateFlow
2528import kotlinx.coroutines.flow.combine
2629import kotlinx.coroutines.flow.distinctUntilChanged
30+ import kotlinx.coroutines.flow.filter
2731import kotlinx.coroutines.flow.filterNotNull
2832import kotlinx.coroutines.flow.launchIn
2933import kotlinx.coroutines.flow.map
@@ -44,6 +48,7 @@ typealias TipUser = Pair<String, CodePayload>
4448@Singleton
4549class TipController @Inject constructor(
4650 private val client : Client ,
51+ betaFlags : BetaFlagsRepository ,
4752 private val prefRepository : PrefRepository ,
4853): LifecycleEventObserver {
4954
@@ -70,7 +75,7 @@ class TipController @Inject constructor(
7075 val showTwitterSplat: Flow <Boolean > =
7176 combine(
7277 connectedAccount,
73- prefRepository.observeOrDefault( PrefsBool . TIPS_ENABLED , false ) ,
78+ betaFlags.observe().map { it.tipsEnabled } ,
7479 prefRepository.observeOrDefault(PrefsBool .SEEN_TIP_CARD , false )
7580 ) { connected, tipsEnabled, seen ->
7681 connected != null && ! seen && tipsEnabled
0 commit comments