`gj ndZddlmZddlZddlZddlmZejeZ e e e fZ ddZddZy) uSuppress benign event-loop teardown noise on the gateway serving loop. When the Desktop client forcibly closes its WebSocket while the gateway still has pending socket operations, asyncio's transport teardown logs a full traceback for every pending ``_call_connection_lost`` callback. On Windows this surfaces as ``ConnectionResetError: [WinError 10054]`` (and the rarer ``ConnectionAbortedError: [WinError 10053]``); on POSIX it is the equivalent ``ConnectionResetError``/``BrokenPipeError``. A single client disconnect can emit 50+ identical tracebacks into ``errors.log`` (#50005). These are not actionable — they are the expected side effect of the peer hanging up before our writes drained. We install a loop exception handler that collapses exactly this class of teardown error to one debug line and forwards everything else to asyncio's default handler unchanged, so genuine loop bugs still surface. ) annotationsN)Anyc|jd}t|tsy|jd}|jd}d}|t|vxs |t|vS)u>True when the loop error is a peer-hangup during transport teardown. Gated on BOTH the exception type AND the ``_call_connection_lost`` callback so we only swallow the disconnect flood — any other place these errors surface (a real handler, a custom callback) still goes to the default handler. exceptionFcallbackhandle_call_connection_lost)get isinstance_BENIGN_TEARDOWN_ERRORSrepr)contextexcrrmarkers I/root/.hermes/venv/lib/python3.12/site-packages/tui_gateway/loop_noise.py_is_benign_teardownr#s` ++k "C c2 3{{:&H [[ "F $F T(^ # =vf'==ct|ddry|jdfd }|j| d|_y#tt f$rYywxYw)zChain a teardown-noise filter ahead of the loop's existing handler. Idempotent: re-installing on a loop that already has the filter is a no-op, so it's safe to call on every reconnect/serve entry. _hermes_noise_filter_installedFNct|r&tjd|jdy ||y|j |y)Nz/ws peer hangup during teardown (suppressed): %sr)r_logdebugr default_exception_handler)looprpreviouss r_handlerz+install_loop_noise_filter.._handlerAsI w ' JJA K(     T7 #  * *7 3rT)rasyncio.AbstractEventLooprdict[str, Any]returnNone)getattrget_exception_handlerset_exception_handlerrAttributeError TypeError)rrrs @rinstall_loop_noise_filterr&6s\ t5u=))+H 4 x( .2+ I &   sAAA)rrrbool)rrrr )__doc__ __future__rasynciologgingtypingr getLogger__name__rConnectionResetErrorConnectionAbortedErrorBrokenPipeErrorr rr&rrr3sG"#w" >& r