Function connectSSE

public/logs.js:43–61

()

// ===== SSE =====
let es;
function connectSSE(){
  if(es)try{es.close()}catch{}
  es=new EventSource(authQ('/api/logs/stream'));
  es.addEventListener('log',e=>{
    const en=JSON.parse(e.data);logs.push(en);
    if(logs.length>5000)logs=logs.slice(-3000);
    if(!selId||selId===en.requestId){if(curTab==='logs')appendLog(en)}
  });
  es.addEventListener('summary',e=>{
    const s=JSON.parse(e.data);rmap[s.requestId]=s;
    const i=reqs.findIndex(r=>r.requestId===s.requestId);
    if(i>=0)reqs[i]=s;else reqs.unshift(s);
    renderRL();updCnt();
    if(selId===s.requestId)renderSCard(s);
  });
  es.addEventListener('stats',e=>{applyStats(JSON.parse(e.data))});
  es.onopen=()=>{const c=document.getElementById('conn');c.className='conn on';c.querySelector('span').textContent='已连接'};
  es.onerror=()=>{const c=document.getElementById('conn');c.className='conn off';c.querySelector('span').textContent='重连中...';setTimeout(connectSSE,3000)};
}

// ===== Stats =====
function updStats(){fetch(authQ('/api/stats')).then(r=>r.json()).then(applyStats).catch(()=>{})}