func()

in storage-aliyunoss/aliyunoss.go [77:138]
56 lines of code
9 McCabe index (conditional complexity)

func (s *Storage) UploadFile(ctx *plugin.GinContext, condition plugin.UploadFileCondition) (resp plugin.UploadFileResponse) {
	resp = plugin.UploadFileResponse{}
	client, err := oss.New(s.Config.Endpoint, s.Config.AccessKeyID, s.Config.AccessKeySecret)
	if err != nil {
		resp.OriginalError = err
		resp.DisplayErrorMsg = plugin.MakeTranslator(i18n.ErrMisStorageConfig)
		return resp
	}

	bucket, err := client.Bucket(s.Config.BucketName)
	if err != nil {
		resp.OriginalError = fmt.Errorf("get bucket failed: %v", err)
		resp.DisplayErrorMsg = plugin.MakeTranslator(i18n.ErrMisStorageConfig)
		return resp
	}

	file, err := ctx.FormFile("file")
	if err != nil {
		resp.OriginalError = fmt.Errorf("get upload file failed: %v", err)
		resp.DisplayErrorMsg = plugin.MakeTranslator(i18n.ErrFileNotFound)
		return resp
	}

	if s.IsUnsupportedFileType(file.Filename, condition) {
		resp.OriginalError = fmt.Errorf("file type not allowed")
		resp.DisplayErrorMsg = plugin.MakeTranslator(i18n.ErrUnsupportedFileType)
		return resp
	}

	if s.ExceedFileSizeLimit(file.Size, condition) {
		resp.OriginalError = fmt.Errorf("file size too large")
		resp.DisplayErrorMsg = plugin.MakeTranslator(i18n.ErrOverFileSizeLimit)
		return resp
	}

	open, err := file.Open()
	if err != nil {
		resp.OriginalError = fmt.Errorf("get file failed: %v", err)
		resp.DisplayErrorMsg = plugin.MakeTranslator(i18n.ErrFileNotFound)
		return resp
	}
	defer open.Close()

	objectKey := s.createObjectKey(file.Filename, condition.Source)
	request := &oss.PutObjectRequest{
		ObjectKey: objectKey,
		Reader:    open,
	}
	var options []oss.Option
	if s.Config.ACL == string(oss.ACLPublicRead) {
		options = append(options, oss.ObjectACL(oss.ACLPublicRead))
	}
	respBody, err := bucket.DoPutObject(request, options)
	if err != nil {
		resp.OriginalError = fmt.Errorf("upload file failed: %v", err)
		resp.DisplayErrorMsg = plugin.MakeTranslator(i18n.ErrUploadFileFailed)
		return resp
	}
	defer respBody.Close()
	resp.FullURL = s.Config.VisitUrlPrefix + objectKey
	return resp
}