^hSrSSKJr SSKrSSKJr SSKJrJrJrJ r SSK J r SSK J r Jr SSKJrJr SS KJr S S KJr S r\(aSSKr"S S\\R25rSSjrSSjr"SS\5rS\4S\4/rg)zOA Websocket Handler for emitting Jupyter server events. .. versionadded:: 2.0 ) annotationsN)datetime) TYPE_CHECKINGAnyOptionalcast) ensure_async)web websocket) authorizedws_authenticated)JupyterHandler) APIHandlereventscf^\rSrSrSr\rSr\U4Sj5r S Sjr Sr Sr Sr U=r$) SubscribeWebsocketz+Websocket handler for subscribing to eventsc# URn[URRXSS55IShvN nU(d[R "S5egN"7f)zcHandles authorization when attempting to subscribe to events emitted by Jupyter Server's eventbus. executerNi) current_userr authorizer is_authorizedr HTTPError)selfuserr s a/home/james-whalen/.local/lib/python3.13/site-packages/jupyter_server/services/events/handlers.pypre_getSubscribeWebsocket.pre_get#sU   ' OO ) )$i J  --$ $ s6AA#Ac># [UR55IShvN [TU] "U0UD6nUb UIShvN ggN#N7f)zGet an event socket.N)r rsuperget)rargskwargsres __class__s rr"SubscribeWebsocket.get0sJ4<<>***gk4*6* ?II  + sAAAAAAcp# [SSU0UD6nUR[R"U55 g7f)zWrite an event message. schema_idN)dict write_messagejsondumps)rloggerr)datacapsules revent_listener!SubscribeWebsocket.event_listener8s033d3 4::g./s46cJURRURS9 g)zbRoutes events that are emitted by Jupyter Server's EventBus to a WebSocket client in the browser. listenerN) event_logger add_listenerr2rs ropenSubscribeWebsocket.open?s! &&0C0C&DcJURRURS9 g)zHandle a socket close.r5N)r7remove_listenerr2r9s ron_closeSubscribeWebsocket.on_closeEs ))43F3F)Gr<r*)r/z!jupyter_events.logger.EventLoggerr)strr0dict[str, Any]returnNone)__name__ __module__ __qualname____firstlineno____doc__ AUTH_RESOURCE auth_resourcerr r"r2r:r?__static_attributes__ __classcell__)r&s@rrrs]6!M %070DG0O]0 0E HHr<rc`1SknUHnX0;dM SUS3n[U5e [[URS55nURU5n[[[URS555nURU:wa#SU<SUR<SUS 3n[U5eg ) zkValidates for required fields in the JSON request body and verifies that a registered schema/version exists>r0versionr)z Missing `z` in the JSON request body.r)rOzUnregistered version: u≠z for ``N) ExceptionrrAr"rO)r0registry required_keyskeymessager)schemarOs rvalidate_modelrWJs 5M ?!#&ABGG$ $S$((;/0I\\) $F$sDHHY/01G ~~ *7+S8J&QZP[[\]  !r<cSU;a[R"USS5nU$SnU$![an[R"SS5UeSnAff=f)z+Parses timestamp from the JSON request body timestampz%Y-%m-%dT%H:%M:%S%zZNzFailed to parse timestamp from JSON request body, an ISO format datetime string with UTC offset is expected, for example, 2022-05-26T13:50:00+05:00Z)rstrptimerQr r)r0rYes r get_timestampr]_sn  $  ))${*;=STI I  mm  7   s )) AA  AcJ\rSrSrSr\r\R\ S55r Sr g) EventHandlerqzREST api handler for eventsc # UR5nUc[R"SS5e[XRR 5 URR [[URS55[SURS55[U5S9 URS5 UR5 g![a&n[R"S[U55UeSnAff=f7f) zEmit an event.NrZzNo JSON data providedr)rBr0)r)r0timestamp_override) get_json_bodyr rrWr7schemasemitrrAr"r] set_statusfinishrQ)rpayloadr\s rpostEventHandler.postvs$$& ?--%<= = 4 7$5$5$=$= >    " "sGKK $<=*GKK,?@#0#9 #  OOC KKM 4--SV,! 3 4s)+C<BC C< C9!C44C99C<r*N) rErFrGrHrIrJrKr authenticatedr rjrLr*r<rr_r_qs*%!M44r<r_z /api/eventsz/api/events/subscribe)r0rBrRz-jupyter_events.schema_registry.SchemaRegistryrCrD)r0rBrCzOptional[datetime])rI __future__rr-rtypingrrrrjupyter_core.utilsr tornador r jupyter_server.auth.decoratorr r jupyter_server.base.handlersr base.handlersrrJjupyter_events.loggerjupyter_eventsWebSocketHandlerrrWr]r_default_handlersr*r<rrxs # 55+"F7'  ,H ,H^! !$Q! !*$4:4:\"12r<