API RPC配置增加disableUpdate，可以停用自动更新API节点

internal/configs/api_config.go

@@ -13,6 +13,7 @@ import (
 type APIConfig struct {
 	RPC struct {
 		Endpoints     []string `yaml:"endpoints"`
+		DisableUpdate bool     `yaml:"disableUpdate"`
 	} `yaml:"rpc"`
 	NodeId string `yaml:"nodeId"`
 	Secret string `yaml:"secret"`

internal/tasks/task_sync_api_nodes.go

@@ -58,6 +58,16 @@ func (this *SyncAPINodesTask) Loop() error {
 		return nil
 	}
 
+	config, err := configs.LoadAPIConfig()
+	if err != nil {
+		return err
+	}
+
+	// 是否禁止自动升级
+	if config.RPC.DisableUpdate {
+		return nil
+	}
+
 	// 获取所有可用的节点
 	rpcClient, err := rpc.SharedRPC()
 	if err != nil {
@@ -68,7 +78,7 @@ func (this *SyncAPINodesTask) Loop() error {
 		return err
 	}
 
-	newEndpoints := []string{}
+	var newEndpoints = []string{}
 	for _, node := range resp.ApiNodes {
 		if !node.IsOn {
 			continue
@@ -77,10 +87,6 @@ func (this *SyncAPINodesTask) Loop() error {
 	}
 
 	// 和现有的对比
-	config, err := configs.LoadAPIConfig()
-	if err != nil {
-		return err
-	}
 	if this.isSame(newEndpoints, config.RPC.Endpoints) {
 		return nil
 	}

internal/web/actions/default/nodes/nodeutils/utils.go

@@ -103,6 +103,7 @@ func SendMessageToCluster(ctx context.Context, clusterId int64, code string, msg
 			apiRPCClient, err := rpc.NewRPCClient(&configs.APIConfig{
 				RPC: struct {
 					Endpoints     []string `yaml:"endpoints"`
+					DisableUpdate bool     `yaml:"disableUpdate"`
 				}{
 					Endpoints: apiNode.AccessAddrs,
 				},
@@ -283,6 +284,7 @@ func SendMessageToNodeIds(ctx context.Context, nodeIds []int64, code string, msg
 			apiRPCClient, err := rpc.NewRPCClient(&configs.APIConfig{
 				RPC: struct {
 					Endpoints     []string `yaml:"endpoints"`
+					DisableUpdate bool     `yaml:"disableUpdate"`
 				}{
 					Endpoints: apiNode.AccessAddrs,
 				},

internal/web/actions/default/recover/updateHosts.go

@@ -37,6 +37,7 @@ func (this *UpdateHostsAction) RunPost(params struct {
 	client, err := rpc.NewRPCClient(&configs.APIConfig{
 		RPC: struct {
 			Endpoints     []string `yaml:"endpoints"`
+			DisableUpdate bool     `yaml:"disableUpdate"`
 		}{
 			Endpoints: []string{params.Protocol + "://" + configutils.QuoteIP(params.Host) + ":" + params.Port},
 		},
@@ -168,6 +169,7 @@ func (this *UpdateHostsAction) RunPost(params struct {
 	var apiConfig = &configs.APIConfig{
 		RPC: struct {
 			Endpoints     []string `yaml:"endpoints"`
+			DisableUpdate bool     `yaml:"disableUpdate"`
 		}{
 			Endpoints: endpoints,
 		},

internal/web/actions/default/recover/validateApi.go

@@ -44,6 +44,7 @@ func (this *ValidateApiAction) RunPost(params struct {
 	client, err := rpc.NewRPCClient(&configs.APIConfig{
 		RPC: struct {
 			Endpoints     []string `yaml:"endpoints"`
+			DisableUpdate bool     `yaml:"disableUpdate"`
 		}{
 			Endpoints: []string{params.Protocol + "://" + configutils.QuoteIP(params.Host) + ":" + params.Port},
 		},

internal/web/actions/default/setup/install.go

@@ -224,6 +224,7 @@ func (this *InstallAction) RunPost(params struct {
 		apiConfig := &configs.APIConfig{
 			RPC: struct {
 				Endpoints     []string `yaml:"endpoints"`
+				DisableUpdate bool     `yaml:"disableUpdate"`
 			}{
 				Endpoints: []string{"http://" + configutils.QuoteIP(apiNodeMap.GetString("newHost")) + ":" + apiNodeMap.GetString("newPort")},
 			},
@@ -286,6 +287,7 @@ func (this *InstallAction) RunPost(params struct {
 		apiConfig := &configs.APIConfig{
 			RPC: struct {
 				Endpoints     []string `yaml:"endpoints"`
+				DisableUpdate bool     `yaml:"disableUpdate"`
 			}{
 				Endpoints: []string{apiNodeMap.GetString("oldProtocol") + "://" + configutils.QuoteIP(apiNodeMap.GetString("oldHost")) + ":" + apiNodeMap.GetString("oldPort")},
 			},

internal/web/actions/default/setup/validateApi.go

@@ -86,6 +86,7 @@ func (this *ValidateApiAction) RunPost(params struct {
 	client, err := rpc.NewRPCClient(&configs.APIConfig{
 		RPC: struct {
 			Endpoints     []string `yaml:"endpoints"`
+			DisableUpdate bool     `yaml:"disableUpdate"`
 		}{
 			Endpoints: []string{params.OldProtocol + "://" + configutils.QuoteIP(params.OldHost) + ":" + params.OldPort},
 		},