// Copyright 2020-2026 Buf Technologies, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package buffetch

import (
	"io"
	"log/slog"
	"path/filepath"
	"testing"

	"buf.build/go/app"
	"github.com/bufbuild/buf/private/buf/buffetch/internal"
	"github.com/bufbuild/buf/private/pkg/slogtestext"
	"github.com/bufbuild/buf/private/pkg/storage/storageos"
	"github.com/stretchr/testify/require"
)

func TestRoundTripBin(t *testing.T) {
	t.Parallel()
	testRoundTripLocalFile(
		t,
		"file.bin",
		[]byte("one"),
		formatBinpb,
		internal.CompressionTypeNone,
	)
}

func TestRoundTripBinGz(t *testing.T) {
	t.Parallel()
	testRoundTripLocalFile(
		t,
		"file.bin.gz",
		[]byte("one"),
		formatBinpb,
		internal.CompressionTypeGzip,
	)
}

func TestRoundTripBinZst(t *testing.T) {
	t.Parallel()
	testRoundTripLocalFile(
		t,
		"file.bin.zst",
		[]byte("one"),
		formatBinpb,
		internal.CompressionTypeZstd,
	)
}

func TestRoundTripBinpb(t *testing.T) {
	t.Parallel()
	testRoundTripLocalFile(
		t,
		"file.binpb",
		[]byte("one"),
		formatBinpb,
		internal.CompressionTypeNone,
	)
}

func TestRoundTripBinpbGz(t *testing.T) {
	t.Parallel()
	testRoundTripLocalFile(
		t,
		"file.binpb.gz",
		[]byte("one"),
		formatBinpb,
		internal.CompressionTypeGzip,
	)
}

func TestRoundTripBinpbZst(t *testing.T) {
	t.Parallel()
	testRoundTripLocalFile(
		t,
		"file.binpb.zst",
		[]byte("one"),
		formatBinpb,
		internal.CompressionTypeZstd,
	)
}

func testRoundTripLocalFile(
	t *testing.T,
	filename string,
	expectedData []byte,
	expectedFormat string,
	expectedCompressionType internal.CompressionType,
) {
	logger := slogtestext.NewLogger(t)
	refParser := newRefParser(logger)
	reader := testNewFetchReader(logger)
	writer := testNewFetchWriter(logger)

	ctx := t.Context()
	container := app.NewContainer(nil, nil, nil, nil)

	tmpDir := t.TempDir()
	filePath := filepath.Join(tmpDir, filename)

	parsedRef, err := refParser.getParsedRef(ctx, filePath, allFormats)
	require.NoError(t, err)
	require.Equal(t, expectedFormat, parsedRef.Format())
	fileRef, ok := parsedRef.(internal.FileRef)
	require.True(t, ok)
	require.Equal(t, expectedCompressionType, fileRef.CompressionType())

	writeCloser, err := writer.PutFile(ctx, container, fileRef)
	require.NoError(t, err)
	_, err = writeCloser.Write(expectedData)
	require.NoError(t, err)
	require.NoError(t, writeCloser.Close())

	readCloser, err := reader.GetFile(ctx, container, fileRef)
	require.NoError(t, err)
	actualData, err := io.ReadAll(readCloser)
	require.NoError(t, err)
	require.NoError(t, readCloser.Close())

	require.Equal(t, string(expectedData), string(actualData))
}

func testNewFetchReader(logger *slog.Logger) internal.Reader {
	storageosProvider := storageos.NewProvider(storageos.ProviderWithSymlinks())
	return internal.NewReader(
		logger,
		storageosProvider,
		internal.WithReaderLocal(),
	)
}

func testNewFetchWriter(logger *slog.Logger) internal.Writer {
	return internal.NewWriter(
		logger,
		internal.WithWriterLocal(),
	)
}