Function connect

cli/cmd/connect.go:203–270

go routine 启动所有工作区

(startedServerWorkspaces []workspace.WorkspaceInfo, cmd *cobra.Command, args []string, LoginUrl string)

// go routine 启动所有工作区
func connect(startedServerWorkspaces []workspace.WorkspaceInfo, cmd *cobra.Command, args []string, LoginUrl string) {
	// appinsight
	executeStartCmdFunc := func(yamlConfig config.SmartIdeConfig, workspaceInfo workspace.WorkspaceInfo, cmdtype, userguid, workspaceid string) {
		// if config.GlobalSmartIdeConfig.IsInsightEnabled != config.IsInsightEnabledEnum_Enabled {
		// 	common.SmartIDELog.Debug("Application Insights disabled")
		// 	return
		// }
		// var imageNames []string
		// for _, service := range yamlConfig.Workspace.Servcies {
		// 	imageNames = append(imageNames, service.Image)
		// }
		// appinsight.SetTrack(cmd.Use, Version.TagName, trackEvent, string(workspace.WorkingMode_Remote), strings.Join(imageNames, ","))
	}

	var mutex sync.Mutex
	//0. start
	forwardFunc := func(fixWorkspaceInfo workspace.WorkspaceInfo) {
		mutex.Lock()
		common.SmartIDELog.Info(fmt.Sprintf("-- workspace (%v) -------------------------------", fixWorkspaceInfo.ServerWorkSpace.NO))
		var err error
		if fixWorkspaceInfo.Mode == workspace.WorkingMode_Remote {

			var imageNames []string
			for _, service := range fixWorkspaceInfo.ConfigYaml.Workspace.LinkCompose.Services {
				imageNames = append(imageNames, service.Image)
			}
			appinsight.SetAllTrack(appinsight.Cli_Server_Connect, args, LoginUrl, fixWorkspaceInfo.ServerWorkSpace.OwnerGUID, fixWorkspaceInfo.ID, "", "", strings.Join(imageNames, ","))
			_, err = start.ExecuteServerVmStartByClientEnvCmd(fixWorkspaceInfo, executeStartCmdFunc)
		} /* else if fixWorkspaceInfo.Mode == workspace.WorkingMode_K8s {
			err = start.ExecuteServerK8sStartByClientEnvCmd(fixWorkspaceInfo, executeStartCmdFunc)
		} */

		if err != nil {
			common.SmartIDELog.ImportanceWithError(err)
			connectedWorkspaceIds = common.RemoveItem(connectedWorkspaceIds, fixWorkspaceInfo.ServerWorkSpace.NO)
		}
		time.Sleep(time.Second * 26)
		defer mutex.Unlock()

		for {
			if !common.Contains(connectedWorkspaceIds, fixWorkspaceInfo.ServerWorkSpace.NO) {
				common.SmartIDELog.Info(fmt.Sprintf("-- workspace (%v) -------------------------------", fixWorkspaceInfo.ServerWorkSpace.NO))
				common.SmartIDELog.Importance(fmt.Sprintf("当前工作区（%v）非启动状态，端口转发停止！", fixWorkspaceInfo.ServerWorkSpace.NO))
				return
			}
			time.Sleep(time.Second * 10)
		}

	}

	//2. 启动工作区
	for _, workspaceInfo := range startedServerWorkspaces {
		if workspaceInfo.ServerWorkSpace.Status == apiResponse.WorkspaceStatusEnum_Start {
			if !common.Contains(connectedWorkspaceIds, workspaceInfo.ServerWorkSpace.NO) {
				// 加入到已连接数组
				connectedWorkspaceIds = append(connectedWorkspaceIds, workspaceInfo.ServerWorkSpace.NO)

				go forwardFunc(workspaceInfo)