feat: bcs-webconsole 支持共享集群(命名空间模式)

bcs-services/bcs-webconsole/console/api/service.go

@@ -14,6 +14,7 @@
 package api
 
 import (
+	"context"
 	"encoding/json"
 	"net/url"
 	"path"
@@ -116,6 +117,10 @@ func (s *service) CreateWebConsoleSession(c *gin.Context) {
 	consoleQuery := new(podmanager.ConsoleQuery)
 	_ = c.BindQuery(consoleQuery)
 
+	// 传递给下游函数
+	projectId := route.MustGetAuthContext(c).ProjectId
+	c.Request = c.Request.WithContext(context.WithValue(c.Request.Context(), podmanager.ProjectIdContextKey, projectId))
+
 	// 封装一个独立函数, 统计耗时
 	podCtx, err := func() (podCtx *types.PodContext, err error) {
 		start := time.Now()

bcs-services/bcs-webconsole/console/components/bcs/bcs.go

@@ -74,16 +74,7 @@ func ListClusters(ctx context.Context, projectId string) ([]*Cluster, error) {
 		return nil, err
 	}
 
-	clusters := make([]*Cluster, 0, len(result))
-	for _, cluster := range result {
-		// 过滤掉共享集群
-		if cluster.IsShared {
-			continue
-		}
-		clusters = append(clusters, cluster)
-	}
-
-	return clusters, nil
+	return result, nil
 }
 
 // GetCluster 获取单个集群信息

bcs-services/bcs-webconsole/console/podmanager/startup.go

@@ -211,10 +211,13 @@ func (m *StartupManager) getExternalKubeConfig(targetClusterId, username string)
 		return nil, err
 	}
 
+	// 获取kubeconfig server
+	server := m.getServer(targetClusterId)
+
 	authInfo := &clusterAuth{
 		Token: tokenObj.Token,
 		Cluster: clientcmdv1.Cluster{
-			Server:                fmt.Sprintf("%s/clusters/%s", config.G.BCS.Host, targetClusterId),
+			Server:                server,
 			InsecureSkipTLSVerify: config.G.BCS.InsecureSkipVerify,
 		},
 	}
@@ -398,3 +401,31 @@ func GetKubectldVersion(clusterId string) (string, error) {
 	v, err := config.G.WebConsole.MatchTag(info)
 	return v, err
 }
+
+// ProjectIdContext projectId context
+type ProjectIdContext string
+
+// ProjectIdContextKey projectId context key
+const ProjectIdContextKey ProjectIdContext = "projectIdContext"
+
+// 获取kubeconfig server
+func (m *StartupManager) getServer(clusterId string) string {
+	server := fmt.Sprintf("%s/clusters/%s", config.G.BCS.Host, clusterId)
+	projectId, ok := m.ctx.Value(ProjectIdContextKey).(string)
+	// 取不出来及空的情况下返回默认地址
+	if !ok || projectId == "" {
+		return server
+	}
+
+	cluster, err := bcs.GetCluster(m.ctx, projectId, clusterId)
+	if err != nil {
+		// 报错情况下返回默认的
+		return server
+	}
+
+	// 共享集群的项目Id和当前项目会不一致，如果是共享集群则加上/projects/%s
+	if cluster.IsShared && cluster.ProjectId != projectId {
+		return fmt.Sprintf("%s/projects/%s/clusters/%s", config.G.BCS.Host, cluster.ProjectId, clusterId)
+	}
+	return server
+}