'use client';
import { ProTable, ProTableActions } from '@/components/pro-table';
import {
createServer,
deleteServer,
filterServerList,
resetSortWithServer,
updateServer,
} from '@/services/admin/server';
import { useNode } from '@/store/node';
import { useServer } from '@/store/server';
import { Badge } from '@workspace/ui/components/badge';
import { Button } from '@workspace/ui/components/button';
import { ConfirmButton } from '@workspace/ui/custom-components/confirm-button';
import { cn } from '@workspace/ui/lib/utils';
import { useTranslations } from 'next-intl';
import { useRef, useState } from 'react';
import { toast } from 'sonner';
import DynamicMultiplier from './dynamic-multiplier';
import OnlineUsersCell from './online-users-cell';
import ServerConfig from './server-config';
import ServerForm from './server-form';
import ServerInstall from './server-install';
function PctBar({ value }: { value: number }) {
const v = value.toFixed(2);
return (
);
}
function RegionIpCell({
country,
city,
ip,
t,
}: {
country?: string;
city?: string;
ip?: string;
t: (key: string) => string;
}) {
const region = [country, city].filter(Boolean).join(' / ') || t('notAvailable');
return (
{region}
{ip || t('notAvailable')}
);
}
export default function ServersPage() {
const t = useTranslations('servers');
const { isServerReferencedByNodes } = useNode();
const { fetchServers } = useServer();
const [loading, setLoading] = useState(false);
const ref = useRef(null);
return (
action={ref}
header={{
title: t('pageTitle'),
toolbar: (
{
setLoading(true);
try {
await createServer(values as unknown as API.CreateServerRequest);
toast.success(t('created'));
ref.current?.refresh();
fetchServers();
setLoading(false);
return true;
} catch (e) {
setLoading(false);
return false;
}
}}
/>
),
}}
columns={[
{
accessorKey: 'id',
header: t('id'),
cell: ({ row }) => {row.getValue('id')},
},
{ accessorKey: 'name', header: t('name') },
{
id: 'region_ip',
header: t('address'),
cell: ({ row }) => (
),
},
{
accessorKey: 'protocols',
header: t('protocols'),
cell: ({ row }) => {
const list = row.original.protocols.filter((p) => p.enable) as API.Protocol[];
if (!list.length) return '—';
return (
{list.map((p, idx) => {
const ratio = Number(p.ratio ?? 1) || 1;
return (
{ratio.toFixed(2)}x
{p.type}
{p.port}
);
})}
);
},
},
{
id: 'status',
header: t('status'),
cell: ({ row }) => {
const offline = row.original.status.status === 'offline';
return (
{offline ? t('offline') : t('online')}
);
},
},
{
id: 'cpu',
header: t('cpu'),
cell: ({ row }) => (
),
},
{
id: 'mem',
header: t('memory'),
cell: ({ row }) => (
),
},
{
id: 'disk',
header: t('disk'),
cell: ({ row }) => (
),
},
{
id: 'online_users',
header: t('onlineUsers'),
cell: ({ row }) => ,
},
// traffic ratio moved to per-protocol configs; column removed
]}
params={[{ key: 'search' }]}
request={async (pagination, filter) => {
const { data } = await filterServerList({
page: pagination.page,
size: pagination.size,
search: filter?.search || undefined,
});
const list = (data?.data?.list || []) as API.Server[];
const total = (data?.data?.total ?? list.length) as number;
return { list, total };
}}
actions={{
render: (row) => [
{
setLoading(true);
try {
// ServerForm already returns API-shaped body; add id for update
await updateServer({
id: row.id,
...(values as unknown as Omit),
});
toast.success(t('updated'));
ref.current?.refresh();
fetchServers();
setLoading(false);
return true;
} catch (e) {
setLoading(false);
return false;
}
}}
/>,
,
{t('delete')}
}
title={t('confirmDeleteTitle')}
description={t('confirmDeleteDesc')}
onConfirm={async () => {
await deleteServer({ id: row.id } as any);
toast.success(t('deleted'));
ref.current?.refresh();
fetchServers();
}}
cancelText={t('cancel')}
confirmText={t('confirm')}
/>,
,
],
batchRender(rows) {
const hasReferencedServers = rows.some((row) => isServerReferencedByNodes(row.id));
return [
{t('delete')}
}
title={t('confirmDeleteTitle')}
description={t('confirmDeleteDesc')}
onConfirm={async () => {
await Promise.all(rows.map((r) => deleteServer({ id: r.id })));
toast.success(t('deleted'));
ref.current?.refresh();
fetchServers();
}}
cancelText={t('cancel')}
confirmText={t('confirm')}
/>,
];
},
}}
onSort={async (source, target, items) => {
const sourceIndex = items.findIndex((item) => String(item.id) === source);
const targetIndex = items.findIndex((item) => String(item.id) === target);
const originalSorts = items.map((item) => item.sort);
const [movedItem] = items.splice(sourceIndex, 1);
items.splice(targetIndex, 0, movedItem!);
const updatedItems = items.map((item, index) => {
const originalSort = originalSorts[index];
const newSort = originalSort !== undefined ? originalSort : item.sort;
return { ...item, sort: newSort };
});
const changedItems = updatedItems.filter((item, index) => {
return item.sort !== items[index]?.sort;
});
if (changedItems.length > 0) {
resetSortWithServer({
sort: changedItems.map((item) => ({
id: item.id,
sort: item.sort,
})) as API.SortItem[],
});
toast.success(t('sorted_success'));
}
return updatedItems;
}}
/>
);
}