refactor: integrate CLI's code & CI into main repo (#1343)

cli/pkg/phase/cluster/add_node.go

@@ -0,0 +1,84 @@
+package cluster
+
+import (
+	"bytetrade.io/web3os/installer/pkg/bootstrap/os"
+	"bytetrade.io/web3os/installer/pkg/common"
+	"bytetrade.io/web3os/installer/pkg/core/logger"
+	"bytetrade.io/web3os/installer/pkg/core/module"
+	"bytetrade.io/web3os/installer/pkg/core/pipeline"
+	"bytetrade.io/web3os/installer/pkg/k3s"
+	"bytetrade.io/web3os/installer/pkg/kubernetes"
+	"bytetrade.io/web3os/installer/pkg/manifest"
+	"bytetrade.io/web3os/installer/pkg/storage"
+	"bytetrade.io/web3os/installer/pkg/terminus"
+)
+
+func AddNodePhase(runtime *common.KubeRuntime) *pipeline.Pipeline {
+	var err error
+	var manifestMap manifest.InstallationManifest
+	manifestMap, err = manifest.ReadAll(runtime.Arg.Manifest)
+	if err != nil {
+		logger.Fatal(err)
+	}
+
+	var m []module.Module
+	m = append(m,
+		&terminus.GetMasterInfoModule{},
+		&terminus.CheckPreparedModule{Force: true},
+		&storage.InstallJuiceFsModule{
+			ManifestModule: manifest.ManifestModule{
+				Manifest: manifestMap,
+				BaseDir:  runtime.GetBaseDir(),
+			},
+		},
+		&AddNodeModule{
+			ManifestModule: manifest.ManifestModule{
+				Manifest: manifestMap,
+				BaseDir:  runtime.GetBaseDir(),
+			},
+		},
+	)
+
+	m = append(m, &terminus.SaveMasterHostConfigModule{}, &terminus.InstalledModule{})
+
+	return &pipeline.Pipeline{
+		Name:    "Add Worker Node To The Cluster",
+		Modules: m,
+		Runtime: runtime,
+	}
+}
+
+type AddNodeModule struct {
+	common.KubeModule
+	manifest.ManifestModule
+	underlyingModules []module.TaskModule
+}
+
+func (m *AddNodeModule) Init() {
+	m.Name = "JoinKubernetesCluster"
+	if m.KubeConf.Arg.Kubetype == common.K8s {
+		m.underlyingModules = []module.TaskModule{
+			&kubernetes.StatusModule{},
+			&os.ConfigureOSModule{},
+			&kubernetes.InstallKubeBinariesModule{
+				ManifestModule: m.ManifestModule,
+			},
+			&kubernetes.JoinNodesModule{},
+		}
+	} else {
+		m.underlyingModules = []module.TaskModule{
+			&k3s.StatusModule{},
+			&os.ConfigureOSModule{},
+			&k3s.InstallKubeBinariesModule{
+				ManifestModule: m.ManifestModule,
+			},
+			&k3s.JoinNodesModule{},
+		}
+	}
+	for _, underlyingModule := range m.underlyingModules {
+		underlyingModule.Default(m.Runtime, m.PipelineCache, m.ModuleCache)
+		underlyingModule.AutoAssert()
+		underlyingModule.Init()
+		m.Tasks = append(m.Tasks, underlyingModule.GetTasks()...)
+	}
+}