fix: avoid bind exception when reconnecting after failure

Signed-off-by: Andre Dietisheim <[email protected]>

Author: adietish

src/main/kotlin/com/redhat/devtools/gateway/DevSpacesConnection.kt

@@ -63,21 +63,22 @@ class DevSpacesConnection(private val devSpacesContext: DevSpacesContext) {
                 false
             )
 
-        val forwarder = Pods(devSpacesContext.client).forward(remoteIdeServer.pod, 5990, 5990)
+        val forwarder = Pods(devSpacesContext.client)
+            .forward(remoteIdeServer.pod, 5990, 5990)
 
         client.run {
-            lifetime.onTermination { forwarder.close() }
             lifetime.onTermination {
+                forwarder.close()
                 if (remoteIdeServer.waitServerTerminated())
                     DevWorkspaces(devSpacesContext.client)
                         .stop(
                             devSpacesContext.devWorkspace.metadata.namespace,
                             devSpacesContext.devWorkspace.metadata.name
                         )
                         .also { onDevWorkspaceStopped() }
+                devSpacesContext.isConnected = false
+                onDisconnected.invoke()
             }
-            lifetime.onTermination { devSpacesContext.isConnected = false }
-            lifetime.onTermination(onDisconnected)
         }
 
         return client

src/main/kotlin/com/redhat/devtools/gateway/DevSpacesConnectionProvider.kt

@@ -164,7 +164,7 @@ class DevSpacesConnectionProvider : GatewayConnectionProvider {
         parameters: Map<String, String>,
         requestor: ConnectionRequestor,
         indicator: ProgressIndicator? = null
-    ): GatewayConnectionHandle? {
+    ): GatewayConnectionHandle {
         thisLogger().debug("Launched Dev Spaces connection provider", parameters)
 
         indicator?.text2 = "Preparing connection environment…"

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

@@ -38,6 +38,7 @@ import java.io.IOException
 import java.io.InputStream
 import java.io.OutputStream
 import java.net.InetAddress
+import java.net.InetSocketAddress
 import java.net.ServerSocket
 import java.net.Socket
 import java.util.concurrent.TimeUnit
@@ -99,16 +100,15 @@ class Pods(private val client: ApiClient) {
     // https://github.com/kubernetes-client/java/blob/master/examples/examples-release-latest/src/main/java/io/kubernetes/client/examples/PortForwardExample.java
     @Throws(IOException::class)
     fun forward(pod: V1Pod, localPort: Int, remotePort: Int): Closeable {
-        val serverSocket = ServerSocket(localPort, 50, InetAddress.getLoopbackAddress())
-
+        val serverSocket = ServerSocket()
+        serverSocket.bind(InetSocketAddress(InetAddress.getLoopbackAddress(), localPort))
         val scope = CoroutineScope(Dispatchers.IO)
         scope.launch {
             supervisorScope {
                 launch {
                     val clientSocket = serverSocket.accept()
-                    val forwardResult = PortForward(client).forward(pod, listOf(remotePort))
-
                     try {
+                        val forwardResult = PortForward(client).forward(pod, listOf(remotePort))
                         copyStreams(clientSocket, forwardResult, remotePort)
                     } catch (e: IOException) {
                         if (coroutineContext.isActive) throw e