From 9c19be5324d68e3e611b4f53db4ae060f4685c43 Mon Sep 17 00:00:00 2001 From: tom twinkle Date: Wed, 22 Nov 2023 09:39:31 +0900 Subject: [PATCH] remove global dialer test --- aws/awss3/options/global/global_test.go | 63 ------------------------- 1 file changed, 63 deletions(-) delete mode 100644 aws/awss3/options/global/global_test.go diff --git a/aws/awss3/options/global/global_test.go b/aws/awss3/options/global/global_test.go deleted file mode 100644 index c6387aa..0000000 --- a/aws/awss3/options/global/global_test.go +++ /dev/null @@ -1,63 +0,0 @@ -package global_test - -import ( - "bytes" - "context" - "fmt" - "testing" - "time" - - "github.com/88labs/go-utils/ulid" - "github.com/aws/aws-sdk-go-v2/aws" - "github.com/aws/aws-sdk-go-v2/feature/s3/manager" - "github.com/aws/aws-sdk-go-v2/service/s3" - "github.com/stretchr/testify/assert" - - "github.com/88labs/go-utils/aws/awsconfig" - "github.com/88labs/go-utils/aws/awss3" - "github.com/88labs/go-utils/aws/awss3/options/global/s3dialer" - "github.com/88labs/go-utils/aws/ctxawslocal" -) - -const ( - TestBucket = "test" - TestRegion = awsconfig.RegionTokyo -) - -func TestGlobalOptionWithHeadObject(t *testing.T) { - ctx := ctxawslocal.WithContext( - context.Background(), - ctxawslocal.WithS3Endpoint("http://127.0.0.1:29000"), // use Minio - ctxawslocal.WithAccessKey("DUMMYACCESSKEYEXAMPLE"), - ctxawslocal.WithSecretAccessKey("DUMMYSECRETKEYEXAMPLE"), - ) - s3Client, err := awss3.GetClient(ctx, TestRegion) - assert.NoError(t, err) - - createFixture := func(fileSize int) awss3.Key { - key := fmt.Sprintf("awstest/%s.txt", ulid.MustNew()) - uploader := manager.NewUploader(s3Client) - input := s3.PutObjectInput{ - Body: bytes.NewReader(bytes.Repeat([]byte{1}, fileSize)), - Bucket: aws.String(TestBucket), - Key: aws.String(key), - Expires: aws.Time(time.Now().Add(10 * time.Minute)), - } - if _, err := uploader.Upload(ctx, &input); err != nil { - assert.NoError(t, err) - } - return awss3.Key(key) - } - - t.Run("If the option is specified", func(t *testing.T) { - key := createFixture(100) - dialer := s3dialer.NewConfGlobalDialer() - dialer.WithTimeout(time.Second) - dialer.WithKeepAlive(2 * time.Second) - dialer.WithDeadline(time.Now().Add(time.Second)) - awss3.GlobalDialer = dialer - res, err := awss3.HeadObject(ctx, TestRegion, TestBucket, key) - assert.NoError(t, err) - assert.Equal(t, aws.Int64(100), res.ContentLength) - }) -}