Function executeStream

src/handler.ts:1181–1220

(detectRefusalEarly = false, onTextDelta?: (delta: string) => void)

    let retryCount = 0;

    const executeStream = async (detectRefusalEarly = false, onTextDelta?: (delta: string) => void): Promise<{ earlyAborted: boolean }> => {
        fullResponse = '';
        const apiStart = Date.now();
        let firstChunk = true;
        let earlyAborted = false;
        log.startPhase('send', '发送到 Cursor');

        // ★ 早期中止支持：检测到拒绝后立即中断流，不等完整响应
        const abortController = detectRefusalEarly ? new AbortController() : undefined;

        try {
            await sendCursorRequest(activeCursorReq, (event: CursorSSEEvent) => {
                if (event.type === 'finish') {
                    if (event.messageMetadata?.usage) cursorUsage = event.messageMetadata.usage;
                    return;
                }
                if (event.type !== 'text-delta' || !event.delta) return;
                if (firstChunk) { log.recordTTFT(); log.endPhase(); log.startPhase('response', '接收响应'); firstChunk = false; }
                fullResponse += event.delta;
                onTextDelta?.(event.delta);

                // ★ 早期拒绝检测：前 300 字符即可判断
                if (detectRefusalEarly && !earlyAborted && fullResponse.length >= 200 && fullResponse.length < 600) {
                    const preview = fullResponse.substring(0, 400);
                    if (isRefusal(preview) && !hasToolCalls(preview)) {
                        earlyAborted = true;
                        log.info('Handler', 'response', `前${fullResponse.length}字符检测到拒绝，提前中止流`, { preview: preview.substring(0, 150) });
                        abortController?.abort();
                    }
                }
            }, abortController?.signal);
        } catch (err) {
            // 仅在非主动中止时抛出
            if (!earlyAborted) throw err;
        }

        log.endPhase();
        log.recordCursorApiTime(apiStart);
        return { earlyAborted };
    };

    try {
        if (!hasTools) {