dev

.actions

@@ -0,0 +1,8 @@
+# Actions 编译部署配置文件，文件格式:YAML
+#
+# 微服务相关配置
+service:
+  origin: bsm
+  image: golang:1.23.1-bookworm
+  describe: system cli cmd
+

cmd/commands/check.go

@@ -0,0 +1,167 @@
+package commands
+
+import (
+	"fmt"
+	"os"
+	"path"
+	"path/filepath"
+	"strings"
+
+	"git.apinb.com/bsm-sdk/engine/env"
+	"git.apinb.com/bsm-sdk/engine/utils"
+	"github.com/spf13/cobra"
+)
+
+type LocalServices struct {
+	Srv          Service
+	LocalVersion string
+}
+
+var checkCmd = &cobra.Command{
+	Use:   "check",
+	Short: "<etc/service/registry> 批量检测微服务和配置并更新.",
+	Run: func(cmd *cobra.Command, args []string) {
+
+		if len(args) != 1 {
+			fmt.Println("check sub command: etc/service/registry")
+			fmt.Println("  etc:      检测并更新本地已经安装的所有微服务的配置文件")
+			fmt.Println("  service:  检测并更新本地已经安装的所有微服务")
+			fmt.Println("  registry: 检测并更新Registry已经发布的所有微服务")
+			return
+		}
+
+		subcmd := strings.ToLower(args[0])
+		switch subcmd {
+		case "etc":
+			// 检测并更新本地已经安装的所有微服务的配置文件
+			ls := getLocalServices()
+			etcExecute(ls)
+		case "service":
+			// 检测并更新本地已经安装的所有微服务
+			ls := getLocalServices()
+			serviceExecute(ls)
+		case "registry":
+			// 检测并更新Registry已经发布的所有微服务
+			rs := getRegistryServices()
+			registryExecute(rs)
+		default:
+			fmt.Println("check sub command: etc/server/registry ")
+			return
+		}
+	},
+}
+
+func etcExecute(ls []LocalServices) {
+	for _, service := range ls {
+		yamlUrl := fmt.Sprintf("%s%s/%s/%s_%s.yaml", service.Srv.OssUrl, service.Srv.EtcPath, env.MeshEnv.Workspace, service.Srv.ServiceKey, env.MeshEnv.RuntimeMode)
+		body, err := utils.HttpGet(yamlUrl)
+		if err != nil {
+			fmt.Println("Check YAML Configure:", yamlUrl, " [ERROR]", err.Error())
+		} else {
+			fmt.Println("Check YAML Configure:", yamlUrl, " [OK]")
+			yamlPath := filepath.Join(env.MeshEnv.Prefix, service.Srv.EtcPath, fmt.Sprintf("%s_%s.yaml", service.Srv.ServiceKey, env.MeshEnv.RuntimeMode))
+			utils.StringToFile(yamlPath, string(body))
+		}
+	}
+}
+
+func getLocalServices() []LocalServices {
+	reles := getRegistryReleases()
+
+	dirFs, err := os.ReadDir(env.MeshEnv.Prefix)
+
+	ls := make([]LocalServices, 0)
+
+	checkError(err)
+
+	for _, v := range reles.Data {
+		var check bool = false
+		for _, srv := range dirFs {
+			if v.ServiceKey == srv.Name() {
+				check = true
+				break
+			}
+		}
+
+		if check {
+			version := getCurrentVersion(v.ServiceKey)
+			if version != " - " {
+
+				ls = append(ls, LocalServices{
+					Srv:          v,
+					LocalVersion: version,
+				})
+			}
+		}
+
+	}
+
+	return ls
+}
+
+func getRegistryServices() []Service {
+	reles := getRegistryReleases()
+
+	rs := make([]Service, 0)
+	for _, srv := range reles.Data {
+		localVersion := getCurrentVersion(srv.ServiceKey)
+		if localVersion == " - " || srv.Version != localVersion {
+			rs = append(rs, srv)
+		}
+	}
+
+	return rs
+}
+
+func serviceExecute(ls []LocalServices) {
+	for _, service := range ls {
+		if service.LocalVersion == service.Srv.Version {
+			fmt.Println("Skip [", service.Srv.ServiceKey, "], already latest version :", service.Srv.Version)
+		} else {
+			service.Srv.Stop()
+			downUrl := service.Srv.OssUrl + service.Srv.FilePath
+			fmt.Println("Update Microservice", service.Srv.ServiceKey, service.Srv.Version, downUrl)
+			binPath := filepath.Join(env.MeshEnv.Prefix, service.Srv.ServiceKey)
+			DownloadFile(downUrl, binPath, func(length, downLen int64) {
+				fmt.Fprintf(os.Stdout, "Total:%d KB, Current:%d KB, Percent:%.2f%%\r", length, downLen, (float32(downLen)/float32(length))*100)
+			})
+			service.Srv.Start()
+		}
+	}
+}
+
+func registryExecute(rs []Service) {
+	if !utils.PathExists(env.MeshEnv.Prefix) {
+		utils.CreateDir(env.MeshEnv.Prefix)
+	}
+	logsPath := path.Join(env.MeshEnv.Prefix, "logs")
+	if !utils.PathExists(logsPath) {
+		utils.CreateDir(logsPath)
+	}
+	etcPath := path.Join(env.MeshEnv.Prefix, "etc")
+	if !utils.PathExists(etcPath) {
+		utils.CreateDir(etcPath)
+	}
+
+	for _, service := range rs {
+		service.Stop()
+
+		yamlUrl := fmt.Sprintf("%s%s/%s/%s_%s.yaml", service.OssUrl, service.EtcPath, env.MeshEnv.Workspace, service.ServiceKey, env.MeshEnv.RuntimeMode)
+		body, err := utils.HttpGet(yamlUrl)
+		checkError(err)
+		fmt.Println("Found Registry YAML Configure:", yamlUrl, " [OK]")
+		yamlPath := filepath.Join(env.MeshEnv.Prefix, service.EtcPath, fmt.Sprintf("%s_%s.yaml", service.ServiceKey, env.MeshEnv.RuntimeMode))
+		utils.StringToFile(yamlPath, string(body))
+
+		downUrl := service.OssUrl + service.FilePath
+		fmt.Println("Found Registry Microservice:", service.ServiceKey, service.Version)
+		binPath := filepath.Join(env.MeshEnv.Prefix, service.ServiceKey)
+		DownloadFile(downUrl, binPath, func(length, downLen int64) {
+			fmt.Fprintf(os.Stdout, "Total:%d KB, Current:%d KB, Percent:%.2f%%\r", length, downLen, (float32(downLen)/float32(length))*100)
+		})
+
+		fmt.Println("Restart Microservice:", service.ServiceKey)
+		service.Start()
+
+	}
+}

cmd/commands/ctl.go

@@ -0,0 +1,47 @@
+package commands
+
+import (
+	"fmt"
+	"path/filepath"
+
+	"git.apinb.com/bsm-sdk/engine/env"
+	"github.com/gookit/goutil/cliutil"
+)
+
+func getFilePath(srv *Service) (binPath, logsPath string) {
+	binPath = filepath.Join(env.MeshEnv.Prefix, srv.ServiceKey)
+	logsPath = filepath.Join(env.MeshEnv.Prefix, "logs", srv.ServiceKey+"-"+srv.Version+".log")
+	return
+}
+
+func (srv *Service) Start() {
+	bin, log := getFilePath(srv)
+
+	cmd := "chmod +x " + bin
+	_, err := cliutil.ShellExec(cmd)
+	checkError(err)
+
+	//nohup ./passport >log/passport.log &
+	cmd = "nohup " + bin + " > " + log + " 2>&1 &"
+	out, err := cliutil.ShellExec(cmd)
+	checkError(err)
+	fmt.Println(string(out))
+}
+
+func (srv *Service) Stop() {
+
+	bin, _ := getFilePath(srv)
+	//killall -9 passport /usr/local/bsm/passport
+	cmd := "-9 " + srv.ServiceKey + " " + bin
+	out, err := cliutil.ExecCmd("killall", cliutil.StringToOSArgs(cmd), env.MeshEnv.Prefix)
+	if err != nil {
+		fmt.Printf("stop error:%s\n", err)
+	} else {
+		fmt.Println(out)
+	}
+}
+
+func (srv *Service) Restart() {
+	srv.Stop()
+	srv.Start()
+}

cmd/commands/ext.go

@@ -0,0 +1,177 @@
+package commands
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	"os"
+	"os/exec"
+	"path/filepath"
+	"strconv"
+	"strings"
+
+	"git.apinb.com/bsm-sdk/engine/env"
+	"git.apinb.com/bsm-sdk/engine/utils"
+)
+
+func getRegistryReleases() Releases {
+	body, err := utils.HttpGet(registryUrl)
+	checkError(err)
+
+	var ms Releases
+	err = json.Unmarshal(body, &ms)
+	checkError(err)
+
+	return ms
+}
+
+func getService(srv string) *Service {
+	reles := getRegistryReleases()
+	for _, v := range reles.Data {
+		if v.ServiceKey == srv {
+			return &v
+		}
+	}
+
+	return nil
+}
+
+func getCurrentVersion(srv string) string {
+	var data map[string]string
+
+	execbin := filepath.Join(env.MeshEnv.Prefix, srv)
+	cmd := exec.Command(execbin, "--json") // 替换为适合操作系统的命令
+	output, err := cmd.Output()
+	if err != nil {
+		return " - "
+	}
+
+	err = json.Unmarshal(output, &data)
+	if err != nil {
+		return " - "
+	}
+
+	if val, ok := data["version"]; ok {
+		return val
+	}
+
+	return " - "
+}
+
+func getProcessInfo(processName string) (string, string) {
+	var info string = " - "
+	cmd := exec.Command("ps", "-eo", "pid,%cpu,%mem,cmd") // 使用ps命令查询进程信息
+	output, err := cmd.Output()                           // 获取命令输出结果
+	if err != nil {
+		return info, info
+	}
+
+	// 将输出按换行符分隔成多行字符串数组
+	lines := strings.Split(string(output), "\n")[1:]
+
+	for _, line := range lines {
+		if strings.Contains(line, processName) {
+			fields := strings.Fields(line) // 将每行按空格分隔为字段数组
+			if len(fields) >= 3 {
+				pid := fields[0]         // PID（进程标识）
+				cpuUsage := fields[1]    // CPU使用情况
+				memoryUsage := fields[2] // 内存使用情况
+				info = fmt.Sprintf("CPU:%s%% / MEM:%s%%", cpuUsage, memoryUsage)
+				return pid, info
+			}
+		}
+	}
+
+	return info, info
+}
+
+func checkProcessRunning(processName string) bool {
+	cmd := exec.Command("ps", "-ef") // 替换为适合操作系统的命令
+	output, err := cmd.Output()
+	if err != nil {
+		return false
+	}
+
+	// 将输出按行分割成切片
+	lines := strings.Split(string(output), "\n")
+
+	for _, line := range lines {
+		if strings.Contains(line, processName) {
+			return true
+		}
+	}
+
+	return false
+}
+
+func DownloadFile(url, saveTo string, fb func(length, downLen int64)) {
+	var (
+		fsize   int64
+		buf     = make([]byte, 32*1024)
+		written int64
+	)
+	//创建一个http client
+	client := new(http.Client)
+	//get方法获取资源
+	resp, err := client.Get(url)
+	if err != nil {
+		fmt.Printf("download %s error:%s\n", url, err)
+		os.Exit(0)
+	}
+	//读取服务器返回的文件大小
+	fsize, err = strconv.ParseInt(resp.Header.Get("Content-Length"), 10, 32)
+	if err != nil {
+		fmt.Println(err)
+	}
+	//创建文件
+	file, err := os.Create(saveTo)
+	file.Chmod(0777)
+	if err != nil {
+		fmt.Printf("Create %s error:%s\n", saveTo, err)
+		os.Exit(0)
+	}
+	defer file.Close()
+	if resp.Body == nil {
+		fmt.Printf("resp %s error:%s\n", url, err)
+		os.Exit(0)
+	}
+	defer resp.Body.Close()
+	//下面是 io.copyBuffer() 的简化版本
+	for {
+		//读取bytes
+		nr, er := resp.Body.Read(buf)
+		if nr > 0 {
+			//写入bytes
+			nw, ew := file.Write(buf[0:nr])
+			//数据长度大于0
+			if nw > 0 {
+				written += int64(nw)
+			}
+			//写入出错
+			if ew != nil {
+				err = ew
+				break
+			}
+			//读取是数据长度不等于写入的数据长度
+			if nr != nw {
+				err = io.ErrShortWrite
+				break
+			}
+		}
+		if er != nil {
+			if er != io.EOF {
+				err = er
+			}
+			break
+		}
+		//没有错误了快使用 callback
+
+		fb(fsize, written)
+	}
+
+	if err != nil {
+		fmt.Printf("callback error:%s\n", err)
+		os.Exit(0)
+	}
+}

cmd/commands/install.go

@@ -0,0 +1,84 @@
+package commands
+
+import (
+	"fmt"
+	"os"
+	"path"
+	"path/filepath"
+
+	"git.apinb.com/bsm-sdk/engine/env"
+	"git.apinb.com/bsm-sdk/engine/utils"
+	"github.com/spf13/cobra"
+)
+
+var installCmd = &cobra.Command{
+	Use:   "install",
+	Short: "<ServiceKey> 安装一个微服务.",
+	Run: func(cmd *cobra.Command, args []string) {
+		if len(args) != 1 {
+			fmt.Println("Please input the name of the microservice to be installed!")
+			return
+		}
+
+		srv := args[0]
+		execbin := filepath.Join(env.MeshEnv.Prefix, srv)
+		binExists := utils.PathExists(execbin)
+		if binExists {
+			fmt.Println(srv, "microservice already exists")
+		} else {
+			installExecute(srv)
+		}
+	},
+}
+
+func installExecute(srv string) {
+	fmt.Println("[1/6] Check local direct[logs,etc].")
+	if !utils.PathExists(env.MeshEnv.Prefix) {
+		utils.CreateDir(env.MeshEnv.Prefix)
+	}
+	logsPath := path.Join(env.MeshEnv.Prefix, "logs")
+	if !utils.PathExists(logsPath) {
+		utils.CreateDir(logsPath)
+	}
+	etcPath := path.Join(env.MeshEnv.Prefix, "etc")
+	if !utils.PathExists(etcPath) {
+		utils.CreateDir(etcPath)
+	}
+
+	fmt.Println("[2/6] Check OS ENV BlocksMesh_Workspace,BlocksMesh_RuntimeMode:", env.MeshEnv.Workspace, ",", env.MeshEnv.RuntimeMode)
+	service, info := getMs(srv)
+	fmt.Println("[3/6] Search Microservice:", info)
+
+	if service != nil {
+
+		yamlUrl := fmt.Sprintf("%s%s/%s/%s_%s.yaml", service.OssUrl, service.EtcPath, env.MeshEnv.Workspace, srv, env.MeshEnv.RuntimeMode)
+		body, err := utils.HttpGet(yamlUrl)
+		checkError(err)
+		fmt.Println("[4/6] Download YAML Configure:", yamlUrl, " [OK]")
+		yamlPath := filepath.Join(env.MeshEnv.Prefix, service.EtcPath, fmt.Sprintf("%s_%s.yaml", srv, env.MeshEnv.RuntimeMode))
+		utils.StringToFile(yamlPath, string(body))
+
+		downUrl := service.OssUrl + service.FilePath
+		fmt.Println("[5/6] Download Binrary File:", downUrl)
+		binPath := filepath.Join(env.MeshEnv.Prefix, srv)
+		DownloadFile(downUrl, binPath, func(length, downLen int64) {
+			fmt.Fprintf(os.Stdout, "Total:%d KB, Current:%d KB, Percent:%.2f%%\r", length, downLen, (float32(downLen)/float32(length))*100)
+		})
+		fmt.Println("[6/6] Download Success!")
+		fmt.Println("[6/6] Restart Microservice:", srv)
+		service.Start()
+		fmt.Println("Install Successful!")
+	}
+
+}
+
+func getMs(srv string) (*Service, string) {
+	reles := getRegistryReleases()
+	for _, v := range reles.Data {
+		if v.ServiceKey == srv {
+			return &v, fmt.Sprintf("Ident:%s, Version:%s, Oss:%s", v.Identity, v.Version, v.OssUrl)
+		}
+	}
+
+	return nil, "Not Found."
+}

cmd/commands/ps.go

@@ -1,11 +1,9 @@
-package cmd
+package commands
 
 import (
 	"encoding/json"
 	"fmt"
-	"os/exec"
 	"path/filepath"
-	"strings"
 	"time"
 
 	"git.apinb.com/bsm-sdk/engine/env"
@@ -15,13 +13,13 @@ import (
 	"github.com/spf13/cobra"
 )
 
-type JSONData struct {
+type Releases struct {
 	Msg  string    `json:"msg"`
 	Code int       `json:"code"`
-	Data []ActionsReleases `json:"data"`
+	Data []Service `json:"data"`
 }
 
-type ActionsReleases struct {
+type Service struct {
 	ID         uint `gorm:"primarykey"`
 	CreatedAt  time.Time
 	UpdatedAt  time.Time
@@ -49,7 +47,7 @@ type PsTable struct {
 
 var psCmd = &cobra.Command{
 	Use:   "ps",
-	Short: "list restiry and local installed microservice.",
+	Short: "列表展示本地已经安装的微服务.",
 	Run: func(cmd *cobra.Command, args []string) {
 		psExecute()
 	},
@@ -61,7 +59,7 @@ func psExecute() {
 	body, err := utils.HttpGet(registryUrl)
 	checkError(err)
 
-	var ms JSONData
+	var ms Releases
 	err = json.Unmarshal(body, &ms)
 	checkError(err)
 
@@ -85,7 +83,8 @@ func psExecute() {
 func getSrvStatus(srv string) PsTable {
 
 	var status string = " - "
-	binExists := utils.PathExists(env.MeshEnv.Prefix + srv)
+	execbin := filepath.Join(env.MeshEnv.Prefix, srv)
+	binExists := utils.PathExists(execbin)
 	if binExists {
 		//status = "\033[32mRunning\033[0m"
 		status = "Running"
@@ -107,71 +106,3 @@ func getSrvStatus(srv string) PsTable {
 	}
 
 }
-
-func getCurrentVersion(srv string) string {
-	var data map[string]string
-
-	execbin := filepath.Join(env.MeshEnv.Prefix, srv)
-	cmd := exec.Command(execbin, "--json") // 替换为适合操作系统的命令
-	output, err := cmd.Output()
-	if err != nil {
-		return " - "
-	}
-
-	err = json.Unmarshal(output, &data)
-	if err != nil {
-		return " - "
-	}
-
-	if val, ok := data["version"]; ok {
-		return val
-	}
-
-	return " - "
-}
-
-func getProcessInfo(processName string) (string, string) {
-	var info string = " - "
-	cmd := exec.Command("ps", "-eo", "pid,%cpu,%mem,cmd") // 使用ps命令查询进程信息
-	output, err := cmd.Output()                           // 获取命令输出结果
-	if err != nil {
-		return info, info
-	}
-
-	// 将输出按换行符分隔成多行字符串数组
-	lines := strings.Split(string(output), "\n")[1:]
-
-	for _, line := range lines {
-		if strings.Contains(line, processName) {
-			fields := strings.Fields(line) // 将每行按空格分隔为字段数组
-			if len(fields) >= 3 {
-				pid := fields[0]         // PID（进程标识）
-				cpuUsage := fields[1]    // CPU使用情况
-				memoryUsage := fields[2] // 内存使用情况
-				info = fmt.Sprintf("CPU:%s%% / MEM:%s%%", cpuUsage, memoryUsage)
-				return pid, info
-			}
-		}
-	}
-
-	return info, info
-}
-
-func checkProcessRunning(processName string) bool {
-	cmd := exec.Command("ps", "-ef") // 替换为适合操作系统的命令
-	output, err := cmd.Output()
-	if err != nil {
-		return false
-	}
-
-	// 将输出按行分割成切片
-	lines := strings.Split(string(output), "\n")
-
-	for _, line := range lines {
-		if strings.Contains(line, processName) {
-			return true
-		}
-	}
-
-	return false
-}

cmd/commands/restart.go

@@ -0,0 +1,72 @@
+package commands
+
+import (
+	"fmt"
+	"os"
+	"path/filepath"
+
+	"git.apinb.com/bsm-sdk/engine/env"
+	"git.apinb.com/bsm-sdk/engine/utils"
+	"github.com/spf13/cobra"
+)
+
+var restartCmd = &cobra.Command{
+	Use:   "restart",
+	Short: "<ServiceKey> 更新一个微服务的服务，并重启该服务.",
+	Run: func(cmd *cobra.Command, args []string) {
+		if len(args) != 1 {
+			fmt.Println("Update a microservice service and restart it!")
+			return
+		}
+
+		srv := args[0]
+		execbin := filepath.Join(env.MeshEnv.Prefix, srv)
+		binExists := utils.PathExists(execbin)
+		if !binExists {
+			fmt.Println(srv, "microservice not install")
+		} else {
+			restartExecute(srv)
+		}
+	},
+}
+
+func restartExecute(srv string) {
+	localVersion := getCurrentVersion(srv)
+	fmt.Println("[1/5] Check local microservice version:", localVersion)
+
+	service := getService(srv)
+	if service == nil {
+		fmt.Println("ERR:", srv, "Not Found!")
+		os.Exit(0)
+	}
+
+	fmt.Println("[2/5] Check registry microservice version:", service.Version)
+
+	service.Stop()
+
+	yamlUrl := fmt.Sprintf("%s%s/%s/%s_%s.yaml", service.OssUrl, service.EtcPath, env.MeshEnv.Workspace, srv, env.MeshEnv.RuntimeMode)
+	body, err := utils.HttpGet(yamlUrl)
+	checkError(err)
+	fmt.Println("[3/5] Download YAML Configure:", yamlUrl, " [OK]")
+	yamlPath := filepath.Join(env.MeshEnv.Prefix, service.EtcPath, fmt.Sprintf("%s_%s.yaml", srv, env.MeshEnv.RuntimeMode))
+	utils.StringToFile(yamlPath, string(body))
+
+	if localVersion != service.Version {
+		downUrl := service.OssUrl + service.FilePath
+		fmt.Println("[4/5] Download Binrary File:", downUrl)
+		binPath := filepath.Join(env.MeshEnv.Prefix, srv)
+		DownloadFile(downUrl, binPath, func(length, downLen int64) {
+			fmt.Fprintf(os.Stdout, "Total:%d KB, Current:%d KB, Percent:%.2f%%\r", length, downLen, (float32(downLen)/float32(length))*100)
+		})
+
+		fmt.Println("[5/5] Start Microservice:", srv)
+		service.Start()
+		fmt.Println("Updated Success!")
+	} else {
+		fmt.Println("[4/5] "+srv+" Already the latest version:", localVersion)
+		fmt.Println("[5/5] Restart Microservice:", srv)
+		service.Start()
+		fmt.Println("Restart Success!")
+	}
+
+}

cmd/commands/root.go

@@ -1,4 +1,4 @@
-package cmd
+package commands
 
 import (
 	"fmt"
@@ -16,13 +16,13 @@ func init() {
 	// get os env.
 	env.NewEnv()
 
-	psCmd.Flags().StringVarP(&registryUrl, "registry", "r", "", "registry url.")
+	rootCmd.Flags().StringVarP(&registryUrl, "registry", "r", "", "registry server url.")
 
 	if registryUrl == "" {
 		registryUrl = env.GetEnvDefault("BlocksMesh_Registry", "http://registry.apinb.com")
 	}
 
-	rootCmd.AddCommand(psCmd)
+	rootCmd.AddCommand(psCmd, installCmd, updateCmd, checkCmd, restartCmd)
 }
 
 var rootCmd = &cobra.Command{

cmd/commands/types.go

@@ -0,0 +1 @@
+package commands

cmd/commands/update.go

@@ -0,0 +1,67 @@
+package commands
+
+import (
+	"fmt"
+	"os"
+	"path/filepath"
+
+	"git.apinb.com/bsm-sdk/engine/env"
+	"git.apinb.com/bsm-sdk/engine/utils"
+	"github.com/spf13/cobra"
+)
+
+var updateCmd = &cobra.Command{
+	Use:   "update",
+	Short: "<ServiceKey> 更新一个微服务至最新版本.",
+	Run: func(cmd *cobra.Command, args []string) {
+		if len(args) != 1 {
+			fmt.Println("Please input the name of the microservice to be updated!")
+			return
+		}
+
+		srv := args[0]
+		execbin := filepath.Join(env.MeshEnv.Prefix, srv)
+		binExists := utils.PathExists(execbin)
+		if !binExists {
+			fmt.Println(srv, "microservice not install")
+		} else {
+			updateExecute(srv)
+		}
+	},
+}
+
+func updateExecute(srv string) {
+	localVersion := getCurrentVersion(srv)
+	fmt.Println("[1/5] Check local microservice version:", localVersion)
+
+	service := getService(srv)
+	if service == nil {
+		fmt.Println("ERR:", srv, "Not Found!")
+		os.Exit(0)
+	}
+
+	fmt.Println("[2/5] Check registry microservice version:", service.Version)
+
+	if localVersion != service.Version {
+		service.Stop()
+
+		yamlUrl := fmt.Sprintf("%s%s/%s/%s_%s.yaml", service.OssUrl, service.EtcPath, env.MeshEnv.Workspace, srv, env.MeshEnv.RuntimeMode)
+		body, err := utils.HttpGet(yamlUrl)
+		checkError(err)
+		fmt.Println("[3/5] Download YAML Configure:", yamlUrl, " [OK]")
+		yamlPath := filepath.Join(env.MeshEnv.Prefix, service.EtcPath, fmt.Sprintf("%s_%s.yaml", srv, env.MeshEnv.RuntimeMode))
+		utils.StringToFile(yamlPath, string(body))
+
+		downUrl := service.OssUrl + service.FilePath
+		fmt.Println("[4/5] Download Binrary File:", downUrl)
+		binPath := filepath.Join(env.MeshEnv.Prefix, srv)
+		DownloadFile(downUrl, binPath, func(length, downLen int64) {
+			fmt.Fprintf(os.Stdout, "Total:%d KB, Current:%d KB, Percent:%.2f%%\r", length, downLen, (float32(downLen)/float32(length))*100)
+		})
+
+		fmt.Println("[5/5] Start Microservice:", srv)
+		service.Start()
+		fmt.Println("Updated Success!")
+	}
+
+}

cmd/main.go

@@ -0,0 +1,14 @@
+package main
+
+import (
+	"fmt"
+
+	"git.apinb.com/bsm-sdk/engine/vars"
+	"git.apinb.com/bsm-tools/bsm/cmd/commands"
+)
+
+func main() {
+	fmt.Printf("Blocks Service Cli Version: %s \n", vars.VERSION)
+
+	commands.Execute()
+}

cmd/types.go

@@ -1 +0,0 @@
-package cmd

go.mod

@@ -1,23 +1,31 @@
 module git.apinb.com/bsm-tools/bsm
 
-go 1.22.0
+go 1.23.1
 
-require git.apinb.com/bsm-sdk/engine v1.0.9
+require git.apinb.com/bsm-sdk/engine v1.2.4
 
 require (
+	github.com/gookit/color v1.5.4 // indirect
 	github.com/inconshreveable/mousetrap v1.1.0 // indirect
+	github.com/oklog/ulid/v2 v2.1.0 // indirect
 	github.com/spf13/pflag v1.0.5 // indirect
+	github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e // indirect
+	golang.org/x/sync v0.8.0 // indirect
+	golang.org/x/sys v0.25.0 // indirect
+	golang.org/x/term v0.24.0 // indirect
+	golang.org/x/text v0.18.0 // indirect
 )
 
 require (
-	github.com/golistic/boxed v0.0.0-20231227175750-bd89723124e7
+	github.com/golistic/boxed v0.0.0-20231227175750-bd89723124e7 // indirect
 	github.com/google/uuid v1.6.0 // indirect
-	github.com/jaevor/go-nanoid v1.3.0 // indirect
+	github.com/gookit/goutil v0.6.16
+	github.com/jaevor/go-nanoid v1.4.0 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
-	github.com/keybase/go-ps v0.0.0-20190827175125-91aafc93ba19
+	github.com/keybase/go-ps v0.0.0-20190827175125-91aafc93ba19 // indirect
 	github.com/modood/table v0.0.0-20220527013332-8d47e76dad33
-	github.com/spf13/cobra v1.8.0
-	github.com/subchen/go-tableify v1.1.0
-	gorm.io/gorm v1.25.7 // indirect
+	github.com/spf13/cobra v1.8.1
+	github.com/subchen/go-tableify v1.1.0 // indirect
+	gorm.io/gorm v1.25.12 // indirect
 )

go.sum

@@ -1,14 +1,25 @@
 git.apinb.com/bsm-sdk/engine v1.0.9 h1:3zPYp8wtBVi7Aeg3H3/q7ZSVDRsGiXxQXwNzyMxfhao=
 git.apinb.com/bsm-sdk/engine v1.0.9/go.mod h1:zCJfxj6RHHVHQmDn+Z2qa5s1qU7a3rTL9AZqEja9vIc=
+git.apinb.com/bsm-sdk/engine v1.2.4 h1:/eIK2nuHgEeJec7P/UCG3cQSiJXnYJ5KBFrdn1q+bW4=
+git.apinb.com/bsm-sdk/engine v1.2.4/go.mod h1:Sazi1hGdcL+mFHACz7caIfuiol02QXKcUuMk5OE4ZlA=
 github.com/cpuguy83/go-md2man/v2 v2.0.3/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
+github.com/cpuguy83/go-md2man/v2 v2.0.4/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
 github.com/golistic/boxed v0.0.0-20231227175750-bd89723124e7 h1:nof2QnZZ42zxwzrWFK/e8CMaN/AXgGX7AGJ/pb8RgBk=
 github.com/golistic/boxed v0.0.0-20231227175750-bd89723124e7/go.mod h1:FB8Aa5H1xlLhPbpXIfP9JcwTt287TCI29X4xCEXaIBg=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/gookit/color v1.5.4 h1:FZmqs7XOyGgCAxmWyPslpiok1k05wmY3SJTytgvYFs0=
+github.com/gookit/color v1.5.4/go.mod h1:pZJOeOS8DM43rXbp4AZo1n9zCU2qjpcRko0b6/QJi9w=
+github.com/gookit/goutil v0.6.15 h1:mMQ0ElojNZoyPD0eVROk5QXJPh2uKR4g06slgPDF5Jo=
+github.com/gookit/goutil v0.6.15/go.mod h1:qdKdYEHQdEtyH+4fNdQNZfJHhI0jUZzHxQVAV3DaMDY=
+github.com/gookit/goutil v0.6.16 h1:9fRMCF4X9abdRD5+2HhBS/GwafjBlTUBjRtA5dgkvuw=
+github.com/gookit/goutil v0.6.16/go.mod h1:op2q8AoPDFSiY2+qkHxcBWQMYxOLQ1GbLXqe7vrwscI=
 github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
 github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
 github.com/jaevor/go-nanoid v1.3.0 h1:nD+iepesZS6pr3uOVf20vR9GdGgJW1HPaR46gtrxzkg=
 github.com/jaevor/go-nanoid v1.3.0/go.mod h1:SI+jFaPuddYkqkVQoNGHs81navCtH388TcrH0RqFKgY=
+github.com/jaevor/go-nanoid v1.4.0 h1:mPz0oi3CrQyEtRxeRq927HHtZCJAAtZ7zdy7vOkrvWs=
+github.com/jaevor/go-nanoid v1.4.0/go.mod h1:GIpPtsvl3eSBsjjIEFQdzzgpi50+Bo1Luk+aYlbJzlc=
 github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
 github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=
 github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
@@ -17,14 +28,39 @@ github.com/keybase/go-ps v0.0.0-20190827175125-91aafc93ba19 h1:WjT3fLi9n8YWh/Ih8
 github.com/keybase/go-ps v0.0.0-20190827175125-91aafc93ba19/go.mod h1:hY+WOq6m2FpbvyrI93sMaypsttvaIL5nhVR92dTMUcQ=
 github.com/modood/table v0.0.0-20220527013332-8d47e76dad33 h1:T5IbS9C1G2zeHb6eBy6OfIvj5tfQB23kGFpewCJuGDg=
 github.com/modood/table v0.0.0-20220527013332-8d47e76dad33/go.mod h1:41qyXVI5QH9/ObyPj27CGCVau5v/njfc3Gjj7yzr0HQ=
+github.com/oklog/ulid/v2 v2.1.0 h1:+9lhoxAP56we25tyYETBBY1YLA2SaoLvUFgrP2miPJU=
+github.com/oklog/ulid/v2 v2.1.0/go.mod h1:rcEKHmBBKfef9DhnvX7y1HZBYxjXb0cP5ExxNsTT1QQ=
+github.com/pborman/getopt v0.0.0-20170112200414-7148bc3a4c30/go.mod h1:85jBQOZwpVEaDAr341tbn15RS4fCAsIst0qp7i8ex1o=
 github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
 github.com/spf13/cobra v1.8.0 h1:7aJaZx1B85qltLMc546zn58BxxfZdR/W22ej9CFoEf0=
 github.com/spf13/cobra v1.8.0/go.mod h1:WXLWApfZ71AjXPya3WOlMsY9yMs7YeiHhFVlvLyhcho=
+github.com/spf13/cobra v1.8.1 h1:e5/vxKd/rZsfSJMUX1agtjeTDf+qv1/JdBF8gg5k9ZM=
+github.com/spf13/cobra v1.8.1/go.mod h1:wHxEcudfqmLYa8iTfL+OuZPbBZkmvliBWKIezN3kD9Y=
 github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
 github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/subchen/go-tableify v1.1.0 h1:VUCCHfXlttR5LhjjEmCThdI0UdYKr/7OnOey78UClrY=
 github.com/subchen/go-tableify v1.1.0/go.mod h1:a4dTYdYueMaCd4MU4V7q9XDjkDhQ/EhlKyQb4WaSCWw=
+github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e h1:JVG44RsyaB9T2KIHavMF/ppJZNG9ZpyihvCd0w101no=
+github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e/go.mod h1:RbqR21r5mrJuqunuUZ/Dhy/avygyECGrLceyNeo4LiM=
+golang.org/x/sync v0.5.0 h1:60k92dhOjHxJkrqnwsfl8KuaHbn/5dl0lUPUklKo3qE=
+golang.org/x/sync v0.5.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sync v0.8.0 h1:3NFvSEYkUoMifnESzZl15y791HH1qU2xm6eCJU5ZPXQ=
+golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sys v0.15.0 h1:h48lPFYpsTvQJZF4EKyI4aLHaev3CxivZmv7yZig9pc=
+golang.org/x/sys v0.15.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.25.0 h1:r+8e+loiHxRqhXVl6ML1nO3l1+oFoWbnlu2Ehimmi34=
+golang.org/x/sys v0.25.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/term v0.15.0 h1:y/Oo/a/q3IXu26lQgl04j/gjuBDOBlx7X6Om1j2CPW4=
+golang.org/x/term v0.15.0/go.mod h1:BDl952bC7+uMoWR75FIrCDx79TPU9oHkTZ9yRbYOrX0=
+golang.org/x/term v0.24.0 h1:Mh5cbb+Zk2hqqXNO7S1iTjEphVL+jb8ZWaqh/g+JWkM=
+golang.org/x/term v0.24.0/go.mod h1:lOBK/LVxemqiMij05LGJ0tzNr8xlmwBRJ81PX6wVLH8=
+golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
+golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
+golang.org/x/text v0.18.0 h1:XvMDiNzPAl0jr17s6W9lcaIhGUfUORdGCNsuLmPG224=
+golang.org/x/text v0.18.0/go.mod h1:BuEKDfySbSR4drPmRPG/7iBdf8hvFMuRexcpahXilzY=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gorm.io/gorm v1.25.7 h1:VsD6acwRjz2zFxGO50gPO6AkNs7KKnvfzUjHQhZDz/A=
 gorm.io/gorm v1.25.7/go.mod h1:hbnx/Oo0ChWMn1BIhpy1oYozzpM15i4YPuHDmfYtwg8=
+gorm.io/gorm v1.25.12 h1:I0u8i2hWQItBq1WfE0o2+WuL9+8L21K9e2HHSTE/0f8=
+gorm.io/gorm v1.25.12/go.mod h1:xh7N7RHfYlNc5EmcI/El95gXusucDrQnHXe0+CgWcLQ=

main.go

@@ -1,7 +0,0 @@
-package main
-
-import "git.apinb.com/bsm-tools/bsm/cmd"
-
-func main() {
-	cmd.Execute()
-}