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)