185 lines
7.2 KiB
JavaScript
185 lines
7.2 KiB
JavaScript
/**
|
||
* SyncXboxCloud.js
|
||
* 两步流程：先读取，写入成功后再删除
|
||
* 顶部时间戳锁防止 Surge 规则重复触发脚本
|
||
*/
|
||
|
||
const readUrl = 'https://xbox-bot.biubiubiu-lalala.workers.dev/surge?token=xbox123';
|
||
const commitUrl = 'https://xbox-bot.biubiubiu-lalala.workers.dev/surge/commit?token=xbox123';
|
||
const storeKey = 'XboxProductList';
|
||
|
||
function escapeHTML(str) {
|
||
return String(str || '')
|
||
.replace(/&/g, '&')
|
||
.replace(/</g, '<')
|
||
.replace(/>/g, '>')
|
||
.replace(/"/g, '"')
|
||
.replace(/'/g, ''');
|
||
}
|
||
|
||
function renderUI(title, message, type = "success") {
|
||
const colorMap = {
|
||
success: "#107C10",
|
||
warning: "#d83b01",
|
||
error: "#c50f1f",
|
||
info: "#0078d4"
|
||
};
|
||
const color = colorMap[type] || "#0078d4";
|
||
|
||
const html = `
|
||
<!DOCTYPE html>
|
||
<html lang="zh-CN">
|
||
<head>
|
||
<meta charset="UTF-8">
|
||
<meta name="viewport" content="width=device-width, initial-scale=1.0, maximum-scale=1">
|
||
<title>${escapeHTML(title)}</title>
|
||
<style>
|
||
@import url('https://fonts.googleapis.com/css2?family=Barlow+Condensed:wght@600;700&family=Noto+Sans+SC:wght@400;500&display=swap');
|
||
*,*::before,*::after{box-sizing:border-box;margin:0;padding:0}
|
||
body {
|
||
min-height: 100vh; display: flex; align-items: center; justify-content: center;
|
||
background: #0b0b0b; color: #ddd;
|
||
font-family: 'Noto Sans SC', sans-serif;
|
||
padding: 24px 18px;
|
||
-webkit-font-smoothing: antialiased;
|
||
background-image: radial-gradient(ellipse 80% 50% at 50% -10%, rgba(16,124,16,0.10) 0%, transparent 60%);
|
||
}
|
||
.card {
|
||
width: 100%; max-width: 520px;
|
||
background: #141414;
|
||
border: 1px solid #222;
|
||
border-top: 3px solid ${color};
|
||
border-radius: 4px;
|
||
padding: 24px 20px 20px;
|
||
}
|
||
.card-title {
|
||
font-family: 'Barlow Condensed', sans-serif;
|
||
font-size: 22px; font-weight: 700; letter-spacing: 1px;
|
||
color: #fff; margin-bottom: 16px;
|
||
}
|
||
.msg { font-size: 13px; line-height: 1.8; color: #aaa; word-break: break-word; }
|
||
.msg p { margin-bottom: 8px; }
|
||
.msg b { color: #ddd; }
|
||
.msg ul { margin: 10px 0 0; padding-left: 18px; }
|
||
.msg li { margin: 5px 0; color: #888; font-size: 12px; font-family: monospace; }
|
||
.footer {
|
||
margin-top: 18px;
|
||
display: flex; align-items: center; justify-content: space-between;
|
||
}
|
||
.sub { font-size: 11px; color: #333; letter-spacing: 1.5px; text-transform: uppercase; }
|
||
button {
|
||
border: 1px solid ${color}; background: transparent;
|
||
color: ${color}; padding: 8px 20px; border-radius: 3px;
|
||
font-size: 13px; font-family: 'Barlow Condensed', sans-serif;
|
||
font-weight: 600; letter-spacing: 1px; cursor: pointer;
|
||
transition: background .2s, color .2s;
|
||
}
|
||
button:hover { background: ${color}; color: #fff; }
|
||
</style>
|
||
</head>
|
||
<body>
|
||
<div class="card">
|
||
<div class="card-title">${escapeHTML(title)}</div>
|
||
<div class="msg">${message}</div>
|
||
<div class="footer">
|
||
<span class="sub">Sync Xbox Cloud</span>
|
||
<button onclick="history.back()">确定</button>
|
||
</div>
|
||
</div>
|
||
</body>
|
||
</html>`;
|
||
|
||
$done({
|
||
response: {
|
||
status: 200,
|
||
headers: {
|
||
"Content-Type": "text/html; charset=utf-8",
|
||
"Cache-Control": "no-store, no-cache, must-revalidate",
|
||
"Pragma": "no-cache"
|
||
},
|
||
body: html
|
||
}
|
||
});
|
||
}
|
||
|
||
// 第一步：读取当前组
|
||
$httpClient.get(readUrl, (error, response, data) => {
|
||
if (error) {
|
||
$notification.post("❌ 同步失败", "无法连接服务器", String(error));
|
||
return renderUI("❌ 连接失败", `<p>无法连接至服务器。</p><p>${escapeHTML(String(error))}</p>`, "error");
|
||
}
|
||
|
||
let payload;
|
||
try {
|
||
payload = JSON.parse((data || '').trim() || '{}');
|
||
} catch (e) {
|
||
$notification.post("❌ 同步失败", "返回 JSON 无法解析", "");
|
||
return renderUI("❌ 解析错误", `<p>服务器返回内容不是合法 JSON。</p><p>${escapeHTML(String(e.message || e))}</p>`, "error");
|
||
}
|
||
|
||
if (!payload || typeof payload !== 'object' || Array.isArray(payload)) {
|
||
$notification.post("❌ 同步失败", "返回结构异常", "");
|
||
return renderUI("❌ 数据异常", `<p>服务器返回的数据结构不正确。</p>`, "error");
|
||
}
|
||
|
||
if (!payload.ok) {
|
||
$notification.post("❌ 同步失败", "服务器返回 ok=false", "");
|
||
return renderUI("❌ 同步失败", `<p>服务器返回失败状态。</p>`, "error");
|
||
}
|
||
|
||
const currentGroup = payload.currentGroup || {};
|
||
const keys = Object.keys(currentGroup);
|
||
|
||
if (!keys.length) {
|
||
$notification.post("📭 当前无待同步组", "云端队列为空", "");
|
||
return renderUI("📭 没有可同步内容", `<p>当前没有待同步的 Product 分组。</p>`, "warning");
|
||
}
|
||
|
||
// 第二步：写入本地，成功后才删云端
|
||
const writeOK = $persistentStore.write(JSON.stringify(currentGroup), storeKey);
|
||
if (!writeOK) {
|
||
$notification.post("❌ 同步失败", "写入 Surge 存储失败", "");
|
||
// 写入失败，不发 clear，云端数据保留，下次可以重试
|
||
return renderUI("❌ 写入失败", `<p>无法写入 Surge 本地存储，云端数据未删除，下次访问可重试。</p>`, "error");
|
||
}
|
||
|
||
// 第三步：本地写入成功，删除云端当前组
|
||
$httpClient.post({ url: commitUrl, headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ remaining: {} }) }, (clearError, clearResponse, clearData) => {
|
||
if (clearError) {
|
||
$notification.post("⚠️ 本地已写入", `第 ${payload.currentGroupIndex} 组已保存`, "但云端清理失败，下次访问仍是这一组");
|
||
return renderUI(
|
||
"⚠️ 当前组已写入，但云端未清理",
|
||
`<p>已成功写入第 <b>${escapeHTML(String(payload.currentGroupIndex))}</b> 组，共 <b>${keys.length}</b> 个商品。</p>
|
||
<p>但清理云端当前组时失败，下次访问时仍会是这一组。</p>`,
|
||
"warning"
|
||
);
|
||
}
|
||
|
||
let clearPayload = {};
|
||
try { clearPayload = JSON.parse((clearData || '').trim() || '{}'); } catch (_) {}
|
||
|
||
const remainingGroups = typeof clearPayload.remainingGroups === 'number'
|
||
? clearPayload.remainingGroups
|
||
: (typeof payload.remainingAfterCurrent === 'number' ? payload.remainingAfterCurrent : 0);
|
||
const nextGroupIndex = clearPayload.nextGroupIndex ?? null;
|
||
const nextGroupCount = clearPayload.nextGroupCount ?? 0;
|
||
const list = keys.map(k => `<li>${escapeHTML(k)}</li>`).join('');
|
||
|
||
let message =
|
||
`<p>本次只同步了第 <b>${escapeHTML(String(payload.currentGroupIndex))}</b> 组，共 <b>${keys.length}</b> 个商品。</p>
|
||
<p>当前这一组已经从云端队列删除。</p>
|
||
<p>现在还剩 <b>${remainingGroups}</b> 组待处理。</p>`;
|
||
|
||
if (remainingGroups > 0 && nextGroupIndex !== null) {
|
||
message += `<p>下次访问网页时，将同步第 <b>${escapeHTML(String(nextGroupIndex))}</b> 组（共 <b>${escapeHTML(String(nextGroupCount))}</b> 个商品）。</p>`;
|
||
} else {
|
||
message += `<p>所有分组已经处理完毕。</p>`;
|
||
}
|
||
|
||
message += `<ul>${list}</ul>`;
|
||
|
||
$notification.post("✅ 当前组同步成功", `第 ${payload.currentGroupIndex} 组已同步`, `剩余 ${remainingGroups} 组`);
|
||
return renderUI("✅ 当前组同步完成", message, "success");
|
||
});
|
||
});
|