package shared_tests

import (
	"context"
	"math"
	"time"

	"github.com/stretchr/testify/require"
	"go.skia.org/infra/go/deepequal/assertdeep"
	"go.skia.org/infra/go/git/testutils/mem_git"
	"go.skia.org/infra/go/gitstore"
	"go.skia.org/infra/go/sktest"
	"go.skia.org/infra/go/vcsinfo"
)

func TestGitStore(t sktest.TestingT, gs gitstore.GitStore) {
	ctx := context.Background()

	// Empty to start.
	branches, err := gs.GetBranches(ctx)
	require.NoError(t, err)
	require.Equal(t, 0, len(branches))
	lcs, err := gs.Get(ctx, []string{"a", "b", "c"})
	require.NoError(t, err)
	require.Equal(t, 3, len(lcs))
	for _, lc := range lcs {
		require.Nil(t, lc)
	}
	ics, err := gs.RangeN(ctx, math.MinInt32, math.MaxInt32, gitstore.ALL_BRANCHES)
	require.NoError(t, err)
	require.Equal(t, 0, len(ics))
	ics, err = gs.RangeByTime(ctx, time.Time{}, vcsinfo.MaxTime, gitstore.ALL_BRANCHES)
	require.NoError(t, err)
	require.Equal(t, 0, len(ics))

	// Put a commit, but don't update the branch head. It should show up in
	// results of Get() and Range, but the master branch should not be
	// updated.
	master := "master"
	c0 := mem_git.FakeCommit(t, "c0", master)
	require.NoError(t, gs.Put(ctx, []*vcsinfo.LongCommit{c0}))
	branches, err = gs.GetBranches(ctx)
	require.NoError(t, err)
	require.Nil(t, branches[master])
	lcs, err = gs.Get(ctx, []string{"a", "b", c0.Hash})
	require.NoError(t, err)
	require.Equal(t, 3, len(lcs))
	require.Nil(t, lcs[0])
	require.Nil(t, lcs[1])
	assertdeep.Equal(t, c0, lcs[2])
	ics, err = gs.RangeN(ctx, math.MinInt32, math.MaxInt32, gitstore.ALL_BRANCHES)
	require.NoError(t, err)
	require.Equal(t, 1, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	ics, err = gs.RangeByTime(ctx, time.Time{}, vcsinfo.MaxTime, gitstore.ALL_BRANCHES)
	require.NoError(t, err)
	require.Equal(t, 1, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	ics, err = gs.RangeN(ctx, math.MinInt32, math.MaxInt32, master)
	require.NoError(t, err)
	require.Equal(t, 0, len(ics))
	ics, err = gs.RangeByTime(ctx, vcsinfo.MinTime, vcsinfo.MaxTime, master)
	require.NoError(t, err)
	require.Equal(t, 0, len(ics))

	// Put the master branch.
	require.NoError(t, gs.PutBranches(ctx, map[string]string{
		master: c0.Hash,
	}))
	branches, err = gs.GetBranches(ctx)
	require.NoError(t, err)
	require.NotNil(t, branches[master])
	require.Equal(t, c0.Hash, branches[master].Head)
	require.Equal(t, 0, branches[master].Index)
	ics, err = gs.RangeN(ctx, math.MinInt32, math.MaxInt32, master)
	require.NoError(t, err)
	require.Equal(t, 1, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	ics, err = gs.RangeByTime(ctx, vcsinfo.MinTime, vcsinfo.MaxTime, master)
	require.NoError(t, err)
	require.Equal(t, 1, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])

	// Add a second commit.
	c1 := mem_git.FakeCommit(t, "c1", master, c0)
	require.NoError(t, gs.Put(ctx, []*vcsinfo.LongCommit{c1}))
	branches, err = gs.GetBranches(ctx)
	require.NoError(t, err)
	require.NotNil(t, branches[master])
	require.Equal(t, c0.Hash, branches[master].Head)
	lcs, err = gs.Get(ctx, []string{c1.Hash})
	require.NoError(t, err)
	require.Equal(t, 1, len(lcs))
	assertdeep.Equal(t, c1, lcs[0])
	ics, err = gs.RangeN(ctx, math.MinInt32, math.MaxInt32, gitstore.ALL_BRANCHES)
	require.NoError(t, err)
	require.Equal(t, 2, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	ics, err = gs.RangeByTime(ctx, time.Time{}, vcsinfo.MaxTime, gitstore.ALL_BRANCHES)
	require.NoError(t, err)
	require.Equal(t, 2, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	ics, err = gs.RangeN(ctx, math.MinInt32, math.MaxInt32, master)
	require.NoError(t, err)
	require.Equal(t, 1, len(ics))
	ics, err = gs.RangeByTime(ctx, vcsinfo.MinTime, vcsinfo.MaxTime, master)
	require.NoError(t, err)
	require.Equal(t, 1, len(ics))
	require.NoError(t, gs.PutBranches(ctx, map[string]string{
		master: c1.Hash,
	}))
	branches, err = gs.GetBranches(ctx)
	require.NoError(t, err)
	require.NotNil(t, branches[master])
	require.Equal(t, c1.Hash, branches[master].Head)
	require.Equal(t, 1, branches[master].Index)
	ics, err = gs.RangeN(ctx, math.MinInt32, math.MaxInt32, master)
	require.NoError(t, err)
	require.Equal(t, 2, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	assertdeep.Equal(t, c1.IndexCommit(), ics[1])
	ics, err = gs.RangeByTime(ctx, vcsinfo.MinTime, vcsinfo.MaxTime, master)
	require.NoError(t, err)
	require.Equal(t, 2, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	assertdeep.Equal(t, c1.IndexCommit(), ics[1])

	// Add a new branch.
	otherbranch := "otherbranch"
	c2 := mem_git.FakeCommit(t, "c2", otherbranch, c0)
	c0.Branches[otherbranch] = true // Re-insert c0 so that it shows up as part of otherbranch.
	require.NoError(t, gs.Put(ctx, []*vcsinfo.LongCommit{c0, c2}))
	branches, err = gs.GetBranches(ctx)
	require.NoError(t, err)
	require.Nil(t, branches[otherbranch])
	lcs, err = gs.Get(ctx, []string{c2.Hash})
	require.NoError(t, err)
	require.Equal(t, 1, len(lcs))
	assertdeep.Equal(t, c2, lcs[0])
	// Note: Behavior for ALL_BRANCHES is undefined for RangeN when there
	// are multiple branches with overlapping indexes, so we don't check
	// that here.
	ics, err = gs.RangeByTime(ctx, time.Time{}, vcsinfo.MaxTime, gitstore.ALL_BRANCHES)
	require.NoError(t, err)
	require.Equal(t, 3, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	// RangeByTime sorts by index, and c1 and c2 both have index 1.
	if ics[1].Hash == c1.Hash {
		assertdeep.Equal(t, c1.IndexCommit(), ics[1])
		assertdeep.Equal(t, c2.IndexCommit(), ics[2])
	} else {
		assertdeep.Equal(t, c1.IndexCommit(), ics[2])
		assertdeep.Equal(t, c2.IndexCommit(), ics[1])
	}
	ics, err = gs.RangeN(ctx, math.MinInt32, math.MaxInt32, otherbranch)
	require.NoError(t, err)
	require.Equal(t, 0, len(ics))
	ics, err = gs.RangeByTime(ctx, vcsinfo.MinTime, vcsinfo.MaxTime, otherbranch)
	require.NoError(t, err)
	require.Equal(t, 0, len(ics))
	require.NoError(t, gs.PutBranches(ctx, map[string]string{
		otherbranch: c2.Hash,
	}))
	branches, err = gs.GetBranches(ctx)
	require.NoError(t, err)
	require.NotNil(t, branches[otherbranch])
	require.Equal(t, c2.Hash, branches[otherbranch].Head)
	require.Equal(t, 1, branches[otherbranch].Index)
	ics, err = gs.RangeN(ctx, math.MinInt32, math.MaxInt32, otherbranch)
	require.NoError(t, err)
	require.Equal(t, 2, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	assertdeep.Equal(t, c2.IndexCommit(), ics[1])
	ics, err = gs.RangeByTime(ctx, vcsinfo.MinTime, vcsinfo.MaxTime, otherbranch)
	require.NoError(t, err)
	require.Equal(t, 2, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	assertdeep.Equal(t, c2.IndexCommit(), ics[1])
	ics, err = gs.RangeN(ctx, math.MinInt32, math.MaxInt32, master)
	require.NoError(t, err)
	require.Equal(t, 2, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	assertdeep.Equal(t, c1.IndexCommit(), ics[1])
	ics, err = gs.RangeByTime(ctx, vcsinfo.MinTime, vcsinfo.MaxTime, master)
	require.NoError(t, err)
	require.Equal(t, 2, len(ics))
	assertdeep.Equal(t, c0.IndexCommit(), ics[0])
	assertdeep.Equal(t, c1.IndexCommit(), ics[1])
}