evalphobia/aws-sdk-go-v2-wrapper

package s3

import (
    "context"
    "testing"

    SDK "github.com/aws/aws-sdk-go-v2/service/s3"
    "github.com/matryer/is"

    "github.com/evalphobia/aws-sdk-go-v2-wrapper/config"
    "github.com/evalphobia/aws-sdk-go-v2-wrapper/log"
)

const (
    defaultEndpoint = "http://localhost:4567"

    testPutBucketName = "test-put-bucket"
)

func TestNew(t *testing.T) {
    is := is.NewRelaxed(t)

    // custom endpoint
    svc, err := New(getTestConfig())
    is.NoErr(err)
    is.True(svc.client != nil)
    is.Equal(SDK.ServiceName, svc.client.Metadata.ServiceName)
    is.Equal(SDK.ServiceID, svc.client.Metadata.ServiceID)
    is.Equal(SDK.EndpointsID, svc.client.Metadata.EndpointsID)

    ep, err := svc.client.EndpointResolver.ResolveEndpoint("", "")
    is.NoErr(err)
    is.Equal(defaultEndpoint, ep.URL)

    // plain region
    svc, err = New(config.Config{})
    is.NoErr(err)
    is.True(svc.client != nil)

    region := "us-west-1"
    expectedEndpoint := "https://s3." + region + ".amazonaws.com"
    ep, err = svc.client.EndpointResolver.ResolveEndpoint(SDK.EndpointsID, region)
    is.NoErr(err)
    is.Equal(expectedEndpoint, ep.URL)

    _, err = svc.client.EndpointResolver.ResolveEndpoint("", "")
    is.True(err != nil)
}

func TestSetLogger(t *testing.T) {
    is := is.NewRelaxed(t)
    svc := getTestClient(t)
    is.Equal(log.DefaultLogger, svc.logger)

    stdLogger := &log.StdLogger{}
    svc.SetLogger(stdLogger)
    is.Equal(stdLogger, svc.logger)
}

func getTestConfig() config.Config {
    return config.Config{
        // creds for minio
        AccessKey:        "dummy",
        SecretKey:        "dummydummy",
        CommonEndpoint:   defaultEndpoint,
        S3ForcePathStyle: true,
    }
}

func getTestClient(t *testing.T) *S3 {
    svc, err := New(getTestConfig())
    if err != nil {
        t.Errorf("error on create client; error=%s;", err.Error())
        t.FailNow()
    }
    return svc
}

func createTestBucket(name string) error {
    svc, err := New(getTestConfig())
    if err != nil {
        return err
    }

    ctx := context.Background()
    ok, err := svc.XExistBucket(ctx, name)
    switch {
    case err != nil:
        return err
    case ok:
        return nil
    }

    _, err = svc.XCreateBucketFromName(ctx, name)
    return err
}