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

package io.oxygenhub.android.alerts

import android.util.Log

import com.google.firebase.messaging.FirebaseMessagingService

import com.google.firebase.messaging.RemoteMessage

import io.oxygenhub.android.OxygenHubApp

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.SupervisorJob

import kotlinx.coroutines.launch

/** Cloud Messaging's side of the hub's alerts (#16): a new token, or a sealed alert. */

class AlertService : FirebaseMessagingService() {

    private val scope = CoroutineScope(SupervisorJob() + Dispatchers.IO)

    /** The phone's registration changed: tell the hub, when signed in. */

    override fun onNewToken(token: String) {

        val api = (application as OxygenHubApp).container.sessions.api() ?: return

        scope.launch {

            runCatching { PushAlerts.register(applicationContext, api, token) }

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

        }

    }

    /** Only data messages come: open the sealed alert and show it. */

    override fun onMessageReceived(message: RemoteMessage) {

        val sealed = message.data["sealed"] ?: return

        val alert = PushAlerts.open(applicationContext, sealed) ?: return

        PushAlerts.show(applicationContext, alert)

    }

}