mirror of
				https://github.com/go-gitea/gitea.git
				synced 2025-10-31 21:28:11 +09:00 
			
		
		
		
	* Add a storage layer for attachments * Fix some bug * fix test * Fix copyright head and lint * Fix bug * Add setting for minio and flags for migrate-storage * Add documents * fix lint * Add test for minio store type on attachments * fix test * fix test * Apply suggestions from code review Co-authored-by: guillep2k <18600385+guillep2k@users.noreply.github.com> * Add warning when storage migrated successfully * Fix drone * fix test * rebase * Fix test * display the error on console * Move minio test to amd64 since minio docker don't support arm64 * refactor the codes * add trace * Fix test * remove log on xorm * Fi download bug * Add a storage layer for attachments * Add setting for minio and flags for migrate-storage * fix lint * Add test for minio store type on attachments * Apply suggestions from code review Co-authored-by: guillep2k <18600385+guillep2k@users.noreply.github.com> * Fix drone * fix test * Fix test * display the error on console * Move minio test to amd64 since minio docker don't support arm64 * refactor the codes * add trace * Fix test * Add URL function to serve attachments directly from S3/Minio * Add ability to enable/disable redirection in attachment configuration * Fix typo * Add a storage layer for attachments * Add setting for minio and flags for migrate-storage * fix lint * Add test for minio store type on attachments * Apply suggestions from code review Co-authored-by: guillep2k <18600385+guillep2k@users.noreply.github.com> * Fix drone * fix test * Fix test * display the error on console * Move minio test to amd64 since minio docker don't support arm64 * don't change unrelated files * Fix lint * Fix build * update go.mod and go.sum * Use github.com/minio/minio-go/v6 * Remove unused function * Upgrade minio to v7 and some other improvements * fix lint * Fix go mod Co-authored-by: guillep2k <18600385+guillep2k@users.noreply.github.com> Co-authored-by: Tyler <tystuyfzand@gmail.com>
		
			
				
	
	
		
			283 lines
		
	
	
		
			10 KiB
		
	
	
	
		
			Go
		
	
	
	
		
			Vendored
		
	
	
	
			
		
		
	
	
			283 lines
		
	
	
		
			10 KiB
		
	
	
	
		
			Go
		
	
	
	
		
			Vendored
		
	
	
	
| /*
 | |
|  * MinIO Go Library for Amazon S3 Compatible Cloud Storage
 | |
|  * Copyright 2020 MinIO, Inc.
 | |
|  *
 | |
|  * Licensed under the Apache License, Version 2.0 (the "License");
 | |
|  * you may not use this file except in compliance with the License.
 | |
|  * You may obtain a copy of the License at
 | |
|  *
 | |
|  *     http://www.apache.org/licenses/LICENSE-2.0
 | |
|  *
 | |
|  * Unless required by applicable law or agreed to in writing, software
 | |
|  * distributed under the License is distributed on an "AS IS" BASIS,
 | |
|  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 | |
|  * See the License for the specific language governing permissions and
 | |
|  * limitations under the License.
 | |
|  */
 | |
| 
 | |
| // Package lifecycle contains all the lifecycle related data types and marshallers.
 | |
| package lifecycle
 | |
| 
 | |
| import (
 | |
| 	"encoding/xml"
 | |
| 	"time"
 | |
| )
 | |
| 
 | |
| // AbortIncompleteMultipartUpload structure, not supported yet on MinIO
 | |
| type AbortIncompleteMultipartUpload struct {
 | |
| 	XMLName             xml.Name       `xml:"AbortIncompleteMultipartUpload,omitempty"  json:"-"`
 | |
| 	DaysAfterInitiation ExpirationDays `xml:"DaysAfterInitiation,omitempty" json:"DaysAfterInitiation,omitempty"`
 | |
| }
 | |
| 
 | |
| // IsDaysNull returns true if days field is null
 | |
| func (n AbortIncompleteMultipartUpload) IsDaysNull() bool {
 | |
| 	return n.DaysAfterInitiation == ExpirationDays(0)
 | |
| }
 | |
| 
 | |
| // MarshalXML if days after initiation is set to non-zero value
 | |
| func (n AbortIncompleteMultipartUpload) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
 | |
| 	if n.IsDaysNull() {
 | |
| 		return nil
 | |
| 	}
 | |
| 	type abortIncompleteMultipartUploadWrapper AbortIncompleteMultipartUpload
 | |
| 	return e.EncodeElement(abortIncompleteMultipartUploadWrapper(n), start)
 | |
| }
 | |
| 
 | |
| // NoncurrentVersionExpiration - Specifies when noncurrent object versions expire.
 | |
| // Upon expiration, server permanently deletes the noncurrent object versions.
 | |
| // Set this lifecycle configuration action on a bucket that has versioning enabled
 | |
| // (or suspended) to request server delete noncurrent object versions at a
 | |
| // specific period in the object's lifetime.
 | |
| type NoncurrentVersionExpiration struct {
 | |
| 	XMLName        xml.Name       `xml:"NoncurrentVersionExpiration" json:"-"`
 | |
| 	NoncurrentDays ExpirationDays `xml:"NoncurrentDays,omitempty"`
 | |
| }
 | |
| 
 | |
| // NoncurrentVersionTransition structure, set this action to request server to
 | |
| // transition noncurrent object versions to different set storage classes
 | |
| // at a specific period in the object's lifetime.
 | |
| type NoncurrentVersionTransition struct {
 | |
| 	XMLName        xml.Name       `xml:"NoncurrentVersionTransition,omitempty"  json:"-"`
 | |
| 	StorageClass   string         `xml:"StorageClass,omitempty" json:"StorageClass,omitempty"`
 | |
| 	NoncurrentDays ExpirationDays `xml:"NoncurrentDays,omitempty" json:"NoncurrentDays,omitempty"`
 | |
| }
 | |
| 
 | |
| // MarshalXML if non-current days not set to non zero value
 | |
| func (n NoncurrentVersionExpiration) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
 | |
| 	if n.IsDaysNull() {
 | |
| 		return nil
 | |
| 	}
 | |
| 	type noncurrentVersionExpirationWrapper NoncurrentVersionExpiration
 | |
| 	return e.EncodeElement(noncurrentVersionExpirationWrapper(n), start)
 | |
| }
 | |
| 
 | |
| // IsDaysNull returns true if days field is null
 | |
| func (n NoncurrentVersionExpiration) IsDaysNull() bool {
 | |
| 	return n.NoncurrentDays == ExpirationDays(0)
 | |
| }
 | |
| 
 | |
| // MarshalXML is extended to leave out
 | |
| // <NoncurrentVersionTransition></NoncurrentVersionTransition> tags
 | |
| func (n NoncurrentVersionTransition) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
 | |
| 	if n.NoncurrentDays == ExpirationDays(0) {
 | |
| 		return nil
 | |
| 	}
 | |
| 	return e.EncodeElement(&n, start)
 | |
| }
 | |
| 
 | |
| // Tag structure key/value pair representing an object tag to apply lifecycle configuration
 | |
| type Tag struct {
 | |
| 	XMLName xml.Name `xml:"Tag,omitempty" json:"-"`
 | |
| 	Key     string   `xml:"Key,omitempty" json:"Key,omitempty"`
 | |
| 	Value   string   `xml:"Value,omitempty" json:"Value,omitempty"`
 | |
| }
 | |
| 
 | |
| // IsEmpty returns whether this tag is empty or not.
 | |
| func (tag Tag) IsEmpty() bool {
 | |
| 	return tag.Key == ""
 | |
| }
 | |
| 
 | |
| // Transition structure - transition details of lifecycle configuration
 | |
| type Transition struct {
 | |
| 	XMLName      xml.Name       `xml:"Transition" json:"-"`
 | |
| 	Date         ExpirationDate `xml:"Date,omitempty" json:"Date,omitempty"`
 | |
| 	StorageClass string         `xml:"StorageClass,omitempty" json:"StorageClass,omitempty"`
 | |
| 	Days         ExpirationDays `xml:"Days,omitempty" json:"Days,omitempty"`
 | |
| }
 | |
| 
 | |
| // IsDaysNull returns true if days field is null
 | |
| func (t Transition) IsDaysNull() bool {
 | |
| 	return t.Days == ExpirationDays(0)
 | |
| }
 | |
| 
 | |
| // IsDateNull returns true if date field is null
 | |
| func (t Transition) IsDateNull() bool {
 | |
| 	return t.Date.Time.IsZero()
 | |
| }
 | |
| 
 | |
| // IsNull returns true if both date and days fields are null
 | |
| func (t Transition) IsNull() bool {
 | |
| 	return t.IsDaysNull() && t.IsDateNull()
 | |
| }
 | |
| 
 | |
| // MarshalXML is transition is non null
 | |
| func (t Transition) MarshalXML(en *xml.Encoder, startElement xml.StartElement) error {
 | |
| 	if t.IsNull() {
 | |
| 		return nil
 | |
| 	}
 | |
| 	type transitionWrapper Transition
 | |
| 	return en.EncodeElement(transitionWrapper(t), startElement)
 | |
| }
 | |
| 
 | |
| // And And Rule for LifecycleTag, to be used in LifecycleRuleFilter
 | |
| type And struct {
 | |
| 	XMLName xml.Name `xml:"And,omitempty" json:"-"`
 | |
| 	Prefix  string   `xml:"Prefix,omitempty" json:"Prefix,omitempty"`
 | |
| 	Tags    []Tag    `xml:"Tag,omitempty" json:"Tags,omitempty"`
 | |
| }
 | |
| 
 | |
| // IsEmpty returns true if Tags field is null
 | |
| func (a And) IsEmpty() bool {
 | |
| 	return len(a.Tags) == 0 && a.Prefix == ""
 | |
| }
 | |
| 
 | |
| // Filter will be used in selecting rule(s) for lifecycle configuration
 | |
| type Filter struct {
 | |
| 	XMLName xml.Name `xml:"Filter" json:"-"`
 | |
| 	And     And      `xml:"And,omitempty" json:"And,omitempty"`
 | |
| 	Prefix  string   `xml:"Prefix,omitempty" json:"Prefix,omitempty"`
 | |
| 	Tag     Tag      `xml:"Tag,omitempty" json:"-"`
 | |
| }
 | |
| 
 | |
| // MarshalXML - produces the xml representation of the Filter struct
 | |
| // only one of Prefix, And and Tag should be present in the output.
 | |
| func (f Filter) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
 | |
| 	if err := e.EncodeToken(start); err != nil {
 | |
| 		return err
 | |
| 	}
 | |
| 
 | |
| 	switch {
 | |
| 	case !f.And.IsEmpty():
 | |
| 		if err := e.EncodeElement(f.And, xml.StartElement{Name: xml.Name{Local: "And"}}); err != nil {
 | |
| 			return err
 | |
| 		}
 | |
| 	case !f.Tag.IsEmpty():
 | |
| 		if err := e.EncodeElement(f.Tag, xml.StartElement{Name: xml.Name{Local: "Tag"}}); err != nil {
 | |
| 			return err
 | |
| 		}
 | |
| 	default:
 | |
| 		// Always print Prefix field when both And & Tag are empty
 | |
| 		if err := e.EncodeElement(f.Prefix, xml.StartElement{Name: xml.Name{Local: "Prefix"}}); err != nil {
 | |
| 			return err
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	return e.EncodeToken(xml.EndElement{Name: start.Name})
 | |
| }
 | |
| 
 | |
| // ExpirationDays is a type alias to unmarshal Days in Expiration
 | |
| type ExpirationDays int
 | |
| 
 | |
| // MarshalXML encodes number of days to expire if it is non-zero and
 | |
| // encodes empty string otherwise
 | |
| func (eDays ExpirationDays) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
 | |
| 	if eDays == 0 {
 | |
| 		return nil
 | |
| 	}
 | |
| 	return e.EncodeElement(int(eDays), startElement)
 | |
| }
 | |
| 
 | |
| // ExpirationDate is a embedded type containing time.Time to unmarshal
 | |
| // Date in Expiration
 | |
| type ExpirationDate struct {
 | |
| 	time.Time
 | |
| }
 | |
| 
 | |
| // MarshalXML encodes expiration date if it is non-zero and encodes
 | |
| // empty string otherwise
 | |
| func (eDate ExpirationDate) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
 | |
| 	if eDate.Time.IsZero() {
 | |
| 		return nil
 | |
| 	}
 | |
| 	return e.EncodeElement(eDate.Format(time.RFC3339), startElement)
 | |
| }
 | |
| 
 | |
| // ExpireDeleteMarker represents value of ExpiredObjectDeleteMarker field in Expiration XML element.
 | |
| type ExpireDeleteMarker bool
 | |
| 
 | |
| // MarshalXML encodes delete marker boolean into an XML form.
 | |
| func (b ExpireDeleteMarker) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
 | |
| 	if !b {
 | |
| 		return nil
 | |
| 	}
 | |
| 	type expireDeleteMarkerWrapper ExpireDeleteMarker
 | |
| 	return e.EncodeElement(expireDeleteMarkerWrapper(b), startElement)
 | |
| }
 | |
| 
 | |
| // Expiration structure - expiration details of lifecycle configuration
 | |
| type Expiration struct {
 | |
| 	XMLName      xml.Name           `xml:"Expiration,omitempty" json:"-"`
 | |
| 	Date         ExpirationDate     `xml:"Date,omitempty" json:"Date,omitempty"`
 | |
| 	Days         ExpirationDays     `xml:"Days,omitempty" json:"Days,omitempty"`
 | |
| 	DeleteMarker ExpireDeleteMarker `xml:"ExpiredObjectDeleteMarker,omitempty"`
 | |
| }
 | |
| 
 | |
| // IsDaysNull returns true if days field is null
 | |
| func (e Expiration) IsDaysNull() bool {
 | |
| 	return e.Days == ExpirationDays(0)
 | |
| }
 | |
| 
 | |
| // IsDateNull returns true if date field is null
 | |
| func (e Expiration) IsDateNull() bool {
 | |
| 	return e.Date.Time.IsZero()
 | |
| }
 | |
| 
 | |
| // IsNull returns true if both date and days fields are null
 | |
| func (e Expiration) IsNull() bool {
 | |
| 	return e.IsDaysNull() && e.IsDateNull()
 | |
| }
 | |
| 
 | |
| // MarshalXML is expiration is non null
 | |
| func (e Expiration) MarshalXML(en *xml.Encoder, startElement xml.StartElement) error {
 | |
| 	if e.IsNull() {
 | |
| 		return nil
 | |
| 	}
 | |
| 	type expirationWrapper Expiration
 | |
| 	return en.EncodeElement(expirationWrapper(e), startElement)
 | |
| }
 | |
| 
 | |
| // Rule represents a single rule in lifecycle configuration
 | |
| type Rule struct {
 | |
| 	XMLName                        xml.Name                       `xml:"Rule,omitempty" json:"-"`
 | |
| 	AbortIncompleteMultipartUpload AbortIncompleteMultipartUpload `xml:"AbortIncompleteMultipartUpload,omitempty" json:"AbortIncompleteMultipartUpload,omitempty"`
 | |
| 	Expiration                     Expiration                     `xml:"Expiration,omitempty" json:"Expiration,omitempty"`
 | |
| 	ID                             string                         `xml:"ID" json:"ID"`
 | |
| 	RuleFilter                     Filter                         `xml:"Filter,omitempty" json:"Filter,omitempty"`
 | |
| 	NoncurrentVersionExpiration    NoncurrentVersionExpiration    `xml:"NoncurrentVersionExpiration,omitempty"  json:"NoncurrentVersionExpiration,omitempty"`
 | |
| 	NoncurrentVersionTransition    NoncurrentVersionTransition    `xml:"NoncurrentVersionTransition,omitempty" json:"NoncurrentVersionTransition,omitempty"`
 | |
| 	Prefix                         string                         `xml:"Prefix,omitempty" json:"Prefix,omitempty"`
 | |
| 	Status                         string                         `xml:"Status" json:"Status"`
 | |
| 	Transition                     Transition                     `xml:"Transition,omitempty" json:"Transition,omitempty"`
 | |
| }
 | |
| 
 | |
| // Configuration is a collection of Rule objects.
 | |
| type Configuration struct {
 | |
| 	XMLName xml.Name `xml:"LifecycleConfiguration,omitempty" json:"-"`
 | |
| 	Rules   []Rule   `xml:"Rule"`
 | |
| }
 | |
| 
 | |
| // Empty check if lifecycle configuration is empty
 | |
| func (c *Configuration) Empty() bool {
 | |
| 	if c == nil {
 | |
| 		return true
 | |
| 	}
 | |
| 	return len(c.Rules) == 0
 | |
| }
 | |
| 
 | |
| // NewConfiguration initializes a fresh lifecycle configuration
 | |
| // for manipulation, such as setting and removing lifecycle rules
 | |
| // and filters.
 | |
| func NewConfiguration() *Configuration {
 | |
| 	return &Configuration{}
 | |
| }
 |