package_upload.go

package package_upload

import (
	"code.cloudfoundry.org/capi-k8s-release/src/registry-buddy/archive"
	"github.com/google/go-containerregistry/pkg/authn"
	"github.com/google/go-containerregistry/pkg/name"
	v1 "github.com/google/go-containerregistry/pkg/v1"
	"github.com/google/go-containerregistry/pkg/v1/mutate"
	"github.com/google/go-containerregistry/pkg/v1/random"
	"github.com/google/go-containerregistry/pkg/v1/remote"
	"github.com/google/go-containerregistry/pkg/v1/tarball"
)

type Hash v1.Hash

func Upload(zipPath, registryPath string, authenticator authn.Authenticator) (Hash, error) {
	image, err := random.Image(0, 0)
	if err != nil {
		return Hash{}, err
	}

	noopFilter := func(string) bool { return true }
	layer, err := tarball.LayerFromReader(archive.ReadZipAsTar(zipPath, "/", 0, 0, -1, true, noopFilter))
	if err != nil {
		return Hash{}, err
	}

	image, err = mutate.AppendLayers(image, layer)
	if err != nil {
		return Hash{}, err
	}

	ref, err := name.ParseReference(registryPath)
	if err != nil {
		return Hash{}, err
	}

	err = remote.Write(ref, image, remote.WithAuth(authenticator))
	if err != nil {
		return Hash{}, err
	}

	hash, err := image.Digest()
	return Hash(hash), err
}