TrueCloudLab/distribution
13
0
Fork 3
Code Issues 3 Pull requests Projects Releases 2 Packages Wiki Activity Actions

Unify permissions settings

Browse source
This commit is contained in:
Andrey Kostov 2014-10-26 10:00:53 -07:00
parent 1342873367
commit e3a5955cd2
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
storagedriver/s3/s3.go
View file

@ -28,7 +28,7 @@ func NewDriver(accessKey string, secretKey string, region aws.Region, encrypt bo
s3obj := s3.New(auth, region) s3obj := s3.New(auth, region)
bucket := s3obj.Bucket(bucketName) bucket := s3obj.Bucket(bucketName)
if err := bucket.PutBucket(s3.PublicRead); err != nil { if err := bucket.PutBucket(getPermissions()); err != nil {
s3Err, ok := err.(*s3.Error) s3Err, ok := err.(*s3.Error)
if !(ok && s3Err.Code == "BucketAlreadyOwnedByYou") { if !(ok && s3Err.Code == "BucketAlreadyOwnedByYou") {
return nil, err return nil, err
@ -43,7 +43,7 @@ func (d *S3Driver) GetContent(path string) ([]byte, error) {
} }
func (d *S3Driver) PutContent(path string, contents []byte) error { func (d *S3Driver) PutContent(path string, contents []byte) error {
return d.Bucket.Put(path, contents, d.getContentType(), d.getPermissions(), d.getOptions()) return d.Bucket.Put(path, contents, d.getContentType(), getPermissions(), d.getOptions())
} }
func (d *S3Driver) ReadStream(path string, offset uint64) (io.ReadCloser, error) { func (d *S3Driver) ReadStream(path string, offset uint64) (io.ReadCloser, error) {
@ -172,7 +172,7 @@ func (d *S3Driver) List(prefix string) ([]string, error) {
func (d *S3Driver) Move(sourcePath string, destPath string) error { func (d *S3Driver) Move(sourcePath string, destPath string) error {
/* This is terrible, but aws doesn't have an actual move. */ /* This is terrible, but aws doesn't have an actual move. */
_, err := d.Bucket.PutCopy(destPath, d.getPermissions(), s3.CopyOptions{d.getOptions(), "", d.getContentType()}, d.Bucket.Name+"/"+sourcePath) _, err := d.Bucket.PutCopy(destPath, getPermissions(), s3.CopyOptions{d.getOptions(), "", d.getContentType()}, d.Bucket.Name+"/"+sourcePath)
if err != nil { if err != nil {
return err return err
} }
@ -224,7 +224,7 @@ func (d *S3Driver) getHighestIdMulti(path string) (multi *s3.Multi, err error) {
} }
return multi, nil return multi, nil
} else { } else {
multi, err := d.Bucket.InitMulti(path, d.getContentType(), d.getPermissions(), d.getOptions()) multi, err := d.Bucket.InitMulti(path, d.getContentType(), getPermissions(), d.getOptions())
return multi, err return multi, err
} }
} }
@ -248,7 +248,7 @@ func (d *S3Driver) getOptions() s3.Options {
return s3.Options{SSE: d.Encrypt} return s3.Options{SSE: d.Encrypt}
} }
func (d *S3Driver) getPermissions() s3.ACL { func getPermissions() s3.ACL {
return s3.Private return s3.Private
} }