LockedStore.kt - mozsearch

Enable keyboard shortcuts

/*

 * This Source Code Form is subject to the terms of the Mozilla Public

 * License, v. 2.0. If a copy of the MPL was not distributed with this

 * file, You can obtain one at http://mozilla.org/MPL/2.0/.

*/

package mozilla.lockbox.store

import io.reactivex.Observable

import io.reactivex.rxkotlin.Observables

import io.reactivex.subjects.BehaviorSubject

import mozilla.lockbox.action.DataStoreAction

import mozilla.lockbox.action.FingerprintAuthAction

import mozilla.lockbox.action.LifecycleAction

import mozilla.lockbox.action.UnlockingAction

import mozilla.lockbox.extensions.filterByType

import mozilla.lockbox.flux.Dispatcher

open class LockedStore(

    val dispatcher: Dispatcher = Dispatcher.shared,

    lifecycleStore: LifecycleStore = LifecycleStore.shared

) {

    companion object {

        val shared = LockedStore()

    private val unlocking = BehaviorSubject.createDefault(false)

    private val forceLock = BehaviorSubject.createDefault(false)

    open val canLaunchAuthenticationOnForeground: Observable<Boolean>

        get() = Observables.combineLatest(unlocking, forceLock)

            .map { !it.first && !it.second }

    open val onAuthentication: Observable<FingerprintAuthAction> =

        dispatcher.register

            .filterByType(FingerprintAuthAction::class.java)

    init {

        dispatcher.register

            .filterByType(DataStoreAction::class.java)

            // the DataStoreAction.Lock is only dispatched when tapping "Lock Now"

            .map { it == DataStoreAction.Lock }

            .subscribe(forceLock)

        lifecycleStore.lifecycleEvents

            .filter { it == LifecycleAction.Background }

            .map { false }

            .subscribe(forceLock)

        dispatcher.register

            .filterByType(UnlockingAction::class.java)

            .map { it.currently }

            .subscribe(unlocking)