Files
cameleer-server/ui/src/pages/Exchanges/ExchangeHeader.tsx

135 lines
6.1 KiB
TypeScript
Raw Normal View History

import { useMemo } from 'react';
import { useNavigate } from 'react-router';
import { GitBranch, Server } from 'lucide-react';
import { StatusDot, MonoText, Badge } from '@cameleer/design-system';
import { useCorrelationChain } from '../../api/queries/correlation';
import { useAgents } from '../../api/queries/agents';
import type { ExecutionDetail } from '../../components/ExecutionDiagram/types';
import styles from './ExchangeHeader.module.css';
interface ExchangeHeaderProps {
detail: ExecutionDetail;
onCorrelatedSelect?: (executionId: string, applicationName: string, routeId: string) => void;
}
type StatusVariant = 'success' | 'error' | 'running' | 'warning';
function statusVariant(s: string): StatusVariant {
switch (s) {
case 'COMPLETED': return 'success';
case 'FAILED': return 'error';
case 'RUNNING': return 'running';
default: return 'warning';
}
}
function statusLabel(s: string): string {
switch (s) {
case 'COMPLETED': return 'OK';
case 'FAILED': return 'ERR';
case 'RUNNING': return 'RUN';
default: return s;
}
}
function formatDuration(ms: number): string {
if (ms >= 60_000) return `${(ms / 1000).toFixed(0)}s`;
if (ms >= 1000) return `${(ms / 1000).toFixed(2)}s`;
return `${ms}ms`;
}
export function ExchangeHeader({ detail, onCorrelatedSelect }: ExchangeHeaderProps) {
const navigate = useNavigate();
const { data: chainResult } = useCorrelationChain(detail.correlationId ?? null);
const chain = chainResult?.data;
const showChain = chain && chain.length > 1;
const attrs = Object.entries(detail.attributes ?? {});
// Look up agent state for icon coloring
const { data: agents } = useAgents(undefined, detail.applicationName);
const agentState = useMemo(() => {
if (!agents || !detail.agentId) return undefined;
const agent = (agents as any[]).find((a: any) => a.id === detail.agentId);
return agent?.state?.toLowerCase() as 'live' | 'stale' | 'dead' | undefined;
}, [agents, detail.agentId]);
return (
<div className={styles.header}>
{/* Exchange info — always shown */}
<div className={styles.info}>
<StatusDot variant={statusVariant(detail.status)} />
<Badge label={statusLabel(detail.status)} color={statusVariant(detail.status)} />
{attrs.length > 0 && (
<>
<span className={styles.separator} />
{attrs.map(([k, v]) => (
<Badge key={k} label={`${k}: ${v}`} color="auto" />
))}
</>
)}
<span className={styles.separator} />
<button className={styles.linkBtn} onClick={() => navigate(`/exchanges/${detail.applicationName}`)} title="Show all exchanges for this application">
<span className={styles.app}>{detail.applicationName}</span>
</button>
<button className={styles.linkBtn} onClick={() => navigate(`/exchanges/${detail.applicationName}/${detail.routeId}`)} title="Show all exchanges for this route">
<span className={styles.route}>{detail.routeId}</span>
<GitBranch size={12} className={styles.icon} />
</button>
{detail.agentId && (
<>
<span className={styles.separator} />
<button className={styles.linkBtn} onClick={() => navigate(`/runtime/${detail.applicationName}`)} title="All agents for this application">
<span className={styles.app}>{detail.applicationName}</span>
</button>
<button className={styles.linkBtn} onClick={() => navigate(`/runtime/${detail.applicationName}/${detail.agentId}`)} title="Agent details">
<MonoText size="xs">{detail.agentId}</MonoText>
<Server size={12} className={agentState === 'live' ? styles.iconLive : agentState === 'stale' ? styles.iconStale : agentState === 'dead' ? styles.iconDead : styles.icon} />
</button>
</>
)}
<span className={styles.duration}>{formatDuration(detail.durationMs)}</span>
</div>
{/* Correlation chain */}
<div className={styles.chain}>
<span className={styles.chainLabel}>Correlated</span>
{showChain ? chain.map((ce: any, i: number) => {
const isCurrent = ce.executionId === detail.executionId;
const variant = statusVariant(ce.status);
const statusCls =
variant === 'success' ? styles.chainNodeSuccess
: variant === 'error' ? styles.chainNodeError
: variant === 'running' ? styles.chainNodeRunning
: styles.chainNodeWarning;
return (
<span key={ce.executionId} className={styles.chainEntry}>
{i > 0 && <span className={styles.chainArrow}>&rarr;</span>}
<button
className={`${styles.chainNode} ${statusCls} ${isCurrent ? styles.chainNodeCurrent : ''}`}
onClick={() => {
if (!isCurrent && onCorrelatedSelect) {
onCorrelatedSelect(ce.executionId, ce.applicationName ?? detail.applicationName, ce.routeId);
}
}}
title={`${ce.executionId}\n${ce.routeId} \u2014 ${formatDuration(ce.durationMs)}`}
>
<StatusDot variant={variant} />
<span className={styles.chainRoute}>{ce.routeId}</span>
<span className={styles.chainDuration}>{formatDuration(ce.durationMs)}</span>
</button>
</span>
);
}) : (
<span className={styles.chainNone}>no correlated exchanges found</span>
)}
{showChain && (() => {
const starts = chain.map((ce: any) => new Date(ce.startTime).getTime()).filter((t: number) => !isNaN(t));
const ends = chain.map((ce: any) => new Date(ce.endTime ?? ce.startTime).getTime() + (ce.durationMs ?? 0)).filter((t: number) => !isNaN(t));
const totalMs = starts.length > 0 && ends.length > 0 ? Math.max(...ends) - Math.min(...starts) : 0;
return totalMs > 0 ? <span className={styles.chainTotal}>{formatDuration(totalMs)}</span> : null;
})()}
</div>
</div>
);
}