Implements browser-based real-time chat messaging, bridging UI events to messaging infrastructure as a chat channel integration.

Stub for unimplemented endpoint responses; saves sessions in init.ts.

Sends an asynchronous JSON-RPC notification using an outbound codec resolved by method name.

WebSocket client handling verified for Wormhole protocol

Merges optimistic UI updates into a page's state within a realtime sync context.

Orchestrates bidirectional audio streaming between telephony and AI providers.

Activity State System — derives visual activity from gateway events. Maps event type + room preset → agent activity for 3D visualization. Pure functions, no React/Three.js dependen

Constructs HTTP API server for realtime app; wires routes, DB, JSON handling, context.

Streams audio data from microphone to server for real-time voice processing.

Streams notebook code exec output in realtime, cleaning logs and rendering results for Jupyter sessions via client.

Sets up authenticated WebSocket server, handling connections and messages for agent runtime.

Subscribes to Redis Pub/Sub channels with optional handler callbacks, updating internal state and triggering subscribed event on first subscription.

Main editor component integrating a rich‑text area, real‑time linting, and a collapsible lint sidebar.

Displays real‑time analytics of sessions, token usage, and events using heatmaps, trend lines, and interactive charts refreshed via WebSocket.

Live feed of agent events with server‑driven filters, batched pagination, and debounced refetch that preserves user scroll state.

Renders live transcript UI, displaying real-time text within card layout.

Processes incoming CDP events, updates internal state for network requests and JavaScript dialogs, then triggers registered callbacks.

MessageTicker — horizontal scrolling feed of recent agent messages Displays a news-ticker style bar at the bottom of the pixel office showing the latest messages from all active ag

OpenClaw Pixel Agents — Backend Server Polls the OpenClaw Gateway for agent states via the CLI and exposes them via REST + WebSocket. Uses `openclaw sessions --all-agents --json` a

Controls voice session lifecycle, validates runtime values, grants, and handles turn state for voice interactions.

Renders chat UI using AI SDK's useChat hook; manages messages, input state, and streaming responses.

Manages CDP event callbacks, network logs, and dialog state. Provides ordered, non-blocking event processing via an async worker queue to keep the WebSocket read loop responsive.

Team-deathmatch rules: score, clock, respawns, kill feed events and the end-of-match summary. Kept free of rendering and input so the whole match can be simulated headlessly in a t

Defines enums and data classes for multiplayer game and chat group modes, user roles, game mechanics, and event handling.

Feishu/Lark channel — connects to Feishu via WebSocket (no public IP needed).

Adds a WebSocket route to the router with optional dependencies, merging them with existing router-level dependencies.

Decorator for defining WebSocket endpoints on an APIRouter, registering a WebSocket route with optional dependencies.

Module exposing: handleWebSocketMessage, handleWebSocketClose, broadcastToConnections, sendToConnection, sendError

Checks if the current WebSocket connection is healthy and establishes a new one if not, ensuring reliable communication.

Intentionally closes the socket connection, marking it as intentional and clearing any error or retry timers to prevent reconnection attempts.

WebSocket chat client for OpenClaw Gateway. Uses device auth (Ed25519 keypair) for full scope access. /

Plugin-style registry for managing multiple communication channels.

Provides a provider-agnostic protocol and events for real-time speech-to-speech voice sessions, supporting multiple backends including Qwen, Gemini, and OpenAI Realtime.

Nanostores store that tracks live preview ports from a WebContainer, exposing ready state and base URLs.

Sends a structured event with type, timestamp, and optional data to a registered callback, enabling external monitoring or logging of agent activity.

Renders an animated green dot to indicate live or active status, commonly used for real-time presence indicators.

Singleton SSE event bus that deduplicates gateway events and broadcasts processed events to N clients. Solves the N-listener duplication problem by funneling all gateway events thr

Creates a service hub for live synchronization in the browser.

Frame definitions and serialization for E2EE handshake protocol.

Provides global state sync via realtime subscriptions, bridging MCP and LSP clients to update app context across components.

Defines gateway client configuration for protocol agents, client resolution, and realtime settings, enabling dynamic per-client setup.

Data class representing a chat message with sender, content, and timestamp fields.

Builds JSON schema for voice tool parameters, enabling AI function calling.

Custom error thrown when a channel action has expired or is no longer available, preventing stale operations.

Kotlin call state graph managing call lifecycle transitions and signaling events.

Creates a new chat room via HTTP handler, validates request, persists room metadata, returns confirmation.

Error thrown when channel delivery is stopped, signaling that no further messages will be processed.

Copyright (c) Microsoft Corporation. Licensed under the MIT License.

Handles WebSocket media streaming for real-time audio transport.

Sends a message to all team members except the sender and optionally excluded agents, delivering via transport and triggering wakeup notifications.