migrate frontend

This commit is contained in:
ryan
2026-06-18 17:26:57 +08:00
parent d7fe4ef8be
commit a9fd0bd128
53 changed files with 4765 additions and 19 deletions
@@ -0,0 +1,170 @@
'use client';
import {useState} from 'react';
import {useQuery} from '@tanstack/react-query';
import {ExternalLink, Loader2} from 'lucide-react';
import {Button} from '@/components/ui/button';
import {
Dialog,
DialogContent,
DialogDescription,
DialogFooter,
DialogHeader,
DialogTitle,
} from '@/components/ui/dialog';
import {formatDateTime} from '@/lib/utils';
import type {NodeAgentReleaseInfo, NodeItem, ReleaseChannel} from '@/lib/services/openflare';
import {NodeService} from '@/lib/services/openflare';
import {NodeStatusBadge} from './node-status-badge';
import {formatRelativeTime, getErrorMessage} from './node-utils';
export function AgentUpdateDialog({
open,
node,
submitting,
onClose,
onConfirm,
}: {
open: boolean;
node: NodeItem;
submitting: boolean;
onClose: () => void;
onConfirm: (release: NodeAgentReleaseInfo | null, channel: ReleaseChannel) => Promise<void>;
}) {
const [channel, setChannel] = useState<ReleaseChannel>('stable');
const releaseQuery = useQuery({
queryKey: ['openflare', 'node-agent-release', node.id, channel],
queryFn: () => NodeService.getAgentRelease(node.id, channel),
enabled: open,
});
const release = releaseQuery.data ?? null;
return (
<Dialog open={open} onOpenChange={(next) => !next && onClose()}>
<DialogContent className="sm:max-w-xl">
<DialogHeader>
<DialogTitle>Agent 升级</DialogTitle>
<DialogDescription>
检查 GitHub 发布并向节点下发升级指令,节点将在下一次心跳后执行。
</DialogDescription>
</DialogHeader>
<div className="space-y-4">
<div className="grid gap-3 sm:grid-cols-3">
<div className="rounded-lg border p-3">
<p className="text-xs text-muted-foreground">当前版本</p>
<p className="mt-1 text-sm font-medium">{node.version || 'unknown'}</p>
</div>
<div className="rounded-lg border p-3">
<p className="text-xs text-muted-foreground">检查通道</p>
<p className="mt-1 text-sm font-medium">
{channel === 'preview' ? '预览版' : '正式版'}
</p>
</div>
<div className="rounded-lg border p-3">
<p className="text-xs text-muted-foreground">更新状态</p>
<div className="mt-1">
<NodeStatusBadge
label={
node.update_requested
? node.update_channel === 'preview'
? '等待预览更新'
: '等待更新'
: '未下发'
}
tone={node.update_requested ? 'warning' : 'info'}
/>
</div>
</div>
</div>
{releaseQuery.isFetching ? (
<div className="flex items-center justify-center py-8 text-sm text-muted-foreground">
<Loader2 className="size-4 mr-2 animate-spin" />
检查发布版本中...
</div>
) : releaseQuery.isError ? (
<p className="text-sm text-destructive">{getErrorMessage(releaseQuery.error)}</p>
) : release ? (
<div className="space-y-3 rounded-lg border p-4">
<div className="flex flex-wrap items-center gap-2">
<NodeStatusBadge
label={release.has_update ? '发现可升级版本' : '当前已是最新版本'}
tone={release.has_update ? 'warning' : 'success'}
/>
{release.prerelease ? (
<NodeStatusBadge label="Preview 发布" tone="warning" />
) : (
<NodeStatusBadge label="正式发布" tone="info" />
)}
</div>
<div className="grid gap-3 sm:grid-cols-2 text-sm">
<div>
<p className="text-xs text-muted-foreground">目标版本</p>
<p className="mt-1 font-medium">{release.tag_name || '未找到'}</p>
</div>
<div>
<p className="text-xs text-muted-foreground">发布时间</p>
<p className="mt-1">
{release.published_at
? `${formatRelativeTime(release.published_at)} · ${formatDateTime(release.published_at)}`
: '—'}
</p>
</div>
</div>
<p className="text-sm text-muted-foreground whitespace-pre-wrap">
{release.body || '暂无更新说明'}
</p>
{release.html_url ? (
<a
href={release.html_url}
target="_blank"
rel="noreferrer"
className="inline-flex items-center text-sm text-primary hover:underline"
>
查看发布详情
<ExternalLink className="size-3 ml-1" />
</a>
) : null}
</div>
) : null}
</div>
<DialogFooter className="gap-2 sm:gap-0">
<Button
type="button"
variant="outline"
disabled={submitting || releaseQuery.isFetching}
onClick={() => setChannel('stable')}
>
检查正式版
</Button>
<Button
type="button"
variant="outline"
disabled={submitting || releaseQuery.isFetching}
onClick={() => setChannel('preview')}
>
检查预览版
</Button>
<Button
type="button"
disabled={
submitting ||
releaseQuery.isFetching ||
!release?.has_update ||
node.update_requested
}
onClick={() => void onConfirm(release, channel)}
>
{submitting ? '下发中...' : channel === 'preview' ? '升级到预览版' : '升级到正式版'}
</Button>
</DialogFooter>
</DialogContent>
</Dialog>
);
}
@@ -0,0 +1,394 @@
'use client';
import Link from 'next/link';
import {useRouter} from 'next/navigation';
import {useMutation, useQuery, useQueryClient} from '@tanstack/react-query';
import {useState} from 'react';
import {ArrowLeft, FileText, Loader2, RefreshCw, RotateCcw, Trash2, Upload,} from 'lucide-react';
import {toast} from 'sonner';
import {
AlertDialog,
AlertDialogAction,
AlertDialogCancel,
AlertDialogContent,
AlertDialogDescription,
AlertDialogFooter,
AlertDialogHeader,
AlertDialogTitle,
} from '@/components/ui/alert-dialog';
import {Button} from '@/components/ui/button';
import {Card, CardContent, CardDescription, CardHeader, CardTitle,} from '@/components/ui/card';
import {formatDateTime} from '@/lib/utils';
import type {NodeAgentReleaseInfo, NodeItem, ReleaseChannel} from '@/lib/services/openflare';
import {NodeService} from '@/lib/services/openflare';
import {AgentUpdateDialog} from './agent-update-dialog';
import {NodeEditorDialog} from './node-editor-dialog';
import {NodeStatusBadge} from './node-status-badge';
import {
formatRelativeTime,
getApplyLabel,
getApplyTone,
getErrorMessage,
getNodeStatusLabel,
getNodeStatusTone,
getOpenrestyStatusLabel,
getOpenrestyStatusTone,
isMeaningfulTime,
} from './node-utils';
const nodesQueryKey = ['openflare', 'nodes'];
export function EdgeNodeDetail({ node }: { node: NodeItem }) {
const router = useRouter();
const queryClient = useQueryClient();
const [editorOpen, setEditorOpen] = useState(false);
const [upgradeOpen, setUpgradeOpen] = useState(false);
const [deleteOpen, setDeleteOpen] = useState(false);
const observabilityQuery = useQuery({
queryKey: ['openflare', 'node-observability', node.id],
queryFn: () => NodeService.getObservability(node.id, { hours: 24, limit: 48 }),
refetchInterval: 10000,
});
const saveMutation = useMutation({
mutationFn: (payload: Parameters<typeof NodeService.updateNode>[1]) =>
NodeService.updateNode(node.id, payload),
onSuccess: async () => {
toast.success('节点已更新');
setEditorOpen(false);
await queryClient.invalidateQueries({ queryKey: nodesQueryKey });
},
onError: (error) => toast.error(getErrorMessage(error)),
});
const forceSyncMutation = useMutation({
mutationFn: () => NodeService.requestForceSync(node.id),
onSuccess: async (updated) => {
toast.success(`已向节点 ${updated.name} 下发强制同步指令`);
await queryClient.invalidateQueries({ queryKey: nodesQueryKey });
},
onError: (error) => toast.error(getErrorMessage(error)),
});
const restartMutation = useMutation({
mutationFn: () => NodeService.requestOpenrestyRestart(node.id),
onSuccess: async (updated) => {
toast.success(`已向节点 ${updated.name} 下发 OpenResty 重启指令`);
await queryClient.invalidateQueries({ queryKey: nodesQueryKey });
},
onError: (error) => toast.error(getErrorMessage(error)),
});
const upgradeMutation = useMutation({
mutationFn: ({
release,
channel,
}: {
release: NodeAgentReleaseInfo | null;
channel: ReleaseChannel;
}) =>
NodeService.requestAgentUpdate(node.id, {
channel: release?.channel ?? channel,
tag_name: release?.channel === 'preview' ? release.tag_name || undefined : undefined,
}),
onSuccess: async (updated) => {
toast.success(
`已向节点 ${updated.name} 下发${updated.update_channel === 'preview' ? '预览版' : '正式版'}升级指令`,
);
setUpgradeOpen(false);
await queryClient.invalidateQueries({ queryKey: nodesQueryKey });
},
onError: (error) => toast.error(getErrorMessage(error)),
});
const deleteMutation = useMutation({
mutationFn: () => NodeService.deleteNode(node.id),
onSuccess: async () => {
toast.success('节点已删除');
await queryClient.invalidateQueries({ queryKey: nodesQueryKey });
router.push('/openflare/nodes');
},
onError: (error) => toast.error(getErrorMessage(error)),
});
const profile = observabilityQuery.data?.profile ?? null;
const latestMetric = observabilityQuery.data?.metric_snapshots?.[0] ?? null;
const activeHealthEvents =
observabilityQuery.data?.health_events.filter((event) => event.status === 'active') ?? [];
const handleRefresh = () => {
void Promise.all([
queryClient.invalidateQueries({ queryKey: nodesQueryKey }),
queryClient.invalidateQueries({ queryKey: ['openflare', 'node-observability', node.id] }),
]);
};
const isRefreshing = observabilityQuery.isFetching;
return (
<div className="py-6 px-1 space-y-6">
<div className="flex flex-wrap items-center justify-between gap-3">
<div className="flex items-center gap-2">
<Button variant="ghost" size="sm" className="h-8 px-2" asChild>
<Link href="/openflare/nodes">
<ArrowLeft className="size-4" />
</Link>
</Button>
<h1 className="text-2xl font-semibold tracking-tight">{node.name}</h1>
<NodeStatusBadge
label={getNodeStatusLabel(node.status)}
tone={getNodeStatusTone(node.status)}
/>
</div>
<div className="flex flex-wrap items-center gap-2">
<Button variant="outline" size="sm" className="h-7 text-xs" onClick={() => setEditorOpen(true)}>
编辑
</Button>
<Button
variant="outline"
size="sm"
className="h-7 text-xs"
onClick={handleRefresh}
disabled={isRefreshing}
>
{isRefreshing ? (
<Loader2 className="size-3.5 mr-1 animate-spin" />
) : (
<RefreshCw className="size-3.5 mr-1" />
)}
刷新
</Button>
<Button
variant="outline"
size="sm"
className="h-7 text-xs"
disabled={forceSyncMutation.isPending}
onClick={() => forceSyncMutation.mutate()}
>
<RotateCcw className="size-3.5 mr-1" />
{forceSyncMutation.isPending ? '同步中...' : '强制同步'}
</Button>
<Button
variant="outline"
size="sm"
className="h-7 text-xs"
disabled={restartMutation.isPending}
onClick={() => restartMutation.mutate()}
>
{restartMutation.isPending ? '下发中...' : '重启 OpenResty'}
</Button>
<Button
variant="secondary"
size="sm"
className="h-7 text-xs"
onClick={() => setUpgradeOpen(true)}
>
<Upload className="size-3.5 mr-1" />
{node.update_requested ? '查看升级' : '升级 Agent'}
</Button>
<Button
variant="outline"
size="sm"
className="h-7 text-xs text-destructive hover:text-destructive"
onClick={() => setDeleteOpen(true)}
>
<Trash2 className="size-3.5 mr-1" />
删除
</Button>
</div>
</div>
<div className="grid gap-4 md:grid-cols-2 xl:grid-cols-4">
<Card className="border-dashed shadow-none">
<CardHeader className="pb-2">
<CardDescription>节点 ID</CardDescription>
<CardTitle className="text-sm font-medium break-all">{node.node_id}</CardTitle>
</CardHeader>
</Card>
<Card className="border-dashed shadow-none">
<CardHeader className="pb-2">
<CardDescription>Agent 版本</CardDescription>
<CardTitle className="text-sm font-medium">{node.version || 'unknown'}</CardTitle>
</CardHeader>
</Card>
<Card className="border-dashed shadow-none">
<CardHeader className="pb-2">
<CardDescription>当前配置版本</CardDescription>
<CardTitle className="text-sm font-medium">{node.current_version || '未应用'}</CardTitle>
</CardHeader>
</Card>
<Card className="border-dashed shadow-none">
<CardHeader className="pb-2">
<CardDescription>最近心跳</CardDescription>
<CardTitle className="text-sm font-medium">
{isMeaningfulTime(node.last_seen_at)
? formatRelativeTime(node.last_seen_at)
: '暂无'}
</CardTitle>
</CardHeader>
</Card>
</div>
<div className="grid gap-6 xl:grid-cols-2">
<Card className="border-dashed shadow-none">
<CardHeader>
<CardTitle className="text-base font-semibold">基本信息</CardTitle>
<CardDescription>边缘代理节点 (edge_node)</CardDescription>
</CardHeader>
<CardContent className="space-y-3 text-sm">
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">运行状态</span>
<NodeStatusBadge
label={getNodeStatusLabel(node.status)}
tone={getNodeStatusTone(node.status)}
/>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">OpenResty 健康</span>
<NodeStatusBadge
label={getOpenrestyStatusLabel(node.openresty_status)}
tone={getOpenrestyStatusTone(node.openresty_status)}
/>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">最近应用</span>
<NodeStatusBadge
label={getApplyLabel(node.latest_apply_result)}
tone={getApplyTone(node.latest_apply_result)}
/>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">IP 地址</span>
<span>
{node.ip || '—'}
{node.ip_manual_override ? '(已锁定)' : ''}
</span>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">地图点位</span>
<span>{node.geo_name || '未配置'}</span>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">创建时间</span>
<span>{formatDateTime(node.created_at)}</span>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">更新时间</span>
<span>{formatDateTime(node.updated_at)}</span>
</div>
{node.last_error ? (
<div className="rounded-lg border border-destructive/20 bg-destructive/5 p-3 text-destructive">
{node.last_error}
</div>
) : null}
</CardContent>
</Card>
<Card className="border-dashed shadow-none">
<CardHeader className="flex-row items-center justify-between space-y-0">
<div>
<CardTitle className="text-base font-semibold">运行快照</CardTitle>
<CardDescription>来自 observability 接口的最近上报</CardDescription>
</div>
<Button variant="outline" size="sm" className="h-7 text-xs" asChild>
<Link href={`/openflare/apply-logs?node_id=${encodeURIComponent(node.node_id)}`}>
<FileText className="size-3.5 mr-1" />
应用记录
</Link>
</Button>
</CardHeader>
<CardContent className="space-y-3 text-sm">
{observabilityQuery.isLoading ? (
<div className="flex items-center text-muted-foreground py-6 justify-center">
<Loader2 className="size-4 mr-2 animate-spin" />
加载运行快照中...
</div>
) : observabilityQuery.isError ? (
<p className="text-destructive">{getErrorMessage(observabilityQuery.error)}</p>
) : (
<>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">活动健康事件</span>
<span>{activeHealthEvents.length}</span>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">主机名</span>
<span>{profile?.hostname || '—'}</span>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">操作系统</span>
<span>
{profile
? `${profile.os_name || 'unknown'} ${profile.os_version || ''}`.trim()
: '—'}
</span>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">CPU 使用率</span>
<span>
{latestMetric ? `${latestMetric.cpu_usage_percent.toFixed(1)}%` : '—'}
</span>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">OpenResty 连接数</span>
<span>{latestMetric?.openresty_connections ?? '—'}</span>
</div>
<div className="flex items-center justify-between gap-3">
<span className="text-muted-foreground">OpenResty 状态消息</span>
<span className="text-right max-w-[60%] break-words">
{node.openresty_message || '无'}
</span>
</div>
</>
)}
</CardContent>
</Card>
</div>
<NodeEditorDialog
open={editorOpen}
node={node}
submitting={saveMutation.isPending}
onClose={() => setEditorOpen(false)}
onSubmit={async (payload) => {
await saveMutation.mutateAsync(payload);
}}
/>
<AgentUpdateDialog
open={upgradeOpen}
node={node}
submitting={upgradeMutation.isPending}
onClose={() => setUpgradeOpen(false)}
onConfirm={async (release, channel) => {
await upgradeMutation.mutateAsync({ release, channel });
}}
/>
<AlertDialog open={deleteOpen} onOpenChange={setDeleteOpen}>
<AlertDialogContent>
<AlertDialogHeader>
<AlertDialogTitle>确认删除节点</AlertDialogTitle>
<AlertDialogDescription>
确认删除节点「{node.name}」吗?删除后该节点需要重新创建并重新接入。
</AlertDialogDescription>
</AlertDialogHeader>
<AlertDialogFooter>
<AlertDialogCancel disabled={deleteMutation.isPending}>取消</AlertDialogCancel>
<AlertDialogAction
className="bg-destructive text-white hover:bg-destructive/90"
disabled={deleteMutation.isPending}
onClick={() => deleteMutation.mutate()}
>
{deleteMutation.isPending ? '删除中...' : '确认删除'}
</AlertDialogAction>
</AlertDialogFooter>
</AlertDialogContent>
</AlertDialog>
</div>
);
}
@@ -0,0 +1,302 @@
'use client';
import {useEffect, useState} from 'react';
import {Button} from '@/components/ui/button';
import {
Dialog,
DialogContent,
DialogDescription,
DialogFooter,
DialogHeader,
DialogTitle,
} from '@/components/ui/dialog';
import {Input} from '@/components/ui/input';
import {Label} from '@/components/ui/label';
import {Select, SelectContent, SelectItem, SelectTrigger, SelectValue,} from '@/components/ui/select';
import {Switch} from '@/components/ui/switch';
import type {NodeItem, NodeMutationPayload, NodeType} from '@/lib/services/openflare';
type FormState = {
node_type: NodeType;
name: string;
ip: string;
ip_manual_override: boolean;
auto_update_enabled: boolean;
geo_manual_override: boolean;
geo_name: string;
geo_latitude: string;
geo_longitude: string;
relay_bind_port: string;
relay_vhost_http_port: string;
};
const defaultForm: FormState = {
node_type: 'edge_node',
name: '',
ip: '',
ip_manual_override: false,
auto_update_enabled: false,
geo_manual_override: false,
geo_name: '',
geo_latitude: '',
geo_longitude: '',
relay_bind_port: '7000',
relay_vhost_http_port: '8080',
};
function buildFormState(node?: NodeItem | null): FormState {
if (!node) return defaultForm;
return {
node_type: node.node_type,
name: node.name,
ip: node.ip,
ip_manual_override: node.ip_manual_override,
auto_update_enabled: node.auto_update_enabled,
geo_manual_override: node.geo_manual_override,
geo_name: node.geo_name,
geo_latitude:
node.geo_latitude === undefined || node.geo_latitude === null
? ''
: String(node.geo_latitude),
geo_longitude:
node.geo_longitude === undefined || node.geo_longitude === null
? ''
: String(node.geo_longitude),
relay_bind_port: String(node.relay_bind_port || 7000),
relay_vhost_http_port: String(node.relay_vhost_http_port || 8080),
};
}
function toPayload(form: FormState): NodeMutationPayload {
const base: NodeMutationPayload = {
node_type: form.node_type,
name: form.name.trim(),
ip: form.ip.trim(),
ip_manual_override: form.ip_manual_override,
auto_update_enabled: form.auto_update_enabled,
geo_manual_override: form.geo_manual_override,
geo_name: form.geo_manual_override ? form.geo_name.trim() : '',
geo_latitude: form.geo_manual_override && form.geo_latitude
? Number(form.geo_latitude)
: null,
geo_longitude: form.geo_manual_override && form.geo_longitude
? Number(form.geo_longitude)
: null,
};
if (form.node_type === 'tunnel_relay') {
return {
...base,
relay_bind_port: Number(form.relay_bind_port),
relay_vhost_http_port: Number(form.relay_vhost_http_port),
relay_web_server_enabled: true,
};
}
return base;
}
export function NodeEditorDialog({
open,
node,
submitting,
onClose,
onSubmit,
}: {
open: boolean;
node: NodeItem | null;
submitting: boolean;
onClose: () => void;
onSubmit: (payload: NodeMutationPayload) => Promise<void>;
}) {
const [form, setForm] = useState<FormState>(defaultForm);
const [error, setError] = useState('');
useEffect(() => {
if (open) {
setForm(buildFormState(node));
setError('');
}
}, [open, node]);
const handleSubmit = async (event: React.FormEvent) => {
event.preventDefault();
if (!form.name.trim()) {
setError('请输入节点名称');
return;
}
if (form.ip_manual_override && !form.ip.trim()) {
setError('锁定 IP 时必须填写节点 IP');
return;
}
setError('');
await onSubmit(toPayload(form));
};
return (
<Dialog open={open} onOpenChange={(next) => !next && onClose()}>
<DialogContent className="sm:max-w-lg">
<DialogHeader>
<DialogTitle>{node ? '编辑节点' : '新增节点'}</DialogTitle>
<DialogDescription>
预创建节点后可在详情页查看专属 Token 与部署命令。
</DialogDescription>
</DialogHeader>
<form onSubmit={(event) => void handleSubmit(event)} className="space-y-4">
<div className="space-y-2">
<Label>节点类型</Label>
<Select
value={form.node_type}
disabled={Boolean(node)}
onValueChange={(value) =>
setForm((prev) => ({ ...prev, node_type: value as NodeType }))
}
>
<SelectTrigger>
<SelectValue />
</SelectTrigger>
<SelectContent>
<SelectItem value="edge_node">Edge 节点</SelectItem>
<SelectItem value="tunnel_relay">Relay 节点</SelectItem>
<SelectItem value="tunnel_client">Tunnel 节点</SelectItem>
</SelectContent>
</Select>
</div>
<div className="space-y-2">
<Label htmlFor="node-name">节点名称</Label>
<Input
id="node-name"
value={form.name}
onChange={(event) => setForm((prev) => ({ ...prev, name: event.target.value }))}
placeholder="例如 edge-hk-01"
/>
</div>
<div className="space-y-2">
<Label htmlFor="node-ip">节点 IP</Label>
<Input
id="node-ip"
value={form.ip}
onChange={(event) => setForm((prev) => ({ ...prev, ip: event.target.value }))}
placeholder="可选,接入后自动上报"
/>
</div>
<div className="flex items-center justify-between rounded-lg border px-3 py-2">
<div>
<p className="text-sm font-medium">锁定 IP</p>
<p className="text-xs text-muted-foreground">启用后管理端不再自动覆盖 IP</p>
</div>
<Switch
checked={form.ip_manual_override}
onCheckedChange={(checked) =>
setForm((prev) => ({ ...prev, ip_manual_override: checked }))
}
/>
</div>
<div className="flex items-center justify-between rounded-lg border px-3 py-2">
<div>
<p className="text-sm font-medium">自动更新 Agent</p>
<p className="text-xs text-muted-foreground">启用后节点将自动拉取正式版更新</p>
</div>
<Switch
checked={form.auto_update_enabled}
onCheckedChange={(checked) =>
setForm((prev) => ({ ...prev, auto_update_enabled: checked }))
}
/>
</div>
{form.node_type === 'tunnel_relay' ? (
<div className="grid gap-3 sm:grid-cols-2">
<div className="space-y-2">
<Label htmlFor="relay-bind-port">绑定端口</Label>
<Input
id="relay-bind-port"
value={form.relay_bind_port}
onChange={(event) =>
setForm((prev) => ({ ...prev, relay_bind_port: event.target.value }))
}
/>
</div>
<div className="space-y-2">
<Label htmlFor="relay-vhost-port">VHost 端口</Label>
<Input
id="relay-vhost-port"
value={form.relay_vhost_http_port}
onChange={(event) =>
setForm((prev) => ({ ...prev, relay_vhost_http_port: event.target.value }))
}
/>
</div>
</div>
) : null}
<div className="flex items-center justify-between rounded-lg border px-3 py-2">
<div>
<p className="text-sm font-medium">手动地图点位</p>
<p className="text-xs text-muted-foreground">用于总览地图展示</p>
</div>
<Switch
checked={form.geo_manual_override}
onCheckedChange={(checked) =>
setForm((prev) => ({ ...prev, geo_manual_override: checked }))
}
/>
</div>
{form.geo_manual_override ? (
<div className="grid gap-3 sm:grid-cols-3">
<div className="space-y-2 sm:col-span-3">
<Label htmlFor="geo-name">位置名称</Label>
<Input
id="geo-name"
value={form.geo_name}
onChange={(event) =>
setForm((prev) => ({ ...prev, geo_name: event.target.value }))
}
/>
</div>
<div className="space-y-2">
<Label htmlFor="geo-lat">纬度</Label>
<Input
id="geo-lat"
value={form.geo_latitude}
onChange={(event) =>
setForm((prev) => ({ ...prev, geo_latitude: event.target.value }))
}
/>
</div>
<div className="space-y-2 sm:col-span-2">
<Label htmlFor="geo-lng">经度</Label>
<Input
id="geo-lng"
value={form.geo_longitude}
onChange={(event) =>
setForm((prev) => ({ ...prev, geo_longitude: event.target.value }))
}
/>
</div>
</div>
) : null}
{error ? <p className="text-sm text-destructive">{error}</p> : null}
<DialogFooter>
<Button type="button" variant="outline" onClick={onClose} disabled={submitting}>
取消
</Button>
<Button type="submit" disabled={submitting}>
{submitting ? '保存中...' : node ? '保存修改' : '新增节点'}
</Button>
</DialogFooter>
</form>
</DialogContent>
</Dialog>
);
}
@@ -0,0 +1,30 @@
import {Badge} from '@/components/ui/badge';
import {cn} from '@/lib/utils';
import type {StatusTone} from './node-utils';
const toneClassName: Record<StatusTone, string> = {
success: 'bg-emerald-500/10 border-emerald-500/20 text-emerald-600',
warning: 'bg-amber-500/10 border-amber-500/20 text-amber-600',
danger: 'bg-destructive/10 border-destructive/20 text-destructive',
info: 'bg-blue-500/10 border-blue-500/20 text-blue-600',
};
export function NodeStatusBadge({
label,
tone,
className,
}: {
label: string;
tone: StatusTone;
className?: string;
}) {
return (
<Badge
variant="outline"
className={cn('text-[10px] rounded-full py-0 px-2 font-medium', toneClassName[tone], className)}
>
{label}
</Badge>
);
}
@@ -0,0 +1,78 @@
'use client';
import Link from 'next/link';
import {useSearchParams} from 'next/navigation';
import {cn} from '@/lib/utils';
export type NodeFilter = 'all' | 'edge' | 'relay' | 'tunnel';
const filters: Array<{ key: NodeFilter; label: string; href: string }> = [
{ key: 'all', label: '全部节点', href: '/openflare/nodes' },
{ key: 'edge', label: 'Edge', href: '/openflare/nodes?filter=edge' },
{ key: 'relay', label: 'Relay', href: '/openflare/nodes?filter=relay' },
{ key: 'tunnel', label: 'Tunnel', href: '/openflare/nodes?filter=tunnel' },
];
export function getNodeFilter(searchParams: URLSearchParams): NodeFilter {
const current = searchParams.get('filter')?.trim().toLowerCase() ?? '';
if (current === 'relay' || current === 'tunnel' || current === 'edge' || current === 'all') {
return current;
}
return 'all';
}
export function filterNodesByType<T extends { node_type: string }>(
nodes: T[],
filter: NodeFilter,
): T[] {
switch (filter) {
case 'relay':
return nodes.filter((node) => node.node_type === 'tunnel_relay');
case 'tunnel':
return nodes.filter((node) => node.node_type === 'tunnel_client');
case 'edge':
return nodes.filter((node) => node.node_type === 'edge_node');
case 'all':
default:
return nodes;
}
}
export function getFilterDescription(filter: NodeFilter) {
switch (filter) {
case 'relay':
return '当前仅展示 Relay 节点。';
case 'tunnel':
return '当前仅展示 Tunnel 节点。';
case 'edge':
return '当前仅展示 Edge 节点。';
case 'all':
default:
return '当前展示全部节点。';
}
}
export function NodeTypeFilter() {
const searchParams = useSearchParams();
const activeFilter = getNodeFilter(searchParams);
return (
<div className="flex flex-wrap gap-2">
{filters.map((item) => (
<Link
key={item.key}
href={item.href}
className={cn(
'inline-flex items-center rounded-full border px-3 py-1.5 text-xs transition',
activeFilter === item.key
? 'border-foreground/30 bg-accent text-foreground'
: 'border-border text-muted-foreground hover:bg-muted/50',
)}
>
{item.label}
</Link>
))}
</div>
);
}
@@ -0,0 +1,98 @@
import type {ApplyResult, NodeItem, NodeStatus, OpenrestyStatus} from '@/lib/services/openflare';
export const WS_CONNECTED_LAST_SEEN = '__OPENFLARE_WS_CONNECTED__';
export const FLARED_WS_CONNECTED_LAST_SEEN = '__OPENFLARE_FLARED_WS_CONNECTED__';
export type StatusTone = 'success' | 'warning' | 'danger' | 'info';
export function isWSConnectedLastSeen(value: string | null | undefined) {
return value === WS_CONNECTED_LAST_SEEN || value === FLARED_WS_CONNECTED_LAST_SEEN;
}
export function isMeaningfulTime(value: string | null | undefined) {
return (
Boolean(value) &&
!isWSConnectedLastSeen(value) &&
!String(value).startsWith('0001-01-01')
);
}
export function formatRelativeTime(value: string) {
const date = new Date(value);
if (Number.isNaN(date.getTime())) {
return value;
}
const diffMs = Date.now() - date.getTime();
const diffMinutes = Math.floor(diffMs / 60_000);
if (diffMinutes < 1) return '刚刚';
if (diffMinutes < 60) return `${diffMinutes} 分钟前`;
const diffHours = Math.floor(diffMinutes / 60);
if (diffHours < 24) return `${diffHours} 小时前`;
const diffDays = Math.floor(diffHours / 24);
if (diffDays < 30) return `${diffDays} 天前`;
return `${Math.floor(diffDays / 30)} 个月前`;
}
export function getNodeStatusTone(status: NodeStatus): StatusTone {
if (status === 'online') return 'success';
if (status === 'pending') return 'warning';
return 'danger';
}
export function getNodeStatusLabel(status: NodeStatus) {
if (status === 'online') return '在线';
if (status === 'pending') return '待接入';
return '离线';
}
export function getApplyTone(result: ApplyResult): StatusTone {
if (result === 'success') return 'success';
if (result === 'warning') return 'warning';
if (result === 'failed') return 'danger';
return 'warning';
}
export function getApplyLabel(result: ApplyResult) {
if (result === 'success') return '成功';
if (result === 'warning') return '警告';
if (result === 'failed') return '失败';
return '暂无';
}
export function getOpenrestyStatusTone(status: OpenrestyStatus): StatusTone {
if (status === 'healthy') return 'success';
if (status === 'unhealthy') return 'danger';
return 'warning';
}
export function getOpenrestyStatusLabel(status: OpenrestyStatus) {
if (status === 'healthy') return '健康';
if (status === 'unhealthy') return '异常';
return '未知';
}
export function getRelayStatusTone(status: string | null | undefined): StatusTone {
if (status === 'healthy') return 'success';
if (status === 'unhealthy') return 'danger';
return 'warning';
}
export function getRelayStatusLabel(status: string | null | undefined) {
if (status === 'healthy') return '健康';
if (status === 'unhealthy') return '异常';
return '未知';
}
export function getNodeTypeLabel(nodeType: NodeItem['node_type']) {
if (nodeType === 'tunnel_relay') return 'Relay';
if (nodeType === 'tunnel_client') return 'Tunnel';
return 'Edge';
}
export function getErrorMessage(error: unknown) {
return error instanceof Error ? error.message : '请求失败,请稍后重试。';
}
@@ -0,0 +1,151 @@
'use client';
import Link from 'next/link';
import {Pencil, Trash2} from 'lucide-react';
import {Button} from '@/components/ui/button';
import {Table, TableBody, TableCell, TableHead, TableHeader, TableRow,} from '@/components/ui/table';
import {formatDateTime} from '@/lib/utils';
import type {NodeItem} from '@/lib/services/openflare';
import {NodeStatusBadge} from './node-status-badge';
import {
formatRelativeTime,
getApplyLabel,
getApplyTone,
getNodeStatusLabel,
getNodeStatusTone,
getNodeTypeLabel,
getOpenrestyStatusLabel,
getOpenrestyStatusTone,
getRelayStatusLabel,
getRelayStatusTone,
isMeaningfulTime,
isWSConnectedLastSeen,
} from './node-utils';
export function NodesTable({
nodes,
deletingId,
onEdit,
onDelete,
}: {
nodes: NodeItem[];
deletingId: number | null;
onEdit: (node: NodeItem) => void;
onDelete: (node: NodeItem) => void;
}) {
return (
<div className="border border-dashed rounded-lg overflow-hidden">
<Table>
<TableHeader>
<TableRow className="border-dashed hover:bg-transparent">
<TableHead className="py-2 h-8">节点</TableHead>
<TableHead className="py-2 h-8">状态</TableHead>
<TableHead className="py-2 h-8">Version</TableHead>
<TableHead className="py-2 h-8">运行健康</TableHead>
<TableHead className="py-2 h-8">当前版本</TableHead>
<TableHead className="py-2 h-8">最近应用</TableHead>
<TableHead className="py-2 h-8">最近心跳</TableHead>
<TableHead className="py-2 h-8 text-right">操作</TableHead>
</TableRow>
</TableHeader>
<TableBody>
{nodes.map((node) => (
<TableRow key={node.id} className="border-dashed align-top">
<TableCell className="py-3">
<div className="space-y-1">
<div className="flex items-center gap-2">
<p className="font-medium">{node.name}</p>
<NodeStatusBadge label={getNodeTypeLabel(node.node_type)} tone="info" />
</div>
<p className="text-xs text-muted-foreground">
IP:{node.ip || '—'}
{node.ip_manual_override ? '(已锁定)' : ''}
</p>
<p className="text-xs text-muted-foreground">
位置:{node.geo_name || '未配置地图点位'}
</p>
</div>
</TableCell>
<TableCell className="py-3">
<NodeStatusBadge
label={getNodeStatusLabel(node.status)}
tone={getNodeStatusTone(node.status)}
/>
</TableCell>
<TableCell className="py-3 text-muted-foreground">
{node.version || 'unknown'}
</TableCell>
<TableCell className="py-3">
{node.node_type === 'tunnel_relay' ? (
<NodeStatusBadge
label={getRelayStatusLabel(node.relay_status)}
tone={getRelayStatusTone(node.relay_status)}
/>
) : node.node_type === 'tunnel_client' ? (
<NodeStatusBadge
label={node.status === 'online' ? '运行中' : '未知'}
tone={node.status === 'online' ? 'success' : 'warning'}
/>
) : (
<NodeStatusBadge
label={getOpenrestyStatusLabel(node.openresty_status)}
tone={getOpenrestyStatusTone(node.openresty_status)}
/>
)}
</TableCell>
<TableCell className="py-3 text-muted-foreground">
{node.current_version ||
(node.node_type === 'tunnel_relay' ? '实时配置' : '未应用')}
</TableCell>
<TableCell className="py-3">
{node.node_type === 'tunnel_relay' ? (
<span className="text-sm text-muted-foreground">—</span>
) : (
<NodeStatusBadge
label={getApplyLabel(node.latest_apply_result)}
tone={getApplyTone(node.latest_apply_result)}
/>
)}
</TableCell>
<TableCell className="py-3 text-muted-foreground">
{isWSConnectedLastSeen(node.last_seen_at)
? 'WS 已连接'
: isMeaningfulTime(node.last_seen_at)
? `${formatRelativeTime(node.last_seen_at)} · ${formatDateTime(node.last_seen_at)}`
: '暂无'}
</TableCell>
<TableCell className="py-3">
<div className="flex flex-wrap justify-end gap-1">
<Button variant="outline" size="sm" className="h-7 text-xs" asChild>
<Link href={`/openflare/nodes/detail?id=${node.id}`}>详情</Link>
</Button>
<Button
variant="outline"
size="sm"
className="h-7 text-xs"
onClick={() => onEdit(node)}
>
<Pencil className="size-3 mr-1" />
编辑
</Button>
<Button
variant="outline"
size="sm"
className="h-7 text-xs text-destructive hover:text-destructive"
disabled={deletingId === node.id}
onClick={() => onDelete(node)}
>
<Trash2 className="size-3 mr-1" />
删除
</Button>
</div>
</TableCell>
</TableRow>
))}
</TableBody>
</Table>
</div>
);
}