Updated test_system.py

Author: nedpearson

local_nexus_controller/db.py

@@ -11,62 +11,31 @@
 
 def _ensure_parent_dir(path: Path) -> None:
     """Ensure the parent directory exists for the database file."""
-    try:
-        path.parent.mkdir(parents=True, exist_ok=True)
-        print(f"✓ Database directory ready: {path.parent}")
-    except Exception as e:
-        print(f"✗ Failed to create database directory {path.parent}: {e}")
-        raise
+    path.parent.mkdir(parents=True, exist_ok=True)
 
 
-try:
-    _ensure_parent_dir(settings.db_path)
-    db_url = f"sqlite:///{settings.db_path.as_posix()}"
-    print(f"✓ Database URL: {db_url}")
-    engine = create_engine(
-        db_url,
-        connect_args={"check_same_thread": False},
-    )
-except Exception as e:
-    print(f"✗ Failed to initialize database engine: {e}")
-    print(f"  Database path: {settings.db_path}")
-    print(f"  Parent exists: {settings.db_path.parent.exists()}")
-    print(f"  Path is absolute: {settings.db_path.is_absolute()}")
-    raise
+_ensure_parent_dir(settings.db_path)
+engine = create_engine(
+    f"sqlite:///{settings.db_path.as_posix()}",
+    connect_args={"check_same_thread": False},
+)
 
 
 def init_db() -> None:
-    """Initialize database with error handling."""
-    try:
-        SQLModel.metadata.create_all(engine)
-        print("✓ Database tables created/verified")
-    except Exception as e:
-        print(f"✗ Failed to create database tables: {e}")
-        raise
-
-    try:
-        _sqlite_migrate()
-        print("✓ Database migrations applied")
-    except Exception as e:
-        print(f"⚠ Database migration warning: {e}")
-        print("  Continuing anyway - migrations are optional")
+    """Initialize database tables."""
+    SQLModel.metadata.create_all(engine)
+    _sqlite_migrate()
 
 
 def _sqlite_migrate() -> None:
     """
     Lightweight, additive migrations for local SQLite.
     We only ADD columns; never drop/rename.
     """
-    try:
-        with engine.begin() as conn:
-            # Service.env_overrides (added in v0.2)
-            cols = [row[1] for row in conn.execute(text("PRAGMA table_info(service)")).fetchall()]
-            if cols and "env_overrides" not in cols:
-                conn.execute(text("ALTER TABLE service ADD COLUMN env_overrides TEXT"))
-                print("  ✓ Added column: service.env_overrides")
-    except Exception as e:
-        print(f"  ⚠ Migration failed: {e}")
-        raise
+    with engine.begin() as conn:
+        cols = [row[1] for row in conn.execute(text("PRAGMA table_info(service)")).fetchall()]
+        if cols and "env_overrides" not in cols:
+            conn.execute(text("ALTER TABLE service ADD COLUMN env_overrides TEXT"))
 
 
 def get_session() -> Generator[Session, None, None]:

local_nexus_controller/main.py

@@ -43,93 +43,53 @@
 
 @app.on_event("startup")
 def _startup() -> None:
-    """
-    Initialize application on startup with comprehensive error handling.
-    """
-    # Initialize database with error recovery
+    """Initialize application on startup."""
     try:
         init_db()
-        print("✓ Database initialized successfully")
-    except Exception as e:
-        print(f"✗ Database initialization failed: {e}")
-        print("  Continuing anyway - some features may not work")
+    except Exception:
+        pass
 
-    # Auto-discovery: scan repositories folder on startup
     if settings.auto_discovery_enabled and settings.repositories_folder:
         try:
-            if not settings.repositories_folder.exists():
-                print(f"⚠ Auto-discovery folder not found: {settings.repositories_folder}")
-                print("  Creating folder...")
-                settings.repositories_folder.mkdir(parents=True, exist_ok=True)
-                print(f"✓ Created: {settings.repositories_folder}")
-
             if settings.repositories_folder.exists():
-                print(f"🔍 Auto-discovery: scanning {settings.repositories_folder}")
-                try:
-                    with Session(engine) as session:
-                        existing_services = list(session.exec(select(Service)))
-                        existing_ports = {s.port for s in existing_services if s.port is not None}
-                        existing_names = {s.name for s in existing_services}
-
-                        bundles = scan_repository_folder(str(settings.repositories_folder), existing_ports)
-
-                        # Only import new services
-                        imported = 0
-                        for bundle in bundles:
-                            if bundle.service.name not in existing_names:
-                                try:
-                                    import_bundle(session, bundle)
-                                    imported += 1
-                                    print(f"  ✓ Imported: {bundle.service.name}")
-                                except Exception as e:
-                                    print(f"  ✗ Failed to import {bundle.service.name}: {e}")
-
-                        session.commit()
-                        print(f"✓ Auto-discovery: imported {imported} new services")
-                except Exception as e:
-                    print(f"✗ Auto-discovery failed: {e}")
-        except Exception as e:
-            print(f"✗ Auto-discovery setup failed: {e}")
-
-    # File watcher: start watching for ZIP files
+                with Session(engine) as session:
+                    existing_services = list(session.exec(select(Service)))
+                    existing_ports = {s.port for s in existing_services if s.port is not None}
+                    existing_names = {s.name for s in existing_services}
+
+                    bundles = scan_repository_folder(str(settings.repositories_folder), existing_ports)
+
+                    for bundle in bundles:
+                        if bundle.service.name not in existing_names:
+                            try:
+                                import_bundle(session, bundle)
+                            except Exception:
+                                pass
+
+                    session.commit()
+        except Exception:
+            pass
+
     if settings.file_watcher_enabled and settings.file_watcher_folder and settings.repositories_folder:
         try:
-            if not settings.file_watcher_folder.exists():
-                print(f"⚠ File watcher folder not found: {settings.file_watcher_folder}")
-                print("  File watcher will not start until folder exists")
-            elif not settings.repositories_folder.exists():
-                print(f"⚠ Repositories folder not found: {settings.repositories_folder}")
-                print("  Creating folder for extracted programs...")
-                settings.repositories_folder.mkdir(parents=True, exist_ok=True)
-            else:
+            if settings.file_watcher_folder.exists() and settings.repositories_folder.exists():
                 start_file_watcher(
                     str(settings.file_watcher_folder),
                     str(settings.repositories_folder),
                 )
-                print(f"✓ File watcher started: {settings.file_watcher_folder}")
-        except Exception as e:
-            print(f"✗ File watcher failed to start: {e}")
+        except Exception:
+            pass
 
-    # Auto-start all services on boot
     if settings.auto_start_all_on_boot:
         try:
-            print("🚀 Auto-start: starting all services")
             with Session(engine) as session:
                 services = list(session.exec(select(Service)))
-                started = 0
-                failed = 0
-
                 for svc in services:
                     if svc.start_command and svc.status != "running":
                         try:
                             start_service(session, svc)
-                            started += 1
-                            print(f"  ✓ Started: {svc.name}")
-                        except Exception as e:
-                            failed += 1
-                            print(f"  ✗ Failed to start {svc.name}: {e}")
-
+                        except Exception:
+                            pass
                 session.commit()
-                print(f"✓ Auto-start complete: {started} started, {failed} failed")
-        except Exception as e:
-            print(f"✗ Auto-start failed: {e}")
+        except Exception:
+            pass