Check if build is still valid when accepting a new client

Author: object-Object

mod/src/main/kotlin/gay/object/mlogv32/ProcessorAccess.kt

@@ -116,11 +116,20 @@ class ProcessorAccess(
                             while (true) {
                                 Log.info("Waiting for clients...")
                                 val client = serverSocket.accept()
-                                launch {
-                                    handleClient(client)
+
+                                if (runOnMainThread { build.isValid }) {
+                                    launch {
+                                        handleClient(client)
+                                    }
+                                } else {
+                                    Log.err("ProcessorAccess build invalid, stopping server.")
+                                    client.close()
+                                    stopServer()
+                                    break
                                 }
                             }
                         }
+                    } catch (_: CancellationException) {
                     } catch (e: Exception) {
                         Log.err("ProcessorAccess server failed", e)
                     }
@@ -301,23 +310,23 @@ private fun linkedBuild(build: LogicBuild, name: String) =
 
 private fun LVar.numu() = num().toUInt()
 
-@Serializable
-sealed class Request {
-    abstract suspend fun handle(processor: ProcessorAccess, rx: ByteReadChannel, tx: ByteWriteChannel): Response
-
-    protected suspend fun <T> runOnMainThread(block: () -> T): T {
-        return suspendCancellableCoroutine { continuation ->
-            Core.app.post {
-                try {
-                    continuation.resume(block())
-                } catch (e: Exception) {
-                    continuation.resumeWithException(e)
-                }
+private suspend fun <T> runOnMainThread(block: () -> T): T {
+    return suspendCancellableCoroutine { continuation ->
+        Core.app.post {
+            try {
+                continuation.resume(block())
+            } catch (e: Exception) {
+                continuation.resumeWithException(e)
             }
         }
     }
 }
 
+@Serializable
+sealed class Request {
+    abstract suspend fun handle(processor: ProcessorAccess, rx: ByteReadChannel, tx: ByteWriteChannel): Response
+}
+
 @Serializable
 @SerialName("flash")
 data class FlashRequest(