wubianHelper.js 68 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044
  1. /*
  2. 无边星链助手
  3. [Script]
  4. # > 无边星链助手
  5. ^https?:\/\/api\.wubian\.pro url script-request-body https://git.jojo21.top/shawenguan/Quantumult-X/raw/master/Scripts/wubian/wubianHelper.js
  6. ^https?:\/\/api\.wubian\.pro url script-response-body https://git.jojo21.top/shawenguan/Quantumult-X/raw/master/Scripts/wubian/wubianHelper.js
  7. [MITM]
  8. hostname = api.wubian.pro
  9. */
  10. const scriptName = `无边星链助手`;
  11. const magicJS = MagicJS(scriptName, "INFO");
  12. const WuBianConstKey = {
  13. // 基础数据
  14. UserInfo: 'WubianUserInfo',
  15. Token: 'WubianProToken',
  16. BrowserProxyUrl: 'WubianBrowserProxyUrl',
  17. TenantId: 'WubianTenantId',
  18. AllMarketGroupListData: 'WubianAllMarketGroupListData',
  19. ActivityListData: 'WubianActivityListData',
  20. ActivityGoodsList: 'WubianActivityGoodsList',
  21. ActivityTaskCaptureEnabled: 'WubianActivityTaskCaptureEnabled',
  22. ActivityTagName: 'WubianActivityActivityTagName',
  23. ActivityIndexName: 'WubianActivityIndexName',
  24. ActivityId: 'WubianActivityId',
  25. SynthesisConcurrentMode: 'WubianSynthesisConcurrentMode',
  26. SynthesisRunsPerSecond: 'WubianSynthesisRunsPerSecond',
  27. FirstOrderCaptureEnabled: 'WubianFirstOrderCaptureEnabled',
  28. FirstArtListData: 'WubianFirstArtListData',
  29. FirstGoodsId: 'WubianFirstGoodsId',
  30. FirstGoodsName: 'WubianFirstGoodsName',
  31. CreateFirstOrderData: 'WubianCreateFirstOrderData',
  32. FirstGrabConcurrentMode: 'WubianFirstGrabConcurrentMode',
  33. FirstGrabRunsPerSecond: 'WubianFirstGrabRunsPerSecond',
  34. ConsignmentCaptureEnabled: 'WubianConsignmentCaptureEnabled',
  35. MyCollectListData: 'WubianMyCollectListData',
  36. ConsignmentArtName: 'WubianConsignmentArtName',
  37. ConsignmentArtId: 'WubianConsignmentArtId',
  38. ConsignmentArtPrice: 'WubianConsignmentArtPrice',
  39. ConsignmentArtAmount: 'WubianConsignmentArtAmount',
  40. FastBuyCaptureEnabled: 'WubianFastBuyCaptureEnabled',
  41. FastBuyQuickModeEnabled: 'WubianFastBuyQuickModeEnabled',
  42. FastBuyArtName: 'WubianFastBuyArtName',
  43. FastBuyArtId: 'WubianFastBuyArtId',
  44. FastBuyArtPrice: 'WubianFastBuyArtPrice',
  45. FastBuyArtAmount: 'WubianFastBuyArtAmount',
  46. FastBuyArtInfo: 'WubianFastBuyArtInfo',
  47. };
  48. const gUserAgent = `Mozilla/5.0 (iPhone; CPU iPhone OS 16_6_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 Html5Plus/1.0 (Immersed/20) uni-app`;
  49. const gHost = `api.wubian.pro`;
  50. let gToken = magicJS.data.read(WuBianConstKey.Token, '');
  51. const gCommonHeaders = {
  52. 'Accept': `*/*`,
  53. 'Accept-Encoding': `gzip, deflate, br`,
  54. 'Connection': `keep-alive`,
  55. 'Content-Type': `application/json`,
  56. 'Cookie': `token=${gToken}`,
  57. 'Host': gHost,
  58. 'User-Agent': gUserAgent,
  59. 'CLIENT-TYPE': `APP`,
  60. 'token': gToken,
  61. 'Accept-Language': `zh-CN,zh-Hans;q=0.9`
  62. };
  63. let gRetBody;
  64. async function Main() {
  65. if (magicJS.isStrictRequest) {
  66. magicJS.checkRecordRequestBody();
  67. }
  68. if (magicJS.isRequest) {
  69. checkHandleRequest();
  70. } else {
  71. updateHeaders();
  72. }
  73. magicJS.notification.msg('');
  74. if (gRetBody) {
  75. magicJS.done({
  76. body: JSON.stringify(gRetBody)
  77. });
  78. } else {
  79. magicJS.done();
  80. }
  81. }
  82. function checkHandleRequest() {
  83. const url = $request.url;
  84. const path = $request.path;
  85. magicJS.logger.info(`请求url=${url}#${$request.method}`);
  86. magicJS.logger.info(`请求body=${magicJS.getRequestBody()}`);
  87. if ($request && $request.method != 'OPTIONS') {
  88. switch (path) {
  89. case '/vmf/app/login/mobileLogin':
  90. handleMobileLogin();
  91. break;
  92. case '/vmf/app/user/collect/list':
  93. // 我的-产品品类列表
  94. handleUserCollectList();
  95. break;
  96. case '/vmf/app/user/collect/verList':
  97. // 我的-某一个产品的列表详情
  98. break;
  99. case '/vmf/app/user/getBatchGiveArtIds':
  100. break;
  101. case '/vmf/app/market/goodsInfo':
  102. // 我的-某产品详情
  103. handleGoodsInfo();
  104. break;
  105. case '/vmf/app/common/getInitData':
  106. handleInitData();
  107. break;
  108. case '/vmf/app/index/topBannerList':
  109. break;
  110. case '/vmf/app/index/bannerArticleList':
  111. break;
  112. case '/vmf/app/index/artList':
  113. // 首发产品
  114. handleFirstArtList();
  115. break;
  116. case '/vmf/app/index/firstArtInfo':
  117. // 首发产品详情,市场产品详情
  118. handleFirstArtInfo();
  119. break;
  120. case '/vmf/app/market/confirmArtInfo':
  121. // 首发产品购买信息确认页面
  122. break;
  123. case '/vmf/app/order/createFirstOrder':
  124. // 创建发售订单
  125. break;
  126. case '/vmf/app/index/littleMinerInfo':
  127. break;
  128. case '/vmf/app/article/category':
  129. break;
  130. case '/vmf/app/article/listByCategory':
  131. // 公告列表
  132. handleNoticeList();
  133. break;
  134. case '/vmf/app/article/info':
  135. // 公告详情
  136. handleNoticeInfo();
  137. break;
  138. case '/vmf/app/article/selectArticleByType':
  139. // 产品相关的历史公告
  140. break;
  141. case '/vmf/app/index/recommend':
  142. // 推荐
  143. break;
  144. case '/vmf/app/index/firstArtInfo':
  145. // 产品信息
  146. break;
  147. case '/vmf/app/user/batchRole':
  148. break;
  149. case '/vmf/app/market/albumList':
  150. // 市场分区专辑列表
  151. break;
  152. case '/vmf/app/market/groupList':
  153. // 市场产品寄售列表信息
  154. hadnleMarketGroupList();
  155. break;
  156. case '/vmf/app/market/saleRecord':
  157. // 市场最近成交记录
  158. break;
  159. case '/vmf/app/market/artInfo':
  160. // 市场寄售时产品详情
  161. break;
  162. case '/vmf/app/market/verList':
  163. // 市场某产品寄售列表
  164. break;
  165. case '/vmf/app/order/entrustArtInfo':
  166. // 市场某产品委托限价范围
  167. break;
  168. case '/vmf/app/order/createEntrustOrder':
  169. // 创建委托订单
  170. break;
  171. case '/vmf/app/order/cancelEntrustOrder':
  172. // 取消委托订单
  173. break;
  174. case '/vmf/app/pay/cashier':
  175. // 支付收银台钱包选择列表
  176. break;
  177. case '/vmf/app/pay/getUrl':
  178. // 获取支付地址
  179. break;
  180. case '/vmf/app/pay/payResult':
  181. break;
  182. case '/vmf/app/synthesis/activityList':
  183. handleActivityList();
  184. break;
  185. case '/vmf/app/synthesis/convertGoodsList':
  186. handleCvtGoodsList();
  187. break;
  188. case '/vmf/app/synthesis/createConvertOrder':
  189. break;
  190. case '/vmf/app/synthesis/compositeGoodsList':
  191. handleCompositeGoodsList();
  192. break;
  193. case '/vmf/app/synthesis/createCompositeOrder':
  194. break;
  195. case 'vmf/app/order/list':
  196. // 订单列表
  197. handleOrderList();
  198. break;
  199. case '/vmf/app/order/info':
  200. // 订单详情
  201. handleOrderInfo();
  202. break;
  203. default:
  204. if (path.indexOf('/vmf/app/order/createFirstOrder') != -1) {
  205. handleCreateFirstOrder();
  206. }
  207. break;
  208. }
  209. }
  210. }
  211. function handleHeaders() {
  212. if ($request && $request.method != 'OPTIONS') {
  213. let headers = $request.headers;
  214. let newToken = headers['token'];
  215. let oldToken = magicJS.data.read(WuBianConstKey.Token, null);
  216. if (newToken) {
  217. if (newToken != oldToken) {
  218. magicJS.logger.info(`当前Token刷新到最新`);
  219. magicJS.notification.appendNotifyInfo(`🎉当前Token刷新到最新`);
  220. } else {
  221. magicJS.logger.info(`当前Token已经是最新无需更新`);
  222. }
  223. magicJS.data.write(WuBianConstKey.Token, newToken);
  224. } else {
  225. let newCookieStr = headers['Cookie'];
  226. if (newCookieStr) {
  227. let cookieDict = magicJS.parseCookies(newCookieStr);
  228. if (cookieDict['token'] != void 0) {
  229. newToken = ookieDict['token'];
  230. magicJS.data.write(WuBianConstKey.Token, newToken);
  231. magicJS.logger.info(`当前Token刷新到最新`);
  232. }
  233. }
  234. }
  235. }
  236. }
  237. function updateHeaders() {
  238. gToken = magicJS.data.read(WuBianConstKey.Token, '');
  239. gCommonHeaders['token'] = gToken;
  240. gCommonHeaders['cookie'] = `token=${gToken}`;
  241. }
  242. function getResponsePlainData() {
  243. let data = magicJS.getResponseBody();
  244. if (!data) {
  245. return;
  246. }
  247. try {
  248. return JSON.parse(data);
  249. } catch (err) {
  250. magicJS.logger.info(data);
  251. magicJS.logger.error(err);
  252. }
  253. }
  254. function getRequestPlainData() {
  255. let data = magicJS.getRequestBody();
  256. let reqData = null;
  257. if (data) {
  258. reqData = JSON.parse(data);
  259. } else {
  260. reqData = magicJS.parseQueryStr($request.url);
  261. }
  262. return reqData;
  263. }
  264. function getQueryPlainData() {
  265. let params = magicJS.parseQueryStr($request.url);
  266. return params;
  267. }
  268. function compareCookieStr(cookieStr1, cookieStr2) {
  269. let cookieDict1 = magicJS.parseCookies(cookieStr1);
  270. let cookieDict2 = magicJS.parseCookies(cookieStr2);
  271. let skipKeys = [];
  272. let retCode = 0;
  273. for (let key in cookieDict1) {
  274. if (!skipKeys.includes(key)) {
  275. if (cookieDict1[key] != void 0 && cookieDict2[key] != void 0 && cookieDict1[key] != cookieDict2[key]) {
  276. magicJS.logger.info(`${key}`);
  277. retCode = -1;
  278. break;
  279. }
  280. }
  281. }
  282. return retCode;
  283. }
  284. function appendCookieStr(newCookieStr) {
  285. let cookieStr = magicJS.data.read(WuBianConstKey.Cookie, null);
  286. let cookieDict = magicJS.parseCookies(cookieStr);
  287. let newCookieDict = magicJS.parseCookies(newCookieStr);
  288. for (let key in newCookieDict) {
  289. cookieDict[key] = newCookieDict[key];
  290. }
  291. cookieStr = magicJS.serializeCookies(cookieDict);
  292. magicJS.data.write(WuBianConstKey.Cookie, cookieStr);
  293. }
  294. function handleMobileLogin() {
  295. let rspData = getResponsePlainData();
  296. if (!rspData) {
  297. return;
  298. }
  299. if (rspData.code != 200) {
  300. return;
  301. }
  302. /*
  303. // 结果示例:
  304. let result = {
  305. "code": 200,
  306. "data": {
  307. "rankInfoHide": 0,
  308. "hashId": "80n19034n1",
  309. "cancellation": 0,
  310. "mobile": "134*****115",
  311. "isAuth": 1,
  312. "isSecurityPassword": 1,
  313. "tokenExpireTime": 1728625959,
  314. "avatar": "/assets/img/avatar01.png",
  315. "token": "bccafa59-d04c-48c9-82f6-08829155b2c6",
  316. "address": "0x3dc7d16739d0f169977f589788007c33a0e8996d",
  317. "locksold": 0,
  318. "gameUserId": 0,
  319. "nickname": "WBXL-9115",
  320. "email": "",
  321. "score": 0,
  322. "lockown": 0
  323. },
  324. "msg": "成功",
  325. "fail": false
  326. }
  327. */
  328. magicJS.data.write(WuBianConstKey.UserInfo, rspData.data);
  329. let token = rspData.data.token;
  330. let expireDate = new Date(rspData.data.tokenExpireTime * 1000);
  331. magicJS.data.write(WuBianConstKey.Token, token);
  332. magicJS.notification.appendNotifyInfo(`🎉当前Token刷新到最新,过期时间:${magicJS.formatDate(expireDate, 'yyyy-MM-dd HH:mm:ss')}`);
  333. }
  334. function handleUserCollectList() {
  335. let rspData = getResponsePlainData();
  336. if (!rspData) {
  337. return;
  338. }
  339. if (rspData.code != 200) {
  340. return;
  341. }
  342. handleHeaders();
  343. }
  344. function handleInitData() {
  345. let rspData = getResponsePlainData();
  346. if (!rspData) {
  347. return;
  348. }
  349. if (rspData.code != 200) {
  350. return;
  351. }
  352. handleHeaders();
  353. }
  354. function handleNoticeList() {
  355. let rspData = getResponsePlainData();
  356. if (!rspData) {
  357. return;
  358. }
  359. if (rspData.code != 200) {
  360. return;
  361. }
  362. let reqData = getRequestPlainData();
  363. let tenantId = reqData.tenantId;
  364. magicJS.data.write(WuBianConstKey.TenantId, tenantId);
  365. if (reqData.page == 1) {
  366. let oneNotice = {
  367. "hashId": "468xab6e",
  368. "category": "系统公告",
  369. "icon": "/uploads/icon/系统公告.png",
  370. "title": "【神秘空间】应有尽有等你来探索!",
  371. "image": "",
  372. "createdTime": magicJS.formatDate(new Date(), 'yyyy-MM-dd HH:mm:ss'),
  373. "type": 0,
  374. "categoryType": 6,
  375. "url": ""
  376. };
  377. rspData.data.list.splice(1, 0, oneNotice);
  378. gRetBody = rspData;
  379. }
  380. }
  381. function handleNoticeInfo() {
  382. let rspData = getResponsePlainData();
  383. if (!rspData) {
  384. return;
  385. }
  386. let reqData = getRequestPlainData();
  387. let hashId = reqData.hashId;
  388. if (hashId == '468xab6e') {
  389. let marketGroupLstDict = magicJS.data.read(WuBianConstKey.AllMarketGroupListData, {});
  390. let baseList = [];
  391. let relationList = [];
  392. let sortId = 1;
  393. for (let artId in marketGroupLstDict) {
  394. const artInfo = marketGroupLstDict[artId];
  395. const artInfoA = {
  396. hash_id: artInfo.artId,
  397. id: sortId,
  398. image: artInfo.image,
  399. title: artInfo.title,
  400. event: "art",
  401. type: { syn: "合成兑换", act: "空投", art: "藏品", pri: "抽奖", article: "公告" },
  402. };
  403. baseList.push(artInfoA);
  404. sortId += 1;
  405. const artInfoB = {
  406. jumpType: "",
  407. url: "",
  408. timeList: [],
  409. title: artInfo.title,
  410. image: artInfo.image,
  411. activityType: "",
  412. authorName: artInfo.brandName,
  413. type: "art",
  414. typeName: "",
  415. categoryType: "",
  416. relationId: artInfo.artId,
  417. };
  418. relationList.push(artInfoB);
  419. }
  420. let artLstText = ``;
  421. for (let i = 0; i < baseList.length; ++i) {
  422. let element = baseList[i];
  423. let dataStr = JSON.stringify(element);
  424. dataStr = dataStr.replace(/"/g, "&quot;");
  425. let tmpStr = `<input ` +
  426. `style="align-content:center;width:80%;height:35px;background:#18bc9c;color:#FFFFFF;" readonly="readonly" ` +
  427. `disabled="disabled" ` +
  428. `name="relation['art'][]" ` +
  429. `value="[显示]藏品:${element.title}" ` +
  430. `data-event="art" ` +
  431. `data-id="${element.hash_id}" ` +
  432. `data-show="1" ` +
  433. `data="${dataStr}" />`;
  434. artLstText += tmpStr;
  435. };
  436. magicJS.logger.info(`artLstText: \n${artLstText}`);
  437. let content = `
  438. <p><br /></p>
  439. <p style="white-space:normal;"><strong>以下过往开放过的藏品:</strong></p>
  440. <p><br /></p>
  441. <p><strong><span style="color:#E53333;">${artLstText}<br /></span></strong></p>
  442. <p><strong><span style="color:#E53333;"><br /></span></strong></p>
  443. <p><strong><span style="color:#E53333;"><br /></span></strong></p>
  444. <p><strong><span style="color:#E53333;">&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;</span></strong></p>
  445. <p style="white-space:normal;text-align:right;"><strong><b>无边星链运营团队</b></strong></p>
  446. <p style="white-space:normal;text-align:right;"><strong><b><br /></b></strong></p>
  447. <p style="white-space:normal;text-align:right;"><strong><b>2024年9月10日</b></strong></p>
  448. <p><br /></p>
  449. `;
  450. rspData.data.content = content;
  451. rspData.data.relationList = relationList;
  452. rspData.data.title = '欢迎来到神秘空间';
  453. gRetBody = rspData;
  454. }
  455. }
  456. function hadnleMarketGroupList() {
  457. let rspData = getResponsePlainData();
  458. if (!rspData) {
  459. return;
  460. }
  461. if (rspData.code != 200) {
  462. return;
  463. }
  464. let dataDict = magicJS.data.read(WuBianConstKey.AllMarketGroupListData, {});
  465. let list = rspData.data?.list || [];
  466. for (let i = 0; i < list.length; ++i) {
  467. let item = list[i];
  468. dataDict[item.artId] = item;
  469. }
  470. magicJS.data.write(WuBianConstKey.AllMarketGroupListData, dataDict);
  471. }
  472. function handleActivityList() {
  473. let rspData = getResponsePlainData();
  474. if (!rspData) {
  475. return;
  476. }
  477. if (rspData.code != 200) {
  478. return;
  479. }
  480. let reqData = getRequestPlainData();
  481. // 1=合成活动,2=置换活动,3=分解活动,4=兑换活动
  482. let activityType = reqData.activityType || 0;
  483. let page = reqData.page;
  484. let status = reqData.status;
  485. let key = `${WuBianConstKey.ActivityListData}#${activityType}`;
  486. let list = rspData.data.list;
  487. let dataDict = magicJS.data.read(key, {});
  488. let nowTime = Math.floor(Date.now() / 1000);
  489. for (let item of list) {
  490. // name
  491. // startTime
  492. // endTiem
  493. // hashId
  494. // activityType
  495. // type 0=合成 1=兑换或置换
  496. const hashId = item.hashId;
  497. dataDict[hashId] = item;
  498. // item.startTime = Math.floor(Date.now() / 1000 - 3600);
  499. // item.endTiem = Math.floor(Date.now() / 1000 + 3600);
  500. if (nowTime < item.endTiem + 24 * 3600) {
  501. if (item.status == 0) {
  502. item.name = `${item.name}(未开始)`;
  503. } else if (item.status == 2) {
  504. item.name = `${item.name}(已结束)`;
  505. }
  506. item.status = 1;
  507. }
  508. }
  509. magicJS.data.write(key, dataDict);
  510. gRetBody = rspData;
  511. }
  512. function isActivityTaskCaptureEnabled() {
  513. let isEnabled = magicJS.data.read(WuBianConstKey.ActivityTaskCaptureEnabled, true);
  514. return isEnabled;
  515. }
  516. function isFirstOrderCaptureEnabled() {
  517. let isEnabled = magicJS.data.read(WuBianConstKey.FirstOrderCaptureEnabled, true);
  518. return isEnabled;
  519. }
  520. function isConsignmentCaptureEnabled() {
  521. let isEnabled = magicJS.data.read(WuBianConstKey.ConsignmentCaptureEnabled, true);
  522. return isEnabled;
  523. }
  524. function isFastBuyCaptureEnabled() {
  525. let isEnabled = magicJS.data.read(WuBianConstKey.FastBuyCaptureEnabled, true);
  526. return isEnabled;
  527. }
  528. function handleCvtGoodsList() {
  529. let rspData = getResponsePlainData();
  530. if (!rspData) {
  531. return;
  532. }
  533. if (rspData.code != 200) {
  534. return;
  535. }
  536. let reqData = getRequestPlainData();
  537. let activityId = reqData.activityId || 'default';
  538. if (isActivityTaskCaptureEnabled()) {
  539. let activityInfo = rspData.data.activityInfo;
  540. activityId = activityInfo.activityId;
  541. magicJS.data.write(WuBianConstKey.ActivityId, activityId);
  542. activityInfo.type = 1;
  543. magicJS.notification.appendNotifyInfo(`🎉[${activityInfo.name}]兑换数据采集成功!`);
  544. }
  545. let key = `${WuBianConstKey.ActivityGoodsList}#${activityId}`;
  546. magicJS.data.write(key, rspData.data);
  547. }
  548. function handleCompositeGoodsList() {
  549. let rspData = getResponsePlainData();
  550. if (!rspData) {
  551. return;
  552. }
  553. if (rspData.code != 200) {
  554. return;
  555. }
  556. let reqData = getRequestPlainData();
  557. let activityId = reqData.id || 'default';
  558. if (isActivityTaskCaptureEnabled()) {
  559. let activityInfo = rspData.data.activityInfo;
  560. activityId = activityInfo.activityId;
  561. magicJS.data.write(WuBianConstKey.ActivityId, activityId);
  562. activityInfo.type = 0;
  563. magicJS.notification.appendNotifyInfo(`🎉[${activityInfo.name}]合成数据采集成功!`);
  564. }
  565. let key = `${WuBianConstKey.ActivityGoodsList}#${activityId}`;
  566. magicJS.data.write(key, rspData.data);
  567. }
  568. function handleFirstArtList() {
  569. let rspData = getResponsePlainData();
  570. if (!rspData) {
  571. return;
  572. }
  573. if (rspData.code != 200) {
  574. return;
  575. }
  576. // 结果示例
  577. /*
  578. let result = {
  579. "code": 200,
  580. "data": {
  581. "total": 1,
  582. "next": 0,
  583. "list": [
  584. {
  585. "category": 1,
  586. "coverImage": "",
  587. "refreshTime": 1725881400,
  588. "count": 10000,
  589. "type": 1,
  590. "title": "星链计划",
  591. "avatar": "/uploads/20240830/c18be0bb7951859b97a7a2afba9d33a2.jpg",
  592. "image": "/uploads/20240909/0c5d20baa4c00a3390b131b84bf8d592.jpg",
  593. "tagList": [
  594. ],
  595. "price": 138,
  596. "attachFileType": 1,
  597. "artId": "3oe8bev8",
  598. "nickname": "无边星链",
  599. "status": "1" // 1=进行中 2=已结束
  600. }
  601. ]
  602. },
  603. "msg": "成功",
  604. "fail": false
  605. }
  606. */
  607. // let result = {
  608. // "code": 200,
  609. // "data": {
  610. // "total": 1,
  611. // "next": 0,
  612. // "list": [
  613. // {
  614. // "category": 1,
  615. // "coverImage": "",
  616. // "refreshTime": 1725881400,
  617. // "count": 10000,
  618. // "type": 1,
  619. // "title": "星链计划",
  620. // "avatar": "/uploads/20240830/c18be0bb7951859b97a7a2afba9d33a2.jpg",
  621. // "image": "/uploads/20240909/0c5d20baa4c00a3390b131b84bf8d592.jpg",
  622. // "tagList": [
  623. // ],
  624. // "price": 138,
  625. // "attachFileType": 1,
  626. // "artId": "3oe8bev8",
  627. // "nickname": "无边星链",
  628. // "status": "1"
  629. // }
  630. // ]
  631. // },
  632. // "msg": "成功",
  633. // "fail": false
  634. // }
  635. // rspData = result;
  636. let artDataDict = magicJS.data.read(WuBianConstKey.FirstArtListData, {});
  637. let reqData = getRequestPlainData();
  638. if (reqData && reqData.page == 1) {
  639. artDataDict = {};
  640. }
  641. let artList = rspData.data.list;
  642. for (let item of artList) {
  643. const artId = item.artId;
  644. artDataDict[artId] = item;
  645. }
  646. magicJS.data.write(WuBianConstKey.FirstArtListData, artDataDict);
  647. gRetBody = rspData;
  648. }
  649. function getFirstArtData(artId) {
  650. let artDataDict = magicJS.data.read(WuBianConstKey.FirstArtListData, {});
  651. return artDataDict[artId];
  652. }
  653. function getFirstArtName(artId) {
  654. let data = getFirstArtData(artId);
  655. if (data) {
  656. return data.title;
  657. }
  658. return `${artId}`;
  659. }
  660. function checkIsValidFirstArt(artId) {
  661. let artData = getFirstArtData(artId);
  662. if (artData) {
  663. if (artData.status == 1) {
  664. return true;
  665. }
  666. }
  667. return false;
  668. }
  669. function handleGoodsInfo() {
  670. let rspData = getResponsePlainData();
  671. if (!rspData) {
  672. return;
  673. }
  674. if (rspData.code != 200) {
  675. return;
  676. }
  677. /* 结果示例:
  678. let result = {
  679. "code": 200,
  680. "data": {
  681. "giveInfo": "",
  682. "resellInfo": "",
  683. "author": {
  684. "avatar": "/uploads/20240830/c18be0bb7951859b97a7a2afba9d33a2.jpg",
  685. "address": "0x96d1e7792e13c655b311e68e71d56698346786ce",
  686. "isAuthor": 1,
  687. "id": "657v3oean1",
  688. "bio": "",
  689. "isFocus": "",
  690. "nickName": "无边星链"
  691. },
  692. "owner": {
  693. "avatar": "/assets/img/avatar01.png",
  694. "address": "0x3dc7d16739d0f169977f589788007c33a0e8996d",
  695. "isAuthor": 0,
  696. "id": "80n19034n1",
  697. "bio": "",
  698. "isFocus": "",
  699. "nickName": "******5"
  700. },
  701. "button": [
  702. {
  703. "key": "NONE",
  704. "disable": 1,
  705. "highlight": ""
  706. }
  707. ],
  708. "isBox": 0,
  709. "paymentInfo": {
  710. "walletType": "",
  711. "isBuy": 0,
  712. "price": 48,
  713. "serviceRate": "0.07",
  714. "saleMinPrice": "",
  715. "saleMaxPrice": "",
  716. "mainOrderSn": "",
  717. "beginSaleTime": "",
  718. "walletId": ""
  719. },
  720. "info": {
  721. "lock": false,
  722. "tokenId": "182894170004127",
  723. "status": 2,
  724. "title": "星链计划",
  725. "image": "/uploads/20240909/0c5d20baa4c00a3390b131b84bf8d592.jpg",
  726. "count": 10000,
  727. "images": "",
  728. "contractAddress": "0x3a7ddb3129c52e8304ba1124a6d5c5f6622d8038",
  729. "type": 1,
  730. "brandName": "无边星链",
  731. "id": "e3nl20k41n4d",
  732. "ver": 4127,
  733. "attachFileType": 1,
  734. "circulationNum": 7500,
  735. "groupName": "限价区",
  736. "json": "{\"entrustEnable\":\"1\"}",
  737. "artId": "3oe8bev8",
  738. "isLike": 0,
  739. "attachFile": "",
  740. "content": "在浩渺的宇宙中,人类的探索从未停止。【星链计划】便是对人类太空探索梦想的独特诠释。这件藏品以精湛的工艺呈现出星链在太空中的壮丽景象。神秘深邃的背景中,无数颗卫星如同璀璨的明珠,以特定的轨道排列,仿佛一条闪耀着科技之光的银河。每一颗卫星都刻画得细致入微,金属质感的外壳散发着冷冽的光泽,彰显着现代科技的强大魅力。星链计划不仅代表着在宇宙领域的重大突破,更是人类向太空进军的勇敢尝试,也是对人类无限创造力的致敬。它不仅具有极高的艺术价值,更是历史与未来的交汇点,让你在欣赏它的同时,仿佛能感受到宇宙的浩瀚与人类的伟大。",
  741. "description": ""
  742. }
  743. },
  744. "msg": "成功",
  745. "fail": false
  746. }
  747. */
  748. let artInfo = rspData.data.info;
  749. if (isConsignmentCaptureEnabled()) {
  750. magicJS.data.write(WuBianConstKey.ConsignmentArtId, artInfo.artId);
  751. magicJS.data.write(WuBianConstKey.ConsignmentArtName, artInfo.title);
  752. magicJS.notification.appendNotifyInfo(`🎉[${artInfo.title}]一键寄售数据采集成功!`);
  753. }
  754. let authorInfo = rspData.data.author;
  755. let paymentInfo = rspData.data.paymentInfo;
  756. if (typeof paymentInfo.saleMinPrice == 'string' && paymentInfo.saleMinPrice.length == 0) {
  757. paymentInfo.saleMinPrice = 1;
  758. }
  759. if (typeof paymentInfo.saleMaxPrice == 'string' && paymentInfo.saleMaxPrice.length == 0) {
  760. paymentInfo.saleMaxPrice = 99999;
  761. }
  762. let buttons = rspData.data.button;
  763. if (buttons[0].disable == 1) {
  764. // let mapList = [
  765. // ["DESTROY", "已销毁"],
  766. // ["LOCKING", "锁定中"],
  767. // ["OPENED", "已开启"],
  768. // ["SOLD", "已售出"],
  769. // ["PAY", "立即购买"],
  770. // ["DRIVE", "车辆试驾"],
  771. // ["AVATAR", "设为头像"],
  772. // ["CLOSE_SALE", "取消寄售"],
  773. // ["SALE", "平台寄售"],
  774. // ["GIVE", "转赠好友"],
  775. // ["OPEN_BOX", "打开宝箱"],
  776. // ["SYNTHESISING", "合成中"],
  777. // ["NONE", "暂未开放"],
  778. // ["CONVERT", "兑换"],
  779. // ["SHARE", "分享"],
  780. // ["RESELL", "转售"],
  781. // ];
  782. buttons[0].disable = 0;
  783. buttons[0].key = 'SALE';
  784. buttons[1] = {
  785. disable: 0,
  786. key: 'GIVE',
  787. };
  788. authorInfo.nickName = `${authorInfo.nickName}#改`;
  789. }
  790. gRetBody = rspData;
  791. }
  792. function handleFirstArtInfo() {
  793. let rspData = getResponsePlainData();
  794. if (!rspData) {
  795. return;
  796. }
  797. if (rspData.code != 200) {
  798. return;
  799. }
  800. /* 结果示例:
  801. let result = {
  802. "code": 200,
  803. "data": {
  804. "artInfo": {
  805. "description": "",
  806. "brandName": "无边星链",
  807. "preBookTime": 600,
  808. "contractAddress": "0x3a7ddb3129c52e8304ba1124a6d5c5f6622d8038",
  809. "json": "{\"entrustEnable\":\"1\"}",
  810. "count": 10000,
  811. "isLike": 0,
  812. "type": 1,
  813. "title": "星链计划",
  814. "image": "/uploads/20240909/0c5d20baa4c00a3390b131b84bf8d592.jpg",
  815. "btnContent": "",
  816. "attachfile": "",
  817. "attachfileType": 1,
  818. "images": [
  819. ],
  820. "groupName": "限价区",
  821. "artId": "3oe8bev8",
  822. "circulationNum": 8723,
  823. "status": 2,
  824. "content": "在浩渺的宇宙中,人类的探索从未停止。【星链计划】便是对人类太空探索梦想的独特诠释。这件藏品以精湛的工艺呈现出星链在太空中的壮丽景象。神秘深邃的背景中,无数颗卫星如同璀璨的明珠,以特定的轨道排列,仿佛一条闪耀着科技之光的银河。每一颗卫星都刻画得细致入微,金属质感的外壳散发着冷冽的光泽,彰显着现代科技的强大魅力。星链计划不仅代表着在宇宙领域的重大突破,更是人类向太空进军的勇敢尝试,也是对人类无限创造力的致敬。它不仅具有极高的艺术价值,更是历史与未来的交汇点,让你在欣赏它的同时,仿佛能感受到宇宙的浩瀚与人类的伟大。"
  825. },
  826. "authorInfo": {
  827. "avatar": "/uploads/20240830/c18be0bb7951859b97a7a2afba9d33a2.jpg",
  828. "address": "0x96d1e7792e13c655b311e68e71d56698346786ce",
  829. "isAuthor": 1,
  830. "id": "657v3oean1",
  831. "bio": "",
  832. "isFocus": "",
  833. "nickName": "无边星链"
  834. },
  835. "covertInfo": "",
  836. "payInfo": {
  837. "category": 1,
  838. "enableConsignment": 0,
  839. "price": 138,
  840. "limited": 0,
  841. "refreshTime": 0,
  842. "btnContent": "立即购买",
  843. "serviceRate": "0.07",
  844. "saleMaxPrice": 438,
  845. "saleMinPrice": 1
  846. }
  847. },
  848. "msg": "成功",
  849. "fail": false
  850. }
  851. */
  852. let artInfo = rspData.data.artInfo;
  853. let authorInfo = rspData.data.authorInfo;
  854. let payInfo = rspData.data.payInfo;
  855. if (checkIsValidFirstArt(artInfo.artId)) {
  856. if (isFirstOrderCaptureEnabled()) {
  857. magicJS.data.write(WuBianConstKey.CreateFirstOrderData, {
  858. title: artInfo.title,
  859. artId: artInfo.artId,
  860. price: artInfo.price,
  861. num: payInfo.limited,
  862. });
  863. magicJS.data.write(WuBianConstKey.FirstGoodsId, artInfo.artId);
  864. magicJS.notification.appendNotifyInfo(`🎉产品[${artInfo.title}]首发数据采集成功!`);
  865. }
  866. } else {
  867. if (isFastBuyCaptureEnabled()) {
  868. magicJS.data.write(WuBianConstKey.FastBuyArtId, artInfo.artId);
  869. magicJS.data.write(WuBianConstKey.FastBuyArtInfo, artInfo);
  870. magicJS.notification.appendNotifyInfo(`🎉产品[${artInfo.title}]快捷购买数据采集成功!`);
  871. }
  872. }
  873. artInfo.title = `${artInfo.title}(流通:${artInfo.circulationNum})`;
  874. // 购买寄售强开
  875. if (payInfo.enableConsignment == 0) {
  876. payInfo.enableConsignment = 1;
  877. authorInfo.nickName = `${authorInfo.nickName}#改`;
  878. magicJS.logger.info(`强制开启批量购买功能`);
  879. }
  880. // payInfo只跟首发相关
  881. // 强制开启首发购买
  882. // artInfo.status = 1;
  883. if (payInfo.limited < 1) {
  884. // 购买数量强开
  885. payInfo.limited = 999;
  886. magicJS.logger.info(`强制开启购买数量限制`);
  887. }
  888. if (payInfo.refreshTime == 0) {
  889. payInfo.refreshTime = Math.floor(Date.now() / 1000);
  890. }
  891. gRetBody = rspData;
  892. }
  893. function handleCreateFirstOrder() {
  894. let rspData = getResponsePlainData();
  895. if (!rspData) {
  896. return;
  897. }
  898. if (isFirstOrderCaptureEnabled()) {
  899. // `https://api.wubian.pro/vmf/app/order/createFirstOrder?token=80n19034n1`
  900. let reqData = JSON.parse(magicJS.getRequestBody());
  901. let queryParams = magicJS.parseQueryStr($request.url);
  902. magicJS.data.write(WuBianConstKey.CreateFirstOrderData, {
  903. token: queryParams.token,
  904. artId: reqData.artHashId,
  905. price: reqData.price,
  906. num: reqData.num,
  907. });
  908. magicJS.data.write(WuBianConstKey.FirstGoodsId, reqData.artHashId);
  909. magicJS.notification.appendNotifyInfo(`🎉产品[${getFirstArtName(reqData.artHashId)}]首发数据采集成功!`);
  910. }
  911. }
  912. function handleOrderList() {
  913. let rspData = getResponsePlainData();
  914. if (!rspData) {
  915. return;
  916. }
  917. /**
  918. *
  919. 结果示例:
  920. {
  921. "code": 200,
  922. "data": {
  923. "total": 283,
  924. "next": 1,
  925. "list": [
  926. {
  927. "state": 8,
  928. "orderTypeName": "兑换订单",
  929. "orderSn": "20240919200738282206032433",
  930. "createdTime": "2024-09-19 20:07:38",
  931. "count": 82781,
  932. "authorName": "无边星链",
  933. "title": "玉兔捣药分解活动!",
  934. "price": 0,
  935. "image": "/uploads/20240919/ca5a67f98ed6396fd548752caa3d8974.png",
  936. "ver": "#22314/82781",
  937. "orderType": 6,
  938. "num": 6,
  939. "lockTime": 0,
  940. "stateDesc": "已兑换",
  941. "buttonList": []
  942. }
  943. ]
  944. },
  945. "msg": "成功",
  946. "fail": false
  947. }
  948. */
  949. // let mapList = [
  950. // ["CANCEL_CONSIGNMENT", "取消寄售"],
  951. // ["VIEW_GOODS", "查看藏品"],
  952. // ["CANCEL_ORDER", "取消订单"],
  953. // ["PAY", "去支付"],
  954. // ["GOODS_LIBRARY", "藏品库"],
  955. // ["BUY_ANOTHER", "继续购买"],
  956. // ["ORDER_CONFIRM", "订单确认中"],
  957. // ["INVOICE", "申请发票"],
  958. // ["UPDATE_PRICE", "修改价格"],
  959. // ["CANCEL_COMPETE", "取消竞价"],
  960. // ["CANCEL_ENTRUST", "取消委托"]
  961. // ];
  962. }
  963. function handleOrderInfo() {
  964. let rspData = getResponsePlainData();
  965. if (!rspData) {
  966. return;
  967. }
  968. }
  969. Main().catch((e) => magicJS.logger.log(`-\n ${e}`)).finally(() => magicJS.done());
  970. //---SyncByPyScript---MagicJS3-start
  971. function MagicJS(e = "MagicJS", t = "INFO") { const n = () => { const e = "undefined" != typeof $loon, t = "undefined" != typeof $task, r = "undefined" != typeof module, n = "undefined" != typeof $httpClient && !e, o = "undefined" != typeof $storm, i = "undefined" != typeof $environment && void 0 !== $environment["stash-build"]; var s = n || e || o || i; const a = "undefined" != typeof importModule; return { isLoon: e, isQuanX: t, isNode: r, isSurge: n, isStorm: o, isStash: i, isSurgeLike: s, isScriptable: a, get name() { return e ? "Loon" : t ? "QuantumultX" : r ? "NodeJS" : n ? "Surge" : a ? "Scriptable" : "unknown" }, get build() { return n ? $environment["surge-build"] : i ? $environment["stash-build"] : o ? $storm.buildVersion : void 0 }, get language() { if (n || i) return $environment.language }, get version() { return n ? $environment["surge-version"] : i ? $environment["stash-version"] : o ? $storm.appVersion : r ? process.version : void 0 }, get system() { return n ? $environment.system : r ? process.platform : void 0 }, get systemVersion() { if (o) return $storm.systemVersion }, get deviceName() { if (o) return $storm.deviceName } } }, o = (r, e = "INFO") => { let n = e, t = "\n"; const o = { SNIFFER: 6, DEBUG: 5, INFO: 4, NOTIFY: 3, WARNING: 2, ERROR: 1, CRITICAL: 0, NONE: -1 }, i = { SNIFFER: "", DEBUG: "", INFO: "", NOTIFY: "", WARNING: "❗ ", ERROR: "❌ ", CRITICAL: "❌ ", NONE: "" }, s = (e, t = "INFO") => { o[n] < o[t.toUpperCase()] || console.log(`██[${r}][${t}]` + i[t.toUpperCase()] + e + "\n") }; return { getLevel: () => n, setLevel: e => { n = e }, sniffer: (...e) => { e = e.join(t); s(e, "SNIFFER") }, log: (...e) => { e = e.join(t); console.log(`██[${r}]` + e + "\n") }, debug: (...e) => { e = e.join(t); s(e, "DEBUG") }, info: (...e) => { e = e.join(t); s(e, "INFO") }, notify: (...e) => { e = e.join(t); s(e, "NOTIFY") }, warning: (...e) => { e = e.join(t); s(e, "WARNING") }, error: (...e) => { e = e.join(t); s(e, "ERROR") }, retry: (...e) => { e = e.join(t); s(e, "RETRY") } } }; return new class { constructor(e, t) { var r; this._startTime = Date.now(), this.version = "3.0.0", this.scriptName = e, this.env = n(), this.logger = o(e, t), this.http = "function" == typeof MagicHttp ? MagicHttp(this.env, this.logger) : void 0, this.data = "function" == typeof MagicData ? MagicData(this.env, this.logger) : void 0, this.notification = "function" == typeof MagicNotification ? MagicNotification(this.scriptName, this.env, this.logger, this.http) : void 0, this.utils = "function" == typeof MagicUtils ? MagicUtils(this.env, this.logger) : void 0, this.qinglong = "function" == typeof MagicQingLong ? MagicQingLong(this.env, this.data, this.logger) : void 0, void 0 !== this.data && (t = this.data.read("magic_loglevel"), r = this.data.read("magic_bark_url"), t && this.logger.setLevel(t.toUpperCase()), r) && this.notification.setBark(r), this.logger.info(e + ", 开始执行!") } get isRequest() { return "undefined" != typeof $request } get isStrictRequest() { return "undefined" != typeof $request && "undefined" == typeof $response } get isResponse() { return "undefined" != typeof $response } get isDebug() { return "DEBUG" === this.logger.level } get request() { return "undefined" != typeof $request ? $request : void 0 } get response() { if ("undefined" != typeof $response) return $response.hasOwnProperty("status") && ($response.statusCode = $response.status), $response.hasOwnProperty("statusCode") && ($response.status = $response.statusCode), $response } log(...e) { this.logger.log(e) } toStr(e, t = null) { try { return JSON.stringify(e) } catch { return t } } toObj(e, t = null) { try { return JSON.parse(e) } catch { return t } } checkRecordRequestBody() { if (this.isRequest) { var t = $request.body; if (t) { var r = this.env, n = $request.path; let e = this.scriptName + "#" + n.replace("/", "_"); e = e.replace("?", "#"), r.isQuanX && $prefs.setValueForKey(t, e), (r.isLoon || r.isSurge) && $persistentStore.write(t, e), r.isNode && require("fs").writeFileSync(e + ".json", t, { flag: "w" }, e => console.log(e)) } } } getRequestBody() { var e = this.env, t = $request.path; let r = this.scriptName + "#" + t.replace("/", "_"); if (r = r.replace("?", "#"), e.isSurge || e.isLoon) return $persistentStore.read(r); if (e.isQuanX) return $prefs.valueForKey(r); if (e.isNode) { t = r + ".json", e = require("fs"); if (!e.existsSync(t)) return JSON.parse(e.readFileSync(t)) } } getResponseBody() { if ($response) return $response.body } parseCookies(e, t = !1) { let r = {}; return t ? e && e.split(";").forEach(function (e) { e = e.split("="); r[e.shift().trim()] = decodeURIComponent(e.join("=")) }) : e && e.split(";").forEach(function (e) { e = e.split("="); r[e.shift().trim()] = e.join("=") }), r } serializeCookies(e, t = !1) { var r = []; if (t) for (var n in e) { var o = e[n], n = n + "=" + encodeURIComponent(o); r.push(n) } else for (var i in e) { var s = e[i], i = i + "=" + s; r.push(i) } return r.join("; ") } parseSetCookies(e) { var t = e.split(/,\s*/).map(e => { var e = e.trim().split(/;\s*(?=[^=]+=[^;]*)/), t = e[0].split("=").map(e => e.trim()); const r = { name: t[0], value: t[1] }; return e.slice(1).forEach(e => { var [e, t] = e.split("=").map(e => e.trim()); r[e] = t || !0 }), r }), r = []; let n = 0; for (; n < t.length;) { var o, i = t[n]; r.push(i), i.Expires ? ((o = t[n + 1]) && (i.Expires = i.Expires + "," + o.name), n += 2) : n += 1 } return r } objToQueryStr(t, r) { let n = ""; for (const o in t) { let e = t[o]; null != e && "" !== e && ("object" == typeof e ? e = JSON.stringify(e) : r && (e = encodeURIComponent(e)), n += `${o}=${e}&`) } return n = n.substring(0, n.length - 1) } parseQueryStr(e) { var t = {}, r = (e = -1 < e.indexOf("?") ? e.split("?")[1] : e).split("&"); for (let e = 0; e < r.length; e++) { var n = r[e].split("="); t[n[0]] = n[1] } return t } deepClone(e, t) { for (var r in t = t || {}, e) "object" == typeof e[r] ? (t[r] = e[r].constructor === Array ? [] : {}, this.deepClone(e[r], t[r])) : t[r] = e[r]; return t } formatDate(e, t) { var r, n = { "M+": e.getMonth() + 1, "d+": e.getDate(), "H+": e.getHours(), "m+": e.getMinutes(), "s+": e.getSeconds(), "q+": Math.floor((e.getMonth() + 3) / 3), S: e.getMilliseconds() }; for (r in /(y+)/.test(t) && (t = t.replace(RegExp.$1, (e.getFullYear() + "").substr(4 - RegExp.$1.length))), n) new RegExp("(" + r + ")").test(t) && (t = t.replace(RegExp.$1, 1 == RegExp.$1.length ? n[r] : ("00" + n[r]).substr(("" + n[r]).length))); return t } parseDate(a, e) { let l = { y: 0, M: 1, d: 0, H: 0, h: 0, m: 0, s: 0, S: 0 }; (e = e || "yyyy-MM-dd").replace(/([^yMdHmsS]*?)(([yMdHmsS])\3*)([^yMdHmsS]*?)/g, function (e, t, r, n, o, i, s) { return a = a.replace(new RegExp(t + "(\\d{" + r.length + "})" + o), function (e, t) { return l[n] = parseInt(t), "" }), "" }), l.M--; e = new Date(l.y, l.M, l.d, l.H, l.m, l.s); return 0 !== l.S && e.setMilliseconds(l.S), e } getBaseDoneHeaders(e = {}) { return Object.assign({ "Access-Control-Allow-Origin": "*", "Access-Control-Allow-Methods": "POST,GET,OPTIONS,PUT,DELETE", "Access-Control-Allow-Headers": "Origin, X-Requested-With, Content-Type, Accept" }, e) } getHtmlDoneHeaders() { return this.getBaseDoneHeaders({ "Content-Type": "text/html;charset=UTF-8" }) } getJsonDoneHeaders() { return this.getBaseDoneHeaders({ "Content-Type": "text/json; charset=utf-8", Connection: "keep-alive" }) } doWxpusherSend(e) { var t = this.getJsonDoneHeaders(), t = (t.Host = "wxpusher.zjiecode.com", t["Content-Type"] = "application/json;charset=UTF-8", { url: "https://wxpusher.zjiecode.com/api/send/message", headers: t, body: JSON.stringify(e) }); return this.http.post(t) } fastWxpusherSend(e, t = "", r = "") { return this.doWxpusherSend({ appToken: "AT_7wDWqSoT8xpJCQqJtHpshKhw7kXc0XCW", content: e, summary: t, contentType: 1, topicIds: [], uids: ["UID_6P4B00X6Zv8U2oKC0I2R09emxtqq"], url: r, verifyPay: !1, verifyPayType: 0 }) } isEmpty(e) { return void 0 === e || null == e || "" == e || "null" == e || "undefined" == e || 0 === e.length } base64Encode(e) { var t, r, n, o = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/"; let i, s, a; for (a = e.length, s = 0, i = ""; s < a;) { if (t = 255 & e.charCodeAt(s++), s == a) { i = (i += o.charAt(t >> 2)) + o.charAt((3 & t) << 4) + "=="; break } if (r = e.charCodeAt(s++), s == a) { i = (i = (i += o.charAt(t >> 2)) + o.charAt((3 & t) << 4 | (240 & r) >> 4)) + o.charAt((15 & r) << 2) + "="; break } n = e.charCodeAt(s++), i = (i = (i = (i += o.charAt(t >> 2)) + o.charAt((3 & t) << 4 | (240 & r) >> 4)) + o.charAt((15 & r) << 2 | (192 & n) >> 6)) + o.charAt(63 & n) } return i } base64Decode(e) { var t = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/="; if (/([^\s]+[^0-9a-zA-Z\+\/\=]|[^0-9a-zA-Z\+\/\=]\s+)/.test(e)) throw new Error("Invalid base64 input"); var r, n, o, i, s, a, l = e.replace(/\s/g, ""); let u = "", c = 0; for (; c < l.length;)o = t.indexOf(l.charAt(c++)), r = (15 & (i = t.indexOf(l.charAt(c++)))) << 4 | (s = t.indexOf(l.charAt(c++))) >> 2, n = (3 & s) << 6 | (a = t.indexOf(l.charAt(c++))), u += String.fromCharCode(o << 2 | i >> 4), 64 !== s && (u += String.fromCharCode(r)), 64 !== a && (u += String.fromCharCode(n)); return u = this.utf8Decode(u) } utf8Decode(t) { let e = [], r = 0, n = 0, o = 0; for (t = t.replace(/\r\n/g, "\n"); r < t.length;) { n = 255 & t.charCodeAt(r), o = 0, o = n <= 191 ? (n &= 127, 1) : n <= 223 ? (n &= 31, 2) : n <= 239 ? (n &= 15, 3) : (n &= 7, 4); for (let e = 1; e < o; ++e)n = n << 6 | 63 & t.charCodeAt(e + r); 4 === o ? (n -= 65536, e.push(String.fromCharCode(55296 | n >> 10 & 1023)), e.push(String.fromCharCode(56320 | 1023 & n))) : e.push(String.fromCharCode(n)), r += o } return e.join("") } parseJwt(e) { try { var t = e.split("."), r = t[0].replace(/-/g, "+").replace(/_/g, "/"), n = this.base64Decode(r).replace(/\0/g, ""), o = JSON.parse(n), i = t[1].replace(/-/g, "+").replace(/_/g, "/"), s = this.base64Decode(i).replace(/\0/g, ""); return { header: o, payload: JSON.parse(s), signature: t[2] } } catch (e) { return this.log(e), null } } costTime() { var e = this.scriptName + "执行完毕!", t = (this._endTime = (new Date).getTime(), this._endTime - this._startTime); this.logger.info(e + `耗时【${t / 1e3}】秒`) } done = (e = {}) => { this.costTime(), "undefined" != typeof $done && $done(e) } }(e, t) } function MagicHttp(d, p) { var e; let g; d.isNode && (e = require("axios"), g = e.create()); class t { constructor(e = !0) { this.handlers = [], this.isRequest = e } use(e, t, r) { return "function" == typeof e && p.debug("Register fulfilled " + e.name), "function" == typeof t && p.debug("Register rejected " + t.name), this.handlers.push({ fulfilled: e, rejected: t, synchronous: !(!r || "boolean" != typeof r.synchronous) && r.synchronous, runWhen: r ? r.runWhen : null }), this.handlers.length - 1 } eject(e) { this.handlers[e] && (this.handlers[e] = null) } forEach(t) { this.handlers.forEach(e => { null !== e && t(e) }) } } function f(e) { let r = { ...e }; return r.params && !d.isNode && (e = Object.keys(r.params).map(e => { var t = encodeURIComponent(e); return r.url = r.url.replace(new RegExp(e + "=[^&]*", "ig"), ""), r.url = r.url.replace(new RegExp(t + "=[^&]*", "ig"), ""), t + "=" + encodeURIComponent(r.params[e]) }).join("&"), r.url.indexOf("?") < 0 && (r.url += "?"), /(&|\?)$/g.test(r.url) || (r.url += "&"), r.url += e, delete r.params, p.debug("Params to QueryString: " + r.url)), r } const h = (e, t = null) => { if (e) { t = { ...e, config: e.config || t, status: e.statusCode || e.status, body: e.body || e.data, headers: e.headers || e.header }; if ("string" == typeof t.body) try { t.body = JSON.parse(t.body) } catch { } return delete t.data, t } return e }; const y = (e, t = null) => { if (e && 400 <= e.status) return p.debug("Raise exception when status code is " + e.status), { name: "RequestException", message: "Request failed with status code " + e.status, config: t || e.config, response: e } }, m = { request: new t, response: new t(!1) }; let v = [], b = [], S = !0; function N(e) { return e = f(e), p.debug(`HTTP ${e.method.toUpperCase()}:` + "\n" + JSON.stringify(e)), e } function E(t) { try { t = t && h(t), p.sniffer(`HTTP ${t.config.method.toUpperCase()}:` + "\n" + JSON.stringify(t.config) + "\nSTATUS CODE:\n" + t.status + "\nRESPONSE:\n" + ("object" == typeof t.body ? JSON.stringify(t.body) : t.body)); var e = y(t); return e ? Promise.reject(e) : t } catch (e) { return p.error(e), t } } const r = (e, r) => { let n; r = ((e, t) => { let r = "object" == typeof t ? { headers: {}, ...t } : { url: t, headers: {} }; return r.method || (r.method = e), !0 === (r = f(r)).rewrite && (d.isSurge ? (r.headers["X-Surge-Skip-Scripting"] = !1, delete r.rewrite) : d.isQuanX && (r.hints = !1, delete r.rewrite)), d.isSurgeLike ? (t = r.headers["content-type"] || r.headers["Content-Type"], "GET" !== r.method && t && 0 <= t.indexOf("application/json") && r.body instanceof Array && (r.body = JSON.stringify(r.body), p.debug("Convert Array object to String: " + r.body))) : d.isQuanX ? (r.hasOwnProperty("body") && "string" != typeof r.body && (r.body = JSON.stringify(r.body)), r.method = e) : d.isNode && ("POST" === e || "PUT" === e || "PATCH" === e || "DELETE" === e ? r.data = r.data || r.body : "GET" === e && (r.params = r.params || r.body), delete r.body), r })(e.toUpperCase(), r), n = d.isNode ? g : d.isSurgeLike ? i => new Promise((n, o) => { $httpClient[e.toLowerCase()](i, (e, t, r) => { e ? (e = { name: e.name || e, message: e.message || e, stack: e.stack || e, config: i, response: h(t) }, o(e)) : (t.config = i, t.body = r, n(t)) }) }) : n => new Promise((r, t) => { $task.fetch(n).then(e => { e = h(e, n); var t = y(e, n); if (t) return Promise.reject(t); r(e) }).catch(e => { e = { name: e.message || e.error, message: e.message || e.error, stack: e.error, config: n, response: e.response ? h(e.response) : null }; t(e) }) }); let o; var t = r; try { v = [], b = [], m.request.forEach(e => { "function" == typeof e.runWhen && !1 === e.runWhen(t) || (S = S && e.synchronous, v.unshift(e.fulfilled, e.rejected)) }), m.response.forEach(e => { b.push(e.fulfilled, e.rejected) }) } catch (e) { p.error(`Failed to register interceptors: ${e}.`) } var i = [N, void 0], s = [E, void 0]; if (S) { for (p.debug("Interceptors are executed in synchronous mode"), Array.prototype.unshift.apply(v, i), v = v.concat([N, void 0]); v.length;) { var a = v.shift(), l = v.shift(); try { "function" == typeof a && p.debug("Executing request fulfilled " + a.name), r = a(r) } catch (e) { "function" == typeof l && p.debug("Executing request rejected " + l.name), l(e); break } } try { o = (!d.isNode && r.timeout ? c : n)(r) } catch (e) { return Promise.reject(e) } for (Array.prototype.unshift.apply(b, s); b.length;)o = o.then(b.shift(), b.shift()); return o } { p.debug("Interceptors are executed in asynchronous mode"); let t = [n, void 0]; for (Array.prototype.unshift.apply(t, i), Array.prototype.unshift.apply(t, v), t = (t = t.concat(s)).concat(b), o = Promise.resolve(r); t.length;)try { let e = t.shift(); var u = t.shift(); "function" == typeof (e = !d.isNode && r.timeout && e === n ? c : e) && p.debug("Executing request fulfilled " + e.name), "function" == typeof u && p.debug("Executing request rejected " + u.name), o = o.then(e, u) } catch (e) { p.error("request exception: " + e) } return o } function c(r) { try { var e = new Promise((e, t) => { setTimeout(() => { var e = { message: `timeout of ${r.timeout}ms exceeded.`, config: r }; t(e) }, r.timeout) }); return Promise.race([n(r), e]) } catch (e) { p.error(`Request Timeout exception: ${e}.`) } } }; return { request: r, interceptors: m, convertHeadersToLowerCase: r => Object.keys(r).reduce((e, t) => (e[t.toLowerCase()] = r[t], e), {}), convertHeadersToCamelCase: r => Object.keys(r).reduce((e, t) => { return e[t.split("-").map(e => e[0].toUpperCase() + e.slice(1)).join("-")] = r[t], e }, {}), modifyResponse: h, get: e => r("GET", e), post: e => r("POST", e), put: e => r("PUT", e), patch: e => r("PATCH", e), delete: e => r("DELETE", e), head: e => r("HEAD", e), options: e => r("OPTIONS", e) } } function MagicData(d, p) { let g = { fs: void 0, data: {} }; if (d.isNode) { g.fs = require("fs"); try { g.fs.accessSync("./magic.json", g.fs.constants.R_OK | g.fs.constants.W_OK) } catch (e) { g.fs.writeFileSync("./magic.json", "{}", { encoding: "utf8" }) } g.data = require("./magic.json") } const s = (e, t) => "object" != typeof t && e === t, a = e => "true" === e || "false" !== e && (void 0 === e ? null : e), l = (e, t, r, n) => { if (r) try { e = !0 === (e = "string" == typeof e ? JSON.parse(e) : e).magic_session ? e[r] : null } catch { e = null } if ("string" == typeof e && "null" !== e) try { e = JSON.parse(e) } catch { } return null == (e = !1 === n && e && !0 === e.magic_session ? null : e) && null != t && (e = t), e = a(e) }, f = t => { if ("string" != typeof t) return t instanceof Array || null == t || t != t || "boolean" == typeof t ? {} : t; { let e = {}; try { var r = typeof (e = JSON.parse(t)); ("object" != r || e instanceof Array || "bool" == r || null === e) && (e = {}) } catch { } return e } }, u = (e, t = null, r = "", n = !1, o = null) => { let i = ""; return i = o || d.isNode ? ((e, t = null, r = "", n = !1, o = null) => { o = o || g.data; return val = o && void 0 !== o[e] && null !== o[e] ? o[e] : r ? {} : null, val = l(val, t, r, n) })(e, t, r, n, o) : (d.isSurgeLike ? i = $persistentStore.read(e) : d.isQuanX && (i = $prefs.valueForKey(e)), l(i, t, r, n)), p.debug(`READ DATA [${e}]${r ? `[${r}]` : ""} <${typeof i}>` + "\n" + JSON.stringify(i)), i }, c = (e, t, r = "", n = null) => { if (void 0 === t || t != t) return !1; d.isNode || "boolean" != typeof t && "number" != typeof t || (t = String(t)); let o = ""; var i, s, a, l, u, c; if (n || d.isNode ? o = ([i, s, a = "", l = null] = [e, t, r, n], c = l || g.data, c = f(c), a ? ((u = f(c[i])).magic_session = !0, u[a] = s, c[i] = u) : c[i] = s, null !== l && (l = c), c) : r ? (d.isSurgeLike ? o = $persistentStore.read(e) ? $persistentStore.read(e) : o : d.isQuanX && (o = $prefs.valueForKey(e) ? $prefs.valueForKey(e) : o), (o = f(o)).magic_session = !0, o[r] = t) : o = t, o && "object" == typeof o && (o = JSON.stringify(o, null, 4)), p.debug(`WRITE DATA [${e}]${r ? `[${r}]` : ""} <${typeof t}>` + "\n" + JSON.stringify(t)), !n) { if (d.isSurgeLike) return $persistentStore.write(o, e); if (d.isQuanX) return $prefs.setValueForKey(o, e); if (d.isNode) try { g.fs.writeFileSync("./magic.json", o) } catch (e) { return p.error(e), !1 } } return !0 }; return { read: u, write: c, del: (e, t = "", r = null) => { let n = {}; if (r || d.isNode) n = (o = e, i = t, s = r || g.data, s = f(s), i ? (delete (obj = f(s[o]))[i], s[o] = obj) : delete s[o], s), r ? r = n : g.fs.writeFileSync("./magic.json", JSON.stringify(n, null, 4)); else if (t) { d.isSurgeLike ? n = $persistentStore.read(e) : d.isQuanX && (n = $prefs.valueForKey(e)), delete (n = f(n))[t]; i = JSON.stringify(n, null, 4); c(e, i) } else { if (d.isStorm) return $persistentStore.remove(e); if (d.isSurgeLike) return $persistentStore.write(null, e); if (d.isQuanX) return $prefs.removeValueForKey(e) } var o, i, s; p.debug(`DELETE KEY [${e}]` + (t ? `[${t}]` : "")) }, update: (e, t, r, n = s, o = null) => { var i; return t = a(t), !0 !== n(u(e, null, r, !1, o), t) && (i = c(e, t, r, o), e = u(e, null, r, !1, o), n === s && "object" == typeof e ? i : n(t, e)) }, allSessions: (e, t = null) => { let r = {}; t = u(e, null, null, !0, t); return !0 === (t = f(t)).magic_session && delete (r = { ...t }).magic_session, p.debug(`READ ALL SESSIONS [${e}] <${typeof r}>` + "\n" + JSON.stringify(r, null, 4)), r }, allSessionNames: (e, t = null) => { let r = []; t = u(e, null, null, !0, t), t = f(t); return r = !0 !== t.magic_session ? [] : Object.keys(t).filter(e => "magic_session" !== e), p.debug(`READ ALL SESSIONS [${e}] <${typeof r}>` + "\n" + JSON.stringify(r, null, 4)), r }, defaultValueComparator: s, convertToObject: f } } function MagicNotification(i, o, s, a) { let l = null, u = null, c = []; function d(e = i, t = "", r = "", n = "") { n = (t => { try { let e = {}; var r; return "string" == typeof t ? 0 < t.length && (o.isLoon ? e = { openUrl: t } : o.isQuanX ? e = { "open-url": t } : o.isSurge && (e = { url: t })) : "object" == typeof t && (o.isLoon ? (e.openUrl = t["open-url"] || "", e.mediaUrl = t["media-url"] || "") : o.isQuanX ? e = t["open-url"] || t["media-url"] ? t : {} : o.isSurge && (r = t["open-url"] || t.openUrl, e = r ? { url: r } : {})), e } catch (e) { s.error("通知选项转换失败" + e) } return t })(n), 1 === arguments.length && (e = i, t = "", r = arguments[0]), s.notify("\ntitle:" + e + "\nsubTitle:" + t + "\nbody:" + r + "\noptions:" + ("object" == typeof n ? JSON.stringify(n) : n)), o.isSurge ? $notification.post(e, t, r, n) : o.isLoon ? n ? $notification.post(e, t, r, n) : $notification.post(e, t, r) : o.isQuanX && $notify(e, t, r, n), l && u && p(e, t, r) } function p(e = i, t = "", r = "", n) { if (void 0 === a || void 0 === a.post) throw "Bark notification needs to import MagicHttp module."; e = { url: l, headers: { "content-type": "application/json; charset=utf-8" }, body: { title: e, body: t ? t + "\n" + r : r, device_key: u } }; a.post(e).catch(e => { s.error("Bark notify error: " + e) }) } return { post: d, debug: function (e = i, t = "", r = "", n = "") { "DEBUG" === s.getLevel() && (1 === arguments.length && (e = i, t = "", r = arguments[0]), this.post(e, t, r, n)) }, bark: p, setBark: e => { try { var t = e.replace(/\/+$/g, ""); l = /^https?:\/\/([^/]*)/.exec(t)[0] + "/push", u = /\/([^\/]+)\/?$/.exec(t)[1] } catch (e) { s.error(`Bark url error: ${e}.`) } }, appendNotifyInfo: function (e, t) { 1 == t ? c = e : c.push(e) }, prependNotifyInfo: function (e) { c.splice(0, 0, e) }, msg: function (e, t, r, n) { var o = {}; r && (o["open-url"] = r), n && (o["media-url"] = n), (t = t && 0 != t.length ? t : Array.isArray(c) ? c.join("\n") : c) && 0 < t.length && d(i, "", t, o) } } } function MagicUtils(n, u) { const e = (e, t = "yyyy-MM-dd hh:mm:ss") => { var r, n = { "M+": e.getMonth() + 1, "d+": e.getDate(), "h+": e.getHours(), "m+": e.getMinutes(), "s+": e.getSeconds(), "q+": Math.floor((e.getMonth() + 3) / 3), S: e.getMilliseconds() }; for (r in /(y+)/.test(t) && (t = t.replace(RegExp.$1, (e.getFullYear() + "").substr(4 - RegExp.$1.length))), n) new RegExp("(" + r + ")").test(t) && (t = t.replace(RegExp.$1, 1 === RegExp.$1.length ? n[r] : ("00" + n[r]).substr(("" + n[r]).length))); return t }; return { retry: (i, s = 5, a = 0, l = null) => (...e) => new Promise((r, n) => { function o(...t) { Promise.resolve().then(() => i.apply(this, t)).then(e => { "function" == typeof l ? Promise.resolve().then(() => l(e)).then(() => { r(e) }).catch(e => { 1 <= s ? 0 < a ? setTimeout(() => o.apply(this, t), a) : o.apply(this, t) : n(e), s-- }) : r(e) }).catch(e => { u.error(e), 1 <= s && 0 < a ? setTimeout(() => o.apply(this, t), a) : 1 <= s ? o.apply(this, t) : n(e), s-- }) } o.apply(this, e) }), formatTime: e, now: () => e(new Date, "yyyy-MM-dd hh:mm:ss"), today: () => e(new Date, "yyyy-MM-dd"), sleep: t => new Promise(e => setTimeout(e, t)), assert: (e, t = null) => { var r; n.isNode ? (r = require("assert"), t ? r(e, t) : r(e)) : !0 !== e && u.error("AssertionError: " + (t || "The expression evaluated to a falsy value.")) } } } function MagicQingLong(e, a, o) { let i = "", s = "", l = "", u = "", c = "", t = ""; const d = "magic.json", p = MagicHttp(e, o); async function r() { return l = l || a.read("magic_qlclient"), u = u || a.read("magic_qlsecrt"), s = s || a.read("magic_qlname"), c = c || a.read("magic_qlpwd"), i && l && u ? (o.info("Get token from QingLong Panel"), await p.get({ url: "/open/auth/token", headers: { "content-type": "application/json" }, params: { client_id: l, client_secret: u } }).then(e => { if (!(0 < Object.keys(e.body).length && e.body.data && e.body.data.token)) throw new Error("Get QingLong Panel token failed."); o.info("Successfully logged in to QingLong Panel"), t = e.body.data.token, a.write("magic_qltoken", t) }).catch(e => { o.error("Error logging in to QingLong Panel.\n" + (e.message || e)) })) : i && s && c && await p.post({ url: "/api/user/login", headers: { "content-type": "application/json" }, body: { username: s, password: c } }).then(e => { o.info("Successfully logged in to QingLong Panel"), t = e.body.data.token, a.write("magic_qltoken", t) }).catch(e => { o.error("Error logging in to QingLong Panel.\n" + (e.message || e)) }), t } async function g(e) { let t = []; return await p.post({ url: "/api/envs", headers: { "content-type": "application/json" }, body: e }).then(e => { 200 === e.body.code ? e.body.data.forEach(e => { o.debug(`QINGLONG ADD ENV ${e.name} <${typeof e.value}> (${e.id})` + "\n" + JSON.stringify(e)), t.push(e.id) }) : o.error("Error adding environments variable from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error adding environments variable from QingLong Panel.\n" + (e.message || e)) }), t } async function n(n = null, e = "", t) { let o = []; return await p.get({ url: "/api/envs", headers: { "content-type": "application/json" }, params: { searchValue: e } }).then(e => { if (200 !== e.body.code) throw new Error("Error reading environment variable from QingLong Panel.\n" + JSON.stringify(e)); e = e.body.data; if (n) { var t = []; for (const r of e) r.name === n && o.push(r); o = t } o = e }).catch(e => { throw new Error("Error reading environments variable from QingLong Panel.\n" + (e.message || e)) }), o } async function f(e, t = "") { let r = ""; return await p.get({ url: "/api/scripts/" + e, params: { path: t } }).then(e => { if (200 !== e.body.code) throw new Error("Error reading data from QingLong Panel.\n" + JSON.stringify(e)); r = e.body.data }).catch(e => { throw new Error("Error reading data from QingLong Panel.\n" + (e.message || e)) }), r } async function h(e, t = "", r = "") { let n = !1; return await p.put({ url: "/api/scripts", headers: { "content-type": "application/json" }, body: { filename: e, path: t, content: r } }).then(e => { 200 === e.body.code ? n = !0 : o.error("Error reading data from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error reading data from QingLong Panel.\n" + (e.message || e)) }), n } return p.interceptors.request.use(function (e) { return i = i || a.read("magic_qlurl"), e.url.indexOf(i) < 0 && (e.url = "" + i + e.url), { ...e, timeout: 3e3 } }, void 0), p.interceptors.request.use(function (e) { return (l = l || a.read("magic_qlclient")) && (e.url = e.url.replace("/api/", "/open/")), e }, void 0, { runWhen: e => e.url.indexOf("api/user/login") < 0 && e.url.indexOf("open/auth/token") < 0 }), p.interceptors.request.use(async function (e) { return (t = t || a.read("magic_qltoken", "")) || await r(), e.headers.authorization = "Bearer " + t, e }, void 0, { runWhen: e => e.url.indexOf("api/user/login") < 0 && e.url.indexOf("open/auth/token") < 0 }), p.interceptors.request.use(function (e) { return e.params = { ...e.params, t: Date.now() }, e }, void 0, { runWhen: e => e.url.indexOf("open/auth/token") < 0 }), p.interceptors.request.use(function (e) { return i = i || a.read("magic_qlurl"), t = t || a.read("magic_qltoken"), o.debug("QingLong url: " + i + "\nQingLong token: " + t), e }, void 0), p.interceptors.response.use(void 0, async function (e) { try { var t = e.message || e.error || JSON.stringify(e); return (0 <= t.indexOf("NSURLErrorDomain") && 0 <= t.indexOf("-1012") || e.response && 401 === e.response.status) && e.config && !0 !== e.config.refreshToken ? (o.warning("QingLong Panel token has expired"), o.info("Refreshing the QingLong Panel token"), await r(), e.config.refreshToken = !0, o.info("Call the previous method again"), await p.request(e.config.method, e.config)) : Promise.reject(e) } catch (e) { return Promise.reject(e) } }), { url: i || a.read("magic_qlurl"), init: (e, t, r, n, o) => { i = e, l = t, u = r, s = n, c = o }, getToken: r, setEnv: async function (t, r, n = null) { if (i = i || a.read("magic_qlurl"), null === n) { var e = await g([{ name: t, value: r }]); if (e && 1 === e.length) return e[0] } else await p.put({ url: "/api/envs", headers: { "content-type": "application/json" }, body: { name: t, value: r, id: n } }).then(e => { if (200 === e.body.code) return o.debug(`QINGLONG UPDATE ENV ${t} <${typeof r}> (${n})` + "\n" + JSON.stringify(r)), !0; o.error("Error adding environment variable from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => (o.error("Error adding environment variable from QingLong Panel.\n" + (e.message || e)), !1)) }, setEnvs: g, getEnv: async function (e) { let t = null; for (const r of await n()) if (r.id === e) { t = r; break } return t }, getEnvs: n, delEnvs: async function (t) { return p.delete({ url: "/api/envs", headers: { accept: "application/json", "accept-language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6", connection: "keep-alive", "content-type": "application/json;charset=UTF-8", "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.5005.63 Safari/537.36 Edg/102.0.1245.30" }, body: t }).then(e => 200 === e.body.code ? (o.debug("QINGLONG DELETE ENV IDS: " + t), !0) : (o.error("Error deleting environments variable from QingLong Panel.\n" + JSON.stringify(e)), !1)).catch(e => { o.error("Error deleting environments variable from QingLong Panel.\n" + (e.message || e)) }) }, disableEnvs: async function (t) { let r = !1; return await p.put({ url: "/api/envs/disable", headers: { accept: "application/json", "accept-Language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6", connection: "keep-alive", "content-type": "application/json;charset=UTF-8", "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.5005.63 Safari/537.36 Edg/102.0.1245.30" }, body: t }).then(e => { 200 === e.body.code ? (o.debug("QINGLONG DISABLED ENV IDS: " + t), r = !0) : o.error("Error disabling environments variable from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error disabling environments variable from QingLong Panel.\n" + (e.message || e)) }), r }, enableEnvs: async function (t) { let r = !1; return await p.put({ url: "/api/envs/enable", headers: { accept: "application/json", "accept-language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6", connection: "keep-alive", "content-type": "application/json;charset=UTF-8", "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.5005.63 Safari/537.36 Edg/102.0.1245.30" }, body: t }).then(e => { 200 === e.body.code ? (o.debug("QINGLONG ENABLED ENV IDS: " + t), r = !0) : o.error("Error enabling environments variable from Qilong panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error enabling environments variable from Qilong panel.\n" + (e.message || e)) }), r }, addScript: async function (e, t = "", r = "") { let n = !1; return await p.post({ url: "/api/scripts", headers: { "content-type": "application/json" }, body: { filename: e, path: t, content: r } }).then(e => { 200 === e.body.code ? n = !0 : o.error("Error reading data from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error reading data from QingLong Panel.\n" + (e.message || e)) }), n }, getScript: f, editScript: h, delScript: async function (e, t = "") { let r = !1; return await p.delete({ url: "/api/scripts", headers: { "content-type": "application/json" }, body: { filename: e, path: t } }).then(e => { 200 === e.body.code ? r = !0 : o.error("Error reading data from QingLong Panel.\n" + JSON.stringify(e)) }).catch(e => { o.error("Error reading data from QingLong Panel.\n" + (e.message || e)) }), r }, write: async function (e, t, r = "") { var n = await f(d, ""), o = a.convertToObject(n), e = a.write(e, t, r, o), n = JSON.stringify(o, null, 4); return await h(d, "", n) && e }, read: async function (e, t, r = "", n = !1) { var o = await f(d, ""), o = a.convertToObject(o); return a.read(e, t, r, n, o) }, del: async function (e, t = "") { var r = await f(d, ""), n = a.convertToObject(r), e = a.del(e, t, n), r = JSON.stringify(n, null, 4), t = await h(d, "", r); return e && t }, update: async function (e, t, r, n = a.defaultValueComparator) { var o = await f(d, ""), i = a.convertToObject(o), e = a.update(e, t, r, n, i); let s = !1; return !0 === e && (o = JSON.stringify(i, null, 4), s = await h(d, "", o)), e && s }, batchWrite: async function (...e) { var t, r = await f(d, ""), n = a.convertToObject(r); for (t of e) a.write(t[0], t[1], void 0 !== t[2] ? t[2] : "", n); return r = JSON.stringify(n, null, 4), h(d, "", r) }, batchRead: async function (...e) { var t, r = await f(d, ""), n = a.convertToObject(r), o = []; for (t of e) { var i = a.read(t[0], t[1], void 0 !== t[2] ? t[2] : "", "boolean" == typeof t[3] && t[3], n); o.push(i) } return o }, batchUpdate: async function (...e) { var t, r = await f(d, ""), n = a.convertToObject(r); for (t of e) a.update(t[0], t[1], void 0 !== t[2] ? t[2] : "", void 0 !== t[3] ? t.comparator : a.defaultValueComparator, n); return r = JSON.stringify(n, null, 4), h(d, "", r) }, batchDel: async function (...e) { var t, r = await f(d, ""), n = a.convertToObject(r); for (t of e) a.del(t[0], void 0 !== t[1] ? t[1] : "", n); return r = JSON.stringify(n, null, 4), h(d, "", r) }, allSessions: async function (e) { var t = await f(d, ""), t = a.convertToObject(t); return a.allSessions(e, t) }, allSessionNames: async function (e) { var t = await f(d, ""), t = a.convertToObject(t); return a.allSessionNames(e, t) } } }
  972. //---SyncByPyScript---MagicJS3-end