package io.oxygenhub.android.alerts

import android.app.job.JobParameters

import android.app.job.JobService

import io.oxygenhub.android.OxygenHubApp

import io.oxygenhub.android.api.HubException

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.SupervisorJob

import kotlinx.coroutines.cancel

import kotlinx.coroutines.launch

/** The periodic check behind [LandAlerts]: what the account can land now. */

class LandCheckJob : JobService() {

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

    override fun onStartJob(params: JobParameters): Boolean {

        // Signed out: nothing to ask, and the next sign-in finds the alerts as they were.

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

        scope.launch {

            try {

                LandAlerts.check(this@LandCheckJob, api.userProposals(landable = true).landable)

            } catch (_: HubException) {

                // Unreachable or refused: the next period asks again.

            }

            jobFinished(params, false)

        }

        return true

    }

    override fun onStopJob(params: JobParameters): Boolean = false

    override fun onDestroy() {

        scope.cancel()

        super.onDestroy()

    }

}