fix: resolve translation shadowing, standardize safe_print, and refactor tests

- Replaced tuple unpacking dummy variables (`_`) with `unused` globally to prevent shadowing the `_` gettext translation function.
- Swapped standard `print()` calls for `safe_print()` in the core, dispatcher, and tests to prevent UnicodeEncodeErrors on strict terminals and Windows.
- Refactored `test_verify_bubble_deps.py` into an OOP `KBSyncVerifier` class with bi-directional (DB ↔ Disk) symmetry checks.
- Relocated FFI and diagnostic tests (`diag_uv_ffi.py`, `test_uv_ffi_contracts.py`) to the root `tests/` directory and fixed linter-induced AttributeErrors.
- Added the "Daemon IPC Showcase" (Option 11) to the interactive `8pkg demo` CLI menu.
- Enhanced the daemon worker pre-warm logic to accurately detect and strip framework (torch/tensorflow) site-packages from the bubble path.
- Registered the `integration` pytest marker in `pytest.ini`.

New files:
  • tests/diag_uv_ffi.py (425 lines)
  • tests/test_uv_ffi_contracts.py (793 lines)

Modified:
  • build_hooks.py (+1/-1 lines)
  • src/omnipkg/cli.py (+4/-2 lines)
  • src/omnipkg/core.py (+2/-2 lines)
  • src/omnipkg/dispatcher.py (+34/-34 lines)
  • src/omnipkg/installation/installers.py (+4/-4 lines)
  • src/omnipkg/installation/smart_install.py (+3/-3 lines)
  • src/omnipkg/integration/reproducible.py (+44/-40 lines)
  • src/omnipkg/isolation/fs_lock_queue.py (+1/-1 lines)
  • src/omnipkg/isolation/fs_watcher.py (+7/-7 lines)
  • src/omnipkg/isolation/resource_monitor.py (+7/-7 lines)
  • src/omnipkg/isolation/worker_daemon.py (+17/-4 lines)
  • src/omnipkg/package_meta_builder.py (+10/-10 lines)
  • src/omnipkg/windows_bootstrap/launcher.py (+1/-1 lines)
  • setup.py (+4/-4 lines)
  • pytest.ini (+1/-0 lines)
  • src/omnipkg/tests/omnipkg_ipc_showcase.py (+22/-17 lines)
  • src/omnipkg/tests/test_concurrent_install.py (+2/-2 lines)
  • src/omnipkg/tests/test_daemon_tags.py (+22/-18 lines)
  • src/omnipkg/tests/test_loader_stress_test.py (+1/-1 lines)
  • src/omnipkg/tests/test_old_rich.py (+1/-1 lines)
  • src/omnipkg/tests/test_rich_switching.py (+3/-3 lines)
  • src/omnipkg/tests/test_tensorflow_switching.py (+1/-1 lines)
  • tests/test_dispatcher_contracts.py (+1/-1 lines)
  • tests/test_ffi_verify.py (+13/-9 lines)
  • tests/test_flask_port_finder.py (+9/-9 lines)
  • tests/test_omnipkg_contracts.py (+11/-11 lines)
  • tests/test_verify_bubble_deps.py (+117/-179 lines)

[gitship-generated]

Author: 1minds3t

build_hooks.py

@@ -101,7 +101,7 @@ def _collect_host_info() -> dict:
                 fields = {}
                 for line in Path(osr).read_text().splitlines():
                     if "=" in line and not line.startswith("#"):
-                        k, _, v = line.partition("=")
+                        k, unused, v = line.partition("=")
                         fields[k.strip()] = v.strip().strip('"')
                 info["linux_distro_id"]      = fields.get("ID", "unknown").lower()
                 info["linux_distro_version"] = fields.get("VERSION_ID", "unknown")

pytest.ini

@@ -2,3 +2,4 @@
 addopts = -ra --color=yes --continue-on-collection-errors
 markers =
     windows_compat: Tests that verify Windows-specific compatibility
+    integration: marks tests as integration tests (deselect with '-m "not integration"')

setup.py

@@ -160,7 +160,7 @@ def _skip(reason, **kw): return {"status": "skipped", "reason": reason, **kw}
 
         if replaced:
             binary_out.unlink(missing_ok=True)
-            print(f"  [dispatcher] ✅ Fast C dispatcher installed over: {replaced}")
+            safe_print(f"  [dispatcher] ✅ Fast C dispatcher installed over: {replaced}")
             installed_paths = []
             for name in replaced:
                 target = Path(install_dir) / (name + _exe)
@@ -276,7 +276,7 @@ def _clean_env():
             import importlib.util, site
             sp = site.getsitepackages()
             sp0 = sp[0] if sp else "unknown"
-            print("  [uv-ffi] ✅ PyO3 FFI extension built and installed")
+            safe_print("  [uv-ffi] ✅ PyO3 FFI extension built and installed")
             print(f"  [uv-ffi]    site-packages : {sp0}")
             # Find the actual .so path for the manifest
             import glob as _uvg
@@ -375,7 +375,7 @@ def _collect_host_info() -> dict:
                 fields = {}
                 for line in Path(osr).read_text().splitlines():
                     if "=" in line and not line.startswith("#"):
-                        k, _, v = line.partition("=")
+                        k, unused, v = line.partition("=")
                         fields[k.strip()] = v.strip().strip('"')
                 info["linux_distro_id"]      = fields.get("ID", "unknown").lower()
                 info["linux_distro_version"] = fields.get("VERSION_ID", "unknown")
@@ -672,7 +672,7 @@ def build_extension(self, ext):
         print(f"  [atomic]   output (.so)  : {Path(so_path).resolve()}")
         try:
             super().build_extension(ext)
-            print(f"  [atomic]   ✅ built to   : {Path(so_path).resolve()}")
+            safe_print(f"  [atomic]   ✅ built to   : {Path(so_path).resolve()}")
             self._atomic_result = {"status": "ok", "so_path": str(Path(so_path).resolve())}
         except Exception as e:
             print(f"\n{'!'*60}")

src/omnipkg/cli.py

@@ -2470,6 +2470,7 @@ def main():
                 safe_print(_("8. 🌠 Quantum Multiverse Warp (concurrent installs) — needs 3.11"))
                 safe_print(_("9. Flask Port Finder (auto-healing with Flask)"))
                 safe_print(_("10. CLI Healing Test (omnipkg run shell commands)"))
+                safe_print(_("11. Daemon IPC Showcase"))
                 safe_print(_("\nFor chaos/stress tests: 8pkg stress-test"))
 
                 from omnipkg.common_utils import safe_input
@@ -2478,7 +2479,7 @@ def main():
 
                 if args.demo_id is not None:
                     if not (1 <= args.demo_id <= 10):
-                        safe_print(_("❌ Invalid demo ID {}. Choose 1-10.").format(args.demo_id))
+                        safe_print(_("❌ Invalid demo ID {}. Choose 1-11.").format(args.demo_id))
                         return 1
                     response = str(args.demo_id)
                     safe_print(_('🎯 Running demo {}...').format(response))
@@ -2487,7 +2488,7 @@ def main():
                     safe_print(_('🤖 Non-interactive: auto-selecting demo {}').format(response))
                 else:
                     response = safe_input(
-                        _("Enter your choice (1-10): "),
+                        _("Enter your choice (1-11): "),
                         default="1",
                         auto_value=os.environ.get("OMNIPKG_DEMO_ID", "1"),
                     )
@@ -2503,6 +2504,7 @@ def main():
                     "8": ("Quantum Multiverse Warp", TESTS_DIR / "test_concurrent_install.py", "3.11"),
                     "9": ("Flask Port Finder", TESTS_DIR / "test_flask_port_finder.py", None),
                     "10": ("CLI Healing Test", TESTS_DIR / "test_cli_healing.py", None),
+                    "11": ("Daemon IPC Showcase", TESTS_DIR / "omnipkg_ipc_showcase.py", None),
                 }
 
                 if response not in demo_map:

src/omnipkg/core.py

@@ -3295,7 +3295,7 @@ def _get_our_config_path(self) -> Path:
                 _gc_exe = Path(_gc.get("python_executable", "")).resolve()
                 if _gc_exe != exe_path:
                     if debug_mode:
-                        print(f"[DEBUG-CONFIG] ⚠️  Global config points to {_gc_exe} but we are {exe_path} — ignoring stale global config", file=sys.stderr)
+                        safe_print(f"[DEBUG-CONFIG] ⚠️  Global config points to {_gc_exe} but we are {exe_path} — ignoring stale global config", file=sys.stderr)
                     self._write_interpreter_config(exe_path, f"{sys.version_info.major}.{sys.version_info.minor}")
                     return per_python_config
             except Exception:
@@ -6639,7 +6639,7 @@ def _self_heal_omnipkg_installation(self):
                 _stamped_ver = _stamp.get("version")
                 if _stamped_ver:
                     # Get running version fast (toml first, then metadata)
-                    _running_ver, _ = self._get_master_version_ultra_fast()
+                    _running_ver, unused = self._get_master_version_ultra_fast()
                     if _running_ver == _stamped_ver:
                         # Already stamped at this exact version — nothing to do.
                         return