"""Tests for _spawn_gateway_restart orphan-reap guard (#77276)."""
from __future__ import annotations

import subprocess
from unittest.mock import MagicMock, patch

import pytest


class TestSpawnGatewayRestartReapsOrphans:
    """_spawn_gateway_restart must reap orphaned gateways before spawning."""

    @patch("hermes_cli.web_server._gateway_subcommand", return_value=["gateway", "restart"])
    @patch("hermes_cli.web_server._spawn_hermes_action")
    @patch("hermes_cli.web_server._ACTION_PROCS", {})
    def test_reap_called_before_spawn(self, mock_spawn, mock_subcmd):
        """Orphan reap runs before the new gateway process is spawned."""
        mock_proc = MagicMock(spec=subprocess.Popen)
        mock_proc.poll.return_value = None
        mock_spawn.return_value = mock_proc

        from hermes_cli.web_server import _spawn_gateway_restart

        with patch(
            "hermes_cli.gateway._reap_unsupervised_gateway_orphans"
        ) as mock_reap:
            proc, reused = _spawn_gateway_restart()

        mock_reap.assert_called_once()
        mock_spawn.assert_called_once()
        assert proc is mock_proc
        assert reused is False

    @patch("hermes_cli.web_server._gateway_subcommand", return_value=["gateway", "restart"])
    @patch("hermes_cli.web_server._spawn_hermes_action")
    @patch("hermes_cli.web_server._ACTION_PROCS", {})
    def test_reap_failure_does_not_block_spawn(self, mock_spawn, mock_subcmd):
        """If reap raises, the restart still proceeds."""
        mock_proc = MagicMock(spec=subprocess.Popen)
        mock_proc.poll.return_value = None
        mock_spawn.return_value = mock_proc

        from hermes_cli.web_server import _spawn_gateway_restart

        with patch(
            "hermes_cli.gateway._reap_unsupervised_gateway_orphans",
            side_effect=OSError("permission denied"),
        ):
            proc, reused = _spawn_gateway_restart()

        mock_spawn.assert_called_once()
        assert proc is mock_proc