GitHub
/
ios_rule_script
mirror of https://github.com/blackmatrix7/ios_rule_script.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
ios_rule_script/script/testflight/testflight.js

710 lines
63 KiB
JavaScript
Raw Normal View History

[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
const scriptName = "TestFlight";
const tfAppIdKey = "tf_app_id";
const tfJoinedAppIdKey = "tf_joined_app_id";
const tfInvalidAppIdKey = "tf_invalid_app_id";
const tfSessionInfoKey = "tf_session_info";
const tfCheckSessionTimeKey = "tf_check_session_time";
const tfCheckSessionTimeDiffKey = "tf_check_session_time_diff";
const tfAppUseAccountIdKey = "tf_app_use_account_id";
[TestFlight] 支持自定义storefrontId
2022-12-23 10:25:49 +08:00
const tfStorefrontId = "tf_storefront_id";
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
const getSessionRegex = /^https:\/\/testflight\.apple\.com\/v3\/accounts\/(\w{8}-\w{4}-\w{4}-\w{4}-\w{12})\/apps$/;
const getFullAppIdRegex = /^https:\/\/testflight\.apple\.com\/v3\/accounts\/\w{8}-\w{4}-\w{4}-\w{4}-\w{12}\/ru\/([a-zA-Z0-9]{8})$/;
const modifyTFRequest = /^https:\/\/testflight\.apple\.com\/v\d\/accounts\/\w{8}-\w{4}-\w{4}-\w{4}-\w{12}\/apps\/\d+/
const modifySettingsTFRequest = /^https:\/\/testflight\.apple\.com\/v\d\/accounts\/settings\/.*\/apps\/\d+/
const modifyInstallTFRequest = /^https:\/\/testflight\.apple\.com\/v\d\/apps\/\d+\/\d+\/install\/status$/
const $ = MagicJS(scriptName, "INFO");
const blankSessionInfo = {
"x-session-id": "", "x-session-digest": "", "x-request-id": "", "valid": false
};
// 加入TestFlight的模式，0: 温和 1: 标准 2: 暴力
const tfJoinMode = parseInt($.data.read("tf_join_mode", 1));
// 尝试加入TF时并发请求数量
const tfJoinConcurrency = parseInt($.data.read("tf_join_concurrency", 2));
// 每次执行循环次数
const tfLoopCount = parseInt($.data.read("tf_loop_count", 5));
// 用于检测TF可用性的专用账号
let tfCheckAccountId = $.data.read('tf_check_account_id', '');
// 同步数据到青龙面板
const syncQingLong = $.data.read("tf_sync_qinglong", false);
function removeHeaders(config) {
let headers = {...config["headers"]};
delete headers["valid"];
delete headers["if-none-match"];
delete headers["If-None-Match"];
config["headers"] = headers;
return config;
}
$.http.interceptors.request.use(removeHeaders);
function modifyHeaders(accountId, headers, session, url = "") {
let newHeaders = {...headers, ...session};
delete newHeaders["valid"];
if ($.env.isQuanX || $.env.isStash) {
newHeaders = $.http.convertHeadersToCamelCase(newHeaders);
delete headers["If-None-Match"];
} else {
newHeaders = $.http.convertHeadersToLowerCase(newHeaders);
delete headers["if-none-match"];
}
$.logger.info(`修改请求头\n${JSON.stringify(newHeaders)}`);
return newHeaders;
}
function modifyRequest() {
$.logger.info(`请求地址\n${$.request.url}`);
let url = $.request.url;
let headers = $.request.headers;
let body = $.request.body ? JSON.parse($.request.body) : {};
const result = /apps\/(\d+)/.exec($.request.url);
if (result) {
const appAdamId = result[1];
const appUseAccountId = $.data.read(tfAppUseAccountIdKey, {});
if (appAdamId in appUseAccountId) {
const accountId = appUseAccountId[appAdamId];
const session = $.data.read(tfSessionInfoKey, blankSessionInfo, accountId);
url = url.replace(/accounts\/\w{8}-\w{4}-\w{4}-\w{4}-\w{12}/, `accounts/${accountId}`);
$.logger.info(`修改请求地址为\n${url}`);
headers = modifyHeaders(accountId, headers, session, url);
}
}
if (/\/install$/.test($.request.url) && Object.keys(body).length > 0) {
[TestFlight] 支持自定义storefrontId
2022-12-23 10:25:49 +08:00
body.storefrontId = $.data.read(tfStorefrontId, "143441-19,29");
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
}
return [url, headers, JSON.stringify(body)];
}
function getAccountAppData(currentAccountId, accountId, headers) {
return new Promise(resolve => {
$.http.get({
url: `https://testflight.apple.com/v3/accounts/${accountId}/apps`, headers: headers
}).then(resp => {
let obj = resp.body;
obj["account_id"] = accountId;
// 当前账户保留"以前测试过的"App数据
if (currentAccountId !== accountId) {
obj["data"] = obj["data"].filter(app => app["previouslyTested"] === false);
}
$.logger.info(`账户 ${accountId} 获取到 ${obj["data"].length} 个App`);
resolve(obj);
}).catch(async err => {
if (err.response.status === 401) {
$.notification.post(`AccountId ${accountId} 的 Session 已过期`);
let sessionInfo = $.data.read(tfSessionInfoKey, blankSessionInfo, accountId);
sessionInfo["valid"] = false;
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
$.data.write(tfSessionInfoKey, sessionInfo, accountId)
try {
if (syncQingLong === true) {
let qlSessionInfo = await $.qinglong.read(tfSessionInfoKey, {}, accountId);
if (qlSessionInfo && qlSessionInfo["x-request-id"] === sessionInfo["x-request-id"] && qlSessionInfo["valid"] === true) {
await $.qinglong.write(tfSessionInfoKey, sessionInfo, accountId);
$.notification.post(`已同步将青龙面板中AccountId ${accountId}设置为失效`);
}
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
}
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
} catch (err) {
$.logger.error(`将青龙面板中AccountId ${accountId}设置为失效时出现异常\n${err}`);
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
}
resolve({data: [], account_id: accountId});
} else {
$.logger.error(`获取 AccountId ${accountId} 的App列表出现异常\n${JSON.stringify(err)}`);
resolve({data: [], account_id: accountId});
}
})
})
}
async function getAllAppData() {
try {
const currentAccountId = $.request.url.match(getSessionRegex)[1];
$.logger.info(`当前账户为：${currentAccountId}`);
let obj = $.response.status === 200 ? JSON.parse($.response.body) : {"data": [], "error": null};
$.logger.debug(`请求到的App列表为：\n${JSON.stringify(obj)}`);
let allSessions = $.data.read(tfSessionInfoKey, null, "", true);
let accountIdList = Object.keys(allSessions);
// 确保当前账户排在数组中的第一位，以保证优先使用当前账户的App数据
if ($.response.status === 304) {
accountIdList = accountIdList.filter(accountId => accountId !== currentAccountId);
accountIdList.unshift(currentAccountId);
}
const promises = accountIdList.filter(accountId => {
return accountId !== 'magic_session' && ($.response.status !== 200 || accountId !== currentAccountId) && allSessions[accountId]['valid'] === true
}).map(accountId => {
let session = allSessions[accountId];
return getAccountAppData(currentAccountId, accountId, modifyHeaders(accountId, $.request.headers, session));
});
$.logger.info(`共有 ${promises.length} 个账户需要获取App列表`);
await Promise.all(promises)
.then((results) => {
let appAccountMap = new Map();
for (let result of results) {
if (result !== undefined && typeof result["data"] !== undefined) {
for (let appData of result["data"]) {
const appAdamId = appData["appAdamId"].toString();
if (appAccountMap.has(appAdamId) === false) {
appAccountMap.set(appAdamId, result["account_id"]);
obj["data"].push(appData);
}
}
} else {
$.logger.warning(`获取到的App数据为undefined`);
}
}
$.data.write(tfAppUseAccountIdKey, Object.fromEntries(appAccountMap));
})
.catch(error => {
// 处理错误
$.logger.error(`获取App数据出现异常\n${JSON.stringify(error)}`);
});
$.logger.debug(`全部有效账户的App数据\n${JSON.stringify(obj)}`);
return {body: JSON.stringify(obj)};
} catch (err) {
$.logger.error(`获取全部有效账户的App数据出现异常\n${err}`);
return {body: $.response.body};
}
}
async function syncToQingLong(currentAccountId = "", currentSessionInfo = null) {
if (syncQingLong === true) {
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
try {
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
let silentSync = true; // 静默同步，本次同步不弹出通知
let [qlAllSessions, qlAppIds] = await $.qinglong.batchRead([tfSessionInfoKey, {}, "", true], [tfAppIdKey, ""]);
let batchWriteData = [];
// 同步本地的Session至青龙面板
if (currentAccountId !== "" && currentSessionInfo !== null) {
try {
const qlSessionInfo = qlAllSessions[currentAccountId];
$.logger.info(`青龙面板中旧的SessionInfo\n${JSON.stringify(qlSessionInfo)}`);
if (!qlSessionInfo || qlSessionInfo["x-session-id"] !== currentSessionInfo["x-session-id"] || qlSessionInfo["valid"] === false) {
$.logger.info(`符合同步条件，已将当前Session同步至青龙面板`);
batchWriteData.push([tfSessionInfoKey, currentSessionInfo, currentAccountId]);
} else {
$.logger.info(`不符合同步条件，无需同步当前Session至青龙面板`);
}
[MagicJS3] 更新框架代码
2022-12-31 22:02:33 +08:00
if (!qlSessionInfo || qlSessionInfo["valid"] === false){
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
silentSync = false;
}
} catch
(error) {
$.logger.error(`同步当前Session至青龙面板出现异常\n${error}`);
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
}
}
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
// 同步AppId至青龙面板
try {
let tfAppIds = $.data.read(tfAppIdKey, "").split(";");
qlAppIds = qlAppIds.split(";").filter(appId => appId !== "");
// 判断是否有在青龙面板上不存在的AppId
let newAppIds = tfAppIds.filter(x => x !== "" && !qlAppIds.includes(x));
if (newAppIds.length > 0) {
qlAppIds = qlAppIds.concat(tfAppIds);
qlAppIds = [...new Set(qlAppIds)];
$.logger.info(`本次需要更新到青龙面板的AppId\n${qlAppIds.join(";")}`);
let strAppIds = "";
if (qlAppIds.length === 1) {
strAppIds = qlAppIds[0];
} else if (qlAppIds.length > 1) {
strAppIds = qlAppIds.join(";")
}
batchWriteData.push([tfAppIdKey, strAppIds]);
silentSync = false;
} else {
$.logger.info(`所有的AppId都已经存在于青龙面板中，本次同步不进行同步！`);
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
}
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
} catch (error) {
$.logger.error(`同步AppId至青龙面板出现异常\n${error}`);
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
}
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
// 同步青龙面板的数据至本地
try {
$.logger.debug(`青龙面板中所有的SessionInfo\n${JSON.stringify(qlAllSessions)}`);
// 遍历青龙面板存储的Session
for (let accountId of Object.keys(qlAllSessions)) {
// 与本地的比较，如果不一致则更新本地的Session
if (accountId !== "magic_session" && qlAllSessions[accountId]["valid"] === true && accountId !== currentAccountId) {
const localSession = $.data.read(tfSessionInfoKey, {}, accountId);
const qlSession = qlAllSessions[accountId];
if (localSession["x-request-id"] !== qlSession["x-request-id"] || localSession["valid"] === false) {
$.data.write(tfSessionInfoKey, qlSession, accountId);
$.logger.info(`将青龙面板 ${accountId} 的 Session 同步到本地`);
}
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
}
}
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
} catch (error) {
$.logger.error(`同步青龙面板的Session至本地出现异常\n${JSON.stringify(error)}`);
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
}
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
// 批量写入数据
const result = await $.qinglong.batchWrite(...batchWriteData);
if (result === true) {
if (silentSync === false) {
$.notification.post(
`${scriptName} ${currentAccountId}`,
"",
`已将您的信息同步至青龙面板：\n${$.qinglong.url}\n如上述地址不是您所配置，则信息已泄露！\n请立即停用脚本，更改密码！\n检查青龙面板配置是否被篡改！`);
} else {
$.logger.info(`青龙面板已经存在相同信息，故本次同步不弹出通知！\n已将您的信息同步至青龙面板：\n${$.qinglong.url}\n如上述地址不是您所配置，则信息已泄露！\n请立即停用脚本，更改密码！\n检查青龙面板配置是否被篡改！`);
}
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
} else {
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
$.notification.post(`将您的信息同步至青龙面板失败：\n${$.qinglong.url}\n请检查青龙面板配置！`);
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
}
[TestFlight] 提高多设备同步稳定性
2022-12-26 21:51:40 +08:00
} catch (error) {
$.logger.error(`同步数据至青龙面板出现异常\n${error}`);
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
$.notification.post(`将您的信息同步至青龙面板失败：\n${$.qinglong.url}\n请检查青龙面板配置！`);
}
}
}
async function getTFSessionInfo() {
try {
const matches = $.request.url.match(/\/accounts\/([a-zA-Z0-9-]+)\/apps/);
if (matches && matches.length > 1) {
// 账户Id
const accountId = matches[1];
// 获取旧的TestFlight Session数据
const oldSessionInfo = $.data.read(tfSessionInfoKey, blankSessionInfo, accountId);
$.logger.info(`旧的SessionInfo:\n${JSON.stringify(oldSessionInfo)}`);
// 获取新的TestFlight Session数据
$.logger.info(`当前的Headers:\n${JSON.stringify($.request.headers)}`);
const newSessionInfo = {
"valid": true,
"x-session-id": $.request.headers["x-session-id"] || $.request.headers["X-Session-Id"],
"x-session-digest": $.request.headers["x-session-digest"] || $.request.headers["X-Session-Digest"],
"x-request-id": $.request.headers["x-request-id"] || $.request.headers["X-Request-Id"],
};
$.logger.info(`新的SessionInfo\n${JSON.stringify(newSessionInfo)}`);
// Session数据不同时写入
if (oldSessionInfo["x-session-id"] !== newSessionInfo["x-session-id"]) {
$.data.write(tfSessionInfoKey, newSessionInfo, accountId);
const tempSessionInfo = $.data.read(tfSessionInfoKey, blankSessionInfo, accountId);
if (newSessionInfo["x-session-id"] === tempSessionInfo["x-session-id"]) {
$.notification.post(`${scriptName} - ${accountId}`, "", "写入TestFlight必要信息成功");
} else {
$.notification.post(`${scriptName} - ${accountId}`, "", "写入TestFlight必要信息失败");
}
}
// 同步数据至青龙面板
await syncToQingLong(accountId, newSessionInfo);
} else {
$.logger.error(`无法获取TestFlight的AccountId，请检查配置。`);
}
} catch (err) {
const errMsg = `获取TestFlight必要信息出现异常`;
$.notification.post(errMsg);
$.logger.error(`${errMsg}\n${err}`);
}
}
async function autoAddAppId() {
let obj = JSON.parse($.response.body);
const match = $.request.url.match(getFullAppIdRegex);
const appId = match[1];
let tfAppIds = $.data.read(tfAppIdKey, "").split(";");
tfAppIds = tfAppIds.filter(appId => {
return appId !== ""
});
$.logger.info(`已存在的TF愿望清单App:${JSON.stringify(tfAppIds)}`);
if (obj.data.status === "FULL") {
if (!tfAppIds.includes(appId)) {
tfAppIds.push(appId);
let strAppIds = "";
if (tfAppIds.length === 1) {
strAppIds = appId;
} else if (tfAppIds.length > 1) {
strAppIds = tfAppIds.join(";")
}
$.data.write(tfAppIdKey, strAppIds);
const msg = `应用 [${appId}] 已满员，自动加入TestFlight愿望清单`;
$.logger.info(msg);
$.notification.post(msg)
} else {
$.logger.info(`应用 [${appId}] 已存在于TestFlight愿望清单，本次不会重复加入`);
}
await syncToQingLong();
} else {
$.logger.info(`应用 [${appId}] 未满员或不开放，请自行加入`);
}
}
function getAppTestFlightHtml(appId) {
return new Promise((resolve) => {
const url = `https://testflight.apple.com/join/${appId}`;
$.http
.get({url, timeout: 5000})
.then((resp) => {
if (resp.status === 200 && (resp.body.indexOf("此 Beta 版本的测试员已满") > 0 || resp.body.indexOf("This beta is full") > 0)) {
$.logger.info(`AppId: [${appId}] 已满员`);
resolve("FULL");
} else {
$.logger.info(`AppId: [${appId}] 未满员`);
$.logger.info(`当前的Response:\n${resp.body}`);
resolve("NOT_FULL");
}
})
.catch((err) => {
if (err.response.status === 404) {
$.logger.warning(`AppId: [${appId}] 不存在`);
resolve("NO_EXIST");
} else {
$.logger.warning(`获取TestFlight信息出现异常\n${JSON.stringify(err)}`);
resolve("ERROR");
}
});
});
}
function getAppTestFlightJson(accountId, sessionInfo, appId) {
return new Promise((resolve) => {
const url = `https://testflight.apple.com/v3/accounts/${accountId}/ru/${appId}`;
$.http
.get({
url, headers: {...sessionInfo}, timeout: 5000
})
.then((resp) => {
if (resp.status === 200) {
if (resp.body.data.status === "FULL") {
$.logger.info(`应用 [${resp.body.data.app.name}] 已满员`);
resolve([false, resp.status]);
} else if (resp.body.data.status === "OPEN") {
$.logger.info(`应用 [${resp.body.data.app.name}] 未满员`);
resolve([true, resp.status]);
} else {
$.logger.info(`应用 [${resp.body.data.app.name}] 状态未知:${resp.body.data.status}`);
resolve([false, resp.status]);
}
} else {
$.logger.warning(`获取App Beta测试状态出现错误`);
resolve([false, resp.status]);
}
})
.catch((err) => {
if (err.response.status === 404) {
$.logger.warning(`应用${appId}不存在`);
let invalidAppIds = $.data.read(tfInvalidAppIdKey, []);
invalidAppIds.push(appId);
$.data.write(tfInvalidAppIdKey, invalidAppIds);
resolve([false, err.response.status]);
} else if (err.response.status === 401) {
$.logger.warning(`获取App Beta测试状态出现未授权，请更新Session`);
resolve([false, err.response.status]);
} else if (err.response && err.response.status) {
$.logger.warning(`获取App Beta测试状态出现错误：\n${JSON.stringify(err)}，http code: ${err.response.status}`);
resolve([false, err.response.status]);
} else {
$.logger.warning(`获取App Beta测试状态出现错误：\n${err}`);
resolve([false, undefined]);
}
});
});
}
function joinTestFlight(accountId, sessionInfo, appId) {
return new Promise((resolve) => {
const url = `https://testflight.apple.com/v3/accounts/${accountId}/ru/${appId}/accept`;
$.http
.post({
url, headers: sessionInfo,
})
.then((resp) => {
if (resp.status === 200) {
// 存储已加入的AppId
let tfJoinedAppIds = $.data.read(tfJoinedAppIdKey, [], accountId);
if (!tfJoinedAppIds.includes(appId)) {
tfJoinedAppIds.push(appId);
tfJoinedAppIds = [...new Set(tfJoinedAppIds)];
$.data.write(tfJoinedAppIdKey, tfJoinedAppIds, accountId);
}
$.logger.info(`成功加入[${resp.body.data.name}]`);
resolve([true, appId, resp.body.data.name, accountId]);
} else {
$.logger.info(`加入[${appId}]失败`);
$.notification.post(`加入[${appId}]失败`);
resolve([false, appId, resp.body.data.name, accountId]);
}
})
.catch((err) => {
if (err && err.response && err.response.status === 409) {
$.logger.warning(`强制加入应用${appId}失败`);
}
$.logger.warning(`加入应用${appId}出现异常\n${JSON.stringify(err)}`);
$.notification.post(`加入[${appId}]失败`);
resolve([false, appId, "", accountId]);
});
});
}
async function startJoinAppTestFlight(accountIds, accountsSessionInfo, appId) {
if (accountIds.length === 0) {
return [];
}
let joinPromise = [];
for (let accountId of accountIds) {
// 遍历N次，尝试加入TestFlight
for (let i = 0; i < tfJoinConcurrency; i++) {
joinPromise.push(joinTestFlight(accountId, accountsSessionInfo[accountId], appId));
}
}
return joinPromise;
}
async function checkAppIsOpen(accountId, sessionInfo, appId) {
let allowJoin = false;
let httpCode;
return new Promise(async resolve => {
if (tfJoinMode === 0) {
const tfStatus = await getAppTestFlightHtml(appId);
if (tfStatus === "NOT_FULL") {
allowJoin = true;
$.logger.info(`温和模式下，未满员的应用 [${appId}] 尝试加入`);
} else {
allowJoin = false;
$.logger.info(`温和模式下，已满员的应用 [${appId}] 不尝试加入`);
}
} else if (tfJoinMode === 1) {
[allowJoin, httpCode] = await getAppTestFlightJson(accountId, sessionInfo, appId);
if (allowJoin === false) {
$.logger.info(`标准模式下，已满员的应用 [${appId}] 不尝试加入`);
} else {
$.logger.info(`标准模式下，未满员的应用 [${appId}] 尝试加入`);
}
} else {
$.logger.info(`暴力模式下，不检查AppId的状态，直接强制请求加入应用 [${appId}]，可能会被封号，慎用`);
}
$.logger.debug(`AppId [${appId}] 是否允许加入：${allowJoin}`);
resolve(allowJoin === true ? {'app_id': appId, 'http_code': httpCode} : {});
}).catch((err) => {
$.logger.warning(`检查应用${appId}是否开放出现异常\n${JSON.stringify(err)}`);
return {};
});
}
async function crowd() {
try {
// 获取配置好的AccountId
let allAccountIds = $.data.allSessionNames(tfSessionInfoKey);
// 获取需要加入的App Id
let appIds = $.data.read(tfAppIdKey, "").split(";");
appIds = appIds.filter(appId => {
return appId !== ""
});
if (appIds.length === 0) {
$.notification.post(`没有检测到有效的AppId，请检查配置。`);
return;
}
if (allAccountIds.length === 0) {
$.notification.post(`没有检测到有效的账户信息，请检查配置。`);
return;
}
// 获取每个账户的基础数据
let accountsJoinedAppIds = $.data.read(tfJoinedAppIdKey, null, "", true);
let accountsSessionInfo = $.data.read(tfSessionInfoKey, null, "", true);
// 账户Session有效性检查
const checkSessionTime = $.data.read(tfCheckSessionTimeKey, 0);
const checkSessionTimeDiff = parseInt($.data.read(tfCheckSessionTimeDiffKey, 7200));
const ts = Math.floor(Date.now() / 1000);
if ((ts - checkSessionTime) >= checkSessionTimeDiff) {
// 随机选择一个作为检查用的AppId
const randomIndex = Math.floor(Math.random() * appIds.length);
const appId = appIds[randomIndex];
for (let accountId of allAccountIds) {
let sessionInfo = accountsSessionInfo[accountId];
// 只检查有效的账户
if (sessionInfo["valid"] === true) {
let [_, httpCode] = await getAppTestFlightJson(accountId, sessionInfo, appId);
if (httpCode === 401) {
// 修改账户Session为失效
sessionInfo["valid"] = false;
$.data.write(tfSessionInfoKey, sessionInfo, accountId);
$.notification.post(`${accountId} 的 Session 已过期，请重新登录`);
} else if (httpCode === 404) {
$.logger.warning(`Session有效性检查异常，所配置的AppId不正确`);
} else if (httpCode === 200) {
// 修改账户Session为有效
sessionInfo["valid"] = true;
$.data.write(tfSessionInfoKey, sessionInfo, accountId);
$.logger.info(`${accountId} Session 有效性检查通过`);
}
}
}
// 更新检查时间
$.data.write(tfCheckSessionTimeKey, ts);
}
let invalidAppIds = $.data.read(tfInvalidAppIdKey, []);
// 移除已被判断为无效的AppId
appIds = appIds.filter((appId) => appId && !invalidAppIds.includes(appId));
allAccountIds = allAccountIds.filter((accountId) => {
return accountsSessionInfo[accountId]["valid"] === true
});
// 判断是否存在专门用于检查TF是否可加入的账户
let checkAccountSessionInfo = blankSessionInfo;
if (tfCheckAccountId && !allAccountIds.includes(tfCheckAccountId)) {
// 移除检查账户
$.logger.error(`存在用于检查的账户 ${tfCheckAccountId} ，但是该账户未配置Session`);
return;
} else if (tfCheckAccountId) {
// 从账户Session中获取用于检查TF可用性账户的session
checkAccountSessionInfo = accountsSessionInfo[tfCheckAccountId];
$.logger.info(`使用账户 ${tfCheckAccountId} 检查TF可用性`);
} else {
// 未指定用于检查的账户，随机获取一个账户
tfCheckAccountId = allAccountIds[Math.floor(Math.random() * allAccountIds.length)];
$.logger.info(`随机使用账户 ${tfCheckAccountId} 检查TF可用性`);
checkAccountSessionInfo = accountsSessionInfo[tfCheckAccountId];
}
let appJoinAccountIds = {};
let openAppInfo = {}; // 可加入的AppId
let checkAppPromise = [];
// 获取本次需要尝试加入的AppId
for (let appId of appIds) {
const accountIds = allAccountIds.filter(accountId => (
accountsJoinedAppIds[accountId] &&
!accountsJoinedAppIds[accountId].includes(appId) &&
!accountsJoinedAppIds[accountId].includes("*")
) ||
!accountsJoinedAppIds[accountId]
);
if (accountIds.length > 0) {
appJoinAccountIds[appId] = accountIds;
checkAppPromise.push(checkAppIsOpen(tfCheckAccountId, checkAccountSessionInfo, appId));
} else {
$.logger.info(`没有任何账户可以加入App [${appId}] 的Beta测试员\n可能已全部加入完成，或账户Session已过期`);
}
}
await Promise.all(checkAppPromise).then(appInfos => {
for (let _appInfo of appInfos) {
if (_appInfo && _appInfo["app_id"] && _appInfo["http_code"] === 200) {
openAppInfo[_appInfo["app_id"]] = appJoinAccountIds[_appInfo["app_id"]];
}
}
}).catch(e => {
$.logger.error(`检查App是否可加入异常：${e}`);
});
// 尝试加入所有开放的AppId
let joinPromise = [];
for (let appId in openAppInfo) {
if (appId !== "") {
let temp = await startJoinAppTestFlight(openAppInfo[appId], accountsSessionInfo, appId)
joinPromise = joinPromise.concat(temp);
}
}
// 执行加入Beta测试员
await Promise.all(joinPromise).then(results => {
let messages = {};
for (let val of results) {
if (val[0] === true) {
const key = `${val[1]}-${val[3]}`
if (!(key in messages)) {
messages[key] = val;
}
}
}
// 发送通知
for (let key in messages) {
$.notification.post(`${scriptName}-${messages[key][3]}`, `已成功加入[${messages[key][2]}]的Beta测试员`);
}
}).catch(err => {
$.logger.error(err);
})
} catch (err) {
$.logger.info(`自动加入TestFlight出现异常\n${err}`);
}
}
async function loop() {
let i = 0;
while (true) {
if (tfLoopCount > 0 && i >= tfLoopCount) {
break;
}
i++;
await new Promise(resolve => setTimeout(async () => {
await crowd();
resolve();
}, 800));
}
}
(async () => {
let response = null;
let url;
let headers;
let body;
try {
// $.notification.post(`链接匹配：${$.request.url}`);
if ($.isResponse) {
if (getFullAppIdRegex.test($.request.url)) {
await autoAddAppId();
} else if (getSessionRegex.test($.request.url)) {
await getTFSessionInfo();
response = await getAllAppData();
} else {
$.logger.warning(`意外的HTTP Request匹配，URL：${$.request.url}\n请检查配置是否正确`);
}
} else if ($.isRequest) {
if (modifyTFRequest.test($.request.url) ||
modifySettingsTFRequest.test($.request.url) ||
modifyInstallTFRequest.test($.request.url)) {
[url, headers, body] = modifyRequest();
} else {
[url, headers, body] = [$.request.url, $.request.headers, $.request.body];
$.logger.warning(`意外的HTTP Response匹配，URL：${$.request.url}\n请检查配置是否正确`);
}
} else {
$.logger.info(`开始监控App的Beta测试状态`);
await loop();
}
} catch (err) {
console.log("出错了\n" + err);
} finally {
if ($.isResponse) {
if (response) {
$.done(response);
} else {
$.done();
}
} else if ($.isRequest) {
$.done({url, headers, body});
} else {
$.done();
}
}
})();
/**
*
* $$\ $$\ $$\ $$$$$\ $$$$$$\ $$$$$$\
* $$$\ $$$ | \__| \__$$ |$$ __$$\ $$ ___$$\
* $$$$\ $$$$ | $$$$$$\ $$$$$$\ $$\ $$$$$$$\ $$ |$$ / \__| \_/ $$ |
* $$\$$\$$ $$ | \____$$\ $$ __$$\ $$ |$$ _____| $$ |\$$$$$$\ $$$$$ /
* $$ \$$$ $$ | $$$$$$$ |$$ / $$ |$$ |$$ / $$\ $$ | \____$$\ \___$$\
* $$ |\$ /$$ |$$ __$$ |$$ | $$ |$$ |$$ | $$ | $$ |$$\ $$ | $$\ $$ |
* $$ | \_/ $$ |\$$$$$$$ |\$$$$$$$ |$$ |\$$$$$$$\\$$$$$$ |\$$$$$$ | \$$$$$$ |
* \__| \__| \_______| \____$$ |\__| \_______|\______/ \______/ \______/
* $$\ $$ |
* \$$$$$$ |
* \______/
*
*/
// @formatter:off
[MagicJS3] 更新框架代码
2022-12-31 22:02:33 +08:00
function MagicJS(scriptName="MagicJS",logLevel="INFO"){const MagicEnvironment=()=>{const isLoon=typeof $loon!=="undefined";const isQuanX=typeof $task!=="undefined";const isNode=typeof module!=="undefined";const isSurge=typeof $httpClient!=="undefined"&&!isLoon;const isStorm=typeof $storm!=="undefined";const isStash=typeof $environment!=="undefined"&&typeof $environment["stash-build"]!=="undefined";const isSurgeLike=isSurge||isLoon||isStorm||isStash;const isScriptable=typeof importModule!=="undefined";return{isLoon:isLoon,isQuanX:isQuanX,isNode:isNode,isSurge:isSurge,isStorm:isStorm,isStash:isStash,isSurgeLike:isSurgeLike,isScriptable:isScriptable,get name(){if(isLoon){return"Loon"}else if(isQuanX){return"QuantumultX"}else if(isNode){return"NodeJS"}else if(isSurge){return"Surge"}else if(isScriptable){return"Scriptable"}else{return"unknown"}},get build(){if(isSurge){return $environment["surge-build"]}else if(isStash){return $environment["stash-build"]}else if(isStorm){return $storm.buildVersion}},get language(){if(isSurge||isStash){return $environment["language"]}},get version(){if(isSurge){return $environment["surge-version"]}else if(isStash){return $environment["stash-version"]}else if(isStorm){return $storm.appVersion}else if(isNode){return process.version}},get system(){if(isSurge){return $environment["system"]}else if(isNode){return process.platform}},get systemVersion(){if(isStorm){return $storm.systemVersion}},get deviceName(){if(isStorm){return $storm.deviceName}}}};const MagicLogger=(scriptName,logLevel="INFO")=>{let _level=logLevel;const logLevels={SNIFFER:6,DEBUG:5,INFO:4,NOTIFY:3,WARNING:2,ERROR:1,CRITICAL:0,NONE:-1};const logEmoji={SNIFFER:"",DEBUG:"",INFO:"",NOTIFY:"",WARNING:"❗ ",ERROR:"❌ ",CRITICAL:"❌ ",NONE:""};const _log=(msg,level="INFO")=>{if(!(logLevels[_level]<logLevels[level.toUpperCase()]))console.log(`[${level}] [${scriptName}]\n${logEmoji[level.toUpperCase()]}${msg}\n`)};const setLevel=logLevel=>{_level=logLevel};return{getLevel:()=>{return _level},setLevel:setLevel,sniffer:msg=>{_log(msg,"SNIFFER")},debug:msg=>{_log(msg,"DEBUG")},info:msg=>{_log(msg,"INFO")},notify:msg=>{_log(msg,"NOTIFY")},warning:msg=>{_log(msg,"WARNING")},error:msg=>{_log(msg,"ERROR")},retry:msg=>{_log(msg,"RETRY")}}};return new class{constructor(scriptName,logLevel){this._startTime=Date.now();this.version="3.0.0";this.scriptName=scriptName;this.env=MagicEnvironment();this.logger=MagicLogger(scriptName,logLevel);this.http=typeof MagicHttp==="function"?MagicHttp(this.env,this.logger):undefined;this.data=typeof MagicData==="function"?MagicData(this.env,this.logger):undefined;this.notification=typeof MagicNotification==="function"?MagicNotification(this.scriptName,this.env,this.logger,this.http):undefined;this.utils=typeof MagicUtils==="function"?MagicUtils(this.env,this.logger):undefined;this.qinglong=typeof MagicQingLong==="function"?MagicQingLong(this.env,this.data,this.logger):undefined;if(typeof this.data!=="undefined"){let magicLoglevel=this.data.read("magic_loglevel");const barkUrl=this.data.read("magic_bark_url");if(magicLoglevel){this.logger.setLevel(magicLoglevel.toUpperCase())}if(barkUrl){this.notification.setBark(barkUrl)}}}get isRequest(){return typeof $request!=="undefined"&&typeof $response==="undefined"}get isResponse(){return typeof $response!=="undefined"}get isDebug(){return this.logger.level==="DEBUG"}get request(){return typeof $request!=="undefined"?$request:undefined}get response(){if(typeof $response!=="undefined"){if($response.hasOwnProperty("status"))$response["statusCode"]=$response["status"];if($response.hasOwnProperty("statusCode"))$response["status"]=$response["statusCode"];return $response}else{return undefined}}done=(value={})=>{this._endTime=Date.now();let span=(this._endTime-this._startTime)/1e3;this.logger.info(`SCRIPT COMPLETED: ${span} S.`);if(typeof $done!=="undefined"){$done(value)}}}(scriptName,logLevel)}
function MagicHttp(env,logger){const phoneUA="Mozilla/5.0 (iPhone; CPU iPhone OS 13_3_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/13.0.5 Mobile/15E148 Safari/604.1";const computerUA="Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/84.0.4147.125 Safari/537.36 Edg/84.0.522.59";let axiosInstance;if(env.isNode){const axios=require("axios");axiosInstance=axios.create()}class InterceptorManager{constructor(isRequest=true){this.handlers=[];this.isRequest=isRequest}use(fulfilled,rejected,options){if(typeof fulfilled==="function"){logger.debug(`Register fulfilled ${fulfilled.name}`)}if(typeof rejected==="function"){logger.debug(`Register rejected ${rejected.name}`)}this.handlers.push({fulfilled:fulfilled,rejected:rejected,synchronous:options&&typeof options.synchronous==="boolean"?options.synchronous:false,runWhen:options?options.runWhen:null});return this.handlers.length-1}eject(id){if(this.handlers[id]){this.handlers[id]=null}}forEach(fn){this.handlers.forEach(element=>{if(element!==null){fn(element)}})}}function paramsToQueryString(config){let _config={...config};if(!!_config.params){if(!env.isNode){let qs=Object.keys(_config.params).map(key=>{const encodeKey=encodeURIComponent(key);_config.url=_config.url.replace(new RegExp(`${key}=[^&]*`,"ig"),"");_config.url=_config.url.replace(new RegExp(`${encodeKey}=[^&]*`,"ig"),"");return`${encodeKey}=${encodeURIComponent(_config.params[key])}`}).join("&");if(_config.url.indexOf("?")<0)_config.url+="?";if(!/(&|\?)$/g.test(_config.url)){_config.url+="&"}_config.url+=qs;delete _config.params;logger.debug(`Params to QueryString: ${_config.url}`)}}return _config}const mergeConfig=(method,configOrUrl)=>{let config=typeof configOrUrl==="object"?{headers:{},...configOrUrl}:{url:configOrUrl,headers:{}};if(!config.method){config["method"]=method}config=paramsToQueryString(config);if(config["rewrite"]===true){if(env.isSurge){config.headers["X-Surge-Skip-Scripting"]=false;delete config["rewrite"]}else if(env.isQuanX){config["hints"]=false;delete config["rewrite"]}}if(env.isSurgeLike){const contentType=config.headers["content-type"]||config.headers["Content-Type"];if(config["method"]!=="GET"&&contentType&&contentType.indexOf("application/json")>=0&&config.body instanceof Array){config.body=JSON.stringify(config.body);logger.debug(`Convert Array object to String: ${config.body}`)}}else if(env.isQuanX){if(config.hasOwnProperty("body")&&typeof config["body"]!=="string")config["body"]=JSON.stringify(config["body"]);config["method"]=method}else if(env.isNode){if(method==="POST"||method==="PUT"||method==="PATCH"||method==="DELETE"){config.data=config.data||config.body}else if(method==="GET"){config.params=config.params||config.body}delete config.body}return config};const modifyResponse=(resp,config=null)=>{if(resp){let _resp={...resp,config:resp.config||config,status:resp.statusCode||resp.status,body:resp.body||resp.data,headers:resp.headers||resp.header};if(typeof _resp.body==="string"){try{_resp.body=JSON.parse(_resp.body)}catch{}}delete _resp.data;return _resp}else{return resp}};const convertHeadersToLowerCase=headers=>{return Object.keys(headers).reduce((acc,key)=>{acc[key.toLowerCase()]=headers[key];return acc},{})};const convertHeadersToCamelCase=headers=>{return Object.keys(headers).reduce((acc,key)=>{const newKey=key.split("-").map(word=>word[0].toUpperCase()+word.slice(1)).join("-");acc[newKey]=headers[key];return acc},{})};const raiseExceptionByStatusCode=(resp,config=null)=>{if(!!resp&&resp.status>=400){logger.debug(`Raise exception when status code is ${resp.status}`);return{name:"RequestException",message:`Request failed with status code ${resp.status}`,config:config||resp.config,response:resp}}};const interceptors={request:new InterceptorManager,response:new InterceptorManager(false)};let requestInterceptorChain=[];let responseInterceptorChain=[];let synchronousRequestInterceptors=true;function interceptConfig(config){config=paramsToQueryString(config);logger.debug(`HTTP ${config["method"].toUpperCase()}:\n${JSON.stringify(confi
function MagicData(env,logger){let node={fs:undefined,data:{}};if(env.isNode){node.fs=require("fs");try{node.fs.accessSync("./magic.json",node.fs.constants.R_OK|node.fs.constants.W_OK)}catch(err){node.fs.writeFileSync("./magic.json","{}",{encoding:"utf8"})}node.data=require("./magic.json")}const defaultValueComparator=(oldVal,newVal)=>{if(typeof newVal==="object"){return false}else{return oldVal===newVal}};const _typeConvertor=val=>{if(val==="true"){return true}else if(val==="false"){return false}else if(typeof val==="undefined"){return null}else{return val}};const _valConvertor=(val,default_,session,read_no_session)=>{if(session){try{if(typeof val==="string")val=JSON.parse(val);if(val["magic_session"]===true){val=val[session]}else{val=null}}catch{val=null}}if(typeof val==="string"&&val!=="null"){try{val=JSON.parse(val)}catch{}}if(read_no_session===false&&!!val&&val["magic_session"]===true){val=null}if((val===null||typeof val==="undefined")&&default_!==null&&typeof default_!=="undefined"){val=default_}val=_typeConvertor(val);return val};const convertToObject=obj=>{if(typeof obj==="string"){let data={};try{data=JSON.parse(obj);const type=typeof data;if(type!=="object"||data instanceof Array||type==="bool"||data===null){data={}}}catch{}return data}else if(obj instanceof Array||obj===null||typeof obj==="undefined"||obj!==obj||typeof obj==="boolean"){return{}}else{return obj}};const readForNode=(key,default_=null,session="",read_no_session=false,externalData=null)=>{let data=externalData||node.data;if(!!data&&typeof data[key]!=="undefined"&&data[key]!==null){val=data[key]}else{val=!!session?{}:null}val=_valConvertor(val,default_,session,read_no_session);return val};const read=(key,default_=null,session="",read_no_session=false,externalData=null)=>{let val="";if(externalData||env.isNode){val=readForNode(key,default_,session,read_no_session,externalData)}else{if(env.isSurgeLike){val=$persistentStore.read(key)}else if(env.isQuanX){val=$prefs.valueForKey(key)}val=_valConvertor(val,default_,session,read_no_session)}logger.debug(`READ DATA [${key}]${!!session?`[${session}]`:""} <${typeof val}>\n${JSON.stringify(val)}`);return val};const writeForNode=(key,val,session="",externalData=null)=>{let data=externalData||node.data;data=convertToObject(data);if(!!session){let obj=convertToObject(data[key]);obj["magic_session"]=true;obj[session]=val;data[key]=obj}else{data[key]=val}if(externalData!==null){externalData=data}return data};const write=(key,val,session="",externalData=null)=>{if(typeof val==="undefined"||val!==val){return false}if(!env.isNode&&(typeof val==="boolean"||typeof val==="number")){val=String(val)}let data="";if(externalData||env.isNode){data=writeForNode(key,val,session,externalData)}else{if(!session){data=val}else{if(env.isSurgeLike){data=!!$persistentStore.read(key)?$persistentStore.read(key):data}else if(env.isQuanX){data=!!$prefs.valueForKey(key)?$prefs.valueForKey(key):data}data=convertToObject(data);data["magic_session"]=true;data[session]=val}}if(!!data&&typeof data==="object"){data=JSON.stringify(data,null,4)}logger.debug(`WRITE DATA [${key}]${session?`[${session}]`:""} <${typeof val}>\n${JSON.stringify(val)}`);if(!externalData){if(env.isSurgeLike){return $persistentStore.write(data,key)}else if(env.isQuanX){return $prefs.setValueForKey(data,key)}else if(env.isNode){try{node.fs.writeFileSync("./magic.json",data);return true}catch(err){logger.error(err);return false}}}return true};const update=(key,val,session,comparator=defaultValueComparator,externalData=null)=>{val=_typeConvertor(val);const oldValue=read(key,null,session,false,externalData);if(comparator(oldValue,val)===true){return false}else{const result=write(key,val,session,externalData);let newVal=read(key,null,session,false,externalData);if(comparator===defaultValueComparator&&typeof newVal==="object"){return result}return comparator(val,newVal)}};const delForNode=(key,session,externalData)=>{let data=externalData||node.data;data=convertToObject(data);if(!!session){obj=convertToObject(data[key]);delete obj[session];data[key]=obj}else{delete data[key]}i
function MagicNotification(scriptName,env,logger,http){let _barkUrl=null;let _barkKey=null;const setBark=url=>{try{let _url=url.replace(/\/+$/g,"");_barkUrl=`${/^https?:\/\/([^/]*)/.exec(_url)[0]}/push`;_barkKey=/\/([^\/]+)\/?$/.exec(_url)[1]}catch(ex){logger.error(`Bark url error: ${ex}.`)}};function post(title=scriptName,subTitle="",body="",opts=""){const _adaptOpts=_opts=>{try{let newOpts={};if(typeof _opts==="string"){if(env.isLoon)newOpts={openUrl:_opts};else if(env.isQuanX)newOpts={"open-url":_opts};else if(env.isSurge)newOpts={url:_opts}}else if(typeof _opts==="object"){if(env.isLoon){newOpts["openUrl"]=!!_opts["open-url"]?_opts["open-url"]:"";newOpts["mediaUrl"]=!!_opts["media-url"]?_opts["media-url"]:""}else if(env.isQuanX){newOpts=!!_opts["open-url"]||!!_opts["media-url"]?_opts:{}}else if(env.isSurge){let openUrl=_opts["open-url"]||_opts["openUrl"];newOpts=openUrl?{url:openUrl}:{}}}return newOpts}catch(err){logger.error(`通知选项转换失败${err}`)}return _opts};opts=_adaptOpts(opts);if(arguments.length===1){title=scriptName;subTitle="",body=arguments[0]}logger.notify(`title:${title}\nsubTitle:${subTitle}\nbody:${body}\noptions:${typeof opts==="object"?JSON.stringify(opts):opts}`);if(env.isSurge){$notification.post(title,subTitle,body,opts)}else if(env.isLoon){if(!!opts)$notification.post(title,subTitle,body,opts);else $notification.post(title,subTitle,body)}else if(env.isQuanX){$notify(title,subTitle,body,opts)}if(_barkUrl&&_barkKey){bark(title,subTitle,body)}}function debug(title=scriptName,subTitle="",body="",opts=""){if(logger.getLevel()==="DEBUG"){if(arguments.length===1){title=scriptName;subTitle="";body=arguments[0]}this.post(title,subTitle,body,opts)}}function bark(title=scriptName,subTitle="",body="",opts=""){if(typeof http==="undefined"||typeof http.post==="undefined"){throw"Bark notification needs to import MagicHttp module."}let options={url:_barkUrl,headers:{"content-type":"application/json; charset=utf-8"},body:{title:title,body:subTitle?`${subTitle}\n${body}`:body,device_key:_barkKey}};http.post(options).catch(ex=>{logger.error(`Bark notify error: ${ex}`)})}return{post:post,debug:debug,bark:bark,setBark:setBark}}
function MagicUtils(env,logger){const retry=(fn,retries=5,interval=0,callback=null)=>{return(...args)=>{return new Promise((resolve,reject)=>{function _retry(...args){Promise.resolve().then(()=>fn.apply(this,args)).then(result=>{if(typeof callback==="function"){Promise.resolve().then(()=>callback(result)).then(()=>{resolve(result)}).catch(ex=>{if(retries>=1){if(interval>0)setTimeout(()=>_retry.apply(this,args),interval);else _retry.apply(this,args)}else{reject(ex)}retries--})}else{resolve(result)}}).catch(ex=>{logger.error(ex);if(retries>=1&&interval>0){setTimeout(()=>_retry.apply(this,args),interval)}else if(retries>=1){_retry.apply(this,args)}else{reject(ex)}retries--})}_retry.apply(this,args)})}};const formatTime=(time,fmt="yyyy-MM-dd hh:mm:ss")=>{let o={"M+":time.getMonth()+1,"d+":time.getDate(),"h+":time.getHours(),"m+":time.getMinutes(),"s+":time.getSeconds(),"q+":Math.floor((time.getMonth()+3)/3),S:time.getMilliseconds()};if(/(y+)/.test(fmt))fmt=fmt.replace(RegExp.$1,(time.getFullYear()+"").substr(4-RegExp.$1.length));for(let k in o)if(new RegExp("("+k+")").test(fmt))fmt=fmt.replace(RegExp.$1,RegExp.$1.length===1?o[k]:("00"+o[k]).substr((""+o[k]).length));return fmt};const now=()=>{return formatTime(new Date,"yyyy-MM-dd hh:mm:ss")};const today=()=>{return formatTime(new Date,"yyyy-MM-dd")};const sleep=time=>{return new Promise(resolve=>setTimeout(resolve,time))};const assert=(val,msg=null)=>{if(env.isNode){const _assert=require("assert");if(msg)_assert(val,msg);else _assert(val)}else{if(val!==true){let err=`AssertionError: ${msg||"The expression evaluated to a falsy value."}`;logger.error(err)}}};return{retry:retry,formatTime:formatTime,now:now,today:today,sleep:sleep,assert:assert}}
function MagicQingLong(env,data,logger){let qlUrl="";let qlName="";let qlClient="";let qlSecret="";let qlPwd="";let qlToken="";const magicJsonFileName="magic.json";const timeout=3e3;const http=(()=>MagicHttp(env,logger))();const init=(url,clientId,clientSecret,username,password)=>{qlUrl=url;qlClient=clientId;qlSecret=clientSecret;qlName=username;qlPwd=password};function readQingLongConfig(config){qlUrl=qlUrl||data.read("magic_qlurl");qlToken=qlToken||data.read("magic_qltoken");logger.debug(`QingLong url: ${qlUrl}\nQingLong token: ${qlToken}`);return config}function setBaseUrlAndTimeout(config){if(!qlUrl){qlUrl=data.read("magic_qlurl")}if(config.url.indexOf(qlUrl)<0){config.url=`${qlUrl}${config.url}`}return{...config,timeout:timeout}}function setTimestamp(config){config.params={...config.params,t:Date.now()};return config}async function setAuthorization(config){qlToken=qlToken||data.read("magic_qltoken","");if(!qlToken){await getToken()}config.headers["authorization"]=`Bearer ${qlToken}`;return config}function switchClientMode(config){qlClient=qlClient||data.read("magic_qlclient");if(!!qlClient){config.url=config.url.replace("/api/","/open/")}return config}async function refreshToken(error){try{const message=error.message||error.error||JSON.stringify(error);if((message.indexOf("NSURLErrorDomain")>=0&&message.indexOf("-1012")>=0||!!error.response&&error.response.status===401)&&!!error.config&&error.config.refreshToken!==true){logger.warning(`QingLong Panel token has expired`);logger.info("Refreshing the QingLong Panel token");await getToken();error.config["refreshToken"]=true;logger.info("Call the previous method again");return await http.request(error.config.method,error.config)}else{return Promise.reject(error)}}catch(ex){return Promise.reject(ex)}}http.interceptors.request.use(setBaseUrlAndTimeout,undefined);http.interceptors.request.use(switchClientMode,undefined,{runWhen:config=>{return config.url.indexOf("api/user/login")<0&&config.url.indexOf("open/auth/token")<0}});http.interceptors.request.use(setAuthorization,undefined,{runWhen:config=>{return config.url.indexOf("api/user/login")<0&&config.url.indexOf("open/auth/token")<0}});http.interceptors.request.use(setTimestamp,undefined,{runWhen:config=>{return config.url.indexOf("open/auth/token")<0}});http.interceptors.request.use(readQingLongConfig,undefined);http.interceptors.response.use(undefined,refreshToken);async function getToken(){qlClient=qlClient||data.read("magic_qlclient");qlSecret=qlSecret||data.read("magic_qlsecrt");qlName=qlName||data.read("magic_qlname");qlPwd=qlPwd||data.read("magic_qlpwd");if(qlUrl&&qlClient&&qlSecret){logger.info("Get token from QingLong Panel");await http.get({url:`/open/auth/token`,headers:{"content-type":"application/json"},params:{client_id:qlClient,client_secret:qlSecret}}).then(resp=>{if(Object.keys(resp.body).length>0&&resp.body.data&&resp.body.data.token){logger.info("Successfully logged in to QingLong Panel");qlToken=resp.body.data.token;data.write("magic_qltoken",qlToken)}else{throw new Error("Get QingLong Panel token failed.")}}).catch(err=>{logger.error(`Error logging in to QingLong Panel.\n${err.message||err}`)})}else if(qlUrl&&qlName&&qlPwd){await http.post({url:`/api/user/login`,headers:{"content-type":"application/json"},body:{username:qlName,password:qlPwd}}).then(resp=>{logger.info("Successfully logged in to QingLong Panel");qlToken=resp.body.data.token;data.write("magic_qltoken",qlToken)}).catch(err=>{logger.error(`Error logging in to QingLong Panel.\n${err.message||err}`)})}return qlToken}async function setEnv(name,value,id=null){qlUrl=qlUrl||data.read("magic_qlurl");if(id===null){let envIds=await setEnvs([{name:name,value:value}]);if(!!envIds&&envIds.length===1){return envIds[0]}}else{await http.put({url:`/api/envs`,headers:{"content-type":"application/json"},body:{name:name,value:value,id:id}}).then(resp=>{if(resp.body.code===200){logger.debug(`QINGLONG UPDATE ENV ${name} <${typeof value}> (${id})\n${JSON.stringify(value)}`);return true}else{logger.error(`Error adding environment variable from QingLong Panel.\n
[TestFlight] 多账户共存与支持青龙面板的自动加入
2022-12-22 20:56:42 +08:00
// @formatter:on