kmeshctl install

ctl/common/common.go

@@ -26,6 +26,7 @@ import (
 	"kmesh.net/kmesh/ctl/secret"
 	"kmesh.net/kmesh/ctl/version"
 	"kmesh.net/kmesh/ctl/waypoint"
+	"kmesh.net/kmesh/ctl/install"
 )
 
 func GetRootCommand() *cobra.Command {
@@ -45,6 +46,7 @@ func GetRootCommand() *cobra.Command {
 	rootCmd.AddCommand(monitoring.NewCmd())
 	rootCmd.AddCommand(authz.NewCmd())
 	rootCmd.AddCommand(secret.NewCmd())
+	rootCmd.AddCommand(install.NewCmd())
 
 	return rootCmd
 }

ctl/install/install.go

@@ -0,0 +1,123 @@
+/*
+ * Copyright The Kmesh Authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package install
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"log"
+	"net/http"
+	"os"
+	"path/filepath"
+	"strings"
+
+	"github.com/spf13/cobra"
+
+	"kmesh.net/kmesh/ctl/utils"
+)
+
+type GitHubFile struct {
+	Name        string `json:"name"`
+	DownloadURL string `json:"download_url"`
+}
+
+func NewCmd() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "install",
+		Short: "install Kmesh with all the resources",
+		Example: `# Install all Kmesh resources (defaults to main):
+kmeshctl install
+
+# Install a specific version of Kmesh
+kmeshctl install --version 0.5.0`,
+		Run: func(cmd *cobra.Command, args []string) {
+			version, err := cmd.Flags().GetString("version")
+			if err != nil {
+				log.Fatal(err)
+			}
+
+			cli, err := utils.CreateKubeClient()
+			if err != nil {
+				log.Fatalf("failed to create cli client: %v", err)
+				os.Exit(1)
+			}
+
+			fmt.Println("install kmesh version: ", version)
+			combinedYAMLFile := getYAMLFile(version)
+
+			if version != "main" {
+				versionYaml := strings.Replace(combinedYAMLFile, ":latest", ":"+version, -1)
+
+				err = cli.ApplyYAMLContents("", versionYaml)
+				if err != nil {
+					log.Fatal(err)
+				}
+			} else {
+				err = cli.ApplyYAMLContents("", combinedYAMLFile)
+				if err != nil {
+					log.Fatal(err)
+				}
+			}
+		},
+	}
+
+	cmd.Flags().String("version", "main", "Version of the resources to initialize")
+	return cmd
+}
+
+func getYAMLFile(version string) string {
+	var url string
+	if version != "main" {
+		url = fmt.Sprintf("https://api.github.com/repos/kmesh-net/kmesh/contents/deploy/yaml?ref=v%s", version)
+	} else {
+		url = "https://api.github.com/repos/kmesh-net/kmesh/contents/deploy/yaml?ref=main"
+	}
+
+	resp, err := http.Get(url)
+	if err != nil {
+		log.Fatal("error fetching files: ", err)
+	}
+	defer resp.Body.Close()
+
+	var files []GitHubFile
+	err = json.NewDecoder(resp.Body).Decode(&files)
+	if err != nil {
+		log.Fatal("error decoding JSON:", err)
+	}
+
+	var combinedYAML string
+
+	for _, file := range files {
+		if filepath.Ext(file.Name) == ".yaml" {
+			resp, err := http.Get(file.DownloadURL)
+			if err != nil {
+				log.Fatal(err)
+			}
+			defer resp.Body.Close()
+
+			deployYaml, err := io.ReadAll(resp.Body)
+			if err != nil {
+				log.Fatalf("yamlFile.Get err: %v ", err)
+			}
+
+			combinedYAML += string(deployYaml) + "\n---\n"
+		}
+	}
+
+	return combinedYAML
+}

pkg/kube/client.go

@@ -30,6 +30,7 @@ import (
 	"k8s.io/client-go/rest"
 	"k8s.io/utils/ptr"
 	gatewayapiclient "sigs.k8s.io/gateway-api/pkg/client/clientset/versioned"
+	istio "istio.io/istio/pkg/kube"
 )
 
 const (
@@ -57,6 +58,8 @@ type CLIClient interface {
 	// NewPortForwarder creates a new PortForwarder configured for the given pod. If localPort=0, a port will be
 	// dynamically selected. If localAddress is empty, "localhost" is used.
 	NewPortForwarder(podName string, ns string, localAddress string, localPort int, podPort int) (PortForwarder, error)
+
+	ApplyYAMLContents(namespace string, yamls ...string) error 
 }
 
 func NewCLIClient(opts ...ClientOption) (CLIClient, error) {
@@ -71,6 +74,12 @@ type client struct {
 	kube          kubernetes.Interface
 	gatewayapi    gatewayapiclient.Interface
 	clientFactory *genericclioptions.ConfigFlags
+	istioClient   istio.CLIClient
+}
+
+func (c *client) ApplyYAMLContents(namespace string, yamls ...string) error {
+	c.istioClient, _ = istio.NewCLIClient(istio.NewClientConfigForRestConfig(c.config))
+	return c.istioClient.ApplyYAMLContents(namespace, yamls...)
 }
 
 func (c *client) NewPortForwarder(podName string, ns string, localAddress string, localPort int, podPort int) (PortForwarder, error) {