ST-Amily2-Chat-Optimisation-SecFix/ui/optimization-progress.js

import { extensionName } from '../utils/settings.js';

let modalInstance = null;
let trackState = {
    main: { step: 0, text: '准备就绪...', active: false, fillEl: null, textEl: null },
    concurrent: { step: 0, text: '等待启动...', active: false, fillEl: null, textEl: null }
};
const totalEstimatedSteps = 5;

let messageQueues = {
    main: [],
    concurrent: []
};
let isProcessingQueues = {
    main: false,
    concurrent: false
};
const MIN_DISPLAY_TIME = 800; 

function createModalHtml() {
    return `
        <div id="amily2-progress-bar-container">
            <!-- 主模型轨道 (LLM-A) -->
            <div class="progress-track-container" id="amily2-track-main">
                <div class="progress-header">
                    <div class="progress-status">
                        <i class="fas fa-brain" style="color: #9e8aff;"></i>
                        <span class="track-label">主意识</span>
                        <span class="track-text" id="amily2-text-main">准备就绪...</span>
                    </div>
                    <button id="amily2-progress-cancel" title="中止任务">
                        <i class="fas fa-times"></i>
                    </button>
                </div>
                <div class="progress-track">
                    <div class="progress-fill" id="amily2-fill-main" style="width: 0%"></div>
                </div>
            </div>

            <!-- 并发模型轨道 (LLM-B) - 初始隐藏 -->
            <div class="progress-track-container" id="amily2-track-concurrent" style="display: none; margin-top: 12px; border-top: 1px solid rgba(255,255,255,0.1); padding-top: 12px;">
                <div class="progress-header">
                    <div class="progress-status">
                        <i class="fas fa-project-diagram" style="color: #6495ed;"></i>
                        <span class="track-label">潜意识</span>
                        <span class="track-text" id="amily2-text-concurrent">等待启动...</span>
                    </div>
                </div>
                <div class="progress-track">
                    <div class="progress-fill" id="amily2-fill-concurrent" style="width: 0%; background: linear-gradient(90deg, #6495ed, #00d2ff);"></div>
                </div>
            </div>
        </div>
    `;
}

function addStyling() {
    const styleId = 'amily2-progress-modal-style';
    if (document.getElementById(styleId)) return;

    const style = document.createElement('style');
    style.id = styleId;
    style.innerHTML = `
        #amily2-progress-bar-container {
            position: fixed;
            top: 20px;
            left: 50%;
            transform: translateX(-50%);
            width: 420px;
            max-width: 90vw;
            background: rgba(30, 30, 40, 0.85);
            backdrop-filter: blur(12px);
            -webkit-backdrop-filter: blur(12px);
            border: 1px solid rgba(255, 255, 255, 0.1);
            border-radius: 12px;
            padding: 12px 16px;
            box-shadow: 0 8px 32px rgba(0, 0, 0, 0.4);
            z-index: 2147483647 !important;
            font-family: "Segoe UI", "Microsoft YaHei", sans-serif;
            transition: all 0.3s cubic-bezier(0.4, 0, 0.2, 1);
            opacity: 0;
            transform: translate(-50%, -20px); /* 初始位置偏上，用于入场动画 */
        }

        #amily2-progress-bar-container.visible {
            opacity: 1;
            transform: translate(-50%, 0);
        }

        .progress-header {
            display: flex;
            justify-content: space-between;
            align-items: center;
            margin-bottom: 8px;
        }

        .progress-status {
            display: flex;
            align-items: center;
            gap: 8px;
            color: var(--smart-theme-body-color, #eee);
            font-size: 13px;
            font-weight: 500;
            white-space: nowrap;
            overflow: hidden;
            flex: 1;
        }

        .track-label {
            font-size: 11px;
            padding: 2px 6px;
            border-radius: 4px;
            background: rgba(255,255,255,0.1);
            color: rgba(255,255,255,0.8);
            margin-right: 4px;
        }

        .track-text {
            overflow: hidden;
            text-overflow: ellipsis;
            opacity: 0.9;
        }

        #amily2-progress-cancel {
            background: transparent;
            border: none;
            color: rgba(255, 255, 255, 0.4);
            cursor: pointer;
            padding: 4px;
            border-radius: 50%;
            transition: all 0.2s;
            display: flex;
            align-items: center;
            justify-content: center;
            width: 24px;
            height: 24px;
            margin-left: 10px;
        }

        #amily2-progress-cancel:hover {
            background-color: rgba(255, 255, 255, 0.1);
            color: #ff6b6b;
        }

        .progress-track {
            height: 4px;
            background: rgba(255, 255, 255, 0.1);
            border-radius: 2px;
            overflow: hidden;
            position: relative;
        }

        .progress-fill {
            height: 100%;
            background: linear-gradient(90deg, var(--smart-theme-color, #9e8aff), #b3a4ff);
            border-radius: 2px;
            transition: width 0.4s cubic-bezier(0.4, 0, 0.2, 1);
            box-shadow: 0 0 10px rgba(158, 138, 255, 0.4);
            position: relative;
        }

        /* 进度条光效动画 */
        .progress-fill::after {
            content: '';
            position: absolute;
            top: 0;
            left: 0;
            bottom: 0;
            right: 0;
            background: linear-gradient(
                90deg,
                transparent,
                rgba(255, 255, 255, 0.4),
                transparent
            );
            transform: translateX(-100%);
            animation: shimmer 1.5s infinite;
        }

        @keyframes shimmer {
            100% {
                transform: translateX(100%);
            }
        }
    `;
    document.head.appendChild(style);
}

export function showPlotOptimizationProgress(cancellationState) {
    if (modalInstance) {
        hidePlotOptimizationProgress();
    }

    addStyling();
    document.body.insertAdjacentHTML('beforeend', createModalHtml());
    
    modalInstance = document.getElementById('amily2-progress-bar-container');
    
    trackState.main.fillEl = document.getElementById('amily2-fill-main');
    trackState.main.textEl = document.getElementById('amily2-text-main');
    trackState.main.step = 0;
    trackState.main.active = true;

    trackState.concurrent.fillEl = document.getElementById('amily2-fill-concurrent');
    trackState.concurrent.textEl = document.getElementById('amily2-text-concurrent');
    trackState.concurrent.step = 0;
    trackState.concurrent.active = false; 

    const cancelButton = document.getElementById('amily2-progress-cancel');

    messageQueues = {
        main: [],
        concurrent: []
    };
    isProcessingQueues = {
        main: false,
        concurrent: false
    };

    requestAnimationFrame(() => {
        if (modalInstance) {
            modalInstance.classList.add('visible');
        }
    });

    if (cancellationState && cancelButton) {
        cancelButton.addEventListener('click', () => {
            cancellationState.isCancelled = true;
            if (trackState.main.textEl) trackState.main.textEl.textContent = "正在中止任务...";
            if (trackState.main.fillEl) trackState.main.fillEl.style.backgroundColor = "#ff6b6b";
            toastr.info("记忆管理任务已请求中止。");
            setTimeout(hidePlotOptimizationProgress, 800);
        });
    }
}

export function updatePlotOptimizationProgress(message, isDone = false, isSkipped = false) {
    if (message.includes('记忆重构完成') || message.includes('所有任务已完成')) {
        messageQueues.main = [];
        messageQueues.concurrent = [];
        performUpdate(message, isDone, isSkipped);
        setTimeout(hidePlotOptimizationProgress, 1000);
        return;
    }

    const isConcurrent = message.includes('(LLM-B)') || message.includes('(并发模型)');
    const queueType = isConcurrent ? 'concurrent' : 'main';

    messageQueues[queueType].push({ message, isDone, isSkipped });

    processQueue(queueType);
}

async function processQueue(queueType) {
    if (isProcessingQueues[queueType] || messageQueues[queueType].length === 0) return;
    
    isProcessingQueues[queueType] = true;
    
    while (messageQueues[queueType].length > 0) {
        const { message, isDone, isSkipped } = messageQueues[queueType].shift();
        
        performUpdate(message, isDone, isSkipped);
        const isLongRunningTaskStart = message.includes('请求') && !isDone && !isSkipped;
        
        if (!isLongRunningTaskStart) {
            await new Promise(resolve => setTimeout(resolve, MIN_DISPLAY_TIME));
        } else {

            await new Promise(resolve => setTimeout(resolve, 500));
        }
    }
    
    isProcessingQueues[queueType] = false;
}

function performUpdate(message, isDone, isSkipped) {
    if (!modalInstance) return;

    if (message === '初始化任务...' || message === '所有任务已完成') {
        if (trackState.main.textEl) trackState.main.textEl.textContent = message;
        return;
    }

    const isConcurrent = message.includes('(LLM-B)') || message.includes('(并发模型)');
    const track = isConcurrent ? trackState.concurrent : trackState.main;
    const trackId = isConcurrent ? 'amily2-track-concurrent' : 'amily2-track-main';

    if (isConcurrent && !track.active) {
        track.active = true;
        const trackEl = document.getElementById(trackId);
        if (trackEl) trackEl.style.display = 'block';
    }
    const cleanMessage = message.replace(/\(LLM-[AB]\)|\(主模型\)|\(并发模型\)/g, '').trim();

    if (isDone || isSkipped) {
        track.step++;
        let percentage = Math.min((track.step / totalEstimatedSteps) * 100, 95);

        if (message.includes('记忆重构完成') || message.includes('所有任务已完成')) {
            percentage = 100;
            if (trackState.concurrent.active && trackState.concurrent.fillEl) {
                trackState.concurrent.fillEl.style.width = '100%';
                if (trackState.concurrent.textEl) trackState.concurrent.textEl.textContent = '同步完成 ✅';
            }
        }
        
        // 特殊处理：并发模型的最后一步
        if (isConcurrent && (message.includes('深度逻辑推演') || message.includes('计算情感最优解'))) {
             percentage = 100;
        }
        
        // 特殊处理：主模型的最后一步（在记忆重构之前）
        if (!isConcurrent && (message.includes('核心意识同步') || message.includes('等待灵魂共鸣'))) {
             percentage = 100;
        }

        if (track.fillEl) {
            track.fillEl.style.width = `${percentage}%`;
        }
        
        if (track.textEl) {
            track.textEl.textContent = `${cleanMessage} ${isSkipped ? '⚪' : '✅'}`;
        }
    } else {
        if (track.textEl) {
            track.textEl.textContent = cleanMessage;
        }
    }
}

export function hidePlotOptimizationProgress() {
    // 重置消息队列
    messageQueues = {
        main: [],
        concurrent: []
    };
    isProcessingQueues = {
        main: false,
        concurrent: false
    };

    if (modalInstance) {
        modalInstance.classList.remove('visible');
        setTimeout(() => {
            if (modalInstance) {
                modalInstance.remove();
                modalInstance = null;
                // 清理引用
                trackState.main.fillEl = null;
                trackState.main.textEl = null;
                trackState.concurrent.fillEl = null;
                trackState.concurrent.textEl = null;
            }
        }, 300);
    }
}