Use printAbove in terminal IO.

Improve display of delayed messages and fix issue where signal is not trapped.

Fixes system exit service to not respond unless required which was showing
in terminal on exit.

Author: neilcsmith-net

praxiscore-hub/src/main/java/org/praxislive/hub/BasicCoreRoot.java

@@ -1,7 +1,7 @@
 /*
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
  * 
- * Copyright 2023 Neil C Smith.
+ * Copyright 2025 Neil C Smith.
  * 
  * This code is free software; you can redistribute it and/or modify it
  * under the terms of the GNU Lesser General Public License version 3 only, as
@@ -37,7 +37,6 @@
 import org.praxislive.core.Root;
 import org.praxislive.core.RootHub;
 import org.praxislive.core.Control;
-import org.praxislive.core.Lookup;
 import org.praxislive.core.PacketRouter;
 import org.praxislive.core.Value;
 import org.praxislive.core.services.RootFactoryService;
@@ -201,7 +200,9 @@ protected void buildControlMap(Map<String, Control> ctrls) {
                             .toIntValue();
                 }
                 forceTermination();
-                router.route(call.reply());
+                if (call.isReplyRequired()) {
+                    router.route(call.reply());
+                }
             }
         });
     }

praxiscore-launcher-jline/pom.xml

@@ -29,12 +29,12 @@
     <dependency>
       <groupId>org.jline</groupId>
       <artifactId>jline-terminal</artifactId>
-      <version>3.30.3</version>
+      <version>3.30.6</version>
     </dependency>
     <dependency>
       <groupId>org.jline</groupId>
       <artifactId>jline-reader</artifactId>
-      <version>3.30.3</version>
+      <version>3.30.6</version>
     </dependency>
   </dependencies>
 

praxiscore-launcher-jline/src/main/java/org/praxislive/launcher/jline/JLineTerminalIO.java

@@ -1,7 +1,7 @@
 /*
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
  *
- * Copyright 2021 Neil C Smith.
+ * Copyright 2025 Neil C Smith.
  *
  * This code is free software; you can redistribute it and/or modify it
  * under the terms of the GNU Lesser General Public License version 3 only, as
@@ -99,7 +99,7 @@ private void handleExit() {
                 .flatMap(s -> s.locate(SystemManagerService.class))
                 .map(cmp -> ControlAddress.of(cmp, SystemManagerService.SYSTEM_EXIT))
                 .ifPresentOrElse(exit -> {
-                    getRouter().route(Call.create(exit, fromAddress,
+                    getRouter().route(Call.createQuiet(exit, fromAddress,
                             getExecutionContext().getTime()));
                 }, () -> System.exit(0));
     }

praxiscore-launcher-jline/src/main/java/org/praxislive/launcher/jline/Response.java

@@ -1,7 +1,7 @@
 /*
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
  *
- * Copyright 2021 Neil C Smith.
+ * Copyright 2025 Neil C Smith.
  *
  * This code is free software; you can redistribute it and/or modify it
  * under the terms of the GNU Lesser General Public License version 3 only, as
@@ -22,22 +22,4 @@
 
 package org.praxislive.launcher.jline;
 
-class Response {
-
-    final String message;
-    final boolean error;
-
-    Response(String message, boolean error) {
-        this.message = message;
-        this.error = error;
-    }
-    
-    String message() {
-        return message;
-    }
-    
-    boolean error() {
-        return error;
-    }
-
-}
+record Response(String message, boolean error) {}

praxiscore-launcher-jline/src/main/java/org/praxislive/launcher/jline/TerminalImpl.java

@@ -22,9 +22,6 @@
 package org.praxislive.launcher.jline;
 
 import java.util.Locale;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicReference;
 import org.jline.reader.EOFError;
 import org.jline.reader.LineReader;
@@ -52,15 +49,13 @@ class TerminalImpl {
 
     private static final TerminalImpl INSTANCE = new TerminalImpl();
 
-    private final BlockingQueue<Response> responses;
     private final AtomicReference<JLineTerminalIO> service;
 
     private Thread inputThread;
     private Terminal terminal;
     private LineReader reader;
 
     private TerminalImpl() {
-        responses = new LinkedBlockingQueue<>(200);
         service = new AtomicReference<>();
     }
 
@@ -94,49 +89,36 @@ synchronized void attach(JLineTerminalIO service) {
     }
 
     synchronized void detach(JLineTerminalIO service) {
-        if (this.service.compareAndSet(service, null)) {
-            postResponse(new Response("", false));
-        }
+        this.service.compareAndSet(service, null);
     }
 
     synchronized void postResponse(Response response) {
-        if (terminal != null) {
-            responses.add(response);
+        if (reader != null) {
+            writeResponse(response);
         }
     }
 
     private void inputLoop() {
 
         while (true) {
             try {
-                var script = reader.readLine(PROMPT);
+                String script = reader.readLine(PROMPT);
                 if (script != null && !script.isBlank()) {
-                    var root = service.get();
+                    JLineTerminalIO root = service.get();
                     if (root != null) {
                         root.postScript(script);
-                        var response = responses.poll(10, TimeUnit.SECONDS);
-                        if (response == null) {
-                            writeResponse(new Response("Timed out", true));
-                        } else {
-                            writeResponse(response);
-                        }
                     } else {
                         writeResponse(new Response("Not running", true));
                     }
                 }
-                // make sure response queue empty
-                Response response;
-                while ((response = responses.poll()) != null) {
-                    writeResponse(response);
-                }
             } catch (UserInterruptException ex) {
                 if (ex.getPartialLine().isBlank()) {
                     try {
-                        var confirm = reader.readLine(EXIT_PROMPT);
+                        String confirm = reader.readLine(EXIT_PROMPT);
                         if ("y".equals(confirm.trim().toLowerCase(Locale.ROOT))) {
                             terminal.writer().println(EXIT_NOTICE);
                             terminal.flush();
-                            var root = service.get();
+                            JLineTerminalIO root = service.get();
                             if (root != null) {
                                 root.postExit();
                                 Thread.sleep(5000);
@@ -157,29 +139,22 @@ private void inputLoop() {
     }
 
     private synchronized void writeResponse(Response response) {
-        if (response.error) {
-            terminal.writer()
-                    .println(new AttributedString("ERR : " + response.message,
+        if (response.error()) {
+            reader.printAbove(new AttributedString("ERR : " + response.message(),
                             AttributedStyle.DEFAULT.foreground(AttributedStyle.RED))
                             .toAnsi(terminal)
                     );
-            terminal.flush();
         } else {
-            terminal.writer()
-                    .println(new AttributedString("--- : " + response.message,
+            reader.printAbove(new AttributedString("--- : " + response.message(),
                             AttributedStyle.DEFAULT.foreground(AttributedStyle.GREEN))
                             .toAnsi(terminal)
                     );
-            terminal.flush();
         }
     }
 
     private boolean isCompleteScript(String script) {
         try {
-            var tok = new Tokenizer(script);
-            for (var t : tok) {
-                // consume to end
-            }
+            Tokenizer.parse(script);
             return true;
         } catch (Exception e) {
             return false;