diff --git a/jd_beauty.js b/jd_beauty.js index dd7960c..6379e4c 100644 --- a/jd_beauty.js +++ b/jd_beauty.js @@ -1,24 +1,20 @@ /* 美丽研究院 修复+尽量优化为同步执行,减少并发,说不定就减小黑号概率了呢? +https://raw.githubusercontent.com/aTenb/jdOpenSharePicker/master/jd_beautyStudy.js 更新时间:2021-12-03 来源 Dylan -定时自定义，集中访问可能炸 活动入口：京东app首页-美妆馆-底部中间按钮 -#随机定时运行一次 +定时自定义，集中访问可能炸 */ const $ = new Env('美丽研究院'); const notify = $.isNode() ? require('./sendNotify') : ''; const jdCookieNode = $.isNode() ? require('./jdCookie.js') : ''; - - const WebSocket = require('ws'); const UA = process.env.JD_USER_AGENT ? process.env.JD_USER_AGENT : (require('./USER_AGENTS').USER_AGENT) -const JD_API_HOST = 'https://api.m.jd.com/client.action'; $.accountCheck = true; $.init = false; let cookiesArr = [], cookie = '', message; - function oc(fn, defaultVal) { try { return fn() @@ -26,7 +22,6 @@ function oc(fn, defaultVal) { return undefined } } - if ($.isNode()) { Object.keys(jdCookieNode).forEach((item) => { cookiesArr.push(jdCookieNode[item]) @@ -35,7 +30,7 @@ if ($.isNode()) { } else { cookiesArr = [$.getdata('CookieJD'), $.getdata('CookieJD2'), ...jsonParse($.getdata('CookiesJD') || "[]").map(item => item.cookie)].filter(item => !!item); } - +const JD_API_HOST = 'https://api.m.jd.com/client.action'; !(async () => { if (!cookiesArr[0]) { $.msg($.name, '【提示】请先获取京东账号一cookie\n直接使用NobyDa的京东签到获取', 'https://bean.m.jd.com/', {"open-url": "https://bean.m.jd.com/"}); @@ -55,7 +50,7 @@ if ($.isNode()) { $.nickName = ''; message = ''; $.token = ''; - await TotalBean(); + //await TotalBean(); console.log(`\n******开始【京东账号${$.index}】${$.nickName || $.UserName}*********\n`); if (!$.isLogin) { $.msg($.name, `【提示】cookie已失效`, `京东账号${$.index} ${$.nickName || $.UserName}\n请重新登录获取\nhttps://bean.m.jd.com/`, {"open-url": "https://bean.m.jd.com/"}); @@ -66,7 +61,9 @@ if ($.isNode()) { continue } await accountCheck(); - await $.wait(10000) + while (!$.hasDone) { + await $.wait(3000) + } if ($.accountCheck) { await jdBeauty(); } @@ -76,21 +73,21 @@ if ($.isNode()) { } } })() - .catch((e) => { - $.log('', `❌ ${$.name}, 失败! 原因: ${e}!`, '') - }) - .finally(() => { - $.done(); - }) + .catch((e) => { + $.log('', `❌ ${$.name}, 失败! 原因: ${e}!`, '') + }) + .finally(() => { + $.done(); + }) async function accountCheck() { $.hasDone = false; - console.log(`***检测账号是否黑号***`); + //console.log(`***检测账号是否黑号***`); await getIsvToken() await $.wait(10000) await getIsvToken2() await $.wait(10000) - await getAuth() + await getToken() await $.wait(10000) if (!$.token) { console.log(`\n\n提示：请尝试换服务器ip或者设置"xinruimz-isv.isvjcloud.com"域名直连，或者自定义UA再次尝试(环境变量JD_USER_AGENT)\n\n`) @@ -99,15 +96,15 @@ async function accountCheck() { } let client = new WebSocket(`wss://xinruimz-isv.isvjcloud.com/wss/?token=${$.token}`, null, { headers: { - 'user-agent': UA, + 'user-agent': UA, } }); client.onopen = async () => { console.log(`美容研究院服务器连接成功`); client.send('{"msg":{"type":"action","args":{"source":1},"action":"_init_"}}'); - await $.wait(20000); + await $.wait(10000); client.send(`{"msg":{"type":"action","args":{"source":1},"action":"get_user"}}`); - await $.wait(20000); + await $.wait(10000); }; client.onmessage = async function (e) { if (e.data !== 'pong' && e.data && safeGet(e.data)) { @@ -146,13 +143,14 @@ async function jdBeauty() { async function mr() { $.coins = 0 let positionList = ['b1', 'h1', 's1', 'b2', 'h2', 's2'] + let positionList2 = ['b2', 'h2', 's2'] $.tokens = [] $.pos = [] $.helpInfo = [] $.needs = [] let client = new WebSocket(`wss://xinruimz-isv.isvjcloud.com/wss/?token=${$.token}`,null,{ headers:{ - 'user-agent': UA, + 'user-agent': UA, } }) console.log(`wss://xinruimz-isv.isvjcloud.com/wss/?token=${$.token}`) @@ -167,18 +165,24 @@ async function mr() { await $.wait(10000); } console.log(`\n========生产任务相关========\n`) + for (let help of helpInfo) { + client.send(help); + } + await $.wait(3000) client.send(`{"msg":{"type":"action","args":{},"action":"get_produce_material"}}`) - await $.wait(20000); + await $.wait(10000); // 获得正在生产的商品信息 client.send('{"msg":{"type":"action","args":{},"action":"product_producing"}}') - await $.wait(20000); + await $.wait(10000); + // 获得库存 + client.send(`{"msg":{"type":"action","args":{},"action":"get_package"}}`) // 获得可生成的商品列表 client.send(`{"msg":{"type":"action","args":{"page":1,"num":10},"action":"product_lists"}}`) - await $.wait(20000); - // 获得原料生产列表 + await $.wait(10000); + // 获得原料生产列表 for (let pos of positionList) { - client.send(`{"msg":{"type":"action","args":{"position":"${pos}"},"action":"produce_position_info_v2"}}`) - await $.wait(20000); + client.send(`{"msg":{"type":"action","args":{"position":"${pos}"},"action":"produce_position_info_v2"}}`) + await $.wait(10000); } console.log(`\n========日常任务相关========`) client.send(`{"msg":{"type":"action","args":{},"action":"check_up"}}`) @@ -192,7 +196,7 @@ async function mr() { await $.wait(50000); //最后做时间最久的日常任务 client.send(`{"msg":{"type":"action","args":{},"action":"shop_products"}}`) - await $.wait(20000); + await $.wait(10000); } }; client.onclose = () => { @@ -201,7 +205,10 @@ async function mr() { $.init = true; $.hasDone = true; for (let i = 0; i < $.pos.length && i < $.tokens.length; ++i) { - $.helpInfo.push(`{"msg":{"type":"action","args":{"inviter_id":"${$.userInfo.id}","position":"${$.pos[i]}","token":"${$.tokens[i]}"},"action":"employee"}}`) + client.send(`{"msg":{"type":"action","args":{"inviter_id":"${$.userInfo.id}"},"action":"employee_get_user"}}`); + $.helpInfo.push(`{"msg":{"type":"action","args":{"inviter_id":"${$.userInfo.id}","position":"${$.pos[i]}","token":"${$.tokens[i]}"},"action":"employee_v2"}}`) + client.send(`{"msg":{"type":"action","args":{"inviter_id":"${$.userInfo.id}","position":"${$.pos[i]}"},"action":"employee_speed_v2"}}`); + client.send(`{"msg":{"action":"write","type":"action","args":{"action_type":3,"channel":2,"source_app":2}}}`); } }; client.onmessage = async function (e) { @@ -216,9 +223,9 @@ async function mr() { // 去签到 console.log(`去做签到任务`) client.send(`{"msg":{"type":"action","args":{},"action":"sign_in"}}`) - await $.wait(20000); + await $.wait(10000); client.send(`{"msg":{"action":"write","type":"action","args":{"action_type":1,"channel":2,"source_app":2}}}`) - await $.wait(20000); + await $.wait(10000); } break case "get_user": @@ -228,7 +235,7 @@ async function mr() { console.log(`去做新手任务`) for (let i = $.userInfo.step; i < 15; ++i) { client.send(`{"msg":{"type":"action","args":{},"action":"newcomer_update"}}`) - await $.wait(20000); + await $.wait(10000); } } else $.init = true; @@ -242,13 +249,13 @@ async function mr() { $.check_up = true // 6-9点签到 //for (let check_up of vo.data.check_up) { - // if (check_up['receive_status'] !== 1) { - // console.log(`去领取第${check_up.times}次签到奖励`) - // client.send(`{"msg":{"type":"action","args":{"check_up_id":${check_up.id}},"action":"check_up_receive"}}`) - // } else { - // console.log(`第${check_up.times}次签到奖励已领取`) - // } - // } + // if (check_up['receive_status'] !== 1) { + // console.log(`去领取第${check_up.times}次签到奖励`) + // client.send(`{"msg":{"type":"action","args":{"check_up_id":${check_up.id}},"action":"check_up_receive"}}`) + // } else { + // console.log(`第${check_up.times}次签到奖励已领取`) + // } + // } break case "shop_products": let count = $.taskState.shop_view.length; @@ -281,11 +288,14 @@ async function mr() { } await $.wait(10000); } - for (let i = $.taskState.meetingplace_view; i < $.taskState.mettingplace_count; ++i) { - console.log(`去做第${i + 1}次浏览会场任务`) - client.send(`{"msg":{"type":"action","args":{"source":1},"action":"meetingplace_view"}}`) - await $.wait(10000); + if ($.taskState.meetingplace_view.length <= vo.data.meetingplaces.length) { + for (let vc of vo.data.meetingplaces) { + console.log(`去做第${vc.name}浏览会场任务`) + client.send(`{"msg":{"type":"action","args":{"source":1,"meetingplace_id":${vc.id}},"action":"meetingplace_view"}}`) + await $.wait(2500) + } } + if ($.taskState.today_answered === 0) { console.log(`去做每日问答任务`) client.send(`{"msg":{"type":"action","args":{"source":1},"action":"get_question"}}`) @@ -356,7 +366,7 @@ async function mr() { client.send(`{"msg":{"type":"action","args":{"position":"${vo.data.position}","material_id":${ma.id}},"action":"material_produce_v2"}}`) await $.wait(5000); } else { - ma = $.material.base[1]['items'][positionList.indexOf(vo.data.position)] + ma = $.material.base[1]['items'][positionList2.indexOf(vo.data.position)] if (ma) { console.log(`else去生产${ma.name}`) client.send(`{"msg":{"type":"action","args":{"position":"${vo.data.position}","material_id":${ma.id}},"action":"material_produce_v2"}}`) @@ -402,7 +412,7 @@ async function mr() { case "product_lists": let need_material = [] if (vo.code === '200' || vo.code === 200) { - $.products = vo.data.filter(vo=>vo.level===$.level) + $.products = vo.data.filter(vo=>vo.level===$.level-1) console.log(`========可生产商品信息========`) for (let product of $.products) { let num = Infinity @@ -431,6 +441,7 @@ async function mr() { console.log(`【${product.name}】可生产份数大于0，去生产`) //product_produce 产品研发里的生产 client.send(`{"msg":{"type":"action","args":{"product_id":${product.id},"amount":${num}},"action":"product_produce"}}`) + client.send(`{"msg":{"type":"action","args":{"product_id":${product.id},"amount":${num}},"action":"once_completion"}}`) await $.wait(10000); } else { console.log(msg) @@ -483,20 +494,20 @@ async function mr() { console.log(`收取产品失败，错误信息${vo.msg}`) } break - // case "get_task": - // console.log(`当前任务【${vo.data.describe}】，需要【${vo.data.product.name}】${vo.data.package_stock}/${vo.data.num}份`) - // if (vo.data.package_stock >= vo.data.num) { - // console.log(`满足任务要求，去完成任务`) - // client.send(`{"msg":{"type":"action","args":{"task_id":${vo.data.id}},"action":"complete_task"}}`) - // } - // break + // case "get_task": + // console.log(`当前任务【${vo.data.describe}】，需要【${vo.data.product.name}】${vo.data.package_stock}/${vo.data.num}份`) + // if (vo.data.package_stock >= vo.data.num) { + // console.log(`满足任务要求，去完成任务`) + // client.send(`{"msg":{"type":"action","args":{"task_id":${vo.data.id}},"action":"complete_task"}}`) + // } + // break case 'get_benefit': for (let benefit of vo.data) { if (benefit.type === 1) { //type 1 是京豆 //console.log(`benefit:${JSON.stringify(benefit)}`); - if(benefit.description === "1 京豆" && parseInt(benefit.day_exchange_count) < 10 && $.total > benefit.coins){ + if(benefit.description === "1 京豆" && parseInt(benefit.day_exchange_count) < 5 && $.total > benefit.coins){ $timenum = parseInt($.total / benefit.coins); - if ($timenum > 10) $timenum = 10; + if ($timenum > 5) $timenum = 5; console.log(`\n可兑换${$timenum}次京豆:`) for (let i = 0; i < $timenum; i++){ client.send(`{"msg":{"type":"action","args":{"benefit_id":${benefit.id}},"action":"to_exchange"}}`); @@ -518,7 +529,7 @@ async function mr() { break case "to_exchange": if(oc(() => vo.data.coins)){ - console.log(`兑换${vo.data.coins/-1000}京豆成功`) + console.log(`兑换${vo.data.coins/-10000}京豆成功`) }else{ console.log(`兑换京豆失败`) } @@ -526,15 +537,15 @@ async function mr() { case "get_produce_material": $.material = vo.data break - case "to_employee": - console.log(`雇佣助力码【${oc(() => vo.data.token)}】`) - if(oc(() => vo.data.token)){ - $.tokens.push(vo.data.token) - }else{ - console.log(`not exist:${oc(() => vo.data)}`) - } - break - case "employee": + //case "to_employee": + // console.log(`雇佣助力码【${oc(() => vo.data.token)}】`) + // if(oc(() => vo.data.token)){ + // $.tokens.push(vo.data.token) + // }else{ + // console.log(`not exist:${oc(() => vo.data)}`) + // } + // break + case "employee_v2": console.log(`${vo.msg}`) break } @@ -564,7 +575,7 @@ function getIsvToken() { if (safeGet(data)) { data = JSON.parse(data); $.isvToken = data['tokenKey']; - console.log(`isvToken:${$.isvToken}`); + //console.log(`isvToken:${$.isvToken}`); } } } catch (e) { @@ -577,18 +588,24 @@ function getIsvToken() { } async function getIsvToken2() { + for (let i=0; i<3; i++){ + var body = await getSignfromDY('isvObfuscator',{"id":"","url":"https://xinruimz-isv.isvjcloud.com"}) + if(body) break; + await $.wait(5000) + } let config = { url: 'https://api.m.jd.com/client.action?functionId=isvObfuscator', - body: await getSignfromDY('isvObfuscator',{"id":"","url":"https://xinruimz-isv.isvjcloud.com"}), + body: `${$.Signz}`, headers: { 'Host': 'api.m.jd.com', 'accept': '*/*', 'user-agent': UA, - 'accept-language': 'zh-Hans-JP;q=1, en-JP;q=0.9, zh-Hant-TW;q=0.8, ja-JP;q=0.7, en-US;q=0.6', - 'content-type': 'application/x-www-form-urlencoded', + //'accept-language': 'zh-Hans-JP;q=1, en-JP;q=0.9, zh-Hant-TW;q=0.8, ja-JP;q=0.7, en-US;q=0.6', + //'content-type': 'application/x-www-form-urlencoded', 'Cookie': cookie } } + return new Promise(resolve => { $.post(config, async (err, resp, data) => { try { @@ -599,7 +616,7 @@ async function getIsvToken2() { if (safeGet(data)) { data = JSON.parse(data); $.token2 = data['token'] - console.log(`token2:${$.token2}`); + //console.log(`token2:${$.token2}`); } } } catch (e) { @@ -610,48 +627,36 @@ async function getIsvToken2() { }) }) } -function getSignfromDY(functionId, body) { - var strsign = ''; - let data = `functionId=${functionId}&body=${encodeURIComponent(JSON.stringify(body))}` - return new Promise((resolve) => { - let opt = { - url: "https://jd.nbplay.xyz/dylan/getsign", - body: data, - headers: { - 'Content-Type': 'application/x-www-form-urlencoded', - } - ,timeout: 30000 - } - $.post(opt, async(err, resp, data) => { - try { - if (data){ - data = JSON.parse(data); - if (data && data.code == 0) { - console.log("连接DY服务成功" ); - if (data.data){ - strsign = data.data || ''; - } - if (strsign != ''){ - resolve(strsign); - } - else - console.log("签名获取失败,换个时间再试."); - } else { - console.log(data.msg); - } - }else{console.log('连接连接DY服务失败，重试。。。')} - }catch (e) { - $.logErr(e, resp); - }finally { - resolve(strsign); - } - }) - }) -} -function getAuth() { +function getSignfromDY(functionId, body) { +let data={'fn':functionId,'body':JSON.stringify(body)}; + let optionsions={'url':'https://api.nolanstore.top/sign','body':JSON.stringify(data),'headers':{"Content-Type": "application/json"},'timeout':30000}; + return new Promise(async resolve=>{ + $.post(optionsions,(err,resp,data)=>{ + try{ + if(err){ + console.log(''+JSON.stringify(err)); + console.log($.name+' getSign API请求失败，请检查网路重试'); + }else{ + data=JSON.parse(data); + if((typeof data==='object')&&data&&data.body){ + $.Signz=data.body ||''; + } else { + console.log('获取服务失败~~'); + } + } + }catch(e){ + $.logErr(e,resp); + } + finally{ + resolve(data); + } + }); + }); +}; +function getToken() { let config = { url: 'https://xinruimz-isv.isvjcloud.com/api/auth', - body: JSON.stringify({"token":$.token2,"source":"01"}), + body: JSON.stringify({"token":$.token2,"source":"01","channel":"meizhuangguandibudaohang"}), headers: { 'Host': 'xinruimz-isv.isvjcloud.com', 'Accept': 'application/x.jd-school-island.v1+json', @@ -662,7 +667,7 @@ function getAuth() { 'user-agent': UA, 'Referer': 'https://xinruimz-isv.isvjcloud.com/logined_jd/', 'Authorization': 'Bearer undefined', - 'Cookie': `IsvToken=${$.isvToken};` + 'Cookie': `IsvToken=${$.token2};` } } return new Promise(resolve => { @@ -675,7 +680,7 @@ function getAuth() { if (safeGet(data)) { data = JSON.parse(data); $.token = data.access_token - console.log(`$.token ${$.token}`) + //console.log(`$.token ${$.token}`) } } } catch (e) { @@ -708,7 +713,7 @@ function TotalBean() { "Cookie": cookie, "Referer": "https://wqs.jd.com/my/jingdou/my.shtml?sceneval=2", 'user-agent': UA, - } + } } $.post(options, (err, resp, data) => { try { @@ -765,4 +770,4 @@ function jsonParse(str) { } // prettier-ignore -function Env(t,e){"undefined"!=typeof process&&JSON.stringify(process.env).indexOf("GITHUB")>-1&&process.exit(0);class s{constructor(t){this.env=t}send(t,e="GET"){t="string"==typeof t?{url:t}:t;let s=this.get;return"POST"===e&&(s=this.post),new Promise((e,i)=>{s.call(this,t,(t,s,r)=>{t?i(t):e(s)})})}get(t){return this.send.call(this.env,t)}post(t){return this.send.call(this.env,t,"POST")}}return new class{constructor(t,e){this.name=t,this.http=new s(this),this.data=null,this.dataFile="box.dat",this.logs=[],this.isMute=!1,this.isNeedRewrite=!1,this.logSeparator="\n",this.startTime=(new Date).getTime(),Object.assign(this,e),this.log("",`🔔${this.name}, 开始!`)}isNode(){return"undefined"!=typeof module&&!!module.exports}isQuanX(){return"undefined"!=typeof $task}isSurge(){return"undefined"!=typeof $httpClient&&"undefined"==typeof $loon}isLoon(){return"undefined"!=typeof $loon}toObj(t,e=null){try{return JSON.parse(t)}catch{return e}}toStr(t,e=null){try{return JSON.stringify(t)}catch{return e}}getjson(t,e){let s=e;const i=this.getdata(t);if(i)try{s=JSON.parse(this.getdata(t))}catch{}return s}setjson(t,e){try{return this.setdata(JSON.stringify(t),e)}catch{return!1}}getScript(t){return new Promise(e=>{this.get({url:t},(t,s,i)=>e(i))})}runScript(t,e){return new Promise(s=>{let i=this.getdata("@chavy_boxjs_userCfgs.httpapi");i=i?i.replace(/\n/g,"").trim():i;let r=this.getdata("@chavy_boxjs_userCfgs.httpapi_timeout");r=r?1*r:20,r=e&&e.timeout?e.timeout:r;const[o,h]=i.split("@"),n={url:`http://${h}/v1/scripting/evaluate`,body:{script_text:t,mock_type:"cron",timeout:r},headers:{"X-Key":o,Accept:"*/*"}};this.post(n,(t,e,i)=>s(i))}).catch(t=>this.logErr(t))}loaddata(){if(!this.isNode())return{};{this.fs=this.fs?this.fs:require("fs"),this.path=this.path?this.path:require("path");const t=this.path.resolve(this.dataFile),e=this.path.resolve(process.cwd(),this.dataFile),s=this.fs.existsSync(t),i=!s&&this.fs.existsSync(e);if(!s&&!i)return{};{const i=s?t:e;try{return JSON.parse(this.fs.readFileSync(i))}catch(t){return{}}}}}writedata(){if(this.isNode()){this.fs=this.fs?this.fs:require("fs"),this.path=this.path?this.path:require("path");const t=this.path.resolve(this.dataFile),e=this.path.resolve(process.cwd(),this.dataFile),s=this.fs.existsSync(t),i=!s&&this.fs.existsSync(e),r=JSON.stringify(this.data);s?this.fs.writeFileSync(t,r):i?this.fs.writeFileSync(e,r):this.fs.writeFileSync(t,r)}}lodash_get(t,e,s){const i=e.replace(/\[(\d+)\]/g,".$1").split(".");let r=t;for(const t of i)if(r=Object(r)[t],void 0===r)return s;return r}lodash_set(t,e,s){return Object(t)!==t?t:(Array.isArray(e)||(e=e.toString().match(/[^.[\]]+/g)||[]),e.slice(0,-1).reduce((t,s,i)=>Object(t[s])===t[s]?t[s]:t[s]=Math.abs(e[i+1])>>0==+e[i+1]?[]:{},t)[e[e.length-1]]=s,t)}getdata(t){let e=this.getval(t);if(/^@/.test(t)){const[,s,i]=/^@(.*?)\.(.*?)$/.exec(t),r=s?this.getval(s):"";if(r)try{const t=JSON.parse(r);e=t?this.lodash_get(t,i,""):e}catch(t){e=""}}return e}setdata(t,e){let s=!1;if(/^@/.test(e)){const[,i,r]=/^@(.*?)\.(.*?)$/.exec(e),o=this.getval(i),h=i?"null"===o?null:o||"{}":"{}";try{const e=JSON.parse(h);this.lodash_set(e,r,t),s=this.setval(JSON.stringify(e),i)}catch(e){const o={};this.lodash_set(o,r,t),s=this.setval(JSON.stringify(o),i)}}else s=this.setval(t,e);return s}getval(t){return this.isSurge()||this.isLoon()?$persistentStore.read(t):this.isQuanX()?$prefs.valueForKey(t):this.isNode()?(this.data=this.loaddata(),this.data[t]):this.data&&this.data[t]||null}setval(t,e){return this.isSurge()||this.isLoon()?$persistentStore.write(t,e):this.isQuanX()?$prefs.setValueForKey(t,e):this.isNode()?(this.data=this.loaddata(),this.data[e]=t,this.writedata(),!0):this.data&&this.data[e]||null}initGotEnv(t){this.got=this.got?this.got:require("got"),this.cktough=this.cktough?this.cktough:require("tough-cookie"),this.ckjar=this.ckjar?this.ckjar:new this.cktough.CookieJar,t&&(t.headers=t.headers?t.headers:{},void 0===t.headers.Cookie&&void 0===t.cookieJar&&(t.cookieJar=this.ckjar))}get(t,e=(()=>{})){t.headers&&(delete t.headers["Content-Type"],delete t.headers["Content-Length"]),this.isSurge()||this.isLoon()?(this.isSurge()&&this.isNeedRewrite&&(t.headers=t.headers||{},Object.assign(t.headers,{"X-Surge-Skip-Scripting":!1})),$httpClient.get(t,(t,s,i)=>{!t&&s&&(s.body=i,s.statusCode=s.status),e(t,s,i)})):this.isQuanX()?(this.isNeedRewrite&&(t.opts=t.opts||{},Object.assign(t.opts,{hints:!1})),$task.fetch(t).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>e(t))):this.isNode()&&(this.initGotEnv(t),this.got(t).on("redirect",(t,e)=>{try{if(t.headers["set-cookie"]){const s=t.headers["set-cookie"].map(this.cktough.Cookie.parse).toString();s&&this.ckjar.setCookieSync(s,null),e.cookieJar=this.ckjar}}catch(t){this.logErr(t)}}).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>{const{message:s,response:i}=t;e(s,i,i&&i.body)}))}post(t,e=(()=>{})){if(t.body&&t.headers&&!t.headers["Content-Type"]&&(t.headers["Content-Type"]="application/x-www-form-urlencoded"),t.headers&&delete t.headers["Content-Length"],this.isSurge()||this.isLoon())this.isSurge()&&this.isNeedRewrite&&(t.headers=t.headers||{},Object.assign(t.headers,{"X-Surge-Skip-Scripting":!1})),$httpClient.post(t,(t,s,i)=>{!t&&s&&(s.body=i,s.statusCode=s.status),e(t,s,i)});else if(this.isQuanX())t.method="POST",this.isNeedRewrite&&(t.opts=t.opts||{},Object.assign(t.opts,{hints:!1})),$task.fetch(t).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>e(t));else if(this.isNode()){this.initGotEnv(t);const{url:s,...i}=t;this.got.post(s,i).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>{const{message:s,response:i}=t;e(s,i,i&&i.body)})}}time(t,e=null){const s=e?new Date(e):new Date;let i={"M+":s.getMonth()+1,"d+":s.getDate(),"H+":s.getHours(),"m+":s.getMinutes(),"s+":s.getSeconds(),"q+":Math.floor((s.getMonth()+3)/3),S:s.getMilliseconds()};/(y+)/.test(t)&&(t=t.replace(RegExp.$1,(s.getFullYear()+"").substr(4-RegExp.$1.length)));for(let e in i)new RegExp("("+e+")").test(t)&&(t=t.replace(RegExp.$1,1==RegExp.$1.length?i[e]:("00"+i[e]).substr((""+i[e]).length)));return t}msg(e=t,s="",i="",r){const o=t=>{if(!t)return t;if("string"==typeof t)return this.isLoon()?t:this.isQuanX()?{"open-url":t}:this.isSurge()?{url:t}:void 0;if("object"==typeof t){if(this.isLoon()){let e=t.openUrl||t.url||t["open-url"],s=t.mediaUrl||t["media-url"];return{openUrl:e,mediaUrl:s}}if(this.isQuanX()){let e=t["open-url"]||t.url||t.openUrl,s=t["media-url"]||t.mediaUrl;return{"open-url":e,"media-url":s}}if(this.isSurge()){let e=t.url||t.openUrl||t["open-url"];return{url:e}}}};if(this.isMute||(this.isSurge()||this.isLoon()?$notification.post(e,s,i,o(r)):this.isQuanX()&&$notify(e,s,i,o(r))),!this.isMuteLog){let t=["","==============📣系统通知📣=============="];t.push(e),s&&t.push(s),i&&t.push(i),console.log(t.join("\n")),this.logs=this.logs.concat(t)}}log(...t){t.length>0&&(this.logs=[...this.logs,...t]),console.log(t.join(this.logSeparator))}logErr(t,e){const s=!this.isSurge()&&!this.isQuanX()&&!this.isLoon();s?this.log("",`❗️${this.name}, 错误!`,t.stack):this.log("",`❗️${this.name}, 错误!`,t)}wait(t){return new Promise(e=>setTimeout(e,t))}done(t={}){const e=(new Date).getTime(),s=(e-this.startTime)/1e3;this.log("",`🔔${this.name}, 结束! 🕛 ${s} 秒`),this.log(),(this.isSurge()||this.isQuanX()||this.isLoon())&&$done(t)}}(t,e)} \ No newline at end of file +function Env(t,e){"undefined"!=typeof process&&JSON.stringify(process.env).indexOf("GITHUB")>-1&&process.exit(0);class s{constructor(t){this.env=t}send(t,e="GET"){t="string"==typeof t?{url:t}:t;let s=this.get;return"POST"===e&&(s=this.post),new Promise((e,i)=>{s.call(this,t,(t,s,r)=>{t?i(t):e(s)})})}get(t){return this.send.call(this.env,t)}post(t){return this.send.call(this.env,t,"POST")}}return new class{constructor(t,e){this.name=t,this.http=new s(this),this.data=null,this.dataFile="box.dat",this.logs=[],this.isMute=!1,this.isNeedRewrite=!1,this.logSeparator="\n",this.startTime=(new Date).getTime(),Object.assign(this,e),this.log("",`🔔${this.name}, 开始!`)}isNode(){return"undefined"!=typeof module&&!!module.exports}isQuanX(){return"undefined"!=typeof $task}isSurge(){return"undefined"!=typeof $httpClient&&"undefined"==typeof $loon}isLoon(){return"undefined"!=typeof $loon}toObj(t,e=null){try{return JSON.parse(t)}catch{return e}}toStr(t,e=null){try{return JSON.stringify(t)}catch{return e}}getjson(t,e){let s=e;const i=this.getdata(t);if(i)try{s=JSON.parse(this.getdata(t))}catch{}return s}setjson(t,e){try{return this.setdata(JSON.stringify(t),e)}catch{return!1}}getScript(t){return new Promise(e=>{this.get({url:t},(t,s,i)=>e(i))})}runScript(t,e){return new Promise(s=>{let i=this.getdata("@chavy_boxjs_userCfgs.httpapi");i=i?i.replace(/\n/g,"").trim():i;let r=this.getdata("@chavy_boxjs_userCfgs.httpapi_timeout");r=r?1*r:20,r=e&&e.timeout?e.timeout:r;const[o,h]=i.split("@"),n={url:`http://${h}/v1/scripting/evaluate`,body:{script_text:t,mock_type:"cron",timeout:r},headers:{"X-Key":o,Accept:"*/*"}};this.post(n,(t,e,i)=>s(i))}).catch(t=>this.logErr(t))}loaddata(){if(!this.isNode())return{};{this.fs=this.fs?this.fs:require("fs"),this.path=this.path?this.path:require("path");const t=this.path.resolve(this.dataFile),e=this.path.resolve(process.cwd(),this.dataFile),s=this.fs.existsSync(t),i=!s&&this.fs.existsSync(e);if(!s&&!i)return{};{const i=s?t:e;try{return JSON.parse(this.fs.readFileSync(i))}catch(t){return{}}}}}writedata(){if(this.isNode()){this.fs=this.fs?this.fs:require("fs"),this.path=this.path?this.path:require("path");const t=this.path.resolve(this.dataFile),e=this.path.resolve(process.cwd(),this.dataFile),s=this.fs.existsSync(t),i=!s&&this.fs.existsSync(e),r=JSON.stringify(this.data);s?this.fs.writeFileSync(t,r):i?this.fs.writeFileSync(e,r):this.fs.writeFileSync(t,r)}}lodash_get(t,e,s){const i=e.replace(/\[(\d+)\]/g,".$1").split(".");let r=t;for(const t of i)if(r=Object(r)[t],void 0===r)return s;return r}lodash_set(t,e,s){return Object(t)!==t?t:(Array.isArray(e)||(e=e.toString().match(/[^.[\]]+/g)||[]),e.slice(0,-1).reduce((t,s,i)=>Object(t[s])===t[s]?t[s]:t[s]=Math.abs(e[i+1])>>0==+e[i+1]?[]:{},t)[e[e.length-1]]=s,t)}getdata(t){let e=this.getval(t);if(/^@/.test(t)){const[,s,i]=/^@(.*?)\.(.*?)$/.exec(t),r=s?this.getval(s):"";if(r)try{const t=JSON.parse(r);e=t?this.lodash_get(t,i,""):e}catch(t){e=""}}return e}setdata(t,e){let s=!1;if(/^@/.test(e)){const[,i,r]=/^@(.*?)\.(.*?)$/.exec(e),o=this.getval(i),h=i?"null"===o?null:o||"{}":"{}";try{const e=JSON.parse(h);this.lodash_set(e,r,t),s=this.setval(JSON.stringify(e),i)}catch(e){const o={};this.lodash_set(o,r,t),s=this.setval(JSON.stringify(o),i)}}else s=this.setval(t,e);return s}getval(t){return this.isSurge()||this.isLoon()?$persistentStore.read(t):this.isQuanX()?$prefs.valueForKey(t):this.isNode()?(this.data=this.loaddata(),this.data[t]):this.data&&this.data[t]||null}setval(t,e){return this.isSurge()||this.isLoon()?$persistentStore.write(t,e):this.isQuanX()?$prefs.setValueForKey(t,e):this.isNode()?(this.data=this.loaddata(),this.data[e]=t,this.writedata(),!0):this.data&&this.data[e]||null}initGotEnv(t){this.got=this.got?this.got:require("got"),this.cktough=this.cktough?this.cktough:require("tough-cookie"),this.ckjar=this.ckjar?this.ckjar:new this.cktough.CookieJar,t&&(t.headers=t.headers?t.headers:{},void 0===t.headers.Cookie&&void 0===t.cookieJar&&(t.cookieJar=this.ckjar))}get(t,e=(()=>{})){t.headers&&(delete t.headers["Content-Type"],delete t.headers["Content-Length"]),this.isSurge()||this.isLoon()?(this.isSurge()&&this.isNeedRewrite&&(t.headers=t.headers||{},Object.assign(t.headers,{"X-Surge-Skip-Scripting":!1})),$httpClient.get(t,(t,s,i)=>{!t&&s&&(s.body=i,s.statusCode=s.status),e(t,s,i)})):this.isQuanX()?(this.isNeedRewrite&&(t.opts=t.opts||{},Object.assign(t.opts,{hints:!1})),$task.fetch(t).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>e(t))):this.isNode()&&(this.initGotEnv(t),this.got(t).on("redirect",(t,e)=>{try{if(t.headers["set-cookie"]){const s=t.headers["set-cookie"].map(this.cktough.Cookie.parse).toString();s&&this.ckjar.setCookieSync(s,null),e.cookieJar=this.ckjar}}catch(t){this.logErr(t)}}).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>{const{message:s,response:i}=t;e(s,i,i&&i.body)}))}post(t,e=(()=>{})){if(t.body&&t.headers&&!t.headers["Content-Type"]&&(t.headers["Content-Type"]="application/x-www-form-urlencoded"),t.headers&&delete t.headers["Content-Length"],this.isSurge()||this.isLoon())this.isSurge()&&this.isNeedRewrite&&(t.headers=t.headers||{},Object.assign(t.headers,{"X-Surge-Skip-Scripting":!1})),$httpClient.post(t,(t,s,i)=>{!t&&s&&(s.body=i,s.statusCode=s.status),e(t,s,i)});else if(this.isQuanX())t.method="POST",this.isNeedRewrite&&(t.opts=t.opts||{},Object.assign(t.opts,{hints:!1})),$task.fetch(t).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>e(t));else if(this.isNode()){this.initGotEnv(t);const{url:s,...i}=t;this.got.post(s,i).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>{const{message:s,response:i}=t;e(s,i,i&&i.body)})}}time(t,e=null){const s=e?new Date(e):new Date;let i={"M+":s.getMonth()+1,"d+":s.getDate(),"H+":s.getHours(),"m+":s.getMinutes(),"s+":s.getSeconds(),"q+":Math.floor((s.getMonth()+3)/3),S:s.getMilliseconds()};/(y+)/.test(t)&&(t=t.replace(RegExp.$1,(s.getFullYear()+"").substr(4-RegExp.$1.length)));for(let e in i)new RegExp("("+e+")").test(t)&&(t=t.replace(RegExp.$1,1==RegExp.$1.length?i[e]:("00"+i[e]).substr((""+i[e]).length)));return t}msg(e=t,s="",i="",r){const o=t=>{if(!t)return t;if("string"==typeof t)return this.isLoon()?t:this.isQuanX()?{"open-url":t}:this.isSurge()?{url:t}:void 0;if("object"==typeof t){if(this.isLoon()){let e=t.openUrl||t.url||t["open-url"],s=t.mediaUrl||t["media-url"];return{openUrl:e,mediaUrl:s}}if(this.isQuanX()){let e=t["open-url"]||t.url||t.openUrl,s=t["media-url"]||t.mediaUrl;return{"open-url":e,"media-url":s}}if(this.isSurge()){let e=t.url||t.openUrl||t["open-url"];return{url:e}}}};if(this.isMute||(this.isSurge()||this.isLoon()?$notification.post(e,s,i,o(r)):this.isQuanX()&&$notify(e,s,i,o(r))),!this.isMuteLog){let t=["","==============📣系统通知📣=============="];t.push(e),s&&t.push(s),i&&t.push(i),console.log(t.join("\n")),this.logs=this.logs.concat(t)}}log(...t){t.length>0&&(this.logs=[...this.logs,...t]),console.log(t.join(this.logSeparator))}logErr(t,e){const s=!this.isSurge()&&!this.isQuanX()&&!this.isLoon();s?this.log("",`❗️${this.name}, 错误!`,t.stack):this.log("",`❗️${this.name}, 错误!`,t)}wait(t){return new Promise(e=>setTimeout(e,t))}done(t={}){const e=(new Date).getTime(),s=(e-this.startTime)/1e3;this.log("",`🔔${this.name}, 结束! 🕛 ${s} 秒`),this.log(),(this.isSurge()||this.isQuanX()||this.isLoon())&&$done(t)}}(t,e)}