squash_iterator_test.go

package gitbase

import (
	"context"
	"os"
	"path/filepath"
	"testing"

	"github.com/src-d/go-borges"
	"github.com/src-d/go-borges/plain"
	fixtures "github.com/src-d/go-git-fixtures"
	"github.com/src-d/go-mysql-server/sql"
	"github.com/src-d/go-mysql-server/sql/expression"
	"github.com/stretchr/testify/require"
	"gopkg.in/src-d/go-billy.v4/osfs"
)

func TestAllReposIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	require.Len(chainableIterRows(t, ctx, NewAllReposIter(nil)), 2)
}

func TestSquashContextCancelled(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	var cancel context.CancelFunc
	ctx.Context, cancel = context.WithCancel(ctx.Context)
	cancel()

	iters := []ChainableIter{
		NewAllReposIter(nil),
		NewAllRemotesIter(nil),
		NewAllRefsIter(nil, false),
		NewAllCommitsIter(nil, false),
		NewAllTreeEntriesIter(nil),
	}

	session, err := getSession(ctx)
	require.NoError(err)

	pool := session.Pool
	iter, err := pool.RepoIter()
	require.NoError(err)

	repo, err := iter.Next()
	require.NoError(err)

	for _, it := range iters {
		iter, err := it.New(ctx, repo)
		require.NoError(err)

		err = iter.Advance()
		require.Error(err)
		require.True(ErrSessionCanceled.Is(err))
	}
}

func TestAllRemotesIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	require.Len(chainableIterRows(t, ctx, NewAllRemotesIter(nil)), 2)

	require.Len(
		chainableIterRows(t, ctx, NewAllRemotesIter(
			expression.NewNot(
				expression.NewEquals(
					expression.NewGetField(2, sql.Text, "push_url", false),
					expression.NewLiteral("git@github.com:git-fixtures/submodule.git", sql.Text),
				),
			),
		)),
		1,
	)

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	require.Len(chainableIterRows(t, ctx, NewAllRemotesIter(nil)), 2)

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(t, ctx, NewAllRemotesIter(nil))
}

func TestRepoRemotesIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	require.Len(chainableIterRows(
		t, ctx,
		NewRepoRemotesIter(NewAllReposIter(nil), nil),
	), 2)

	require.Len(chainableIterRows(
		t, ctx,
		NewRepoRemotesIter(
			NewAllReposIter(nil),
			expression.NewNot(
				expression.NewEquals(
					expression.NewGetField(3, sql.Text, "push_url", false),
					expression.NewLiteral("git@github.com:git-fixtures/submodule.git", sql.Text),
				),
			),
		),
	), 1)

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	require.Len(chainableIterRows(
		t, ctx,
		NewRepoRemotesIter(NewAllReposIter(nil), nil),
	), 2)

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(
		t, ctx,
		NewRepoRemotesIter(NewAllReposIter(nil), nil),
	)
}

func TestAllRefsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewAllRefsIter(nil, false),
	)

	expectedRowsLen := len(rows)

	table := newReferencesTable(poolFromCtx(t, ctx))
	expected, err := tableToRows(ctx, table)
	require.NoError(err)

	require.ElementsMatch(expected, rows)

	rows = chainableIterRows(
		t, ctx,
		NewAllRefsIter(
			expression.NewEquals(
				expression.NewGetField(1, sql.Text, "name", false),
				expression.NewLiteral("HEAD", sql.Text),
			),
			false,
		),
	)

	require.Len(rows, 2)

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	rows = chainableIterRows(
		t, ctx,
		NewAllRefsIter(nil, false),
	)

	require.Len(rows, expectedRowsLen)

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(
		t, ctx,
		NewAllRefsIter(nil, false),
	)
}

func TestRepoRefsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewRepoRefsIter(
			NewAllReposIter(nil),
			nil,
			false,
		),
	)

	expectedRowsLen := len(rows)

	expected := chainableIterRows(
		t, ctx,
		NewAllRefsIter(nil, false),
	)

	for i := range rows {
		rows[i] = rows[i][1:]
	}

	require.ElementsMatch(expected, rows)

	rows = chainableIterRows(
		t, ctx,
		NewRepoRefsIter(
			NewAllReposIter(nil),
			expression.NewEquals(
				expression.NewGetField(2, sql.Text, "name", false),
				expression.NewLiteral("HEAD", sql.Text),
			),
			false,
		),
	)

	require.Len(rows, 2)

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	rows = chainableIterRows(
		t, ctx,
		NewRepoRefsIter(
			NewAllReposIter(nil),
			nil,
			false,
		),
	)

	require.Equal(expectedRowsLen, len(rows))

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(
		t, ctx,
		NewRepoRefsIter(
			NewAllReposIter(nil),
			nil,
			false,
		),
	)
}

func TestRemoteRefsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewRemoteRefsIter(
			NewAllRemotesIter(nil),
			nil,
		),
	)

	expectedRowsLen := len(rows)

	expected := chainableIterRows(
		t, ctx,
		NewAllRefsIter(nil, false),
	)

	for i := range rows {
		rows[i] = rows[i][6:]
	}

	require.ElementsMatch(expected, rows)

	rows = chainableIterRows(
		t, ctx,
		NewRemoteRefsIter(
			NewAllRemotesIter(nil),
			expression.NewEquals(
				expression.NewGetField(7, sql.Text, "name", false),
				expression.NewLiteral("HEAD", sql.Text),
			),
		),
	)

	require.Len(rows, 2)

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	rows = chainableIterRows(
		t, ctx,
		NewRemoteRefsIter(
			NewAllRemotesIter(nil),
			nil,
		),
	)

	require.Len(rows, expectedRowsLen)

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(
		t, ctx,
		NewRemoteRefsIter(
			NewAllRemotesIter(nil),
			nil,
		),
	)
}

func TestAllCommitsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewAllCommitsIter(nil, false),
	)

	expectedRowsLen := len(rows)

	expected, err := tableToRows(
		ctx,
		newCommitsTable(poolFromCtx(t, ctx)),
	)
	require.NoError(err)

	require.ElementsMatch(expected, rows)

	rows = chainableIterRows(
		t, ctx,
		NewAllCommitsIter(
			expression.NewEquals(
				expression.NewGetField(3, sql.Text, "commit_author_email", false),
				expression.NewLiteral("mcuadros@gmail.com", sql.Text),
			),
			false,
		),
	)

	require.Len(rows, 12)

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	rows = chainableIterRows(
		t, ctx,
		NewAllCommitsIter(nil, false),
	)

	require.Len(rows, expectedRowsLen)

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(
		t, ctx,
		NewAllCommitsIter(nil, false),
	)
}

func TestRepoCommitsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewRepoCommitsIter(
			NewAllReposIter(nil),
			nil,
		),
	)

	expected := chainableIterRows(
		t, ctx,
		NewAllCommitsIter(nil, false),
	)

	for i := range rows {
		rows[i] = rows[i][1:]
	}

	require.ElementsMatch(expected, rows)

	rows = chainableIterRows(
		t, ctx,
		NewRepoCommitsIter(
			NewAllReposIter(nil),
			expression.NewEquals(
				expression.NewGetField(2, sql.Text, "commit_hash", false),
				expression.NewLiteral("918c48b83bd081e863dbe1b80f8998f058cd8294", sql.Text),
			),
		),
	)

	require.Len(rows, 1)
}

func TestRefHEADCommitsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewRefHEADCommitsIter(NewAllRefsIter(nil, false), nil, false),
	)

	expectedRowsLen := len(rows)

	table := newReferencesTable(poolFromCtx(t, ctx))
	expected, err := tableToRows(ctx, table)
	require.NoError(err)

	require.Len(rows, len(expected))
	for _, row := range rows {
		require.Equal(row[2 /* ref hash */], row[4 /* commit hash */])
	}

	rows = chainableIterRows(
		t, ctx,
		NewRefHEADCommitsIter(
			NewAllRefsIter(nil, false),
			expression.NewEquals(
				expression.NewGetField(6, sql.Text, "commit_author_email", false),
				expression.NewLiteral("mcuadros@gmail.com", sql.Text),
			),
			false,
		),
	)

	require.Len(rows, 7)
	for _, row := range rows {
		require.Equal(row[2 /* ref hash */], row[4 /* commit hash */])
	}

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	rows = chainableIterRows(
		t, ctx,
		NewRefHEADCommitsIter(NewAllRefsIter(nil, false), nil, false),
	)

	require.Len(rows, expectedRowsLen)

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(
		t, ctx,
		NewRefHEADCommitsIter(NewAllRefsIter(nil, false), nil, false),
	)
}

func TestAllTreeEntriesIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewAllTreeEntriesIter(nil),
	)

	expectedRowsLen := len(rows)

	expected, err := tableToRows(ctx, newTreeEntriesTable(poolFromCtx(t, ctx)))
	require.NoError(err)

	require.ElementsMatch(expected, rows)

	rows = chainableIterRows(
		t, ctx,
		NewAllTreeEntriesIter(
			expression.NewEquals(
				expression.NewGetField(1, sql.Text, "tree_entry_name", false),
				expression.NewLiteral("LICENSE", sql.Text),
			),
		),
	)

	require.Len(rows, 8)

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	rows = chainableIterRows(
		t, ctx,
		NewAllTreeEntriesIter(nil),
	)

	require.Len(rows, expectedRowsLen)

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(
		t, ctx,
		NewAllTreeEntriesIter(nil),
	)
}

func TestRepoTreeEntriesIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewRepoTreeEntriesIter(
			NewAllReposIter(nil),
			nil,
		),
	)

	expected := chainableIterRows(
		t, ctx,
		NewAllTreeEntriesIter(nil),
	)

	for i := range rows {
		rows[i] = rows[i][1:]
	}

	require.ElementsMatch(expected, rows)

	rows = chainableIterRows(
		t, ctx,
		NewRepoTreeEntriesIter(
			NewAllReposIter(nil),
			expression.NewEquals(
				expression.NewGetField(2, sql.Text, "tree_entry_name", false),
				expression.NewLiteral("LICENSE", sql.Text),
			),
		),
	)

	require.Len(rows, 8)
}

func TestCommitTreesIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewCommitTreesIter(
			NewAllCommitsIter(nil, true),
			nil,
			false,
		),
	)

	require.Len(rows, 24)

	expectedRowsLen := len(rows)

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	rows = chainableIterRows(
		t, ctx,
		NewCommitTreesIter(
			NewAllCommitsIter(nil, false),
			nil,
			false,
		),
	)

	require.Len(rows, expectedRowsLen)

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(
		t, ctx,
		NewCommitTreesIter(
			NewAllCommitsIter(nil, false),
			nil,
			false,
		),
	)
}

func TestTreeEntryBlobsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewTreeEntryBlobsIter(
			NewAllTreeEntriesIter(nil),
			nil,
			false,
		),
	)

	require.Len(rows, 39)

	expectedRowsLen := len(rows)

	rows = chainableIterRows(
		t, ctx,
		NewTreeEntryBlobsIter(
			NewAllTreeEntriesIter(nil),
			expression.NewLessThan(
				expression.NewGetField(len(TreeEntriesSchema)+2, sql.Int64, "blob_size", false),
				expression.NewLiteral(int64(150), sql.Int64),
			),
			false,
		),
	)

	require.Len(rows, 10)

	ctx, cleanup2 := setupIterWithErrors(t, true, true)
	defer cleanup2()

	rows = chainableIterRows(
		t, ctx,
		NewTreeEntryBlobsIter(
			NewAllTreeEntriesIter(nil),
			nil,
			false,
		),
	)

	require.Len(rows, expectedRowsLen)

	ctx, cleanup3 := setupIterWithErrors(t, true, false)
	defer cleanup3()

	chainableIterRowsError(
		t, ctx,
		NewTreeEntryBlobsIter(
			NewAllTreeEntriesIter(nil),
			nil,
			false,
		),
	)
}

func TestRepoBlobsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewRepoBlobsIter(
			NewAllReposIter(nil),
			nil,
			false,
		),
	)

	expected, err := tableToRows(
		ctx,
		newBlobsTable(poolFromCtx(t, ctx)),
	)
	require.NoError(err)

	for i := range rows {
		rows[i] = rows[i][1:]
	}

	require.ElementsMatch(expected, rows)

	rows = chainableIterRows(
		t, ctx,
		NewRepoBlobsIter(
			NewAllReposIter(nil),
			expression.NewEquals(
				expression.NewGetField(2, sql.Text, "hash", false),
				expression.NewLiteral("d3ff53e0564a9f87d8e84b6e28e5060e517008aa", sql.Text),
			),
			false,
		),
	)

	require.Len(rows, 1)
}

func TestCommitBlobsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewCommitBlobsIter(
			NewAllCommitsIter(nil, true),
			nil,
		),
	)

	require.Len(rows, 52)
}

func TestCommitFileBlobsIter(t *testing.T) {
	require := require.New(t)
	ctx, cleanup := setupIter(t)
	defer cleanup()

	rows := chainableIterRows(
		t, ctx,
		NewCommitFileBlobsIter(
			NewAllCommitFilesIter(nil).(FilesIter),
			nil,
			true,
		),
	)

	expected := chainableIterRows(
		t, ctx,
		NewCommitFileFilesIter(
			NewAllCommitFilesIter(nil).(FilesIter),
			nil,
			true,
		),
	)

	// transform the result of the files table into the expected for blobs
	offset := len(CommitFilesSchema)
	size := offset + len(BlobsSchema)
	for i, e := range expected {
		var newRow = make(sql.Row, size)
		copy(newRow[:offset], e[:offset])
		newRow[offset] = e[offset]     // repository_id
		newRow[offset+1] = e[offset+2] // blob_hash
		newRow[offset+2] = e[offset+6] // blob_size
		newRow[offset+3] = e[offset+5] // blob_content
		expected[i] = newRow
	}

	require.ElementsMatch(expected, rows)
}

func chainableIterRowsError(t *testing.T, ctx *sql.Context, iter ChainableIter) {
	t.Helper()
	table := newSquashTable(iter)
	_, err := tableToRows(ctx, table)
	require.Error(t, err)
}

func chainableIterRows(t *testing.T, ctx *sql.Context, iter ChainableIter) []sql.Row {
	t.Helper()
	table := newSquashTable(iter)
	rows, err := tableToRows(ctx, table)
	require.NoError(t, err)
	return rows
}

func setupIter(t *testing.T) (*sql.Context, func()) {
	t.Helper()
	return setupIterWithErrors(t, false, false)
}

func setupIterWithErrors(t *testing.T, badRepo bool, skipErrors bool) (*sql.Context, func()) {
	t.Helper()
	require := require.New(t)

	lib, pool, err := newMultiPool()
	require.NoError(err)

	if badRepo {
		// TODO: add repo with errors
		loc, err := plain.NewLocation(borges.LocationID("bad"), osfs.New("/does/not/exist"), nil)
		require.NoError(err)

		lib.plain.AddLocation(loc)
	}

	for _, f := range fixtures.ByTag("worktree") {
		path := f.Worktree().Root()
		ok, err := IsGitRepo(path)
		require.NoError(err)
		if ok {
			err = lib.AddPlain(pathToName(path), path, nil)
			require.NoError(err)
		}
	}

	session := NewSession(pool, WithSkipGitErrors(skipErrors))
	ctx := sql.NewContext(context.TODO(), sql.WithSession(session))
	cleanup := func() {
		require.NoError(fixtures.Clean())
	}

	return ctx, cleanup
}

func TestIndexRefsIter(t *testing.T) {
	require := require.New(t)

	ctx, index, cleanup := setupWithIndex(t, new(referencesTable))
	defer cleanup()

	table := newSquashTable(
		NewAllRefsIter(nil, false),
	)

	expected, err := tableToRows(ctx, table)
	require.NoError(err)

	table = newSquashTable(
		NewIndexRefsIter(nil, index),
	)

	rows, err := tableToRows(ctx, table)
	require.NoError(err)

	require.ElementsMatch(expected, rows)
}

func TestIndexRefCommitsIter(t *testing.T) {
	require := require.New(t)

	ctx, index, cleanup := setupWithIndex(t, new(refCommitsTable))
	defer cleanup()

	table := newSquashTable(
		NewRefCommitCommitsIter(NewAllRefCommitsIter(nil), nil),
	)

	expected, err := tableToRows(ctx, table)
	require.NoError(err)

	iter := NewRefCommitCommitsIter(
		NewIndexRefCommitsIter(index, nil),
		nil,
	)

	table = newSquashTable(iter)

	rows, err := tableToRows(ctx, table)
	require.NoError(err)

	require.ElementsMatch(expected, rows)
}

func TestIndexCommitsIter(t *testing.T) {
	require := require.New(t)

	ctx, index, cleanup := setupWithIndex(t, new(commitsTable))
	defer cleanup()

	table := newSquashTable(
		NewCommitTreesIter(NewAllCommitsIter(nil, false), nil, false),
	)

	expected, err := tableToRows(ctx, table)
	require.NoError(err)

	iter := NewCommitTreesIter(
		NewIndexCommitsIter(index, nil),
		nil,
		false,
	)

	table = newSquashTable(iter)

	rows, err := tableToRows(ctx, table)
	require.NoError(err)

	require.ElementsMatch(expected, rows)
}

func TestIndexCommitTreesIter(t *testing.T) {
	require := require.New(t)

	ctx, index, cleanup := setupWithIndex(t, new(commitTreesTable))
	defer cleanup()

	table := newSquashTable(
		NewTreeTreeEntriesIter(NewAllCommitTreesIter(nil), nil, false),
	)

	expected, err := tableToRows(ctx, table)
	require.NoError(err)

	iter := NewTreeTreeEntriesIter(
		NewIndexCommitTreesIter(index, nil),
		nil,
		false,
	)

	table = newSquashTable(iter)

	rows, err := tableToRows(ctx, table)
	require.NoError(err)

	require.ElementsMatch(expected, rows)
}

func TestIndexCommitBlobsIter(t *testing.T) {
	require := require.New(t)

	ctx, index, cleanup := setupWithIndex(t, new(commitBlobsTable))
	defer cleanup()

	table := newSquashTable(
		NewCommitBlobBlobsIter(NewAllCommitBlobsIter(nil), nil, false),
	)

	expected, err := tableToRows(ctx, table)
	require.NoError(err)

	iter := NewCommitBlobBlobsIter(
		NewIndexCommitBlobsIter(index, nil),
		nil,
		false,
	)

	table = newSquashTable(iter)

	rows, err := tableToRows(ctx, table)
	require.NoError(err)

	require.ElementsMatch(expected, rows)
}

func TestIndexTreeEntriesIter(t *testing.T) {
	require := require.New(t)

	ctx, index, cleanup := setupWithIndex(t, new(treeEntriesTable))
	defer cleanup()

	table := newSquashTable(
		NewTreeEntryBlobsIter(NewAllTreeEntriesIter(nil), nil, false),
	)

	expected, err := tableToRows(ctx, table)
	require.NoError(err)

	iter := NewTreeEntryBlobsIter(
		NewIndexTreeEntriesIter(index, nil),
		nil,
		false,
	)

	table = newSquashTable(iter)

	rows, err := tableToRows(ctx, table)
	require.NoError(err)

	require.ElementsMatch(expected, rows)
}

func setupWithIndex(
	t *testing.T,
	table Indexable,
) (*sql.Context, sql.IndexLookup, CleanupFunc) {
	t.Helper()
	ctx, _, cleanup := setup(t)
	index := tableIndexLookup(t, table, ctx)
	return ctx, index, cleanup
}

func TestRefsIterSiva(t *testing.T) {
	cwd, err := os.Getwd()
	require.NoError(t, err)

	path := filepath.Join(cwd, "_testdata", "05893125684f2d3943cd84a7ab2b75e53668fba1.siva")

	lib, pool, err := newMultiPool()
	require.NoError(t, err)

	err = lib.AddSiva(path, nil)
	require.NoError(t, err)

	session := NewSession(pool)
	ctx := sql.NewContext(context.Background(), sql.WithSession(session))

	cases := []struct {
		name string
		iter ChainableIter
	}{
		{"all refs", NewAllRefsIter(nil, false)},
		{"repo refs", NewRepoRefsIter(NewAllReposIter(nil), nil, false)},
	}

	expected := []sql.Row{
		{
			"015da2f4-6d89-7ec8-5ac9-a38329ea875b",
			"HEAD",
			"dbfab055c70379219cbcf422f05316fdf4e1aed3",
		},
		{
			"015da2f4-6d89-7ec8-5ac9-a38329ea875b",
			"refs/heads/master",
			"dbfab055c70379219cbcf422f05316fdf4e1aed3",
		},
	}

	for _, tt := range cases {
		t.Run(tt.name, func(t *testing.T) {
			require := require.New(t)
			table := newSquashTable(tt.iter)

			rows, err := tableToRows(ctx, table)
			require.NoError(err)

			// remove all non-ref columns
			for i := range rows {
				rows[i] = rows[i][len(rows[i])-3:]
			}

			require.ElementsMatch(expected, rows)
		})
	}

	t.Run("remote refs", func(t *testing.T) {
		require := require.New(t)
		table := newSquashTable(
			NewRemoteRefsIter(NewAllRemotesIter(nil), nil),
		)

		rows, err := tableToRows(ctx, table)
		require.NoError(err)

		// remove all non-ref columns
		for i := range rows {
			rows[i] = rows[i][len(rows[i])-3:]
		}

		expected := []sql.Row{
			expected[0], expected[1],
			expected[0], expected[1],
			expected[0], expected[1],
		}

		require.ElementsMatch(expected, rows)
	})
}

func newSquashTable(iter ChainableIter) sql.Table {
	return NewSquashedTable(iter, nil, nil, nil)
}