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 74
• requires_auth — def at line 78; references register_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_state
• requires_csrf — def at line 82; references register_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_state
• requires_api_key — def at line 86; references register_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_state
• on_connect — def at line 89; references register_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_state
• on_disconnect — def at line 93; references 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, debug, _store_remote_tool_metadata, _associate_declared_context, agent_zero_version, build_exec_config, _remote_tool_state
• process — 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; references get, 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; references str, get, strip, subscribe_sid_to_context, computer_use_metadata_for_sid
• _remote_tool_state — def at line 230; references computer_use_metadata_for_sid
• _handle_subscribe_context — def at line 251; references str, get, strip, int, error, subscribe_sid_to_context, get_context_log_entries, _emit_context_snapshot, _start_streaming
• _handle_unsubscribe_context — def at line 303; references str, get, strip, error, _cancel_streaming, unsubscribe_sid_from_context
• _handle_send_message — def at line 320; references str, 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; references str, 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; references str, get, strip, error, remove, mark_dirty_for_context, _emit_message_queue_updated, _queue_items_for_context
• _handle_message_queue_send — def at line 517; references str, get, strip, bool, error, has_queue, _emit_message_queue_updated
• _normalize_attachment_refs — def at line 579; references isinstance, strip, str, get, lower, startswith, append, split, int, len
• _queue_item_payload — def at line 607; references str, 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; references get, _queue_items_for_context, repr, bool, is_running
• _context_is_running — def at line 644; references get, 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; references str, get, strip, error, resolve_pending_file_op
• _handle_remote_tree_update — def at line 694; references get, isinstance, strip, error, store_remote_tree_snapshot
• _handle_exec_op_result — def at line 732; references str, get, strip, error, resolve_pending_exec_op
• _handle_computer_use_op_result — def at line 754; references str, get, strip, error, resolve_pending_computer_use_op
• _handle_browser_op_result — def at line 776; references str, get, strip, error, resolve_pending_browser_op
• _handle_gateway_control_result — def at line 798; references str, get, strip, error, resolve_pending_gateway_control
• _resolve_context — def at line 818; references import, get_existing_context, create_context, use, communicate, UserMessage, result, error, _emit_context_error, str, _emit_context_complete
• _run_message — def at line 848; references use, 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; references emit_to, _queue_items_for_context
• _start_streaming — def at line 943; references get, 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; references pop, 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; references max, 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; references max, int, subscribed_contexts_for_sid, get_context_log_entries, _queue_state_for_context_id, emit_to

File-level call references

• import — line 14
• register_sid — line 90
• debug — line 91
• unregister_sid — line 94
• _cancel_streaming — line 96
• clear_remote_tree_snapshot — line 97
• fail_pending_file_ops_for_sid — line 98
• fail_pending_exec_ops_for_sid — line 102
• fail_pending_computer_use_ops_for_sid — line 106
• fail_pending_browser_ops_for_sid — line 110
• fail_pending_gateway_controls_for_sid — line 114
• clear_sid_computer_use_metadata — line 118
• clear_sid_host_browser_metadata — line 119
• clear_sid_remote_file_metadata — line 120
• clear_sid_remote_exec_metadata — line 121
• clear_sid_launcher_gateway_metadata — line 122
• _store_remote_tool_metadata — line 132
• _associate_declared_context — line 133
• agent_zero_version — line 136
• build_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 176
• startswith — line 178
• error — line 179
• get — line 182
• isinstance — line 193
• store_sid_computer_use_metadata — line 194
• store_sid_host_browser_metadata — line 198
• store_sid_remote_file_metadata — line 202
• store_sid_remote_exec_metadata — line 206
• store_sid_launcher_gateway_metadata — line 210
• str — line 215
• strip — line 215
• subscribe_sid_to_context — line 227
• computer_use_metadata_for_sid — line 231
• host_browser_metadata_for_sid — line 232
• remote_file_metadata_for_sid — line 233
• remote_exec_metadata_for_sid — line 234
• lower — line 235
• sorted — line 237
• subscribed_contexts_for_sid — line 237
• bool — line 238
• int — line 259
• get_context_log_entries — line 277
• _emit_context_snapshot — line 282
• _start_streaming — line 290
• unsubscribe_sid_from_context — line 317
• list — line 334
• _normalize_attachment_refs — line 335
• _resolve_context — line 352
• log — line 400
• create_task — line 408
• _run_message — line 409
• add — line 464
• mark_dirty_for_context — line 470
• _emit_message_queue_updated — line 471
• _queue_item_payload — line 476
• _queue_items_for_context — line 477
• remove — line 506
• has_queue — line 544
• send_all_aggregated — line 554
• pop_item — line 557
• pop_first — line 557
• send_message — line 565
• append — line 603
• split — line 610
• len — line 617
• get_queue — line 628
• repr — line 641
• is_running — line 649
• subscribed_sids_for_context — line 663
• emit_to — line 665
• resolve_pending_file_op — line 685
• store_remote_tree_snapshot — line 724
• resolve_pending_exec_op — line 745
• resolve_pending_computer_use_op — line 767
• resolve_pending_browser_op — line 789
• resolve_pending_gateway_control — line 810
• get_existing_context — line 832
• create_context — line 839
• use — line 859
• communicate — line 860
• UserMessage — line 861
• result — line 863
• _emit_context_error — line 866
• _emit_context_complete — line 871
• done — line 953
• _stream_events — line 957
• pop — line 967
• get_loop — line 969
• call_soon_threadsafe — line 969
• max — line 980
• _queue_state_for_context_id — line 981
• _context_is_running — line 982
• _replay_history_snapshots — line 985
• sleep — line 1022

Source: plugins/_a0_connector/api/ws_connector.py