Source symbols: plugins/_a0_connector/api/ws_connector.py
Deterministic, value-free symbol metadata extracted from public source. Implementations and literal values are not copied into this page.
- Revision: main@d1d48bc9c0e6e253e87c354ce757c518820c6e25 · 2026-07-20T15:04:19Z
- Declarations: 37
- Referenced calls: 107
Declared symbols
WsConnector— class at line 74requires_auth— def at line 78; referencesregister_sid,debug,unregister_sid,_cancel_streaming,clear_remote_tree_snapshot,fail_pending_file_ops_for_sid,fail_pending_exec_ops_for_sid,fail_pending_computer_use_ops_for_sid,fail_pending_browser_ops_for_sid,fail_pending_gateway_controls_for_sid,clear_sid_computer_use_metadata,clear_sid_host_browser_metadata,clear_sid_remote_file_metadata,clear_sid_remote_exec_metadata,clear_sid_launcher_gateway_metadata,_store_remote_tool_metadata,_associate_declared_context,agent_zero_version,build_exec_config,_remote_tool_staterequires_csrf— def at line 82; referencesregister_sid,debug,unregister_sid,_cancel_streaming,clear_remote_tree_snapshot,fail_pending_file_ops_for_sid,fail_pending_exec_ops_for_sid,fail_pending_computer_use_ops_for_sid,fail_pending_browser_ops_for_sid,fail_pending_gateway_controls_for_sid,clear_sid_computer_use_metadata,clear_sid_host_browser_metadata,clear_sid_remote_file_metadata,clear_sid_remote_exec_metadata,clear_sid_launcher_gateway_metadata,_store_remote_tool_metadata,_associate_declared_context,agent_zero_version,build_exec_config,_remote_tool_staterequires_api_key— def at line 86; referencesregister_sid,debug,unregister_sid,_cancel_streaming,clear_remote_tree_snapshot,fail_pending_file_ops_for_sid,fail_pending_exec_ops_for_sid,fail_pending_computer_use_ops_for_sid,fail_pending_browser_ops_for_sid,fail_pending_gateway_controls_for_sid,clear_sid_computer_use_metadata,clear_sid_host_browser_metadata,clear_sid_remote_file_metadata,clear_sid_remote_exec_metadata,clear_sid_launcher_gateway_metadata,_store_remote_tool_metadata,_associate_declared_context,agent_zero_version,build_exec_config,_remote_tool_stateon_connect— def at line 89; referencesregister_sid,debug,unregister_sid,_cancel_streaming,clear_remote_tree_snapshot,fail_pending_file_ops_for_sid,fail_pending_exec_ops_for_sid,fail_pending_computer_use_ops_for_sid,fail_pending_browser_ops_for_sid,fail_pending_gateway_controls_for_sid,clear_sid_computer_use_metadata,clear_sid_host_browser_metadata,clear_sid_remote_file_metadata,clear_sid_remote_exec_metadata,clear_sid_launcher_gateway_metadata,_store_remote_tool_metadata,_associate_declared_context,agent_zero_version,build_exec_config,_remote_tool_stateon_disconnect— def at line 93; referencesunregister_sid,_cancel_streaming,clear_remote_tree_snapshot,fail_pending_file_ops_for_sid,fail_pending_exec_ops_for_sid,fail_pending_computer_use_ops_for_sid,fail_pending_browser_ops_for_sid,fail_pending_gateway_controls_for_sid,clear_sid_computer_use_metadata,clear_sid_host_browser_metadata,clear_sid_remote_file_metadata,clear_sid_remote_exec_metadata,clear_sid_launcher_gateway_metadata,debug,_store_remote_tool_metadata,_associate_declared_context,agent_zero_version,build_exec_config,_remote_tool_stateprocess— def at line 125; references_store_remote_tool_metadata,_associate_declared_context,agent_zero_version,build_exec_config,_remote_tool_state_store_remote_tool_metadata— def at line 187; referencesget,isinstance,store_sid_computer_use_metadata,clear_sid_computer_use_metadata,store_sid_host_browser_metadata,clear_sid_host_browser_metadata,store_sid_remote_file_metadata,clear_sid_remote_file_metadata,store_sid_remote_exec_metadata,clear_sid_remote_exec_metadata,store_sid_launcher_gateway_metadata,clear_sid_launcher_gateway_metadata,str,strip,subscribe_sid_to_context,computer_use_metadata_for_sid_associate_declared_context— def at line 214; referencesstr,get,strip,subscribe_sid_to_context,computer_use_metadata_for_sid_remote_tool_state— def at line 230; referencescomputer_use_metadata_for_sid_handle_subscribe_context— def at line 251; referencesstr,get,strip,int,error,subscribe_sid_to_context,get_context_log_entries,_emit_context_snapshot,_start_streaming_handle_unsubscribe_context— def at line 303; referencesstr,get,strip,error,_cancel_streaming,unsubscribe_sid_from_context_handle_send_message— def at line 320; referencesstr,get,strip,list,isinstance,_normalize_attachment_refs,error,_resolve_context,subscribed_contexts_for_sid,subscribe_sid_to_context,get_context_log_entries,_emit_context_snapshot,_start_streaming,log_handle_message_queue_add— def at line 423; referencesstr,get,strip,list,isinstance,_normalize_attachment_refs,error,add,mark_dirty_for_context,_emit_message_queue_updated,_queue_item_payload,_queue_items_for_context_handle_message_queue_remove— def at line 480; referencesstr,get,strip,error,remove,mark_dirty_for_context,_emit_message_queue_updated,_queue_items_for_context_handle_message_queue_send— def at line 517; referencesstr,get,strip,bool,error,has_queue,_emit_message_queue_updated_normalize_attachment_refs— def at line 579; referencesisinstance,strip,str,get,lower,startswith,append,split,int,len_queue_item_payload— def at line 607; referencesstr,get,split,strip,int,len_queue_items_for_context— def at line 622; references_queue_item_payload,get_queue,get,repr,bool,is_running_queue_state_for_context_id— def at line 632; referencesget,_queue_items_for_context,repr,bool,is_running_context_is_running— def at line 644; referencesget,bool,is_running,_queue_items_for_context_emit_message_queue_updated— def at line 653; references_queue_items_for_context_handle_file_op_result— def at line 672; referencesstr,get,strip,error,resolve_pending_file_op_handle_remote_tree_update— def at line 694; referencesget,isinstance,strip,error,store_remote_tree_snapshot_handle_exec_op_result— def at line 732; referencesstr,get,strip,error,resolve_pending_exec_op_handle_computer_use_op_result— def at line 754; referencesstr,get,strip,error,resolve_pending_computer_use_op_handle_browser_op_result— def at line 776; referencesstr,get,strip,error,resolve_pending_browser_op_handle_gateway_control_result— def at line 798; referencesstr,get,strip,error,resolve_pending_gateway_control_resolve_context— def at line 818; referencesimport,get_existing_context,create_context,use,communicate,UserMessage,result,error,_emit_context_error,str,_emit_context_complete_run_message— def at line 848; referencesuse,communicate,UserMessage,result,error,_emit_context_error,str,_emit_context_complete_emit_context_error— def at line 882_emit_context_complete— def at line 902_emit_context_snapshot— def at line 921; referencesemit_to,_queue_items_for_context_start_streaming— def at line 943; referencesget,done,create_task,_stream_events,pop,get_loop,call_soon_threadsafe,max,int,_queue_state_for_context_id,_context_is_running,_replay_history_snapshots,subscribed_contexts_for_sid,get_context_log_entries,emit_to_cancel_streaming— def at line 966; referencespop,done,get_loop,call_soon_threadsafe,max,int,_queue_state_for_context_id,_context_is_running,_replay_history_snapshots,subscribed_contexts_for_sid,get_context_log_entries,emit_to_stream_events— def at line 971; referencesmax,int,_queue_state_for_context_id,_context_is_running,_replay_history_snapshots,subscribed_contexts_for_sid,get_context_log_entries,emit_to_replay_history_snapshots— def at line 1032; referencesmax,int,subscribed_contexts_for_sid,get_context_log_entries,_queue_state_for_context_id,emit_to
File-level call references
import— line 14register_sid— line 90debug— line 91unregister_sid— line 94_cancel_streaming— line 96clear_remote_tree_snapshot— line 97fail_pending_file_ops_for_sid— line 98fail_pending_exec_ops_for_sid— line 102fail_pending_computer_use_ops_for_sid— line 106fail_pending_browser_ops_for_sid— line 110fail_pending_gateway_controls_for_sid— line 114clear_sid_computer_use_metadata— line 118clear_sid_host_browser_metadata— line 119clear_sid_remote_file_metadata— line 120clear_sid_remote_exec_metadata— line 121clear_sid_launcher_gateway_metadata— line 122_store_remote_tool_metadata— line 132_associate_declared_context— line 133agent_zero_version— line 136build_exec_config— line 138_remote_tool_state— line 139_handle_subscribe_context— line 143_handle_unsubscribe_context— line 146_handle_send_message— line 149_handle_message_queue_add— line 152_handle_message_queue_remove— line 155_handle_message_queue_send— line 158_handle_file_op_result— line 161_handle_remote_tree_update— line 164_handle_exec_op_result— line 167_handle_computer_use_op_result— line 170_handle_browser_op_result— line 173_handle_gateway_control_result— line 176startswith— line 178error— line 179get— line 182isinstance— line 193store_sid_computer_use_metadata— line 194store_sid_host_browser_metadata— line 198store_sid_remote_file_metadata— line 202store_sid_remote_exec_metadata— line 206store_sid_launcher_gateway_metadata— line 210str— line 215strip— line 215subscribe_sid_to_context— line 227computer_use_metadata_for_sid— line 231host_browser_metadata_for_sid— line 232remote_file_metadata_for_sid— line 233remote_exec_metadata_for_sid— line 234lower— line 235sorted— line 237subscribed_contexts_for_sid— line 237bool— line 238int— line 259get_context_log_entries— line 277_emit_context_snapshot— line 282_start_streaming— line 290unsubscribe_sid_from_context— line 317list— line 334_normalize_attachment_refs— line 335_resolve_context— line 352log— line 400create_task— line 408_run_message— line 409add— line 464mark_dirty_for_context— line 470_emit_message_queue_updated— line 471_queue_item_payload— line 476_queue_items_for_context— line 477remove— line 506has_queue— line 544send_all_aggregated— line 554pop_item— line 557pop_first— line 557send_message— line 565append— line 603split— line 610len— line 617get_queue— line 628repr— line 641is_running— line 649subscribed_sids_for_context— line 663emit_to— line 665resolve_pending_file_op— line 685store_remote_tree_snapshot— line 724resolve_pending_exec_op— line 745resolve_pending_computer_use_op— line 767resolve_pending_browser_op— line 789resolve_pending_gateway_control— line 810get_existing_context— line 832create_context— line 839use— line 859communicate— line 860UserMessage— line 861result— line 863_emit_context_error— line 866_emit_context_complete— line 871done— line 953_stream_events— line 957pop— line 967get_loop— line 969call_soon_threadsafe— line 969max— line 980_queue_state_for_context_id— line 981_context_is_running— line 982_replay_history_snapshots— line 985sleep— line 1022
Source: plugins/_a0_connector/api/ws_connector.py