"""Tests for hermes_cli.gateway.ensure_gateway_service — the zero-prompt
service install/start path used by `hermes setup` and `hermes import`.

The helper's contract:
  * never prompts, never raises (returns False on any failure)
  * no-ops in containers and on hosts without a service manager
  * short-circuits True when a service is already running
  * installs (user scope) then starts when nothing is installed
  * starts without reinstalling when a unit exists but isn't running
  * refuses to install on top of conflicting user+system systemd units
"""

import hermes_cli.gateway as gateway_mod


def _patch_host(monkeypatch, *, container=False, systemd=True, macos=False, windows=False):
    monkeypatch.setattr("hermes_constants.is_container", lambda: container)
    monkeypatch.setattr(gateway_mod, "supports_systemd_services", lambda: systemd)
    monkeypatch.setattr(gateway_mod, "is_macos", lambda: macos)
    monkeypatch.setattr(gateway_mod, "is_windows", lambda: windows)


class TestEnsureGatewayService:
    def test_container_is_noop(self, monkeypatch, capsys):
        _patch_host(monkeypatch, container=True)
        called = []
        monkeypatch.setattr(gateway_mod, "systemd_install", lambda **kw: called.append("install"))

        assert gateway_mod.ensure_gateway_service() is False
        assert not called
        out = capsys.readouterr().out
        assert "restart policy" in out

    def test_no_service_manager_is_noop(self, monkeypatch, capsys):
        _patch_host(monkeypatch, systemd=False)
        assert gateway_mod.ensure_gateway_service() is False
        out = capsys.readouterr().out
        assert "hermes gateway" in out

    def test_already_running_short_circuits(self, monkeypatch):
        _patch_host(monkeypatch)
        monkeypatch.setattr(gateway_mod, "_is_service_running", lambda: True)
        called = []
        monkeypatch.setattr(gateway_mod, "systemd_install", lambda **kw: called.append("install"))
        monkeypatch.setattr(gateway_mod, "systemd_start", lambda **kw: called.append("start"))

        assert gateway_mod.ensure_gateway_service() is True
        assert not called

    def test_fresh_host_installs_and_starts_user_scope(self, monkeypatch):
        _patch_host(monkeypatch)
        monkeypatch.setattr(gateway_mod, "_is_service_running", lambda: False)
        monkeypatch.setattr(gateway_mod, "_is_service_installed", lambda: False)
        monkeypatch.setattr(gateway_mod, "has_conflicting_systemd_units", lambda: False)
        calls = []
        monkeypatch.setattr(
            gateway_mod, "systemd_install",
            lambda force=False, non_interactive=False, **kw: calls.append(
                ("install", force, non_interactive, kw)
            ),
        )
        monkeypatch.setattr(gateway_mod, "systemd_start", lambda **kw: calls.append(("start", kw)))

        assert gateway_mod.ensure_gateway_service() is True
        assert calls[0][0] == "install"
        # user scope: no system=True ever passed from this path
        assert "system" not in calls[0][3] or not calls[0][3]["system"]
        # non_interactive so legacy-unit cleanup can't prompt
        assert calls[0][2] is True
        assert calls[1][0] == "start"

    def test_installed_but_stopped_starts_without_reinstall(self, monkeypatch):
        _patch_host(monkeypatch)
        monkeypatch.setattr(gateway_mod, "_is_service_running", lambda: False)
        monkeypatch.setattr(gateway_mod, "_is_service_installed", lambda: True)
        calls = []
        monkeypatch.setattr(gateway_mod, "systemd_install", lambda **kw: calls.append("install"))
        monkeypatch.setattr(gateway_mod, "systemd_start", lambda **kw: calls.append("start"))

        assert gateway_mod.ensure_gateway_service() is True
        assert calls == ["start"]

    def test_conflicting_units_block_install(self, monkeypatch):
        _patch_host(monkeypatch)
        monkeypatch.setattr(gateway_mod, "_is_service_running", lambda: False)
        monkeypatch.setattr(gateway_mod, "_is_service_installed", lambda: False)
        monkeypatch.setattr(gateway_mod, "has_conflicting_systemd_units", lambda: True)
        warned = []
        monkeypatch.setattr(
            gateway_mod, "print_systemd_scope_conflict_warning", lambda: warned.append(True)
        )
        calls = []
        monkeypatch.setattr(gateway_mod, "systemd_install", lambda **kw: calls.append("install"))

        assert gateway_mod.ensure_gateway_service() is False
        assert warned and not calls

    def test_macos_uses_launchd(self, monkeypatch):
        _patch_host(monkeypatch, systemd=False, macos=True)
        monkeypatch.setattr(gateway_mod, "_is_service_running", lambda: False)
        monkeypatch.setattr(gateway_mod, "_is_service_installed", lambda: False)
        calls = []
        monkeypatch.setattr(gateway_mod, "launchd_install", lambda force=False: calls.append("install"))
        monkeypatch.setattr(gateway_mod, "launchd_start", lambda: calls.append("start"))

        assert gateway_mod.ensure_gateway_service() is True
        assert calls == ["install", "start"]

    def test_never_raises_on_install_failure(self, monkeypatch, capsys):
        _patch_host(monkeypatch)
        monkeypatch.setattr(gateway_mod, "_is_service_running", lambda: False)
        monkeypatch.setattr(gateway_mod, "_is_service_installed", lambda: False)
        monkeypatch.setattr(gateway_mod, "has_conflicting_systemd_units", lambda: False)

        def boom(**kw):
            raise RuntimeError("dbus fell over")

        monkeypatch.setattr(gateway_mod, "systemd_install", boom)

        assert gateway_mod.ensure_gateway_service() is False
        out = capsys.readouterr().out
        assert "hermes gateway install" in out

    def test_never_raises_on_sys_exit(self, monkeypatch, capsys):
        """Install paths that sys.exit() must not abort setup/import."""
        _patch_host(monkeypatch)
        monkeypatch.setattr(gateway_mod, "_is_service_running", lambda: False)
        monkeypatch.setattr(gateway_mod, "_is_service_installed", lambda: False)
        monkeypatch.setattr(gateway_mod, "has_conflicting_systemd_units", lambda: False)

        def bail(**kw):
            raise SystemExit(1)

        monkeypatch.setattr(gateway_mod, "systemd_install", bail)

        assert gateway_mod.ensure_gateway_service() is False
        out = capsys.readouterr().out
        assert "hermes gateway install" in out

    def test_user_systemd_unreachable_reports_remediation(self, monkeypatch, capsys):
        _patch_host(monkeypatch)
        monkeypatch.setattr(gateway_mod, "_is_service_running", lambda: False)
        monkeypatch.setattr(gateway_mod, "_is_service_installed", lambda: True)

        def unreachable(**kw):
            raise gateway_mod.UserSystemdUnavailableError("no D-Bus session\nenable linger")

        monkeypatch.setattr(gateway_mod, "systemd_start", unreachable)

        assert gateway_mod.ensure_gateway_service() is False
        out = capsys.readouterr().out
        assert "enable linger" in out