352 lines
11 KiB
TypeScript
352 lines
11 KiB
TypeScript
import { RefreshRounded, StorageOutlined } from "@mui/icons-material";
|
|
import {
|
|
Box,
|
|
Button,
|
|
Dialog,
|
|
DialogActions,
|
|
DialogContent,
|
|
DialogTitle,
|
|
Divider,
|
|
IconButton,
|
|
LinearProgress,
|
|
List,
|
|
ListItem,
|
|
ListItemText,
|
|
Typography,
|
|
alpha,
|
|
styled,
|
|
} from "@mui/material";
|
|
import { useLockFn } from "ahooks";
|
|
import dayjs from "dayjs";
|
|
import { useState } from "react";
|
|
import { useTranslation } from "react-i18next";
|
|
import { updateProxyProvider } from "tauri-plugin-mihomo-api";
|
|
|
|
import { useAppData } from "@/providers/app-data-context";
|
|
import { showNotice } from "@/services/noticeService";
|
|
import parseTraffic from "@/utils/parse-traffic";
|
|
|
|
// 样式化组件 - 类型框
|
|
const TypeBox = styled(Box)<{ component?: React.ElementType }>(({ theme }) => ({
|
|
display: "inline-block",
|
|
border: "1px solid #ccc",
|
|
borderColor: alpha(theme.palette.secondary.main, 0.5),
|
|
color: alpha(theme.palette.secondary.main, 0.8),
|
|
borderRadius: 4,
|
|
fontSize: 10,
|
|
marginRight: "4px",
|
|
padding: "0 2px",
|
|
lineHeight: 1.25,
|
|
}));
|
|
|
|
// 解析过期时间
|
|
const parseExpire = (expire?: number) => {
|
|
if (!expire) return "-";
|
|
return dayjs(expire * 1000).format("YYYY-MM-DD");
|
|
};
|
|
|
|
export const ProviderButton = () => {
|
|
const { t } = useTranslation();
|
|
const [open, setOpen] = useState(false);
|
|
const { proxyProviders, refreshProxy, refreshProxyProviders } = useAppData();
|
|
const [updating, setUpdating] = useState<Record<string, boolean>>({});
|
|
|
|
// 检查是否有提供者
|
|
const hasProviders = Object.keys(proxyProviders || {}).length > 0;
|
|
|
|
// 更新单个代理提供者
|
|
const updateProvider = useLockFn(async (name: string) => {
|
|
try {
|
|
// 设置更新状态
|
|
setUpdating((prev) => ({ ...prev, [name]: true }));
|
|
|
|
await updateProxyProvider(name);
|
|
|
|
// 刷新数据
|
|
await refreshProxy();
|
|
await refreshProxyProviders();
|
|
|
|
showNotice("success", {
|
|
i18nKey: "components.notices.providers.updateSuccess",
|
|
params: { name },
|
|
});
|
|
} catch (err: any) {
|
|
const message = err?.message || err?.toString?.() || String(err);
|
|
showNotice("error", {
|
|
i18nKey: "components.notices.providers.updateFailed",
|
|
params: { name, message },
|
|
});
|
|
} finally {
|
|
// 清除更新状态
|
|
setUpdating((prev) => ({ ...prev, [name]: false }));
|
|
}
|
|
});
|
|
|
|
// 更新所有代理提供者
|
|
const updateAllProviders = useLockFn(async () => {
|
|
try {
|
|
// 获取所有provider的名称
|
|
const allProviders = Object.keys(proxyProviders || {});
|
|
if (allProviders.length === 0) {
|
|
showNotice("info", {
|
|
i18nKey: "components.notices.providers.none",
|
|
});
|
|
return;
|
|
}
|
|
|
|
// 设置所有provider为更新中状态
|
|
const newUpdating = allProviders.reduce(
|
|
(acc, key) => {
|
|
acc[key] = true;
|
|
return acc;
|
|
},
|
|
{} as Record<string, boolean>,
|
|
);
|
|
setUpdating(newUpdating);
|
|
|
|
// 改为串行逐个更新所有provider
|
|
for (const name of allProviders) {
|
|
try {
|
|
await updateProxyProvider(name);
|
|
// 每个更新完成后更新状态
|
|
setUpdating((prev) => ({ ...prev, [name]: false }));
|
|
} catch (err) {
|
|
console.error(`更新 ${name} 失败`, err);
|
|
// 继续执行下一个，不中断整体流程
|
|
}
|
|
}
|
|
|
|
// 刷新数据
|
|
await refreshProxy();
|
|
await refreshProxyProviders();
|
|
|
|
showNotice("success", {
|
|
i18nKey: "components.notices.providers.allUpdated",
|
|
});
|
|
} catch (err: any) {
|
|
const message = err?.message || err?.toString?.() || String(err);
|
|
showNotice("error", {
|
|
i18nKey: "components.notices.providers.genericError",
|
|
params: { message },
|
|
});
|
|
} finally {
|
|
// 清除所有更新状态
|
|
setUpdating({});
|
|
}
|
|
});
|
|
|
|
const handleClose = () => {
|
|
setOpen(false);
|
|
};
|
|
|
|
if (!hasProviders) return null;
|
|
|
|
return (
|
|
<>
|
|
<Button
|
|
variant="outlined"
|
|
size="small"
|
|
startIcon={<StorageOutlined />}
|
|
onClick={() => setOpen(true)}
|
|
sx={{ mr: 1 }}
|
|
>
|
|
{t("pages.proxies.provider.title")}
|
|
</Button>
|
|
|
|
<Dialog open={open} onClose={handleClose} maxWidth="sm" fullWidth>
|
|
<DialogTitle>
|
|
<Box
|
|
display="flex"
|
|
justifyContent="space-between"
|
|
alignItems="center"
|
|
>
|
|
<Typography variant="h6">
|
|
{t("pages.proxies.provider.title")}
|
|
</Typography>
|
|
<Box>
|
|
<Button
|
|
variant="contained"
|
|
size="small"
|
|
onClick={updateAllProviders}
|
|
aria-label={t("pages.proxies.provider.actions.updateAll")}
|
|
>
|
|
{t("pages.proxies.provider.actions.updateAll")}
|
|
</Button>
|
|
</Box>
|
|
</Box>
|
|
</DialogTitle>
|
|
|
|
<DialogContent>
|
|
<List sx={{ py: 0, minHeight: 250 }}>
|
|
{Object.entries(proxyProviders || {})
|
|
.sort()
|
|
.map(([key, item]) => {
|
|
const provider = item;
|
|
const time = dayjs(provider.updatedAt);
|
|
const isUpdating = updating[key];
|
|
|
|
// 订阅信息
|
|
const sub = provider.subscriptionInfo;
|
|
const hasSubInfo = !!sub;
|
|
const upload = sub?.Upload || 0;
|
|
const download = sub?.Download || 0;
|
|
const total = sub?.Total || 0;
|
|
const expire = sub?.Expire || 0;
|
|
|
|
// 流量使用进度
|
|
const progress =
|
|
total > 0
|
|
? Math.min(
|
|
Math.round(((download + upload) * 100) / total) + 1,
|
|
100,
|
|
)
|
|
: 0;
|
|
|
|
return (
|
|
<ListItem
|
|
key={key}
|
|
sx={[
|
|
{
|
|
p: 0,
|
|
mb: "8px",
|
|
borderRadius: 2,
|
|
overflow: "hidden",
|
|
transition: "all 0.2s",
|
|
},
|
|
({ palette: { mode, primary } }) => {
|
|
const bgcolor =
|
|
mode === "light" ? "#ffffff" : "#24252f";
|
|
const hoverColor =
|
|
mode === "light"
|
|
? alpha(primary.main, 0.1)
|
|
: alpha(primary.main, 0.2);
|
|
|
|
return {
|
|
backgroundColor: bgcolor,
|
|
"&:hover": {
|
|
backgroundColor: hoverColor,
|
|
},
|
|
};
|
|
},
|
|
]}
|
|
>
|
|
<ListItemText
|
|
sx={{ px: 2, py: 1 }}
|
|
primary={
|
|
<Box
|
|
sx={{
|
|
display: "flex",
|
|
justifyContent: "space-between",
|
|
alignItems: "center",
|
|
}}
|
|
>
|
|
<Typography
|
|
variant="subtitle1"
|
|
component="div"
|
|
noWrap
|
|
title={key}
|
|
sx={{ display: "flex", alignItems: "center" }}
|
|
>
|
|
<span style={{ marginRight: "8px" }}>{key}</span>
|
|
<TypeBox component="span">
|
|
{provider.proxies.length}
|
|
</TypeBox>
|
|
<TypeBox component="span">
|
|
{provider.vehicleType}
|
|
</TypeBox>
|
|
</Typography>
|
|
|
|
<Typography
|
|
variant="body2"
|
|
color="text.secondary"
|
|
noWrap
|
|
>
|
|
<small>{t("Update At")}: </small>
|
|
{time.fromNow()}
|
|
</Typography>
|
|
</Box>
|
|
}
|
|
secondary={
|
|
<>
|
|
{/* 订阅信息 */}
|
|
{hasSubInfo && (
|
|
<>
|
|
<Box
|
|
sx={{
|
|
mb: 1,
|
|
display: "flex",
|
|
alignItems: "center",
|
|
justifyContent: "space-between",
|
|
}}
|
|
>
|
|
<span title={t("Used / Total") as string}>
|
|
{parseTraffic(upload + download)} /{" "}
|
|
{parseTraffic(total)}
|
|
</span>
|
|
<span title={t("Expire Time") as string}>
|
|
{parseExpire(expire)}
|
|
</span>
|
|
</Box>
|
|
|
|
{/* 进度条 */}
|
|
<LinearProgress
|
|
variant="determinate"
|
|
value={progress}
|
|
sx={{
|
|
height: 6,
|
|
borderRadius: 3,
|
|
opacity: total > 0 ? 1 : 0,
|
|
}}
|
|
/>
|
|
</>
|
|
)}
|
|
</>
|
|
}
|
|
/>
|
|
<Divider orientation="vertical" flexItem />
|
|
<Box
|
|
sx={{
|
|
width: 40,
|
|
display: "flex",
|
|
justifyContent: "center",
|
|
alignItems: "center",
|
|
}}
|
|
>
|
|
<IconButton
|
|
size="small"
|
|
color="primary"
|
|
onClick={() => {
|
|
updateProvider(key);
|
|
}}
|
|
disabled={isUpdating}
|
|
sx={{
|
|
animation: isUpdating
|
|
? "spin 1s linear infinite"
|
|
: "none",
|
|
"@keyframes spin": {
|
|
"0%": { transform: "rotate(0deg)" },
|
|
"100%": { transform: "rotate(360deg)" },
|
|
},
|
|
}}
|
|
title={t("pages.proxies.provider.actions.update")}
|
|
aria-label={t("pages.proxies.provider.actions.update")}
|
|
>
|
|
<RefreshRounded />
|
|
</IconButton>
|
|
</Box>
|
|
</ListItem>
|
|
);
|
|
})}
|
|
</List>
|
|
</DialogContent>
|
|
|
|
<DialogActions>
|
|
<Button onClick={handleClose} variant="outlined">
|
|
{t("Close")}
|
|
</Button>
|
|
</DialogActions>
|
|
</Dialog>
|
|
</>
|
|
);
|
|
};
|