)jdZddlZddlZddlmZddlmZddlmZej e Z dZ GddZ Gd d ZGd d ZdS) z This module implements the core RPC and publish APIs. Developers can extend LinkProtocol to provide additional RPC callbacks for their web-applications. Then extend ServerProtocol to hook all the needed LinkProtocols together. N)register)schedule_callback) EventEmittercdSN)___s J/DATA/AppData/hermes/venv/lib/python3.11/site-packages/wslink/websocket.pynoopr c0eZdZdZdZdZdZdZdZdS) LinkProtocolzu Subclass this to communicate with wslink clients. LinkProtocol objects provide rpc and pub/sub actions. cDt|_t|_d|_dSr)r publish addAttachment coreServerselfs r __init__zLinkProtocol.__init__!s !rc0||_||_||_dSrrr stopServerrrrrs r initzLinkProtocol.init' *$rcH|jr|j|SdSr)rgetSharedObjectrkeys r rzLinkProtocol.getSharedObject,s' ? 8?22377 7trcdSzCalled when a new websocket connection is established. request is the HTTP request header, and client_id an opaque string that identifies the connection. The default implementation is a noop. A subclass may redefine it. Nrrrequest client_ids r onConnectzLinkProtocol.onConnect1r rcdSz-Called when a websocket connection is closed.Nrrr&s r onClosezLinkProtocol.onClose:r rN) __name__ __module__ __qualname____doc__rrrr'r+rrr rrsi  %%%     <<<<cT%777"3'''&,D s # # #rc2||jvr |j|SdSr)rer s r rzServerProtocol.getSharedObjects# $$ $ $%c* *trcvt|tsJ||_|j|dSr) isinstancerrr_append)rprotocols r registerLinkProtocolz#ServerProtocol.registerLinkProtocols=(L11111" !!(+++++rct|tsJd|_ |j|dS#t $r6d}t ||d|YdSwxYw)Nz+Link protocol missing from registered list.rX) rkrrr_remove ValueErrorloggerrXr^)rrm error_messages r unregisterLinkProtocolz%ServerProtocol.unregisterLinkProtocols(L11111" 5   % %h / / / / / 5 5 5IM LL ' ' '   Wm 4 4 4 4 4 4 5s<rs (((((($$$$$$''''''  8 $ $ < < < < < < <