@@ -2174,7 +2196,8 @@ const CRON_DEFS = [
{id:'jarvis_deploy', label:'Deploy Runner', schedule:'Every 1 min', host:'jarvis-do'},
{id:'jarvis_watchdog', label:'Watchdog', schedule:'Every 5 min', host:'jarvis-do'},
{id:'jarvis_backup', label:'JARVIS Backup', schedule:'Daily 2am', host:'jarvis-do', norun:true},
- {id:'do_server_backup',label:'DO Server Backup', schedule:'Weekly Sun 4am', host:'jarvis-do', norun:true},
+ {id:'do_server_backup', label:'DO Server Backup', schedule:'Weekly Sun 4am', host:'jarvis-do', norun:true},
+ {id:'kb_intent_generator', label:'KB Intent Generator', schedule:'Daily 3am', host:'jarvis'},
];
function wBtn(col) {
const c={cyan:'var(--cyan)',red:'var(--red)',green:'var(--green)',dim:'var(--dim)'}[col]||'var(--dim)';
@@ -2201,12 +2224,127 @@ function wToast(msg,err=false) {
t.style.opacity='1';t.textContent=msg;
setTimeout(()=>{t.style.opacity='0';},3000);
}
+async function runIntentGenerator() {
+ // Open the working popup
+ const modalHtml = `
+
+
LAUNCHING...
+
Waiting for first output...
+
+
`;
+
+ openModal('▶ KB INTENT GENERATOR', modalHtml, null, null);
+ document.getElementById('modalSave').textContent = 'CLOSE';
+ document.getElementById('modalSave').onclick = () => { _igStop = true; closeModal(); };
+
+ const logEl = document.getElementById('ig-log');
+ const statEl = document.getElementById('ig-status');
+ const statsEl = document.getElementById('ig-stats');
+
+ let _igStop = false;
+ let lastLine = 0;
+ let dotted = 0;
+
+ // Snapshot current log position BEFORE triggering so we only see new lines
+ const snap = await api('intent_gen_log', {snapshot:1});
+ lastLine = snap?.next_line ?? 0;
+
+ // Kick off the generator (fire-and-forget in background on server)
+ const kick = await api('worker_action', {worker_type:'cron', worker_id:'kb_intent_generator', waction:'run'});
+ if (!kick || !kick.ok) {
+ statEl.style.color = 'var(--red)';
+ statEl.textContent = 'LAUNCH FAILED: ' + (kick?.error || 'unknown error');
+ document.getElementById('modalSave').textContent = 'CLOSE';
+ return;
+ }
+ statEl.textContent = 'RUNNING — polling log every 3s...';
+
+ // Poll the cron log for new output
+ async function pollLog() {
+ if (_igStop) return;
+ try {
+ const res = await api('intent_gen_log', {since: lastLine});
+ if (res && Array.isArray(res.lines) && res.lines.length) {
+ lastLine = res.next_line;
+ const isFirst = logEl.textContent === 'Waiting for first output...';
+ if (isFirst) logEl.textContent = '';
+ res.lines.forEach(line => {
+ const div = document.createElement('div');
+ const lower = line.toLowerCase();
+ if (lower.includes('error') || lower.includes('fail'))
+ div.style.color = 'var(--red)';
+ else if (lower.includes('skip') || lower.includes('warn'))
+ div.style.color = 'var(--yellow)';
+ else if (lower.includes('insert') || lower.includes('added') || lower.includes('done') || lower.includes('complete') || lower.includes('cleanup'))
+ div.style.color = 'var(--green)';
+ else
+ div.style.color = 'var(--text-dim)';
+ div.textContent = line;
+ logEl.appendChild(div);
+ });
+ logEl.scrollTop = logEl.scrollHeight;
+
+ // Detect completion
+ const lastLines = res.lines.join(' ').toLowerCase();
+ if (lastLines.includes('kb intent generator: done') || lastLines.includes('total inserted') || lastLines.includes('cleanup complete')) {
+ statEl.style.color = 'var(--green)';
+ statEl.textContent = 'COMPLETE';
+ // Extract stats from log
+ const total = (res.lines.join('\n').match(/inserted[:\s]+(\d+)/i) || [])[1];
+ if (total) statsEl.innerHTML = `
+${total} intents added`;
+ return; // stop polling
+ }
+ dotted = 0;
+ } else {
+ // No new lines yet — show a waiting dot
+ dotted++;
+ if (dotted < 30) { // Stop waiting after ~90s with no output
+ const waitDiv = document.createElement('div');
+ waitDiv.style.color = 'rgba(0,212,255,0.3)';
+ waitDiv.textContent = '· waiting for output' + '.'.repeat(dotted % 4);
+ // Replace last waiting line instead of appending
+ const last = logEl.lastChild;
+ if (last && last.textContent && last.textContent.startsWith('· waiting')) {
+ logEl.replaceChild(waitDiv, last);
+ } else {
+ if (logEl.textContent === 'Waiting for first output...') logEl.textContent = '';
+ logEl.appendChild(waitDiv);
+ }
+ logEl.scrollTop = logEl.scrollHeight;
+ } else {
+ statEl.style.color = 'var(--yellow)';
+ statEl.textContent = 'RUNNING IN BACKGROUND (check cron log for results)';
+ return;
+ }
+ }
+ } catch(e) {
+ // network error — keep trying
+ }
+ if (!_igStop) setTimeout(pollLog, 3000);
+ }
+
+ setTimeout(pollLog, 2000); // give server 2s head-start
+}
+
+async function arcSetup() {
+ if (!confirm('Run Arc Reactor setup?\n\nThis will:\n• Copy reactor.py from deploy/\n• Install Python packages\n• Install/update systemd service\n• Restart jarvis-arc')) return;
+ const btn = event.currentTarget;
+ btn.disabled = true; btn.textContent = '⏳ SETTING UP...';
+ try {
+ const d = await api('worker', {type:'daemon', id:'arc_reactor', action:'setup'});
+ toast(d.msg || (d.ok ? 'Setup started' : 'Setup failed'), d.ok ? 'ok' : 'err');
+ setTimeout(() => { loadWorkers(); btn.disabled=false; btn.innerHTML='⚙ SETUP'; }, 5000);
+ } catch(e) {
+ toast('Setup failed: ' + e.message, 'err');
+ btn.disabled=false; btn.innerHTML='⚙ SETUP';
+ }
+}
async function workerAction(type,id,action) {
if (type === 'agent' && action === 'update') {
await agentUpdateFlow(id);
return;
}
- const res=await api('worker_action',{worker_type:type,worker_id:id,action});
+ const res=await api('worker_action',{worker_type:type,worker_id:id,waction:action});
if(res&&res.ok){wToast(res.msg||'Done');setTimeout(loadWorkers,2500);}
else wToast((res&&res.error)||'Action failed',true);
}
@@ -2231,7 +2369,7 @@ async function agentUpdateFlow(agentId) {
};
// Dispatch command
- const res = await api('worker_action', {worker_type:'agent', worker_id:agentId, action:'update'});
+ const res = await api('worker_action', {worker_type:'agent', worker_id:agentId, waction:'update'});
if (!res || !res.ok) {
log('✗ Failed to dispatch: ' + (res?.error||'unknown'), 'var(--red)');
document.getElementById('modalSave').style.display = '';
@@ -2242,7 +2380,7 @@ async function agentUpdateFlow(agentId) {
log('✓ Command dispatched — waiting for agent to pick up...', 'var(--cyan)');
// Poll agent_commands for the result (max 90s)
- const cmdRes = await api('worker_action', {worker_type:'agent', worker_id:agentId, action:'update_status'}).catch(()=>null);
+ const cmdRes = await api('worker_action', {worker_type:'agent', worker_id:agentId, waction:'update_status'}).catch(()=>null);
// Actually poll via workers_list for version change
const deadline = Date.now() + 90000;
let done = false;
@@ -2346,9 +2484,9 @@ async function loadWorkers() {
jarvis-do :7474 |
${rdot}${ron?'ONLINE':'OFFLINE'} |
${rinfo} |
-
+ |
-
+
|
`;
}