Porter triggers autobuild when detecting that invocation image does n…

…ot exist

Signed-off-by: joshuabezaleel <joshua.bezaleel@gmail.com>

pkg/cnab/cnab-to-oci/helpers.go

@@ -8,9 +8,10 @@ import (
 var _ RegistryProvider = &TestRegistry{}
 
 type TestRegistry struct {
-	MockPullBundle          func(ref cnab.OCIReference, insecureRegistry bool) (cnab.BundleReference, error)
-	MockPushBundle          func(bundleRef cnab.BundleReference, insecureRegistry bool) (bundleReference cnab.BundleReference, err error)
-	MockPushInvocationImage func(invocationImage string) (imageDigest digest.Digest, err error)
+	MockPullBundle              func(ref cnab.OCIReference, insecureRegistry bool) (cnab.BundleReference, error)
+	MockPushBundle              func(bundleRef cnab.BundleReference, insecureRegistry bool) (bundleReference cnab.BundleReference, err error)
+	MockPushInvocationImage     func(invocationImage string) (imageDigest digest.Digest, err error)
+	MockIsInvocationImageExists func(invocationImage string) (bool, error)
 }
 
 func NewTestRegistry() *TestRegistry {
@@ -39,3 +40,11 @@ func (t TestRegistry) PushInvocationImage(invocationImage string) (digest.Digest
 	}
 	return "", nil
 }
+
+func (t TestRegistry) IsInvocationImageExists(invocationImage string) (bool, error) {
+	if t.MockIsInvocationImageExists != nil {
+		return t.MockIsInvocationImageExists(invocationImage)
+	}
+
+	return true, nil
+}

pkg/cnab/cnab-to-oci/provider.go

@@ -17,4 +17,6 @@ type RegistryProvider interface {
 	// the expected format of the invocationImage is REGISTRY/NAME:TAG.
 	// Returns the image digest from the registry.
 	PushInvocationImage(invocationImage string) (digest.Digest, error)
+
+	IsInvocationImageExists(invocationImage string) (bool, error)
 }

pkg/cnab/cnab-to-oci/registry.go

@@ -13,6 +13,7 @@ import (
 	dockerconfig "github.com/docker/cli/cli/config"
 	cliflags "github.com/docker/cli/cli/flags"
 	"github.com/docker/docker/api/types"
+	"github.com/docker/docker/api/types/filters"
 	"github.com/docker/docker/pkg/jsonmessage"
 	"github.com/docker/docker/pkg/term"
 	"github.com/opencontainers/go-digest"
@@ -188,3 +189,30 @@ func (r *Registry) getDockerClient() (*command.DockerCli, error) {
 	}
 	return cli, nil
 }
+
+func (r *Registry) IsInvocationImageExists(invocationImage string) (bool, error) {
+	ctx := context.Background()
+
+	cli, err := r.getDockerClient()
+	if err != nil {
+		return false, err
+	}
+
+	ref, err := cnab.ParseOCIReference(invocationImage)
+	if err != nil {
+		return false, err
+	}
+
+	imageListOpts := types.ImageListOptions{All: true, Filters: filters.NewArgs(filters.KeyValuePair{Key: "reference", Value: ref.Repository()})}
+
+	imageSummaries, err := cli.Client().ImageList(ctx, imageListOpts)
+	if err != nil {
+		return false, err
+	}
+
+	if len(imageSummaries) == 0 {
+		return false, nil
+	}
+
+	return true, nil
+}

pkg/porter/stamp.go

@@ -60,6 +60,21 @@ func (p *Porter) IsBundleUpToDate(opts bundleFileOptions) (bool, error) {
 			return false, errors.Wrapf(err, "could not marshal data from %s", opts.CNABFile)
 		}
 
+		// Check whether invocation images exist in host registry.
+		for _, invocationImage := range bun.InvocationImages {
+			isInvocationImageExists, err := p.Registry.IsInvocationImageExists(invocationImage.Image)
+			if err != nil {
+				return false, errors.Wrapf(err, "error while checking for existing invocation image")
+			}
+
+			if !isInvocationImageExists {
+				if p.Debug {
+					fmt.Fprintln(p.Err, errors.New(fmt.Sprintf("Invocation image %s doesn't exist in host registry, will need to build first", invocationImage.Image)))
+				}
+				return false, nil
+			}
+		}
+
 		oldStamp, err := configadapter.LoadStamp(bun)
 		if err != nil {
 			return false, errors.Wrapf(err, "could not load stamp from %s", opts.CNABFile)