From 0844a51e43df1c7c445c3142e7729069c06812bd Mon Sep 17 00:00:00 2001
From: Kay Yan <kay.yan@daocloud.io>
Date: Wed, 9 Aug 2023 14:35:12 +0000
Subject: [PATCH] support test integration docker 23 compatibility

Signed-off-by: Kay Yan <kay.yan@daocloud.io>
---
 .github/workflows/test.yml             | 15 ++-------------
 cmd/nerdctl/builder_build_test.go      |  4 ----
 cmd/nerdctl/compose_up_test.go         |  2 +-
 cmd/nerdctl/system_prune_linux_test.go |  6 +++++-
 cmd/nerdctl/volume_prune.go            |  7 +++++++
 cmd/nerdctl/volume_prune_linux_test.go |  8 +++++---
 pkg/api/types/volume_types.go          |  2 ++
 pkg/cmd/system/prune.go                |  1 +
 pkg/cmd/volume/prune.go                |  8 ++++++++
 9 files changed, 31 insertions(+), 22 deletions(-)

diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml
index badf87f1d18..534986876dd 100644
--- a/.github/workflows/test.yml
+++ b/.github/workflows/test.yml
@@ -181,26 +181,15 @@ jobs:
           go-version: ${{ env.GO_VERSION }}
           cache: true
           check-latest: true
-      # Docker >= 23 is still unsupported: https://github.com/containerd/nerdctl/issues/2421
-      - name: "Install Docker 20.10"
+      - name: "Enable BuildKit"
         run: |
           set -eux -o pipefail
-          # Uninstall the preinstalled Docker (Moby)
-          sudo apt-get remove moby-*
           # Enable BuildKit explicitly
           sudo apt-get install -y moreutils
           cat /etc/docker/daemon.json
           jq '.features.buildkit = true' </etc/docker/daemon.json  | sudo sponge /etc/docker/daemon.json
           cat /etc/docker/daemon.json
-          # Download Docker packages
-          curl -OSL https://download.docker.com/linux/ubuntu/dists/jammy/pool/stable/amd64/containerd.io_1.6.22-1_amd64.deb
-          curl -OSL https://download.docker.com/linux/ubuntu/dists/jammy/pool/stable/amd64/docker-ce_20.10.24~3-0~ubuntu-jammy_amd64.deb
-          curl -OSL https://download.docker.com/linux/ubuntu/dists/jammy/pool/stable/amd64/docker-ce-cli_20.10.24~3-0~ubuntu-jammy_amd64.deb
-          curl -OSL https://download.docker.com/linux/ubuntu/dists/jammy/pool/stable/amd64/docker-buildx-plugin_0.11.2-1~ubuntu.22.04~jammy_amd64.deb
-          curl -OSL https://download.docker.com/linux/ubuntu/dists/jammy/pool/stable/amd64/docker-compose-plugin_2.20.2-1~ubuntu.22.04~jammy_amd64.deb
-          # Install Docker
-          sudo apt-get install -y ./*.deb
-          rm -f ./*.deb
+          sudo systemctl restart docker
           # Print docker info
           docker info
           docker version
diff --git a/cmd/nerdctl/builder_build_test.go b/cmd/nerdctl/builder_build_test.go
index 4b7e89f9301..2341c850019 100644
--- a/cmd/nerdctl/builder_build_test.go
+++ b/cmd/nerdctl/builder_build_test.go
@@ -278,10 +278,6 @@ CMD echo $TEST_STRING
 			base.Cmd("run", "--rm", imageName).AssertOutExactly(tc.expected)
 		})
 	}
-
-	t.Run("InvalidBuildArgCausesError", func(t *testing.T) {
-		base.Cmd("build", buildCtx, "-t", imageName, "--build-arg", "=TEST_STRING").AssertFail()
-	})
 }
 
 func TestBuildWithIIDFile(t *testing.T) {
diff --git a/cmd/nerdctl/compose_up_test.go b/cmd/nerdctl/compose_up_test.go
index ef1811fcd8e..308993ff124 100644
--- a/cmd/nerdctl/compose_up_test.go
+++ b/cmd/nerdctl/compose_up_test.go
@@ -49,7 +49,7 @@ services:
 		Err:      `exec: \"invalid\": executable file not found in $PATH`,
 	}
 	if base.Target == testutil.Docker {
-		expected.Err = `Unknown runtime specified invalid`
+		expected.Err = `unknown or invalid runtime name: invalid`
 	}
 	c.Assert(expected)
 }
diff --git a/cmd/nerdctl/system_prune_linux_test.go b/cmd/nerdctl/system_prune_linux_test.go
index 361698d0954..034225b0bb8 100644
--- a/cmd/nerdctl/system_prune_linux_test.go
+++ b/cmd/nerdctl/system_prune_linux_test.go
@@ -46,6 +46,9 @@ func TestSystemPrune(t *testing.T) {
 	base.Cmd("volume", "create", vID).AssertOK()
 	defer base.Cmd("volume", "rm", vID).Run()
 
+	vID2 := base.Cmd("volume", "create").Out()
+	defer base.Cmd("volume", "rm", vID2).Run()
+
 	tID := testutil.Identifier(t)
 	base.Cmd("run", "-v", fmt.Sprintf("%s:/volume", vID), "--net", nID,
 		"--name", tID, testutil.CommonImage).AssertOK()
@@ -55,7 +58,8 @@ func TestSystemPrune(t *testing.T) {
 	base.Cmd("images").AssertOutContains(testutil.ImageRepo(testutil.CommonImage))
 
 	base.Cmd("system", "prune", "-f", "--volumes", "--all").AssertOK()
-	base.Cmd("volume", "ls").AssertNoOut(vID)
+	base.Cmd("volume", "ls").AssertOutContains(vID) // docker system prune --all --volume does not prune named volume
+	base.Cmd("volume", "ls").AssertNoOut(vID2)      // docker system prune --all --volume prune anonymous volume
 	base.Cmd("ps", "-a").AssertNoOut(tID)
 	base.Cmd("network", "ls").AssertNoOut(nID)
 	base.Cmd("images").AssertNoOut(testutil.ImageRepo(testutil.CommonImage))
diff --git a/cmd/nerdctl/volume_prune.go b/cmd/nerdctl/volume_prune.go
index df0cbbd680b..d015462134b 100644
--- a/cmd/nerdctl/volume_prune.go
+++ b/cmd/nerdctl/volume_prune.go
@@ -35,6 +35,7 @@ func newVolumePruneCommand() *cobra.Command {
 		SilenceUsage:  true,
 		SilenceErrors: true,
 	}
+	volumePruneCommand.Flags().BoolP("all", "a", false, "Remove all unused volumes, not just anonymous ones")
 	volumePruneCommand.Flags().BoolP("force", "f", false, "Do not prompt for confirmation")
 	return volumePruneCommand
 }
@@ -45,6 +46,11 @@ func processVolumePruneOptions(cmd *cobra.Command) (types.VolumePruneOptions, er
 		return types.VolumePruneOptions{}, err
 	}
 
+	all, err := cmd.Flags().GetBool("all")
+	if err != nil {
+		return types.VolumePruneOptions{}, err
+	}
+
 	force, err := cmd.Flags().GetBool("force")
 	if err != nil {
 		return types.VolumePruneOptions{}, err
@@ -52,6 +58,7 @@ func processVolumePruneOptions(cmd *cobra.Command) (types.VolumePruneOptions, er
 
 	options := types.VolumePruneOptions{
 		GOptions: globalOptions,
+		All:      all,
 		Force:    force,
 		Stdout:   cmd.OutOrStdout(),
 	}
diff --git a/cmd/nerdctl/volume_prune_linux_test.go b/cmd/nerdctl/volume_prune_linux_test.go
index e9a53b064f0..be7a7fc093b 100644
--- a/cmd/nerdctl/volume_prune_linux_test.go
+++ b/cmd/nerdctl/volume_prune_linux_test.go
@@ -26,19 +26,21 @@ import (
 func TestVolumePrune(t *testing.T) {
 	base := testutil.NewBase(t)
 	tID := testutil.Identifier(t)
-	base.Cmd("volume", "prune", "-f").Run()
+	base.Cmd("volume", "prune", "-a", "-f").Run()
 
+	vID := base.Cmd("volume", "create").Out()
 	base.Cmd("volume", "create", tID+"-1").AssertOK()
 	base.Cmd("volume", "create", tID+"-2").AssertOK()
 
 	base.Cmd("run", "-v", fmt.Sprintf("%s:/volume", tID+"-1"), "--name", tID, testutil.CommonImage).AssertOK()
 	defer base.Cmd("rm", "-f", tID).Run()
 
-	base.Cmd("volume", "prune", "-f").AssertOutContains(tID + "-2")
+	base.Cmd("volume", "prune", "-f").AssertOutContains(vID)
+	base.Cmd("volume", "prune", "-a", "-f").AssertOutContains(tID + "-2")
 	base.Cmd("volume", "ls").AssertOutContains(tID + "-1")
 	base.Cmd("volume", "ls").AssertNoOut(tID + "-2")
 
 	base.Cmd("rm", "-f", tID).AssertOK()
-	base.Cmd("volume", "prune", "-f").AssertOK()
+	base.Cmd("volume", "prune", "-a", "-f").AssertOK()
 	base.Cmd("volume", "ls").AssertNoOut(tID + "-1")
 }
diff --git a/pkg/api/types/volume_types.go b/pkg/api/types/volume_types.go
index 8fd67cecb09..903d8e68698 100644
--- a/pkg/api/types/volume_types.go
+++ b/pkg/api/types/volume_types.go
@@ -54,6 +54,8 @@ type VolumeListOptions struct {
 type VolumePruneOptions struct {
 	Stdout   io.Writer
 	GOptions GlobalCommandOptions
+	//Remove all unused volumes, not just anonymous ones
+	All bool
 	// Do not prompt for confirmation
 	Force bool
 }
diff --git a/pkg/cmd/system/prune.go b/pkg/cmd/system/prune.go
index cc3446a234e..94c941a48aa 100644
--- a/pkg/cmd/system/prune.go
+++ b/pkg/cmd/system/prune.go
@@ -48,6 +48,7 @@ func Prune(ctx context.Context, client *containerd.Client, options types.SystemP
 	if options.Volumes {
 		if err := volume.Prune(ctx, client, types.VolumePruneOptions{
 			GOptions: options.GOptions,
+			All:      false,
 			Force:    true,
 			Stdout:   options.Stdout,
 		}); err != nil {
diff --git a/pkg/cmd/volume/prune.go b/pkg/cmd/volume/prune.go
index 06cd202e955..cc7faa85b5b 100644
--- a/pkg/cmd/volume/prune.go
+++ b/pkg/cmd/volume/prune.go
@@ -22,6 +22,7 @@ import (
 
 	"github.com/containerd/containerd"
 	"github.com/containerd/nerdctl/pkg/api/types"
+	"github.com/containerd/nerdctl/pkg/labels"
 )
 
 func Prune(ctx context.Context, client *containerd.Client, options types.VolumePruneOptions) error {
@@ -47,6 +48,13 @@ func Prune(ctx context.Context, client *containerd.Client, options types.VolumeP
 		if _, ok := usedVolumes[volume.Name]; ok {
 			continue
 		}
+		if !options.All {
+			val, ok := (*volume.Labels)[labels.AnonymousVolumes]
+			//skip the named volume and only remove the anonymous volume
+			if !ok || val != "" {
+				continue
+			}
+		}
 		removeNames = append(removeNames, volume.Name)
 	}
 	removedNames, err := volStore.Remove(removeNames)