214 lines
22 KiB
JavaScript
214 lines
22 KiB
JavaScript
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';
|
||
|
||
let magicJS = MagicJS(scriptName, "INFO");
|
||
magicJS.unifiedPushUrl = magicJS.read("bark_url");
|
||
|
||
function GetCoordinate() {
|
||
try {
|
||
let arr = [];
|
||
const hisLongitude = magicJS.read(elemeLongitudeKey);
|
||
const hisLatitude = magicJS.read(elemeLatitudeKey);
|
||
arr = magicJS.request.url.match(getCoordinateRegex1);
|
||
if (arr && arr.length < 2) {
|
||
arr = magicJS.request.url.match(getCoordinateRegex2);
|
||
}
|
||
if (arr && arr.length < 2) {
|
||
arr = magicJS.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(`更新坐标成功!`)
|
||
}
|
||
}
|
||
catch (err) {
|
||
magicJS.notify('获取坐标出现异常,请查阅日志。');
|
||
magicJS.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写入成功!!');
|
||
}
|
||
else {
|
||
magicJS.logInfo('Cookie没有变化,无需更新');
|
||
}
|
||
}
|
||
|
||
// 获取待领取的吃货豆列表
|
||
function GetPeaList(cookie, longitude, latitude) {
|
||
return new Promise((resolve, reject) => {
|
||
let options = {
|
||
url: `https://h5.ele.me/restapi/biz.svip_core/v1/foodie/homepage?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-74",
|
||
"f-refer": "wv_h5",
|
||
"x-shard": `loc=${longitude},${latitude}`
|
||
}
|
||
}
|
||
magicJS.get(options, (err, resp, data) => {
|
||
if (err) {
|
||
magicJS.logError(`获取待领取的吃货豆失败,请求异常:${err}`);
|
||
reject('获取待领取的吃货豆失败,请求异常,请查阅日志!');
|
||
}
|
||
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('获取待领取的吃货豆失败,执行异常,请查阅日志!');
|
||
}
|
||
}
|
||
})
|
||
})
|
||
}
|
||
|
||
// 领取吃货豆
|
||
function DrawPea(cookie, peaId, longitude, latitude) {
|
||
return new Promise((resolve, reject) => {
|
||
let options = {
|
||
url: `https://h5.ele.me/restapi/biz.svip_bonus/v1/users/supervip/pea/draw?peaId=${peaId}`,
|
||
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.2 Eleme/9.3.8",
|
||
"f-pTraceId": "WVNet_WV_2-3-73",
|
||
"f-refer": "wv_h5",
|
||
"x-shard": `loc=${longitude},${latitude}`
|
||
},
|
||
body: JSON.stringify({
|
||
"longitude": longitude,
|
||
"latitude": latitude
|
||
})
|
||
}
|
||
magicJS.post(options, (err, resp, data) => {
|
||
if (err) {
|
||
magicJS.logError(`领取吃货豆失败,请求异常:${err}`);
|
||
reject('领取吃货豆失败,请求异常,请查阅日志!');
|
||
}
|
||
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('领取吃货豆失败,执行异常,请查阅日志!');
|
||
}
|
||
}
|
||
})
|
||
})
|
||
}
|
||
|
||
; (async () => {
|
||
if (magicJS.isRequest) {
|
||
if ((
|
||
getCoordinateRegex1.test(magicJS.request.url) ||
|
||
getCoordinateRegex2.test(magicJS.request.url) ||
|
||
getCoordinateRegex3.test(magicJS.request.url)
|
||
) && magicJS.request.method == "GET") {
|
||
GetCoordinate();
|
||
}
|
||
else if (getCookies.test(magicJS.request.url)) {
|
||
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!!';
|
||
}
|
||
else {
|
||
// 获取待领取的吃货豆
|
||
let [getPeaListErr, peaList] = await magicJS.attempt(GetPeaList(cookie, longitude, latitude), []);
|
||
content = '吃货豆领取结果:';
|
||
if (getPeaListErr) {
|
||
content += '\n获取待领取的吃货豆异常,请查阅日志';
|
||
}
|
||
else if (peaList.length == 0) {
|
||
content += '\n没有发现待领取的吃货豆';
|
||
}
|
||
else {
|
||
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);
|
||
}
|
||
content += `\n本次共领取吃货豆${peaCount}个${drawPeaContent}`;
|
||
}
|
||
}
|
||
// 通知
|
||
magicJS.notify(scriptName, subTitle, content);
|
||
}
|
||
magicJS.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) }
|