`gj! (UdZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z m Z mZeej ej"ej$ej&eeddeeddhdhz Zej,eZej2j5dd xsd j7j9d vZeGd d e Zej>d dZ de!d<ddZ"ddZ#ddZ$GddZ%GddZ&y)uCTransport abstraction for the tui_gateway JSON-RPC server. Historically the gateway wrote every JSON frame directly to real stdout. This module decouples the I/O sink from the handler logic so the same dispatcher can be driven over stdio (``tui_gateway.entry``) or WebSocket (``tui_gateway.ws``) without duplicating code. A :class:`Transport` is anything that can accept a JSON-serialisable dict and forward it to its peer. The active transport for the current request is tracked in a :class:`contextvars.ContextVar` so handlers — including those dispatched onto the worker pool — route their writes to the right peer. Backward compatibility ---------------------- ``tui_gateway.server.write_json`` still works without any transport bound. When nothing is on the contextvar and no session-level transport is found, it falls back to the module-level :class:`StdioTransport`, which wraps the original ``_real_stdout`` + ``_stdout_lock`` pair. Tests that monkey-patch ``server._real_stdout`` continue to work because the stdio transport resolves the stream lazily through a callback. ) annotationsN)AnyCallableOptionalProtocolruntime_checkable WSAECONNRESET WSAESHUTDOWNHERMES_TUI_GATEWAY_NO_FLUSH>1onyestruec eZdZdZddZddZy) Transportz-Minimal interface every transport implements.cy)z"!!!%78MQTUVQWzCallable[[], Any]r?zthreading.Lockr!r$rr#r%r&r'r( __slots__r@rrrrrr8r8ds,IBHrr8c,eZdZdZdZddZddZd dZy) TeeTransportu]Mirrors writes to one primary plus N best-effort secondaries. The primary's return value (and exceptions) determine the result — secondaries swallow failures so a wedged sidecar never stalls the main IO path. Used by the PTY child so every dispatcher emit lands on stdio (Ink) AND on a back-WS feeding the dashboard sidebar. _primary _secondariesc ||_||_yr=rZ)rprimary secondariess rr@zTeeTransport.__init__s 'rc|jj|}|jD]} |j||S#t$rY$wxYwr=)r[rr\ Exception)rroksecs rrzTeeTransport.writesV ]]  %$$ C  #     sA A  A c |jj|jD]} |jy#t$rY"wxYw#|jD]"} |j#t$rY wxYwwxYwr=)r[rr\ra)rrcs rrzTeeTransport.closes  MM   !(( IIK !(( IIK  s>A? A  A BA0/B0 A< 9B;A< <BN)r^ 'Transport'r_rer!r$rr#rVrrrrYrYs-I(rrY)r!Optional[Transport])r1rfr#)'r( __future__r contextvarsrLrDloggingos threadingtypingrrrrr frozensetEPIPE ECONNRESETEBADF ESHUTDOWNgetattrrM getLoggerr%rNenvironr-striplowerrPr ContextVarr+__annotations__r.r2r6r8rYrrrrys.,#  GG  KK  KK OO E?B' E>2& D     8 $**..!>CIrPPRXXZ_===K"?$ - $ SSl!!r