102 lines
2.8 KiB
Go
102 lines
2.8 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
"net/http"
|
|
"net/url"
|
|
"reflect"
|
|
"unsafe"
|
|
|
|
"github.com/minio/minio-go/v7"
|
|
"github.com/minio/minio-go/v7/pkg/credentials"
|
|
|
|
_ "unsafe"
|
|
)
|
|
|
|
type obsOptions struct {
|
|
Endpoint string
|
|
Region string
|
|
Secure bool
|
|
BucketName string
|
|
|
|
HostRedirect string
|
|
}
|
|
|
|
var defaultObsOpts obsOptions
|
|
|
|
func newObsClient(opts obsOptions) (*minio.Client, error) {
|
|
client, err := minio.New(opts.Endpoint, &minio.Options{
|
|
Creds: credentials.NewEnvAWS(),
|
|
BucketLookup: minio.BucketLookupAuto, // vhost / path
|
|
Region: opts.Region,
|
|
Secure: opts.Secure,
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
setOverrideSignerType(client, credentials.SignatureV2)
|
|
return client, nil
|
|
}
|
|
|
|
var (
|
|
offsetCredsProvider uintptr
|
|
offsetOverrideSignerType uintptr
|
|
)
|
|
|
|
func init() {
|
|
vt := reflect.TypeOf(minio.Client{})
|
|
if field, ok := vt.FieldByName("credsProvider"); ok {
|
|
offsetCredsProvider = field.Offset
|
|
} else {
|
|
panic("cannot find credsProvider field")
|
|
}
|
|
|
|
if field, ok := vt.FieldByName("overrideSignerType"); ok {
|
|
offsetOverrideSignerType = field.Offset
|
|
} else {
|
|
panic("cannot find overrideSignerType field")
|
|
}
|
|
}
|
|
|
|
func getCredsProvider(client *minio.Client) *credentials.Credentials {
|
|
return *(**credentials.Credentials)(unsafe.Add(unsafe.Pointer(client), offsetCredsProvider))
|
|
}
|
|
|
|
func setOverrideSignerType(client *minio.Client, signerType credentials.SignatureType) {
|
|
ptr := (*credentials.SignatureType)(unsafe.Add(unsafe.Pointer(client), offsetOverrideSignerType))
|
|
*ptr = signerType
|
|
}
|
|
|
|
//go:linkname isVirtualHostStyleRequest github.com/minio/minio-go/v7.(*Client).isVirtualHostStyleRequest
|
|
func isVirtualHostStyleRequest(client *minio.Client, url url.URL, bucketName string) bool
|
|
|
|
//go:linkname makeTargetURL github.com/minio/minio-go/v7.(*Client).makeTargetURL
|
|
func makeTargetURL(client *minio.Client, bucketName, objectName, bucketLocation string, isVirtualHostStyle bool, queryValues url.Values) (*url.URL, error)
|
|
|
|
// requestMetadata - is container for all the values to make a request.
|
|
type requestMetadata struct {
|
|
// If set newRequest presigns the URL.
|
|
presignURL bool
|
|
|
|
// User supplied.
|
|
bucketName string
|
|
objectName string
|
|
queryValues url.Values
|
|
customHeader http.Header
|
|
extraPresignHeader http.Header
|
|
expires int64
|
|
|
|
// Generated by our internal code.
|
|
bucketLocation string
|
|
contentBody io.Reader
|
|
contentLength int64
|
|
contentMD5Base64 string // carries base64 encoded md5sum
|
|
contentSHA256Hex string // carries hex encoded sha256sum
|
|
streamSha256 bool
|
|
addCrc bool
|
|
trailer http.Header // (http.Request).Trailer. Requires v4 signature.
|
|
}
|
|
|
|
//go:linkname newRequest github.com/minio/minio-go/v7.(*Client).newRequest
|
|
func newRequest(client *minio.Client, ctx context.Context, method string, metadata requestMetadata) (req *http.Request, err error)
|