`).join('');
document.getElementById('dashExecutions').innerHTML = dashHtml;
@@ -1615,14 +1637,15 @@
const clickHandler = compareMode ? `toggleExecutionSelection('${e.id}')` : `viewExecution('${e.id}')`;
const selectedStyle = isSelected ? 'background: rgba(255, 176, 0, 0.2); border-left-width: 5px; border-left-color: var(--terminal-amber);' : '';
+ const elapsed = e.status === 'running' ? ` • ${formatElapsed(e.started_at)}` : '';
return `
-
+
${compareMode && isSelected ? '
✓ ' : ''}
${e.status}
${e.workflow_name || '[Quick Command]'}
- Started by ${e.started_by} at ${new Date(e.started_at).toLocaleString()}
- ${e.completed_at ? ` • Completed at ${new Date(e.completed_at).toLocaleString()}` : ''}
+ Started by ${e.started_by} at ${safeDate(e.started_at)?.toLocaleString() ?? 'N/A'}
+ ${e.completed_at ? ` • Completed at ${safeDate(e.completed_at)?.toLocaleString() ?? 'N/A'}` : elapsed}
`;
@@ -1737,7 +1760,7 @@
Execution ${idx + 1}
${exec.status} ${new Date(exec.started_at).toLocaleString()}
+ ${safeDate(exec.started_at)?.toLocaleString() ?? 'N/A'}
${duration}
`;
@@ -1853,24 +1876,14 @@
if (!confirm('Delete all completed and failed executions?')) return;
try {
- const response = await fetch('/api/executions?limit=9999'); // Get all executions
- const data = await response.json();
- const executions = data.executions || data; // Handle new pagination format
-
- const toDelete = executions.filter(e => e.status === 'completed' || e.status === 'failed');
-
- if (toDelete.length === 0) {
- alert('No completed or failed executions to delete');
+ const response = await fetch('/api/executions/completed', { method: 'DELETE' });
+ if (!response.ok) {
+ const err = await response.json().catch(() => ({}));
+ showTerminalNotification(err.error || 'Failed to delete executions', 'error');
return;
}
-
- let deleted = 0;
- for (const execution of toDelete) {
- const deleteResponse = await fetch(`/api/executions/${execution.id}`, { method: 'DELETE' });
- if (deleteResponse.ok) deleted++;
- }
-
- showTerminalNotification(`Deleted ${deleted} execution(s)`, 'success');
+ const data = await response.json();
+ showTerminalNotification(`Deleted ${data.deleted} execution(s)`, 'success');
refreshData();
} catch (error) {
console.error('Error clearing executions:', error);
@@ -1970,8 +1983,8 @@
let html = `
Status: ${execution.status}
-
Started: ${new Date(execution.started_at).toLocaleString()}
- ${execution.completed_at ? `
Completed: ${new Date(execution.completed_at).toLocaleString()}
` : ''}
+
Started: ${safeDate(execution.started_at)?.toLocaleString() ?? 'N/A'}
+ ${execution.completed_at ? `
Completed: ${safeDate(execution.completed_at)?.toLocaleString() ?? 'N/A'}
` : ''}
Started by: ${execution.started_by}
`;
@@ -2015,7 +2028,7 @@
// Re-run button (only for quick commands with command in logs)
const commandLog = execution.logs?.find(l => l.action === 'command_sent');
if (commandLog && commandLog.command) {
- html += `
🔄 Re-run Command `;
+ html += `
🔄 Re-run Command `;
}
// Download logs button
@@ -2264,8 +2277,9 @@
}
function escapeHtml(text) {
+ if (text == null) return '';
const div = document.createElement('div');
- div.textContent = text;
+ div.textContent = String(text);
return div.innerHTML;
}
@@ -2288,7 +2302,9 @@
}
function getTimeAgo(date) {
+ if (!date || isNaN(date)) return 'N/A';
const seconds = Math.floor((new Date() - date) / 1000);
+ if (seconds < 0) return 'just now';
if (seconds < 60) return `${seconds}s ago`;
const minutes = Math.floor(seconds / 60);
if (minutes < 60) return `${minutes}m ago`;
@@ -2298,6 +2314,22 @@
return `${days}d ago`;
}
+ function safeDate(val) {
+ if (!val) return null;
+ const d = new Date(val);
+ return isNaN(d) ? null : d;
+ }
+
+ function formatElapsed(startedAt) {
+ const start = safeDate(startedAt);
+ if (!start) return '';
+ const secs = Math.floor((Date.now() - start) / 1000);
+ if (secs < 60) return `${secs}s`;
+ const mins = Math.floor(secs / 60);
+ if (mins < 60) return `${mins}m ${secs % 60}s`;
+ return `${Math.floor(mins / 60)}h ${mins % 60}m`;
+ }
+
async function rerunCommand(command, workerId) {
if (!confirm(`Re-run command: ${command}?`)) return;
@@ -2431,7 +2463,7 @@
const html = history.map((item, index) => `
${escapeHtml(item.command)}
-
${new Date(item.timestamp).toLocaleString()} - ${item.worker}
+
${safeDate(item.timestamp)?.toLocaleString() ?? 'N/A'} - ${item.worker}
`).join('');
document.getElementById('historyList').innerHTML = html;
@@ -2800,37 +2832,24 @@
document.querySelectorAll('.tab').forEach(t => t.classList.remove('active'));
document.querySelectorAll('.tab-content').forEach(c => c.classList.remove('active'));
- // Find the button by its onclick attribute rather than relying on bare `event`
const tabBtn = document.querySelector(`.tab[onclick*="'${tabName}'"]`);
if (tabBtn) tabBtn.classList.add('active');
const tabContent = document.getElementById(tabName);
if (tabContent) tabContent.classList.add('active');
+
+ // Persist active tab across page loads
+ try { localStorage.setItem('pulse_activeTab', tabName); } catch {}
}
async function refreshData() {
- try {
- await loadWorkers();
- } catch (e) {
- console.error('Error loading workers:', e);
- }
+ try { await loadWorkers(); } catch (e) { console.error('Error loading workers:', e); }
+ try { await loadWorkflows(); } catch (e) { console.error('Error loading workflows:', e); }
+ try { await loadExecutions(); } catch (e) { console.error('Error loading executions:', e); }
+ try { await loadSchedules(); } catch (e) { console.error('Error loading schedules:', e); }
- try {
- await loadWorkflows();
- } catch (e) {
- console.error('Error loading workflows:', e);
- }
-
- try {
- await loadExecutions();
- } catch (e) {
- console.error('Error loading executions:', e);
- }
-
- try {
- await loadSchedules();
- } catch (e) {
- console.error('Error loading schedules:', e);
- }
+ // Update "last refreshed" indicator
+ const el = document.getElementById('lastRefreshed');
+ if (el) el.textContent = `Refreshed: ${new Date().toLocaleTimeString()}`;
}
// Terminal beep sound (Web Audio API)
@@ -2992,8 +3011,12 @@
loadExecutions();
}
+ if (data.type === 'executions_bulk_deleted') {
+ loadExecutions();
+ }
+
// Generic refresh for other message types
- if (!['command_result', 'workflow_result', 'worker_update', 'execution_started', 'execution_status', 'workflow_created', 'workflow_deleted', 'workflow_updated', 'execution_prompt'].includes(data.type)) {
+ if (!['command_result', 'workflow_result', 'worker_update', 'execution_started', 'execution_status', 'workflow_created', 'workflow_deleted', 'workflow_updated', 'execution_prompt', 'executions_bulk_deleted'].includes(data.type)) {
refreshData();
}
} catch (error) {
@@ -3026,12 +3049,29 @@
// Initialize
loadUser().then((success) => {
if (success) {
+ // Restore last-active tab
+ try {
+ const saved = localStorage.getItem('pulse_activeTab');
+ if (saved) switchTab(saved);
+ } catch {}
+
setExecutionView(executionView);
refreshData();
connectWebSocket();
setInterval(refreshData, 30000);
}
});
+
+ // Ctrl+Enter submits the quick command form
+ document.addEventListener('keydown', (e) => {
+ if ((e.ctrlKey || e.metaKey) && e.key === 'Enter') {
+ const activeTab = document.querySelector('.tab-content.active');
+ if (activeTab && activeTab.id === 'quickcommand') {
+ e.preventDefault();
+ executeQuickCommand();
+ }
+ }
+ });