ControlModeEngine(types): Introduce process protocol for test hooks

why: Remove mypy ignores and support injectable control-mode process factory.

what:
- Define _ControlProcess and _ProcessFactory protocols for control-mode transport
- Type engine process and helper threads against protocol instead of Popen
- Make close/restart logic rely on protocol methods without ignores

Author: tony

src/libtmux/_internal/engines/control_mode.py

@@ -28,6 +28,40 @@
 logger = logging.getLogger(__name__)
 
 
+class _ControlProcess(t.Protocol):
+    """Protocol for control-mode process handle (real or test fake)."""
+
+    stdin: t.TextIO | None
+    stdout: t.Iterable[str] | None
+    stderr: t.Iterable[str] | None
+
+    def terminate(self) -> None:
+        ...
+
+    def kill(self) -> None:
+        ...
+
+    def wait(self, timeout: float | None = None) -> t.Any:
+        ...
+
+
+class _ProcessFactory(t.Protocol):
+    """Protocol for constructing a control-mode process."""
+
+    def __call__(
+        self,
+        cmd: list[str],
+        *,
+        stdin: t.Any,
+        stdout: t.Any,
+        stderr: t.Any,
+        text: bool,
+        bufsize: int,
+        errors: str,
+    ) -> _ControlProcess:
+        ...
+
+
 class ControlModeEngine(Engine):
     """Engine that runs tmux commands via a persistent Control Mode process.
 
@@ -46,7 +80,7 @@ def __init__(
         notification_queue_size: int = 4096,
         internal_session_name: str | None = None,
         attach_to: str | None = None,
-        process_factory: t.Callable[[list[str]], subprocess.Popen[str]] | None = None,
+        process_factory: _ProcessFactory | None = None,
     ) -> None:
         """Initialize control mode engine.
 
@@ -69,12 +103,12 @@ def __init__(
             .. warning::
                Attaching to user sessions can cause notification spam from
                pane output. Use for advanced scenarios only.
-        process_factory : Callable[[list[str]], subprocess.Popen], optional
+        process_factory : _ProcessFactory, optional
             Test hook to override how the tmux control-mode process is created.
             When provided, it receives the argv list and must return an object
             compatible with ``subprocess.Popen`` (stdin/stdout/stderr streams).
         """
-        self.process: subprocess.Popen[str] | None = None
+        self.process: _ControlProcess | None = None
         self._lock = threading.Lock()
         self._server_args: tuple[str | int, ...] | None = None
         self.command_timeout = command_timeout
@@ -98,15 +132,11 @@ def close(self) -> None:
             return
 
         try:
-            if hasattr(proc, "terminate"):
-                proc.terminate()  # type: ignore[call-arg]
-            if hasattr(proc, "wait"):
-                proc.wait(timeout=1)  # type: ignore[call-arg]
+            proc.terminate()
+            proc.wait(timeout=1)
         except subprocess.TimeoutExpired:
-            if hasattr(proc, "kill"):
-                proc.kill()  # type: ignore[call-arg]
-            if hasattr(proc, "wait"):
-                proc.wait()  # type: ignore[call-arg]
+            proc.kill()
+            proc.wait()
         finally:
             self.process = None
             self._server_args = None
@@ -361,8 +391,10 @@ def _start_process(self, server_args: tuple[str | int, ...]) -> None:
             ]
 
         logger.debug("Starting Control Mode process: %s", cmd)
-        popen_factory = self._process_factory or subprocess.Popen
-        self.process = popen_factory(  # type: ignore[arg-type]
+        popen_factory: _ProcessFactory = (
+            self._process_factory or subprocess.Popen  # type: ignore[assignment]
+        )
+        self.process = popen_factory(
             cmd,
             stdin=subprocess.PIPE,
             stdout=subprocess.PIPE,
@@ -416,7 +448,7 @@ def _write_line(
             msg = "control mode process unavailable"
             raise exc.ControlModeConnectionError(msg) from None
 
-    def _reader(self, process: subprocess.Popen[str]) -> None:
+    def _reader(self, process: _ControlProcess) -> None:
         assert process.stdout is not None
         try:
             for raw in process.stdout:
@@ -426,7 +458,7 @@ def _reader(self, process: subprocess.Popen[str]) -> None:
         finally:
             self._protocol.mark_dead("EOF from tmux")
 
-    def _drain_stderr(self, process: subprocess.Popen[str]) -> None:
+    def _drain_stderr(self, process: _ControlProcess) -> None:
         if process.stderr is None:
             return
         for err_line in process.stderr: