import { rowHTML, setRows, safe, showToast, badge } from './helpers.js'; import { api } from './api.js'; // --- State --- const liveSockets = new Map(); let slowTimer = null; let fastTimer = null; const activeSids = new Set(); // --- tiny safe helpers --- function q(root, sel){ return root ? root.querySelector(sel) : null; } function qq(root, sel){ return root ? Array.from(root.querySelectorAll(sel)) : []; } function txt(el){ return (el && el.textContent) ? el.textContent : ''; } function low(x){ return String(x||'').toLowerCase(); } function injectOnceCSS() { if (document.getElementById('vmadmin-live-css')) return; const style = document.createElement('style'); style.id = 'vmadmin-live-css'; style.textContent = ` .pulse-dot{display:inline-block;width:8px;height:8px;border-radius:50%;background:#22c55e;margin-left:.5rem;opacity:.25;animation:pulse-vm 1s ease-in-out 4} @keyframes pulse-vm {0%,100%{opacity:.25;transform:scale(1)}50%{opacity:1;transform:scale(1.25)}} `; document.head.appendChild(style); } function flashDot(cell) { if (!cell) return; const dot = document.createElement('span'); dot.className = 'pulse-dot'; cell.appendChild(dot); setTimeout(function(){ if (dot && dot.parentNode) dot.parentNode.removeChild(dot); }, 1500); } function setBadgeCell(cell, textOrState) { if (!cell) return false; let html = ''; const s = low(textOrState); if (/running|online|started/.test(s)) html = badge('running','ok'); else if (/stopp|shutdown|offline/.test(s)) html = badge('stopped','dark'); else if (/working|progress|busy/.test(s)) html = badge('working','info'); else html = badge(textOrState || '—','dark'); if (cell.innerHTML !== html) { cell.innerHTML = html; return true; } return false; } function extractNodeNames(ns){ if (!ns) return []; if (Array.isArray(ns.nodes)) return Array.from(new Set(ns.nodes.map(n => String(n.name || n.node || n).trim()).filter(Boolean))); if (Array.isArray(ns)) return Array.from(new Set(ns.map(n => String(n.name || n.node || n).trim()).filter(Boolean))); return []; } function rebuildTargetSelect(selectEl, currentNode, nodes) { if (!selectEl) return []; const current = String(currentNode || '').trim(); const all = (nodes || []).map(n => String(n && (n.name || n.node || n)).trim()).filter(Boolean); const others = all.filter(n => n !== current); selectEl.innerHTML = others.map(n => ``).join(''); // default: pick the "second node" if exists, otherwise first available other var idx = 0; if (all.length >= 2) { const preferred = all[1]; const j = others.indexOf(preferred); if (j >= 0) idx = j; } if (selectEl.options.length > 0) selectEl.selectedIndex = idx; return others; } function updateMigrateButton(tr, isRunning) { const btn = q(tr, '.act-migrate'); const targetSel = q(tr, '.target-node'); const hasTarget = !!(targetSel && targetSel.options && targetSel.options.length > 0); const enable = !!(isRunning && hasTarget); if (!btn) return; if (enable) { btn.removeAttribute('disabled'); btn.classList.remove('disabled'); } else { btn.setAttribute('disabled',''); btn.classList.add('disabled'); } } function updateActionButtons(tr, isRunning) { const bStart = q(tr, '.act-start'); const bStop = q(tr, '.act-stop'); const bShutdown = q(tr, '.act-shutdown'); if (bStart) { if (isRunning) { bStart.setAttribute('disabled',''); bStart.classList.add('disabled'); } else { bStart.removeAttribute('disabled'); bStart.classList.remove('disabled'); } } if (bStop) { if (isRunning) { bStop.removeAttribute('disabled'); bStop.classList.remove('disabled'); } else { bStop.setAttribute('disabled',''); bStop.classList.add('disabled'); } } if (bShutdown) { if (isRunning) { bShutdown.removeAttribute('disabled'); bShutdown.classList.remove('disabled'); } else { bShutdown.setAttribute('disabled',''); bShutdown.classList.add('disabled'); } } } export function stopAllAdminWatches() { liveSockets.forEach(function(ws){ try { ws.close(); } catch(e){} }); liveSockets.clear(); if (slowTimer) clearInterval(slowTimer); if (fastTimer) clearInterval(fastTimer); slowTimer = null; fastTimer = null; activeSids.clear(); } function ensureWatchOn() { const tbody = document.querySelector('#vm-admin tbody'); if (!tbody) return; qq(tbody, 'tr[data-sid]').forEach(function(tr){ const sid = tr.getAttribute('data-sid'); if (!sid || liveSockets.has(sid)) return; try { const wsProto = (location.protocol === 'https:') ? 'wss' : 'ws'; const ws = new WebSocket(wsProto + '://' + location.host + '/ws/observe?sid=' + encodeURIComponent(sid)); liveSockets.set(sid, ws); ws.onopen = function(){}; ws.onclose = function(){ liveSockets.delete(sid); }; ws.onerror = function(){}; ws.onmessage = function(ev){ try { const msg = JSON.parse(ev.data || '{}'); if (!msg || !msg.type) return; const tr2 = tbody.querySelector('tr[data-sid="' + sid + '"]'); if (!tr2) return; const statusCell = tr2.children[4]; const nameCell = tr2.children[2]; const nodeCell = tr2.children[3]; const targetSel = q(tr2, '.target-node'); if (msg.type === 'status') { const stRaw = low(msg.status); const changed = setBadgeCell(statusCell, stRaw); const isRunning = /running|online|started/.test(stRaw); updateMigrateButton(tr2, isRunning); updateActionButtons(tr2, isRunning); if (changed) flashDot(nameCell); if (stRaw && /running|stopped|shutdown/.test(stRaw)) { setTimeout(function(){ activeSids.delete(sid); }, 3000); } } if (msg.type === 'node' && msg.node) { const newNode = String(msg.node).trim(); if (nodeCell && newNode && txt(nodeCell).trim() !== newNode) { nodeCell.textContent = newNode; rebuildTargetSelect(targetSel, newNode, window.__nodesCache || []); flashDot(nameCell); } } } catch(e){} }; } catch(e){} }); } export async function startAdminWatches() { injectOnceCSS(); const tbody = document.querySelector('#vm-admin tbody'); if (!tbody) return; const ns = await api.nodesSummary(); const availableNodes = extractNodeNames(ns); setRows(tbody, []); try { const latest = await api.listAllVmct(); const all = Array.isArray(latest.all) ? latest.all : []; const nodesNow = Array.isArray(latest.nodes) ? latest.nodes : []; window.__nodesCache = nodesNow.slice(); const rows = all.map(vm => ({ sid: safe(vm.sid), name: safe(vm.name || vm.vmid || vm.sid), node: safe(vm.node || '—'), status: safe(vm.status || '—') })); const htmlRows = rows.map(r => rowHTML([ ``, safe(r.sid), safe(r.name), safe(r.node), badge(safe(r.status), /running|online|started/i.test(r.status) ? 'ok' : 'dark'), `