transport

type BatchRequest struct {
	Objects []*HaveObject `json:"objects"`
}

type BatchResponse struct {
	Objects []*HaveObject `json:"objects"`
}

type BatchShareObjectsRequest struct {
	Objects []*WantObject `json:"objects"`
}

type BatchShareObjectsResponse struct {
	Objects []*Representation `json:"objects"`
}

type Command struct {
	Refname     plumbing.ReferenceName `json:"refname"`
	OldRev      string                 `json:"old_rev"`
	NewRev      string                 `json:"new_rev"`
	Metadata    int                    `json:"metadata"`
	Objects     int                    `json:"objects"`
	PushOptions []string               `json:"push_options,omitempty"`
}

type Endpoint struct {
	url.URL
	// InsecureSkipTLS skips ssl verify if protocol is https
	InsecureSkipTLS bool
	// ExtraHeader extra header
	ExtraHeader map[string]string
	// ExtraEnv extra env
	ExtraEnv map[string]string
	// CredentialStorage specifies the credential storage backend (Linux only)
	CredentialStorage string
	// CredentialEncryptionKey specifies the encryption key for file storage
	CredentialEncryptionKey string
	// CredentialStoragePath specifies the path for encrypted credential file
	CredentialStoragePath string
	// contains filtered or unexported fields
}

type HaveObject struct {
	OID            string    `json:"oid"`
	CompressedSize int64     `json:"compressed_size"`
	Action         Operation `json:"action,omitempty"`
}

type MetadataOptions struct {
	SparseDirs []string
	DeepenFrom plumbing.Hash
	Have       plumbing.Hash
	Deepen     int
	Depth      int
}

type Operation string

type Options struct {
	InsecureSkipTLS bool
	ExtraHeader     []string
	ExtraEnv        []string
	// Credential configuration
	CredentialStorage       string
	CredentialEncryptionKey string
	CredentialStoragePath   string
}

type Reference struct {
	Remote          string                 `json:"remote"`
	Name            plumbing.ReferenceName `json:"name"`
	Hash            string                 `json:"hash"`
	Peeled          string                 `json:"peeled,omitempty"`
	HEAD            string                 `json:"head"`
	Version         int                    `json:"version"`
	Agent           string                 `json:"agent"`
	HashAlgo        string                 `json:"hash-algo"`
	CompressionALGO string                 `json:"compression-algo"`
	Capabilities    []string               `json:"capabilities"`
}

type Representation struct {
	OID            string            `json:"oid"`
	CompressedSize int64             `json:"compressed_size"`
	Href           string            `json:"href"`
	Header         map[string]string `json:"header,omitempty"`
	ExpiresAt      time.Time         `json:"expires_at,omitzero"`
}

type SASHandshake struct {
	Operation Operation `json:"operation"`
	Version   string    `json:"version"`
}

type SASPayload struct {
	Header    map[string]string `json:"header,omitempty"`
	Notice    string            `json:"notice,omitempty"`
	ExpiresAt time.Time         `json:"expires_at,omitzero"`
}

type SessionReader interface {
	io.Reader
	io.Closer
	LastError() error
}

type SizeReader interface {
	io.Reader
	io.Closer
	Offset() int64
	Size() int64
	LastError() error
}

type Transport interface {
	// FetchReference: discover reference and remote repo info and caps
	FetchReference(ctx context.Context, refname plumbing.ReferenceName) (*Reference, error)
	// FetchMetadata: support base metadata and sparse metadata.
	//  target: commit or tag
	FetchMetadata(ctx context.Context, target plumbing.Hash, opts *MetadataOptions) (SessionReader, error)
	// BatchMetadata: batch download metadata
	BatchMetadata(ctx context.Context, oids []plumbing.Hash, depth int) (SessionReader, error)
	// BatchObjects: batch download objects AKA blobs
	BatchObjects(ctx context.Context, oids []plumbing.Hash) (SessionReader, error)
	// GetObject: get large object, support Range feature
	GetObject(ctx context.Context, oid plumbing.Hash, fromByte int64) (SizeReader, error)
	// Share: get large objects shared links
	Share(ctx context.Context, wantObjects []*WantObject) ([]*Representation, error)
	// Push: push metadata and blobs to remote and update reference
	Push(ctx context.Context, r io.Reader, cmd *Command) (rc SessionReader, err error)
	// BatchCheck: check large objects exists in remote
	BatchCheck(ctx context.Context, refname plumbing.ReferenceName, haveObjects []*HaveObject) ([]*HaveObject, error)
	// PutObject: upload large object to remote
	PutObject(ctx context.Context, refname plumbing.ReferenceName, oid plumbing.Hash, r io.Reader, size int64) error
}

type WantObject struct {
	OID string `json:"oid"`
}