a ?Df:?@s@dZddlmZddlZeeZddlmZm Z m Z ddl m Z m Z ddlmZddlmZmZdd lmZdd lmZdd lmZmZmZdd lmZdd lmZddlm Z ddl!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(ddl)m*Z*er$ddl+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2ddl3m4Z4dZ5GdddZ6e dS)z Implements a very low level facility for communicating with a Bokeh Server. Users will always want to use :class:`~bokeh.client.session.ClientSession` instead for standard usage. ) annotationsN) TYPE_CHECKINGAnyCallable)HTTPClientError HTTPRequest)IOLoop)WebSocketErrorwebsocket_connect)ID)Protocol) MessageError ProtocolErrorValidationError)Receiver)format_url_query_arguments)fixup_windows_event_loop_policy)CONNECTED_AFTER_ACKCONNECTED_BEFORE_ACK DISCONNECTEDNOT_YET_CONNECTEDWAITING_FOR_REPLY ErrorReasonState) WebSocketClientConnectionWrapper)Document)DocumentChangedEvent)Message) ServerInfo) ClientSession)ClientConnectionc@seZdZUdZded<ded<ded<d[d d d d dddddZeddddZeddddZed dddZ eddddZ edddd Z ed dd!d"Z ddd#d$Z d\d dd&d'd(Zddd)d*Zddd+d,Zd-dd.d/d0Zd-d1d.d2d3Zd4dd5d6Zd1dd7d8d9Zddd:d;Zddddd?d@dAZdddBdCZdDddEdFZd1dDd7dGdHZdIdJddKdLdMZd4ddNdOZdddPdQZdddRdSdTZdUddVdWdXZdddYdZZ dS)]r"z; A low-level class used to connect to a Bokeh server. r_stater_loopzCallable[[], bool] | None_until_predicateN@r!strz IOLoop | Nonezdict[str, str] | NoneintNone)session websocket_urlio_loop argumentsmax_message_sizereturncCs^||_||_||_||_t|_t|j|_d|_t |_ |durF|nt |_ d|_ d|_dS)z6 Opens a websocket connection to the server. N)_url_session _arguments_max_message_sizer _protocolr _receiver_socketrr#rr$r% _server_info)selfr*r+r,r-r.r9d/nfs/NAS7/SABIOD/METHODE/ermites/ermites_venv/lib/python3.9/site-packages/bokeh/client/connection.py__init__Us zClientConnection.__init__boolr/cCs t|jtS)zg Whether we've connected the Websocket and have exchanged initial handshake messages. ) isinstancer#rr8r9r9r: connectedjszClientConnection.connectedcCs|jS)z2 The Tornado ``IOLoop`` this connection is using. )r$r?r9r9r:r,rszClientConnection.io_loopcCs|jS)z1 The URL of the websocket this Connection is to. )r0r?r9r9r:urlwszClientConnection.urlzErrorReason | NonecCst|jtsdS|jjS)zX The reason of the connection loss encoded as a ``DISCONNECTED.ErrorReason`` enum value N)r>r#r error_reasonr?r9r9r:rB|s zClientConnection.error_reasonz int | NonecCst|jtsdS|jjS)zv If there was an error that caused a disconnect, this property holds the error code. None otherwise. r)r>r#r error_coder?r9r9r:rCs zClientConnection.error_codecCst|jtsdS|jjS)z If there was an error that caused a disconnect, this property holds the error detail. Empty string otherwise. )r>r#r error_detailr?r9r9r:rEs zClientConnection.error_detailcs ddfdd }|dS)Nr<r=cstjttfSN)r>r#rrr9r?r9r:connected_or_closedsz5ClientConnection.connect..connected_or_closed) _loop_until)r8rGr9r?r:connectszClientConnection.connectclosed)whyr/cCs|jdur|jd|dS)z* Close the Websocket connection. Ni)r6close)r8rKr9r9r:rLs zClientConnection.closecCs |dS)a  Force a round-trip request/reply to the server, sometimes needed to avoid race conditions. Mostly useful for testing. Outside of test suites, this method hurts performance and should not be needed. Returns: None N)_send_request_server_infor?r9r9r:force_roundtrips z ClientConnection.force_roundtripcs>tjtrt_nddfdd }|dS)a6 Execute a blocking loop that runs and executes event callbacks until the connection is closed (e.g. by hitting Ctrl-C). While this method can be used to run Bokeh application code "outside" the Bokeh server, this practice is HIGHLY DISCOURAGED for any real use case. r<r=cs tjtSrF)r>r#rr9r?r9r:rJsz2ClientConnection.loop_until_closed..closedN)r>r#r_tell_session_about_disconnectrrH)r8rJr9r?r:loop_until_closeds  z"ClientConnection.loop_until_closedr)documentr/cCsX|jd}||}|dur(tdn,|jddkrJtd|jdn ||dS)z Pull a document from the server, overwriting the passed-in document Args: document : (Document) The document to overwrite with server content. Returns: None z PULL-DOC-REQNConnection to server was lostmsgtypeERRORzFailed to pull document: text)r4create_send_message_wait_for_reply RuntimeErrorheadercontentZpush_to_documentr8rQmsgreplyr9r9r:pull_docs   zClientConnection.pull_doc Message[Any]cCsT|jd|}||}|dur*tdn&|jddkrLtd|jdn|SdS)z Push a document to the server, overwriting any existing server-side doc. Args: document : (Document) A Document to push to the server Returns: The server reply zPUSH-DOCNrRrSrTzFailed to push document: rU)r4rVrWrXrYrZr[r9r9r:push_docs   zClientConnection.push_docr cCs|jdur||_|jS)zq Ask for information about the server. Returns: A dictionary of server attributes. N)r7rMr?r9r9r:request_server_infos  z$ClientConnection.request_server_info)messager/c s~|jdurtd|nbz$||jIdH}td||Wn<tyx}z$td||jddWYd}~n d}~00dS)Nz-We're disconnected, so not sending message %rzSent %r [%d bytes]z#Error sending message to server: %rzreceived error while sendingrK)r6loginfosenddebugr rL)r8rbsenter9r9r: send_messages  "zClientConnection.send_messagec st|j|j}t|}z,t|d|jjg|jdIdH}t||_ Wnrt y}z,| t t j|j|jIdHWYd}~dSd}~0ty}ztd|WYd}~n d}~00|j dur| t t jddIdHn|tIdHdS)NZbokeh)Z subprotocolsr.zFailed to connect to server: %rzSocket invalid.)rr0r2rr r1tokenr3rr6r_transition_to_disconnectedrr HTTP_ERRORcoderb ExceptionrdreZ NETWORK_ERROR _transitionr)r8Z formatted_urlrequestsocketrir9r9r:_connect_asyncs" zClientConnection._connect_asynccsr|IdH}|dur2|ttjddIdHn<|jdkrTtd|j |n td|| IdHdS)NInternal server error. PATCH-DOCz"Got PATCH-DOC, applying to sessionz Ignoring %r) _pop_messagerlrrrmrSrdrgr1Z _handle_patch_nextr8rbr9r9r:_handle_messages,s   z!ClientConnection._handle_messageszCallable[[], bool]) predicater/cCsD||_z|j|j|jWnty>|dYn0dS)Nzuser interruption)r%r$ add_callbackrxstartKeyboardInterruptrL)r8r{r9r9r:rH9s  zClientConnection._loop_untilcsh|jdur>|r>td|jjj|jjd|_|jdStd|jjj|j|IdHdS)Nz4Stopping client loop in state %s due to True from %szRunning state ) r%rdrgr# __class____name__r$stoprunr?r9r9r:rxDs zClientConnection._nextzMessage[Any] | Nonec s|jdurdSd}z|jIdH}Wn0tyV}ztd|WYd}~n d}~00|durntddSz2|j|IdH}|durtd||WSWqtt t fy}z(tj d|dd|j ddWYd}~qd}~00qdS) NzError reading from socket %rzConnection closed by serverzReceived message %rz%rT)exc_infoz!error parsing message from serverrc) r6Z read_messagerordrgrer5consumerrrerrorrL)r8fragmentrirbr9r9r:rwOs$ "  zClientConnection._pop_messagecst|jd_gddddfdd }j||dd fd d }|dd fd d }|jS)Nmsgidr_z list[None]r))rb send_resultr/cs|IdH}||dSrF)rjappend)rbrresultr?r9r:handle_messagenszEClientConnection._send_message_wait_for_reply..handle_messager<r=cstdkpjkS)Nr)lenr#r9r8rwaiterr9r: have_send_result_or_disconnectedsszWClientConnection._send_message_wait_for_reply..have_send_result_or_disconnectedcsjkpjduSrF)r#r]r9)r8rr9r:have_reply_or_disconnectedwszQClientConnection._send_message_wait_for_reply..have_reply_or_disconnected)rrYr#r$r|rHr])r8rbrrrr9rr:rWis  z-ClientConnection._send_message_wait_for_replyr r) session_ideventr/cCs$|jd|g}|j|j|dS)Nrv)r4rVr$r|rj)r8rrr\r9r9r:_send_patch_document}sz%ClientConnection._send_patch_documentcCs,|jd}||}|dur&td|jS)NzSERVER-INFO-REQzs4        $       ]