Improved handling of Pod events and synced square button color. Closes …

…#1.

src/main/kotlin/de/qaware/cloud/nativ/k8s/ClusterNode.kt

@@ -38,9 +38,15 @@ data class ClusterNode(val row: Int, val column: Int,
         return this
     }
 
+    fun update(p: Phase) {
+        if (active.get()) {
+            phase = p
+        }
+    }
+
     fun deactivate(): ClusterNode {
         active.compareAndSet(true, false)
-        phase = Phase.Unknown
+        phase = Phase.Terminated
         return this
     }
 

src/main/kotlin/de/qaware/cloud/nativ/k8s/ClusterNodeGrid.kt

@@ -30,6 +30,7 @@ import org.slf4j.Logger
 import java.util.concurrent.ExecutorService
 import java.util.concurrent.ScheduledExecutorService
 import java.util.concurrent.TimeUnit
+import javax.annotation.PreDestroy
 import javax.enterprise.context.ApplicationScoped
 import javax.enterprise.event.Event
 import javax.enterprise.event.Observes
@@ -86,19 +87,27 @@ open class ClusterNodeGrid @Inject constructor(@Named("default")
         }
     }
 
+    @PreDestroy
+    open fun shutdown() {
+        deployments.clear()
+        grid.forEach { row ->
+            row.forEach { it.deactivate() }
+        }
+    }
+
     private fun watch(row: Int, labels: MutableMap<String, String>) {
         scheduler.scheduleWithFixedDelay({
             if (deployments.deployments()[row] == null ) {
                 throw IllegalStateException("No deployment at $row to watch.")
             }
 
-            val nodes = grid[row]
-            val active = nodes.filter { it.active.get() }
+            pods.all(labels).forEachIndexed { j, pod ->
+                val nodes = grid[row]
+                val active = nodes.filter { it.active.get() }
 
-            pods.all(labels).reversed().forEachIndexed { j, pod ->
                 val node = active.elementAtOrElse(j) { nodes[next(row)].activate() }
                 if (node.active.get()) {
-                    node.phase = phase(pod)
+                    node.update(phase(pod))
                     updateClusterNode(row, node)
                 }
             }
@@ -131,10 +140,8 @@ open class ClusterNodeGrid @Inject constructor(@Named("default")
         val node = grid[event.row][event.column]
         val running = grid[event.row].count { it.active.get() }
 
-        executor.execute({
-            updateClusterNode(event.row, node.activate())
-            deployments.scale(event.row, running + 1)
-        })
+        updateClusterNode(event.row, node.activate())
+        executor.execute { deployments.scale(event.row, running + 1) }
     }
 
     /**
@@ -148,12 +155,10 @@ open class ClusterNodeGrid @Inject constructor(@Named("default")
         val node = grid[event.row][event.column]
         val running = grid[event.row].count { it.active.get() }
 
-        executor.execute({
-            deployments.scale(event.row, running - 1)
-            stopping(event.row, node)
-            node.deactivate()
-            stopped(event.row, node)
-        })
+        stopping(event.row, node)
+        node.deactivate()
+        executor.execute { deployments.scale(event.row, running - 1) }
+        stopped(event.row, node)
     }
 
     /**

src/main/kotlin/de/qaware/cloud/nativ/k8s/KubepadApplication.kt

@@ -45,9 +45,6 @@ fun main(args: Array<String>) {
     val cdiContainer = getCdiContainer()
     cdiContainer.boot();
 
-    // ensure we shutdown nicely on exit
-    Runtime.getRuntime().addShutdownHook(Thread() { cdiContainer.shutdown() })
-
     // and initialize the CDI container control
     val contextControl = cdiContainer.contextControl;
     contextControl.startContext(Dependent::class.java)
@@ -71,4 +68,7 @@ fun main(args: Array<String>) {
     } else {
         logger.warning("No Leap Motion support.")
     }
+
+    // ensure we shutdown nicely on exit
+    Runtime.getRuntime().addShutdownHook(Thread() { cdiContainer.shutdown() })
 }

src/main/kotlin/de/qaware/cloud/nativ/k8s/KubernetesDeployments.kt

@@ -62,6 +62,11 @@ open class KubernetesDeployments @Inject constructor(private val client: Kuberne
         operation.watch(this)
     }
 
+    open fun clear() {
+        deployments.clear()
+        names.clear()
+    }
+
     open fun deployments(): List<Deployment?> = deployments.toList()
 
     open operator fun get(row: Int): Deployment? = deployments[row]