From 5d0d0acc77ffaf58c6d81a23bfc423bb03948615 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=C5=81ukasz=20Ole=C5=9B?= <lukaszoles@gmail.com>
Date: Mon, 16 Aug 2021 14:58:33 +0200
Subject: [PATCH 1/2] [FIX] Do not override hostIP when hostPort is missing
 (#693, @lukaszo)

---
 cmd/cluster/clusterCreate.go | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/cmd/cluster/clusterCreate.go b/cmd/cluster/clusterCreate.go
index f5fc4af5..7758b928 100644
--- a/cmd/cluster/clusterCreate.go
+++ b/cmd/cluster/clusterCreate.go
@@ -26,6 +26,7 @@ import (
 	"fmt"
 	"os"
 	"runtime"
+	"strconv"
 	"strings"
 	"time"
 
@@ -390,10 +391,15 @@ func applyCLIOverrides(cfg conf.SimpleConfig) (conf.SimpleConfig, error) {
 
 	// Set to random port if port is empty string
 	if len(exposeAPI.Binding.HostPort) == 0 {
-		exposeAPI, err = cliutil.ParsePortExposureSpec("random", k3d.DefaultAPIPort)
-		if err != nil {
-			return cfg, err
+		var freePort string
+		port, err := cliutil.GetFreePort()
+		freePort = strconv.Itoa(port)
+		if err != nil || port == 0 {
+			log.Warnf("Failed to get random free port: %+v", err)
+			log.Warnf("Falling back to internal port %s (may be blocked though)...", k3d.DefaultAPIPort)
+			freePort = k3d.DefaultAPIPort
 		}
+		exposeAPI.Binding.HostPort = freePort
 	}
 
 	cfg.ExposeAPI = conf.SimpleExposureOpts{

From 0c02607d1e27b57e0342a9c8f5cdab35ffaacda1 Mon Sep 17 00:00:00 2001
From: Mateusz Szostok <szostok.mateusz@gmail.com>
Date: Wed, 18 Aug 2021 13:35:07 +0200
Subject: [PATCH 2/2] [FIX]: import all requested images (#701, @mszostok)

---
 pkg/tools/tools.go      | 10 ++++++---
 pkg/tools/tools_test.go | 46 +++++++++++++++++++++++++++++++++++++++++
 2 files changed, 53 insertions(+), 3 deletions(-)

diff --git a/pkg/tools/tools.go b/pkg/tools/tools.go
index 56866ed3..46eaa7c6 100644
--- a/pkg/tools/tools.go
+++ b/pkg/tools/tools.go
@@ -178,7 +178,11 @@ func ImageImportIntoClusterMulti(ctx context.Context, runtime runtimes.Runtime,
 
 }
 
-func findImages(ctx context.Context, runtime runtimes.Runtime, requestedImages []string) (imagesFromRuntime, imagesFromTar []string, err error) {
+type runtimeImageGetter interface {
+	GetImages(context.Context) ([]string, error)
+}
+
+func findImages(ctx context.Context, runtime runtimeImageGetter, requestedImages []string) (imagesFromRuntime, imagesFromTar []string, err error) {
 	runtimeImages, err := runtime.GetImages(ctx)
 	if err != nil {
 		log.Errorln("Failed to fetch list of existing images from runtime")
@@ -189,14 +193,14 @@ func findImages(ctx context.Context, runtime runtimes.Runtime, requestedImages [
 		if isFile(requestedImage) {
 			imagesFromTar = append(imagesFromTar, requestedImage)
 			log.Debugf("Selected image '%s' is a file", requestedImage)
-			break
+			continue
 		}
 
 		runtimeImage, found := findRuntimeImage(requestedImage, runtimeImages)
 		if found {
 			imagesFromRuntime = append(imagesFromRuntime, runtimeImage)
 			log.Debugf("Selected image '%s' (found as '%s') in runtime", requestedImage, runtimeImage)
-			break
+			continue
 		}
 
 		log.Warnf("Image '%s' is not a file and couldn't be found in the container runtime", requestedImage)
diff --git a/pkg/tools/tools_test.go b/pkg/tools/tools_test.go
index 1e104c07..8fc5f8a7 100644
--- a/pkg/tools/tools_test.go
+++ b/pkg/tools/tools_test.go
@@ -23,7 +23,12 @@ THE SOFTWARE.
 package tools
 
 import (
+	"context"
+	"io/ioutil"
+	"os"
 	"testing"
+
+	"github.com/go-test/deep"
 )
 
 func Test_findRuntimeImage(T *testing.T) {
@@ -170,3 +175,44 @@ func Test_findRuntimeImage(T *testing.T) {
 		})
 	}
 }
+
+func Test_findImages(t *testing.T) {
+	// given
+	tarImage, err := ioutil.TempFile("", "images.tgz")
+	if err != nil {
+		t.Fatal("Failed to create temporary file")
+	}
+	defer os.Remove(tarImage.Name())
+
+	tarImages := []string{tarImage.Name()}
+	runtimeImages := []string{
+		"alpine:version",
+		"busybox:latest",
+	}
+	runtime := &FakeRuntimeImageGetter{runtimeImages: runtimeImages}
+
+	requestedImages := append(runtimeImages, tarImages...)
+
+	// when
+	foundRuntimeImages, foundTarImages, err := findImages(context.Background(), runtime, requestedImages)
+
+	// then
+	if err != nil {
+		t.Errorf("Got unexpected error %v", err)
+	}
+
+	if diff := deep.Equal(foundRuntimeImages, runtimeImages); diff != nil {
+		t.Errorf("Found runtime images\n%+v\ndoes not match expected runtime images\n%+v\nDiff:\n%+v", foundRuntimeImages, runtimeImages, diff)
+	}
+	if diff := deep.Equal(foundTarImages, tarImages); diff != nil {
+		t.Errorf("Found tar images\n%+v\ndoes not match expected tar images\n%+v\nDiff:\n%+v", foundTarImages, runtimeImages, diff)
+	}
+}
+
+type FakeRuntimeImageGetter struct {
+	runtimeImages []string
+}
+
+func (f *FakeRuntimeImageGetter) GetImages(_ context.Context) ([]string, error) {
+	return f.runtimeImages, nil
+}