TrialInitializer.kt

package com.simplecityapps.shuttle.appinitializers

import android.app.Application
import com.simplecityapps.playback.PlaybackManager
import com.simplecityapps.shuttle.di.AppCoroutineScope
import com.simplecityapps.trial.BillingManager
import com.simplecityapps.trial.TrialManager
import com.simplecityapps.trial.TrialState
import javax.inject.Inject
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.flow.collect
import kotlinx.coroutines.launch
import timber.log.Timber

class TrialInitializer
@Inject
constructor(
    private val trialManager: TrialManager,
    private val playbackManager: PlaybackManager,
    private val billingManager: BillingManager,
    @AppCoroutineScope private val coroutineScope: CoroutineScope
) : AppInitializer {
    override fun init(application: Application) {
        Timber.v("Initializing trial manager")
        billingManager.addListener(
            object : BillingManager.Listener {
                override fun onBillingClientAvailable() {
                    Timber.v("Billing client available")
                    billingManager.queryPurchases()
                    coroutineScope.launch {
                        billingManager.queryProductDetails()
                    }
                }
            }
        )
        billingManager.start()

        coroutineScope.launch {
            trialManager.trialState.collect { trialState ->
                when (trialState) {
                    is TrialState.Expired -> {
                        playbackManager.setPlaybackSpeed(trialState.multiplier())
                    }
                    TrialState.Paid, is TrialState.Pretrial, is TrialState.Trial, TrialState.Unknown -> {
                        playbackManager.setPlaybackSpeed(1.0f)
                    }
                }
            }
        }
    }
}