now Credentials & UpToken field would be checked to make sure it is not nil

Author: bachue

storagev2/apis/api_add_bucket_rules.go

@@ -60,6 +60,9 @@ func (storage *Storage) AddBucketRules(ctx context.Context, request *AddBucketRu
 	}
 	innerRequest := (*innerAddBucketRulesRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "rules", "add")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_async_fetch_object.go

@@ -7,6 +7,7 @@ import (
 	"encoding/json"
 	auth "github.com/qiniu/go-sdk/v7/auth"
 	asyncfetchobject "github.com/qiniu/go-sdk/v7/storagev2/apis/async_fetch_object"
+	errors "github.com/qiniu/go-sdk/v7/storagev2/errors"
 	httpclient "github.com/qiniu/go-sdk/v7/storagev2/http_client"
 	region "github.com/qiniu/go-sdk/v7/storagev2/region"
 	"strings"
@@ -44,6 +45,9 @@ func (storage *Storage) AsyncFetchObject(ctx context.Context, request *AsyncFetc
 	}
 	innerRequest := (*innerAsyncFetchObjectRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceApi}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "sisyphus", "fetch")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_batch_ops.go

@@ -47,6 +47,9 @@ func (storage *Storage) BatchOps(ctx context.Context, request *BatchOpsRequest,
 	}
 	innerRequest := (*innerBatchOpsRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRs}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "batch")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_copy_object.go

@@ -57,6 +57,9 @@ func (storage *Storage) CopyObject(ctx context.Context, request *CopyObjectReque
 	}
 	innerRequest := (*innerCopyObjectRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRs}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "copy")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_create_bucket.go

@@ -47,6 +47,9 @@ func (storage *Storage) CreateBucket(ctx context.Context, request *CreateBucketR
 	}
 	innerRequest := (*innerCreateBucketRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "mkbucketv3")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_delete_bucket.go

@@ -47,6 +47,9 @@ func (storage *Storage) DeleteBucket(ctx context.Context, request *DeleteBucketR
 	}
 	innerRequest := (*innerDeleteBucketRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "drop")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_delete_bucket_rules.go

@@ -53,6 +53,9 @@ func (storage *Storage) DeleteBucketRules(ctx context.Context, request *DeleteBu
 	}
 	innerRequest := (*innerDeleteBucketRulesRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "rules", "delete")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_delete_bucket_taggings.go

@@ -48,6 +48,9 @@ func (storage *Storage) DeleteBucketTaggings(ctx context.Context, request *Delet
 	}
 	innerRequest := (*innerDeleteBucketTaggingsRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "bucketTagging")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_delete_object.go

@@ -48,6 +48,9 @@ func (storage *Storage) DeleteObject(ctx context.Context, request *DeleteObjectR
 	}
 	innerRequest := (*innerDeleteObjectRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRs}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "delete")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_delete_object_after_days.go

@@ -50,6 +50,9 @@ func (storage *Storage) DeleteObjectAfterDays(ctx context.Context, request *Dele
 	}
 	innerRequest := (*innerDeleteObjectAfterDaysRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRs}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "deleteAfterDays")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_fetch_object.go

@@ -56,6 +56,9 @@ func (storage *Storage) FetchObject(ctx context.Context, request *FetchObjectReq
 	}
 	innerRequest := (*innerFetchObjectRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceIo}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "fetch")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_get_async_fetch_task.go

@@ -45,6 +45,9 @@ func (storage *Storage) GetAsyncFetchTask(ctx context.Context, request *GetAsync
 	}
 	innerRequest := (*innerGetAsyncFetchTaskRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceApi}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "sisyphus", "fetch")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_get_bucket_cors_rules.go

@@ -47,6 +47,9 @@ func (storage *Storage) GetBucketCORSRules(ctx context.Context, request *GetBuck
 	}
 	innerRequest := (*innerGetBucketCORSRulesRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "corsRules", "get")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_get_bucket_domains.go

@@ -48,6 +48,9 @@ func (storage *Storage) GetBucketDomains(ctx context.Context, request *GetBucket
 	}
 	innerRequest := (*innerGetBucketDomainsRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "v2", "domains")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_get_bucket_quota.go

@@ -47,6 +47,9 @@ func (storage *Storage) GetBucketQuota(ctx context.Context, request *GetBucketQu
 	}
 	innerRequest := (*innerGetBucketQuotaRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "getbucketquota")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_get_bucket_rules.go

@@ -45,6 +45,9 @@ func (storage *Storage) GetBucketRules(ctx context.Context, request *GetBucketRu
 	}
 	innerRequest := (*innerGetBucketRulesRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "rules", "get")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_get_bucket_taggings.go

@@ -48,6 +48,9 @@ func (storage *Storage) GetBucketTaggings(ctx context.Context, request *GetBucke
 	}
 	innerRequest := (*innerGetBucketTaggingsRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "bucketTagging")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_get_buckets.go

@@ -6,6 +6,7 @@ import (
 	"context"
 	auth "github.com/qiniu/go-sdk/v7/auth"
 	getbuckets "github.com/qiniu/go-sdk/v7/storagev2/apis/get_buckets"
+	errors "github.com/qiniu/go-sdk/v7/storagev2/errors"
 	httpclient "github.com/qiniu/go-sdk/v7/storagev2/http_client"
 	region "github.com/qiniu/go-sdk/v7/storagev2/region"
 	"net/url"
@@ -42,6 +43,9 @@ func (storage *Storage) GetBuckets(ctx context.Context, request *GetBucketsReque
 	}
 	innerRequest := (*innerGetBucketsRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "buckets")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_get_buckets_v4.go

@@ -6,6 +6,7 @@ import (
 	"context"
 	auth "github.com/qiniu/go-sdk/v7/auth"
 	getbucketsv4 "github.com/qiniu/go-sdk/v7/storagev2/apis/get_buckets_v4"
+	errors "github.com/qiniu/go-sdk/v7/storagev2/errors"
 	httpclient "github.com/qiniu/go-sdk/v7/storagev2/http_client"
 	region "github.com/qiniu/go-sdk/v7/storagev2/region"
 	"net/url"
@@ -49,6 +50,9 @@ func (storage *Storage) GetBucketsV4(ctx context.Context, request *GetBucketsV4R
 	}
 	innerRequest := (*innerGetBucketsV4Request)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "buckets")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_get_objects.go

@@ -64,6 +64,9 @@ func (storage *Storage) GetObjects(ctx context.Context, request *GetObjectsReque
 	}
 	innerRequest := (*innerGetObjectsRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRsf}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "list")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_get_objects_v2.go

@@ -64,6 +64,9 @@ func (storage *Storage) GetObjectsV2(ctx context.Context, request *GetObjectsV2R
 	}
 	innerRequest := (*innerGetObjectsV2Request)(request)
 	serviceNames := []region.ServiceName{region.ServiceRsf}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "v2", "list")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_get_regions.go

@@ -6,6 +6,7 @@ import (
 	"context"
 	auth "github.com/qiniu/go-sdk/v7/auth"
 	getregions "github.com/qiniu/go-sdk/v7/storagev2/apis/get_regions"
+	errors "github.com/qiniu/go-sdk/v7/storagev2/errors"
 	httpclient "github.com/qiniu/go-sdk/v7/storagev2/http_client"
 	region "github.com/qiniu/go-sdk/v7/storagev2/region"
 	"strings"
@@ -34,6 +35,9 @@ func (storage *Storage) GetRegions(ctx context.Context, request *GetRegionsReque
 	}
 	innerRequest := (*innerGetRegionsRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceBucket}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "regions")
 	path := "/" + strings.Join(pathSegments, "/")

storagev2/apis/api_modify_object_life_cycle.go

@@ -64,6 +64,9 @@ func (storage *Storage) ModifyObjectLifeCycle(ctx context.Context, request *Modi
 	}
 	innerRequest := (*innerModifyObjectLifeCycleRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRs}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "lifecycle")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_modify_object_metadata.go

@@ -58,6 +58,9 @@ func (storage *Storage) ModifyObjectMetadata(ctx context.Context, request *Modif
 	}
 	innerRequest := (*innerModifyObjectMetadataRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRs}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "chgm")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_modify_object_status.go

@@ -50,6 +50,9 @@ func (storage *Storage) ModifyObjectStatus(ctx context.Context, request *ModifyO
 	}
 	innerRequest := (*innerModifyObjectStatusRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRs}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "chstatus")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_move_object.go

@@ -57,6 +57,9 @@ func (storage *Storage) MoveObject(ctx context.Context, request *MoveObjectReque
 	}
 	innerRequest := (*innerMoveObjectRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRs}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "move")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_prefetch_object.go

@@ -48,6 +48,9 @@ func (storage *Storage) PrefetchObject(ctx context.Context, request *PrefetchObj
 	}
 	innerRequest := (*innerPrefetchObjectRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceIo}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "prefetch")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_restore_archived_object.go

@@ -54,6 +54,9 @@ func (storage *Storage) RestoreArchivedObject(ctx context.Context, request *Rest
 	}
 	innerRequest := (*innerRestoreArchivedObjectRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceRs}
+	if innerRequest.Credentials == nil && storage.client.GetCredentials() == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "Credentials"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "restoreAr")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_resumable_upload_v1_bput.go

@@ -51,6 +51,9 @@ func (storage *Storage) ResumableUploadV1Bput(ctx context.Context, request *Resu
 	}
 	innerRequest := (*innerResumableUploadV1BputRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceUp}
+	if innerRequest.UpToken == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "UpToken"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "bput")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_resumable_upload_v1_make_block.go

@@ -50,6 +50,9 @@ func (storage *Storage) ResumableUploadV1MakeBlock(ctx context.Context, request
 	}
 	innerRequest := (*innerResumableUploadV1MakeBlockRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceUp}
+	if innerRequest.UpToken == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "UpToken"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "mkblk")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_resumable_upload_v1_make_file.go

@@ -60,6 +60,9 @@ func (storage *Storage) ResumableUploadV1MakeFile(ctx context.Context, request *
 	}
 	innerRequest := (*innerResumableUploadV1MakeFileRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceUp}
+	if innerRequest.UpToken == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "UpToken"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "mkfile")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_resumable_upload_v2_abort_multipart_upload.go

@@ -60,6 +60,9 @@ func (storage *Storage) ResumableUploadV2AbortMultipartUpload(ctx context.Contex
 	}
 	innerRequest := (*innerResumableUploadV2AbortMultipartUploadRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceUp}
+	if innerRequest.UpToken == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "UpToken"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "buckets")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_resumable_upload_v2_complete_multipart_upload.go

@@ -67,6 +67,9 @@ func (storage *Storage) ResumableUploadV2CompleteMultipartUpload(ctx context.Con
 	}
 	innerRequest := (*innerResumableUploadV2CompleteMultipartUploadRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceUp}
+	if innerRequest.UpToken == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "UpToken"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "buckets")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_resumable_upload_v2_initiate_multipart_upload.go

@@ -55,6 +55,9 @@ func (storage *Storage) ResumableUploadV2InitiateMultipartUpload(ctx context.Con
 	}
 	innerRequest := (*innerResumableUploadV2InitiateMultipartUploadRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceUp}
+	if innerRequest.UpToken == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "UpToken"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "buckets")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_resumable_upload_v2_list_parts.go

@@ -72,6 +72,9 @@ func (storage *Storage) ResumableUploadV2ListParts(ctx context.Context, request
 	}
 	innerRequest := (*innerResumableUploadV2ListPartsRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceUp}
+	if innerRequest.UpToken == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "UpToken"}
+	}
 	var pathSegments []string
 	pathSegments = append(pathSegments, "buckets")
 	if segments, err := innerRequest.buildPath(); err != nil {

storagev2/apis/api_resumable_upload_v2_upload_part.go

@@ -74,6 +74,9 @@ func (storage *Storage) ResumableUploadV2UploadPart(ctx context.Context, request
 	}
 	innerRequest := (*innerResumableUploadV2UploadPartRequest)(request)
 	serviceNames := []region.ServiceName{region.ServiceUp}
+	if innerRequest.UpToken == nil {
+		return nil, errors.MissingRequiredFieldError{Name: "UpToken"}
+	}
 	headers, err := innerRequest.buildHeaders()
 	if err != nil {
 		return nil, err