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.

Creates coworking tools for real-time collaboration, managing shared state and events.

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

Bukkit event fired when a player's pose changes, tracking before/after poses and allowing cancellation or pose modification.

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.

Provides authenticated WebSocket connections using session tokens for real-time communication.

React context store managing socket state and actions for real-time UI updates.

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

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.

Express server exposing WebSocket.IO runtime for realtime automation sync; serves browser-pool.

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

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

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.

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

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

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).

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

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

Represents a node in a chat tree, holding a message, child references, and a chosen child index. Enables branching conversations with observable properties and serialization suppor

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

Reusable WebSocket wrapper with builder pattern, exponential/linear/constant backoff strategies, JSON/Bebop serialization, SolidJS reactive effects, heartbeat, and auto-reconnectio

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

Generates Asterisk configuration for realtime media, defining RTP/WebSocket transport types and related settings.

WebSocket channel — streaming gateway to the KrillClaw agent. Spawns the Zig agent as a subprocess per message and streams stdout back as WebSocket frames. Uses the `websockets` li

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

Creates a fresh progress-tracking dictionary for SSE event stores, initializing status, events, error, timestamp, and a cancel event.

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

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

Plugin-style registry for managing multiple communication channels.

Enterprise-Grade Offline State Manager Features: - Multi-signal detection (browser API + server ping + Network Info API) - Stability buffer (prevents flapping between online/offlin

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

Event fired after a player's pose changes, containing the affected player and their new pose type.

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

Frame definitions and serialization for E2EE handshake protocol.

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

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

Synchronizes state between browser tabs using BroadcastChannel API and manages peer identity in localStorage for cross-tab coordination.

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.

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

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