128 lines
4.9 KiB
TypeScript
128 lines
4.9 KiB
TypeScript
|
|
import { useMemo } from 'react';
|
||
|
|
import { useParams } from 'react-router';
|
||
|
|
import {
|
||
|
|
StatCard, StatusDot, Badge, MonoText, Card,
|
||
|
|
LineChart, AreaChart, EventFeed, Breadcrumb, Spinner,
|
||
|
|
SectionHeader, CodeBlock,
|
||
|
|
} from '@cameleer/design-system';
|
||
|
|
import { useAgents, useAgentEvents } from '../../api/queries/agents';
|
||
|
|
import { useStatsTimeseries } from '../../api/queries/executions';
|
||
|
|
import { useGlobalFilters } from '@cameleer/design-system';
|
||
|
|
|
||
|
|
export default function AgentInstance() {
|
||
|
|
const { appId, instanceId } = useParams();
|
||
|
|
const { timeRange } = useGlobalFilters();
|
||
|
|
const timeFrom = timeRange.start.toISOString();
|
||
|
|
const timeTo = timeRange.end.toISOString();
|
||
|
|
|
||
|
|
const { data: agents, isLoading } = useAgents(undefined, appId);
|
||
|
|
const { data: events } = useAgentEvents(appId, instanceId);
|
||
|
|
const { data: timeseries } = useStatsTimeseries(timeFrom, timeTo, undefined, appId);
|
||
|
|
|
||
|
|
const agent = useMemo(() =>
|
||
|
|
(agents || []).find((a: any) => a.id === instanceId),
|
||
|
|
[agents, instanceId],
|
||
|
|
);
|
||
|
|
|
||
|
|
const chartData = useMemo(() =>
|
||
|
|
(timeseries?.buckets || []).map((b: any) => ({
|
||
|
|
time: new Date(b.timestamp).toLocaleTimeString([], { hour: '2-digit', minute: '2-digit' }),
|
||
|
|
throughput: b.totalCount,
|
||
|
|
latency: b.avgDurationMs,
|
||
|
|
errors: b.failedCount,
|
||
|
|
})),
|
||
|
|
[timeseries],
|
||
|
|
);
|
||
|
|
|
||
|
|
const feedEvents = useMemo(() =>
|
||
|
|
(events || []).filter((e: any) => !instanceId || e.agentId === instanceId).map((e: any) => ({
|
||
|
|
id: String(e.id),
|
||
|
|
severity: e.eventType === 'WENT_DEAD' ? 'error' as const
|
||
|
|
: e.eventType === 'WENT_STALE' ? 'warning' as const
|
||
|
|
: e.eventType === 'RECOVERED' ? 'success' as const
|
||
|
|
: 'running' as const,
|
||
|
|
message: `${e.eventType}${e.detail ? ' — ' + e.detail : ''}`,
|
||
|
|
timestamp: new Date(e.timestamp),
|
||
|
|
})),
|
||
|
|
[events, instanceId],
|
||
|
|
);
|
||
|
|
|
||
|
|
if (isLoading) return <Spinner size="lg" />;
|
||
|
|
|
||
|
|
return (
|
||
|
|
<div>
|
||
|
|
<Breadcrumb items={[
|
||
|
|
{ label: 'Agents', href: '/agents' },
|
||
|
|
{ label: appId || '', href: `/agents/${appId}` },
|
||
|
|
{ label: agent?.name || instanceId || '' },
|
||
|
|
]} />
|
||
|
|
|
||
|
|
{agent && (
|
||
|
|
<>
|
||
|
|
<div style={{ display: 'flex', alignItems: 'center', gap: '0.75rem', margin: '1rem 0' }}>
|
||
|
|
<StatusDot variant={agent.status === 'LIVE' ? 'live' : agent.status === 'STALE' ? 'stale' : 'dead'} />
|
||
|
|
<h2>{agent.name}</h2>
|
||
|
|
<Badge label={agent.status} color={agent.status === 'LIVE' ? 'success' : agent.status === 'STALE' ? 'warning' : 'error'} />
|
||
|
|
</div>
|
||
|
|
|
||
|
|
<div style={{ display: 'flex', gap: '1rem', marginBottom: '1.5rem', flexWrap: 'wrap' }}>
|
||
|
|
<StatCard label="TPS" value={agent.tps?.toFixed(1) ?? '0'} />
|
||
|
|
<StatCard label="Error Rate" value={agent.errorRate ? `${(agent.errorRate * 100).toFixed(1)}%` : '0%'} accent={agent.errorRate > 0.05 ? 'error' : undefined} />
|
||
|
|
<StatCard label="Active Routes" value={`${agent.activeRoutes ?? 0}/${agent.totalRoutes ?? 0}`} />
|
||
|
|
<StatCard label="Uptime" value={formatUptime(agent.uptimeSeconds ?? 0)} />
|
||
|
|
</div>
|
||
|
|
|
||
|
|
<SectionHeader>Routes</SectionHeader>
|
||
|
|
<div style={{ display: 'flex', gap: '0.5rem', flexWrap: 'wrap', marginBottom: '1.5rem' }}>
|
||
|
|
{(agent.routeIds || []).map((r: string) => (
|
||
|
|
<Badge key={r} label={r} color="auto" />
|
||
|
|
))}
|
||
|
|
</div>
|
||
|
|
</>
|
||
|
|
)}
|
||
|
|
|
||
|
|
{chartData.length > 0 && (
|
||
|
|
<>
|
||
|
|
<SectionHeader>Performance</SectionHeader>
|
||
|
|
<div style={{ display: 'grid', gridTemplateColumns: '1fr 1fr', gap: '1rem', marginBottom: '1.5rem' }}>
|
||
|
|
<AreaChart series={[{ label: 'Throughput', data: chartData.map((d: any, i: number) => ({ x: i, y: d.throughput })) }]} height={200} />
|
||
|
|
<LineChart series={[{ label: 'Latency', data: chartData.map((d: any, i: number) => ({ x: i, y: d.latency })) }]} height={200} />
|
||
|
|
</div>
|
||
|
|
</>
|
||
|
|
)}
|
||
|
|
|
||
|
|
{feedEvents.length > 0 && (
|
||
|
|
<>
|
||
|
|
<SectionHeader>Events</SectionHeader>
|
||
|
|
<EventFeed events={feedEvents} maxItems={50} />
|
||
|
|
</>
|
||
|
|
)}
|
||
|
|
|
||
|
|
{agent && (
|
||
|
|
<>
|
||
|
|
<SectionHeader>Agent Info</SectionHeader>
|
||
|
|
<Card>
|
||
|
|
<div style={{ padding: '1rem' }}>
|
||
|
|
<CodeBlock content={JSON.stringify({
|
||
|
|
id: agent.id,
|
||
|
|
name: agent.name,
|
||
|
|
group: agent.group,
|
||
|
|
registeredAt: agent.registeredAt,
|
||
|
|
lastHeartbeat: agent.lastHeartbeat,
|
||
|
|
routeIds: agent.routeIds,
|
||
|
|
}, null, 2)} />
|
||
|
|
</div>
|
||
|
|
</Card>
|
||
|
|
</>
|
||
|
|
)}
|
||
|
|
</div>
|
||
|
|
);
|
||
|
|
}
|
||
|
|
|
||
|
|
function formatUptime(seconds: number): string {
|
||
|
|
if (seconds < 60) return `${seconds}s`;
|
||
|
|
if (seconds < 3600) return `${Math.floor(seconds / 60)}m`;
|
||
|
|
if (seconds < 86400) return `${Math.floor(seconds / 3600)}h ${Math.floor((seconds % 3600) / 60)}m`;
|
||
|
|
return `${Math.floor(seconds / 86400)}d ${Math.floor((seconds % 86400) / 3600)}h`;
|
||
|
|
}
|