exists_test.go

package s3

import (
	"context"
	"fmt"
	"testing"

	"github.com/stretchr/testify/assert"
	"github.com/viant/afs/asset"
	"github.com/viant/afs/storage"
)

func TestStorager_Exists(t *testing.T) {

	authConfig, err := NewTestAuthConfig()
	if err != nil {
		t.Skip(err)
		return

	}
	ctx := context.Background()
	var useCases = []struct {
		description string
		assets      []*asset.Resource
		URL         string
		exists      bool
		hasError    bool
	}{
		{
			description: "exists test",
			URL:         fmt.Sprintf("s3://%v/exists001/asset1.txt", TestBucket),
			exists:      true,
			assets: []*asset.Resource{
				asset.NewFile("exists001/asset1.txt", []byte("test is test 1 "), 0655),
			},
		},
		{
			description: "exists test",
			URL:         fmt.Sprintf("s3://%v/exists002/asset1.txt", TestBucket),
			exists:      false,
			assets:      []*asset.Resource{},
		},
		{
			description: "does exists test",
			URL:         fmt.Sprintf("s3://%v/exists002/asset1.txt", TestBucket+"123"),
			exists:      false,
			hasError:    false,
			assets:      []*asset.Resource{},
		},
		{
			description: "invalid bucket name test",
			URL:         fmt.Sprintf("s3://%v/exists002/asset1.txt", TestBucket+"!@ 3232"),
			exists:      false,
			hasError:    true,
			assets:      []*asset.Resource{},
		},
	}

	mgr := New(authConfig)
	defer mgr.Delete(ctx, fmt.Sprintf("s3://%v/", TestBucket))

	for _, useCase := range useCases {
		err = asset.Create(mgr, useCase.URL, useCase.assets)

		if !assert.Nil(t, err, useCase.description) {
			continue
		}
		checker := mgr.(storage.Checker)
		actual, err := checker.Exists(ctx, useCase.URL)
		if useCase.hasError {
			assert.NotNil(t, err, useCase.description)
			continue
		}

		assert.Nil(t, err, useCase.description)
		assert.Equal(t, useCase.exists, actual, useCase.description)
	}

}