f dZddlmZddlZddlmZmZddlZddlZddl m Z ddl m Z Gdde Z dd Z dd Ze d dd Ze d dd Z d dd ZddgZy)zJModule holding utility and convenience functions for zmq event monitoring.) annotationsN) Awaitableoverload) TypedDict)_check_versionc,eZdZUded<ded<ded<y)_MonitorMessageinteventvaluebytesendpointN)__name__ __module__ __qualname____annotations__L/var/www/cvtools/html/venv/lib/python3.12/site-packages/zmq/utils/monitor.pyr r s J JOrr ct|dk7st|ddk7rtd|tjd|d\}}t j |t j ||dd}|S)adecode zmq_monitor event messages. Parameters ---------- msg : list(bytes) zmq multipart message that has arrived on a monitor PAIR socket. First frame is:: 16 bit event id 32 bit event value no padding Second frame is the endpoint as a bytestring Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. rzInvalid event message format: z=hi)r r r)len RuntimeErrorstructunpackzmqEvent)msgevent_idr r s rparse_monitor_messager"sv* 3x1}CF q(;C5ABBmmE3q62OHe8$5!FE Lrc8K|d{}t|S7w)zyLike parse_monitor_msg, but awaitable Given awaitable message, return awaitable for the parsed monitor message. N)r") awaitable_msgr s r_parse_monitor_msg_asyncr%7s  C  %% s cyNrsocketflagss rrecv_monitor_messager+Ds"%rcyr'rr(s rr+r+Ksrctdd|j|}t|tr t |St |S)uReceive and decode the given raw message from the monitoring socket and return a dict. Requires libzmq ≥ 4.0 The returned dict will have the following entries: event : int the event id as described in `libzmq.zmq_socket_monitor` value : int the event value associated with the event, see `libzmq.zmq_socket_monitor` endpoint : str the affected endpoint .. versionchanged:: 23.1 Support for async sockets added. When called with a async socket, returns an awaitable for the monitor message. Parameters ---------- socket : zmq.Socket The PAIR socket (created by other.get_monitor_socket()) on which to recv the message flags : int standard zmq recv flags Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. )rzlibzmq event API)rrecv_multipart isinstancerr%r")r)r*r s rr+r+RsDD6-.    &C#y!',, ! %%rr"r+)r z list[bytes]returnr )r$zAwaitable[list[bytes]]r1r )r)r)zzmq.asyncio.Socketr*r r1zAwaitable[_MonitorMessage])r)zzmq.Socket[bytes]r*r r1r )r)z zmq.Socketr*r r1z,_MonitorMessage | Awaitable[_MonitorMessage])__doc__ __future__rrtypingrrr zmq.asyncio zmq._typingr zmq.errorrr r"r%r+__all__rrrr9sP # & !$i @ &) & & % % % % %     ,& ,& ,&2,&^ #$: ;r