Function handleWebsocketCallback

dash/dash-renderer/src/actions/callbacks.ts:699–825

* Handle serverside callback via WebSocket connection. * * Uses the SharedWorker to send the callback request through the persistent * WebSocket connection instead of HTTP POST.

(
    dispatch: any,
    hooks: any,
    config: any,
    payload: ICallbackPayload,
    running: any
)

 * WebSocket connection instead of HTTP POST.
 */
async function handleWebsocketCallback(
    dispatch: any,
    hooks: any,
    config: any,
    payload: ICallbackPayload,
    running: any
): Promise<CallbackResponse> {
    if (hooks.request_pre) {
        hooks.request_pre(payload);
    }

    const requestTime = Date.now();
    let runningOff: any;

    if (running) {
        dispatch(sideUpdate(running.running, payload));
        runningOff = running.runningOff;
    }

    const workerClient = getWorkerClient();

    try {
        // Ensure WebSocket connection is established
        await workerClient.ensureConnected(config);

        const response = await workerClient.sendCallback(payload);

        // Handle running off state
        if (runningOff) {
            dispatch(sideUpdate(runningOff, payload));
        }

        if (response.status === 'prevent_update') {
            // Record timing for profiling
            if (config.ui) {
                const totalTime = Date.now() - requestTime;
                dispatch(
                    updateResourceUsage({
                        id: payload.output,
                        usage: {
                            __dash_server: totalTime,
                            __dash_client: totalTime,
                            __dash_upload: 0,
                            __dash_download: 0
                        },
                        status: STATUS.PREVENT_UPDATE,
                        result: {},
                        inputs: payload.inputs,
                        state: payload.state
                    })
                );
            }
            return {};
        }

        if (response.status === 'error') {
            throw new Error(response.message || 'Callback error');
        }