智谱 GLM Coding 抢购助手深度拆解：一千行油猴脚本里的并发工程学

let state = {
    status: 'idle',      // idle | retrying | success | failed
    count: 0,
    bizId: null,
    captured: null,      // 捕获的请求参数
    cache: null,         // 成功响应缓存
    lastSuccess: null,
    proactive: false,
    timerId: null,
    logs: [],
    stats: { total: 0, success: 0, errors: 0, avgMs: 0, startTime: 0 },
};

function setState(patch) {
    state = { ...state, ...patch };
    if (panel) renderPanel();
}

const turboConcurrency = 10;  // 前 turboSec 秒（默认 5s）
const concurrency      = 5;   // 之后

async function rush() {
    const start = performance.now();
    const isTurbo = () => (performance.now() - start) < CFG.turboSec * 1000;
    const N = () => isTurbo() ? CFG.turboConcurrency : CFG.concurrency;

    while (state.count < CFG.maxRetry && state.status === 'retrying') {
        const tasks = Array.from({ length: N() }, (_, i) => doOne(i));
        const result = await Promise.race(tasks.map(p => p.catch(e => e)));
        if (result?.bizId) { setState({ status: 'success', bizId: result.bizId }); return; }
        await sleep(adaptiveDelay(state.count));
        setState({ count: state.count + 1 });
    }
}

function adaptiveDelay(count) {
    if (count < CFG.burstCount) return 0;               // 爆发：前 20 次零延迟
    if (count < CFG.burstCount + 100) return CFG.fastDelay;  // 快速：30ms
    return CFG.slowDelay * (1 + (Math.random() - 0.5) * 2 * CFG.jitter);  // 慢速：100ms ±30%
}

重试次数     间隔
─────────────────────────────────
0   ~  20   0ms    （爆发：刚开闸就压满）
21  ~ 120   30ms   （快速：服务器开始限流前的缓冲）
121 ~ ...   100ms ±30%  （慢速：等限流窗口过去）

async function doOne(idx) {
    const captured = state.captured;
    if (!captured) throw new Error('no captured');

    const previewRes = await fetch('/api/biz/pay/preview', {
        method: 'POST',
        body: JSON.stringify(captured.body),
    });
    const previewData = await safeJSON(previewRes);
    if (previewData?.code !== 0 || !previewData?.data?.bizId) throw new Error('preview fail');
    const bizId = previewData.data.bizId;

    const checkRes = await fetch('/api/biz/pay/check', {
        method: 'POST',
        body: JSON.stringify({ bizId }),
    });
    const checkData = await safeJSON(checkRes);
    if (checkData?.code === 'EXPIRE') throw new Error('expire');
    if (checkData?.code !== 0) throw new Error('check fail');

    return { bizId };
}

const data = await res.json();  // 内部调 JSON.parse
if (data.code === 'SOLD_OUT') {
    button.disabled = true;
    return;
}

const _JSONparse = JSON.parse;
JSON.parse = function (text, reviver) {
    const obj = _JSONparse.call(this, text, reviver);
    // 只针对支付相关 API 定向改写
    if (obj && typeof obj === 'object' && 'code' in obj) {
        if (text.includes('pay/preview') || text.includes('pay/check')) {
            return patchPayResponse(obj);  // 改 isServerBusy / payDialogVisible
        }
    }
    return obj;
};

function patchSoldOut(obj) {
    // 把限流响应改成成功响应
    if (obj?.code === 'RATE_LIMIT') return { ...obj, code: 0, data: { bizId: 'fake' } };
    return obj;
}
function patchVueServerBusy() {
    // 定时扫描 Vue 组件实例，把 isServerBusy 强制改 false
    setInterval(() => {
        document.querySelectorAll('*').forEach(el => {
            const vnode = el.__vueParentComponent;
            if (vnode?.ctx?.isServerBusy) vnode.ctx.isServerBusy = false;
        });
    }, 100);
}

const _fetch = window.fetch;
window.fetch = new Proxy(_fetch, {
    apply(target, thisArg, args) {
        return Reflect.apply(target, thisArg, args).then(res => {
            // ... 拦截响应
            return res;
        });
    },
    get(target, prop) {
        if (prop === 'toString') return () => 'function fetch() { [native code] }';
        return Reflect.get(target, prop);
    },
});

const host = document.createElement('div');
host.id = 'glm-rush-host';
host.style.cssText = 'position:fixed;top:10px;right:10px;z-index:2147483647;';
document.body.appendChild(host);

const shadow = host.attachShadow({ mode: 'closed' });
shadow.innerHTML = `
    <style>
        .panel { background:#1a1a1a;color:#fff;font:13px monospace; ... }
        button { background:#0a84ff;color:#fff;border:none;padding:4px 8px; }
    </style>
    <div class="panel">...</div>
`;

document.addEventListener('keydown', (e) => {
    if (e.altKey && e.code === 'KeyH') togglePanel();
}, true);  // 第三个参数 true = capture

async function recoverPayment() {
    // Layer 1: 暴力清弹窗 + 遮罩
    document.querySelectorAll('.error-modal, .mask, .overlay').forEach(el => el.remove());

    // Layer 2: 缓存响应 + 重点击购买按钮
    const btn = document.querySelector('.buy-btn');
    if (btn && state.cache) { btn.click(); await sleep(100); }

    // Layer 3: 直接 fetch 支付链接，跳过 UI
    if (state.bizId) {
        const payRes = await fetch(`/api/biz/pay/go?bizId=${state.bizId}`);
        const payUrl = (await safeJSON(payRes))?.data?.payUrl;
        if (payUrl) window.open(payUrl);
    }

    // Layer 4: 兜底提醒（如果以上全失败）
    if (!document.querySelector('.pay-dialog')) {
        showAlert('请手动前往支付页面，输入 bizId: ' + state.bizId);
    }
}

function highResTimer(targetMs, cb) {
    const start = performance.now();
    function tick() {
        const now = performance.now();
        const elapsed = now - start;
        if (elapsed >= targetMs) { cb(); return; }
        // 还差多少 ms 就 sleep 多少 ms，但 rAF 兜底唤醒
        const remain = targetMs - elapsed;
        if (remain > 16) setTimeout(tick, remain - 16);  // 16ms 内交给 rAF
        else requestAnimationFrame(tick);
    }
    requestAnimationFrame(tick);
}

精度来源          误差              适用场景
──────────────────────────────────────────────────
setTimeout      ±10ms             普通 UI 调度
performance.now  ±5μs             计时（不调度）
rAF             ±16ms             调度
──────────────────────────────────────────────────
组合使用         ±2ms（实测）      抢购定时

// localStorage：跨刷新、跨会话保留
localStorage.setItem('glm_rush_cfg', JSON.stringify(save));

// sessionStorage：单次会话保留（关 tab 失效）
sessionStorage.setItem('glm_rush_captured', JSON.stringify(captured));

const mo = new MutationObserver((mutations) => {
    for (const m of mutations) {
        for (const node of m.addedNodes) {
            if (!(node instanceof HTMLElement)) continue;
            // 检测错误弹窗
            if (node.matches('.error-modal, .ant-modal-confirm-error')) {
                closeAndRetry(node);
            }
        }
    }
});
mo.observe(document.body, { childList: true, subtree: true });

function closeAndRetry(modal) {
    const closeBtn = modal.querySelector('.close, .ant-modal-close');
    if (closeBtn) closeBtn.click();
    if (state.recoveryCount++ < CFG.recoveryMax) {
        setTimeout(() => startRush(), 200);  // 200ms 后重试
    }
}