mirrors/object-browser
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mcs make bucket api remove setting access policy (#29)

Browse Source
This commit is contained in:
César Nieto
2020-04-06 09:59:19 -07:00
committed by GitHub
parent a749c4e3fd
commit e33615a9f6
7 changed files with 33 additions and 95 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
restapi/client-admin.go
View File

@@ -18,12 +18,13 @@ package restapi
import (
"context"
mcCmd "github.com/minio/mc/cmd"
"github.com/minio/mc/pkg/probe"
"github.com/minio/minio/pkg/madmin"
"io"
"path/filepath"
"runtime"
mcCmd "github.com/minio/mc/cmd"
"github.com/minio/mc/pkg/probe"
"github.com/minio/minio/pkg/madmin"
)
const globalAppName = "mcs"

1
restapi/client.go
View File

@@ -31,7 +31,6 @@ func init() {
minio.MaxRetry = 1
}
// Define MinioClient interface with all functions to be implemented
// by mock when testing, it should include all MinioClient respective api calls
// that are used within this project.

6
restapi/embedded_spec.go
View File

@@ -1317,9 +1317,6 @@ func init() {
"name"
],
"properties": {
"access": {
"$ref": "#/definitions/bucketAccess"
},
"name": {
"type": "string"
}
@@ -2855,9 +2852,6 @@ func init() {
"name"
],
"properties": {
"access": {
"$ref": "#/definitions/bucketAccess"
},
"name": {
"type": "string"
}

53
restapi/user_buckets.go
View File

@@ -124,13 +124,35 @@ func getListBucketsResponse() (*models.ListBucketsResponse, error) {
}
// makeBucket creates a bucket for an specific minio client
func makeBucket(ctx context.Context, client MinioClient, bucketName string, access models.BucketAccess) error {
func makeBucket(ctx context.Context, client MinioClient, bucketName string) error {
// creates a new bucket with bucketName with a context to control cancellations and timeouts.
if err := client.makeBucketWithContext(ctx, bucketName, "us-east-1"); err != nil {
return err
}
if err := setBucketAccessPolicy(ctx, client, bucketName, access); err != nil {
return fmt.Errorf("bucket created but error occurred while setting policy: %s", err.Error())
return nil
}
// getMakeBucketResponse performs makeBucket() to create a bucket with its access policy
func getMakeBucketResponse(br *models.MakeBucketRequest) error {
ctx, cancel := context.WithTimeout(context.Background(), time.Second*20)
defer cancel()
// bucket request needed to proceed
if br == nil {
log.Println("error bucket body not in request")
return errors.New(500, "error bucket body not in request")
}
mClient, err := newMinioClient()
if err != nil {
log.Println("error creating MinIO Client:", err)
return err
}
// create a minioClient interface implementation
// defining the client to be used
minioClient := minioClient{client: mClient}
if err := makeBucket(ctx, minioClient, *br.Name); err != nil {
log.Println("error making bucket:", err)
return err
}
return nil
}
@@ -163,31 +185,6 @@ func setBucketAccessPolicy(ctx context.Context, client MinioClient, bucketName s
return client.setBucketPolicyWithContext(ctx, bucketName, string(policyJSON))
}
// getMakeBucketResponse performs makeBucket() to create a bucket with its access policy
func getMakeBucketResponse(br *models.MakeBucketRequest) error {
ctx, cancel := context.WithTimeout(context.Background(), time.Second*20)
defer cancel()
// bucket request needed to proceed
if br == nil {
log.Println("error bucket body not in request")
return errors.New(500, "error bucket body not in request")
}
mClient, err := newMinioClient()
if err != nil {
log.Println("error creating MinIO Client:", err)
return err
}
// create a minioClient interface implementation
// defining the client to be used
minioClient := minioClient{client: mClient}
if err := makeBucket(ctx, minioClient, *br.Name, br.Access); err != nil {
log.Println("error making bucket:", err)
return err
}
return nil
}
// getBucketSetPolicyResponse calls setBucketAccessPolicy() to set a access policy to a bucket
// and returns the serialized output.
func getBucketSetPolicyResponse(bucketName string, req *models.SetBucketPolicyRequest) (*models.Bucket, error) {

36
restapi/user_buckets_test.go
View File

@@ -112,50 +112,22 @@ func TestMakeBucket(t *testing.T) {
minClient := minioClientMock{}
function := "makeBucket()"
ctx := context.Background()
// Test-1: makeBucket() create a bucket with public access
// Test-1: makeBucket() create a bucket
// mock function response from makeBucketWithContext(ctx)
minioMakeBucketWithContextMock = func(ctx context.Context, bucketName, location string) error {
return nil
}
// mock function response from setBucketPolicyWithContext(ctx)
minioSetBucketPolicyWithContextMock = func(ctx context.Context, bucketName, policy string) error {
return nil
}
if err := makeBucket(ctx, minClient, "bucktest1", models.BucketAccessPUBLIC); err != nil {
if err := makeBucket(ctx, minClient, "bucktest1"); err != nil {
t.Errorf("Failed on %s:, error occurred: %s", function, err.Error())
}
// Test-2: makeBucket() create a bucket with private access
if err := makeBucket(ctx, minClient, "bucktest1", models.BucketAccessPRIVATE); err != nil {
t.Errorf("Failed on %s:, error occurred: %s", function, err.Error())
}
// Test-3: makeBucket() create a bucket with an invalid access, expected error
if err := makeBucket(ctx, minClient, "bucktest1", "other"); assert.Error(err) {
assert.Equal("bucket created but error occurred while setting policy: access: `other` not supported", err.Error())
}
// Test-4 makeBucket() make sure errors are handled correctly when error on MakeBucketWithContext
// Test-2 makeBucket() make sure errors are handled correctly when error on MakeBucketWithContext
minioMakeBucketWithContextMock = func(ctx context.Context, bucketName, location string) error {
return errors.New("error")
}
minioSetBucketPolicyWithContextMock = func(ctx context.Context, bucketName, policy string) error {
return nil
}
if err := makeBucket(ctx, minClient, "bucktest1", models.BucketAccessPUBLIC); assert.Error(err) {
if err := makeBucket(ctx, minClient, "bucktest1"); assert.Error(err) {
assert.Equal("error", err.Error())
}
// Test-5 makeBucket() make sure errors are handled correctly when error on SetBucketPolicyWithContext
minioMakeBucketWithContextMock = func(ctx context.Context, bucketName, location string) error {
return nil
}
minioSetBucketPolicyWithContextMock = func(ctx context.Context, bucketName, policy string) error {
return errors.New("error")
}
if err := makeBucket(ctx, minClient, "bucktest1", models.BucketAccessPUBLIC); assert.Error(err) {
assert.Equal("bucket created but error occurred while setting policy: error", err.Error())
}
}
func TestDeleteBucket(t *testing.T) {