feat: Gateway: "Connect to Dev Spaces" wizard is to be added with "Start" [Workspace] button

Fixes: eclipse-che/che#23585

Signed-off-by: Victor Rubezhny <[email protected]>

Author: vrubezhny

src/main/kotlin/com/redhat/devtools/gateway/openshift/DevWorkspaces.kt

@@ -24,6 +24,7 @@ import java.io.IOException
 import java.util.concurrent.Executors
 import java.util.concurrent.TimeUnit
 
+
 class DevWorkspaces(private val client: ApiClient) {
     private val customApi = CustomObjectsApi(client)
 
@@ -181,6 +182,48 @@ class DevWorkspaces(private val client: ApiClient) {
         return phaseIsDesiredState
     }
 
+    // Waits until the DevWorkspace goes out of any the given phases
+    @Throws(ApiException::class, IOException::class)
+    fun waitPhaseChanges(
+        namespace: String,
+        name: String,
+        currentPhases: Collection<String>,
+        timeout: Long
+    ): Boolean {
+        var phaseChanged = false
+
+        val watcher = createWatcher(namespace, "metadata.name=$name")
+        val executor = Executors.newSingleThreadScheduledExecutor()
+
+        executor.schedule (
+            {
+                try {
+                    for (item in watcher) {
+                        val devWorkspace = DevWorkspace.from(item.`object`)
+                        if (devWorkspace.phase !in currentPhases) {
+                            phaseChanged = true
+                            break
+                        }
+                    }
+                } finally {
+                    watcher.close()
+                    executor.shutdown()
+                }
+            },
+            0,
+            TimeUnit.SECONDS
+        )
+
+        try {
+            executor.awaitTermination(timeout, TimeUnit.SECONDS)
+        } finally {
+            watcher.close()
+            executor.shutdownNow()
+        }
+
+        return phaseChanged
+    }
+
     // Example:
     // https://github.com/kubernetes-client/java/blob/master/examples/examples-release-20/src/main/java/io/kubernetes/client/examples/PatchExample.java
     @Throws(ApiException::class)

src/main/kotlin/com/redhat/devtools/gateway/view/steps/DevSpacesWorkspacesStepView.kt

@@ -57,6 +57,7 @@ class DevSpacesWorkspacesStepView(
     // 'true' when there are DevWorkspaces come from multiple namespaces
     private var multipleNamespaces = false
 
+    private lateinit var startDevWorkspaceButton: JButton
     private lateinit var stopDevWorkspaceButton: JButton
 
     override val component = panel {
@@ -71,6 +72,10 @@ class DevSpacesWorkspacesStepView(
         row {
             label("").resizableColumn().align(AlignX.FILL)
 
+            startDevWorkspaceButton =
+                button(DevSpacesBundle.message("connector.wizard_step.remote_server_connection.button.start")) {
+                    startDevWorkspace()
+                }.gap(RightGap.SMALL).align(AlignX.RIGHT).component
             stopDevWorkspaceButton =
                 button(DevSpacesBundle.message("connector.wizard_step.remote_server_connection.button.stop")) {
                     stopDevWorkspace()
@@ -160,6 +165,34 @@ class DevSpacesWorkspacesStepView(
         listDevWorkspaces.selectedIndex = selectedIndex
     }
 
+    private fun startDevWorkspace() {
+        if (!listDevWorkspaces.isSelectionEmpty) {
+            listDWDataModel
+                .get(listDevWorkspaces.selectedIndex)
+                .also {
+                    DevWorkspaces(devSpacesContext.client)
+                        .start(
+                            it.namespace,
+                            it.name
+                        )
+                    ProgressManager.getInstance().runProcessWithProgressSynchronously(
+                        {
+                            if (waitDevWorkspaceNotStopped(it)) {
+                                refreshDevWorkspace(
+                                    it.namespace,
+                                    it.name
+                                )
+                                enableButtons()
+                            }
+                        },
+                        "Refreshing Workspace",
+                        true,
+                        null
+                    )
+                }
+        }
+    }
+
     private fun stopDevWorkspace() {
         if (!listDevWorkspaces.isSelectionEmpty) {
             listDWDataModel
@@ -235,6 +268,16 @@ class DevSpacesWorkspacesStepView(
         )
     }
 
+    private fun waitDevWorkspaceNotStopped(devWorkspace: DevWorkspace): Boolean {
+        return DevWorkspaces(devSpacesContext.client)
+            .waitPhaseChanges(
+                devWorkspace.namespace,
+                devWorkspace.name,
+                listOf(DevWorkspaces.STOPPED, DevWorkspaces.FAILED),
+                30
+            )
+    }
+
     private fun waitDevWorkspaceStopped(devWorkspace: DevWorkspace): Boolean {
         return DevWorkspaces(devSpacesContext.client)
             .waitPhase(
@@ -249,9 +292,11 @@ class DevSpacesWorkspacesStepView(
         runInEdt {
             val workspace = getSelectedWorkspace()
             val running = isRunning(workspace)
+            val stopped = isStopped(workspace)
             val alreadyConnected = isAlreadyConnected(workspace)
 
             // stop button enabled only if workspace is running
+            startDevWorkspaceButton.isEnabled = stopped
             stopDevWorkspaceButton.isEnabled = running
 
             // Enable/disable "Next" (connect) button dynamically
@@ -279,6 +324,10 @@ class DevSpacesWorkspacesStepView(
         return isRunning(workspace) && !isAlreadyConnected(workspace)
     }
 
+    private fun isStopped(workspace: DevWorkspace?): Boolean {
+        return workspace?.started == false
+    }
+
     private fun isRunning(workspace: DevWorkspace?): Boolean {
         return workspace?.running ?: false
     }

src/main/resources/messages/DevSpacesBundle.properties

@@ -13,6 +13,7 @@ connector.wizard_step.openshift_connection.button.next=Check connection and cont
 connector.wizard_step.remote_server_connection.title=Select running DevWorkspace
 connector.wizard_step.remote_server_connection.button.previous=Back
 connector.wizard_step.remote_server_connection.button.next=Connect
+connector.wizard_step.remote_server_connection.button.start=Start
 connector.wizard_step.remote_server_connection.button.stop=Stop
 connector.wizard_step.remote_server_connection.button.refresh=Refresh
 connector.wizard_step.remote_server_connection.list.empty_text=There are no DevWorkspaces