Rodrigo Rodriguez (Pragmatismo)
b51c542afa
- Normalize task ID comparison in retry logic for consistent lookups - Use normalized keys in pendingManifestUpdates Map - Skip manifest_update in ProgressPanel (already handled by tasks.js) - Clean up existing handler before registering new one in ProgressPanel.init - Add name-based fallback lookups for sections/children/items when IDs change - Detect structure changes (section count, children, items, names) and rebuild tree - Clear progress-empty placeholder before rendering tree - Add detailed BUILD_TREE logging for debugging - Add cache-busting version to tasks.js script tag
2200 lines
67 KiB
JavaScript
2200 lines
67 KiB
JavaScript
/* =============================================================================
|
||
AUTO TASK JAVASCRIPT - Sentient Theme
|
||
Intelligent Self-Executing Task Interface
|
||
============================================================================= */
|
||
|
||
// =============================================================================
|
||
// STATE MANAGEMENT
|
||
// =============================================================================
|
||
|
||
const AutoTaskState = {
|
||
currentFilter: "active",
|
||
selectedIntentId: null,
|
||
intents: [],
|
||
compiledPlan: null,
|
||
pendingDecisions: [],
|
||
pendingApprovals: [],
|
||
refreshInterval: null,
|
||
wsConnection: null,
|
||
progressWsConnection: null,
|
||
activeTaskProgress: {},
|
||
llmOutputStream: [],
|
||
};
|
||
|
||
// =============================================================================
|
||
// INITIALIZATION
|
||
// =============================================================================
|
||
|
||
document.addEventListener("DOMContentLoaded", function () {
|
||
initAutoTask();
|
||
});
|
||
|
||
function initAutoTask() {
|
||
// Initialize WebSocket for real-time updates
|
||
initWebSocket();
|
||
|
||
// Initialize task progress WebSocket
|
||
initTaskProgressWebSocket();
|
||
|
||
// Start auto-refresh
|
||
startAutoRefresh();
|
||
|
||
// Setup event listeners
|
||
setupEventListeners();
|
||
|
||
// Load initial stats
|
||
updateStats();
|
||
|
||
// Setup keyboard shortcuts
|
||
setupKeyboardShortcuts();
|
||
|
||
// Initialize floating panel (hidden by default)
|
||
initFloatingPanel();
|
||
|
||
console.log("AutoTask Sentient initialized");
|
||
}
|
||
|
||
// =============================================================================
|
||
// FLOATING PANEL
|
||
// =============================================================================
|
||
|
||
function initFloatingPanel() {
|
||
const panel = document.getElementById("floating-progress");
|
||
if (panel) {
|
||
panel.style.display = "none";
|
||
}
|
||
}
|
||
|
||
function showFloatingPanel(taskId, taskName) {
|
||
const panel = document.getElementById("floating-progress");
|
||
if (!panel) return;
|
||
|
||
panel.style.display = "block";
|
||
panel.dataset.taskId = taskId;
|
||
|
||
const nameEl = document.getElementById("floating-task-name");
|
||
if (nameEl) nameEl.textContent = taskName || "Processing...";
|
||
|
||
updateFloatingProgress(0, 0, 0, "Initializing...");
|
||
}
|
||
|
||
function updateFloatingProgress(progress, current, total, statusText) {
|
||
const fill = document.getElementById("floating-progress-fill");
|
||
const pct = document.getElementById("floating-percentage");
|
||
const steps = document.getElementById("floating-status-steps");
|
||
const status = document.getElementById("floating-status-text");
|
||
|
||
if (fill) fill.style.width = `${progress}%`;
|
||
if (pct) pct.textContent = `${progress}%`;
|
||
if (steps) steps.textContent = `${current}/${total}`;
|
||
if (status) status.textContent = statusText;
|
||
}
|
||
|
||
function addFloatingLog(icon, message, type = "info") {
|
||
const log = document.getElementById("floating-log");
|
||
if (!log) return;
|
||
|
||
const entry = document.createElement("div");
|
||
entry.className = `floating-log-entry ${type}`;
|
||
entry.innerHTML = `
|
||
<span class="log-icon">${icon}</span>
|
||
<span class="log-message">${escapeHtml(message)}</span>
|
||
<span class="log-time">${formatTime(new Date())}</span>
|
||
`;
|
||
log.appendChild(entry);
|
||
log.scrollTop = log.scrollHeight;
|
||
}
|
||
|
||
function addFloatingTerminalOutput(text) {
|
||
const terminal = document.getElementById("floating-terminal");
|
||
if (!terminal) return;
|
||
|
||
const line = document.createElement("div");
|
||
line.className = "llm-output";
|
||
line.textContent = text;
|
||
terminal.appendChild(line);
|
||
terminal.scrollTop = terminal.scrollHeight;
|
||
|
||
// Keep only last 50 lines
|
||
while (terminal.children.length > 50) {
|
||
terminal.removeChild(terminal.firstChild);
|
||
}
|
||
}
|
||
|
||
function minimizeFloatingPanel() {
|
||
const panel = document.getElementById("floating-progress");
|
||
if (panel) {
|
||
panel.classList.toggle("minimized");
|
||
}
|
||
}
|
||
|
||
function closeFloatingPanel() {
|
||
const panel = document.getElementById("floating-progress");
|
||
if (panel) {
|
||
panel.style.display = "none";
|
||
}
|
||
}
|
||
|
||
function completeFloatingPanel(message) {
|
||
updateFloatingProgress(100, 0, 0, message || "Complete!");
|
||
addFloatingLog("✅", message || "Task completed successfully", "success");
|
||
|
||
// Auto-hide after delay
|
||
setTimeout(() => {
|
||
closeFloatingPanel();
|
||
}, 5000);
|
||
}
|
||
|
||
// =============================================================================
|
||
// WEBSOCKET CONNECTION
|
||
// =============================================================================
|
||
|
||
function initWebSocket() {
|
||
const protocol = window.location.protocol === "https:" ? "wss:" : "ws:";
|
||
const wsUrl = `${protocol}//${window.location.host}/ws/autotask`;
|
||
|
||
try {
|
||
AutoTaskState.wsConnection = new WebSocket(wsUrl);
|
||
|
||
AutoTaskState.wsConnection.onopen = function () {
|
||
console.log("AutoTask WebSocket connected");
|
||
};
|
||
|
||
AutoTaskState.wsConnection.onmessage = function (event) {
|
||
handleWebSocketMessage(JSON.parse(event.data));
|
||
};
|
||
|
||
AutoTaskState.wsConnection.onclose = function () {
|
||
console.log("AutoTask WebSocket disconnected, reconnecting...");
|
||
setTimeout(initWebSocket, 5000);
|
||
};
|
||
|
||
AutoTaskState.wsConnection.onerror = function (error) {
|
||
console.error("AutoTask WebSocket error:", error);
|
||
};
|
||
} catch (e) {
|
||
console.warn("WebSocket not available, using polling");
|
||
}
|
||
}
|
||
|
||
function initTaskProgressWebSocket() {
|
||
// Use the singleton WebSocket from tasks.js instead of creating a duplicate connection
|
||
// This prevents the "2 receivers" problem where manifest_update events go to one
|
||
// WebSocket while the browser UI is listening on a different one
|
||
|
||
console.log("[AutoTask] Using singleton WebSocket for task progress");
|
||
|
||
// Create handler for task progress messages
|
||
const handler = function (data) {
|
||
handleTaskProgressMessage(data);
|
||
};
|
||
|
||
// Store handler reference for cleanup
|
||
AutoTaskState._progressHandler = handler;
|
||
|
||
// Register with the global singleton WebSocket from tasks.js
|
||
if (typeof registerTaskProgressHandler === "function") {
|
||
registerTaskProgressHandler(handler);
|
||
console.log("[AutoTask] Registered with singleton WebSocket");
|
||
} else {
|
||
// Fallback: wait for tasks.js to load and retry
|
||
console.log("[AutoTask] Waiting for tasks.js singleton to be available...");
|
||
setTimeout(initTaskProgressWebSocket, 500);
|
||
}
|
||
}
|
||
|
||
function handleTaskProgressMessage(data) {
|
||
// Note: ProgressPanel now registers its own handler with the singleton,
|
||
// so we don't need to forward messages manually here
|
||
|
||
console.log("[AutoTask] Task progress:", data.type, data.task_id);
|
||
|
||
switch (data.type) {
|
||
case "connected":
|
||
console.log("Connected to task progress stream");
|
||
break;
|
||
case "task_started":
|
||
onTaskStarted(data);
|
||
break;
|
||
case "task_progress":
|
||
onTaskProgress(data);
|
||
break;
|
||
case "task_completed":
|
||
onTaskProgressCompleted(data);
|
||
break;
|
||
case "task_error":
|
||
onTaskProgressError(data);
|
||
break;
|
||
case "llm_stream":
|
||
onLLMStream(data);
|
||
break;
|
||
default:
|
||
console.log("Unknown progress event:", data.type);
|
||
}
|
||
}
|
||
|
||
function onTaskStarted(data) {
|
||
AutoTaskState.activeTaskProgress[data.task_id] = {
|
||
started: new Date(),
|
||
totalSteps: data.total_steps,
|
||
currentStep: 0,
|
||
progress: 0,
|
||
logs: [],
|
||
};
|
||
|
||
// Show floating panel
|
||
showFloatingPanel(data.task_id, data.message);
|
||
addFloatingLog("🚀", data.message, "started");
|
||
|
||
// Also update detail panel if viewing this intent
|
||
if (AutoTaskState.selectedIntentId === data.task_id) {
|
||
updateDetailPanelProgress(data);
|
||
}
|
||
}
|
||
|
||
function onTaskProgress(data) {
|
||
const taskProgress = AutoTaskState.activeTaskProgress[data.task_id];
|
||
if (taskProgress) {
|
||
taskProgress.currentStep = data.current_step;
|
||
taskProgress.progress = data.progress;
|
||
taskProgress.logs.push({
|
||
time: new Date(),
|
||
step: data.step,
|
||
message: data.message,
|
||
details: data.details,
|
||
});
|
||
}
|
||
|
||
// Update floating panel
|
||
updateFloatingProgress(
|
||
data.progress,
|
||
data.current_step,
|
||
data.total_steps,
|
||
data.message,
|
||
);
|
||
|
||
const stepIcons = {
|
||
llm_request: "🤖",
|
||
llm_response: "✨",
|
||
parse_structure: "📋",
|
||
create_tables: "🗄️",
|
||
tables_synced: "✅",
|
||
write_files: "📝",
|
||
write_file: "📄",
|
||
write_designer: "🎨",
|
||
write_tools: "🔧",
|
||
sync_site: "🔄",
|
||
};
|
||
const icon = stepIcons[data.step] || "📌";
|
||
addFloatingLog(icon, data.message, "progress");
|
||
|
||
// Update detail panel if viewing this intent
|
||
if (AutoTaskState.selectedIntentId === data.task_id) {
|
||
updateDetailPanelProgress(data);
|
||
addTerminalLine(data.message);
|
||
}
|
||
}
|
||
|
||
function onTaskProgressCompleted(data) {
|
||
const taskProgress = AutoTaskState.activeTaskProgress[data.task_id];
|
||
if (taskProgress) {
|
||
taskProgress.progress = 100;
|
||
taskProgress.completed = new Date();
|
||
}
|
||
|
||
completeFloatingPanel(data.message);
|
||
|
||
// Refresh intent list
|
||
setTimeout(() => {
|
||
refreshIntents();
|
||
updateStats();
|
||
}, 1000);
|
||
}
|
||
|
||
function onTaskProgressError(data) {
|
||
addFloatingLog("❌", data.error, "error");
|
||
updateFloatingProgress(
|
||
AutoTaskState.activeTaskProgress[data.task_id]?.progress || 0,
|
||
0,
|
||
0,
|
||
`Error: ${data.error}`,
|
||
);
|
||
}
|
||
|
||
function onLLMStream(data) {
|
||
// Stream LLM output to terminal
|
||
addFloatingTerminalOutput(data.text);
|
||
if (AutoTaskState.selectedIntentId === data.task_id) {
|
||
addTerminalLine(data.text, true);
|
||
}
|
||
}
|
||
|
||
function addTerminalLine(text, isLLM = false) {
|
||
const terminal = document.querySelector(
|
||
`#terminal-${AutoTaskState.selectedIntentId}`,
|
||
);
|
||
if (!terminal) return;
|
||
|
||
const line = document.createElement("div");
|
||
line.className = `terminal-line${isLLM ? " highlight" : ""}`;
|
||
line.textContent = text;
|
||
terminal.appendChild(line);
|
||
terminal.scrollTop = terminal.scrollHeight;
|
||
}
|
||
|
||
function updateDetailPanelProgress(data) {
|
||
// Update progress bar in detail panel
|
||
const progressFill = document.querySelector(
|
||
".detail-progress .progress-fill",
|
||
);
|
||
const progressSteps = document.querySelector(
|
||
".detail-progress .progress-steps",
|
||
);
|
||
const progressPct = document.querySelector(
|
||
".detail-progress .progress-percent",
|
||
);
|
||
|
||
if (progressFill) progressFill.style.width = `${data.progress}%`;
|
||
if (progressSteps)
|
||
progressSteps.textContent = `${data.current_step}/${data.total_steps} Steps`;
|
||
if (progressPct) progressPct.textContent = `${data.progress}%`;
|
||
}
|
||
|
||
// =============================================================================
|
||
// INTENT SELECTION & DETAIL PANEL
|
||
// =============================================================================
|
||
|
||
function selectIntent(intentId) {
|
||
// Update selected state
|
||
document.querySelectorAll(".intent-card").forEach((card) => {
|
||
card.classList.remove("selected");
|
||
});
|
||
|
||
const selectedCard = document.querySelector(
|
||
`.intent-card[data-intent-id="${intentId}"]`,
|
||
);
|
||
if (selectedCard) {
|
||
selectedCard.classList.add("selected");
|
||
}
|
||
|
||
AutoTaskState.selectedIntentId = intentId;
|
||
|
||
// Load detail panel
|
||
loadIntentDetail(intentId);
|
||
}
|
||
|
||
function loadIntentDetail(intentId) {
|
||
const panel = document.getElementById("intent-detail-panel");
|
||
if (!panel) return;
|
||
|
||
// Show loading state
|
||
panel.innerHTML = `
|
||
<div class="loading-state">
|
||
<div class="spinner"></div>
|
||
<span>Loading intent details...</span>
|
||
</div>
|
||
`;
|
||
|
||
// Fetch intent details and manifest in parallel
|
||
Promise.all([
|
||
fetch(`/api/autotask/${intentId}`).then((r) => r.json()),
|
||
fetch(`/api/autotask/${intentId}/manifest`)
|
||
.then((r) => r.json())
|
||
.catch(() => null),
|
||
])
|
||
.then(([taskData, manifestData]) => {
|
||
renderIntentDetail(taskData);
|
||
|
||
// If manifest exists, initialize ProgressPanel
|
||
if (manifestData && manifestData.success && manifestData.manifest) {
|
||
if (typeof ProgressPanel !== "undefined") {
|
||
ProgressPanel.manifest = manifestData.manifest;
|
||
ProgressPanel.init(intentId);
|
||
ProgressPanel.render();
|
||
}
|
||
}
|
||
})
|
||
.catch((error) => {
|
||
console.error("Failed to load intent detail:", error);
|
||
panel.innerHTML = `
|
||
<div class="detail-placeholder">
|
||
<span class="placeholder-icon">⚠️</span>
|
||
<p>Failed to load intent details</p>
|
||
</div>
|
||
`;
|
||
});
|
||
}
|
||
|
||
function renderIntentDetail(intent) {
|
||
const panel = document.getElementById("intent-detail-panel");
|
||
if (!panel) return;
|
||
|
||
const statusIcons = {
|
||
active: "⚡",
|
||
complete: "✓",
|
||
paused: "⏸",
|
||
blocked: "⚠",
|
||
awaiting: "⏳",
|
||
};
|
||
|
||
const healthClass =
|
||
intent.health >= 80 ? "good" : intent.health >= 50 ? "warning" : "bad";
|
||
|
||
panel.innerHTML = `
|
||
<div class="detail-view">
|
||
<!-- Header -->
|
||
<div class="detail-header">
|
||
<button class="btn-back" onclick="closeDetailPanel()">
|
||
<span>◀</span>
|
||
</button>
|
||
<h2 class="detail-title">${escapeHtml(intent.title || intent.intent)}</h2>
|
||
<div class="detail-status">
|
||
<span class="status-icon">${statusIcons[intent.status] || "⚡"}</span>
|
||
<span class="status-label">${intent.status_display || intent.status}</span>
|
||
</div>
|
||
<button class="btn-pause" onclick="togglePause('${intent.id}')">
|
||
<span class="pause-icon">${intent.status === "paused" ? "▶" : "⏸"}</span>
|
||
</button>
|
||
</div>
|
||
|
||
<!-- Progress Bar -->
|
||
<div class="detail-progress">
|
||
<div class="progress-bar large">
|
||
<div class="progress-fill" style="width: ${intent.progress || 0}%"></div>
|
||
</div>
|
||
<div class="progress-stats">
|
||
<span class="progress-steps">${intent.current_step || 0}/${intent.total_steps || 0} Steps</span>
|
||
<span class="progress-percent">${intent.progress || 0}%</span>
|
||
</div>
|
||
</div>
|
||
|
||
${
|
||
intent.decision_required
|
||
? `
|
||
<!-- Decision Required Panel -->
|
||
<div class="decision-panel">
|
||
<div class="decision-header">
|
||
<span class="decision-badge">DECISION REQUIRED</span>
|
||
<span class="decision-title">${escapeHtml(intent.decision_title || "Decision needed")}</span>
|
||
</div>
|
||
<div class="decision-body">
|
||
<div class="decision-actions">
|
||
<button class="btn-decision-primary" onclick="openDecisionModal('${intent.id}')">
|
||
Make Decision
|
||
</button>
|
||
<button class="btn-decision-secondary" onclick="viewDecisionContext('${intent.id}')">
|
||
View Context Details
|
||
</button>
|
||
</div>
|
||
<div class="decision-context">
|
||
<div class="context-label">Context:</div>
|
||
<p class="context-text">${escapeHtml(intent.decision_context || "")}</p>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
`
|
||
: ""
|
||
}
|
||
|
||
<!-- Status Section -->
|
||
<div class="detail-section">
|
||
<div class="section-header">
|
||
<span class="section-title">STATUS</span>
|
||
<span class="section-runtime">Runtime: ${intent.runtime || "0 min"}</span>
|
||
</div>
|
||
<div class="status-current-task">
|
||
<span class="task-name">${escapeHtml(intent.current_task_name || "Processing...")}</span>
|
||
<span class="task-estimate">Estimated: ${intent.estimated_time || "calculating..."}</span>
|
||
</div>
|
||
<div class="status-steps-preview">
|
||
${renderStepsPreview(intent.steps || [])}
|
||
</div>
|
||
</div>
|
||
|
||
<!-- Progress Log Section -->
|
||
<div class="detail-section">
|
||
<div class="section-header">
|
||
<span class="section-title">PROGRESS LOG</span>
|
||
</div>
|
||
<div class="progress-log" id="progress-log-${intent.id}">
|
||
${renderProgressLog(intent.logs || [])}
|
||
</div>
|
||
</div>
|
||
|
||
<!-- Terminal Activity Section -->
|
||
<div class="detail-section terminal-section">
|
||
<div class="section-header">
|
||
<span class="section-title">TERMINAL (LIVE AGENT ACTIVITY)</span>
|
||
<span class="terminal-stats">
|
||
Processed: <strong>${intent.processed_count || 0}</strong> data points /
|
||
Processing speed: <strong>${intent.processing_speed || "~8 sources/s"}</strong> /
|
||
Estimated completion: <strong>${intent.estimated_completion || "calculating"}</strong>
|
||
</span>
|
||
</div>
|
||
<div class="terminal-output" id="terminal-${intent.id}">
|
||
<div class="terminal-line">Initializing agent...</div>
|
||
</div>
|
||
<div class="terminal-cursor"></div>
|
||
</div>
|
||
</div>
|
||
`;
|
||
}
|
||
|
||
function renderStepsPreview(steps) {
|
||
if (!steps || steps.length === 0) {
|
||
return '<div class="step-item pending"><span class="step-dot"></span><span class="step-name">No steps yet</span></div>';
|
||
}
|
||
|
||
return steps
|
||
.slice(0, 3)
|
||
.map(
|
||
(step) => `
|
||
<div class="step-item ${step.status || "pending"}">
|
||
<span class="step-dot"></span>
|
||
<span class="step-name">${escapeHtml(step.name)}</span>
|
||
${step.note ? `<span class="step-note">${escapeHtml(step.note)}</span>` : ""}
|
||
</div>
|
||
`,
|
||
)
|
||
.join("");
|
||
}
|
||
|
||
function renderProgressLog(logs) {
|
||
if (!logs || logs.length === 0) {
|
||
return '<div class="log-entry"><div class="log-entry-header"><span class="log-icon pending">●</span><span class="log-title">Waiting for activity...</span></div></div>';
|
||
}
|
||
|
||
return logs
|
||
.map(
|
||
(log) => `
|
||
<div class="log-entry ${log.expanded ? "expanded" : ""}">
|
||
<div class="log-entry-header" onclick="toggleLogEntry(this)">
|
||
<span class="log-icon ${log.status || "pending"}">●</span>
|
||
<span class="log-title">${escapeHtml(log.title)}</span>
|
||
<span class="log-expand">▶</span>
|
||
${log.step_label ? `<span class="log-step-badge">${escapeHtml(log.step_label)}</span>` : ""}
|
||
</div>
|
||
<div class="log-entry-body">
|
||
<div class="log-sub-entries">
|
||
${(log.sub_entries || [])
|
||
.map(
|
||
(sub) => `
|
||
<div class="log-sub-entry">
|
||
<span class="sub-icon ${sub.status || "complete"}">●</span>
|
||
<span class="sub-text">${escapeHtml(sub.text)}</span>
|
||
<span class="sub-duration">Duration: ${sub.duration || "< 1 min"}</span>
|
||
<span class="sub-check">${sub.status === "complete" ? "✓" : ""}</span>
|
||
</div>
|
||
`,
|
||
)
|
||
.join("")}
|
||
</div>
|
||
</div>
|
||
</div>
|
||
`,
|
||
)
|
||
.join("");
|
||
}
|
||
|
||
function toggleLogEntry(header) {
|
||
const entry = header.closest(".log-entry");
|
||
if (entry) {
|
||
entry.classList.toggle("expanded");
|
||
}
|
||
}
|
||
|
||
function closeDetailPanel() {
|
||
// Clean up ProgressPanel if active
|
||
if (typeof ProgressPanel !== "undefined") {
|
||
ProgressPanel.destroy();
|
||
}
|
||
|
||
AutoTaskState.selectedIntentId = null;
|
||
|
||
document.querySelectorAll(".intent-card").forEach((card) => {
|
||
card.classList.remove("selected");
|
||
});
|
||
|
||
const panel = document.getElementById("intent-detail-panel");
|
||
if (panel) {
|
||
panel.innerHTML = `
|
||
<div class="detail-placeholder">
|
||
<span class="placeholder-icon">📋</span>
|
||
<p>Select an intent to view details</p>
|
||
</div>
|
||
`;
|
||
}
|
||
}
|
||
|
||
function viewDetailedIntent(intentId) {
|
||
selectIntent(intentId);
|
||
}
|
||
|
||
function togglePause(intentId) {
|
||
const intent = AutoTaskState.intents.find((i) => i.id === intentId);
|
||
if (!intent) return;
|
||
|
||
const action = intent.status === "paused" ? "resume" : "pause";
|
||
|
||
fetch(`/api/autotask/${intentId}/${action}`, { method: "POST" })
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast(`Intent ${action}d`, "success");
|
||
refreshIntents();
|
||
if (AutoTaskState.selectedIntentId === intentId) {
|
||
loadIntentDetail(intentId);
|
||
}
|
||
} else {
|
||
showToast(`Failed to ${action} intent`, "error");
|
||
}
|
||
})
|
||
.catch((error) => {
|
||
console.error(`Failed to ${action} intent:`, error);
|
||
showToast(`Failed to ${action} intent`, "error");
|
||
});
|
||
}
|
||
|
||
function formatTime(date) {
|
||
return date.toLocaleTimeString("en-US", {
|
||
hour: "2-digit",
|
||
minute: "2-digit",
|
||
second: "2-digit",
|
||
hour12: false,
|
||
});
|
||
}
|
||
|
||
function escapeHtml(text) {
|
||
const div = document.createElement("div");
|
||
div.textContent = text;
|
||
return div.innerHTML;
|
||
}
|
||
|
||
function handleWebSocketMessage(data) {
|
||
switch (data.type) {
|
||
case "task_update":
|
||
case "intent_update":
|
||
updateIntentInList(data.task || data.intent);
|
||
break;
|
||
case "step_progress":
|
||
updateStepProgress(data.taskId, data.step, data.progress);
|
||
break;
|
||
case "decision_required":
|
||
showDecisionNotification(data.decision);
|
||
break;
|
||
case "approval_required":
|
||
showApprovalNotification(data.approval);
|
||
break;
|
||
case "task_completed":
|
||
case "intent_completed":
|
||
onIntentCompleted(data.task || data.intent);
|
||
break;
|
||
case "task_failed":
|
||
case "intent_failed":
|
||
onIntentFailed(data.task || data.intent, data.error);
|
||
break;
|
||
case "stats_update":
|
||
updateStatsFromData(data.stats);
|
||
break;
|
||
}
|
||
}
|
||
|
||
function updateIntentInList(intent) {
|
||
const card = document.querySelector(
|
||
`.intent-card[data-intent-id="${intent.id}"]`,
|
||
);
|
||
if (card) {
|
||
// Update progress
|
||
const progressFill = card.querySelector(".progress-fill");
|
||
const progressSteps = card.querySelector(".progress-steps");
|
||
const progressPct = card.querySelector(".progress-percent");
|
||
|
||
if (progressFill) progressFill.style.width = `${intent.progress}%`;
|
||
if (progressSteps)
|
||
progressSteps.textContent = `${intent.current_step}/${intent.total_steps} Steps`;
|
||
if (progressPct) progressPct.textContent = `${intent.progress}%`;
|
||
|
||
// Update status indicator
|
||
const statusIndicator = card.querySelector(".intent-status-indicator");
|
||
if (statusIndicator) {
|
||
statusIndicator.className = `intent-status-indicator ${intent.status}`;
|
||
}
|
||
}
|
||
}
|
||
|
||
function onIntentCompleted(intent) {
|
||
showToast(`Intent completed: ${intent.title || intent.id}`, "success");
|
||
updateIntentInList(intent);
|
||
updateStats();
|
||
}
|
||
|
||
function onIntentFailed(intent, error) {
|
||
showToast(`Intent failed: ${intent.title || intent.id} - ${error}`, "error");
|
||
updateIntentInList(intent);
|
||
updateStats();
|
||
}
|
||
|
||
// =============================================================================
|
||
// EVENT LISTENERS
|
||
// =============================================================================
|
||
|
||
function setupEventListeners() {
|
||
// Intent form submission
|
||
const intentForm = document.getElementById("intent-form");
|
||
if (intentForm) {
|
||
intentForm.addEventListener("htmx:afterSwap", function (event) {
|
||
if (event.detail.target.id === "compilation-result") {
|
||
onCompilationComplete(event);
|
||
}
|
||
});
|
||
}
|
||
|
||
// Task list updates
|
||
const taskList = document.getElementById("task-list");
|
||
if (taskList) {
|
||
taskList.addEventListener("htmx:afterSwap", function () {
|
||
updateStats();
|
||
highlightPendingItems();
|
||
});
|
||
}
|
||
|
||
// Expand log entries on details open
|
||
document.addEventListener(
|
||
"toggle",
|
||
function (event) {
|
||
if (
|
||
event.target.classList.contains("execution-log") &&
|
||
event.target.open
|
||
) {
|
||
const taskId = event.target.closest(".autotask-item")?.dataset.taskId;
|
||
if (taskId) {
|
||
loadExecutionLogs(taskId);
|
||
}
|
||
}
|
||
},
|
||
true,
|
||
);
|
||
}
|
||
|
||
function setupKeyboardShortcuts() {
|
||
document.addEventListener("keydown", function (e) {
|
||
// Alt + N: Focus on intent input
|
||
if (e.altKey && e.key === "n") {
|
||
e.preventDefault();
|
||
document.getElementById("intent-input")?.focus();
|
||
}
|
||
|
||
// Alt + R: Refresh tasks
|
||
if (e.altKey && e.key === "r") {
|
||
e.preventDefault();
|
||
refreshTasks();
|
||
}
|
||
|
||
// Escape: Close any open modal
|
||
if (e.key === "Escape") {
|
||
closeAllModals();
|
||
}
|
||
|
||
// Alt + 1-4: Switch filters
|
||
if (e.altKey && e.key >= "1" && e.key <= "4") {
|
||
e.preventDefault();
|
||
const filters = ["all", "running", "approval", "decision"];
|
||
const index = parseInt(e.key) - 1;
|
||
const tabs = document.querySelectorAll(".filter-tab");
|
||
if (tabs[index]) {
|
||
tabs[index].click();
|
||
}
|
||
}
|
||
});
|
||
}
|
||
|
||
// =============================================================================
|
||
// AUTO REFRESH
|
||
// =============================================================================
|
||
|
||
function startAutoRefresh() {
|
||
// Refresh every 5 seconds
|
||
AutoTaskState.refreshInterval = setInterval(function () {
|
||
if (!document.hidden) {
|
||
updateStats();
|
||
}
|
||
}, 5000);
|
||
}
|
||
|
||
function stopAutoRefresh() {
|
||
if (AutoTaskState.refreshInterval) {
|
||
clearInterval(AutoTaskState.refreshInterval);
|
||
AutoTaskState.refreshInterval = null;
|
||
}
|
||
}
|
||
|
||
// =============================================================================
|
||
// STATS MANAGEMENT
|
||
// =============================================================================
|
||
|
||
function updateStats() {
|
||
fetch("/api/autotask/stats")
|
||
.then((response) => response.json())
|
||
.then((stats) => {
|
||
updateStatsFromData(stats);
|
||
})
|
||
.catch((error) => {
|
||
console.error("Failed to fetch stats:", error);
|
||
});
|
||
}
|
||
|
||
function updateStatsFromData(stats) {
|
||
// Sentient filter counts
|
||
const countComplete = document.getElementById("count-complete");
|
||
const countActive = document.getElementById("count-active");
|
||
const countAwaiting = document.getElementById("count-awaiting");
|
||
const countPaused = document.getElementById("count-paused");
|
||
const countBlocked = document.getElementById("count-blocked");
|
||
const timeSaved = document.getElementById("time-saved");
|
||
|
||
if (countComplete) countComplete.textContent = stats.completed || 0;
|
||
if (countActive) countActive.textContent = stats.running || stats.active || 0;
|
||
if (countAwaiting)
|
||
countAwaiting.textContent = stats.pending_decision || stats.awaiting || 0;
|
||
if (countPaused) countPaused.textContent = stats.paused || 0;
|
||
if (countBlocked)
|
||
countBlocked.textContent = stats.blocked || stats.failed || 0;
|
||
if (timeSaved) timeSaved.textContent = stats.time_saved || "0 hrs this week";
|
||
|
||
// Legacy support
|
||
const statRunning = document.getElementById("stat-running");
|
||
const statPending = document.getElementById("stat-pending");
|
||
const statCompleted = document.getElementById("stat-completed");
|
||
const statApproval = document.getElementById("stat-approval");
|
||
|
||
if (statRunning) statRunning.textContent = stats.running || 0;
|
||
if (statPending) statPending.textContent = stats.pending || 0;
|
||
if (statCompleted) statCompleted.textContent = stats.completed || 0;
|
||
if (statApproval) statApproval.textContent = stats.pending_approval || 0;
|
||
}
|
||
|
||
// =============================================================================
|
||
// TASK FILTERING
|
||
// =============================================================================
|
||
|
||
function filterTasks(filter, button) {
|
||
AutoTaskState.currentFilter = filter;
|
||
|
||
// Update active tab
|
||
document.querySelectorAll(".filter-tab").forEach((tab) => {
|
||
tab.classList.remove("active");
|
||
});
|
||
button.classList.add("active");
|
||
|
||
// Trigger HTMX request
|
||
htmx.ajax("GET", `/api/autotask/list?filter=${filter}`, {
|
||
target: "#task-list",
|
||
swap: "innerHTML",
|
||
});
|
||
}
|
||
|
||
// Sentient status filter
|
||
function filterByStatus(status, button) {
|
||
AutoTaskState.currentFilter = status;
|
||
|
||
// Update active filter
|
||
document.querySelectorAll(".status-filter").forEach((filter) => {
|
||
filter.classList.remove("active");
|
||
});
|
||
button.classList.add("active");
|
||
|
||
// Trigger HTMX request for intent list
|
||
htmx.ajax("GET", `/api/autotask/list?status=${status}`, {
|
||
target: "#intent-list",
|
||
swap: "innerHTML",
|
||
});
|
||
}
|
||
|
||
function refreshTasks() {
|
||
const filter = AutoTaskState.currentFilter;
|
||
htmx.ajax("GET", `/api/autotask/list?filter=${filter}`, {
|
||
target: "#task-list",
|
||
swap: "innerHTML",
|
||
});
|
||
updateStats();
|
||
}
|
||
|
||
function refreshIntents() {
|
||
const status = AutoTaskState.currentFilter;
|
||
htmx.ajax("GET", `/api/autotask/list?status=${status}`, {
|
||
target: "#intent-list",
|
||
swap: "innerHTML",
|
||
});
|
||
updateStats();
|
||
}
|
||
|
||
// =============================================================================
|
||
// MODAL FUNCTIONS - SENTIENT
|
||
// =============================================================================
|
||
|
||
function showNewIntentModal() {
|
||
const modal = document.getElementById("new-intent-modal");
|
||
if (modal) {
|
||
modal.style.display = "flex";
|
||
document.body.classList.add("modal-open");
|
||
setTimeout(() => {
|
||
document.getElementById("intent-input")?.focus();
|
||
}, 100);
|
||
}
|
||
}
|
||
|
||
function closeNewIntentModal() {
|
||
const modal = document.getElementById("new-intent-modal");
|
||
if (modal) {
|
||
modal.style.display = "none";
|
||
document.body.classList.remove("modal-open");
|
||
}
|
||
}
|
||
|
||
function openDecisionModal(intentId) {
|
||
const modal = document.getElementById("decision-modal");
|
||
if (!modal) return;
|
||
|
||
modal.style.display = "flex";
|
||
document.body.classList.add("modal-open");
|
||
|
||
const content = document.getElementById("decision-content");
|
||
if (content) {
|
||
content.innerHTML = `
|
||
<div class="loading-state">
|
||
<div class="spinner"></div>
|
||
<span>Loading decision options...</span>
|
||
</div>
|
||
`;
|
||
}
|
||
|
||
// Fetch decision details
|
||
fetch(`/api/autotask/${intentId}/decisions`)
|
||
.then((response) => response.json())
|
||
.then((decisions) => {
|
||
renderDecisionContent(intentId, decisions);
|
||
})
|
||
.catch((error) => {
|
||
console.error("Failed to load decisions:", error);
|
||
if (content) {
|
||
content.innerHTML = `
|
||
<div class="detail-placeholder">
|
||
<span class="placeholder-icon">⚠️</span>
|
||
<p>Failed to load decision options</p>
|
||
</div>
|
||
`;
|
||
}
|
||
});
|
||
}
|
||
|
||
function renderDecisionContent(intentId, decisions) {
|
||
const content = document.getElementById("decision-content");
|
||
if (!content || !decisions || decisions.length === 0) {
|
||
if (content) {
|
||
content.innerHTML = `
|
||
<div class="detail-placeholder">
|
||
<span class="placeholder-icon">✓</span>
|
||
<p>No pending decisions</p>
|
||
</div>
|
||
`;
|
||
}
|
||
return;
|
||
}
|
||
|
||
const decision = decisions[0];
|
||
content.innerHTML = `
|
||
<div class="decision-detail">
|
||
<h3>${escapeHtml(decision.title)}</h3>
|
||
<p class="decision-desc">${escapeHtml(decision.description)}</p>
|
||
|
||
<div class="decision-options-list">
|
||
${decision.options
|
||
.map(
|
||
(opt, idx) => `
|
||
<label class="decision-option-item ${opt.recommended ? "recommended" : ""}">
|
||
<input type="radio" name="decision_option" value="${opt.id}" ${idx === 0 ? "checked" : ""}>
|
||
<div class="option-content">
|
||
<span class="option-label">${escapeHtml(opt.label)}</span>
|
||
${opt.recommended ? '<span class="recommended-tag">Recommended</span>' : ""}
|
||
<p class="option-desc">${escapeHtml(opt.description || "")}</p>
|
||
</div>
|
||
</label>
|
||
`,
|
||
)
|
||
.join("")}
|
||
</div>
|
||
|
||
<div class="form-actions">
|
||
<button class="btn-secondary" onclick="closeDecisionModal()">Cancel</button>
|
||
<button class="btn-primary" onclick="submitDecisionFromModal('${intentId}', '${decision.id}')">
|
||
Submit Decision
|
||
</button>
|
||
</div>
|
||
</div>
|
||
`;
|
||
}
|
||
|
||
function submitDecisionFromModal(intentId, decisionId) {
|
||
const selectedOption = document.querySelector(
|
||
'input[name="decision_option"]:checked',
|
||
)?.value;
|
||
|
||
if (!selectedOption) {
|
||
showToast("Please select an option", "warning");
|
||
return;
|
||
}
|
||
|
||
fetch(`/api/autotask/${intentId}/decide`, {
|
||
method: "POST",
|
||
headers: { "Content-Type": "application/json" },
|
||
body: JSON.stringify({
|
||
decision_id: decisionId,
|
||
option_id: selectedOption,
|
||
}),
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast("Decision submitted", "success");
|
||
closeDecisionModal();
|
||
refreshIntents();
|
||
if (AutoTaskState.selectedIntentId === intentId) {
|
||
loadIntentDetail(intentId);
|
||
}
|
||
} else {
|
||
showToast(`Failed: ${result.error || "Unknown error"}`, "error");
|
||
}
|
||
})
|
||
.catch((error) => {
|
||
console.error("Failed to submit decision:", error);
|
||
showToast("Failed to submit decision", "error");
|
||
});
|
||
}
|
||
|
||
function closeDecisionModal() {
|
||
const modal = document.getElementById("decision-modal");
|
||
if (modal) {
|
||
modal.style.display = "none";
|
||
document.body.classList.remove("modal-open");
|
||
}
|
||
}
|
||
|
||
function viewDecisionContext(intentId) {
|
||
openDecisionModal(intentId);
|
||
}
|
||
|
||
function closeAllModals() {
|
||
closeNewIntentModal();
|
||
closeDecisionModal();
|
||
document.body.classList.remove("modal-open");
|
||
}
|
||
|
||
// =============================================================================
|
||
// COMPILATION HANDLING
|
||
// =============================================================================
|
||
|
||
function onCompilationComplete(event) {
|
||
const result = event.detail.target.querySelector(".compiled-plan");
|
||
if (result) {
|
||
// Scroll to result
|
||
result.scrollIntoView({ behavior: "smooth", block: "start" });
|
||
|
||
// Store compiled plan
|
||
const planId = result.dataset?.planId;
|
||
if (planId) {
|
||
AutoTaskState.compiledPlan = planId;
|
||
}
|
||
|
||
// Syntax highlight the code
|
||
highlightBasicCode();
|
||
}
|
||
}
|
||
|
||
function highlightBasicCode() {
|
||
const codeBlocks = document.querySelectorAll(".code-preview code");
|
||
codeBlocks.forEach((block) => {
|
||
// Basic syntax highlighting for BASIC keywords
|
||
let html = block.innerHTML;
|
||
|
||
// Keywords
|
||
const keywords = [
|
||
"PLAN_START",
|
||
"PLAN_END",
|
||
"STEP",
|
||
"SET",
|
||
"GET",
|
||
"IF",
|
||
"THEN",
|
||
"ELSE",
|
||
"END IF",
|
||
"FOR EACH",
|
||
"NEXT",
|
||
"WHILE",
|
||
"WEND",
|
||
"TALK",
|
||
"HEAR",
|
||
"LLM",
|
||
"CREATE_TASK",
|
||
"RUN_PYTHON",
|
||
"RUN_JAVASCRIPT",
|
||
"RUN_BASH",
|
||
"USE_MCP",
|
||
"POST",
|
||
"GET",
|
||
"PUT",
|
||
"PATCH",
|
||
"DELETE HTTP",
|
||
"REQUIRE_APPROVAL",
|
||
"SIMULATE_IMPACT",
|
||
"AUDIT_LOG",
|
||
"SEND_MAIL",
|
||
"SAVE",
|
||
"UPDATE",
|
||
"INSERT",
|
||
"DELETE",
|
||
"FIND",
|
||
];
|
||
|
||
keywords.forEach((keyword) => {
|
||
const regex = new RegExp(`\\b${keyword}\\b`, "g");
|
||
html = html.replace(regex, `<span class="keyword">${keyword}</span>`);
|
||
});
|
||
|
||
// Comments
|
||
html = html.replace(/(\'[^\n]*)/g, '<span class="comment">$1</span>');
|
||
|
||
// Strings
|
||
html = html.replace(/("[^"]*")/g, '<span class="string">$1</span>');
|
||
|
||
// Numbers
|
||
html = html.replace(/\b(\d+)\b/g, '<span class="number">$1</span>');
|
||
|
||
block.innerHTML = html;
|
||
});
|
||
}
|
||
|
||
function copyGeneratedCode() {
|
||
const code = document.querySelector(".code-preview code")?.textContent;
|
||
if (code) {
|
||
navigator.clipboard
|
||
.writeText(code)
|
||
.then(() => {
|
||
showToast("Code copied to clipboard", "success");
|
||
})
|
||
.catch(() => {
|
||
showToast("Failed to copy code", "error");
|
||
});
|
||
}
|
||
}
|
||
|
||
function discardPlan() {
|
||
if (confirm("Are you sure you want to discard this plan?")) {
|
||
document.getElementById("compilation-result").innerHTML = "";
|
||
AutoTaskState.compiledPlan = null;
|
||
document.getElementById("intent-input").value = "";
|
||
document.getElementById("intent-input").focus();
|
||
}
|
||
}
|
||
|
||
function editPlan() {
|
||
if (!AutoTaskState.compiledPlan) {
|
||
showToast("No plan to edit", "warning");
|
||
return;
|
||
}
|
||
|
||
const modal = document.createElement("div");
|
||
modal.className = "modal-overlay";
|
||
modal.id = "plan-editor-modal";
|
||
modal.innerHTML = `
|
||
<div class="modal-content large">
|
||
<div class="modal-header">
|
||
<h3>Edit Plan</h3>
|
||
<button class="close-btn" onclick="closePlanEditor()">×</button>
|
||
</div>
|
||
<div class="modal-body">
|
||
<div class="form-group">
|
||
<label for="plan-name">Plan Name</label>
|
||
<input type="text" id="plan-name" value="${AutoTaskState.compiledPlan.name || "Untitled Plan"}" />
|
||
</div>
|
||
<div class="form-group">
|
||
<label for="plan-description">Description</label>
|
||
<textarea id="plan-description" rows="3">${AutoTaskState.compiledPlan.description || ""}</textarea>
|
||
</div>
|
||
<div class="form-group">
|
||
<label for="plan-steps">Steps (JSON)</label>
|
||
<textarea id="plan-steps" rows="10" class="code-editor">${JSON.stringify(AutoTaskState.compiledPlan.steps || [], null, 2)}</textarea>
|
||
</div>
|
||
<div class="form-group">
|
||
<label for="plan-priority">Priority</label>
|
||
<select id="plan-priority">
|
||
<option value="low" ${AutoTaskState.compiledPlan.priority === "low" ? "selected" : ""}>Low</option>
|
||
<option value="medium" ${AutoTaskState.compiledPlan.priority === "medium" ? "selected" : ""}>Medium</option>
|
||
<option value="high" ${AutoTaskState.compiledPlan.priority === "high" ? "selected" : ""}>High</option>
|
||
<option value="urgent" ${AutoTaskState.compiledPlan.priority === "urgent" ? "selected" : ""}>Urgent</option>
|
||
</select>
|
||
</div>
|
||
</div>
|
||
<div class="modal-footer">
|
||
<button class="btn btn-secondary" onclick="closePlanEditor()">Cancel</button>
|
||
<button class="btn btn-primary" onclick="savePlanEdits()">Save Changes</button>
|
||
</div>
|
||
</div>
|
||
`;
|
||
document.body.appendChild(modal);
|
||
}
|
||
|
||
function closePlanEditor() {
|
||
const modal = document.getElementById("plan-editor-modal");
|
||
if (modal) {
|
||
modal.remove();
|
||
}
|
||
}
|
||
|
||
function savePlanEdits() {
|
||
const name = document.getElementById("plan-name").value;
|
||
const description = document.getElementById("plan-description").value;
|
||
const stepsJson = document.getElementById("plan-steps").value;
|
||
const priority = document.getElementById("plan-priority").value;
|
||
|
||
let steps;
|
||
try {
|
||
steps = JSON.parse(stepsJson);
|
||
} catch (e) {
|
||
showToast("Invalid JSON in steps", "error");
|
||
return;
|
||
}
|
||
|
||
AutoTaskState.compiledPlan = {
|
||
...AutoTaskState.compiledPlan,
|
||
name: name,
|
||
description: description,
|
||
steps: steps,
|
||
priority: priority,
|
||
};
|
||
|
||
closePlanEditor();
|
||
showToast("Plan updated successfully", "success");
|
||
|
||
const resultDiv = document.getElementById("compilation-result");
|
||
if (resultDiv && AutoTaskState.compiledPlan) {
|
||
renderCompiledPlan(AutoTaskState.compiledPlan);
|
||
}
|
||
}
|
||
|
||
function renderCompiledPlan(plan) {
|
||
const resultDiv = document.getElementById("compilation-result");
|
||
if (!resultDiv) return;
|
||
|
||
const stepsHtml = (plan.steps || [])
|
||
.map(
|
||
(step, i) => `
|
||
<div class="plan-step">
|
||
<span class="step-number">${i + 1}</span>
|
||
<span class="step-action">${step.action || step.type || "Action"}</span>
|
||
<span class="step-target">${step.target || step.description || ""}</span>
|
||
</div>
|
||
`,
|
||
)
|
||
.join("");
|
||
|
||
resultDiv.innerHTML = `
|
||
<div class="compiled-plan">
|
||
<div class="plan-header">
|
||
<h4>${plan.name || "Compiled Plan"}</h4>
|
||
<span class="plan-priority priority-${plan.priority || "medium"}">${plan.priority || "medium"}</span>
|
||
</div>
|
||
${plan.description ? `<p class="plan-description">${plan.description}</p>` : ""}
|
||
<div class="plan-steps">${stepsHtml}</div>
|
||
<div class="plan-actions">
|
||
<button class="btn btn-secondary" onclick="editPlan()">Edit</button>
|
||
<button class="btn btn-secondary" onclick="discardPlan()">Discard</button>
|
||
<button class="btn btn-primary" onclick="executePlan('${plan.id || ""}')">Execute</button>
|
||
</div>
|
||
</div>
|
||
`;
|
||
}
|
||
|
||
// =============================================================================
|
||
// PLAN EXECUTION
|
||
// =============================================================================
|
||
|
||
function simulatePlan(planId) {
|
||
showSimulationModal();
|
||
|
||
fetch(`/api/autotask/simulate/${planId}`, {
|
||
method: "POST",
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
renderSimulationResult(result);
|
||
})
|
||
.catch((error) => {
|
||
document.getElementById("simulation-content").innerHTML = `
|
||
<div class="error-message">
|
||
<span class="error-icon">❌</span>
|
||
<p>Failed to simulate plan: ${error.message}</p>
|
||
</div>
|
||
`;
|
||
});
|
||
}
|
||
|
||
function executePlan(planId) {
|
||
const executionMode =
|
||
document.querySelector('[name="execution_mode"]')?.value ||
|
||
"semi-automatic";
|
||
const priority =
|
||
document.querySelector('[name="priority"]')?.value || "medium";
|
||
|
||
if (!confirm("Are you sure you want to execute this plan?")) {
|
||
return;
|
||
}
|
||
|
||
fetch("/api/autotask/execute", {
|
||
method: "POST",
|
||
headers: {
|
||
"Content-Type": "application/json",
|
||
},
|
||
body: JSON.stringify({
|
||
plan_id: planId,
|
||
execution_mode: executionMode,
|
||
priority: priority,
|
||
}),
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast("Task execution started!", "success");
|
||
document.getElementById("compilation-result").innerHTML = "";
|
||
document.getElementById("intent-input").value = "";
|
||
refreshTasks();
|
||
} else {
|
||
showToast(`Failed to start execution: ${result.error}`, "error");
|
||
}
|
||
})
|
||
.catch((error) => {
|
||
showToast(`Failed to execute plan: ${error.message}`, "error");
|
||
});
|
||
}
|
||
|
||
// =============================================================================
|
||
// TASK ACTIONS
|
||
// =============================================================================
|
||
|
||
function viewTaskDetails(taskId) {
|
||
window.location.href = `/suite/tasks/detail/${taskId}`;
|
||
}
|
||
|
||
function simulateTask(taskId) {
|
||
showSimulationModal();
|
||
|
||
fetch(`/api/autotask/${taskId}/simulate`, {
|
||
method: "POST",
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
result.task_id = taskId;
|
||
renderSimulationResult(result);
|
||
})
|
||
.catch((error) => {
|
||
document.getElementById("simulation-content").innerHTML = `
|
||
<div class="error-message">
|
||
<span class="error-icon">❌</span>
|
||
<p>Failed to simulate task: ${error.message}</p>
|
||
</div>
|
||
`;
|
||
});
|
||
}
|
||
|
||
function pauseTask(taskId) {
|
||
fetch(`/api/autotask/${taskId}/pause`, {
|
||
method: "POST",
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast("Task paused", "success");
|
||
refreshTasks();
|
||
} else {
|
||
showToast(`Failed to pause task: ${result.error}`, "error");
|
||
}
|
||
});
|
||
}
|
||
|
||
function resumeTask(taskId) {
|
||
fetch(`/api/autotask/${taskId}/resume`, {
|
||
method: "POST",
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast("Task resumed", "success");
|
||
refreshTasks();
|
||
} else {
|
||
showToast(`Failed to resume task: ${result.error}`, "error");
|
||
}
|
||
});
|
||
}
|
||
|
||
function cancelTask(taskId) {
|
||
if (
|
||
!confirm(
|
||
"Are you sure you want to cancel this task? This may not be reversible.",
|
||
)
|
||
) {
|
||
return;
|
||
}
|
||
|
||
fetch(`/api/autotask/${taskId}/cancel`, {
|
||
method: "POST",
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast("Task cancelled", "success");
|
||
refreshTasks();
|
||
} else {
|
||
showToast(`Failed to cancel task: ${result.error}`, "error");
|
||
}
|
||
});
|
||
}
|
||
|
||
function updateTaskInList(task) {
|
||
const taskElement = document.querySelector(`[data-task-id="${task.id}"]`);
|
||
if (taskElement) {
|
||
// Update status badge
|
||
const statusBadge = taskElement.querySelector(".task-status-badge");
|
||
if (statusBadge) {
|
||
statusBadge.className = `task-status-badge status-${task.status}`;
|
||
statusBadge.textContent = task.status.replace(/-/g, " ");
|
||
}
|
||
|
||
// Update progress
|
||
const progressFill = taskElement.querySelector(".progress-fill");
|
||
const progressText = taskElement.querySelector(".progress-text");
|
||
if (progressFill && progressText) {
|
||
progressFill.style.width = `${task.progress}%`;
|
||
progressText.textContent = `${task.current_step}/${task.total_steps} steps (${Math.round(task.progress)}%)`;
|
||
}
|
||
|
||
// Update data attribute
|
||
taskElement.dataset.status = task.status;
|
||
}
|
||
}
|
||
|
||
function updateStepProgress(taskId, step, progress) {
|
||
const taskElement = document.querySelector(`[data-task-id="${taskId}"]`);
|
||
if (taskElement) {
|
||
const currentStep = taskElement.querySelector(".current-step");
|
||
if (currentStep) {
|
||
currentStep.querySelector(".step-name").textContent =
|
||
`Step ${step.order}: ${step.name}`;
|
||
currentStep.querySelector(".step-status").textContent =
|
||
`${Math.round(progress)}%`;
|
||
}
|
||
}
|
||
}
|
||
|
||
// =============================================================================
|
||
// DECISIONS
|
||
// =============================================================================
|
||
|
||
function viewDecisions(taskId) {
|
||
showDecisionModal();
|
||
|
||
fetch(`/api/autotask/${taskId}/decisions`)
|
||
.then((response) => response.json())
|
||
.then((decisions) => {
|
||
renderDecisions(taskId, decisions);
|
||
})
|
||
.catch((error) => {
|
||
document.getElementById("decision-content").innerHTML = `
|
||
<div class="error-message">
|
||
<span class="error-icon">❌</span>
|
||
<p>Failed to load decisions: ${error.message}</p>
|
||
</div>
|
||
`;
|
||
});
|
||
}
|
||
|
||
function renderDecisions(taskId, decisions) {
|
||
const container = document.getElementById("decision-content");
|
||
|
||
if (!decisions || decisions.length === 0) {
|
||
container.innerHTML = '<p class="no-decisions">No pending decisions.</p>';
|
||
return;
|
||
}
|
||
|
||
let html = '<div class="decisions-list">';
|
||
|
||
decisions.forEach((decision) => {
|
||
html += `
|
||
<div class="decision-item" data-decision-id="${decision.id}">
|
||
<h4>${decision.title}</h4>
|
||
<p class="decision-description">${decision.description}</p>
|
||
|
||
<div class="decision-options">
|
||
${decision.options
|
||
.map(
|
||
(opt) => `
|
||
<div class="decision-option ${opt.recommended ? "recommended" : ""}" data-option-id="${opt.id}">
|
||
<div class="option-header">
|
||
<input type="radio" name="decision_${decision.id}" value="${opt.id}" id="opt_${opt.id}" ${opt.recommended ? "checked" : ""}>
|
||
<label for="opt_${opt.id}">
|
||
<span class="option-label">${opt.label}</span>
|
||
${opt.recommended ? '<span class="recommended-badge">Recommended</span>' : ""}
|
||
</label>
|
||
</div>
|
||
<p class="option-description">${opt.description}</p>
|
||
<div class="option-impact">
|
||
<span class="impact-cost">💰 ${opt.estimated_impact.cost_change >= 0 ? "+" : ""}$${opt.estimated_impact.cost_change}</span>
|
||
<span class="impact-time">⏱️ ${opt.estimated_impact.time_change_minutes >= 0 ? "+" : ""}${opt.estimated_impact.time_change_minutes}m</span>
|
||
<span class="impact-risk risk-${opt.risk_level.toLowerCase()}">⚠️ ${opt.risk_level}</span>
|
||
</div>
|
||
</div>
|
||
`,
|
||
)
|
||
.join("")}
|
||
</div>
|
||
|
||
<div class="decision-actions">
|
||
<button class="btn-secondary" onclick="skipDecision('${taskId}', '${decision.id}')">Skip</button>
|
||
<button class="btn-primary" onclick="submitDecision('${taskId}', '${decision.id}')">Submit Decision</button>
|
||
</div>
|
||
</div>
|
||
`;
|
||
});
|
||
|
||
html += "</div>";
|
||
container.innerHTML = html;
|
||
}
|
||
|
||
function submitDecision(taskId, decisionId) {
|
||
const selectedOption = document.querySelector(
|
||
`input[name="decision_${decisionId}"]:checked`,
|
||
)?.value;
|
||
|
||
if (!selectedOption) {
|
||
showToast("Please select an option", "warning");
|
||
return;
|
||
}
|
||
|
||
fetch(`/api/autotask/${taskId}/decide`, {
|
||
method: "POST",
|
||
headers: {
|
||
"Content-Type": "application/json",
|
||
},
|
||
body: JSON.stringify({
|
||
decision_id: decisionId,
|
||
option_id: selectedOption,
|
||
}),
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast("Decision submitted", "success");
|
||
closeDecisionModal();
|
||
refreshTasks();
|
||
} else {
|
||
showToast(`Failed to submit decision: ${result.error}`, "error");
|
||
}
|
||
});
|
||
}
|
||
|
||
function skipDecision(taskId, decisionId) {
|
||
if (
|
||
!confirm(
|
||
"Are you sure you want to skip this decision? The default option will be used.",
|
||
)
|
||
) {
|
||
return;
|
||
}
|
||
|
||
fetch(`/api/autotask/${taskId}/decide`, {
|
||
method: "POST",
|
||
headers: {
|
||
"Content-Type": "application/json",
|
||
},
|
||
body: JSON.stringify({
|
||
decision_id: decisionId,
|
||
skip: true,
|
||
}),
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast("Decision skipped", "info");
|
||
closeDecisionModal();
|
||
refreshTasks();
|
||
} else {
|
||
showToast(`Failed to skip decision: ${result.error}`, "error");
|
||
}
|
||
});
|
||
}
|
||
|
||
function showDecisionNotification(decision) {
|
||
showToast(`Decision required: ${decision.title}`, "warning", 10000);
|
||
updateStats();
|
||
}
|
||
|
||
// =============================================================================
|
||
// APPROVALS
|
||
// =============================================================================
|
||
|
||
function viewApprovals(taskId) {
|
||
showApprovalModal();
|
||
|
||
fetch(`/api/autotask/${taskId}/approvals`)
|
||
.then((response) => response.json())
|
||
.then((approvals) => {
|
||
renderApprovals(taskId, approvals);
|
||
})
|
||
.catch((error) => {
|
||
document.getElementById("approval-content").innerHTML = `
|
||
<div class="error-message">
|
||
<span class="error-icon">❌</span>
|
||
<p>Failed to load approvals: ${error.message}</p>
|
||
</div>
|
||
`;
|
||
});
|
||
}
|
||
|
||
function renderApprovals(taskId, approvals) {
|
||
const container = document.getElementById("approval-content");
|
||
|
||
if (!approvals || approvals.length === 0) {
|
||
container.innerHTML = '<p class="no-approvals">No pending approvals.</p>';
|
||
return;
|
||
}
|
||
|
||
let html = '<div class="approvals-list">';
|
||
|
||
approvals.forEach((approval) => {
|
||
html += `
|
||
<div class="approval-item" data-approval-id="${approval.id}">
|
||
<div class="approval-header">
|
||
<span class="approval-type type-${approval.approval_type.toLowerCase().replace(/_/g, "-")}">${approval.approval_type.replace(/_/g, " ")}</span>
|
||
<span class="approval-risk risk-${approval.risk_level.toLowerCase()}">${approval.risk_level} Risk</span>
|
||
</div>
|
||
|
||
<h4>${approval.title}</h4>
|
||
<p class="approval-description">${approval.description}</p>
|
||
|
||
<div class="approval-impact">
|
||
<h5>Impact Summary</h5>
|
||
<p>${approval.impact_summary}</p>
|
||
</div>
|
||
|
||
${
|
||
approval.simulation_result
|
||
? `
|
||
<div class="simulation-preview">
|
||
<h5>Simulation Result</h5>
|
||
<div class="simulation-summary">
|
||
<span class="sim-risk risk-${approval.simulation_result.risk_level.toLowerCase()}">Risk: ${approval.simulation_result.risk_level}</span>
|
||
<span class="sim-confidence">Confidence: ${Math.round(approval.simulation_result.confidence * 100)}%</span>
|
||
</div>
|
||
</div>
|
||
`
|
||
: ""
|
||
}
|
||
|
||
<div class="approval-meta">
|
||
<span>Step: ${approval.step_name || "N/A"}</span>
|
||
<span>Expires: ${formatRelativeTime(approval.expires_at)}</span>
|
||
<span>Default: ${approval.default_action}</span>
|
||
</div>
|
||
|
||
<div class="approval-actions">
|
||
<button class="btn-reject" onclick="rejectApproval('${taskId}', '${approval.id}')">
|
||
<span>❌</span> Reject
|
||
</button>
|
||
<button class="btn-defer" onclick="deferApproval('${taskId}', '${approval.id}')">
|
||
<span>⏸️</span> Defer
|
||
</button>
|
||
<button class="btn-approve" onclick="approveApproval('${taskId}', '${approval.id}')">
|
||
<span>✅</span> Approve
|
||
</button>
|
||
</div>
|
||
</div>
|
||
`;
|
||
});
|
||
|
||
html += "</div>";
|
||
container.innerHTML = html;
|
||
}
|
||
|
||
function approveApproval(taskId, approvalId) {
|
||
submitApprovalDecision(taskId, approvalId, "approve");
|
||
}
|
||
|
||
function rejectApproval(taskId, approvalId) {
|
||
if (!confirm("Are you sure you want to reject this action?")) {
|
||
return;
|
||
}
|
||
submitApprovalDecision(taskId, approvalId, "reject");
|
||
}
|
||
|
||
function deferApproval(taskId, approvalId) {
|
||
submitApprovalDecision(taskId, approvalId, "defer");
|
||
}
|
||
|
||
function submitApprovalDecision(taskId, approvalId, action) {
|
||
fetch(`/api/autotask/${taskId}/approve`, {
|
||
method: "POST",
|
||
headers: {
|
||
"Content-Type": "application/json",
|
||
},
|
||
body: JSON.stringify({
|
||
approval_id: approvalId,
|
||
action: action,
|
||
}),
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
const messages = {
|
||
approve: "Approval granted",
|
||
reject: "Approval rejected",
|
||
defer: "Approval deferred",
|
||
};
|
||
showToast(messages[action], "success");
|
||
closeApprovalModal();
|
||
refreshTasks();
|
||
} else {
|
||
showToast(`Failed to ${action}: ${result.error}`, "error");
|
||
}
|
||
});
|
||
}
|
||
|
||
function showApprovalNotification(approval) {
|
||
showToast(`Approval required: ${approval.title}`, "warning", 10000);
|
||
updateStats();
|
||
}
|
||
|
||
// =============================================================================
|
||
// SIMULATION
|
||
// =============================================================================
|
||
|
||
function renderSimulationResult(result) {
|
||
const container = document.getElementById("simulation-content");
|
||
|
||
const statusIcon = result.success ? "✅" : "⚠️";
|
||
const statusText = result.success
|
||
? "Simulation Successful"
|
||
: "Simulation Found Issues";
|
||
|
||
let html = `
|
||
<div class="simulation-result">
|
||
<div class="simulation-header">
|
||
<div class="simulation-status status-${result.success}">
|
||
<span class="status-icon">${statusIcon}</span>
|
||
<span class="status-text">${statusText}</span>
|
||
</div>
|
||
<div class="simulation-confidence">
|
||
Confidence: ${Math.round(result.confidence * 100)}%
|
||
</div>
|
||
</div>
|
||
|
||
<div class="impact-overview">
|
||
<h4>Impact Assessment</h4>
|
||
<div class="impact-grid">
|
||
<div class="impact-card">
|
||
<span class="impact-icon">💾</span>
|
||
<span class="impact-label">Data Impact</span>
|
||
<span class="impact-value">${result.impact.data_impact.records_modified} records modified</span>
|
||
</div>
|
||
<div class="impact-card">
|
||
<span class="impact-icon">💰</span>
|
||
<span class="impact-label">Cost Impact</span>
|
||
<span class="impact-value">$${result.impact.cost_impact.total_estimated_cost.toFixed(2)}</span>
|
||
</div>
|
||
<div class="impact-card">
|
||
<span class="impact-icon">⏱️</span>
|
||
<span class="impact-label">Time Impact</span>
|
||
<span class="impact-value">${formatDuration(result.impact.time_impact.estimated_duration_seconds)}</span>
|
||
</div>
|
||
<div class="impact-card risk-${result.impact.security_impact.risk_level.toLowerCase()}">
|
||
<span class="impact-icon">🔒</span>
|
||
<span class="impact-label">Security Impact</span>
|
||
<span class="impact-value">${result.impact.security_impact.risk_level}</span>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
|
||
<div class="step-outcomes">
|
||
<h4>Step-by-Step Predictions</h4>
|
||
<div class="outcomes-list">
|
||
${result.step_outcomes
|
||
.map(
|
||
(step) => `
|
||
<div class="outcome-item ${step.would_succeed ? "success" : "warning"}">
|
||
<span class="outcome-icon">${step.would_succeed ? "✅" : "⚠️"}</span>
|
||
<span class="outcome-name">${step.step_name}</span>
|
||
<span class="outcome-probability">${Math.round(step.success_probability * 100)}% success</span>
|
||
</div>
|
||
`,
|
||
)
|
||
.join("")}
|
||
</div>
|
||
</div>
|
||
|
||
${
|
||
result.side_effects.length > 0
|
||
? `
|
||
<div class="side-effects">
|
||
<h4>⚠️ Potential Side Effects</h4>
|
||
<div class="side-effects-list">
|
||
${result.side_effects
|
||
.map(
|
||
(effect) => `
|
||
<div class="side-effect-item severity-${effect.severity.toLowerCase()}">
|
||
<span class="effect-description">${effect.description}</span>
|
||
${effect.mitigation ? `<span class="effect-mitigation">Mitigation: ${effect.mitigation}</span>` : ""}
|
||
</div>
|
||
`,
|
||
)
|
||
.join("")}
|
||
</div>
|
||
</div>
|
||
`
|
||
: ""
|
||
}
|
||
|
||
${
|
||
result.recommendations.length > 0
|
||
? `
|
||
<div class="recommendations">
|
||
<h4>💡 Recommendations</h4>
|
||
<div class="recommendations-list">
|
||
${result.recommendations
|
||
.map(
|
||
(rec) => `
|
||
<div class="recommendation-item">
|
||
<span class="rec-description">${rec.description}</span>
|
||
${rec.action ? `<button class="btn-apply-rec" onclick="applyRecommendation('${rec.id}')">${rec.action}</button>` : ""}
|
||
</div>
|
||
`,
|
||
)
|
||
.join("")}
|
||
</div>
|
||
</div>
|
||
`
|
||
: ""
|
||
}
|
||
|
||
<div class="simulation-actions">
|
||
<button class="btn-secondary" onclick="closeSimulationModal()">
|
||
<span>↩️</span> Back
|
||
</button>
|
||
<button class="btn-primary" onclick="proceedAfterSimulation('${result.task_id}')" ${result.impact.risk_score > 0.8 ? "disabled" : ""}>
|
||
<span>🚀</span> Proceed with Execution
|
||
</button>
|
||
</div>
|
||
</div>
|
||
`;
|
||
|
||
container.innerHTML = html;
|
||
}
|
||
|
||
// =============================================================================
|
||
// MODAL FUNCTIONS
|
||
// =============================================================================
|
||
|
||
function showSimulationModal() {
|
||
const modal = document.getElementById("simulation-modal");
|
||
if (modal) {
|
||
modal.style.display = "flex";
|
||
document.body.classList.add("modal-open");
|
||
// Show loading state
|
||
document.getElementById("simulation-content").innerHTML = `
|
||
<div class="loading-state">
|
||
<div class="spinner"></div>
|
||
<p>Running impact simulation...</p>
|
||
</div>
|
||
`;
|
||
}
|
||
}
|
||
|
||
function closeSimulationModal() {
|
||
const modal = document.getElementById("simulation-modal");
|
||
if (modal) {
|
||
modal.style.display = "none";
|
||
document.body.classList.remove("modal-open");
|
||
}
|
||
}
|
||
|
||
function showDecisionModal() {
|
||
const modal = document.getElementById("decision-modal");
|
||
if (modal) {
|
||
modal.style.display = "flex";
|
||
document.body.classList.add("modal-open");
|
||
// Show loading state
|
||
document.getElementById("decision-content").innerHTML = `
|
||
<div class="loading-state">
|
||
<div class="spinner"></div>
|
||
<p>Loading decisions...</p>
|
||
</div>
|
||
`;
|
||
}
|
||
}
|
||
|
||
function closeDecisionModal() {
|
||
const modal = document.getElementById("decision-modal");
|
||
if (modal) {
|
||
modal.style.display = "none";
|
||
document.body.classList.remove("modal-open");
|
||
}
|
||
}
|
||
|
||
function showApprovalModal() {
|
||
const modal = document.getElementById("approval-modal");
|
||
if (modal) {
|
||
modal.style.display = "flex";
|
||
document.body.classList.add("modal-open");
|
||
// Show loading state
|
||
document.getElementById("approval-content").innerHTML = `
|
||
<div class="loading-state">
|
||
<div class="spinner"></div>
|
||
<p>Loading approvals...</p>
|
||
</div>
|
||
`;
|
||
}
|
||
}
|
||
|
||
function closeApprovalModal() {
|
||
const modal = document.getElementById("approval-modal");
|
||
if (modal) {
|
||
modal.style.display = "none";
|
||
document.body.classList.remove("modal-open");
|
||
}
|
||
}
|
||
|
||
function closeAllModals() {
|
||
closeSimulationModal();
|
||
closeDecisionModal();
|
||
closeApprovalModal();
|
||
}
|
||
|
||
// =============================================================================
|
||
// SIMULATION ACTIONS
|
||
// =============================================================================
|
||
|
||
function proceedAfterSimulation(taskId) {
|
||
closeSimulationModal();
|
||
|
||
if (!taskId) {
|
||
showToast("No task ID provided", "error");
|
||
return;
|
||
}
|
||
|
||
fetch(`/api/autotask/${taskId}/execute`, {
|
||
method: "POST",
|
||
headers: {
|
||
"Content-Type": "application/json",
|
||
},
|
||
body: JSON.stringify({
|
||
confirmed: true,
|
||
}),
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast("Task execution started!", "success");
|
||
refreshTasks();
|
||
} else {
|
||
showToast(result.error || "Failed to start execution", "error");
|
||
}
|
||
})
|
||
.catch((error) => {
|
||
console.error("Failed to proceed after simulation:", error);
|
||
showToast("Failed to start execution", "error");
|
||
});
|
||
}
|
||
|
||
function applyRecommendation(recId) {
|
||
fetch(`/api/autotask/recommendations/${recId}/apply`, {
|
||
method: "POST",
|
||
})
|
||
.then((response) => response.json())
|
||
.then((result) => {
|
||
if (result.success) {
|
||
showToast("Recommendation applied", "success");
|
||
// Re-run simulation to show updated results
|
||
const taskId =
|
||
document.querySelector(".simulation-result")?.dataset?.taskId;
|
||
if (taskId) {
|
||
simulateTask(taskId);
|
||
}
|
||
} else {
|
||
showToast(result.error || "Failed to apply recommendation", "error");
|
||
}
|
||
})
|
||
.catch((error) => {
|
||
console.error("Failed to apply recommendation:", error);
|
||
showToast("Failed to apply recommendation", "error");
|
||
});
|
||
}
|
||
|
||
// =============================================================================
|
||
// TOAST NOTIFICATIONS
|
||
// =============================================================================
|
||
|
||
function showToast(message, type = "info") {
|
||
// Get or create toast container
|
||
let container = document.getElementById("toast-container");
|
||
if (!container) {
|
||
container = document.createElement("div");
|
||
container.id = "toast-container";
|
||
container.className = "toast-container";
|
||
document.body.appendChild(container);
|
||
}
|
||
|
||
// Create toast element
|
||
const toast = document.createElement("div");
|
||
toast.className = `toast toast-${type}`;
|
||
|
||
const icons = {
|
||
success: "✅",
|
||
error: "❌",
|
||
warning: "⚠️",
|
||
info: "ℹ️",
|
||
};
|
||
|
||
toast.innerHTML = `
|
||
<span class="toast-icon">${icons[type] || icons.info}</span>
|
||
<span class="toast-message">${message}</span>
|
||
<button class="toast-close" onclick="this.parentElement.remove()">×</button>
|
||
`;
|
||
|
||
container.appendChild(toast);
|
||
|
||
// Auto-remove after 5 seconds
|
||
setTimeout(() => {
|
||
toast.classList.add("toast-fade-out");
|
||
setTimeout(() => {
|
||
toast.remove();
|
||
}, 300);
|
||
}, 5000);
|
||
}
|
||
|
||
// =============================================================================
|
||
// UTILITY FUNCTIONS
|
||
// =============================================================================
|
||
|
||
function formatDuration(seconds) {
|
||
if (seconds < 60) {
|
||
return `${Math.round(seconds)}s`;
|
||
} else if (seconds < 3600) {
|
||
const minutes = Math.floor(seconds / 60);
|
||
const secs = Math.round(seconds % 60);
|
||
return `${minutes}m ${secs}s`;
|
||
} else {
|
||
const hours = Math.floor(seconds / 3600);
|
||
const minutes = Math.floor((seconds % 3600) / 60);
|
||
return `${hours}h ${minutes}m`;
|
||
}
|
||
}
|
||
|
||
function formatRelativeTime(dateString) {
|
||
if (!dateString) return "N/A";
|
||
|
||
const date = new Date(dateString);
|
||
const now = new Date();
|
||
const diffMs = date - now;
|
||
const diffSeconds = Math.floor(diffMs / 1000);
|
||
const diffMinutes = Math.floor(diffSeconds / 60);
|
||
const diffHours = Math.floor(diffMinutes / 60);
|
||
const diffDays = Math.floor(diffHours / 24);
|
||
|
||
if (diffMs < 0) {
|
||
// Past
|
||
const absDays = Math.abs(diffDays);
|
||
const absHours = Math.abs(diffHours);
|
||
const absMinutes = Math.abs(diffMinutes);
|
||
|
||
if (absDays > 0) return `${absDays}d ago`;
|
||
if (absHours > 0) return `${absHours}h ago`;
|
||
if (absMinutes > 0) return `${absMinutes}m ago`;
|
||
return "just now";
|
||
} else {
|
||
// Future
|
||
if (diffDays > 0) return `in ${diffDays}d`;
|
||
if (diffHours > 0) return `in ${diffHours}h`;
|
||
if (diffMinutes > 0) return `in ${diffMinutes}m`;
|
||
return "soon";
|
||
}
|
||
}
|
||
|
||
// =============================================================================
|
||
// TASK LIFECYCLE HANDLERS
|
||
// =============================================================================
|
||
|
||
function onTaskCompleted(task) {
|
||
showToast(`Task completed: ${task.title || task.id}`, "success");
|
||
updateTaskInList(task);
|
||
updateStats();
|
||
}
|
||
|
||
function onTaskFailed(task, error) {
|
||
showToast(`Task failed: ${task.title || task.id} - ${error}`, "error");
|
||
updateTaskInList(task);
|
||
updateStats();
|
||
}
|
||
|
||
function highlightPendingItems() {
|
||
// Highlight tasks requiring attention
|
||
document.querySelectorAll(".autotask-item").forEach((item) => {
|
||
const status = item.dataset.status;
|
||
if (status === "pending-approval" || status === "pending-decision") {
|
||
item.classList.add("attention-required");
|
||
} else {
|
||
item.classList.remove("attention-required");
|
||
}
|
||
});
|
||
}
|
||
|
||
function loadExecutionLogs(taskId) {
|
||
const logContainer = document.querySelector(
|
||
`[data-task-id="${taskId}"] .log-entries`,
|
||
);
|
||
if (!logContainer || logContainer.dataset.loaded === "true") {
|
||
return;
|
||
}
|
||
|
||
logContainer.innerHTML = `
|
||
<div class="loading-state">
|
||
<div class="spinner"></div>
|
||
<p>Loading logs...</p>
|
||
</div>
|
||
`;
|
||
|
||
fetch(`/api/autotask/${taskId}/logs`)
|
||
.then((response) => response.json())
|
||
.then((logs) => {
|
||
if (!logs || logs.length === 0) {
|
||
logContainer.innerHTML =
|
||
"<p class='no-logs'>No execution logs yet.</p>";
|
||
} else {
|
||
logContainer.innerHTML = logs
|
||
.map(
|
||
(log) => `
|
||
<div class="log-entry log-${log.level.toLowerCase()}">
|
||
<span class="log-time">${new Date(log.timestamp).toLocaleTimeString()}</span>
|
||
<span class="log-level">${log.level}</span>
|
||
<span class="log-message">${log.message}</span>
|
||
</div>
|
||
`,
|
||
)
|
||
.join("");
|
||
}
|
||
logContainer.dataset.loaded = "true";
|
||
})
|
||
.catch((error) => {
|
||
logContainer.innerHTML = `
|
||
<div class="error-message">
|
||
<span class="error-icon">❌</span>
|
||
<p>Failed to load logs: ${error.message}</p>
|
||
</div>
|
||
`;
|
||
});
|
||
}
|