更新 Discard/SyncXboxCloud.js
This commit is contained in:
184
Discard/SyncXboxCloud.js
Normal file
184
Discard/SyncXboxCloud.js
Normal file
@@ -0,0 +1,184 @@
|
||||
/**
|
||||
* 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");
|
||||
});
|
||||
});
|
||||
Reference in New Issue
Block a user