327 lines
14 KiB
JavaScript
327 lines
14 KiB
JavaScript
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|stopped/.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 && n !== current);
|
|
selectEl.innerHTML = others.map(n => `<option value="${n}">${n}</option>`).join('');
|
|
// wybierz pierwszy sensowny inny node
|
|
if (selectEl.options.length > 0) selectEl.selectedIndex = 0;
|
|
return others;
|
|
}
|
|
|
|
function updateMigrateButton(tr, rawStatus) {
|
|
const btn = q(tr, '.act-migrate');
|
|
const targetSel = q(tr, '.target-node');
|
|
if (!btn) return;
|
|
const hasTarget = !!(targetSel && targetSel.options && targetSel.options.length > 0);
|
|
const s = low(rawStatus || '');
|
|
const busy = /working|progress|busy/.test(s);
|
|
// pozwól offline i online migrate — byle jest docelowy węzeł i nie trwa inna akcja
|
|
const enable = hasTarget && !busy && s !== '';
|
|
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');
|
|
|
|
// dopasowane do serwera: type="vm" i "moved"
|
|
if (msg.type === 'vm') {
|
|
const cur = msg.current || {};
|
|
const stRaw = low(cur.status || cur.qmpstatus || '');
|
|
const changed = setBadgeCell(statusCell, stRaw);
|
|
const isRunning = /running|online|started/.test(stRaw);
|
|
updateMigrateButton(tr2, stRaw);
|
|
updateActionButtons(tr2, isRunning);
|
|
if (changed) flashDot(nameCell);
|
|
if (stRaw && /running|stopped|shutdown/.test(stRaw)) {
|
|
setTimeout(function(){ activeSids.delete(sid); }, 3000);
|
|
}
|
|
}
|
|
|
|
if (msg.type === 'moved' && msg.new_node) {
|
|
const newNode = String(msg.new_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([
|
|
`<input type="checkbox" class="row-check">`,
|
|
safe(r.sid),
|
|
safe(r.name),
|
|
safe(r.node),
|
|
badge(safe(r.status), /running|online|started/i.test(r.status) ? 'ok' : 'dark'),
|
|
`<div class="btn-group">
|
|
<button type="button" class="btn btn-sm btn-outline-success act-start">Start</button>
|
|
<button type="button" class="btn btn-sm btn-outline-warning act-shutdown">Shutdown</button>
|
|
<button type="button" class="btn btn-sm btn-outline-danger act-stop">Stop</button>
|
|
<button type="button" class="btn btn-sm btn-outline-secondary act-unlock">Unlock</button>
|
|
</div>`,
|
|
`<select class="form-select form-select-sm target-node position-relative"></select>`,
|
|
`<button type="button" class="btn btn-sm btn-outline-primary w-100 act-migrate" disabled>MIGRATE</button>`
|
|
]));
|
|
|
|
setRows(tbody, htmlRows);
|
|
|
|
// prepare rows
|
|
qq(tbody, 'tr[data-sid]').forEach(function(tr){
|
|
const nodeCell = tr.children[3];
|
|
const targetSel = q(tr, '.target-node');
|
|
const currentNode = txt(nodeCell).trim();
|
|
rebuildTargetSelect(targetSel, currentNode, availableNodes);
|
|
const stRaw = low(tr.children[4].innerText);
|
|
const isRunning = /running|online|started/.test(stRaw);
|
|
updateMigrateButton(tr, stRaw);
|
|
updateActionButtons(tr, isRunning);
|
|
});
|
|
|
|
// delegated events (reliable after refreshes)
|
|
tbody.addEventListener('click', async function(ev){
|
|
const t = ev.target;
|
|
const btn = t && t.closest ? t.closest('.act-start,.act-stop,.act-shutdown,.act-unlock,.act-migrate') : null;
|
|
if (!btn) return;
|
|
ev.preventDefault(); ev.stopPropagation(); // <— kluczowe, żeby zawsze doszedł POST
|
|
const tr = btn.closest ? btn.closest('tr[data-sid]') : null;
|
|
if (!tr) return;
|
|
const sid = tr.getAttribute('data-sid');
|
|
const nameCell = tr.children[2];
|
|
const statusCell = tr.children[4];
|
|
const targetSel = q(tr, '.target-node');
|
|
|
|
async function doAction(kind, needsTarget) {
|
|
try {
|
|
const targetNode = needsTarget ? (targetSel ? targetSel.value : undefined) : undefined;
|
|
activeSids.add(sid);
|
|
setBadgeCell(statusCell, 'working');
|
|
updateMigrateButton(tr, 'working');
|
|
const res = await api.vmAction(sid, kind, targetNode);
|
|
if (res && res.ok) { showToast('OK', `Task ${kind} started for ${safe(txt(nameCell))}`, 'success'); }
|
|
else { showToast('Error', `Task ${kind} failed for ${safe(txt(nameCell))}`, 'danger'); }
|
|
} catch(e) { showToast('Error', String(e && e.message ? e.message : e), 'danger'); }
|
|
}
|
|
if (btn.classList.contains('act-start')) return doAction('start');
|
|
if (btn.classList.contains('act-stop')) return doAction('stop');
|
|
if (btn.classList.contains('act-shutdown')) return doAction('shutdown');
|
|
if (btn.classList.contains('act-unlock')) return doAction('unlock');
|
|
if (btn.classList.contains('act-migrate')) return doAction('migrate', true);
|
|
});
|
|
|
|
window.__nodesCache = availableNodes.slice();
|
|
|
|
// slow full refresh
|
|
slowTimer = setInterval(async function(){
|
|
try {
|
|
const latest2 = await api.listAllVmct();
|
|
const all2 = Array.isArray(latest2.all) ? latest2.all : [];
|
|
const bySid = new Map(all2.map(x => [String(x.sid), x]));
|
|
const nodesNow2 = Array.isArray(latest2.nodes) ? latest2.nodes : (window.__nodesCache || []);
|
|
window.__nodesCache = nodesNow2;
|
|
|
|
qq(tbody, 'tr[data-sid]').forEach(function(tr){
|
|
const sid = tr.getAttribute('data-sid');
|
|
const rowData = bySid.get(sid);
|
|
if (!rowData) return;
|
|
const nodeCell = tr.children[3];
|
|
const statusCell= tr.children[4];
|
|
const nameCell = tr.children[2];
|
|
const targetSel = q(tr, '.target-node');
|
|
|
|
const newNode = String(rowData.node || '').trim();
|
|
if (nodeCell && newNode && txt(nodeCell).trim() !== newNode) {
|
|
nodeCell.textContent = newNode;
|
|
rebuildTargetSelect(targetSel, newNode, nodesNow2);
|
|
flashDot(nameCell);
|
|
}
|
|
|
|
const currentTxt = low((statusCell && statusCell.innerText) || '');
|
|
if (!/working/.test(currentTxt)) {
|
|
const stRaw = low(rowData.status || '');
|
|
if (stRaw) {
|
|
const changed = setBadgeCell(statusCell, stRaw);
|
|
const isRunning = /running|online|started/.test(stRaw);
|
|
updateMigrateButton(tr, stRaw);
|
|
updateActionButtons(tr, isRunning);
|
|
if (changed) flashDot(nameCell);
|
|
}
|
|
}
|
|
});
|
|
} catch(e){}
|
|
}, 30000);
|
|
|
|
// fast refresh: active sids
|
|
fastTimer = setInterval(async function(){
|
|
try {
|
|
const sids = Array.from(activeSids);
|
|
if (!sids.length) return;
|
|
for (let i=0;i<sids.length;i++){
|
|
const sid = sids[i];
|
|
const detail = await api.vmDetail(sid);
|
|
if (!detail || !detail.meta) continue;
|
|
const tr = tbody.querySelector('tr[data-sid="' + sid + '"]');
|
|
if (!tr) continue;
|
|
|
|
const nodeCell = tr.children[3];
|
|
const statusCell= tr.children[4];
|
|
const nameCell = tr.children[2];
|
|
const targetSel = q(tr, '.target-node');
|
|
|
|
const stRaw = low((detail.current && (detail.current.status || detail.current.qmpstatus)) || '');
|
|
const changed = setBadgeCell(statusCell, stRaw);
|
|
const isRunning = /running|online|started/.test(stRaw);
|
|
updateMigrateButton(tr, stRaw);
|
|
updateActionButtons(tr, isRunning);
|
|
if (changed) flashDot(nameCell);
|
|
|
|
const newNode = String(detail.node || (detail.meta && detail.meta.node) || '').trim();
|
|
if (newNode) {
|
|
if (nodeCell && txt(nodeCell).trim() !== newNode) {
|
|
nodeCell.textContent = newNode;
|
|
rebuildTargetSelect(targetSel, newNode, window.__nodesCache || []);
|
|
flashDot(nameCell);
|
|
}
|
|
}
|
|
|
|
if (stRaw && /running|stopped|shutdown/.test(stRaw)) {
|
|
setTimeout(function(){ activeSids.delete(sid); }, 4000);
|
|
}
|
|
}
|
|
} catch(e){}
|
|
}, 10000);
|
|
|
|
ensureWatchOn();
|
|
window.addEventListener('beforeunload', stopAllAdminWatches, { once: true });
|
|
} catch (e) {
|
|
showToast('Error', `Failed to load list: ${e && e.message ? e.message : e}`, 'danger');
|
|
}
|
|
}
|
|
|
|
// Entry point used by main.js
|
|
export async function renderVMAdmin() {
|
|
try { await startAdminWatches(); }
|
|
catch (e) {
|
|
showToast('Error', `VM Admin initialization error: ${e && e.message ? e.message : e}`, 'danger');
|
|
console.error(e);
|
|
}
|
|
}
|