Method StartupWorker

pkg/controllers/cloudshell_controller.go:452–509

(_ context.Context, cloudshell *cloudshellv1alpha1.CloudShell, kubeConfigByte []byte)

}

func (c *Controller) StartupWorker(_ context.Context, cloudshell *cloudshellv1alpha1.CloudShell, kubeConfigByte []byte) error {
	// TODO: Some extra logic in order to upload and download files.
	var podName, namespace, container, serverBufferSize, ps1, pingInterval, clientOptionsStr, credential string
	serverBufferSize = c.ttydServiceBufferSize
	pingInterval = c.ttydPingInterval
	for _, env := range cloudshell.Spec.Env {
		switch env.Name {
		case "POD_NAME":
			podName = env.Value
		case "POD_NAMESPACE":
			namespace = env.Value
		case "CONTAINER":
			container = env.Value
		case "TTYD_SERVER_BUFFER_SIZE":
			serverBufferSize = env.Value
		case "TTYD_PING_INTERVAL":
			pingInterval = env.Value
		case "TTYD_CREDENTIAL":
			credential = env.Value
		case "PS1":
			ps1 = env.Value
		}
	}

	// clientOptions is a map, convert it to string, the pattern is "k1=v1|k2=v2|..."
	// If k or v contains a delimiter(|), return an error.
	if clientOptions := cloudshell.Spec.TtydClientOptions; clientOptions != nil {
		var clientOptionsSlice []string
		for k, v := range clientOptions {
			if strings.Contains(k, ClientOptionsDelimiter) || strings.Contains(v, ClientOptionsDelimiter) {
				return errors.New("clientOptions key or value contains delimiter(|)")
			}
			clientOptionsSlice = append(clientOptionsSlice, fmt.Sprintf("%s=%s", k, v))
		}
		clientOptionsStr = strings.Join(clientOptionsSlice, ClientOptionsDelimiter)
	}

	klog.InfoS("Cloudshell config", "cloudshell.name", cloudshell.Name, "CommandAction", cloudshell.Spec.CommandAction,
		"serverBufferSize", serverBufferSize, "pingInterval", pingInterval, "clientOptions", clientOptionsStr, "credential", credential)
	// start ttyd, ttyd args passed as shell parameter
	// case: ttydCommand := []string{"/usr/lib/ttyd/startup.sh", "${KUBECONFIG}" "${ONCE}", "${URLARG}", "${COMMAND}"}
	ttydCommand := []string{
		startupScriptPath,                  // $0 startup.sh
		string(kubeConfigByte),             // $1 kubeconfig
		fmt.Sprint(cloudshell.Spec.Once),   // $2 once
		fmt.Sprint(cloudshell.Spec.UrlArg), // $3 urlArg
		cloudshell.Spec.CommandAction,      // $4 command
		podName,                            // $5 podName
		namespace,                          // $6 namespace
		container,                          // $7 container
		ps1,                                // $8 ps1
		serverBufferSize,                   // $9 serverBufferSize
		pingInterval,                       // $10 pingInterval
		clientOptionsStr,                   // $11 clientOptions
		credential,                         // $12 credential
	}
	return execCommand(cloudshell, ttydCommand, c.config)
}