Update app.py

app.py

@@ -1853,7 +1853,7 @@ def launch_ui(bootstrap_instance: "Bootstrap"):
         if not res.get("ok"): return f"Test failed: {res.get('reason','unknown')}"
         if _last["obj"].kind=="code" and role!="owner" and not CFG["OPT_AUTO_APPLY"]: return "Awaiting Owner approval for code changes." # type: ignore
         ok,msg=hive_instance.changes.apply(res); return msg if ok else f"Apply failed: {msg}" # type: ignore
-    demo.launch(server_name="0.0.0.0", server_port=int(os.environ.get("PORT", "7860")), share=False)
+    demo.launch(server_name="0.0.0.0", server_port=int(os.environ.get("PORT", "7860")), share=False, quiet=True)
 
 class Bootstrap:
     """Handles the entire application startup sequence cleanly."""
@@ -1929,6 +1929,10 @@ class Bootstrap:
         """Performs a hot-reload of the application logic without restarting the process."""
         print("[Bootstrap] Performing soft restart (hot-reload)...")
         self.hive_ready.clear()
+        if self.hive_instance:
+            self.hive_instance.module_manager.stop_all()
+        if self.app and hasattr(self.app, 'close'):
+            self.app.close()
         
         # Reload the app module to get the new code
         import app
@@ -1982,12 +1986,12 @@ class Bootstrap:
             print("\nExiting Hive CLI.")
             pass
 
-    def graceful_shutdown(self, signum, frame):
+    def graceful_shutdown(self, signum=None, frame=None):
         """Handles SIGINT/SIGTERM for clean shutdown."""
         print("\n[Bootstrap] Graceful shutdown requested...")
-        if self.hive_instance:
-            print("[Bootstrap] Persisting final state...")
-            # In a full implementation, this would call hive.persistence.flush_all()
+        if self.hive_instance and hasattr(self.hive_instance, 'module_manager'):
+            self.hive_instance.module_manager.stop_all()
+        gr.close_all()
         print("[Bootstrap] Exiting.")
         sys.exit(0)
 
@@ -1995,86 +1999,4 @@ class Bootstrap:
 if __name__=="__main__":
     bootstrap = Bootstrap(CFG)
     bootstrap.run()
-
-class Bootstrap:
-    """Handles the entire application startup sequence cleanly."""
-    def __init__(self, config: Dict):
-        self.config = config
-        self.caps: Optional[Dict] = None
-        self.hive_instance: Optional[Hive] = None
-        self.hive_lite_instance: Optional[Hive] = None
-        self.hive_ready = threading.Event()
-
-    def run(self):
-        """Executes the full startup sequence."""
-        print("[Bootstrap] Starting Hive System...")
-        self.caps = probe_caps()
-        print(f"[Bootstrap] System capabilities: {self.caps}")
-
-        # Create a 'lite' instance immediately for basic chat
-        print("[Bootstrap] Initializing Lite Hive core...")
-        self.hive_lite_instance = Hive(lite=True)
-        print("[Bootstrap] Lite Hive core is ready.")
-
-        # Launch UI immediately, it will wait for the hive_ready event
-        ui_thread = threading.Thread(target=self.launch, daemon=True)
-        ui_thread.start()
-
-        print("[Bootstrap] Initializing Hive core in background...")
-        # Now initialize the full instance. This is the slow part.
-        self.hive_instance = Hive(lite=False)
-
-        self.hive_ready.set() # Signal that the Hive instance is ready
-        print("[Bootstrap] Hive core is ready.")
-
-        self.setup_memory()
-        ui_thread.join() # Keep main thread alive
-
-    def setup_memory(self):
-        """Handles memory restoration and staged ingestion."""
-        def _memory_task():
-            print("[Bootstrap] Starting background memory setup...")
-            try:
-                ok_restored, restore_msg = restore_curves_if_missing(str(self.config["CURVE_DIR"]))
-                with open(os.path.join(self.config["STATE_DIR"], "restore_status.log"), "a", encoding="utf-8") as f:
-                    f.write(json.dumps({"ok":bool(ok_restored),"msg":restore_msg,"ts":time.time()})+"\n")
-                if ok_restored:
-                    print(f"[Bootstrap] Memory restore status: {restore_msg}")
-                else:
-                        print("[Bootstrap] No memory restored, proceeding to staged ingestion in background...")
-                        staged_ingest_chain_if_enabled(str(self.config["CURVE_DIR"]))
-            except Exception as e:
-                    with open(os.path.join(self.config["STATE_DIR"], "restore_error.log"), "a", encoding="utf-8") as f:
-                        f.write(f"restore/ingest: {e}\n")
-        # Run the memory setup in a background thread to not block the UI
-        threading.Thread(target=_memory_task, daemon=True).start()
-
-    def launch(self):
-        """Launches the appropriate interface (UI or CLI)."""
-        if self.config["LAUNCH_UI"]:
-            print("[Bootstrap] Launching Web UI...")
-            launch_ui(self)
-        else:
-            print("[Bootstrap] Launching CLI...")
-            self.run_cli_loop()
-
-    def run_cli_loop(self):
-        """Runs a command-line interface loop for Hive. Waits for full init."""
-        self.hive_ready.wait()
-        print("Hive is ready. Type a message and press Enter (Ctrl+C to exit).")
-        try:
-            while True:
-                s = input("> ").strip()
-                if not s: continue
-                reply = self.hive_instance.chat(s, effective_role="user", caller_id="cli") # type: ignore
-                print(reply)
-        except (KeyboardInterrupt, EOFError):
-            print("\nExiting Hive CLI.")
-            pass
-
-# ----------- entry -----------
-if __name__=="__main__":
-
-    bootstrap = Bootstrap(CFG)
-    bootstrap.run()