Coverage / app/src/main/java/io/oxygenhub/android/OxygenHubApp.kt 0.0%

package io.oxygenhub.android

import android.app.Application

import android.os.Build

import android.util.Log

import io.oxygenhub.android.alerts.PushAlerts

import io.oxygenhub.android.api.DeviceAuth

import io.oxygenhub.android.api.HubClient

import io.oxygenhub.android.api.HubDeviceAuth

import io.oxygenhub.android.api.hubHttpClient

import io.oxygenhub.android.auth.KeystoreSessionStore

import io.oxygenhub.android.auth.SessionManager

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.SupervisorJob

import kotlinx.coroutines.flow.distinctUntilChanged

import kotlinx.coroutines.flow.filterNotNull

import kotlinx.coroutines.launch

import okhttp3.OkHttpClient

/** The hub the app signs in to unless told otherwise. */

const val DEFAULT_HUB = "https://oxygenhub.io"

/** The app's shared objects, made once. A small hand-made container: no DI framework yet. */

class AppContainer(app: Application) {

    val http: OkHttpClient = hubHttpClient()

    val sessions = SessionManager(KeystoreSessionStore(app)) { session, onUnauthorized ->

        HubClient(session.hub, session.token, http, onUnauthorized)

    }

    fun deviceAuth(hub: String): DeviceAuth = HubDeviceAuth(hub, http)

    /** What the app calls itself on the hub's /device page and token list. */

    val clientName: String = "OxygenHub for Android on ${Build.MODEL}".take(80)

}

class OxygenHubApp : Application() {

    lateinit var container: AppContainer

        private set

    override fun onCreate() {

        super.onCreate()

        container = AppContainer(this)

        // Alerts from the hub (#16): each signed-in session registers this

        // phone; signing out revokes the token, which ends it on the hub.

        if (PushAlerts.available) {

            PushAlerts.start(this)

            CoroutineScope(SupervisorJob() + Dispatchers.IO).launch {

                container.sessions.session.filterNotNull().distinctUntilChanged().collect {

                    val api = container.sessions.api() ?: return@collect

                    runCatching { PushAlerts.register(this@OxygenHubApp, api) }

                        .onFailure { Log.w("OxygenHubApp", "alerts: registering with the hub: ${it.message}") }

                }

            }

        }

    }

}