Fix/enhance IPFS tests

Signed-off-by: apostasie <[email protected]>

Author: apostasie

cmd/nerdctl/ipfs_linux_test.go

@@ -26,6 +26,7 @@ import (
 	"github.com/containerd/nerdctl/v2/pkg/rootlessutil"
 	"github.com/containerd/nerdctl/v2/pkg/testutil"
 	"github.com/containerd/nerdctl/v2/pkg/testutil/nettestutil"
+	"github.com/containerd/nerdctl/v2/pkg/testutil/portlock"
 
 	"gotest.tools/v3/assert"
 )
@@ -73,27 +74,30 @@ func TestIPFSAddress(t *testing.T) {
 }
 
 func runIPFSDaemonContainer(t *testing.T, base *testutil.Base) (ipfsAddress string, done func()) {
+	port, err := portlock.Acquire(0)
+	assert.NilError(base.T, err, fmt.Errorf("failed acquiring port: %w", err))
+
 	name := "test-ipfs-address-" + testutil.Identifier(t)
 	var ipfsaddr string
 	var addrTest string
 	if detachedNetNS, _ := rootlessutil.DetachedNetNS(); detachedNetNS != "" {
 		// detached-netns mode can't use .NetworkSettings.IPAddress, because the daemon and CNI has different network namespaces
-		base.Cmd("run", "-d", "-p", "127.0.0.1:5999:5999", "--name", name, "--entrypoint=/bin/sh", testutil.KuboImage, "-c", "ipfs init && ipfs config Addresses.API /ip4/0.0.0.0/tcp/5999 && ipfs daemon --offline").AssertOK()
-		ipfsaddr = "/ip4/127.0.0.1/tcp/5999"
-		addrTest = "127.0.0.1:5999"
+		base.Cmd("run", "-d", "-p", fmt.Sprintf("127.0.0.1:%d:%d", port, port), "--name", name, "--entrypoint=/bin/sh", testutil.KuboImage, "-c", fmt.Sprintf("ipfs init && ipfs config Addresses.API /ip4/0.0.0.0/tcp/%d && ipfs daemon --offline", port)).AssertOK()
+		ipfsaddr = fmt.Sprintf("/ip4/127.0.0.1/tcp/%d", port)
+		addrTest = fmt.Sprintf("127.0.0.1:%d", port)
 	} else {
-		base.Cmd("run", "-d", "--name", name, "--entrypoint=/bin/sh", testutil.KuboImage, "-c", "ipfs init && ipfs config Addresses.API /ip4/0.0.0.0/tcp/5001 && ipfs daemon --offline").AssertOK()
+		base.Cmd("run", "-d", "--name", name, "--entrypoint=/bin/sh", testutil.KuboImage, "-c", fmt.Sprintf("ipfs init && ipfs config Addresses.API /ip4/0.0.0.0/tcp/%d && ipfs daemon --offline", port)).AssertOK()
 		iplines := base.Cmd("inspect", name, "-f", "'{{json .NetworkSettings.IPAddress}}'").OutLines()
 		t.Logf("IPAddress=%v", iplines)
 		assert.Equal(t, len(iplines), 2)
 		matches := iplineRegexp.FindStringSubmatch(iplines[0])
 		t.Logf("ip address matches=%v", matches)
 		assert.Equal(t, len(matches), 2)
-		ipfsaddr = fmt.Sprintf("/ip4/%s/tcp/5001", matches[1])
-		addrTest = matches[1] + ":5001"
+		ipfsaddr = fmt.Sprintf("/ip4/%s/tcp/%d", matches[1], port)
+		addrTest = matches[1] + fmt.Sprintf(":%d", port)
 	}
 
-	_, err := nettestutil.HTTPGet(fmt.Sprintf("http://%s/api/v0", addrTest), 30, true)
+	_, err = nettestutil.HTTPGet(fmt.Sprintf("http://%s/api/v0", addrTest), 30, true)
 	// Not there... give it more time...
 	if err != nil {
 		time.Sleep(1 * time.Second)
@@ -111,6 +115,10 @@ func runIPFSDaemonContainer(t *testing.T, base *testutil.Base) (ipfsAddress stri
 	return ipfsaddr, func() {
 		base.Cmd("kill", name).AssertOK()
 		base.Cmd("rm", name).AssertOK()
+		err = portlock.Release(port)
+		if err != nil {
+			t.Errorf("failed to release ipfs port %d: %v", port, err)
+		}
 	}
 }