Be)'ddlmZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z mZddlmZmZmZmZddlmZddlmZddlmZmZmZmZmZdd lmZd d l m Z d d l!m"Z"d dl#m$Z$d dl%m&Z&m'Z'd dl(m)Z)m(Z(ej*e+Z,eeeefZ-ej.GddZ/GddeZ0d*dZ1d+dZ2d,dZ3d,d Z4d-d#Z5d$Z6d%Z7e d.d'Z8e d/d0d)Z9dS)1) annotationsN)contextmanager)partialwraps)CallableIteratorListOptional)SessionContext)Document)ColumnDataChangedEventColumnsPatchedEventColumnsStreamedEventDocumentChangedEventModelChangedEvent)CustomJS)config)param_watchers)LOADING_INDICATOR_CSS_CLASS)holdmonkeypatch_events) curdoc_lockedstatec.eZdZUded<ded<ded<dS)Requestdictheaderscookies argumentsN)__name__ __module__ __qualname____annotations__1lib/python3.11/site-packages/panel/io/document.pyrr*s0NNNNNNr'rcXeZdZddfd ZdZed dZedZxZS) MockSessionContextN)documentcN||_tj|ddd|dS)N)server_context session_id) _documentsuper__init__)selfr+argskwargs __class__s r(r1zMockSessionContext.__init__3s3!$tOOOOOOOr'cdSNr&)r2r3s r(with_locked_documentz'MockSessionContext.with_locked_document7sr'returnboolcdS)NFr&r2s r( destroyedzMockSessionContext.destroyed:sur'c&tiiiS)N)rr r!)rr<s r(requestzMockSessionContext.request>sr2<<<  #MOOF ~  ) ) Mr'c 2t|}|js|Stj}|r|jt j|<tjr:| dtdtdtj d|jj }t jd}||vr|S||dt ji|dt j|S)Ndocument_readyze const body = document.getElementsByTagName('body')[0] body.classList.remove(z, z) )codesessionsstarted)rksession_context threadingcurrent_threadidentr _thread_id_rglobal_loading_spinner js_on_eventrrloading_spinnerid session_infoupdatedtdatetimenow timestampon_event _init_session)rBrjthreadr.ros r(init_docrs* &s + +F  !  % ' 'F 1$*L&! $  h-#>--DJDZ---   '*J!*-H!!  Z2;??$$..00! OO$e&9::: Mr'funcrctjrtfd}ntfd}d|_|S)a) Wrap a callback function to execute with a lock allowing the function to modify bokeh models directly. Arguments --------- func: callable The callable to wrap Returns ------- wrapper: callable Function wrapped to execute without a Document lock. c$K|i|d{VSr7r&r3kwrs r(wrapperzwith_lock..wrappers.t*r******** *r'c|i|Sr7r&rs r(rzwith_lock..wrappers4$$$ $r'T)inspectiscoroutinefunctionrlock)rrs` r( with_lockrs}"4((% t + + + +  + + t % % % %  %GL Nr'c 8ddlm}|j}t|dd}|r|rgS|jd|}|||j|||j |||j g}|j D]p}tj |j}|} ||||||| dgq|S)Nr)WebSocketHandler ws_connectionF PATCH-DOCT)binary)tornado.websocketr_socketgetattr is_closingprotocolcreate write_message header_json metadata_json content_json_buffersjsondumpsr_to_bytesextend) connrCrsocketws_connmsgfuturesbufferheaderpayloads r(dispatch_tornadors0222222 \Ffou55G g((** -  {F 3 3C&&vs??&&vs/@AA&&vs/?@@G ,  FJ''//##  * *66 : :  * *674 * H H      Nr'c|j}|jd|}||j||j||jg}|jD]n}tj |j }| }| ||||go|S)Nr) text_data) binary_data) rrrsendrrrrrrr_rr)rrCrrrrrrs r(dispatch_djangors \F -  {F 3 3C co .. c/ 00 c. //G ,  FJ''//## KK&K ) ) KKGK , ,      Nr'rc #\ Ktj}t|dd}t|dd}||| tjrdVdS|jjrdVt |jjdSddlm m }|j }|  dVd}|D]2}|j }t|dr|jjjdkrd}n3|jj}t |gg} } |D]D} t%| t&r|s| | /| | Eg|D]A}| st%|j |rt+|| z .t-|| z B fd } rltj|rC t1j| n:#t4$r|| YnwxYw|| | |j_ |dS#t4$r2| r,|t;t<|| YdSYdSwxYw# |w#t4$r0| r+|t;t<|| YwYwwxYwxYw) z Context manager which unlocks a Document and dispatches ModelChangedEvents triggered in the context body to all sockets on current sessions. rqNsessionr)WebSocketClosedErrorrF write_lockTcKD]_} |d{V #$rtdY-t$r'}td|Yd}~Xd}~wwxYwdS)Nz/Failed sending message as connection was closedz/Failed sending message due to following error: )loggerwarningrO)futureerrs r(handle_write_errorsz%unlocked..handle_write_errorss! Z ZZ LLLLLLLL+VVVNN#TUUUUU ZZZNN#XUV#X#XYYYYYYYYZ  Z ZsA# A#AA#)rrjr_jupyter_kernel_contextrG hold_valuer _held_eventsrrr_subscribed_connectionsrrrPr_block_valuerVDISPATCH_EVENTSappendrr _unblockedasyncio ensure_future RuntimeErroradd_next_tick_callbackunholdrrJ)rjrqrr connectionslockedrrrCremaining_eventsdispatch_eventsrIrrrs @@r(unlockedrs\Ff&7>>Ooy$77G ~0GOuGdO    $ 6+8999HHHHHHHH1K KKMMM5c   D\Fv|,, 1B1I1PTU1U1U!.6""",./ / /E%11 /& /&&u---- ''.... B BD" BDL*:;; B+D/BBB?4AAA Z Z Z Z Z Z  C'' CG)*=*=*?*?@@@@#GGG112EFFFFFG--.ABBB(8% c MMOOOOO c c c c--g6FP`.a.abbbbbb c c c c c MMOOOO c c c c--g6FP`.a.abbbbb c c csgDIF;:I;GIG$IH5IIJ+I.-J+.5J(#J+'J((J+Document | Nonec#BK|p tj}|r|jsdVdS|jj}|jj}g|j_|jt5dVdddn #1swxYwY||j_||j_dS)a$ Context manager to trigger immediate dispatch of events triggered inside the execution context even when Document events are currently on hold. Arguments --------- doc: Document The document to dispatch events on (if `None` then `state.curdoc` is used). N)rrj_session_contextrGr_holdrr)rB old_eventshelds r(immediate_dispatchr+s  C c* +J = D!#CMM  CM!+CMs+A<<BB)rBr rCrDr9rE)T)rBrgr9r )rrr9r)r9rr7)rBr): __future__rr dataclassesr}r|rrloggingrr contextlibr functoolsrrtypingrrr r bokeh.application.applicationr bokeh.document.documentr bokeh.document.eventsr rrrr bokeh.modelsrrutilrloadingrmodelrrrr getLoggerr"rr dataclassrr*rJrfrkrrrrrrr&r'r(rs"""""" %%%%%%$$$$$$$$988888,,,,,,"!!!!!!!!!!!000000++++++++''''''''  8 $ $/1E   ========$////))))^84*"JcJcJcJcX,,,,,,,r'