package io.oxygenhub.android.ui

import io.oxygenhub.android.FakeHubApi

import io.oxygenhub.android.Fixtures

import io.oxygenhub.android.MainDispatcherRule

import io.oxygenhub.android.api.Avatar

import io.oxygenhub.android.api.HubException

import io.oxygenhub.android.api.UserSky

import io.oxygenhub.android.auth.Session

import io.oxygenhub.android.ui.backdrop.Frame

import io.oxygenhub.android.ui.backdrop.repoSkyOrNull

import io.oxygenhub.android.ui.backdrop.skyEvents

import io.oxygenhub.android.ui.backdrop.straight

import io.oxygenhub.android.ui.common.Load

import io.oxygenhub.android.ui.dashboard.Dashboard

import io.oxygenhub.android.ui.dashboard.DashboardViewModel

import org.junit.Assert.assertEquals

import org.junit.Assert.assertFalse

import org.junit.Assert.assertNull

import org.junit.Assert.assertTrue

import org.junit.Rule

import org.junit.Test

class DashboardViewModelTest {

    @get:Rule val main = MainDispatcherRule()

    private val api = FakeHubApi()

    private val session = Session("https://oxygenhub.io", "andymccall", "t")

    private fun ready(vm: DashboardViewModel): Dashboard = (vm.state.value as Load.Ready).value

    @Test

    fun greetsAndListsTheUsersRecentRepositories() {

        val d = ready(DashboardViewModel(api, session) { 9 })

        assertEquals("Good morning, Andy McCall", d.greeting)

        assertTrue(d.recentAreYours)

        assertEquals(listOf("andymccall/oxygenflow", "andymccall/secret-plans"), d.recent.map { it.slug })

        assertEquals(2, d.repositoryCount)

    }

    @Test

    fun showsTheAccountsAvatarAndKeepsItWhenTheHubFails() {

        val mine = Avatar.Identicon(196, setOf(3 to 3))

        api.avatar = { if (it == "andymccall") mine else null }

        val vm = DashboardViewModel(api, session) { 9 }

        assertEquals(mine, ready(vm).avatar)

        assertEquals("andymccall", ready(vm).username)

        // A failed fetch keeps the one before; the page still loads.

        api.avatar = { throw HubException.Http(500, "down") }

        vm.refresh()

        assertEquals(mine, ready(vm).avatar)

    }

    @Test

    fun drawsYourSkyFromTheHubAndTheFieldWithoutIt() {

        val vm = DashboardViewModel(api, session) { 9 }

        val sky = ready(vm).sky!!

        val events = skyEvents(sky)

        assertEquals(1, events.size)

        assertEquals(1f, events[0].ageDays, 0.001f)

        assertEquals(3u, events[0].n)

        // A hub before /user/sky: the dashboard loads, with no sky.

        api.userSky = { throw HubException.Http(404, "no such endpoint") }

        vm.refresh()

        assertNull(ready(vm).sky)

        assertEquals(2, ready(vm).repositoryCount)

    }

    @Test

    fun aRepositorysSkyIsNothingFromAHubWithoutIt() = kotlinx.coroutines.test.runTest {

        assertEquals(listOf("andymccall/oxygen"), repoSkyOrNull(api, "andymccall", "oxygen")?.repos)

        api.userSky = { throw HubException.Http(404, "no such endpoint") }

        assertNull(repoSkyOrNull(api, "andymccall", "oxygen"))

    }

    @Test

    fun leavesOutMalformedSkyEvents() {

        val sky = UserSky(now = 0, repos = listOf("a/b"), events = listOf(listOf(0L, 9L, 0L, 1L), listOf(3L, 0L, 0L, 1L), listOf(0L), listOf(0L, 4L, 5L, 0L)))

        val events = skyEvents(sky)

        assertEquals(1, events.size)

        assertEquals(4u, events[0].kind)

        assertEquals(0f, events[0].ageDays)

        assertEquals("at least one mark", 1u, events[0].n)

    }

    @Test

    fun decodesAFrameAndUnpremultipliesItsColours() {

        val bytes = java.nio.ByteBuffer.allocate(8).order(java.nio.ByteOrder.LITTLE_ENDIAN).putFloat(1.5f).putFloat(-2f).array()

        assertTrue(Frame.floats(bytes).contentEquals(floatArrayOf(1.5f, -2f)))

        val c = straight(0.25f, 0f, 0.5f, 0.5f)

        assertEquals(0.5f, c.red, 0.01f)

        assertEquals(1f, c.blue, 0.01f)

        assertEquals(0.5f, c.alpha, 0.01f)

        assertEquals(0f, straight(0.1f, 0.1f, 0.1f, 0f).alpha)

    }

    @Test

    fun showsProposalsToReviewAndNoneFromAHubWithoutTheCall() {

        val vm = DashboardViewModel(api, session) { 9 }

        assertEquals(listOf(300L), ready(vm).proposals?.review?.map { it.number })

        assertEquals("andymccall" to "oxygenhub", ready(vm).proposals!!.review[0].let { it.owner to it.name })

        api.userProposals = { throw HubException.Http(404, "no such endpoint") }

        vm.refresh()

        assertNull(ready(vm).proposals)

        assertEquals(2, ready(vm).repositoryCount)

    }

    @Test

    fun withNoRepositoriesOfTheirOwnShowsTheHubs() {

        val d = ready(DashboardViewModel(api, session.copy(username = "newcomer")) { 14 }.also {

            api.user = { Fixtures.user.copy(username = "newcomer", displayName = "") }

            it.refresh()

        })

        assertEquals("Good afternoon, newcomer", d.greeting)

        assertFalse(d.recentAreYours)

        assertEquals("doomsdayone/tetris", d.recent.first().slug)

    }

    @Test

    fun withoutUserReadGreetsByTheSessionsName() {

        api.user = { throw HubException.Http(403, "this token lacks the user:read scope") }

        val d = ready(DashboardViewModel(api, session) { 22 })

        assertEquals("Good evening, andymccall", d.greeting)

        assertNull(d.user)

    }

    @Test

    fun aFailureAndARetry() {

        api.repositories = { throw HubException.Http(503, "down") }

        val vm = DashboardViewModel(api, session) { 9 }

        assertTrue(vm.state.value is Load.Failed)

        api.repositories = { Fixtures.repos }

        vm.refresh()

        assertTrue(vm.state.value is Load.Ready)

    }

    @Test

    fun greetings() {

        assertEquals("Good evening, a", DashboardViewModel.greeting(4, "a"))

        assertEquals("Good morning, a", DashboardViewModel.greeting(5, "a"))

        assertEquals("Good afternoon, a", DashboardViewModel.greeting(12, "a"))

        assertEquals("Good evening, a", DashboardViewModel.greeting(18, "a"))

    }

}