const $ = new Env('会话切换') $.KEY_sessions = 'chavy_boxjs_sessions' $.KEY_curSessions = 'chavy_boxjs_cur_sessions' $.CFG_isSilent = $.getdata('CFG_BoxSwitcher_isSilent') !(async () => { await execSwitch() await showmsg() })() .catch((e) => $.logErr(e)) .finally(() => $.done()) function execSwitch() { $.subt = '' $.desc = [] return new Promise((resove) => { const sessions = getSessions() const curSessions = getCurSessions() // 会话排序: `创建时间`升序 sessions.sort((a, b) => a.createTime.replace(/-|:| /g, '') - b.createTime.replace(/-|:| /g, '')) const apps = {} sessions.forEach((session) => { const appId = session.appId const appName = session.appName apps[appId] = apps[appId] ? apps[appId] : {id: appId, name: appName, sessions: []} const app = apps[appId] app.sessions.push(session) }) Object.keys(apps).forEach((appId) => { const app = apps[appId] if (app.sessions.length <= 1) { $.desc.push(`${app.name}: 跳过! 原因: 只有 1 个会话?`) return true } let curSessionIdx = app.sessions.findIndex((session) => session.id === curSessions[appId]) if (curSessionIdx === -1) { curSessionIdx = app.sessions.length - 1 } const curSession = app.sessions[curSessionIdx] const isNewRound = curSessionIdx + 1 === app.sessions.length const nextSessionIdx = isNewRound ? 0 : curSessionIdx + 1 const nextSession = app.sessions[nextSessionIdx] nextSession.datas.forEach((_data) => $.setdata([undefined, null, 'undefined', 'null', ''].includes(_data.val) ? '' : _data.val, _data.key)) curSessions[appId] = nextSession.id $.desc.push(`${curSession.appName}: ${curSession.name} => #${nextSessionIdx + 1} ${nextSession.name} ${isNewRound ? '(新一轮)' : ''}`) }) $.setdata(JSON.stringify(curSessions), $.KEY_curSessions) resove() }) } function getSessions() { const sessionstr = $.getdata($.KEY_sessions) const sessions = ![undefined, null, 'null', ''].includes(sessionstr) ? JSON.parse(sessionstr) : [] return Array.isArray(sessions) ? sessions : [] } function getCurSessions() { const sessionstr = $.getdata($.KEY_curSessions) return ![undefined, null, 'null', ''].includes(sessionstr) ? JSON.parse(sessionstr) : {} } function showmsg() { return new Promise((resove) => { if (!$.CFG_isSilent || $.CFG_isSilent === 'false') { $.msg($.name, $.subt, $.desc.join('\n')) } else { $.log('', ...$.desc) } resove() }) } // prettier-ignore function Env(t, s) { return new class { constructor(t, s) { this.name = t, this.data = null, this.dataFile = "box.dat", this.logs = [], this.logSeparator = "\n", this.startTime = (new Date).getTime(), Object.assign(this, s), this.log("", `\ud83d\udd14${this.name}, \u5f00\u59cb!`) } isNode() { return "undefined" != typeof module && !!module.exports } isQuanX() { return "undefined" != typeof $task } isSurge() { return "undefined" != typeof $httpClient } isLoon() { return "undefined" != typeof $loon } 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), s = this.path.resolve(process.cwd(), this.dataFile), e = this.fs.existsSync(t), i = !e && this.fs.existsSync(s); if (!e && !i) return {}; { const i = e ? t : s; try { return JSON.parse(this.fs.readFileSync(i)) } catch { 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), s = this.path.resolve(process.cwd(), this.dataFile), e = this.fs.existsSync(t), i = !e && this.fs.existsSync(s), o = JSON.stringify(this.data); e ? this.fs.writeFileSync(t, o) : i ? this.fs.writeFileSync(s, o) : this.fs.writeFileSync(t, o) } } lodash_get(t, s, e) { const i = s.replace(/\[(\d+)\]/g, ".$1").split("."); let o = t; for (const t of i) if (o = Object(o)[t], void 0 === o) return e; return o } lodash_set(t, s, e) { return Object(t) !== t ? t : (Array.isArray(s) || (s = s.toString().match(/[^.[\]]+/g) || []), s.slice(0, -1).reduce((t, e, i) => Object(t[e]) === t[e] ? t[e] : t[e] = Math.abs(s[i + 1]) >> 0 == +s[i + 1] ? [] : {}, t)[s[s.length - 1]] = e, t) } getdata(t) { let s = this.getval(t); if (/^@/.test(t)) { const [, e, i] = /^@(.*?)\.(.*?)$/.exec(t), o = e ? this.getval(e) : ""; if (o) try { const t = JSON.parse(o); s = t ? this.lodash_get(t, i, "") : s } catch (t) { s = "" } } return s } setdata(t, s) { let e = !1; if (/^@/.test(s)) { const [, i, o] = /^@(.*?)\.(.*?)$/.exec(s), h = this.getval(i), a = i ? "null" === h ? null : h || "{}" : "{}"; try { const s = JSON.parse(a); this.lodash_set(s, o, t), e = this.setval(JSON.stringify(s), i), console.log(`${i}: ${JSON.stringify(s)}`) } catch { const s = {}; this.lodash_set(s, o, t), e = this.setval(JSON.stringify(s), i), console.log(`${i}: ${JSON.stringify(s)}`) } } else e = $.setval(t, s); return e } 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, s) { return this.isSurge() || this.isLoon() ? $persistentStore.write(t, s) : this.isQuanX() ? $prefs.setValueForKey(t, s) : this.isNode() ? (this.data = this.loaddata(), this.data[s] = t, this.writedata(), !0) : this.data && this.data[s] || 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, s = (() => { })) { t.headers && (delete t.headers["Content-Type"], delete t.headers["Content-Length"]), this.isSurge() || this.isLoon() ? $httpClient.get(t, (t, e, i) => { !t && e && (e.body = i, e.statusCode = e.status, s(t, e, i)) }) : this.isQuanX() ? $task.fetch(t).then(t => { const {statusCode: e, statusCode: i, headers: o, body: h} = t; s(null, {status: e, statusCode: i, headers: o, body: h}, h) }, t => s(t)) : this.isNode() && (this.initGotEnv(t), this.got(t).on("redirect", (t, s) => { try { const e = t.headers["set-cookie"].map(this.cktough.Cookie.parse).toString(); this.ckjar.setCookieSync(e, null), s.cookieJar = this.ckjar } catch (t) { this.logErr(t) } }).then(t => { const {statusCode: e, statusCode: i, headers: o, body: h} = t; s(null, {status: e, statusCode: i, headers: o, body: h}, h) }, t => s(t))) } post(t, s = (() => { })) { if (t.body && t.headers && !t.headers["Content-Type"] && (t.headers["Content-Type"] = "application/x-www-form-urlencoded"), delete t.headers["Content-Length"], this.isSurge() || this.isLoon()) $httpClient.post(t, (t, e, i) => { !t && e && (e.body = i, e.statusCode = e.status, s(t, e, i)) }); else if (this.isQuanX()) t.method = "POST", $task.fetch(t).then(t => { const {statusCode: e, statusCode: i, headers: o, body: h} = t; s(null, {status: e, statusCode: i, headers: o, body: h}, h) }, t => s(t)); else if (this.isNode()) { this.initGotEnv(t); const {url: e, ...i} = t; this.got.post(e, i).then(t => { const {statusCode: e, statusCode: i, headers: o, body: h} = t; s(null, {status: e, statusCode: i, headers: o, body: h}, h) }, t => s(t)) } } msg(s = t, e = "", i = "", o) { this.isSurge() || this.isLoon() ? $notification.post(s, e, i) : this.isQuanX() && $notify(s, e, i), this.logs.push("", "==============\ud83d\udce3\u7cfb\u7edf\u901a\u77e5\ud83d\udce3=============="), this.logs.push(s), e && this.logs.push(e), i && this.logs.push(i) } log(...t) { t.length > 0 ? this.logs = [...this.logs, ...t] : console.log(this.logs.join(this.logSeparator)) } logErr(t, s) { const e = !this.isSurge() && !this.isQuanX() && !this.isLoon(); e ? $.log("", `\u2757\ufe0f${this.name}, \u9519\u8bef!`, t.stack) : $.log("", `\u2757\ufe0f${this.name}, \u9519\u8bef!`, t.message) } wait(t) { return new Promise(s => setTimeout(s, t)) } done(t = null) { const s = (new Date).getTime(), e = (s - this.startTime) / 1e3; this.log("", `\ud83d\udd14${this.name}, \u7ed3\u675f! \ud83d\udd5b ${e} \u79d2`), this.log(), (this.isSurge() || this.isQuanX() || this.isLoon()) && $done(t) } }(t, s) }