mirror of
https://github.com/ZeroCatDev/Classworks.git
synced 2026-03-21 09:13:10 +00:00
2 lines
11 KiB
JavaScript
2 lines
11 KiB
JavaScript
import{a as X,g as Y}from"./vendor-utils-DDRLRfsI.js";import{n as u,ag as q,s as O}from"./index-C305lth9.js";import{i as R,t as I,g as j}from"./serverRotation-CMezt1Be.js";const K=(e,r)=>r.some(t=>e instanceof t);let F,V;function ee(){return F||(F=[IDBDatabase,IDBObjectStore,IDBIndex,IDBCursor,IDBTransaction])}function re(){return V||(V=[IDBCursor.prototype.advance,IDBCursor.prototype.continue,IDBCursor.prototype.continuePrimaryKey])}const P=new WeakMap,_=new WeakMap,S=new WeakMap;function te(e){const r=new Promise((t,s)=>{const o=()=>{e.removeEventListener("success",a),e.removeEventListener("error",n)},a=()=>{t(p(e.result)),o()},n=()=>{s(e.error),o()};e.addEventListener("success",a),e.addEventListener("error",n)});return S.set(r,e),r}function se(e){if(P.has(e))return;const r=new Promise((t,s)=>{const o=()=>{e.removeEventListener("complete",a),e.removeEventListener("error",n),e.removeEventListener("abort",n)},a=()=>{t(),o()},n=()=>{s(e.error||new DOMException("AbortError","AbortError")),o()};e.addEventListener("complete",a),e.addEventListener("error",n),e.addEventListener("abort",n)});P.set(e,r)}let L={get(e,r,t){if(e instanceof IDBTransaction){if(r==="done")return P.get(e);if(r==="store")return t.objectStoreNames[1]?void 0:t.objectStore(t.objectStoreNames[0])}return p(e[r])},set(e,r,t){return e[r]=t,!0},has(e,r){return e instanceof IDBTransaction&&(r==="done"||r==="store")?!0:r in e}};function J(e){L=e(L)}function ne(e){return re().includes(e)?function(...r){return e.apply(C(this),r),p(this.request)}:function(...r){return p(e.apply(C(this),r))}}function oe(e){return typeof e=="function"?ne(e):(e instanceof IDBTransaction&&se(e),K(e,ee())?new Proxy(e,L):e)}function p(e){if(e instanceof IDBRequest)return te(e);if(_.has(e))return _.get(e);const r=oe(e);return r!==e&&(_.set(e,r),S.set(r,e)),r}const C=e=>S.get(e);function ae(e,r,{blocked:t,upgrade:s,blocking:o,terminated:a}={}){const n=indexedDB.open(e,r),c=p(n);return s&&n.addEventListener("upgradeneeded",i=>{s(p(n.result),i.oldVersion,i.newVersion,p(n.transaction),i)}),t&&n.addEventListener("blocked",i=>t(i.oldVersion,i.newVersion,i)),c.then(i=>{a&&i.addEventListener("close",()=>a()),o&&i.addEventListener("versionchange",d=>o(d.oldVersion,d.newVersion,d))}).catch(()=>{}),c}const ie=["get","getKey","getAll","getAllKeys","count"],ce=["put","add","delete","clear"],B=new Map;function W(e,r){if(!(e instanceof IDBDatabase&&!(r in e)&&typeof r=="string"))return;if(B.get(r))return B.get(r);const t=r.replace(/FromIndex$/,""),s=r!==t,o=ce.includes(t);if(!(t in(s?IDBIndex:IDBObjectStore).prototype)||!(o||ie.includes(t)))return;const a=async function(n,...c){const i=this.transaction(n,o?"readwrite":"readonly");let d=i.store;return s&&(d=d.index(c.shift())),(await Promise.all([d[t](...c),o&&i.done]))[0]};return B.set(r,a),a}J(e=>({...e,get:(r,t,s)=>W(r,t)||e.get(r,t,s),has:(r,t)=>!!W(r,t)||e.has(r,t)}));const ue=["continue","continuePrimaryKey","advance"],H={},T=new WeakMap,G=new WeakMap,de={get(e,r){if(!ue.includes(r))return e[r];let t=H[r];return t||(t=H[r]=function(...s){T.set(this,G.get(this)[r](...s))}),t}};async function*le(...e){let r=this;if(r instanceof IDBCursor||(r=await r.openCursor(...e)),!r)return;r=r;const t=new Proxy(r,de);for(G.set(t,r),S.set(t,C(r));r;)yield t,r=await(T.get(t)||r.continue()),T.delete(t)}function z(e,r){return r===Symbol.asyncIterator&&K(e,[IDBIndex,IDBObjectStore,IDBCursor])||r==="iterate"&&K(e,[IDBIndex,IDBObjectStore])}J(e=>({...e,get(r,t,s){return z(r,t)?le:e.get(r,t,s)},has(r,t){return z(r,t)||e.has(r,t)}}));const fe="ClassworksDB",ve=2,x=async()=>ae(fe,ve,{upgrade(e){e.objectStoreNames.contains("kv")||e.createObjectStore("kv"),e.objectStoreNames.contains("system")||e.createObjectStore("system")}}),N={async loadData(e){try{const t=await(await x()).get("kv",e);return t?y(JSON.parse(t)):f("数据不存在","NOT_FOUND")}catch(r){return f("读取本地数据失败："+r)}},async saveData(e,r){try{return await(await x()).put("kv",JSON.stringify(r),e),y(!0)}catch(t){return f("保存本地数据失败："+t)}},async loadKeys(e={}){try{const o=await(await x()).transaction(["kv"],"readonly").objectStore("kv").getAllKeys(),{sortDir:a="asc",limit:n=100,skip:c=0}=e,i=o.sort((k,l)=>a==="desc"?l.localeCompare(k):k.localeCompare(l)),d=i.length,m=i.slice(c,c+n),w={keys:m,total_rows:d,current_page:{limit:n,skip:c,count:m.length},load_more:null};return y(w)}catch(r){return f("获取本地键名列表失败："+r.message)}}};function me(e,r){return"headers"in e&&typeof e.headers=="object"&&!Array.isArray(e.headers)?$(e.headers):"getHeaders"in e&&typeof e.getHeaders=="function"?$(e.getHeaders()):$(e)}function $(e,r){const t=h(e,"ratelimit");if(t)return De(t);let s;if(h(e,"ratelimit-remaining"))s="ratelimit-";else if(h(e,"x-ratelimit-remaining"))s="x-ratelimit-";else if(h(e,"x-rate-limit-remaining"))s="x-rate-limit-";else return;const o=g(h(e,`${s}limit`)),a=g(h(e,`${s}used`))||g(h(e,`${s}observed`)),n=g(h(e,`${s}remaining`));let c;const i=h(e,`${s}reset`);switch(void 0){case"date":{c=Z(i??"");break}case"unix":{c=M(i??"");break}case"seconds":{c=Q(i??"");break}case"milliseconds":{c=pe(i??"");break}default:if(i)c=ke(i);else{const m=h(e,"retry-after");m&&(c=M(m))}}return{limit:Number.isNaN(o)?a+n:o,used:Number.isNaN(a)?o-n:a,remaining:n,reset:c}}var ye=/limit\s*=\s*(\d+)/i,ge=/remaining\s*=\s*(\d+)/i,he=/reset\s*=\s*(\d+)/i;function De(e){var r,t,s;const o=g((r=ye.exec(e))==null?void 0:r[1]),a=g((t=ge.exec(e))==null?void 0:t[1]),n=g((s=he.exec(e))==null?void 0:s[1]),c=U(n);return{limit:o,used:o-a,remaining:a,reset:c}}function U(e){const r=new Date;return r.setSeconds(r.getSeconds()+e),r}function g(e){return typeof e=="number"?e:Number.parseInt(e??"",10)}function h(e,r){var t;if("get"in e&&typeof e.get=="function")return(t=e.get(r))!=null?t:void 0;if(r in e&&typeof e[r]=="string")return e[r]}function Z(e){return new Date(e)}function M(e){const r=g(e);return new Date(r*1e3)}function Q(e){const r=g(e);return U(r)}function pe(e){const r=g(e);return U(r/1e3)}var we=/[a-z]/i;function ke(e){if(we.test(e))return Z(e);const r=g(e);return r&&r>1e9?M(r):Q(r)}const v=X.create({timeout:1e4});v.interceptors.request.use(e=>{const r=u("server.provider");if(r==="kv-server"||r==="classworkscloud"){const t=u("server.kvToken");if(t)e.headers["x-app-token"]=t;else{const s=u("server.siteKey");s&&(e.headers["x-site-key"]=Y.encode(s))}}return e},e=>(console.log(e),Promise.reject(e)));v.interceptors.response.use(e=>e,e=>{if(e.response&&e.response.status===429)try{const r=me(e.response);r&&q.show(r.reset,e.config.url,e.config.method.toUpperCase())}catch(r){console.error("解析限速头信息失败:",r)}return Promise.reject(e)});const Ee=Object.freeze(Object.defineProperty({__proto__:null,default:v},Symbol.toStringTag,{value:"Module"})),D=()=>{const e={Accept:"application/json"},r=u("server.kvToken"),t=u("server.siteKey");return r?e["x-app-token"]=r:t&&(e["x-site-key"]=t),e},E={async loadNamespaceInfo(){var e,r;try{if(R())return await I(async o=>{const a=await v.get(`${o}/kv/_info`,{headers:D()});return y(a.data)});const t=u("server.domain"),s=await v.get(`${t}/kv/_info`,{headers:D()});return y(s.data)}catch(t){return console.error("获取命名空间信息失败:",t),f(((r=(e=t.response)==null?void 0:e.data)==null?void 0:r.message)||"获取命名空间信息失败","NAMESPACE_ERROR")}},async updateNamespaceInfo(e){var r,t;try{if(R())return await I(async a=>await v.put(`${a}/kv/_info`,e,{headers:D()}));const s=u("server.domain");return await v.put(`${s}/kv/_info`,e,{headers:D()})}catch(s){return f(((t=(r=s.response)==null?void 0:r.data)==null?void 0:t.message)||"更新命名空间信息失败","NAMESPACE_ERROR")}},async loadData(e){var r,t,s;try{if(R())return await I(async n=>{const c=await v.get(`${n}/kv/${e}`,{headers:D()});return y(c.data)});const o=u("server.domain"),a=await v.get(`${o}/kv/${e}`,{headers:D()});return y(a.data)}catch(o){return((r=o.response)==null?void 0:r.status)===404?f("数据不存在","NOT_FOUND"):(console.log(o),f(((s=(t=o.response)==null?void 0:t.data)==null?void 0:s.message)||"服务器连接失败","NETWORK_ERROR"))}},async saveData(e,r){var t,s;try{if(R())return await I(async a=>(await v.post(`${a}/kv/${e}`,r,{headers:D()}),y(!0)));const o=u("server.domain");return await v.post(`${o}/kv/${e}`,r,{headers:D()}),y(!0)}catch(o){return console.log(o),f(((s=(t=o.response)==null?void 0:t.data)==null?void 0:s.message)||"保存失败","SAVE_ERROR")}},async loadKeys(e={}){var r,t,s,o,a;try{const{sortBy:n="key",sortDir:c="asc",limit:i=100,skip:d=0}=e,m=new URLSearchParams({sortBy:n,sortDir:c,limit:i.toString(),skip:d.toString()});if(R())return await I(async l=>{const b=await v.get(`${l}/kv/_keys?${m}`,{headers:D()});return y(b.data)});const w=u("server.domain"),k=await v.get(`${w}/kv/_keys?${m}`,{headers:D()});return y(k.data)}catch(n){return((r=n.response)==null?void 0:r.status)===404?f("命名空间不存在","NOT_FOUND"):((t=n.response)==null?void 0:t.status)===403?f("无权限访问此命名空间","PERMISSION_DENIED"):((s=n.response)==null?void 0:s.status)===401?f("认证失败","UNAUTHORIZED"):(console.log(n),f(((a=(o=n.response)==null?void 0:o.data)==null?void 0:a.message)||"获取键名列表失败","NETWORK_ERROR"))}}},y=e=>e,f=(e,r="UNKNOWN_ERROR")=>({success:!1,error:{code:r,message:e}}),Ne={loadData:async e=>{const r=u("server.provider");return r==="kv-server"||r==="classworkscloud"?E.loadData(e):N.loadData(e)},saveData:async(e,r)=>{const t=u("server.provider");return t==="kv-server"||t==="classworkscloud"?E.saveData(e,r):N.saveData(e,r)},loadKeys:async(e={})=>{const r=u("server.provider");return r==="kv-server"||r==="classworkscloud"?E.loadKeys(e):N.loadKeys(e)},async getKeyCloudUrl(e,r={}){var o;const{migrateFromLocal:t=!0,autoConfigureCloud:s=!0}=r;try{const a=u("server.provider");let n;a==="classworkscloud"?n=j():n=u("server.domain");let c=u("server.siteKey");const i=u("device.uuid");let d=!1;if(!n||!i)if(s){const l={"server.domain":"https://kv-service.houlang.cloud","server.siteKey":""};n||(O("server.domain",l["server.domain"]),n=l["server.domain"],d=!0),c||(O("server.siteKey",l["server.siteKey"]),c=l["server.siteKey"]),O("server.provider","classworkscloud"),n=j()}else return f("云端配置无效，请检查服务器域名和设备UUID","CONFIG_ERROR");let m=!1;if(t)try{const l=await N.loadData(e);if(l&&l.success!==!1){const b=await E.loadData(e);if(b&&b.success===!1&&((o=b.error)==null?void 0:o.code)==="NOT_FOUND"){const A=await E.saveData(e,l);A&&A.success!==!1&&(m=!0,console.log(`已成功将键 ${e} 的数据从本地迁移到云端`))}}}catch(l){console.warn(`迁移键 ${e} 的数据时出错:`,l)}const w=u("server.kvToken");return{success:!0,url:`${n}/kv/${e}?token=${w}`,migrated:m,configured:d}}catch(a){return console.error("获取键云端地址时出错:",a),f(a.message||"获取键云端地址失败","CLOUD_URL_ERROR")}}};export{v as a,N as b,Ee as c,Ne as d,E as k,ae as o};
|