// Copyright 2025 The Forgejo Authors. All rights reserved.
// SPDX-License-Identifier: GPL-3.0-or-later

package lfs

import (
	"cmp"
	"path/filepath"
	"slices"
	"testing"

	"forgejo.org/modules/git"

	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
)

func TestSearchPointerBlobs(t *testing.T) {
	repo, err := git.OpenRepository(t.Context(), filepath.Join(testReposDir, "simple-lfs"))
	require.NoError(t, err)

	pointerChan := make(chan PointerBlob)
	errChan := make(chan error, 1)

	go SearchPointerBlobs(t.Context(), repo, pointerChan, errChan)

	// Collect all found pointer blobs.
	var pointerBlobs []PointerBlob
	for pointerBlob := range pointerChan {
		pointerBlobs = append(pointerBlobs, pointerBlob)
	}

	// Check that no errors were reported.
	errChanClosed := false
	select {
	case err, ok := <-errChan:
		if ok {
			require.NoError(t, err)
		} else {
			errChanClosed = true
		}
	default:
	}
	assert.True(t, errChanClosed)

	// Sort them, they might arrive in any order
	slices.SortFunc(pointerBlobs, func(a, b PointerBlob) int {
		return cmp.Compare(a.Oid, b.Oid)
	})

	// Assert the values of the found pointer blobs.
	if assert.Len(t, pointerBlobs, 3) {
		assert.Equal(t, "31b9a6a709729b8ae48bde8176caf2990c0d7121", pointerBlobs[0].Hash)
		assert.Equal(t, "2f91b6326743db344ca96b1be86e3ed34abf04262255b4d04db8a961a2a72545", pointerBlobs[0].Oid)
		assert.EqualValues(t, 43789, pointerBlobs[0].Size)

		assert.Equal(t, "b53619fbbc3d2bfa85a26787238264cdbf551f19", pointerBlobs[1].Hash)
		assert.Equal(t, "36dae031efb96625cda973c11508617b750665933a36bd52dfcfef586c4fd85c", pointerBlobs[1].Oid)
		assert.EqualValues(t, 101800, pointerBlobs[1].Size)

		assert.Equal(t, "513d4c000f63ee9fd6a805e9a518206b860ce38a", pointerBlobs[2].Hash)
		assert.Equal(t, "4d7a214614ab2935c943f9e0ff69d22eadbb8f32b1258daaa5e2ca24d17e2393", pointerBlobs[2].Oid)
		assert.EqualValues(t, 1234, pointerBlobs[2].Size)
	}
}