1 files changed, 76 insertions, 0 deletions
diff --git a/cmd/gcrane/cmd/gc.go b/cmd/gcrane/cmd/gc.go
new file mode 100644
index 0000000..b377be4
--- /dev/null
+++ b/cmd/gcrane/cmd/gc.go
@@ -0,0 +1,76 @@
+// Copyright 2018 Google LLC All Rights Reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//    http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package cmd
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/google/go-containerregistry/pkg/gcrane"
+	"github.com/google/go-containerregistry/pkg/name"
+	"github.com/google/go-containerregistry/pkg/v1/google"
+	"github.com/spf13/cobra"
+)
+
+// NewCmdGc creates a new cobra.Command for the gc subcommand.
+func NewCmdGc() *cobra.Command {
+	recursive := false
+	cmd := &cobra.Command{
+		Use:   "gc",
+		Short: "List images that are not tagged",
+		Args:  cobra.ExactArgs(1),
+		RunE: func(cc *cobra.Command, args []string) error {
+			return gc(cc.Context(), args[0], recursive)
+		},
+	}
+
+	cmd.Flags().BoolVarP(&recursive, "recursive", "r", false, "Whether to recurse through repos")
+
+	return cmd
+}
+
+func gc(ctx context.Context, root string, recursive bool) error {
+	repo, err := name.NewRepository(root)
+	if err != nil {
+		return err
+	}
+
+	opts := []google.Option{
+		google.WithAuthFromKeychain(gcrane.Keychain),
+		google.WithUserAgent(userAgent()),
+		google.WithContext(ctx),
+	}
+
+	if recursive {
+		return google.Walk(repo, printUntaggedImages, opts...)
+	}
+
+	tags, err := google.List(repo, opts...)
+	return printUntaggedImages(repo, tags, err)
+}
+
+func printUntaggedImages(repo name.Repository, tags *google.Tags, err error) error {
+	if err != nil {
+		return err
+	}
+
+	for digest, manifest := range tags.Manifests {
+		if len(manifest.Tags) == 0 {
+			fmt.Printf("%s@%s\n", repo, digest)
+		}
+	}
+
+	return nil
+}