From 6c45f314593b2511345e9bcab4e0a1ecb234faff Mon Sep 17 00:00:00 2001
From: blackmatrix7 <27717518+blackmatrix7@users.noreply.github.com>
Date: Thu, 15 Sep 2022 21:10:09 +0800
Subject: [PATCH] =?UTF-8?q?[=E9=A5=BF=E4=BA=86=E4=B9=88]=20=E6=94=AF?=
=?UTF-8?q?=E6=8C=81=E5=A4=9A=E8=B4=A6=E6=88=B7=E5=8F=8A=E9=9D=92=E9=BE=99?=
=?UTF-8?q?=E9=9D=A2=E6=9D=BF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
README.md | 19 +-
script/README.md | 26 +-
script/boxjs.json | 79 ++----
script/eleme/README.md | 74 +++---
script/eleme/eleme_daily.js | 436 +++++++++++++++++++++++-----------
script/eleme/eleme_mission.js | 159 -------------
6 files changed, 390 insertions(+), 403 deletions(-)
delete mode 100644 script/eleme/eleme_mission.js
diff --git a/README.md b/README.md
index 68d1ca446..40ee8a56e 100644
--- a/README.md
+++ b/README.md
@@ -35,13 +35,13 @@ https://github.com/blackmatrix7/ios_rule_script/tree/master/rewrite
自动化脚本在不同平台支持情况：
-| | Surge | Quantumult X | Loon | Shadowrocket | Node.js |
-| -------- | ----------- | ------------ | ----------- | ------------ | ---------------- |
-| 需要硬件 | iPhone/iPad | iPhone/iPad | iPhone/iPad | iPhone/iPad | 可长期运行的电脑 |
-| 脚本更新 | 自动更新 | 自动更新 | 自动更新 | 自动更新 | 手动更新 |
-| 推送通知 | 手机推送 | 手机推送 | 手机推送 | 手机推送 | 无 |
-| 使用成本 | 付费App | 付费App | 付费App | 付费App | 免费 |
-| 支持情况 | 优先支持 | 兼容支持 | 兼容支持 | 部分支持 | 部分支持 |
+| | Surge | Quantumult X | Loon | Shadowrocket | Node.js |
+| -------- | ----------- | ------------ | ----------- | ------------ | -------- |
+| 需要硬件 | iPhone/iPad | iPhone/iPad | iPhone/iPad | iPhone/iPad | 电脑/NAS |
+| 脚本更新 | 自动更新 | 自动更新 | 自动更新 | 自动更新 | 自动更新 |
+| 推送通知 | 手机推送 | 手机推送 | 手机推送 | 手机推送 | Bark |
+| 使用成本 | 付费App | 付费App | 付费App | 付费App | 免费 |
+| 支持情况 | 优先支持 | 兼容支持 | 兼容支持 | 部分支持 | 部分支持 |
优先支持：优先确保运行正常，出现异常优先解决
@@ -62,10 +62,9 @@ https://github.com/blackmatrix7/ios_rule_script/tree/master/rewrite
| [什么值得买](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/smzdm) | 什么值得买签到和去广告脚本 | MagicJS 3 | 正常 |
| [百度贴吧](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/tieba) | 带重试功能的贴吧签到，提高签到成功率 | MagicJS 3 | 正常 |
| [开屏去广告](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/startup) | 通过脚本去除缓存到本地的APP开屏广告 | MagicJS 2 | 正常 |
-| [家长帮](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/jiazhangbang) | 每日自动签到 | MagicJS 2 | 正常 |
| [慢慢买](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/manmanbuy) | 每日自动签到 | MagicJS 2 | 正常 |
-| [叮咚买菜](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/dingdong) | 每日自动签到 | MagicJS 2 | 正常 |
-| [饿了么](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/eleme) | 每日自动领取会员任务 | MagicJS 2 | 正常 |
+| [叮咚买菜](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/dingdong) | 每日自动签到 | MagicJS 3 | 正常 |
+| [饿了么](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/eleme) | 每日自动领取吃货豆和会员任务 | MagicJS 3 | 正常 |
| [Fa米家](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/famijia) | 每日自动签到 | MagicJS 2 | 正常 |
| [Luka](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/luka) | 每日自动签到 | MagicJS 2 | 正常 |
| [美团买菜](https://github.com/blackmatrix7/ios_rule_script/tree/master/script/meituan) | 每日自动签到 | MagicJS 2 | 正常 |
diff --git a/script/README.md b/script/README.md
index 0b7841008..4475f55bd 100644
--- a/script/README.md
+++ b/script/README.md
@@ -128,13 +128,13 @@ MagicJS 3 增加“青龙面板模块”，可以将所使用的变量，直接
JavaScript脚本可以执行非常多的操作，通常来说，在客户端中调用脚本属于高风险行为。您在使用脚本前，务必确认脚本安全可信，如果有条件，应该仔细阅读脚本代码。
-特别需要注意：
+### 特别注意
-### 脚本是否含有对外发送请求的操作
+#### 脚本是否含有对外发送请求的操作
如带有Cookie、Token、Password等等可以作为身份凭证的请求，这类请求比较敏感，务必确认请求的目标安全可信。理论上恶意脚本可以利用你的Cookie，进行非常多的行为，如发帖、购物等等。
-### 脚本对响应体进行修改
+#### 脚本对响应体进行修改
对于修改响应体的脚本，必须确认修改响应体内容可信。通过对Http请求响应体的修改，可以在客户端上显示一些欺诈信息，例如显示一些虚假的中奖信息。
@@ -146,5 +146,23 @@ JavaScript脚本可以执行非常多的操作，通常来说，在客户端中
**出于安全性考虑，不建议使用任何被加密、混淆的脚本。**
-如果你在使用青龙面板，由于magic.json内的数据是完全开放不做加密的，并不能防止其他恶意脚本读取magic.json导致信息泄露。所以请务必确保在青龙面板上运行脚本的安全性，本仓库的脚本不会窃取你的数据，但是无法避免第三方恶意脚本，窃取由本仓库的脚本存储/生成的数据。
+### 青龙面板
+
+如果你在使用青龙面板，由于magic.json内的数据是完全开放不做加密的，并不能防止其他恶意脚本读取magic.json导致信息泄露。
+
+所以请务必确保在青龙面板上运行脚本的安全性，本仓库的脚本不会窃取你的数据，但是无法避免第三方恶意脚本，窃取由magic.json的内容。
+
+##### 数据同步
+
+MagicJS 3的青龙模块，提供了快速将手机上数据同步至青龙面板的功能，但也带来额外的安全风险。
+
+青龙面板所需的登录配置，受运行环境限制，仅能以明文的形式存储在客户端提供的存储池中。
+
+如果恶意脚本篡改青龙面板的登录配置，脚本会将你的Cookies等数据，同步至恶意脚本所提供的青龙面板中，造成信息泄露。此类风险，在当前的条件下，没有很好的解决方式。
+
+**所以再次建议不要使用被混淆和加密的脚本。**
+
+
+
+
diff --git a/script/boxjs.json b/script/boxjs.json
index 3e620a441..e90404909 100644
--- a/script/boxjs.json
+++ b/script/boxjs.json
@@ -171,10 +171,11 @@
"id": "blackmatrix7.eleme",
"name": "饿了么",
"keys": [
- "eleme_app_cookie",
- "eleme_app_longitude",
- "eleme_app_latitude",
- "eleme_task_keywords"
+ "eleme_cookies",
+ "eleme_coordinate",
+ "eleme_mission",
+ "eleme_task_keywords",
+ "eleme_sync_qinglong"
],
"author": "@blackmatrix7",
"repo": "https://github.com/blackmatrix7/ios_rule_script/tree/master/script/eleme",
@@ -182,43 +183,24 @@
"https://raw.githubusercontent.com/Orz-3/mini/master/Alpha/elem.png",
"https://raw.githubusercontent.com/Orz-3/mini/master/Color/elem.png"
],
- "scripts": [
- {
- "name": "领取吃货豆",
- "script": "https://raw.githubusercontent.com/blackmatrix7/ios_rule_script/master/script/eleme/eleme_daily.js"
- },
- {
- "name": "领取会员任务",
- "script": "https://raw.githubusercontent.com/blackmatrix7/ios_rule_script/master/script/eleme/eleme_mission.js"
- }
- ],
"settings": [
{
- "id": "eleme_app_cookie",
+ "id": "eleme_cookies",
"name": "Cookie",
"val": "",
- "type": "input",
+ "type": "textarea",
"placeholder": "",
"autoGrow": true,
"desc": "填写获取的饿了么Cookie"
},
{
- "id": "eleme_app_longitude",
- "name": "经度",
+ "id": "eleme_coordinate",
+ "name": "坐标",
"val": "",
- "type": "input",
+ "type": "textarea",
"placeholder": "",
"autoGrow": true,
- "desc": "填写抓包获取的饿了么经度"
- },
- {
- "id": "eleme_app_latitude",
- "name": "纬度",
- "val": "",
- "type": "input",
- "placeholder": "",
- "autoGrow": true,
- "desc": "填写抓包获取的饿了么纬度"
+ "desc": "填写抓包获取的饿了么坐标"
},
{
"id": "eleme_task_keywords",
@@ -230,33 +212,18 @@
"desc": "只领取含有关键字的任务"
},
{
- "id": "magicjs_loglevel",
- "name": "日志等级",
- "val": "INFO",
- "type": "radios",
- "items": [
- {
- "key": "INFO",
- "label": "INFO"
- },
- {
- "key": "WARNING",
- "label": "WARNING"
- },
- {
- "key": "ERROR",
- "label": "ERROR"
- },
- {
- "key": "CRITICAL",
- "label": "CRITICAL"
- },
- {
- "key": "DEBUG",
- "label": "DEBUG"
- }
- ],
- "desc": "出现异常时请选择DEBUG提交日志"
+ "id": "eleme_mission",
+ "name": "领取会员任务",
+ "val": true,
+ "type": "boolean",
+ "desc": "根据任务关键字领取会员任务"
+ },
+ {
+ "id": "eleme_sync_qinglong",
+ "name": "同步Cookie到青龙面板",
+ "val": false,
+ "type": "boolean",
+ "desc": "将获取的Cookies和坐标同步至青龙面板"
}
]
},
diff --git a/script/eleme/README.md b/script/eleme/README.md
index ed0f8cb5c..956772860 100644
--- a/script/eleme/README.md
+++ b/script/eleme/README.md
@@ -1,8 +1,8 @@
-# 饿了么
+# 🧸饿了么
-饿了么每日自动领取会员任务，及自动领取吃货豆功能。
+饿了么每日自动领取会员任务及吃货豆功能。
-领取会员任务，限饿了么会员使用，解决忘记领取会员任务再下单的问题。
+领取会员任务，限饿了么会员使用，解决下单前忘记领取会员任务的问题。
自动领取吃货豆，非会员可能能用，我没有非会员账号，无法验证，有兴趣可以自己试试。
@@ -14,7 +14,9 @@
### 多选一任务
-脚本会依次尝试领取所有任务。但因为多选一的关系，通常只会有第一个任务能成功领取。
+默认会领取含有“美食外卖”关键字的任务，可以在BoxJS中自定义关键字。
+
+脚本会依次尝试领取所有匹配关键字的任务。但因为多选一的关系，通常只会有第一个任务能成功领取。
## 配置说明
@@ -44,7 +46,6 @@ https://raw.githubusercontent.com/blackmatrix7/ios_rule_script/master/script/ele
[task_local]
05 10 * * * https://raw.githubusercontent.com/blackmatrix7/ios_rule_script/master/script/eleme/eleme_daily.js, tag=饿了么_领取吃货豆, enabled=true
-05 10 * * * https://raw.githubusercontent.com/blackmatrix7/ios_rule_script/master/script/eleme/eleme_mission.js, tag=饿了么_领取会员任务, enabled=true
```
## 获取数据
@@ -53,7 +54,7 @@ https://raw.githubusercontent.com/blackmatrix7/ios_rule_script/master/script/ele
打开饿了么APP即可。
-Surge需要关闭MITM over HTTP/2，你可以获取成功后再打开。
+**Surge需要关闭MITM over HTTP/2，你可以获取成功后再打开。**
### 获取坐标
@@ -61,8 +62,6 @@ Surge需要关闭MITM over HTTP/2，你可以获取成功后再打开。
由于获取坐标的请求不是每次都触发的，如果没有正确获取到坐标，建议移除饿了么APP后台，间隔10分钟后，再尝试上述操作。
-或者通过其他途径获取自身坐标，通过BoxJS填入。
-
## Bark推送
通过BoxJS，配置Bark推送链接，可以将脚本通知，通过Bark推送到其他设备上。
@@ -75,45 +74,38 @@ Surge需要关闭MITM over HTTP/2，你可以获取成功后再打开。
-## 青龙面板
+## 多账户
-MagicJS所有的变量，都存储在脚本同级目录下的`magic.json`文件中，不支持通过环境变量读取变量。
+目前无法在单台iPhone/iPad设备上实现多账户执行日常任务和领取吃货豆。
-在青龙面板中，在左侧菜单选择脚本管理，新建 `magic.json` 文件(文件名不可修改)。
+多账户更多的作用是在多设备的情况下，将Cookies和坐标同步至青龙面板，由青龙面板执行多账户作业。
-写入如下json：
+## 脚本变量
+
+你可以根据下表，在magic.json中配置所需数据。
+
+| 变量名 | 类型 | 说明 |
+| ------------------- | ------ | ---------------------------------------------- |
+| eleme_cookies | Json | 饿了么Cookie |
+| eleme_coordinate | Json | 饿了么坐标 |
+| eleme_mission | Bool | 是否领取会员任务 |
+| eleme_task_keywords | String | 饿了么任务关键词，含有此关键词的任务才会被领取 |
+| eleme_sync_qinglong | Bool | 是否同步Cookies和坐标到青龙面板 |
+
+部分变量示例
```json
{
- "eleme_app_cookie": "xxxxxxxxxxxxxxxxx",
- "eleme_app_longitude": "111.1111111111",
- "eleme_app_latitude": "111.1111111111",
- "eleme_task_keywords": "美食外卖",
- "bark_url": "https://api.day.app/xxxxxxxxxxxxxxxxxx/"
-}
-```
-
-变量说明
-
-| 变量名 | 说明 |
-| ------------------- | ---------------------------------------------- |
-| eleme_app_cookie | 饿了么Cookie |
-| eleme_app_longitude | 饿了么经度 |
-| eleme_app_latitude | 饿了么纬度 |
-| eleme_task_keywords | 饿了么任务关键词，含有此关键词的任务才会被领取 |
-| bark_url | Bark推送地址 |
-
-如果你正在使用多个由MagicJS支持的脚本，可以将变量写在同一个`magic.json`文件中，例如：
-
-```json
-{
- "smzdm_cookie": "xxxxxxxxxxxxxxxxxxxxx",
- "smzdm_session": "xxxxxxxxxxxxxxxxxxxxx",
- "eleme_app_cookie": "xxxxxxxxxxxxxxxxx",
- "eleme_app_longitude": "111.1111111111",
- "eleme_app_latitude": "111.1111111111",
- "eleme_task_keywords": "美食外卖",
- "bark_url": "https://api.day.app/xxxxxxxxxxxxxxxxxx/"
+ "eleme_cookies": {
+ "magic_session": true,
+ "UserId1": "Cookie1",
+ "UserId2": "Cookie2"
+ },
+ "eleme_coordinate": {
+ "magic_session": true,
+ "UserId1": {"longitude": "xxxxxxxxxxxx", "latitude": "xxxxxxxxxxxxxx"},
+ "UserId2": {"longitude": "xxxxxxxxxxxx", "latitude": "xxxxxxxxxxxxxx"}
+ }
}
```
diff --git a/script/eleme/eleme_daily.js b/script/eleme/eleme_daily.js
index bb0299a37..e815d983f 100644
--- a/script/eleme/eleme_daily.js
+++ b/script/eleme/eleme_daily.js
@@ -2,110 +2,161 @@ const scriptName = '饿了么';
const getCoordinateRegex1 = /^https?:\/\/air\.tb\.ele\.me\/app\/conch-page\/svip-home-tasklist-new\/home\?.*longitude=([^&]*).*latitude=([^&]*)/;
const getCoordinateRegex2 = /^https?:\/\/tb\.ele\.me\/wow\/alsc\/mod\/.*longitude=([^&]*).*latitude=([^&]*)/;
const getCoordinateRegex3 = /^https?:\/\/h5\.ele\.me\/restapi\/biz\.svip_scene\/svip\/engine\/queryTrafficSupply\?.*longitude=([^&]*).*latitude=([^&]*)/;
-const getCookies = /^https?:\/\/air\.tb\.ele\.me\/app\/conch-page\/svip-foodie-card\/home/;
-const elemeCookieKey = 'eleme_app_cookie';
-const elemeLongitudeKey = 'eleme_app_longitude';
-const elemeLatitudeKey = 'eleme_app_latitude';
+const getCookiesRegex = /^https?:\/\/air\.tb\.ele\.me\/app\/conch-page\/svip-foodie-card\/home/;
+const elemeCookieKey = 'eleme_cookies';
+const elemeCoordinateKey = 'eleme_coordinate';
+const elemeMissionKey = 'eleme_mission';
+const elemeSyncQinglongKey = 'eleme_sync_qinglong';
+const elemeTaskKey = "eleme_task_keywords";
+let currentUserId = "";
+let currentCookies = "";
+let currentCoordinate = null;
-let magicJS = MagicJS(scriptName, "INFO");
-magicJS.unifiedPushUrl = magicJS.read("bark_url");
+const $ = MagicJS(scriptName, "INFO");
-function GetCoordinate() {
+function getUserId(cookies) {
+ if (!!cookies) {
+ let userId = /USERID=(\d*)/.exec(cookies)[1];
+ $.logger.info(`当前UserId：${userId}`);
+ return userId;
+ }
+}
+
+async function getCoordinate() {
try {
- let arr = [];
- const hisLongitude = magicJS.read(elemeLongitudeKey);
- const hisLatitude = magicJS.read(elemeLatitudeKey);
- arr = magicJS.request.url.match(getCoordinateRegex1);
+ $.logger.debug(`当前获取的header\n${$.request.headers}`);
+ currentUserId = getUserId($.request.headers.Cookie);
+ let hisCoordinate = $.data.read(elemeCoordinateKey, "", currentUserId);
+ arr = $.request.url.match(getCoordinateRegex1);
if (arr && arr.length < 2) {
- arr = magicJS.request.url.match(getCoordinateRegex2);
+ arr = $.request.url.match(getCoordinateRegex2);
}
if (arr && arr.length < 2) {
- arr = magicJS.request.url.match(getCoordinateRegex3);
+ arr = $.request.url.match(getCoordinateRegex3);
}
const longitude = arr[1];
const latitude = arr[2];
- magicJS.write(elemeLongitudeKey, longitude);
- magicJS.write(elemeLatitudeKey, latitude);
- if (longitude !== hisLongitude || latitude !== hisLatitude) {
- magicJS.notify(`更新坐标成功！`)
+ if (!hisCoordinate || (!!hisCoordinate && (hisCoordinate.longitude !== longitude || hisCoordinate.latitude !== latitude))) {
+ $.data.write(elemeCoordinateKey, { longitude, latitude }, currentUserId);
+ $.notification.post("更新坐标成功");
+ }
+ const syncQinglong = $.data.read(elemeSyncQinglongKey, false);
+ if (syncQinglong === true) {
+ // 获取青龙面板存储的坐标
+ hisCoordinate = await $.qinglong.read(elemeCoordinateKey, "", currentUserId);
+ if (!hisCoordinate || (!!hisCoordinate && (hisCoordinate.longitude !== longitude || hisCoordinate.latitude !== latitude))) {
+ await $.qinglong.write(elemeCoordinateKey, { longitude, latitude }, currentUserId);
+ $.notification.post("同步坐标至青龙面板成功");
+ }
}
}
catch (err) {
- magicJS.notify('获取坐标出现异常，请查阅日志。');
- magicJS.logError(`获取坐标出现执行异常，异常信息：${err}`);
+ $.notify('获取坐标出现异常，请查阅日志。');
+ $.logError(`获取坐标出现执行异常，异常信息：${err}`);
}
}
-
-function GetCookies() {
- let cookie = magicJS.request.headers.Cookie;
- let hisCookie = magicJS.read(elemeCookieKey);
- let compareCookie2 = !!cookie ? /cookie2=([a-zA-Z0-9]*)/.exec(cookie)[1] : null;
- let compareHisCookie2 = !!hisCookie ? /cookie2=([a-zA-Z0-9]*)/.exec(hisCookie)[1] : null;
- if (cookie && (!hisCookie || compareCookie2 !== compareHisCookie2)) {
- magicJS.write(elemeCookieKey, cookie);
- magicJS.logInfo(`旧的Cookie：${hisCookie}\n新的Cookie：${cookie}\nCookie不同，写入新的Cookie成功！`);
- magicJS.notify('Cookie写入成功！！');
+async function getCookies() {
+ try {
+ const cookie = $.request.headers.Cookie;
+ $.logger.info(`本次运行获取的新Cookies\n${cookie}`);
+ currentUserId = getUserId(cookie);
+ const compareCookie2 = !!cookie ? /cookie2=([a-zA-Z0-9]*)/.exec(cookie)[1] : null;
+ // 获取存储池中的旧Cookie
+ let hisCookie = $.data.read(elemeCookieKey, "", currentUserId);
+ $.logger.info(`存储池中旧的Cookies\n${hisCookie}`);
+ if (!!cookie) {
+ if (!hisCookie) {
+ $.data.write(elemeCookieKey, cookie, currentUserId);
+ $.notification.post("Cookie获取成功！");
+ }
+ else {
+ const compareHisCookie2 = !!hisCookie ? /cookie2=([a-zA-Z0-9]*)/.exec(hisCookie)[1] : null;
+ $.logger.info(`用于比较Cookie变化\n新:${compareCookie2}\n旧:${compareHisCookie2}`);
+ if (compareCookie2 !== compareHisCookie2) {
+ $.data.write(elemeCookieKey, cookie, currentUserId);
+ $.notification.post("Cookie更新成功！");
+ }
+ }
+ if ($.data.read(elemeSyncQinglongKey, false) === true) {
+ hisCookie = await $.qinglong.read(elemeCookieKey, "", currentUserId);
+ $.logger.info(`青龙面板中旧的Cookies\n${hisCookie}`);
+ if (!hisCookie) {
+ await $.qinglong.write(elemeCookieKey, cookie, currentUserId);
+ $.notification.post("Cookie同步至青龙面板成功！");
+ }
+ else {
+ const compareHisCookie2 = !!hisCookie ? /cookie2=([a-zA-Z0-9]*)/.exec(hisCookie)[1] : null;
+ $.logger.info(`用于比较Cookie变化\n新:${compareCookie2}\n旧:${compareHisCookie2}`);
+ if (compareCookie2 !== compareHisCookie2) {
+ await $.qinglong.write(elemeCookieKey, cookie, currentUserId);
+ $.notification.post("Cookie同步至青龙面板成功！");
+ }
+ }
+ }
+ }
+ else {
+ $.logger.warning('没有获取到有效的Cookies，Surge请关闭MITM over HTTP/2')
+ }
}
- else {
- magicJS.logInfo('Cookie没有变化，无需更新');
+ catch (err) {
+ $.logger.error(`获取Cookies出现异常\n${err}`);
}
}
+function addConfig(config) {
+ currentCoordinate = currentCoordinate || $.data.read(elemeCoordinateKey, "", currentUserId);
+ config.headers.Cookie = currentCookies;
+ config.headers["x-shard"] = `loc=${currentCoordinate.longitude},${currentCoordinate.latitude}`;
+ return config;
+}
+$.http.interceptors.request.use(addConfig);
+
// 获取待领取的吃货豆列表
-function GetPeaList(cookie, longitude, latitude) {
+function getPeaList() {
return new Promise((resolve, reject) => {
- let options = {
- url: `https://h5.ele.me/restapi/biz.svip_core/v1/foodie/homepage?longitude=${longitude}&latitude=${latitude}`,
+ currentCoordinate = currentCoordinate || $.data.read(elemeCoordinateKey, "", currentUserId);
+ $.http.get({
+ url: `https://h5.ele.me/restapi/biz.svip_core/v1/foodie/homepage?longitude=${currentCoordinate.longitude}&latitude=${currentCoordinate.latitude}`,
headers: {
"Accept": "application/json, text/plain, */*",
"Accept-Encoding": "gzip, deflate, br",
"Accept-Language": "zh-cn",
"Connection": "keep-alive",
- "Cookie": cookie,
"Host": "h5.ele.me",
"Referer": "https://h5.ele.me/svip/home?entryStat=profile",
"User-Agent": "Rajax/1 Apple/iPhone10,3 iOS/14.2 Eleme/9.3.8",
"f-pTraceId": "WVNet_WV_2-3-74",
- "f-refer": "wv_h5",
- "x-shard": `loc=${longitude},${latitude}`
+ "f-refer": "wv_h5"
}
- }
- magicJS.get(options, (err, resp, data) => {
- if (err) {
- magicJS.logError(`获取待领取的吃货豆失败，请求异常：${err}`);
- reject('获取待领取的吃货豆失败，请求异常，请查阅日志！');
+ }).then(resp => {
+ const obj = resp.body;
+ if (obj.success === true) {
+ let peaList = [];
+ obj.foodiePeaBlock.peaList.forEach(element => {
+ peaList.push({ 'id': element.id, 'count': element.count, 'description': element.description });
+ });
+ $.logger.info(`获取待领取的吃货豆成功：${JSON.stringify(peaList)}`);
+ resolve(peaList);
}
else {
- try {
- magicJS.logDebug(`获取待领取吃货豆列表响应结果：${data}`);
- let obj = typeof data === 'string' ? JSON.parse(data) : data;
- if (obj.success === true) {
- let peaList = [];
- obj.foodiePeaBlock.peaList.forEach(element => {
- peaList.push({ 'id': element.id, 'count': element.count, 'description': element.description });
- });
- magicJS.logInfo(`获取待领取的吃货豆成功：${JSON.stringify(peaList)}`);
- resolve(peaList);
- }
- else {
- magicJS.logError(`获取待领取的吃货豆失败，响应异常：${data}`);
- reject('获取待领取的吃货豆失败，响应异常，请查阅日志！');
- }
- }
- catch (err) {
- magicJS.logError(`获取待领取的吃货豆失败，执行异常：${err}，接口响应：${data}`);
- reject('获取待领取的吃货豆失败，执行异常，请查阅日志！');
- }
+ const msg = `获取待领取的吃货豆失败\n${JSON.stringify(obj)}`;
+ $.logger.warning(msg);
+ reject(msg);
}
+ }).catch(err => {
+ const msg = `获取待领取的吃货豆出现异常\n${err}`;
+ $.logger.error(msg);
+ reject(msg);
})
})
}
// 领取吃货豆
-function DrawPea(cookie, peaId, longitude, latitude) {
+function drawPea(peaId) {
return new Promise((resolve, reject) => {
- let options = {
+ currentCoordinate = currentCoordinate || $.data.read(elemeCoordinateKey, "", currentUserId);
+ $.http.post({
url: `https://h5.ele.me/restapi/biz.svip_bonus/v1/users/supervip/pea/draw?peaId=${peaId}`,
headers: {
"Accept": "application/json, text/plain, */*",
@@ -113,101 +164,220 @@ function DrawPea(cookie, peaId, longitude, latitude) {
"Accept-Language": "zh-cn",
"Connection": "keep-alive",
"Content-Type": "application/json;charset=utf-8",
- "Cookie": cookie,
"Host": "h5.ele.me",
"Origin": "https://h5.ele.me",
"Referer": "https://h5.ele.me/svip/home?entryStat=profile",
"User-Agent": "Rajax/1 Apple/iPhone10,3 iOS/14.2 Eleme/9.3.8",
"f-pTraceId": "WVNet_WV_2-3-73",
- "f-refer": "wv_h5",
- "x-shard": `loc=${longitude},${latitude}`
+ "f-refer": "wv_h5"
},
- body: JSON.stringify({
- "longitude": longitude,
- "latitude": latitude
- })
- }
- magicJS.post(options, (err, resp, data) => {
- if (err) {
- magicJS.logError(`领取吃货豆失败，请求异常：${err}`);
- reject('领取吃货豆失败，请求异常，请查阅日志！');
+ body: JSON.stringify(currentCoordinate)
+ }).then(resp => {
+ const obj = resp.body;
+ if (obj.success === true) {
+ $.logger.info(`领取吃货豆成功\n${JSON.stringify(obj)}`);
+ resolve(true);
}
else {
- try {
- magicJS.logDebug(`领取吃货豆响应结果：${data}`);
- let obj = typeof data === 'string' ? JSON.parse(data) : data;
- if (obj.success === true) {
- magicJS.logInfo(`领取吃货豆成功：${data}`);
- resolve(true);
- }
- else {
- magicJS.logError(`领取吃货豆失败，响应异常：${data}`);
- reject('领取吃货豆失败，响应异常，请查阅日志！');
- }
- }
- catch (err) {
- magicJS.logError(`领取吃货豆失败，执行异常：${err}，接口响应：${data}`);
- reject('领取吃货豆失败，执行异常，请查阅日志！');
- }
+ const msg = `领取吃货豆失败\n${JSON.stringify(obj)}`;
+ $.logger.warning(msg);
+ reject(msg)
}
+ }).catch(err => {
+ const msg = `领取吃货豆异常\n${err}`;
+ $.logger.error(msg);
+ reject(msg)
})
})
}
+// 获取超级会员任务列表
+function getSuperVipMissions() {
+ return new Promise((resolve, reject) => {
+ // 获取配置的任务关键词
+ let taskKeywords = $.data.read(elemeTaskKey, "美食外卖");
+ $.logger.info(`只获取含有以下关键词的任务：${taskKeywords}`);
+ taskKeywords = taskKeywords.split(';');
+ // 获取坐标
+ currentCoordinate = currentCoordinate || $.data.read(elemeCoordinateKey, "", currentUserId);
+ $.http.get({
+ url: `https://h5.ele.me/restapi/svip_biz/v1/supervip/query_mission_list?longitude=${currentCoordinate.longitude}&latitude=${currentCoordinate.latitude}`,
+ headers: {
+ "Accept": "application/json, text/plain, */*",
+ "Accept-Encoding": "gzip, deflate, br",
+ "Accept-Language": "zh-cn",
+ "Connection": "keep-alive",
+ "Host": "h5.ele.me",
+ "Referer": "https://h5.ele.me/svip/home?entryStat=profile",
+ "User-Agent": "Rajax/1 Apple/iPhone10,3 iOS/14.2 Eleme/9.3.8",
+ "f-pTraceId": "WVNet_WV_2-3-30",
+ "f-refer": "wv_h5"
+ },
+ }).then(resp => {
+ const obj = resp.body;
+ if (obj && obj.missions) {
+ let result = [];
+ obj.missions.forEach((element) => {
+ let missionInfo = JSON.stringify(element);
+ let flag = false;
+ for (keyword of taskKeywords) {
+ if (missionInfo.indexOf(keyword) >= 0) {
+ flag = true;
+ break;
+ }
+ }
+ if (flag === true) {
+ result.push(element.mission_id);
+ }
+ });
+ resolve(result);
+ }
+ else {
+ const msg = `获取待领取的会员任务失败\n${JSON.stringify(obj)}`;
+ $.logger.warning(msg);
+ reject(msg);
+ }
+ }).catch(err => {
+ const msg = `获取待领取的会员任务异常\n${JSON.stringify(err)}`;
+ $.logger.error(msg);
+ reject(msg);
+ })
+ });
+}
+
+// 接受超级会员任务列表中的任务
+function acceptMission(missionId) {
+ return new Promise((resolve, reject) => {
+ const _mission_id = encodeURIComponent(missionId);
+ // 获取坐标
+ currentCoordinate = currentCoordinate || $.data.read(elemeCoordinateKey, "", currentUserId);
+ $.http.post({
+ url: `https://h5.ele.me/restapi/svip_biz/v1/supervip/accept_mission?type=0&receiveType=1&mission_id=${_mission_id}`,
+ headers: {
+ "Accept": "application/json, text/plain, */*",
+ "Accept-Encoding": "gzip, deflate, br",
+ "Accept-Language": "zh-cn",
+ "Connection": "keep-alive",
+ "Content-Type": "application/json;charset=utf-8",
+ "Host": "h5.ele.me",
+ "Origin": "https://h5.ele.me",
+ "Referer": "https://h5.ele.me/svip/home?entryStat=profile",
+ "User-Agent": "Rajax/1 Apple/iPhone10,3 iOS/14.5.1 Eleme/9.8.5",
+ "f-pTraceId": "WVNet_WV_1-1-40",
+ "f-refer": "wv_h5"
+ },
+ body: currentCoordinate,
+ }).then(resp => {
+ const obj = resp.body;
+ if (obj.success === true) {
+ $.logger.info(`领取会员任务成功，任务Id：${missionId}，任务描述：${obj.mission.checkout_description}`);
+ resolve(obj.mission.checkout_description);
+ } else {
+ const msg = `领取会员任务失败，任务Id：${missionId}\n${JSON.stringify(obj)}`;
+ $.logger.warning(msg);
+ reject(msg);
+ }
+ }).catch(err => {
+ const msg = `领取会员任务异常，任务Id：${missionId}\n${err}`;
+ $.logger.error(msg);
+ reject(msg);
+ })
+ });
+}
+
+
; (async () => {
- if (magicJS.isRequest) {
+ if ($.isRequest) {
if ((
- getCoordinateRegex1.test(magicJS.request.url) ||
- getCoordinateRegex2.test(magicJS.request.url) ||
- getCoordinateRegex3.test(magicJS.request.url)
- ) && magicJS.request.method == "GET") {
- GetCoordinate();
+ getCoordinateRegex1.test($.request.url) ||
+ getCoordinateRegex2.test($.request.url) ||
+ getCoordinateRegex3.test($.request.url)
+ ) && $.request.method == "GET") {
+ await getCoordinate();
}
- else if (getCookies.test(magicJS.request.url)) {
- GetCookies();
+ else if (getCookiesRegex.test($.request.url)) {
+ await getCookies();
}
}
else {
- let subTitle = "";
- let content = "";
- let cookie = magicJS.read(elemeCookieKey);
- let longitude = magicJS.read(elemeLongitudeKey);
- let latitude = magicJS.read(elemeLatitudeKey);
- if (!!!cookie) {
- magicJS.logWarning('没有读取到Cookie，请先从App中获取一次Cookie！');
- content = '❓没有读取到有效Cookie，请先从App中获取Cookie!!';
+ const allSessions = $.data.allSessions(elemeCookieKey);
+ if (!allSessions) {
+ const msg = "没有读取到需要执行的Cookies，请先打开饿了么获取!";
+ $.logger.warning(msg);
+ $.notification.post(msg);
}
else {
- // 获取待领取的吃货豆
- let [getPeaListErr, peaList] = await magicJS.attempt(GetPeaList(cookie, longitude, latitude), []);
- content = '吃货豆领取结果：';
- if (getPeaListErr) {
- content += '\n获取待领取的吃货豆异常，请查阅日志';
- }
- else if (peaList.length == 0) {
- content += '\n没有发现待领取的吃货豆';
- }
- else {
+ $.logger.info(`共${allSessions.length}个Cookies需要执行`);
+ for (let [index, session] of allSessions.entries()) {
+ $.logger.info(`正在执行第 ${index + 1} 个Cookie的任务`);
+ let content = "";
+ currentUserId = session;
+ currentCookies = $.data.read(elemeCookieKey, "", session);
+ // 获取待领取的吃货豆
+ $.logger.info("开始领取吃货豆")
let peaCount = 0;
let drawPeaContent = '';
- for (let j = 0; j < peaList.length; j++) {
- let [drawPeaErr, result] = await magicJS.attempt(DrawPea(cookie, peaList[j].id, longitude, latitude), false);
- if (drawPeaErr || result === false) {
- drawPeaContent += `\n${peaList[j].description}-${peaList[j].count}吃货豆-领取失败`;
- }
- else {
- peaCount += peaList[j].count;
- drawPeaContent += `\n${peaList[j].description}-${peaList[j].count}吃货豆-领取成功`;
- }
- await magicJS.sleep(1000);
+ const peaList = await getPeaList();
+ if (!!peaList && peaList.length > 0) {
+ let tasks = [];
+ peaList.forEach(pea => {
+ tasks.push($.utils.retry(drawPea, 3, 500)(pea.id).then(() => {
+ peaCount += pea.count;
+ drawPeaContent += `\n${pea.description}-${pea.count}吃货豆-领取成功`;
+ }).catch(() => {
+ drawPeaContent += `\n${pea.description}-${pea.count}吃货豆-领取失败`;
+ }));
+ });
+ await Promise.all(tasks).then(() => {
+ content = `本次共领取吃货豆${peaCount}个`;
+ $.logger.info(drawPeaContent);
+ })
}
- content += `\n本次共领取吃货豆${peaCount}个${drawPeaContent}`;
+ else {
+ const msg = "没发现待领取的吃货豆";
+ content = msg;
+ $.logger.info(msg);
+ }
+
+ // 根据关键词领取任务
+ if ($.data.read(elemeMissionKey, true) === true) {
+ const missionIds = await $.utils.retry(getSuperVipMissions, 3, 1000)().catch(err => {
+ $.notification.post(err);
+ });
+ if (!!missionIds && missionIds.length > 0) {
+ $.logger.info(`匹配关键词的任务Id:\n${JSON.stringify(missionIds)}`);
+ content += !!content? "\n": "";
+ content += "会员任务领取结果:\n";
+ for (let missionId of missionIds) {
+ await $.utils.retry(acceptMission, 3, 1000)(missionId).then((desc) => {
+ content += desc;
+ }).catch(err => {
+ $.notification.post(err);
+ })
+ }
+ }
+ }
+ $.notification.post(`${scriptName} - ${currentUserId}`, "", content);
+ $.logger.info(`第 ${index + 1} 个Cookie任务执行完毕`);
}
}
- // 通知
- magicJS.notify(scriptName, subTitle, content);
}
- magicJS.done();
+ $.done();
})();
-function MagicJS(e = "MagicJS", t = "INFO") { const s = { accept: "Accept", "accept-ch": "Accept-CH", "accept-charset": "Accept-Charset", "accept-features": "Accept-Features", "accept-encoding": "Accept-Encoding", "accept-language": "Accept-Language", "accept-ranges": "Accept-Ranges", "access-control-allow-credentials": "Access-Control-Allow-Credentials", "access-control-allow-origin": "Access-Control-Allow-Origin", "access-control-allow-methods": "Access-Control-Allow-Methods", "access-control-allow-headers": "Access-Control-Allow-Headers", "access-control-max-age": "Access-Control-Max-Age", "access-control-expose-headers": "Access-Control-Expose-Headers", "access-control-request-method": "Access-Control-Request-Method", "access-control-request-headers": "Access-Control-Request-Headers", age: "Age", allow: "Allow", alternates: "Alternates", authorization: "Authorization", "cache-control": "Cache-Control", connection: "Connection", "content-encoding": "Content-Encoding", "content-language": "Content-Language", "content-length": "Content-Length", "content-location": "Content-Location", "content-md5": "Content-MD5", "content-range": "Content-Range", "content-security-policy": "Content-Security-Policy", "content-type": "Content-Type", cookie: "Cookie", dnt: "DNT", date: "Date", etag: "ETag", expect: "Expect", expires: "Expires", from: "From", host: "Host", "if-match": "If-Match", "if-modified-since": "If-Modified-Since", "if-none-match": "If-None-Match", "if-range": "If-Range", "if-unmodified-since": "If-Unmodified-Since", "last-event-id": "Last-Event-ID", "last-modified": "Last-Modified", link: "Link", location: "Location", "max-forwards": "Max-Forwards", negotiate: "Negotiate", origin: "Origin", pragma: "Pragma", "proxy-authenticate": "Proxy-Authenticate", "proxy-authorization": "Proxy-Authorization", range: "Range", referer: "Referer", "retry-after": "Retry-After", "sec-websocket-extensions": "Sec-Websocket-Extensions", "sec-websocket-key": "Sec-Websocket-Key", "sec-websocket-origin": "Sec-Websocket-Origin", "sec-websocket-protocol": "Sec-Websocket-Protocol", "sec-websocket-version": "Sec-Websocket-Version", server: "Server", "set-cookie": "Set-Cookie", "set-cookie2": "Set-Cookie2", "strict-transport-security": "Strict-Transport-Security", tcn: "TCN", te: "TE", trailer: "Trailer", "transfer-encoding": "Transfer-Encoding", upgrade: "Upgrade", "user-agent": "User-Agent", "variant-vary": "Variant-Vary", vary: "Vary", via: "Via", warning: "Warning", "www-authenticate": "WWW-Authenticate", "x-content-duration": "X-Content-Duration", "x-content-security-policy": "X-Content-Security-Policy", "x-dnsprefetch-control": "X-DNSPrefetch-Control", "x-frame-options": "X-Frame-Options", "x-requested-with": "X-Requested-With", "x-surge-skip-scripting": "X-Surge-Skip-Scripting" }; return new class { constructor() { this.version = "2.2.3.3"; this.scriptName = e; this.logLevels = { DEBUG: 5, INFO: 4, NOTIFY: 3, WARNING: 2, ERROR: 1, CRITICAL: 0, NONE: -1 }; this.isLoon = typeof $loon !== "undefined"; this.isQuanX = typeof $task !== "undefined"; this.isJSBox = typeof $drive !== "undefined"; this.isNode = typeof module !== "undefined" && !this.isJSBox; this.isSurge = typeof $httpClient !== "undefined" && !this.isLoon; this.platform = this.getPlatform(); this.node = { request: undefined, fs: undefined, data: {} }; this.iOSUserAgent = "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"; this.pcUserAgent = "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"; this.logLevel = t; this._unifiedPushUrl = ""; if (this.isNode) { this.node.fs = require("fs"); this.node.request = require("request"); try { this.node.fs.accessSync("./magic.json", this.node.fs.constants.R_OK | this.node.fs.constants.W_OK) } catch (e) { this.node.fs.writeFileSync("./magic.json", "{}", { encoding: "utf8" }) } this.node.data = require("./magic.json") } else if (this.isJSBox) { if (!$file.exists("drive://MagicJS")) { $file.mkdir("drive://MagicJS") } if (!$file.exists("drive://MagicJS/magic.json")) { $file.write({ data: $data({ string: "{}" }), path: "drive://MagicJS/magic.json" }) } } } set unifiedPushUrl(e) { this._unifiedPushUrl = !!e ? e.replace(/\/+$/g, "") : "" } set logLevel(e) { this._logLevel = typeof e === "string" ? e.toUpperCase() : "DEBUG" } get logLevel() { return this._logLevel } get isRequest() { return typeof $request !== "undefined" && typeof $response === "undefined" } get isResponse() { return typeof $response !== "undefined" } 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 } } getPlatform() { if (this.isSurge) return "Surge"; else if (this.isQuanX) return "QuantumultX"; else if (this.isLoon) return "Loon"; else if (this.isJSBox) return "JSBox"; else if (this.isNode) return "Node.js"; else return "unknown" } read(e, t = "") { let s = ""; if (this.isSurge || this.isLoon) { s = $persistentStore.read(e) } else if (this.isQuanX) { s = $prefs.valueForKey(e) } else if (this.isNode) { s = this.node.data } else if (this.isJSBox) { s = $file.read("drive://MagicJS/magic.json").string } try { if (this.isNode) s = s[e]; if (this.isJSBox) s = JSON.parse(s)[e]; if (!!t) { if (typeof s === "string") s = JSON.parse(s); s = !!s && typeof s === "object" ? s[t] : null } } catch (i) { this.logError(i); s = !!t ? {} : null; this.del(e) } if (typeof s === "undefined") s = null; try { if (!!s && typeof s === "string") s = JSON.parse(s) } catch (e) { } this.logDebug(`READ DATA [${e}]${!!t ? `[${t}]` : ""}(${typeof s})\n${JSON.stringify(s)}`); return s } write(e, t, s = "") { let i = !!s ? {} : ""; if (!!s && (this.isSurge || this.isLoon)) { i = $persistentStore.read(e) } else if (!!s && this.isQuanX) { i = $prefs.valueForKey(e) } else if (this.isNode) { i = this.node.data } else if (this.isJSBox) { i = JSON.parse($file.read("drive://MagicJS/magic.json").string) } if (!!s) { try { if (typeof i === "string") i = JSON.parse(i); i = typeof i === "object" && !!i ? i : {} } catch (t) { this.logError(t); this.del(e); i = {} } if (this.isJSBox || this.isNode) { if (!i.hasOwnProperty(e) || typeof i[e] !== "object" || i[e] === null) { i[e] = {} } if (!i[e].hasOwnProperty(s)) { i[e][s] = null } if (typeof t === "undefined") { delete i[e][s] } else { i[e][s] = t } } else { if (typeof t === "undefined") { delete i[s] } else { i[s] = t } } } else { if (this.isNode || this.isJSBox) { if (typeof t === "undefined") { delete i[e] } else { i[e] = t } } else { if (typeof t === "undefined") { i = null } else { i = t } } } if (typeof i === "object") i = JSON.stringify(i); if (this.isSurge || this.isLoon) { $persistentStore.write(i, e) } else if (this.isQuanX) { $prefs.setValueForKey(i, e) } else if (this.isNode) { this.node.fs.writeFileSync("./magic.json", i) } else if (this.isJSBox) { $file.write({ data: $data({ string: i }), path: "drive://MagicJS/magic.json" }) } this.logDebug(`WRITE DATA [${e}]${!!s ? `[${s}]` : ""}(${typeof t})\n${JSON.stringify(t)}`) } del(e, t = "") { this.logDebug(`DELETE KEY [${e}]${!!t ? `[${t}]` : ""}`); this.write(e, null, t) } notify(e = this.scriptName, t = "", s = "", i = "") { let o = e => { let t = {}; if (this.isSurge || this.isQuanX || this.isLoon) { if (typeof e === "string") { if (this.isLoon) t = { openUrl: e }; else if (this.isQuanX) t = { "open-url": e }; else if (this.isSurge) t = { url: e } } else if (typeof e === "object") { let s = { Surge: { openUrl: "url", "open-url": "url" }, Loon: { url: "openUrl", "open-url": "openUrl", "media-url": "mediaUrl" }, QuantumultX: { url: "open-url", openUrl: "open-url", mediaUrl: "media-url" } }; let i = Object.keys(e); for (let o = 0; o < i.length; o++) { if (!!s[this.platform][i[o]]) { t[s[this.platform][i[o]]] = e[i[o]] } else { t[i[o]] = e[i[o]] } } } } return t }; i = o(i); this.logNotify(`title:${e}\nsubTitle:${t}\nbody:${s}\noptions:${typeof i === "object" ? JSON.stringify(i) : i}`); if (arguments.length == 1) { e = this.scriptName; t = "", s = arguments[0] } if (!!this._unifiedPushUrl) { let i = encodeURI(`${e}/${t}${!!t ? "\n" : ""}${s}`); this.get(`${this._unifiedPushUrl}/${i}`, () => { }) } if (this.isSurge || this.isLoon) { $notification.post(e, t, s, i) } else if (this.isQuanX) { $notify(e, t, s, i) } else if (this.isJSBox) { let i = { title: e, body: !!t ? `${t}\n${s}` : s }; $push.schedule(i) } } log(e, t = "INFO") { if (!(this.logLevels[this._logLevel] < this.logLevels[t.toUpperCase()])) console.log(`[${t}] [${this.scriptName}]\n${e}\n`) } logDebug(e) { this.log(e, "DEBUG") } logInfo(e) { this.log(e, "INFO") } logNotify(e) { this.log(e, "NOTIFY") } logWarning(e) { this.log(e, "WARNING") } logError(e) { this.log(e, "ERROR") } adapterHttpOptions(e, t) { let i = typeof e === "object" ? Object.assign({}, e) : { url: e, headers: {} }; if (i.hasOwnProperty("header") && !i.hasOwnProperty("headers")) { i["headers"] = i["header"]; delete i["header"] } if (typeof i.headers === "object" && !!s) { for (let e in i.headers) { if (s[e]) { i.headers[s[e]] = i.headers[e]; delete i.headers[e] } } } if (!!!i.headers || typeof i.headers !== "object" || !!!i.headers["User-Agent"]) { if (!!!i.headers || typeof i.headers !== "object") i.headers = {}; if (this.isNode) i.headers["User-Agent"] = this.pcUserAgent; else i.headers["User-Agent"] = this.iOSUserAgent } let o = false; if (typeof i["opts"] === "object" && (i["opts"]["hints"] === true || i["opts"]["Skip-Scripting"] === true) || typeof i["headers"] === "object" && i["headers"]["X-Surge-Skip-Scripting"] === true) { o = true } if (!o) { if (this.isSurge) i.headers["X-Surge-Skip-Scripting"] = false; else if (this.isLoon) i.headers["X-Requested-With"] = "XMLHttpRequest"; else if (this.isQuanX) { if (typeof i["opts"] !== "object") i.opts = {}; i.opts["hints"] = false } } if (!this.isSurge || o) delete i.headers["X-Surge-Skip-Scripting"]; if (!this.isQuanX && i.hasOwnProperty("opts")) delete i["opts"]; if (this.isQuanX && i.hasOwnProperty("opts")) delete i["opts"]["Skip-Scripting"]; if (t === "GET" && !this.isNode && !!i.body) { let e = Object.keys(i.body).map(e => { if (typeof i.body === "undefined") return ""; return `${encodeURIComponent(e)}=${encodeURIComponent(i.body[e])}` }).join("&"); if (i.url.indexOf("?") < 0) i.url += "?"; if (i.url.lastIndexOf("&") + 1 != i.url.length && i.url.lastIndexOf("?") + 1 != i.url.length) i.url += "&"; i.url += e; delete i.body } if (this.isQuanX) { if (i.hasOwnProperty("body") && typeof i["body"] !== "string") i["body"] = JSON.stringify(i["body"]); i["method"] = t } else if (this.isNode) { delete i.headers["Accept-Encoding"]; if (typeof i.body === "object") { if (t === "GET") { i.qs = i.body; delete i.body } else if (t === "POST") { i["json"] = true; i.body = i.body } } } else if (this.isJSBox) { i["header"] = i["headers"]; delete i["headers"] } return i } get(e, t) { let s = this.adapterHttpOptions(e, "GET"); this.logDebug(`HTTP GET: ${JSON.stringify(s)}`); if (this.isSurge || this.isLoon) { $httpClient.get(s, t) } else if (this.isQuanX) { $task.fetch(s).then(e => { e["status"] = e.statusCode; t(null, e, e.body) }, e => t(e.error, null, null)) } else if (this.isNode) { return this.node.request.get(s, t) } else if (this.isJSBox) { s["handler"] = (e => { let s = e.error ? JSON.stringify(e.error) : undefined; let i = typeof e.data === "object" ? JSON.stringify(e.data) : e.data; t(s, e.response, i) }); $http.get(s) } } post(e, t) { let s = this.adapterHttpOptions(e, "POST"); this.logDebug(`HTTP POST: ${JSON.stringify(s)}`); if (this.isSurge || this.isLoon) { $httpClient.post(s, t) } else if (this.isQuanX) { $task.fetch(s).then(e => { e["status"] = e.statusCode; t(null, e, e.body) }, e => { t(e.error, null, null) }) } else if (this.isNode) { return this.node.request.post(s, t) } else if (this.isJSBox) { s["handler"] = (e => { let s = e.error ? JSON.stringify(e.error) : undefined; let i = typeof e.data === "object" ? JSON.stringify(e.data) : e.data; t(s, e.response, i) }); $http.post(s) } } done(e = {}) { if (typeof $done !== "undefined") { $done(e) } } isToday(e) { if (e == null) { return false } else { let t = new Date; if (typeof e == "string") { e = new Date(e) } if (t.getFullYear() == e.getFullYear() && t.getMonth() == e.getMonth() && t.getDay() == e.getDay()) { return true } else { return false } } } isNumber(e) { return parseFloat(e).toString() === "NaN" ? false : true } attempt(e, t = null) { return e.then(e => { return [null, e] }).catch(e => { this.logError(e); return [e, t] }) } retry(e, t = 5, s = 0, i = null) { return (...o) => { return new Promise((r, n) => { function a(...o) { Promise.resolve().then(() => e.apply(this, o)).then(e => { if (typeof i === "function") { Promise.resolve().then(() => i(e)).then(() => { r(e) }).catch(e => { this.logError(e); if (t >= 1 && s > 0) { setTimeout(() => a.apply(this, o), s) } else if (t >= 1) { a.apply(this, o) } else { n(e) } t-- }) } else { r(e) } }).catch(e => { this.logError(e); if (t >= 1 && s > 0) { setTimeout(() => a.apply(this, o), s) } else if (t >= 1) { a.apply(this, o) } else { n(e) } t-- }) } a.apply(this, o) }) } } formatTime(e, t = "yyyy-MM-dd hh:mm:ss") { var s = { "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() }; if (/(y+)/.test(t)) t = t.replace(RegExp.$1, (e.getFullYear() + "").substr(4 - RegExp.$1.length)); for (let e in s) if (new RegExp("(" + e + ")").test(t)) t = t.replace(RegExp.$1, RegExp.$1.length == 1 ? s[e] : ("00" + s[e]).substr(("" + s[e]).length)); return t } now() { return this.formatTime(new Date, "yyyy-MM-dd hh:mm:ss") } today() { return this.formatTime(new Date, "yyyy-MM-dd") } sleep(e) { return new Promise(t => setTimeout(t, e)) } }(e) }
+/**
+ *
+ * $$\ $$\ $$\ $$$$$\ $$$$$$\ $$$$$$\
+ * $$$\ $$$ | \__| \__$$ |$$ __$$\ $$ ___$$\
+ * $$$$\ $$$$ | $$$$$$\ $$$$$$\ $$\ $$$$$$$\ $$ |$$ / \__| \_/ $$ |
+ * $$\$$\$$ $$ | \____$$\ $$ __$$\ $$ |$$ _____| $$ |\$$$$$$\ $$$$$ /
+ * $$ \$$$ $$ | $$$$$$$ |$$ / $$ |$$ |$$ / $$\ $$ | \____$$\ \___$$\
+ * $$ |\$ /$$ |$$ __$$ |$$ | $$ |$$ |$$ | $$ | $$ |$$\ $$ | $$\ $$ |
+ * $$ | \_/ $$ |\$$$$$$$ |\$$$$$$$ |$$ |\$$$$$$$\\$$$$$$ |\$$$$$$ | \$$$$$$ |
+ * \__| \__| \_______| \____$$ |\__| \_______|\______/ \______/ \______/
+ * $$\ $$ |
+ * \$$$$$$ |
+ * \______/
+ *
+*/
+function MagicJS(e = "MagicJS", t = "INFO") { const r = () => { const e = typeof $loon !== "undefined"; const t = typeof $task !== "undefined"; const n = typeof module !== "undefined"; const r = typeof $httpClient !== "undefined" && !e; const i = typeof $storm !== "undefined"; const o = typeof $environment !== "undefined" && typeof $environment["stash-build"] !== "undefined"; const s = r || e || i || o; const a = typeof importModule !== "undefined"; return { isLoon: e, isQuanX: t, isNode: n, isSurge: r, isStorm: i, isStash: o, isSurgeLike: s, isScriptable: a, get name() { if (e) { return "Loon" } else if (t) { return "QuantumultX" } else if (n) { return "NodeJS" } else if (r) { return "Surge" } else if (a) { return "Scriptable" } else { return "unknown" } }, get build() { if (r) { return $environment["surge-build"] } else if (o) { return $environment["stash-build"] } else if (i) { return $storm.buildVersion } }, get language() { if (r || o) { return $environment["language"] } }, get version() { if (r) { return $environment["surge-version"] } else if (o) { return $environment["stash-version"] } else if (i) { return $storm.appVersion } else if (n) { return process.version } }, get system() { if (r) { return $environment["system"] } else if (n) { return process.platform } }, get systemVersion() { if (i) { return $storm.systemVersion } }, get deviceName() { if (i) { return $storm.deviceName } } } }; const i = (n, e = "INFO") => { let r = e; const i = { SNIFFER: 6, DEBUG: 5, INFO: 4, NOTIFY: 3, WARNING: 2, ERROR: 1, CRITICAL: 0, NONE: -1 }; const o = { SNIFFER: "", DEBUG: "", INFO: "", NOTIFY: "", WARNING: "❗ ", ERROR: "❌ ", CRITICAL: "❌ ", NONE: "" }; const t = (e, t = "INFO") => { if (!(i[r] < i[t.toUpperCase()])) console.log(`[${t}] [${n}]\n${o[t.toUpperCase()]}${e}\n`) }; const s = e => { r = e }; return { setLevel: s, sniffer: e => { t(e, "SNIFFER") }, debug: e => { t(e, "DEBUG") }, info: e => { t(e, "INFO") }, notify: e => { t(e, "NOTIFY") }, warning: e => { t(e, "WARNING") }, error: e => { t(e, "ERROR") }, retry: e => { t(e, "RETRY") } } }; return new class { constructor(e, t) { this._startTime = Date.now(); this.version = "3.0.0"; this.scriptName = e; this.env = r(); this.logger = i(e, t); 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 e = this.data.read("magic_loglevel"); const n = this.data.read("magic_bark_url"); if (e) { this.logger.setLevel(e.toUpperCase()) } if (n) { this.notification.setBark(n) } } } 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 = (e = {}) => { this._endTime = Date.now(); let t = (this._endTime - this._startTime) / 1e3; this.logger.info(`SCRIPT COMPLETED: ${t} S.`); if (typeof $done !== "undefined") { $done(e) } } }(e, t) } function MagicHttp(u, c) { const t = "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 n = "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 f; if (u.isNode) { const a = require("axios"); f = a.create() } class e { constructor(e = true) { this.handlers = []; this.isRequest = e } use(e, t, n) { this.handlers.push({ fulfilled: e, rejected: t, synchronous: n ? n.synchronous : false, runWhen: n ? n.runWhen : null }); return this.handlers.length - 1 } eject(e) { if (this.handlers[e]) { this.handlers[e] = null } } forEach(t) { this.handlers.forEach(e => { if (e !== null) { t(e) } }) } } function r(e) { let n = { ...e }; if (!!n.params) { if (!u.isNode) { let e = Object.keys(n.params).map(e => { const t = encodeURIComponent(e); n.url = n.url.replace(new RegExp(`${e}=[^&]*`, "ig"), ""); n.url = n.url.replace(new RegExp(`${t}=[^&]*`, "ig"), ""); return `${t}=${encodeURIComponent(n.params[e])}` }).join("&"); if (n.url.indexOf("?") < 0) n.url += "?"; if (!/(&|\?)$/g.test(n.url)) { n.url += "&" } n.url += e; delete n.params; c.debug(`Params to QueryString: ${n.url}`) } } return n } const d = (e, t) => { let n = typeof t === "object" ? { headers: {}, ...t } : { url: t, headers: {} }; if (!n.method) { n["method"] = e } n = r(n); if (n["rewrite"] === true) { if (u.isSurge) { n.headers["X-Surge-Skip-Scripting"] = false; delete n["rewrite"] } else if (u.isQuanX) { n["hints"] = false; delete n["rewrite"] } } if (u.isSurge) { if (n["method"] !== "GET" && n.headers["Content-Type"].indexOf("application/json") >= 0 && n.body instanceof Array) { n.body = JSON.stringify(n.body); c.debug(`Convert Array object to String: ${n.body}`) } } else if (u.isQuanX) { if (n.hasOwnProperty("body") && typeof n["body"] !== "string") n["body"] = JSON.stringify(n["body"]); n["method"] = e } else if (u.isNode) { if (e === "POST" || e === "PUT" || e === "PATCH" || e === "DELETE") { n.data = n.data || n.body } else if (e === "GET") { n.params = n.params || n.body } delete n.body } return n }; const p = (t, n = null) => { if (t) { let e = { ...t, config: t.config || n, status: t.statusCode || t.status, body: t.body || t.data, headers: t.headers || t.header }; if (typeof e.body === "string") { try { e.body = JSON.parse(e.body) } catch { } } delete t.data; return e } else { return t } }; const i = r => { if (!!r) { delete r["Content-Length"]; let e = new Set(["Accept", "Accept-CH", "Accept-Charset", "Accept-Features", "Accept-Encoding", "Accept-Language", "Accept-Ranges", "Access-Control-Allow-Credentials", "Access-Control-Allow-Origin", "Access-Control-Allow-Methods", "Access-Control-Allow-Headers", "Access-Control-Max-Age", "Access-Control-Expose-Headers", "Access-Control-Request-Method", "Access-Control-Request-Headers", "Age", "Allow", "Alternates", "Authorization", "Cache-Control", "Connection", "Content-Encoding", "Content-Language", "ontent-Length", "Content-Location", "Content-Range", "Content-Security-Policy", "Content-Type", "Cookie", "DNT", "Date", "ETag", "Expect", "Expires", "From", "Host", "If-Match", "If-Modified-Since", "If-None-Match", "If-Range", "If-Unmodified-Since", "Last-Event-ID", "Last-Modified", "Link", "Location", "Max-Forwards", "Negotiate", "Origin", "Pragma", "Proxy-Authenticate", "Proxy-Authorization", "Range", "Referer", "Retry-After", "Sec-Websocket-Extensions", "Sec-Websocket-Key", "Sec-Websocket-Origin", "Sec-Websocket-Protocol", "Sec-Websocket-Version", "Server", "Set-Cookie", "Set-Cookie2", "Strict-Transport-Security", "TCN", "TE", "Trailer", "Transfer-Encoding", "Upgrade", "User-Agent", "Variant-Vary", "Vary", "Via", "Warning", "WWW-Authenticate", "X-Content-Duration", "X-Content-Security-Policy", "X-DNSPrefetch-Control", "X-Frame-Options", "X-Requested-With"]); for (let n of Object.keys(r)) { if (!e.has(n)) { for (let t of e) { let e = n.replace(new RegExp(t, "ig"), t); if (n !== e) { r[e] = r[n]; delete r[n]; break } } } } if (!r["User-Agent"]) { if (u.isNode) { r["User-Agent"] = n } else { r["User-Agent"] = t } } return r } return r }; const g = (t, n = null) => { if (!!t && t.status >= 400) { c.debug(`Raise exception when status code is ${t.status}`); let e = { name: "RequestException", message: `Request failed with status code ${t.status}`, config: n || t.config, response: t }; return e } }; const o = { request: new e, response: new e(false) }; let y = []; let h = []; let m = true; function $(e) { if (typeof e === "object" && e["modify"] !== false) { e["headers"] = i(e["headers"]) } e = r(e); return e } function b(e) { try { e = !!e ? p(e) : e; c.sniffer(`HTTP ${e.config["method"].toUpperCase()}:\n${JSON.stringify(e.config)}\nSTATUS CODE:\n${e.status}\nRESPONSE:\n${typeof e.body === "object" ? JSON.stringify(e.body) : e.body}`); const t = g(e); if (!!t) { return Promise.reject(t) } return e } catch (t) { c.error(t); return e } } const S = t => { try { y = []; h = []; o.request.forEach(e => { if (typeof e.runWhen === "function" && e.runWhen(t) === false) { return } m = m && e.synchronous; y.unshift(e.fulfilled, e.rejected) }); o.response.forEach(e => { h.push(e.fulfilled, e.rejected) }) } catch (e) { c.error(`failed to register interceptors: ${e}`) } }; const s = (e, r) => { let i; const t = e.toUpperCase(); r = d(t, r); if (u.isNode) { i = f } else { if (u.isSurgeLike) { i = o => { return new Promise((r, i) => { $httpClient[e.toLowerCase()](o, (t, n, e) => { if (t) { let e = { name: t.name || t, message: t.message || t, stack: t.stack || t, config: o, response: p(n) }; i(e) } else { n.config = o; n.body = e; r(n) } }) }) } } else { i = i => { return new Promise((n, r) => { $task.fetch(i).then(e => { e = p(e, i); const t = g(e, i); if (t) { return Promise.reject(t) } n(e) }).catch(e => { let t = { name: e.message || e.error, message: e.message || e.error, stack: e.error, config: i, response: !!e.response ? p(e.response) : null }; r(t) }) }) } } } let o; S(r); const s = [$, undefined]; const a = [b, undefined]; if (!m) { c.debug("Interceptors are executed in asynchronous mode"); let n = [i, undefined]; Array.prototype.unshift.apply(n, s); Array.prototype.unshift.apply(n, y); Array.prototype.unshift.apply(n, s); n = n.concat(a); n = n.concat(h); o = Promise.resolve(r); while (n.length) { try { let e = n.shift(); let t = n.shift(); if (!u.isNode && r["timeout"] && e === i) { o = l(r) } else { o = o.then(e, t) } } catch (e) { c.error(`request exception: ${e}`) } } return o } else { c.debug("Interceptors are executed in synchronous mode"); Array.prototype.unshift.apply(y, s); y = y.concat([$, undefined]); while (y.length) { let e = y.shift(); let t = y.shift(); try { r = e(r) } catch (e) { t(e); break } } try { if (!u.isNode && r["timeout"]) { o = l(r) } else { o = i(r) } } catch (e) { return Promise.reject(e) } Array.prototype.unshift.apply(h, a); while (h.length) { o = o.then(h.shift(), h.shift()) } return o } function l(n) { try { const e = new Promise((e, t) => { setTimeout(() => { let e = { message: `timeout of ${n["timeout"]}ms exceeded`, config: n }; t(e) }, n["timeout"]) }); return Promise.race([i(n), e]) } catch (e) { c.error(`Request Timeout exception: ${e}`) } } }; return { request: s, interceptors: o, modifyHeaders: i, modifyResponse: p, get: e => { return s("GET", e) }, post: e => { return s("POST", e) }, put: e => { return s("PUT", e) }, patch: e => { return s("PATCH", e) }, delete: e => { return s("DELETE", e) }, head: e => { return s("HEAD", e) }, options: e => { return s("OPTIONS", e) } } } function MagicNotification(o, s, a, l) { let u = null; let c = null; const e = t => { try { let e = t.replace(/\/+$/g, ""); u = `${/^https?:\/\/([^/]*)/.exec(e)[0]}/push`; c = /\/([^\/]+)\/?$/.exec(e)[1] } catch (e) { a.error(`Bark url error: ${e}.`) } }; function t(e = o, t = "", n = "", r = "") { const i = n => { try { let t = {}; if (typeof n === "string") { if (s.isLoon) t = { openUrl: n }; else if (s.isQuanX) t = { "open-url": n }; else if (s.isSurge) t = { url: n } } else if (typeof n === "object") { if (s.isLoon) { t["openUrl"] = !!n["open-url"] ? n["open-url"] : ""; t["mediaUrl"] = !!n["media-url"] ? n["media-url"] : "" } else if (s.isQuanX) { t = !!n["open-url"] || !!n["media-url"] ? n : {} } else if (s.isSurge) { let e = n["open-url"] || n["openUrl"]; t = e ? { url: e } : {} } } return t } catch (e) { a.error(`Failed to convert notification option, ${e}`) } return n }; r = i(r); if (arguments.length == 1) { e = o; t = "", n = arguments[0] } a.notify(`title:${e}\nsubTitle:${t}\nbody:${n}\noptions:${typeof r === "object" ? JSON.stringify(r) : r}`); if (s.isSurge) { $notification.post(e, t, n, r) } else if (s.isLoon) { if (!!r) $notification.post(e, t, n, r); else $notification.post(e, t, n) } else if (s.isQuanX) { $notify(e, t, n, r) } if (u && c) { f(e, t, n) } } function n(e = o, t = "", n = "", r = "") { if (a.level === "DEBUG") { if (arguments.length == 1) { e = o; t = "", n = arguments[0] } this.notify(e, t, n, r) } } function f(e = o, t = "", n = "", r = "") { if (typeof l === "undefined" || typeof l.post === "undefined") { throw "Bark notification needs to import MagicHttp module." } let i = { url: u, headers: { "Content-Type": "application/json; charset=utf-8" }, body: { title: e, body: t ? `${t}\n${n}` : n, device_key: c } }; l.post(i).catch(e => { a.error(`Bark notify error: ${e}`) }) } return { post: t, debug: n, bark: f, setBark: e } } function MagicData(s, a) { let l = { fs: undefined, data: {} }; if (s.isNode) { l.fs = require("fs"); try { l.fs.accessSync("./magic.json", l.fs.constants.R_OK | l.fs.constants.W_OK) } catch (e) { l.fs.writeFileSync("./magic.json", "{}", { encoding: "utf8" }) } l.data = require("./magic.json") } const u = (e, t) => { if (typeof t === "object") { return false } else { return e === t } }; const c = e => { if (e === "true") { return true } else if (e === "false") { return false } else if (typeof e === "undefined") { return null } else { return e } }; const f = (e, t, n, r) => { if (n) { try { if (typeof e === "string") e = JSON.parse(e); if (e["magic_session"] === true) { e = e[n] } else { e = null } } catch { e = null } } if (typeof e === "string" && e !== "null") { try { e = JSON.parse(e) } catch { } } if (r === false && !!e && e["magic_session"] === true) { e = null } if ((e === null || typeof e === "undefined") && t !== null && typeof t !== "undefined") { e = t } e = c(e); return e }; const o = t => { if (typeof t === "string") { let e = {}; try { e = JSON.parse(t); const n = typeof e; if (n !== "object" || e instanceof Array || n === "bool" || e === null) { e = {} } } catch { } return e } else if (t instanceof Array || t === null || typeof t === "undefined" || t !== t || typeof t === "boolean") { return {} } else { return t } }; const d = (e, t = null, n = "", r = false, i = null) => { let o = i || l.data; if (!!o && typeof o[e] !== "undefined" && o[e] !== null) { val = o[e] } else { val = !!n ? {} : null } val = f(val, t, n, r); return val }; const p = (e, t = null, n = "", r = false, i = null) => { let o = ""; if (i || s.isNode) { o = d(e, t, n, r, i) } else { if (s.isSurgeLike) { o = $persistentStore.read(e) } else if (s.isQuanX) { o = $prefs.valueForKey(e) } o = f(o, t, n, r) } a.debug(`READ DATA [${e}]${!!n ? `[${n}]` : ""} <${typeof o}>\n${JSON.stringify(o)}`); return o }; const g = (t, n, r = "", e = null) => { let i = e || l.data; i = o(i); if (!!r) { let e = o(i[t]); e["magic_session"] = true; e[r] = n; i[t] = e } else { i[t] = n } if (e !== null) { e = i } return i }; const y = (e, t, n = "", r = null) => { if (typeof t === "undefined" || t !== t) { return false } if (!s.isNode && (typeof t === "boolean" || typeof t === "number")) { t = String(t) } let i = ""; if (r || s.isNode) { i = g(e, t, n, r) } else { if (!n) { i = t } else { if (s.isSurgeLike) { i = !!$persistentStore.read(e) ? $persistentStore.read(e) : i } else if (s.isQuanX) { i = !!$prefs.valueForKey(e) ? $prefs.valueForKey(e) : i } i = o(i); i["magic_session"] = true; i[n] = t } } if (!!i && typeof i === "object") { i = JSON.stringify(i, "", "\t") } a.debug(`WRITE DATA [${e}]${n ? `[${n}]` : ""} <${typeof t}>\n${JSON.stringify(t)}`); if (!r) { if (s.isSurgeLike) { return $persistentStore.write(i, e) } else if (s.isQuanX) { return $prefs.setValueForKey(i, e) } else if (s.isNode) { try { l.fs.writeFileSync("./magic.json", i); return true } catch (e) { a.error(e); return false } } } return true }; const e = (t, n, r, i = u, o = null) => { n = c(n); const e = p(t, null, r, false, o); if (i(e, n) === true) { return false } else { const s = y(t, n, r, o); let e = p(t, null, r, false, o); if (i === u && typeof e === "object") { return s } return i(n, e) } }; const h = (e, t, n) => { let r = n || l.data; r = o(r); if (!!t) { obj = o(r[e]); delete obj[t]; r[e] = obj } else { delete r[e] } if (!!n) { n = r } return r }; const t = (e, t = "", n = null) => { let r = {}; if (n || s.isNode) { r = h(e, t, n); if (!n) { l.fs.writeFileSync("./magic.json", JSON.stringify(r)) } else { n = r } } else { if (!t) { if (s.isStorm) { return $persistentStore.remove(e) } else if (s.isSurgeLike) { return $persistentStore.write(null, e) } else if (s.isQuanX) { return $prefs.removeValueForKey(e) } } else { if (s.isSurgeLike) { r = $persistentStore.read(e) } else if (s.isQuanX) { r = $prefs.valueForKey(e) } r = o(r); delete r[t]; const i = JSON.stringify(r); y(e, i) } } a.debug(`DELETE KEY [${e}]${!!t ? `[${t}]` : ""}`) }; const n = (e, t = null) => { let n = []; let r = p(e, null, null, true, t); r = o(r); if (r["magic_session"] !== true) { n = [] } else { n = Object.keys(r).filter(e => e !== "magic_session") } a.debug(`READ ALL SESSIONS [${e}] <${typeof n}>\n${JSON.stringify(n)}`); return n }; return { read: p, write: y, del: t, update: e, allSessions: n, defaultValueComparator: u, convertToObject: o } } function MagicUtils(r, u) { const e = (o, s = 5, a = 0, l = null) => { return (...e) => { return new Promise((n, r) => { function i(...t) { Promise.resolve().then(() => o.apply(this, t)).then(e => { if (typeof l === "function") { Promise.resolve().then(() => l(e)).then(() => { n(e) }).catch(e => { if (s >= 1) { if (a > 0) setTimeout(() => i.apply(this, t), a); else i.apply(this, t) } else { r(e) } s-- }) } else { n(e) } }).catch(e => { u.error(e); if (s >= 1 && a > 0) { setTimeout(() => i.apply(this, t), a) } else if (s >= 1) { i.apply(this, t) } else { r(e) } s-- }) } i.apply(this, e) }) } }; const t = (e, t = "yyyy-MM-dd hh:mm:ss") => { let 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() }; if (/(y+)/.test(t)) t = t.replace(RegExp.$1, (e.getFullYear() + "").substr(4 - RegExp.$1.length)); for (let e in n) if (new RegExp("(" + e + ")").test(t)) t = t.replace(RegExp.$1, RegExp.$1.length == 1 ? n[e] : ("00" + n[e]).substr(("" + n[e]).length)); return t }; const n = () => { return t(new Date, "yyyy-MM-dd hh:mm:ss") }; const i = () => { return t(new Date, "yyyy-MM-dd") }; const o = t => { return new Promise(e => setTimeout(e, t)) }; const s = (e, t = null) => { if (r.isNode) { const n = require("assert"); if (t) n(e, t); else n(e) } else { if (e !== true) { let e = `AssertionError: ${t || "The expression evaluated to a falsy value"}`; u.error(e) } } }; return { retry: e, formatTime: t, now: n, today: i, sleep: o, assert: s } } function MagicQingLong(e, l, i) { let o = ""; let s = ""; let a = ""; let u = ""; let c = ""; let t = ""; const f = "magic.json"; const n = 3e3; const d = MagicHttp(e, i); const r = (e, t, n, r, i) => { o = e; a = t; u = n; s = r; c = i }; function p(e) { o = o || l.read("magic_qlurl"); t = t || l.read("magic_qltoken"); return e } function g(e) { if (!o) { o = l.read("magic_qlurl") } if (e.url.indexOf(o) < 0) { e.url = `${o}${e.url}` } return { ...e, timeout: n } } function y(e) { e.params = { ...e.params, t: Date.now() }; return e } function h(e) { t = t || l.read("magic_qltoken"); if (t) { e.headers["Authorization"] = `Bearer ${t}` } return e } function m(e) { a = a || l.read("magic_qlclient"); if (!!a) { e.url = e.url.replace("/api/", "/open/") } return e } async function $(e) { try { const t = e.message || e.error || JSON.stringify(e); if ((t.indexOf("NSURLErrorDomain") >= 0 && t.indexOf("-1012") >= 0 || !!e.response && e.response.status === 401) && (!!e.config && e.config.refreshToken !== true)) { i.warning(`Qinglong panel token has expired`); await b(); e.config["refreshToken"] = true; return await d.request(e.config.method, e.config) } else { return Promise.reject(e) } } catch (e) { return Promise.reject(e) } } d.interceptors.request.use(p, undefined); d.interceptors.request.use(g, undefined); d.interceptors.request.use(m, undefined, { runWhen: e => { return e.url.indexOf("api/user/login") < 0 && e.url.indexOf("open/auth/token") < 0 } }); d.interceptors.request.use(h, undefined, { runWhen: e => { return e.url.indexOf("api/user/login") < 0 && e.url.indexOf("open/auth/token") < 0 } }); d.interceptors.request.use(y, undefined, { runWhen: e => { return e.url.indexOf("open/auth/token") < 0 && e.url.indexOf("t=") < 0 } }); d.interceptors.response.use(undefined, $); async function b() { a = a || l.read("magic_qlclient"); u = u || l.read("magic_qlsecrt"); s = s || l.read("magic_qlname"); c = c || l.read("magic_qlpwd"); if (o && a && u) { await d.get({ url: `/open/auth/token`, headers: { "Content-Type": "application/json" }, params: { client_id: a, client_secret: u } }).then(e => { i.info("Log in to Qinglong panel successfully"); t = e.body.data.token; l.update("magic_qltoken", t); return t }).catch(e => { i.error(`Failed to log in to Qinglong panel.\n${e.message}`) }) } else if (o && s && c) { await d.post({ url: `/api/user/login`, headers: { "Content-Type": "application/json" }, body: { username: s, password: c } }).then(e => { i.info("Log in to Qinglong panel successfully"); t = e.body.data.token; l.update("magic_qltoken", t); return t }).catch(e => { i.error(`Failed to log in to Qinglong panel.\n${e.message}`) }) } } async function S(t, n, r = null) { o = o || l.read("magic_qlurl"); if (r === null) { let e = await N([{ name: t, value: n }]); if (!!e && e.length === 1) { return e[0] } } else { d.put({ url: `/api/envs`, headers: { "Content-Type": "application/json" }, body: { name: t, value: n, id: r } }).then(e => { if (e.body.code === 200) { i.debug(`QINGLONG UPDATE ENV ${t} <${typeof n}> (${r})\n${JSON.stringify(n)}`); return true } else { i.error(`Failed to update Qinglong panel environment variable.\n${JSON.stringify(e)}`) } }).catch(e => { i.error(`Failed to update Qinglong panel environment variable.\n${e.message}`); return false }) } } async function N(e) { let t = []; await d.post({ url: `/api/envs`, headers: { "Content-Type": "application/json" }, body: e }).then(e => { if (e.body.code === 200) { e.body.data.forEach(e => { i.debug(`QINGLONG ADD ENV ${e.name} <${typeof e.value}> (${e.id})\n${JSON.stringify(e)}`); t.push(e.id) }) } else { i.error(`Failed to add Qinglong panel environment variable.\n${JSON.stringify(e)}`) } }).catch(e => { i.error(`Failed to add Qinglong panel environment variable.\n${e.message}`) }); return t } async function v(t) { return await d.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 => { if (e.body.code === 200) { i.debug(`QINGLONG DELETE ENV IDS: ${t}`); return true } else { i.error(`Failed to delete QingLong envs.\n${JSON.stringify(e)}`); return false } }).catch(e => { i.error(`Failed to delete QingLong envs.\n${e.message}`) }) } async function O(n = null, e = "") { let r = []; await d.get({ url: `/api/envs`, headers: { "Content-Type": "application/json" }, params: { searchValue: e } }).then(e => { if (e.body.code === 200) { const t = e.body.data; if (!!n) { let e = []; for (const e of t) { if (e.name === n) { r.push(e) } } r = e } r = t } else { i.error(`Failed to get environment variables from Qinglong panel.\n${JSON.stringify(e)}`) } }).catch(e => { i.error(`Failed to get environment variables from Qinglong panel.\n${JSON.stringify(e)}`) }); return r } async function E(e) { let t = null; const n = await O(); for (const r of n) { if (r.id === e) { t = r; break } } return t } async function T(t) { let n = false; await d.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 => { if (e.body.code === 200) { i.debug(`QINGLONG DISABLED ENV IDS: ${t}`); n = true } else { i.error(`Failed to disable QingLong envs.\n${JSON.stringify(e)}`) } }).catch(e => { i.error(`Failed to disable QingLong envs.\n${e.message}`) }); return n } async function w(t) { let n = false; await d.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 => { if (e.body.code === 200) { i.debug(`QINGLONG ENABLED ENV IDS: ${t}`); n = true } else { i.error(`Failed to enable QingLong envs.\n${JSON.stringify(e)}`) } }).catch(e => { i.error(`Failed to enable QingLong envs.\n${e.message}`) }); return n } async function C(e, t = "", n = "") { let r = false; await d.post({ url: `/api/scripts`, headers: { "Content-Type": "application/json" }, body: { filename: e, path: t, content: n } }).then(e => { if (e.body.code === 200) { r = true } else { i.error(`Failed to add script content from Qinglong panel.\n${JSON.stringify(e)}`) } }).catch(e => { i.error(`Failed to add script content from Qinglong panel.\n${e.message}`) }); return r } async function A(e, t = "") { let n = ""; await d.get({ url: `/api/scripts/${e}`, params: { path: t } }).then(e => { if (e.body.code === 200) { n = e.body.data } else { i.error(`Failed to read script content from Qinglong panel.\n${JSON.stringify(e)}`) } }).catch(e => { i.error(`Failed to read script content from Qinglong panel.\n${e.message}`) }); return n } async function k(e, t = "", n = "") { let r = false; await d.put({ url: `/api/scripts`, headers: { "Content-Type": "application/json" }, body: { filename: e, path: t, content: n } }).then(e => { if (e.body.code === 200) { r = true } else { i.error(`Failed to read script content from Qinglong panel.\n${JSON.stringify(e)}`) } }).catch(e => { i.error(`Failed to read script content from Qinglong panel.\n${e.message}`) }); return r } async function L(e, t = "") { let n = false; await d.delete({ url: `/api/scripts`, headers: { "Content-Type": "application/json" }, body: { filename: e, path: t } }).then(e => { if (e.body.code === 200) { n = true } else { i.error(`Failed to read script content from Qinglong panel.\n${JSON.stringify(e)}`) } }).catch(e => { i.error(`Failed to read script content from Qinglong panel.\n${e.message}`) }); return n } async function F(e, t, n = "") { let r = await A(f, ""); let i = l.convertToObject(r); let o = l.write(e, t, n, i); r = JSON.stringify(i, "", "\t"); let s = await k(f, "", r); return s && o } async function j(e, t, n, r = l.defaultValueComparator) { let i = await A(f, ""); let o = l.convertToObject(i); const s = l.update(e, t, n, r, o); let a = false; if (s === true) { i = JSON.stringify(o, "", "\t"); a = await k(f, "", i) } return s && a } async function M(e, t, n = "") { let r = await A(f, ""); let i = l.convertToObject(r); const o = l.read(e, t, n, false, i); return o } async function R(e, t = "") { let n = await A(f, ""); let r = l.convertToObject(n); const i = l.del(e, t, r); n = JSON.stringify(r, "", "\t"); const o = await k(f, "", n); return i && o } async function q(e) { let t = await A(f, ""); let n = l.convertToObject(t); const r = l.allSessions(e, n); return r } return { init: r, getToken: b, setEnv: S, setEnvs: N, getEnv: E, getEnvs: O, delEnvs: v, disableEnvs: T, enbleEnvs: w, addScript: C, getScript: A, editScript: k, delScript: L, write: F, read: M, del: R, update: j, allSessions: q } }
diff --git a/script/eleme/eleme_mission.js b/script/eleme/eleme_mission.js
deleted file mode 100644
index b18db7b35..000000000
--- a/script/eleme/eleme_mission.js
+++ /dev/null
@@ -1,159 +0,0 @@
-const scriptName = "饿了么";
-const elemeCookieKey = "eleme_app_cookie";
-const elemeLongitudeKey = "eleme_app_longitude";
-const elemeLatitudeKey = "eleme_app_latitude";
-const elemeTaskKey = "eleme_task_keywords";
-
-let magicJS = MagicJS(scriptName, "INFO");
-magicJS.barkUrl = magicJS.read("bark_url");
-
-// 获取超级会员任务列表
-function GetSuperVipMissions(cookie, longitude, latitude) {
- return new Promise((resolve, reject) => {
- // 获取配置的任务关键词
- const taskKeywords = magicJS.read(elemeTaskKey).split(';');
- magicJS.logInfo(`只获取含有以下关键词的任务：${magicJS.read(elemeTaskKey)}`);
-
- let options = {
- url: `https://h5.ele.me/restapi/svip_biz/v1/supervip/query_mission_list?longitude=${longitude}&latitude=${latitude}`,
- headers: {
- "Accept": "application/json, text/plain, */*",
- "Accept-Encoding": "gzip, deflate, br",
- "Accept-Language": "zh-cn",
- "Connection": "keep-alive",
- "Cookie": cookie,
- "Host": "h5.ele.me",
- "Referer": "https://h5.ele.me/svip/home?entryStat=profile",
- "User-Agent": "Rajax/1 Apple/iPhone10,3 iOS/14.2 Eleme/9.3.8",
- "f-pTraceId": "WVNet_WV_2-3-30",
- "f-refer": "wv_h5",
- "x-shard": `loc=${longitude},${latitude}`,
- },
- };
- magicJS.get(options, (err, resp, data) => {
- if (err) {
- magicJS.logError(`获取会员任务失败，请求异常：${err}`);
- reject("❌获取会员任务失败，请求异常，请查阅日志！");
- } else {
- try {
- magicJS.logInfo(`获取会员任务，接口响应：${data}`);
- let obj = typeof data === "string" ? JSON.parse(data) : data;
- if (obj) {
- let result = [];
- obj.missions.forEach((element) => {
- let missionInfo = JSON.stringify(element);
- let flag = false;
- for (keyword of taskKeywords) {
- if (missionInfo.indexOf(keyword) >= 0) {
- flag = true;
- break;
- }
- }
- if (flag === true) {
- result.push(element.mission_id);
- }
- });
- resolve(result);
- } else {
- magicJS.logWarning(`没有可领取的会员任务，接口响应：${data}`);
- reject("❌没有可领取的会员任务，请查阅日志！");
- }
- } catch (err) {
- magicJS.logError(`获取会员任务失败，执行异常：${err}，接口响应：${data}`);
- reject("❌获取会员任务失败，执行异常，请查阅日志！");
- }
- }
- });
- });
-}
-
-// 接受超级会员任务列表中的任务
-function AcceptMission(cookie, longitude, latitude, mission_id) {
- let _mission_id = encodeURIComponent(mission_id);
- return new Promise((resolve, reject) => {
- let options = {
- url: `https://h5.ele.me/restapi/svip_biz/v1/supervip/accept_mission?type=0&receiveType=1&mission_id=${_mission_id}`,
- headers: {
- "Accept": "application/json, text/plain, */*",
- "Accept-Encoding": "gzip, deflate, br",
- "Accept-Language": "zh-cn",
- "Connection": "keep-alive",
- "Content-Type": "application/json;charset=utf-8",
- "Cookie": cookie,
- "Host": "h5.ele.me",
- "Origin": "https://h5.ele.me",
- "Referer": "https://h5.ele.me/svip/home?entryStat=profile",
- "User-Agent": "Rajax/1 Apple/iPhone10,3 iOS/14.5.1 Eleme/9.8.5",
- "f-pTraceId": "WVNet_WV_1-1-40",
- "f-refer": "wv_h5",
- "x-shard": "loc=121.52699279785156,31.2293643951416",
- },
- body: {
- longitude: longitude,
- latitude: latitude,
- },
- };
- magicJS.post(options, (err, resp, data) => {
- if (err) {
- magicJS.logError(`领取会员任务失败，任务Id：${mission_id}，请求异常：${err}`);
- reject(`领取会员任务失败，任务Id：${mission_id}`);
- } else {
- try {
- let obj = typeof data === "string" ? JSON.parse(data) : data;
- if (obj.success === true) {
- magicJS.logInfo(`领取会员任务成功，任务Id：${mission_id}，任务描述：${obj.mission.checkout_description}`);
- resolve(obj.mission.checkout_description);
- } else {
- magicJS.logError(`领取会员任务失败，任务Id：${mission_id}，响应异常：${data}`);
- reject(`领取会员任务失败，任务Id：${mission_id}`);
- }
- } catch (err) {
- magicJS.logError(`领取会员任务失败，任务Id：${mission_id}，执行异常：${err}，接口响应：${data}`);
- reject(`领取会员任务失败，任务Id：${mission_id}`);
- }
- }
- });
- });
-}
-
-(async () => {
- let subTitle = "";
- let content = "";
- let cookie = magicJS.read(elemeCookieKey);
- let longitude = magicJS.read(elemeLongitudeKey);
- let latitude = magicJS.read(elemeLatitudeKey);
- if (!!!cookie) {
- magicJS.logWarning("没有读取到Cookie，请先从App中获取一次Cookie！");
- content = "❓没有读取到有效Cookie，请先从App中获取Cookie!!";
- } else {
- // 领取会员任务
- let [getMissionErr, missions] = await magicJS.attempt(magicJS.retry(GetSuperVipMissions, 3, 2000)(cookie, longitude, latitude), []);
- if (getMissionErr) {
- subTitle = getMissionErr;
- } else if (missions.length == 0) {
- magicJS.log("领取任务失败，没有发现符合要求的任务。请查阅任务返回JSON，确认是否因为任务描述改变而无法领取。");
- subTitle = "❌没有符合要求的任务可以领取";
- } else {
- magicJS.logDebug(`获取待领取的任务Id：${JSON.stringify(missions)}`);
- let acceptMissionList = [];
- content = "会员任务领取结果：";
- for (let i = 0; i < missions.length; i++) {
- let [acceptErr, acceptResult] = await magicJS.attempt(AcceptMission(cookie, longitude, latitude, missions[i]), null);
- if (acceptResult) {
- acceptMissionList.push(missions[i]);
- content += `\n${acceptResult}`;
- }
- magicJS.logInfo(`成功领取的任务Id：${JSON.stringify(acceptMissionList)}`);
- }
- if (acceptMissionList.length <= 0) {
- content += "\n没有领取任何任务";
- }
- }
- }
- // 通知
- magicJS.notify(scriptName, subTitle, content);
- magicJS.done();
-})();
-
-// prettier-ignore
-function MagicJS(e="MagicJS",t="INFO"){const s={accept:"Accept","accept-ch":"Accept-CH","accept-charset":"Accept-Charset","accept-features":"Accept-Features","accept-encoding":"Accept-Encoding","accept-language":"Accept-Language","accept-ranges":"Accept-Ranges","access-control-allow-credentials":"Access-Control-Allow-Credentials","access-control-allow-origin":"Access-Control-Allow-Origin","access-control-allow-methods":"Access-Control-Allow-Methods","access-control-allow-headers":"Access-Control-Allow-Headers","access-control-max-age":"Access-Control-Max-Age","access-control-expose-headers":"Access-Control-Expose-Headers","access-control-request-method":"Access-Control-Request-Method","access-control-request-headers":"Access-Control-Request-Headers",age:"Age",allow:"Allow",alternates:"Alternates",authorization:"Authorization","cache-control":"Cache-Control",connection:"Connection","content-encoding":"Content-Encoding","content-language":"Content-Language","content-length":"Content-Length","content-location":"Content-Location","content-md5":"Content-MD5","content-range":"Content-Range","content-security-policy":"Content-Security-Policy","content-type":"Content-Type",cookie:"Cookie",dnt:"DNT",date:"Date",etag:"ETag",expect:"Expect",expires:"Expires",from:"From",host:"Host","if-match":"If-Match","if-modified-since":"If-Modified-Since","if-none-match":"If-None-Match","if-range":"If-Range","if-unmodified-since":"If-Unmodified-Since","last-event-id":"Last-Event-ID","last-modified":"Last-Modified",link:"Link",location:"Location","max-forwards":"Max-Forwards",negotiate:"Negotiate",origin:"Origin",pragma:"Pragma","proxy-authenticate":"Proxy-Authenticate","proxy-authorization":"Proxy-Authorization",range:"Range",referer:"Referer","retry-after":"Retry-After","sec-websocket-extensions":"Sec-Websocket-Extensions","sec-websocket-key":"Sec-Websocket-Key","sec-websocket-origin":"Sec-Websocket-Origin","sec-websocket-protocol":"Sec-Websocket-Protocol","sec-websocket-version":"Sec-Websocket-Version",server:"Server","set-cookie":"Set-Cookie","set-cookie2":"Set-Cookie2","strict-transport-security":"Strict-Transport-Security",tcn:"TCN",te:"TE",trailer:"Trailer","transfer-encoding":"Transfer-Encoding",upgrade:"Upgrade","user-agent":"User-Agent","variant-vary":"Variant-Vary",vary:"Vary",via:"Via",warning:"Warning","www-authenticate":"WWW-Authenticate","x-content-duration":"X-Content-Duration","x-content-security-policy":"X-Content-Security-Policy","x-dnsprefetch-control":"X-DNSPrefetch-Control","x-frame-options":"X-Frame-Options","x-requested-with":"X-Requested-With","x-surge-skip-scripting":"X-Surge-Skip-Scripting"};return new class{constructor(){this.version="2.2.3.3";this.scriptName=e;this.logLevels={DEBUG:5,INFO:4,NOTIFY:3,WARNING:2,ERROR:1,CRITICAL:0,NONE:-1};this.isLoon=typeof $loon!=="undefined";this.isQuanX=typeof $task!=="undefined";this.isJSBox=typeof $drive!=="undefined";this.isNode=typeof module!=="undefined"&&!this.isJSBox;this.isSurge=typeof $httpClient!=="undefined"&&!this.isLoon;this.platform=this.getPlatform();this.node={request:undefined,fs:undefined,data:{}};this.iOSUserAgent="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";this.pcUserAgent="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";this.logLevel=t;this._unifiedPushUrl="";if(this.isNode){this.node.fs=require("fs");this.node.request=require("request");try{this.node.fs.accessSync("./magic.json",this.node.fs.constants.R_OK|this.node.fs.constants.W_OK)}catch(e){this.node.fs.writeFileSync("./magic.json","{}",{encoding:"utf8"})}this.node.data=require("./magic.json")}else if(this.isJSBox){if(!$file.exists("drive://MagicJS")){$file.mkdir("drive://MagicJS")}if(!$file.exists("drive://MagicJS/magic.json")){$file.write({data:$data({string:"{}"}),path:"drive://MagicJS/magic.json"})}}}set barkUrl(e){this._unifiedPushUrl=!!e?e.replace(/\/+$/g,""):""}set logLevel(e){this._logLevel=typeof e==="string"?e.toUpperCase():"DEBUG"}get logLevel(){return this._logLevel}get isRequest(){return typeof $request!=="undefined"&&typeof $response==="undefined"}get isResponse(){return typeof $response!=="undefined"}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}}getPlatform(){if(this.isSurge)return"Surge";else if(this.isQuanX)return"QuantumultX";else if(this.isLoon)return"Loon";else if(this.isJSBox)return"JSBox";else if(this.isNode)return"Node.js";else return"unknown"}read(e,t=""){let s="";if(this.isSurge||this.isLoon){s=$persistentStore.read(e)}else if(this.isQuanX){s=$prefs.valueForKey(e)}else if(this.isNode){s=this.node.data}else if(this.isJSBox){s=$file.read("drive://MagicJS/magic.json").string}try{if(this.isNode)s=s[e];if(this.isJSBox)s=JSON.parse(s)[e];if(!!t){if(typeof s==="string")s=JSON.parse(s);s=!!s&&typeof s==="object"?s[t]:null}}catch(i){this.logError(i);s=!!t?{}:null;this.del(e)}if(typeof s==="undefined")s=null;try{if(!!s&&typeof s==="string")s=JSON.parse(s)}catch(e){}this.logDebug(`READ DATA [${e}]${!!t?`[${t}]`:""}(${typeof s})\n${JSON.stringify(s)}`);return s}write(e,t,s=""){let i=!!s?{}:"";if(!!s&&(this.isSurge||this.isLoon)){i=$persistentStore.read(e)}else if(!!s&&this.isQuanX){i=$prefs.valueForKey(e)}else if(this.isNode){i=this.node.data}else if(this.isJSBox){i=JSON.parse($file.read("drive://MagicJS/magic.json").string)}if(!!s){try{if(typeof i==="string")i=JSON.parse(i);i=typeof i==="object"&&!!i?i:{}}catch(t){this.logError(t);this.del(e);i={}}if(this.isJSBox||this.isNode){if(!i.hasOwnProperty(e)||typeof i[e]!=="object"||i[e]===null){i[e]={}}if(!i[e].hasOwnProperty(s)){i[e][s]=null}if(typeof t==="undefined"){delete i[e][s]}else{i[e][s]=t}}else{if(typeof t==="undefined"){delete i[s]}else{i[s]=t}}}else{if(this.isNode||this.isJSBox){if(typeof t==="undefined"){delete i[e]}else{i[e]=t}}else{if(typeof t==="undefined"){i=null}else{i=t}}}if(typeof i==="object")i=JSON.stringify(i);if(this.isSurge||this.isLoon){$persistentStore.write(i,e)}else if(this.isQuanX){$prefs.setValueForKey(i,e)}else if(this.isNode){this.node.fs.writeFileSync("./magic.json",i)}else if(this.isJSBox){$file.write({data:$data({string:i}),path:"drive://MagicJS/magic.json"})}this.logDebug(`WRITE DATA [${e}]${!!s?`[${s}]`:""}(${typeof t})\n${JSON.stringify(t)}`)}del(e,t=""){this.logDebug(`DELETE KEY [${e}]${!!t?`[${t}]`:""}`);this.write(e,null,t)}notify(e=this.scriptName,t="",s="",i=""){let o=e=>{let t={};if(this.isSurge||this.isQuanX||this.isLoon){if(typeof e==="string"){if(this.isLoon)t={openUrl:e};else if(this.isQuanX)t={"open-url":e};else if(this.isSurge)t={url:e}}else if(typeof e==="object"){let s={Surge:{openUrl:"url","open-url":"url"},Loon:{url:"openUrl","open-url":"openUrl","media-url":"mediaUrl"},QuantumultX:{url:"open-url",openUrl:"open-url",mediaUrl:"media-url"}};let i=Object.keys(e);for(let o=0;o{})}if(this.isSurge||this.isLoon){$notification.post(e,t,s,i)}else if(this.isQuanX){$notify(e,t,s,i)}else if(this.isJSBox){let i={title:e,body:!!t?`${t}\n${s}`:s};$push.schedule(i)}}log(e,t="INFO"){if(!(this.logLevels[this._logLevel]{if(typeof i.body==="undefined")return"";return`${encodeURIComponent(e)}=${encodeURIComponent(i.body[e])}`}).join("&");if(i.url.indexOf("?")<0)i.url+="?";if(i.url.lastIndexOf("&")+1!=i.url.length&&i.url.lastIndexOf("?")+1!=i.url.length)i.url+="&";i.url+=e;delete i.body}if(this.isQuanX){if(i.hasOwnProperty("body")&&typeof i["body"]!=="string")i["body"]=JSON.stringify(i["body"]);i["method"]=t}else if(this.isNode){delete i.headers["Accept-Encoding"];if(typeof i.body==="object"){if(t==="GET"){i.qs=i.body;delete i.body}else if(t==="POST"){i["json"]=true;i.body=i.body}}}else if(this.isJSBox){i["header"]=i["headers"];delete i["headers"]}return i}get(e,t){let s=this.adapterHttpOptions(e,"GET");this.logDebug(`HTTP GET: ${JSON.stringify(s)}`);if(this.isSurge||this.isLoon){$httpClient.get(s,t)}else if(this.isQuanX){$task.fetch(s).then(e=>{e["status"]=e.statusCode;t(null,e,e.body)},e=>t(e.error,null,null))}else if(this.isNode){return this.node.request.get(s,t)}else if(this.isJSBox){s["handler"]=(e=>{let s=e.error?JSON.stringify(e.error):undefined;let i=typeof e.data==="object"?JSON.stringify(e.data):e.data;t(s,e.response,i)});$http.get(s)}}post(e,t){let s=this.adapterHttpOptions(e,"POST");this.logDebug(`HTTP POST: ${JSON.stringify(s)}`);if(this.isSurge||this.isLoon){$httpClient.post(s,t)}else if(this.isQuanX){$task.fetch(s).then(e=>{e["status"]=e.statusCode;t(null,e,e.body)},e=>{t(e.error,null,null)})}else if(this.isNode){return this.node.request.post(s,t)}else if(this.isJSBox){s["handler"]=(e=>{let s=e.error?JSON.stringify(e.error):undefined;let i=typeof e.data==="object"?JSON.stringify(e.data):e.data;t(s,e.response,i)});$http.post(s)}}done(e={}){if(typeof $done!=="undefined"){$done(e)}}isToday(e){if(e==null){return false}else{let t=new Date;if(typeof e=="string"){e=new Date(e)}if(t.getFullYear()==e.getFullYear()&&t.getMonth()==e.getMonth()&&t.getDay()==e.getDay()){return true}else{return false}}}isNumber(e){return parseFloat(e).toString()==="NaN"?false:true}attempt(e,t=null){return e.then(e=>{return[null,e]}).catch(e=>{this.logError(e);return[e,t]})}retry(e,t=5,s=0,i=null){return(...o)=>{return new Promise((r,n)=>{function a(...o){Promise.resolve().then(()=>e.apply(this,o)).then(e=>{if(typeof i==="function"){Promise.resolve().then(()=>i(e)).then(()=>{r(e)}).catch(e=>{this.logError(e);if(t>=1&&s>0){setTimeout(()=>a.apply(this,o),s)}else if(t>=1){a.apply(this,o)}else{n(e)}t--})}else{r(e)}}).catch(e=>{this.logError(e);if(t>=1&&s>0){setTimeout(()=>a.apply(this,o),s)}else if(t>=1){a.apply(this,o)}else{n(e)}t--})}a.apply(this,o)})}}formatTime(e,t="yyyy-MM-dd hh:mm:ss"){var s={"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()};if(/(y+)/.test(t))t=t.replace(RegExp.$1,(e.getFullYear()+"").substr(4-RegExp.$1.length));for(let e in s)if(new RegExp("("+e+")").test(t))t=t.replace(RegExp.$1,RegExp.$1.length==1?s[e]:("00"+s[e]).substr((""+s[e]).length));return t}now(){return this.formatTime(new Date,"yyyy-MM-dd hh:mm:ss")}today(){return this.formatTime(new Date,"yyyy-MM-dd")}sleep(e){return new Promise(t=>setTimeout(t,e))}}(e)}