@ExperimentalTime
internal class AuthenticationRepositoryImpl(
    private val authenticationApi: AuthenticationApi,
    private val authenticationQueries: AuthenticationQueries
) : AuthenticationRepository {

    override suspend fun authenticateUser() {
        authenticationQueries.clearAuthenticationData()
        authenticationApi.authenticateUser().toAuthentication().apply {
            authenticationQueries.setAuthenticationData(accessToken, expiresBy)
        }
    }

    @ExperimentalTime
    override suspend fun getAuthenticationData(): Flow<Authentication?> {
        val timeNow = Clock.System.now().epochSeconds
        return authenticationQueries.getAuthenticationData(timeNow).asFlow().mapToOneOrNull()
    }
}

fun checkAuthentication() {
    viewModelScope.launch {
        authenticationRepository.getAuthenticationData().onEach {
            if (it != null) {
                Timber.d("Valid Authentication Found")
                isAuthenticationValid.value = true
            } else {
                Timber.d("Valid Authentication Not Found - Requesting Authentication")
                authenticationRepository.authenticateUser()
            }
        }.collect()
    }
}