@@ -74,31 +74,10 @@ def initialize_settings(self):
7474 self .event_logger .add_listener (
7575 schema_id = JUPYTER_COLLABORATION_EVENTS_URI , listener = self ._on_chat_event
7676 )
77- self .event_loop .create_task (self ._check_notebook_observer ())
7877
7978 elapsed = time .time () - start
8079 self .log .info (f"Initialized RouterExtension in { elapsed :.2f} s" )
8180
82-
83- async def _check_notebook_observer (self ):
84- await asyncio .sleep (20 )
85- def callback (username , prev_active_cell , notebook_path ):
86- self .log .info (
87- f"notebook observer callback : { username = } , { prev_active_cell = } , { notebook_path = } "
88- )
89-
90- jcollab_api = self .serverapp .web_app .settings ["jupyter_server_ydoc" ]
91- yroom_manager = jcollab_api .yroom_manager
92- yroom = yroom_manager .get_room ("JupyterLab:globalAwareness" )
93- awareness = yroom .get_awareness ()
94- for _ , state in awareness .states .items ():
95- if username := state .get ("user" , {}).get ("username" , None ):
96- self .router .observe_notebook_activity (
97- username = username , callback = callback
98- )
99- break
100-
101-
10281 def _get_global_awareness (self ):
10382 # TODO: make this compatible with jcollab
10483 jcollab_api = self .serverapp .web_app .settings ["jupyter_server_ydoc" ]
0 commit comments