Initial windows configurer

Signed-off-by: Kimmo Lehto <[email protected]>

Author: kke

configurer/interface.go

@@ -0,0 +1,61 @@
+package configurer
+
+import (
+	"time"
+
+	"github.com/k0sproject/rig/exec"
+	"github.com/k0sproject/rig/os"
+)
+
+// Configurer defines the per-host operations required for managing a host.
+type Configurer interface {
+	Kind() string
+	OSKind() string
+	CheckPrivilege(os.Host) error
+	StartService(os.Host, string) error
+	StopService(os.Host, string) error
+	RestartService(os.Host, string) error
+	ServiceIsRunning(os.Host, string) bool
+	Arch(os.Host) (string, error)
+	K0sCmdf(string, ...interface{}) string
+	K0sBinaryPath() string
+	K0sConfigPath() string
+	DataDirDefaultPath() string
+	K0sJoinTokenPath() string
+	WriteFile(os.Host, string, string, string) error
+	UpdateEnvironment(os.Host, map[string]string) error
+	DaemonReload(os.Host) error
+	ReplaceK0sTokenPath(os.Host, string) error
+	ServiceScriptPath(os.Host, string) (string, error)
+	ReadFile(os.Host, string) (string, error)
+	FileExist(os.Host, string) bool
+	Chmod(os.Host, string, string, ...exec.Option) error
+	Chown(os.Host, string, string, ...exec.Option) error
+	DownloadURL(os.Host, string, string, ...exec.Option) error
+	InstallPackage(os.Host, ...string) error
+	FileContains(os.Host, string, string) bool
+	MoveFile(os.Host, string, string) error
+	MkDir(os.Host, string, ...exec.Option) error
+	DeleteFile(os.Host, string) error
+	CommandExist(os.Host, string) bool
+	Hostname(os.Host) string
+	KubectlCmdf(os.Host, string, string, ...interface{}) string
+	KubeconfigPath(os.Host, string) string
+	IsContainer(os.Host) bool
+	FixContainer(os.Host) error
+	HTTPStatus(os.Host, string) (int, error)
+	PrivateInterface(os.Host) (string, error)
+	PrivateAddress(os.Host, string, string) (string, error)
+	TempDir(os.Host) (string, error)
+	TempFile(os.Host) (string, error)
+	UpdateServiceEnvironment(os.Host, string, map[string]string) error
+	CleanupServiceEnvironment(os.Host, string) error
+	Stat(os.Host, string, ...exec.Option) (*os.FileInfo, error)
+	DeleteDir(os.Host, string, ...exec.Option) error
+	K0sctlLockFilePath(os.Host) string
+	UpsertFile(os.Host, string, string) error
+	MachineID(os.Host) (string, error)
+	SetPath(string, string)
+	SystemTime(os.Host) (time.Time, error)
+	Touch(os.Host, string, time.Time, ...exec.Option) error
+}

configurer/linux.go

@@ -12,13 +12,18 @@ import (
 	"al.essio.dev/pkg/shellescape"
 	"github.com/k0sproject/rig/exec"
 	"github.com/k0sproject/rig/os"
-	"github.com/k0sproject/version"
 )
 
 // Linux is a base module for various linux OS support packages
 type Linux struct {
-	paths  map[string]string
-	pathMu sync.Mutex
+	paths    map[string]string
+	pathMu   sync.RWMutex
+	pathOnce sync.Once
+}
+
+// OSKind returns the identifier for Linux hosts
+func (l *Linux) OSKind() string {
+	return "linux"
 }
 
 // NOTE The Linux struct does not embed rig/os.Linux because it will confuse
@@ -30,59 +35,48 @@ type Linux struct {
 // path as a parameter.
 
 func (l *Linux) initPaths() {
-	if l.paths != nil {
-		return
-	}
-	l.paths = map[string]string{
-		"K0sBinaryPath":      "/usr/local/bin/k0s",
-		"K0sConfigPath":      "/etc/k0s/k0s.yaml",
-		"K0sJoinTokenPath":   "/etc/k0s/k0stoken",
-		"DataDirDefaultPath": "/var/lib/k0s",
-	}
+	l.pathOnce.Do(func() {
+		l.paths = map[string]string{
+			"K0sBinaryPath":      "/usr/local/bin/k0s",
+			"K0sConfigPath":      "/etc/k0s/k0s.yaml",
+			"K0sJoinTokenPath":   "/etc/k0s/k0stoken",
+			"DataDirDefaultPath": "/var/lib/k0s",
+		}
+	})
+}
+
+func (l *Linux) path(key string) string {
+	l.initPaths()
+	l.pathMu.RLock()
+	defer l.pathMu.RUnlock()
+	return l.paths[key]
 }
 
 // K0sBinaryPath returns the path to the k0s binary on the host
 func (l *Linux) K0sBinaryPath() string {
-	l.pathMu.Lock()
-	defer l.pathMu.Unlock()
-
-	l.initPaths()
-	return l.paths["K0sBinaryPath"]
+	return l.path("K0sBinaryPath")
 }
 
 // K0sConfigPath returns the path to the k0s config file on the host
 func (l *Linux) K0sConfigPath() string {
-	l.pathMu.Lock()
-	defer l.pathMu.Unlock()
-
-	l.initPaths()
-	return l.paths["K0sConfigPath"]
+	return l.path("K0sConfigPath")
 }
 
 // K0sJoinTokenPath returns the path to the k0s join token file on the host
 func (l *Linux) K0sJoinTokenPath() string {
-	l.pathMu.Lock()
-	defer l.pathMu.Unlock()
-
-	l.initPaths()
-	return l.paths["K0sJoinTokenPath"]
+	return l.path("K0sJoinTokenPath")
 }
 
 // DataDirDefaultPath returns the path to the k0s data dir on the host
 func (l *Linux) DataDirDefaultPath() string {
-	l.pathMu.Lock()
-	defer l.pathMu.Unlock()
-
-	l.initPaths()
-	return l.paths["DataDirDefaultPath"]
+	return l.path("DataDirDefaultPath")
 }
 
 // SetPath sets a path for a key
 func (l *Linux) SetPath(key, value string) {
+	l.initPaths()
 	l.pathMu.Lock()
 	defer l.pathMu.Unlock()
-
-	l.initPaths()
 	l.paths[key] = value
 }
 
@@ -109,21 +103,6 @@ func (l *Linux) K0sCmdf(template string, args ...interface{}) string {
 	return fmt.Sprintf("%s %s", l.K0sBinaryPath(), fmt.Sprintf(template, args...))
 }
 
-func (l *Linux) K0sBinaryVersion(h os.Host) (*version.Version, error) {
-	k0sVersionCmd := l.K0sCmdf("version")
-	output, err := h.ExecOutput(k0sVersionCmd, exec.Sudo(h))
-	if err != nil {
-		return nil, err
-	}
-
-	version, err := version.NewVersion(output)
-	if err != nil {
-		return nil, err
-	}
-
-	return version, nil
-}
-
 // K0sctlLockFilePath returns a path to a lock file
 func (l *Linux) K0sctlLockFilePath(h os.Host) string {
 	if h.Exec("test -d /run/lock", exec.Sudo(h)) == nil {
@@ -168,17 +147,6 @@ func (l *Linux) DownloadURL(h os.Host, url, destination string, opts ...exec.Opt
 	return nil
 }
 
-// DownloadK0s performs k0s binary download from github on the host
-func (l *Linux) DownloadK0s(h os.Host, path string, version *version.Version, arch string, opts ...exec.Option) error {
-	v := strings.ReplaceAll(strings.TrimPrefix(version.String(), "v"), "+", "%2B")
-	url := fmt.Sprintf("https://github.com/k0sproject/k0s/releases/download/v%[1]s/k0s-v%[1]s-%[2]s", v, arch)
-	if err := l.DownloadURL(h, url, path, opts...); err != nil {
-		return fmt.Errorf("failed to download k0s - check connectivity and k0s version validity: %w", err)
-	}
-
-	return nil
-}
-
 // ReplaceK0sTokenPath replaces the config path in the service stub
 func (l *Linux) ReplaceK0sTokenPath(h os.Host, spath string) error {
 	return h.Exec(fmt.Sprintf("sed -i 's^REPLACEME^%s^g' %s", l.K0sJoinTokenPath(), spath))
@@ -194,6 +162,15 @@ func (l *Linux) MoveFile(h os.Host, src, dst string) error {
 	return h.Execf(`mv "%s" "%s"`, src, dst, exec.Sudo(h))
 }
 
+// Chown sets owner for a file or directory
+func (l *Linux) Chown(h os.Host, path, owner string, opts ...exec.Option) error {
+	if len(opts) == 0 {
+		opts = []exec.Option{exec.Sudo(h)}
+	}
+	cmd := fmt.Sprintf(`chown %s %s`, shellescape.Quote(owner), shellescape.Quote(path))
+	return h.Exec(cmd, opts...)
+}
+
 // KubeconfigPath returns the path to a kubeconfig on the host
 func (l *Linux) KubeconfigPath(h os.Host, dataDir string) string {
 	linux := &os.Linux{}

configurer/linux/alpine.go

@@ -21,6 +21,8 @@ type Alpine struct {
 	BaseLinux
 }
 
+var _ configurer.Configurer = (*Alpine)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/archlinux.go

@@ -13,6 +13,8 @@ type Archlinux struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*Archlinux)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/coreos.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"strings"
 
+	"github.com/k0sproject/k0sctl/configurer"
 	"github.com/k0sproject/rig"
 	"github.com/k0sproject/rig/os"
 	"github.com/k0sproject/rig/os/registry"
@@ -15,6 +16,8 @@ type CoreOS struct {
 	BaseLinux
 }
 
+var _ configurer.Configurer = (*CoreOS)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/debian.go

@@ -13,6 +13,8 @@ type Debian struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*Debian)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/enterpriselinux/almalinux.go

@@ -13,6 +13,8 @@ type AlmaLinux struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*AlmaLinux)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/enterpriselinux/amazon.go

@@ -14,6 +14,8 @@ type AmazonLinux struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*AmazonLinux)(nil)
+
 // Hostname on amazon linux will return the full hostname
 func (l *AmazonLinux) Hostname(h os.Host) string {
 	hostname, _ := h.ExecOutput("hostname")

configurer/linux/enterpriselinux/centos.go

@@ -13,6 +13,8 @@ type CentOS struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*CentOS)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/enterpriselinux/fedora.go

@@ -15,6 +15,8 @@ type Fedora struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*Fedora)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {