Function initializeWebSocket

dash/dash-renderer/src/observers/websocketObserver.ts:53–264

(
    store: Store<IStoreState>,
    config: DashConfig
)

 * @param config Dash configuration
 */
export async function initializeWebSocket(
    store: Store<IStoreState>,
    config: DashConfig
): Promise<void> {
    // Initialize WebSocket if:
    // 1. Global websocket is enabled, OR
    // 2. WebSocket config is available (for per-callback websocket=True)
    const wsAvailable = !!(
        config.websocket?.url && config.websocket?.worker_url
    );
    if (!wsAvailable) {
        return;
    }

    // Check if SharedWorker is supported
    if (typeof SharedWorker === 'undefined') {
        console.warn(
            'SharedWorker not supported in this browser. ' +
                'WebSocket callbacks will fall back to HTTP.'
        );
        return;
    }

    const workerClient = getWorkerClient();

    // Helper to process a single set_props payload
    const processSetProps = (payload: SetPropsPayload) => {
        const {componentId, props: rawProps} = payload;
        const parsedId = parseComponentId(componentId);
        const state = store.getState();
        const componentPath = getPath(state.paths, parsedId);

        if (!componentPath) {
            console.warn(
                `SET_PROPS: Component ${componentId} not found in layout`
            );
            return;
        }

        // Get old component for Patch processing and path recomputation
        const oldComponent = path(componentPath, state.layout) as Record<
            string,
            unknown
        > | null;
        const oldProps = (oldComponent?.props || {}) as Record<string, unknown>;

        // Process props to handle Patch objects
        const processedProps = parsePatchProps(rawProps, oldProps);

        // Update the component props
        store.dispatch(
            updateProps({
                props: processedProps,
                itempath: componentPath,
                renderType: 'websocket'
            }) as any
        );