Initial HV=kubevirt eve test for node ready.

Simply check that the local node is ready after boot.

Signed-off-by: Andrew Durbin <andrewd@zededa.com>

Author: andrewd-zededa

tests/kubevirt/Makefile

@@ -0,0 +1,75 @@
+DEBUG ?= "debug"
+
+# HOSTARCH is the host architecture
+# ARCH is the target architecture
+# we need to keep track of them separately
+HOSTARCH ?= $(shell uname -m)
+HOSTOS ?= $(shell uname -s | tr A-Z a-z)
+
+# canonicalized names for host architecture
+override HOSTARCH := $(subst aarch64,arm64,$(subst x86_64,amd64,$(HOSTARCH)))
+
+# unless otherwise set, I am building for my own architecture, i.e. not cross-compiling
+# and for my OS
+ARCH ?= $(HOSTARCH)
+OS ?= $(HOSTOS)
+
+# canonicalized names for target architecture
+override ARCH := $(subst aarch64,arm64,$(subst x86_64,amd64,$(ARCH)))
+
+WORKDIR ?= $(CURDIR)/../../dist
+TESTDIR := tests/$(shell basename $(CURDIR))
+BINDIR := $(WORKDIR)/bin
+DATADIR := $(WORKDIR)/$(TESTDIR)/
+BIN := eden
+LOCALBIN := $(BINDIR)/$(BIN)-$(OS)-$(ARCH)
+TESTNAME := eden.kubevirt
+TESTBIN := $(TESTNAME).test
+TESTSCN := $(TESTNAME).tests.txt
+LOCALTESTBIN := $(TESTBIN)-$(OS)-$(ARCH)
+LINKDIR := ../../tests/kubevirt
+
+.DEFAULT_GOAL := help
+
+clean:
+	rm -rf $(LOCALTESTBIN) $(BINDIR)/$(TESTBIN) $(WORKDIR)/$(TESTSCN) $(CURDIR)/$(TESTBIN) $(BINDIR)/$(TESTBIN)
+
+$(BINDIR):
+	mkdir -p $@
+$(DATADIR):
+	mkdir -p $@
+
+test_kubevirt:
+	go test kubevirt_test.go common.go -v -count=1 -timeout 3000s
+
+test:
+	$(LOCALBIN) test $(CURDIR) -v $(DEBUG) -s eden.kubevirt.tests.txt
+
+build: setup
+
+testbin: $(TESTBIN)
+$(LOCALTESTBIN): $(BINDIR) *.go
+	CGO_ENABLED=0 GOOS=$(OS) GOARCH=$(ARCH) go test -c -ldflags "-s -w" -o $@ *.go
+
+$(TESTBIN): $(LOCALTESTBIN)
+	ln -sf $(LOCALTESTBIN) $(CURDIR)/$(TESTBIN)
+
+setup: testbin $(BINDIR) $(DATADIR)
+	cp -a $(LOCALTESTBIN) $(CURDIR)/$(TESTBIN) $(BINDIR)
+	cp -a *.yml $(TESTSCN) $(DATADIR)
+
+.PHONY: test build setup clean all testbin
+
+help:
+	@echo "EDEN is the harness for testing EVE and ADAM"
+	@echo
+	@echo "This Makefile automates commons tasks of EDEN testing"
+	@echo
+	@echo "Commonly used maintenance and development targets:"
+	@echo "   build         build test-binary (OS and ARCH options supported, for ex. OS=linux ARCH=arm64)"
+	@echo "   setup         setup of test environment"
+	@echo "   test          run tests"
+	@echo "   clean         cleanup of test harness"
+	@echo
+	@echo "You need install requirements for EVE (look at https://github.com/lf-edge/eve#install-dependencies)."
+	@echo "You need access to docker socket and installed qemu packages."

tests/kubevirt/eden-config.yml

@@ -0,0 +1,7 @@
+---
+eden:
+    # test binary
+    test-bin: "eden.kubevirt.test"
+
+    # test scenario
+    test-scenario: "eden.kubevirt.tests.txt"

tests/kubevirt/eden.kubevirt.tests.txt

@@ -0,0 +1 @@
+eden.kubevirt.test

tests/kubevirt/kubevirt_test.go

@@ -0,0 +1,89 @@
+package kubevirt_test
+
+import (
+	"os"
+	"path/filepath"
+	"strings"
+	"testing"
+	"time"
+
+	"github.com/lf-edge/eden/pkg/defaults"
+	tk "github.com/lf-edge/eden/pkg/evetestkit"
+	"github.com/lf-edge/eden/pkg/openevec"
+	"github.com/lf-edge/eden/pkg/utils"
+	log "github.com/sirupsen/logrus"
+)
+
+const projectName = "kubevirt-test"
+const k3sNodeReadyStatusCmd = "eve exec kube /usr/bin/kubectl get node -o jsonpath='{.items[].status.conditions[?(@.type==\"Ready\")].status}'"
+const hvTypeKubevirt = "kubevirt"
+
+var eveNode *tk.EveNode
+
+func TestMain(m *testing.M) {
+	log.Println("Kubevirt Test Suite started")
+	defer log.Println("Kubevirt Suite finished")
+
+	currentPath, err := os.Getwd()
+	if err != nil {
+		log.Fatal(err)
+	}
+	twoLevelsUp := filepath.Dir(filepath.Dir(currentPath))
+
+	configPath := utils.GetConfig("default")
+	cfg, err := openevec.LoadConfig(configPath)
+	if err != nil {
+		log.Fatalf("Failed to get config %v\n", err)
+	}
+
+	if cfg.Eve.HV != hvTypeKubevirt {
+		log.Fatalf("Incorrect eve.hv value %s, test only supports kubevirt", cfg.Eve.HV)
+	}
+
+	evec := openevec.CreateOpenEVEC(cfg)
+	configDir := filepath.Join(twoLevelsUp, "eve-config-dir")
+	if err := evec.SetupEden("config", configDir, "", "", "", []string{}, false, false); err != nil {
+		log.Fatalf("Failed to setup Eden: %v", err)
+	}
+	if err := evec.StartEden(defaults.DefaultVBoxVMName, "", ""); err != nil {
+		log.Fatalf("Start eden failed: %s", err)
+	}
+	if err := evec.OnboardEve(cfg.Eve.CertsUUID); err != nil {
+		log.Fatalf("Eve onboard failed: %s", err)
+	}
+
+	node, err := tk.InitializeTestFromConfig(projectName, cfg, tk.WithControllerVerbosity("debug"))
+	if err != nil {
+		log.Fatalf("Failed to initialize test: %v", err)
+	}
+
+	eveNode = node
+	res := m.Run()
+	os.Exit(res)
+}
+
+// TestNodeReady to verify the kubernetes control plane becomes ready.
+func TestNodeReady(t *testing.T) {
+	log.Println("TestNodeReady started")
+	defer log.Println("TestNodeReady finished")
+
+	maxTries := 20 // 5 minutes of once every 15sec
+	attempt := 1
+
+	for attempt < maxTries {
+		out, err := eveNode.EveRunCommand(k3sNodeReadyStatusCmd)
+		if err == nil {
+			condition := strings.TrimSpace(string(out))
+			if condition == "True" {
+				t.Logf("k3s node ready")
+				return
+			}
+		}
+
+		t.Logf("Warn: node ready command returned err:%v out:%s", err, string(out))
+		time.Sleep(15 * time.Second)
+		attempt++
+	}
+
+	t.Fatalf("k3s node did not become ready")
+}