import React, { useState, useEffect } from 'react';
import './App.css';
const App = () => {
const [tasks, setTasks] = useState([]);
const [selectedTask, setSelectedTask] = useState(null);
const [showForm, setShowForm] = useState(false);
const [formData, setFormData] = useState({
name: '',
description: '',
prompt: '',
schedule_type: 'manual',
schedule_value: '',
enabled: true
});
const [systemInfo, setSystemInfo] = useState(null);
const [usageStats, setUsageStats] = useState(null);
const [authStatus, setAuthStatus] = useState(null);
const [mcpServers, setMcpServers] = useState(null);
const [showAddMcp, setShowAddMcp] = useState(false);
const [mcpForm, setMcpForm] = useState({ name: '', server_type: 'sse', url: '', command: '' });
const [loading, setLoading] = useState(false);
const [activeView, setActiveView] = useState('tasks'); // 'tasks' | 'dashboard'
// Fetch tasks on component mount
useEffect(() => {
fetchTasks();
fetchSystemInfo();
fetchUsageStats();
fetchAuthStatus();
fetchMcpServers();
const interval = setInterval(() => {
fetchTasks();
fetchSystemInfo();
fetchUsageStats();
fetchAuthStatus();
fetchMcpServers();
}, 10000);
return () => clearInterval(interval);
}, []);
const fetchTasks = async () => {
try {
const response = await fetch('/api/tasks');
const data = await response.json();
setTasks(data);
} catch (error) {
console.error('Error fetching tasks:', error);
}
};
const fetchSystemInfo = async () => {
try {
const response = await fetch('/api/system/info');
const data = await response.json();
setSystemInfo(data);
} catch (error) {
console.error('Error fetching system info:', error);
}
};
const fetchUsageStats = async () => {
try {
const response = await fetch('/api/system/usage');
const data = await response.json();
setUsageStats(data);
} catch (error) {
console.error('Error fetching usage stats:', error);
}
};
const fetchAuthStatus = async () => {
try {
const response = await fetch('/api/auth/status');
const data = await response.json();
setAuthStatus(data);
} catch (error) {
console.error('Error fetching auth status:', error);
}
};
const [loginLoading, setLoginLoading] = useState(false);
const handleLogin = async () => {
setLoginLoading(true);
try {
const response = await fetch('/api/auth/login', { method: 'POST' });
const data = await response.json();
setAuthStatus(prev => ({ ...prev, ...data }));
if (data.auth_url) {
window.open(data.auth_url, '_blank');
} else if (data.status === 'error') {
alert(data.message || 'Login failed. Check container logs.');
}
} catch (error) {
console.error('Error initiating login:', error);
alert('Failed to connect to auth endpoint');
}
setLoginLoading(false);
};
const handleLogout = async () => {
try {
await fetch('/api/auth/logout', { method: 'POST' });
fetchAuthStatus();
} catch (error) {
console.error('Error logging out:', error);
}
};
const fetchMcpServers = async () => {
try {
const response = await fetch('/api/mcp/servers');
const data = await response.json();
setMcpServers(data);
} catch (error) {
console.error('Error fetching MCP servers:', error);
}
};
const handleAddMcp = async (e) => {
e.preventDefault();
try {
const response = await fetch('/api/mcp/servers', {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify(mcpForm)
});
const data = await response.json();
if (data.status === 'ok') {
setShowAddMcp(false);
setMcpForm({ name: '', server_type: 'sse', url: '', command: '' });
fetchMcpServers();
} else {
alert(data.message || 'Failed to add MCP server');
}
} catch (error) {
console.error('Error adding MCP server:', error);
}
};
const handleRemoveMcp = async (name) => {
if (!confirm(`Remove MCP server "${name}"?`)) return;
try {
await fetch(`/api/mcp/servers/${name}`, { method: 'DELETE' });
fetchMcpServers();
} catch (error) {
console.error('Error removing MCP server:', error);
}
};
const handleCreateTask = async (e) => {
e.preventDefault();
setLoading(true);
try {
const response = await fetch('/api/tasks', {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify(formData)
});
if (response.ok) {
await fetchTasks();
setShowForm(false);
setFormData({
name: '',
description: '',
prompt: '',
schedule_type: 'manual',
schedule_value: '',
enabled: true
});
}
} catch (error) {
console.error('Error creating task:', error);
}
setLoading(false);
};
const handleRunTask = async (taskId) => {
try {
const response = await fetch(`/api/tasks/${taskId}/run`, {
method: 'POST'
});
const data = await response.json();
console.log('Task started:', data);
await fetchTasks();
} catch (error) {
console.error('Error running task:', error);
}
};
const handleDeleteTask = async (taskId) => {
if (confirm('Delete this task?')) {
try {
await fetch(`/api/tasks/${taskId}`, { method: 'DELETE' });
await fetchTasks();
setSelectedTask(null);
} catch (error) {
console.error('Error deleting task:', error);
}
}
};
const getStatusColor = (status) => {
switch (status) {
case 'running': return '#3498db';
case 'completed': return '#27ae60';
case 'failed': return '#e74c3c';
default: return '#95a5a6';
}
};
return (
{activeView === 'dashboard' && (
System Dashboard
{systemInfo && (
<>
📋
{systemInfo.task_count}
Total Tasks
✅
{systemInfo.completed_runs || 0}
Completed Runs
❌
{systemInfo.failed_runs || 0}
Failed Runs
⚡
{systemInfo.running_runs || 0}
Currently Running
🔄
{systemInfo.total_runs || 0}
Total Runs Ever
{systemInfo.scheduler_running ? '🟢' : '🔴'}
{systemInfo.scheduler_running ? 'Active' : 'Stopped'}
Scheduler
>
)}
Claude Authentication
{authStatus?.status === 'logged_in' ? (
✅
Connected to Claude Max
{authStatus.account}
) : authStatus?.status === 'pending' ? (
) : (
🔐
Not logged in
Log in with your Claude Max account to run tasks
)}
MCP Servers
{mcpServers?.servers?.length > 0 ? (
{mcpServers.servers.map((srv, i) => (
{srv.name || srv}
{srv.details || srv.url || srv.type || ''}
))}
) : (
No MCP servers configured.
{mcpServers?.raw &&
{mcpServers.raw}}
)}
{showAddMcp ? (
) : (
)}
Claude API Usage
{usageStats ? (
<>
Claude Runs (all time)
{usageStats.claude_runs_total ?? '—'}
Active Sessions
{usageStats.session_count ?? '—'}
First Run
{usageStats.first_run ? new Date(usageStats.first_run).toLocaleString() : '—'}
Last Run
{usageStats.last_run ? new Date(usageStats.last_run).toLocaleString() : '—'}
🔄 Next Monthly Reset
{usageStats.next_reset ? new Date(usageStats.next_reset).toLocaleDateString() : '—'}
⏳ Days Until Reset
{usageStats.days_until_reset ?? '—'}
{usageStats.note && (
{usageStats.note}
)}
>
) : (
Loading usage stats…
)}
Task Breakdown
{tasks.length === 0 ? (
No tasks yet. Create one in the Tasks view.
) : (
tasks.map(t => (
{t.name}
{t.schedule_type}
{t.status}
{t.last_run ? new Date(t.last_run).toLocaleString() : 'never'}
))
)}
)}
{activeView === 'tasks' && (<>
{showForm ? (
) : selectedTask ? (
{selectedTask.name}
Status:
{selectedTask.status}
Schedule:
{selectedTask.schedule_type === 'manual'
? 'Manual'
: `${selectedTask.schedule_type}: ${selectedTask.schedule_value}`}
Created:
{new Date(selectedTask.created_at).toLocaleString()}
{selectedTask.last_run && (
Last Run:
{new Date(selectedTask.last_run).toLocaleString()}
)}
{selectedTask.description && (
Description
{selectedTask.description}
)}
Prompt
{selectedTask.prompt}
) : (
Select a task to view details
Or create a new one to get started
)}
>)} {/* end activeView === 'tasks' */}
);
};
const TaskRuns = ({ taskId }) => {
const [runs, setRuns] = useState([]);
useEffect(() => {
const fetchRuns = async () => {
try {
const response = await fetch(`/api/tasks/${taskId}/runs`);
const data = await response.json();
setRuns(data);
} catch (error) {
console.error('Error fetching runs:', error);
}
};
fetchRuns();
const interval = setInterval(fetchRuns, 3000);
return () => clearInterval(interval);
}, [taskId]);
return (
Run History
{runs.length === 0 ? (
No runs yet
) : (
{runs.map((run) => (
{run.status}
{new Date(run.started_at).toLocaleString()}
{run.output && (
Output
{run.output}
)}
{run.error && (
Error
{run.error}
)}
))}
)}
);
};
export default App;