s3/client_op_object_put.go - Code Metrics - evalphobia/aws-sdk-go-v2-wrapper - Measure and Improve Code Quality continuously with Scrutinizer

s3/client_op_object_put.go A
last analyzed 2021-09-01 07:21 UTC

↳ Parent: Project

Size/Duplication

Total Lines	221
Duplicated Lines	0 %

Importance

Changes

Metric	Value
cc	41
eloc	152
dl	0
loc	221
rs	9.1199
c	0
b	0
f	0

3 Methods

Rating	Name	Size	Complexity
C	s3.NewPutObjectResult	34	11
F	s3.PutObjectRequest.ToInput	103	28
A	s3.*S3.PutObject	11	2

package s3

import (
	"bytes"
	"context"
	"io"
	"strings"
	"time"

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

	"github.com/evalphobia/aws-sdk-go-v2-wrapper/errors"
	"github.com/evalphobia/aws-sdk-go-v2-wrapper/private/pointers"
)

// PutObject executes `PutObject` operation.
func (svc *S3) PutObject(ctx context.Context, r PutObjectRequest) (*PutObjectResult, error) {
	out, err := svc.RawPutObject(ctx, r.ToInput())
	if err != nil {
		err = svc.errWrap(errors.ErrorData{
			Err:          err,
			AWSOperation: "PutObject",
		})
		svc.Errorf(err.Error())

		return nil, err
	}
	return NewPutObjectResult(out), nil
}

// PutObjectRequest has parameters for `PutObject` operation.
type PutObjectRequest struct {
	Bucket string
	Key    string

	// optional
	ACL                       ObjectCannedACL
	Body                      io.ReadSeeker
	BodyBytes                 []byte
	CacheControl              string
	ContentDisposition        string
	ContentEncoding           string
	ContentLanguage           string
	ContentLength             int64
	ContentMD5                string
	ContentType               string
	Expires                   time.Time
	GrantFullControl          string
	GrantRead                 string
	GrantReadACP              string
	GrantWriteACP             string
	Metadata                  map[string]string
	ObjectLockLegalHoldStatus ObjectLockLegalHoldStatus
	ObjectLockMode            ObjectLockMode
	ObjectLockRetainUntilDate time.Time
	RequestPayer              RequestPayer
	SSECustomerAlgorithm      string
	SSECustomerKey            string
	SSECustomerKeyMD5         string
	SSEKMSEncryptionContext   string
	SSEKMSKeyID               string
	ServerSideEncryption      ServerSideEncryption
	StorageClass              StorageClass
	Tagging                   string
	WebsiteRedirectLocation   string

	// TaggingTagSet is used for tagging. this won't override `Tagging` and can be used together.
	TaggingTagSet []Tag
}

func (r PutObjectRequest) ToInput() *SDK.PutObjectInput {

	in := &SDK.PutObjectInput{}
	if r.Bucket != "" {
		in.Bucket = pointers.String(r.Bucket)
	}
	if r.Key != "" {
		in.Key = pointers.String(r.Key)
	}

	in.ACL = SDK.ObjectCannedACL(r.ACL)

	switch {
	case r.Body != nil:
		in.Body = r.Body
	case len(r.BodyBytes) != 0:
		in.Body = bytes.NewReader(r.BodyBytes)
	}

	if r.CacheControl != "" {
		in.CacheControl = pointers.String(r.CacheControl)
	}
	if r.ContentDisposition != "" {
		in.ContentDisposition = pointers.String(r.ContentDisposition)
	}
	if r.ContentEncoding != "" {
		in.ContentEncoding = pointers.String(r.ContentEncoding)
	}
	if r.ContentLanguage != "" {
		in.ContentLanguage = pointers.String(r.ContentLanguage)
	}
	if r.ContentLength != 0 {
		in.ContentLength = pointers.Long64(r.ContentLength)
	}
	if r.ContentMD5 != "" {
		in.ContentMD5 = pointers.String(r.ContentMD5)
	}
	if r.ContentType != "" {
		in.ContentType = pointers.String(r.ContentType)
	}
	if !r.Expires.IsZero() {
		in.Expires = &r.Expires
	}
	if r.GrantFullControl != "" {
		in.GrantFullControl = pointers.String(r.GrantFullControl)
	}
	if r.GrantRead != "" {
		in.GrantRead = pointers.String(r.GrantRead)
	}
	if r.GrantReadACP != "" {
		in.GrantReadACP = pointers.String(r.GrantReadACP)
	}
	if r.GrantWriteACP != "" {
		in.GrantWriteACP = pointers.String(r.GrantWriteACP)
	}

	in.Metadata = r.Metadata
	in.ObjectLockLegalHoldStatus = SDK.ObjectLockLegalHoldStatus(r.ObjectLockLegalHoldStatus)
	in.ObjectLockMode = SDK.ObjectLockMode(r.ObjectLockMode)

	if !r.ObjectLockRetainUntilDate.IsZero() {
		in.ObjectLockRetainUntilDate = &r.ObjectLockRetainUntilDate
	}

	in.RequestPayer = SDK.RequestPayer(r.RequestPayer)

	if r.SSECustomerAlgorithm != "" {
		in.SSECustomerAlgorithm = pointers.String(r.SSECustomerAlgorithm)
	}
	if r.SSECustomerKey != "" {
		in.SSECustomerKey = pointers.String(r.SSECustomerKey)
	}
	if r.SSECustomerKeyMD5 != "" {
		in.SSECustomerKeyMD5 = pointers.String(r.SSECustomerKeyMD5)
	}
	if r.SSEKMSEncryptionContext != "" {
		in.SSEKMSEncryptionContext = pointers.String(r.SSEKMSEncryptionContext)
	}
	if r.SSEKMSKeyID != "" {
		in.SSEKMSKeyId = pointers.String(r.SSEKMSKeyID)
	}

	in.ServerSideEncryption = SDK.ServerSideEncryption(r.ServerSideEncryption)
	in.StorageClass = SDK.StorageClass(r.StorageClass)

	tags := r.Tagging
	if len(r.TaggingTagSet) != 0 {
		tt := make([]string, 0, len(r.TaggingTagSet))
		if tags != "" {
			tt = append(tt, tags)
		}
		for _, v := range r.TaggingTagSet {
			tt = append(tt, v.Key+"="+v.Value)
		}
		tags = strings.Join(tt, "&")
	}
	if tags != "" {
		in.Tagging = pointers.String(tags)
	}

	if r.WebsiteRedirectLocation != "" {
		in.WebsiteRedirectLocation = pointers.String(r.WebsiteRedirectLocation)
	}
	return in
}

// PutObjectResult contains results from `PutObject` operation.
type PutObjectResult struct {
	ETag                    string
	Expiration              string
	RequestCharged          RequestCharged
	SSECustomerAlgorithm    string
	SSECustomerKeyMD5       string
	SSEKMSEncryptionContext string
	SSEKMSKeyID             string
	ServerSideEncryption    ServerSideEncryption
	VersionID               string
}

func NewPutObjectResult(output *SDK.PutObjectResponse) *PutObjectResult {

	r := &PutObjectResult{}
	if output == nil {
		return r
	}

	if output.ETag != nil {
		r.ETag = *output.ETag
	}
	if output.Expiration != nil {
		r.Expiration = *output.Expiration
	}
	if output.RequestCharged != "" {
		r.RequestCharged = RequestCharged(output.RequestCharged)
	}
	if output.SSECustomerAlgorithm != nil {
		r.SSECustomerAlgorithm = *output.SSECustomerAlgorithm
	}
	if output.SSECustomerKeyMD5 != nil {
		r.SSECustomerKeyMD5 = *output.SSECustomerKeyMD5
	}
	if output.SSEKMSEncryptionContext != nil {
		r.SSEKMSEncryptionContext = *output.SSEKMSEncryptionContext
	}
	if output.SSEKMSKeyId != nil {
		r.SSEKMSKeyID = *output.SSEKMSKeyId
	}
	if output.ServerSideEncryption != "" {
		r.ServerSideEncryption = ServerSideEncryption(output.ServerSideEncryption)
	}
	if output.VersionId != nil {
		r.VersionID = *output.VersionId
	}
	return r
}


1			package s3
2
3			import (
4			"bytes"
5			"context"
6			"io"
7			"strings"
8			"time"
9
10			SDK "github.com/aws/aws-sdk-go-v2/service/s3"
11
12			"github.com/evalphobia/aws-sdk-go-v2-wrapper/errors"
13			"github.com/evalphobia/aws-sdk-go-v2-wrapper/private/pointers"
14			)
15
16			// PutObject executes `PutObject` operation.
17			func (svc S3) PutObject(ctx context.Context, r PutObjectRequest) (PutObjectResult, error) {
18			out, err := svc.RawPutObject(ctx, r.ToInput())
19			if err != nil {
20			err = svc.errWrap(errors.ErrorData{
21			Err: err,
22			AWSOperation: "PutObject",
23			})
24			svc.Errorf(err.Error())
			0 ignored issues – show introduced 2020-08-27 03:45 UTC by Report Bug Copy Issue Report can't check non-constant format in call to Errorf Loading history...
25			return nil, err
26			}
27			return NewPutObjectResult(out), nil
28			}
29
30			// PutObjectRequest has parameters for `PutObject` operation.
31			type PutObjectRequest struct {
32			Bucket string
33			Key string
34
35			// optional
36			ACL ObjectCannedACL
37			Body io.ReadSeeker
38			BodyBytes []byte
39			CacheControl string
40			ContentDisposition string
41			ContentEncoding string
42			ContentLanguage string
43			ContentLength int64
44			ContentMD5 string
45			ContentType string
46			Expires time.Time
47			GrantFullControl string
48			GrantRead string
49			GrantReadACP string
50			GrantWriteACP string
51			Metadata map[string]string
52			ObjectLockLegalHoldStatus ObjectLockLegalHoldStatus
53			ObjectLockMode ObjectLockMode
54			ObjectLockRetainUntilDate time.Time
55			RequestPayer RequestPayer
56			SSECustomerAlgorithm string
57			SSECustomerKey string
58			SSECustomerKeyMD5 string
59			SSEKMSEncryptionContext string
60			SSEKMSKeyID string
61			ServerSideEncryption ServerSideEncryption
62			StorageClass StorageClass
63			Tagging string
64			WebsiteRedirectLocation string
65
66			// TaggingTagSet is used for tagging. this won't override `Tagging` and can be used together.
67			TaggingTagSet []Tag
68			}
69
70			func (r PutObjectRequest) ToInput() *SDK.PutObjectInput {
			0 ignored issues – show introduced 2020-08-27 03:45 UTC by Report Bug Copy Issue Report exported method PutObjectRequest.ToInput should have comment or be unexported Loading history...
71			in := &SDK.PutObjectInput{}
72			if r.Bucket != "" {
73			in.Bucket = pointers.String(r.Bucket)
74			}
75			if r.Key != "" {
76			in.Key = pointers.String(r.Key)
77			}
78
79			in.ACL = SDK.ObjectCannedACL(r.ACL)
80
81			switch {
82			case r.Body != nil:
83			in.Body = r.Body
84			case len(r.BodyBytes) != 0:
85			in.Body = bytes.NewReader(r.BodyBytes)
86			}
87
88			if r.CacheControl != "" {
89			in.CacheControl = pointers.String(r.CacheControl)
90			}
91			if r.ContentDisposition != "" {
92			in.ContentDisposition = pointers.String(r.ContentDisposition)
93			}
94			if r.ContentEncoding != "" {
95			in.ContentEncoding = pointers.String(r.ContentEncoding)
96			}
97			if r.ContentLanguage != "" {
98			in.ContentLanguage = pointers.String(r.ContentLanguage)
99			}
100			if r.ContentLength != 0 {
101			in.ContentLength = pointers.Long64(r.ContentLength)
102			}
103			if r.ContentMD5 != "" {
104			in.ContentMD5 = pointers.String(r.ContentMD5)
105			}
106			if r.ContentType != "" {
107			in.ContentType = pointers.String(r.ContentType)
108			}
109			if !r.Expires.IsZero() {
110			in.Expires = &r.Expires
111			}
112			if r.GrantFullControl != "" {
113			in.GrantFullControl = pointers.String(r.GrantFullControl)
114			}
115			if r.GrantRead != "" {
116			in.GrantRead = pointers.String(r.GrantRead)
117			}
118			if r.GrantReadACP != "" {
119			in.GrantReadACP = pointers.String(r.GrantReadACP)
120			}
121			if r.GrantWriteACP != "" {
122			in.GrantWriteACP = pointers.String(r.GrantWriteACP)
123			}
124
125			in.Metadata = r.Metadata
126			in.ObjectLockLegalHoldStatus = SDK.ObjectLockLegalHoldStatus(r.ObjectLockLegalHoldStatus)
127			in.ObjectLockMode = SDK.ObjectLockMode(r.ObjectLockMode)
128
129			if !r.ObjectLockRetainUntilDate.IsZero() {
130			in.ObjectLockRetainUntilDate = &r.ObjectLockRetainUntilDate
131			}
132
133			in.RequestPayer = SDK.RequestPayer(r.RequestPayer)
134
135			if r.SSECustomerAlgorithm != "" {
136			in.SSECustomerAlgorithm = pointers.String(r.SSECustomerAlgorithm)
137			}
138			if r.SSECustomerKey != "" {
139			in.SSECustomerKey = pointers.String(r.SSECustomerKey)
140			}
141			if r.SSECustomerKeyMD5 != "" {
142			in.SSECustomerKeyMD5 = pointers.String(r.SSECustomerKeyMD5)
143			}
144			if r.SSEKMSEncryptionContext != "" {
145			in.SSEKMSEncryptionContext = pointers.String(r.SSEKMSEncryptionContext)
146			}
147			if r.SSEKMSKeyID != "" {
148			in.SSEKMSKeyId = pointers.String(r.SSEKMSKeyID)
149			}
150
151			in.ServerSideEncryption = SDK.ServerSideEncryption(r.ServerSideEncryption)
152			in.StorageClass = SDK.StorageClass(r.StorageClass)
153
154			tags := r.Tagging
155			if len(r.TaggingTagSet) != 0 {
156			tt := make([]string, 0, len(r.TaggingTagSet))
157			if tags != "" {
158			tt = append(tt, tags)
159			}
160			for _, v := range r.TaggingTagSet {
161			tt = append(tt, v.Key+"="+v.Value)
162			}
163			tags = strings.Join(tt, "&")
164			}
165			if tags != "" {
166			in.Tagging = pointers.String(tags)
167			}
168
169			if r.WebsiteRedirectLocation != "" {
170			in.WebsiteRedirectLocation = pointers.String(r.WebsiteRedirectLocation)
171			}
172			return in
173			}
174
175			// PutObjectResult contains results from `PutObject` operation.
176			type PutObjectResult struct {
177			ETag string
178			Expiration string
179			RequestCharged RequestCharged
180			SSECustomerAlgorithm string
181			SSECustomerKeyMD5 string
182			SSEKMSEncryptionContext string
183			SSEKMSKeyID string
184			ServerSideEncryption ServerSideEncryption
185			VersionID string
186			}
187
188			func NewPutObjectResult(output SDK.PutObjectResponse) PutObjectResult {
			0 ignored issues – show introduced 2020-08-27 03:45 UTC by Report Bug Copy Issue Report exported function NewPutObjectResult should have comment or be unexported Loading history...
189			r := &PutObjectResult{}
190			if output == nil {
191			return r
192			}
193
194			if output.ETag != nil {
195			r.ETag = *output.ETag
196			}
197			if output.Expiration != nil {
198			r.Expiration = *output.Expiration
199			}
200			if output.RequestCharged != "" {
201			r.RequestCharged = RequestCharged(output.RequestCharged)
202			}
203			if output.SSECustomerAlgorithm != nil {
204			r.SSECustomerAlgorithm = *output.SSECustomerAlgorithm
205			}
206			if output.SSECustomerKeyMD5 != nil {
207			r.SSECustomerKeyMD5 = *output.SSECustomerKeyMD5
208			}
209			if output.SSEKMSEncryptionContext != nil {
210			r.SSEKMSEncryptionContext = *output.SSEKMSEncryptionContext
211			}
212			if output.SSEKMSKeyId != nil {
213			r.SSEKMSKeyID = *output.SSEKMSKeyId
214			}
215			if output.ServerSideEncryption != "" {
216			r.ServerSideEncryption = ServerSideEncryption(output.ServerSideEncryption)
217			}
218			if output.VersionId != nil {
219			r.VersionID = *output.VersionId
220			}
221			return r
222			}
223

evalphobia / aws-sdk-go-v2-wrapper

s3/client_op_object_put.go A last analyzed 2021-09-01 07:21 UTC

Size/Duplication

Importance

3 Methods

Duplication Side-by-Side

Filter issues like

s3/client_op_object_put.go A
last analyzed 2021-09-01 07:21 UTC