Function watchDomainTask

static/js/accounts.js:76–113

(fetchTask, onUpdate, maxWaitMs = 20 * 60 * 1000, options = {})

}

async function watchDomainTask(fetchTask, onUpdate, maxWaitMs = 20 * 60 * 1000, options = {}) {
    const startedAt = Date.now();
    const poller = createAdaptivePoller({
        baseIntervalMs: Number(options.baseIntervalMs || 1200),
        maxIntervalMs: Number(options.maxIntervalMs || 12000),
    });
    let lastError = null;

    while (Date.now() - startedAt < maxWaitMs) {
        try {
            const task = await fetchTask();
            poller.recordSuccess();

            if (typeof onUpdate === 'function') {
                onUpdate(task);
            }

            const status = String(task?.status || '').toLowerCase();
            if (TASK_TERMINAL_STATUSES.has(status)) {
                return task;
            }
        } catch (error) {
            lastError = error;
            const statusCode = Number(error?.response?.status || 0);
            if (statusCode === 404) {
                throw error;
            }
            poller.recordError();
        }

        await sleep(poller.nextDelay({ forceSlow: !api.networkOnline }));
    }

    if (lastError && lastError.message) {
        throw new Error(`任务等待超时: ${lastError.message}`);
    }
    throw new Error('任务等待超时，请稍后刷新查看结果');
}

async function watchAccountTask(taskId, onUpdate, maxWaitMs = 20 * 60 * 1000) {
    return watchDomainTask(