🎩 You're Invited:Meet the Socket team at Black Hat in Las Vegas, August 3-6.RSVP →
@autostorejs/devtools
Advanced tools
@autostorejs/devtools - npm Package Compare versions
+21
| MIT License | ||
| Copyright (c) 2024 fisher | ||
| Permission is hereby granted, free of charge, to any person obtaining a copy | ||
| of this software and associated documentation files (the "Software"), to deal | ||
| in the Software without restriction, including without limitation the rights | ||
| to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
| copies of the Software, and to permit persons to whom the Software is | ||
| furnished to do so, subject to the following conditions: | ||
| The above copyright notice and this permission notice shall be included in all | ||
| copies or substantial portions of the Software. | ||
| THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
| IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
| FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
| AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
| LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
| OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE | ||
| SOFTWARE. |
+24
-21
@@ -1,10 +0,13 @@ | ||
| $ tsup | ||
| > @autostorejs/devtools@2.0.6 build /home/runner/work/autostore/autostore/packages/devTools | ||
| > tsup | ||
| [34mCLI[39m Building entry: src/index.ts | ||
| [34mCLI[39m Using tsconfig: tsconfig.json | ||
| [34mCLI[39m tsup v8.5.0 | ||
| [34mCLI[39m Using tsup config: E:\Work\Code\sources\autostore\packages\devTools\tsup.config.ts | ||
| [34mCLI[39m Using tsup config: /home/runner/work/autostore/autostore/packages/devTools/tsup.config.ts | ||
| [34mCLI[39m Building entry: src/cycleDetectExtend.ts | ||
| [34mCLI[39m Using tsconfig: tsconfig.json | ||
| [34mCLI[39m tsup v8.5.0 | ||
| [34mCLI[39m Using tsup config: E:\Work\Code\sources\autostore\packages\devTools\tsup.config.ts | ||
| [34mCLI[39m Using tsup config: /home/runner/work/autostore/autostore/packages/devTools/tsup.config.ts | ||
| [34mCLI[39m Target: es2022 | ||
@@ -18,21 +21,21 @@ [34mCLI[39m Target: es2022 | ||
| [34mCJS[39m Build start | ||
| [32mESM[39m [1mdist\index.mjs [22m[32m3.55 KB[39m | ||
| [32mESM[39m [1mdist\index.mjs.map [22m[32m16.79 KB[39m | ||
| [32mESM[39m ⚡️ Build success in 930ms | ||
| [32mESM[39m [1mdist/cycleDetectExtend.mjs [22m[32m2.23 KB[39m | ||
| [32mESM[39m [1mdist/cycleDetectExtend.mjs.map [22m[32m12.06 KB[39m | ||
| [32mESM[39m ⚡️ Build success in 634ms | ||
| [32mCJS[39m [1mdist/cycleDetectExtend.js [22m[32m2.24 KB[39m | ||
| [32mCJS[39m [1mdist/cycleDetectExtend.js.map [22m[32m12.06 KB[39m | ||
| [32mCJS[39m ⚡️ Build success in 638ms | ||
| [32mESM[39m [1mdist/index.mjs [22m[32m3.55 KB[39m | ||
| [32mESM[39m [1mdist/index.mjs.map [22m[32m16.11 KB[39m | ||
| [32mESM[39m ⚡️ Build success in 647ms | ||
| [32mCJS[39m [1mdist/index.js [22m[32m3.57 KB[39m | ||
| [32mCJS[39m [1mdist/index.js.map [22m[32m16.11 KB[39m | ||
| [32mCJS[39m ⚡️ Build success in 646ms | ||
| [34mDTS[39m Build start | ||
| [34mDTS[39m Build start | ||
| [32mESM[39m [1mdist\cycleDetectExtend.mjs [22m[32m2.22 KB[39m | ||
| [32mESM[39m [1mdist\cycleDetectExtend.mjs.map [22m[32m12.54 KB[39m | ||
| [32mESM[39m ⚡️ Build success in 1002ms | ||
| [32mCJS[39m [1mdist\cycleDetectExtend.js [22m[32m2.24 KB[39m | ||
| [32mCJS[39m [1mdist\cycleDetectExtend.js.map [22m[32m12.54 KB[39m | ||
| [32mCJS[39m ⚡️ Build success in 1004ms | ||
| [32mCJS[39m [1mdist\index.js [22m[32m3.57 KB[39m | ||
| [32mCJS[39m [1mdist\index.js.map [22m[32m16.78 KB[39m | ||
| [32mCJS[39m ⚡️ Build success in 1014ms | ||
| [32mDTS[39m ⚡️ Build success in 5267ms | ||
| [32mDTS[39m [1mdist\cycleDetectExtend.d.mts [22m[32m1.20 KB[39m | ||
| [32mDTS[39m [1mdist\cycleDetectExtend.d.ts [22m[32m1.20 KB[39m | ||
| [32mDTS[39m ⚡️ Build success in 5388ms | ||
| [32mDTS[39m [1mdist\index.d.mts [22m[32m2.13 KB[39m | ||
| [32mDTS[39m [1mdist\index.d.ts [22m[32m2.13 KB[39m | ||
| [32mDTS[39m ⚡️ Build success in 2911ms | ||
| [32mDTS[39m [1mdist/cycleDetectExtend.d.mts [22m[32m1.20 KB[39m | ||
| [32mDTS[39m [1mdist/cycleDetectExtend.d.ts [22m[32m1.20 KB[39m | ||
| [32mDTS[39m ⚡️ Build success in 3112ms | ||
| [32mDTS[39m [1mdist/index.d.mts [22m[32m2.13 KB[39m | ||
| [32mDTS[39m [1mdist/index.d.ts [22m[32m2.13 KB[39m |
+6
-0
| # @autostorejs/devtools | ||
| ## 2.0.6 | ||
| ### Patch Changes | ||
| - 63e1fa9: 修复导出错误 | ||
| ## 2.0.5 | ||
@@ -4,0 +10,0 @@ |
@@ -1,2 +0,2 @@ | ||
| 'use strict';function g(i,e){return !i||!e||i.length!==e.length?false:i.every((n,s)=>n===e[s])}function y(i,e){return i.length>e.length?false:i.every((n,s)=>n===e[s])}function f(i,e){let n=i.reduce((r,a,l)=>(a===e&&r.push(l),r),[]),s=n.map((r,a)=>a<n.length-1?i.slice(r,n[a+1]):i.slice(r)),t=new Map;for(let r=0;r<s.length;r++){let a=s[r];if(!(a.length<2))for(let l=r+1;l<s.length;l++){let h=s[l];if(g(a,h)||y(a,h)){let p=a.join("->");t.has(p)||t.set(p,1);let d=t.get(p);t.set(p,d+1);}}}let o=0,c;return t.forEach((r,a)=>{r<3||a.length>o&&(c=a,o=r);}),[c,o]}var u=class{constructor(e,n){this.computedObject=e;this.path=e.path.join("."),this.steps.push(this.path),this.options=Object.assign({cycleCount:8,maxOpereates:200,stores:[]},n);}steps=[];running=false;_watcher;path;options;start(){this.running=true,this.steps.push(this.path),this._watcher=this.computedObject.store.watch(e=>{this.steps.length<500&&this.steps.push(e.path.join("."));},{operates:"read"});}analysisCycleSteps(){let[e,n]=f(this.steps,this.path),{onDetected:s,cycleCount:t}=this.options;if(!(n<t)&&(this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${e}`,"warn"),typeof s=="function")){let o=s(e,this.computedObject);if(o==="ignore")return;if(o==="disable")this.computedObject.enable=false;else throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${e}`)}}detect(){if(this.steps.length>this.options.maxOpereates){this._watcher.off();try{this.analysisCycleSteps();}finally{this.steps=[];}}}};function m(i){return function(n){let{onObserverCreated:s}=n.options;typeof s=="function"?n.log(`Store<${n.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,"warn"):(n.options.onObserverCreated=t=>{if(t.type==="computed"&&t.async){t._cycleDetector=new u(t,i);let o=t.run;t.run=async function(c){return c&&c.first===true?t._cycleDetector.start():t._cycleDetector.detect(),await o.apply(t,c)}.bind(t);}},n.log("cycleDetectExtend is already installed"));}}function E(i){globalThis.__AUTOSTORE_EXTENDS__||(globalThis.__AUTOSTORE_EXTENDS__=[]),globalThis.__AUTOSTORE_EXTENDS__.push(m(i));}exports.AsyncCycleDetector=u;exports.installCycleDetectExtend=E;//# sourceMappingURL=cycleDetectExtend.js.map | ||
| 'use strict';function g(i,e){return !i||!e||i.length!==e.length?false:i.every((n,s)=>n===e[s])}function y(i,e){return i.length>e.length?false:i.every((n,s)=>n===e[s])}function f(i,e){let n=i.reduce((r,a,l)=>(a===e&&r.push(l),r),[]),s=n.map((r,a)=>a<n.length-1?i.slice(r,n[a+1]):i.slice(r)),t=new Map;for(let r=0;r<s.length;r++){let a=s[r];if(!(a.length<2))for(let l=r+1;l<s.length;l++){let h=s[l];if(g(a,h)||y(a,h)){let p=a.join("->");t.has(p)||t.set(p,1);let d=t.get(p);t.set(p,d+1);}}}let o=0,c;return t.forEach((r,a)=>{r<3||a.length>o&&(c=a,o=r);}),[c,o]}var u=class{constructor(e,n){this.computedObject=e;this.path=e.path.join("."),this.steps.push(this.path),this.options=Object.assign({cycleCount:8,maxOpereates:200,stores:[]},n);}steps=[];running=false;_watcher;path;options;start(){this.running=true,this.steps.push(this.path),this._watcher=this.computedObject.store.watch(e=>{this.steps.length<500&&this.steps.push(e.path.join("."));},{operates:"read"});}analysisCycleSteps(){let[e,n]=f(this.steps,this.path),{onDetected:s,cycleCount:t}=this.options;if(!(n<t)&&(this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${e}`,"warn"),typeof s=="function")){let o=s(e,this.computedObject);if(o==="ignore")return;if(o==="disable")this.computedObject.enable=false;else throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${e}`)}}detect(){if(this.steps.length>this.options.maxOpereates){this._watcher.off();try{this.analysisCycleSteps();}finally{this.steps=[];}}}};function m(i){return function(n){let{onObserverCreated:s}=n.options;typeof s=="function"?n.log(`Store<${n.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,"warn"):(n.options.onObserverCreated=t=>{if(t.type==="computed"&&t.async){t._cycleDetector=new u(t,i);let o=t.run;t.run=(async function(c){return c&&c.first===true?t._cycleDetector.start():t._cycleDetector.detect(),await o.apply(t,c)}).bind(t);}},n.log("cycleDetectExtend is already installed"));}}function E(i){globalThis.__AUTOSTORE_EXTENDS__||(globalThis.__AUTOSTORE_EXTENDS__=[]),globalThis.__AUTOSTORE_EXTENDS__.push(m(i));}exports.AsyncCycleDetector=u;exports.installCycleDetectExtend=E;//# sourceMappingURL=cycleDetectExtend.js.map | ||
| //# sourceMappingURL=cycleDetectExtend.js.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/utils.ts","../src/cycleDetectExtend.ts"],"names":["isPathEq","a","b","item","index","pathStartsWith","basePath","destPath","p","i","analysisCyclePath","steps","curPath","indexs","prev","cur","groups","v","results","group","j","group2","gKey","n","count","paths","k","AsyncCycleDetector","computedObject","options","event","onDetected","cycleCount","result","createCycleDetectExtend","store","onObserverCreated","observerObject","oldRun","installCycleDetectExtend"],"mappings":"aAwCO,SAASA,CAAAA,CAASC,CAAuBC,CAAAA,CAAAA,CAA+B,CAG7E,OAFG,CAACD,CAAAA,EACD,CAACC,CAAAA,EACDD,CAAE,CAAA,MAAA,GAASC,CAAE,CAAA,MAAA,CAAe,MACxBD,CAAE,CAAA,KAAA,CAAM,CAACE,CAAAA,CAAKC,CAAQD,GAAAA,CAAAA,GAAOD,CAAEE,CAAAA,CAAK,CAAC,CAC9C,CAMO,SAASC,CAAeC,CAAAA,CAAAA,CAAkBC,EAAkB,CACjE,OAAGD,CAAS,CAAA,MAAA,CAAOC,CAAS,CAAA,MAAA,CAAe,KACpCD,CAAAA,CAAAA,CAAS,KAAM,CAAA,CAACE,CAAEC,CAAAA,CAAAA,GACdD,CAAID,GAAAA,CAAAA,CAASE,CAAC,CACxB,CACH,CAEO,SAASC,CAAAA,CAAkBC,CAAeC,CAAAA,CAAAA,CAA4C,CAE3F,IAAMC,CAASF,CAAAA,CAAAA,CAAM,MAAO,CAAA,CAACG,CAAKC,CAAAA,CAAAA,CAAIX,KAC/BW,CAAMH,GAAAA,CAAAA,EAASE,CAAK,CAAA,IAAA,CAAKV,CAAK,CAAA,CAC1BU,CACT,CAAA,CAAA,EAAc,CAAA,CAEVE,CAASH,CAAAA,CAAAA,CAAO,GAAI,CAAA,CAACI,EAAER,CACtBA,GAAAA,CAAAA,CAAEI,CAAO,CAAA,MAAA,CAAO,CACRF,CAAAA,CAAAA,CAAM,KAAMM,CAAAA,CAAAA,CAAEJ,CAAOJ,CAAAA,CAAAA,CAAE,CAAC,CAAC,CAEzBE,CAAAA,CAAAA,CAAM,MAAMM,CAAC,CAE3B,CAGKC,CAAAA,CAAAA,CAAU,IAAI,GAAA,CACpB,IAAQT,IAAAA,CAAAA,CAAE,CAAEA,CAAAA,CAAAA,CAAEO,CAAO,CAAA,MAAA,CAAOP,CAAI,EAAA,CAAA,CAC5B,IAAMU,CAAAA,CAAQH,CAAOP,CAAAA,CAAC,CACtB,CAAA,GAAG,EAAAU,CAAAA,CAAM,MAAO,CAAA,CAAA,CAAA,CAChB,IAAQC,IAAAA,CAAAA,CAAEX,CAAE,CAAA,CAAA,CAAEW,CAAEJ,CAAAA,CAAAA,CAAO,OAAOI,CAAI,EAAA,CAAA,CAC9B,IAAMC,CAAAA,CAASL,CAAOI,CAAAA,CAAC,CACvB,CAAA,GAAGpB,CAASmB,CAAAA,CAAAA,CAAME,CAAM,CAAA,EAAKhB,CAAec,CAAAA,CAAAA,CAAME,CAAM,CAAE,CAAA,CACtD,IAAMC,CAAAA,CAAOH,CAAM,CAAA,IAAA,CAAK,IAAI,CAAA,CACxBD,CAAQ,CAAA,GAAA,CAAII,CAAI,CAAA,EAChBJ,CAAQ,CAAA,GAAA,CAAII,EAAK,CAAC,CAAA,CAEtB,IAAMC,CAAAA,CAAIL,CAAQ,CAAA,GAAA,CAAII,CAAI,CAAA,CAC1BJ,CAAQ,CAAA,GAAA,CAAII,CAAKC,CAAAA,CAAAA,CAAE,CAAC,EACxB,CACJ,CACJ,CAEA,IAAIC,CAAQ,CAAA,CAAA,CACRC,CACJ,CAAA,OAAAP,CAAQ,CAAA,OAAA,CAAQ,CAACD,CAAAA,CAAES,CAAI,GAAA,CAChBT,CAAE,CAAA,CAAA,EACFS,EAAE,MAAOF,CAAAA,CAAAA,GACVC,CAAQC,CAAAA,CAAAA,CACRF,CAAQP,CAAAA,CAAAA,EAEd,CAAC,CAAA,CACM,CAACQ,CAAAA,CAAMD,CAAK,CAErB,CC5DO,IAAMG,CAAN,CAAA,KAAwB,CAM3B,WAAA,CAAmBC,CAAmBC,CAAAA,CAAAA,CAA4B,CAA/C,IAAA,CAAA,cAAA,CAAAD,CACf,CAAA,IAAA,CAAK,IAAOA,CAAAA,CAAAA,CAAe,IAAK,CAAA,IAAA,CAAK,GAAG,CAAA,CACxC,KAAK,KAAM,CAAA,IAAA,CAAK,IAAK,CAAA,IAAI,CACzB,CAAA,IAAA,CAAK,OAAU,CAAA,MAAA,CAAO,MAAO,CAAA,CACzB,UAAc,CAAA,CAAA,CACd,YAAc,CAAA,GAAA,CACd,MAAO,CAAA,EACX,CAAA,CAAEC,CAAO,EACb,CAbA,KAAA,CAAiB,EAAC,CAClB,OAAkB,CAAA,KAAA,CACV,QACR,CAAA,IAAA,CACA,OAaA,CAAA,KAAA,EAAO,CACH,IAAK,CAAA,OAAA,CAAU,IACf,CAAA,IAAA,CAAK,KAAM,CAAA,IAAA,CAAK,IAAK,CAAA,IAAI,CACzB,CAAA,IAAA,CAAK,QAAW,CAAA,IAAA,CAAK,cAAe,CAAA,KAAA,CAAM,MAAOC,CAAY,EAAA,CACtD,IAAK,CAAA,KAAA,CAAM,MAAO,CAAA,GAAA,EACjB,IAAK,CAAA,KAAA,CAAM,IAAKA,CAAAA,CAAAA,CAAM,IAAK,CAAA,IAAA,CAAK,GAAG,CAAC,EAE5C,CAAE,CAAA,CAAC,QAAS,CAAA,MAAM,CAAC,EACvB,CAkBQ,kBAAA,EAAoB,CACxB,GAAM,CAACL,CAAAA,CAAMD,CAAK,CAAA,CAAId,CAAkB,CAAA,IAAA,CAAK,KAAM,CAAA,IAAA,CAAK,IAAI,CAAA,CACtD,CAAE,UAAA,CAAAqB,CAAW,CAAA,UAAA,CAAAC,CAAW,CAAA,CAAI,IAAK,CAAA,OAAA,CACvC,GAAG,EAAAR,EAAMQ,CACT,CAAA,GAAA,IAAA,CAAK,cAAe,CAAA,KAAA,CAAM,GAAI,CAAA,CAAA,yBAAA,EAA4B,IAAK,CAAA,cAAA,CAAe,QAAS,EAAC,CAAMP,GAAAA,EAAAA,CAAK,CAAG,CAAA,CAAA,MAAM,EACzG,OAAOM,CAAAA,EAAe,UAAW,CAAA,CAAA,CAChC,IAAME,CAAAA,CAASF,CAAWN,CAAAA,CAAAA,CAAM,IAAK,CAAA,cAAc,CACnD,CAAA,GAAGQ,CAAS,GAAA,QAAA,CACR,OACE,GAAGA,CAAAA,GAAS,SACd,CAAA,IAAA,CAAK,cAAe,CAAA,MAAA,CAAS,KAE7B,CAAA,KAAA,MAAM,IAAI,KAAA,CAAM,CAAyB,sBAAA,EAAA,IAAA,CAAK,cAAe,CAAA,QAAA,EAAU,CAAA,GAAA,EAAMR,CAAK,CAAA,CAAE,CAE5F,CACJ,CACA,MAAA,EAAQ,CACJ,GAAG,IAAK,CAAA,KAAA,CAAM,MAAO,CAAA,IAAA,CAAK,OAAQ,CAAA,YAAA,CAAa,CAC3C,IAAK,CAAA,QAAA,CAAS,GAAI,EAAA,CAClB,GAAG,CACC,IAAK,CAAA,kBAAA,GACT,CAAA,OAAC,CACG,IAAA,CAAK,KAAM,CAAA,GACf,CACJ,CACJ,CACJ,EAGA,SAASS,CAAAA,CAAwBL,CAAkC,CAAA,CAC/D,OAAO,SAA2BM,CAAU,CAAA,CACxC,GAAM,CAAE,kBAAAC,CAAkB,CAAA,CAAID,CAAM,CAAA,OAAA,CACjC,OAAOC,CAAAA,EAAsB,UAE5BD,CAAAA,CAAAA,CAAM,GAAI,CAAA,CAAA,MAAA,EAASA,CAAM,CAAA,EAAE,CAA2E,wEAAA,CAAA,CAAA,MAAM,CAE5GA,EAAAA,CAAAA,CAAM,OAAQ,CAAA,iBAAA,CAAqBE,CAAqB,EAAA,CAEpD,GAAGA,CAAAA,CAAe,IAAO,GAAA,UAAA,EAAcA,CAAe,CAAA,KAAA,CAAM,CACxDA,CAAAA,CAAe,cAAiB,CAAA,IAAIV,EAAmBU,CAAeR,CAAAA,CAAO,CAC7E,CAAA,IAAMS,CAASD,CAAAA,CAAAA,CAAe,GAE9BA,CAAAA,CAAAA,CAAe,GAAO,CAAA,eAAeR,CAAY,CAAA,CAE7C,OAAGA,CAAAA,EAAWA,CAAQ,CAAA,KAAA,GAAQ,IAC1BQ,CAAAA,CAAAA,CAAe,cAAe,CAAA,KAAA,EAE9BA,CAAAA,CAAAA,CAAe,cAAe,CAAA,MAAA,EAE3B,CAAA,MAAMC,CAAO,CAAA,KAAA,CAAMD,CAAeR,CAAAA,CAAO,CACpD,CAAG,CAAA,IAAA,CAAKQ,CAAc,EAC1B,CACJ,CAAA,CACAF,CAAM,CAAA,GAAA,CAAI,wCAAwC,CAAA,EAE1D,CAEJ,CAGO,SAASI,CAAAA,CAAyBV,CAAkC,CAAA,CAEnE,UAAW,CAAA,qBAAA,GAEX,UAAW,CAAA,qBAAA,CAAsB,EAAC,CAAA,CAGtC,UAAW,CAAA,qBAAA,CAAsB,IAAKK,CAAAA,CAAAA,CAAwBL,CAAO,CAAC,EAE1E","file":"cycleDetectExtend.js","sourcesContent":["\r\nexport class WeakObjectMap<T extends object> {\r\n private map: Map<string, WeakRef<T>>;\r\n private finalizationRegistry: FinalizationRegistry<string>;\r\n \r\n constructor() {\r\n this.map = new Map();\r\n this.finalizationRegistry = new FinalizationRegistry((key) => {\r\n this.map.delete(key);\r\n });\r\n }\r\n \r\n set(key: string, value: T): void {\r\n const weakRef = new WeakRef(value);\r\n this.map.set(key, weakRef);\r\n this.finalizationRegistry.register(value, key);\r\n }\r\n \r\n get(key: string): T | undefined {\r\n const weakRef = this.map.get(key);\r\n return weakRef ? weakRef.deref() : undefined;\r\n }\r\n \r\n delete(key: string): boolean {\r\n return this.map.delete(key);\r\n }\r\n \r\n has(key: string): boolean {\r\n const weakRef = this.map.get(key);\r\n return weakRef ? weakRef.deref() !== undefined : false;\r\n }\r\n}\r\n/**\r\n * 判定两个值是否相等\r\n * \r\n * 如果两个值都是对象，则判断两个对象是否相等\r\n * 如果两个值都是数组，则判断两个数组的值是否相等\r\n * \r\n */\r\n\r\nexport function isPathEq(a:string[] | undefined,b:string[] | undefined):boolean{\r\n if(!a) return false\r\n if(!b) return false\r\n if(a.length!==b.length) return false\r\n return a.every((item,index)=>item===b[index])\r\n}\r\n/**\r\n * 判断一个路径destPath是否包含另一个路径basePath判断\r\n * @param basePath \r\n * @param destPath \r\n */\r\nexport function pathStartsWith(basePath:string[],destPath:string[]){\r\n if(basePath.length>destPath.length) return false\r\n return basePath.every((p,i)=>{\r\n return p===destPath[i]\r\n })\r\n}\r\n\r\nexport function analysisCyclePath(steps:string[],curPath:string):[string | undefined,number] {\r\n // 使用curPath将steps分割为多个数组\r\n const indexs = steps.reduce((prev,cur,index)=>{\r\n if(cur===curPath) prev.push(index) \r\n return prev\r\n },[] as number[])\r\n\r\n const groups = indexs.map((v,i)=>{\r\n if(i<indexs.length-1){\r\n return steps.slice(v,indexs[i+1])\r\n }else{\r\n return steps.slice(v)\r\n } \r\n })\r\n\r\n // 找到groups相同的分组\r\n const results = new Map<string,number>()\r\n for(let i=0;i<groups.length;i++){\r\n const group = groups[i]\r\n if(group.length<2) continue\r\n for(let j=i+1;j<groups.length;j++){\r\n const group2 = groups[j]\r\n if(isPathEq(group,group2) || pathStartsWith(group,group2)){\r\n const gKey = group.join('->')\r\n if(!results.has(gKey)){\r\n results.set(gKey,1)\r\n }\r\n const n = results.get(gKey)! \r\n results.set(gKey,n+1)\r\n }\r\n }\r\n }\r\n // 找到results里面路径最长的\r\n let count = 0\r\n let paths = undefined\r\n results.forEach((v,k)=>{\r\n if(v<3) return\r\n if(k.length>count){\r\n paths = k\r\n count = v \r\n }\r\n }) \r\n return [paths,count]\r\n\r\n}\r\n","/**\r\n * \r\n * import { installCycleDetectExtend } from \"@autostore/devtools\"\r\n * \r\n * installCycleDetectExtend({....})\r\n * \r\n * \r\n */\r\nimport { analysisCyclePath } from \"./utils\"\r\n\r\n\r\nexport type CycleDetectExtendOptions = { \r\n /**\r\n * 当检测到多少个循环时视为循环依赖 \r\n */\r\n cycleCount?:number\r\n /**\r\n * \r\n * 当检测时间操作数量达到此值时，停止检测\r\n * \r\n */\r\n maxOpereates?:number\r\n /**\r\n * 指定仅作用于指定的store\r\n * =[]代表所有store均生效\r\n */\r\n stores?:string[]\r\n /**\r\n * \r\n */\r\n onDetected?:(paths:string[],computedObject:any)=>'ignore'|'throw'|'disable' \r\n\r\n}\r\n\r\n/**\r\n * \r\n * - 在异步计算第一次执行时调用\r\n * cycleDetector.start()\r\n * \r\n * \r\n * \r\n */\r\nexport class AsyncCycleDetector{\r\n steps:string[] = []\r\n running:boolean = false \r\n private _watcher:any\r\n path:string\r\n options: Record<string,any>\r\n constructor(public computedObject:any,options?:Record<string,any>){\r\n this.path = computedObject.path.join('.')\r\n this.steps.push(this.path)\r\n this.options = Object.assign({\r\n cycleCount : 8,\r\n maxOpereates: 200,\r\n stores:[]\r\n },options)\r\n } \r\n /**\r\n * 本方法应该在异步函数第一次运行时调用\r\n */\r\n start(){\r\n this.running = true\r\n this.steps.push(this.path)\r\n this._watcher = this.computedObject.store.watch((event:any)=>{\r\n if(this.steps.length<500){\r\n this.steps.push(event.path.join('.'))\r\n }\r\n },{operates:'read'}) \r\n }\r\n /**\r\n * \r\n * 开始检测是否存在循环依赖\r\n * \r\n * \r\n * [\"a\",'d','c','b','a','d','c','b','a']\r\n * \r\n * \r\n * 编写一个函数，检测是否存在循环依赖\r\n * \r\n * 逻辑如下：\r\n * \r\n * 对this.steps里面是否存在连续的相同的路径，如果存在，则表示存在循环依赖\r\n * \r\n * \r\n * @returns \r\n */\r\n private analysisCycleSteps(){\r\n const [paths,count] = analysisCyclePath(this.steps,this.path)\r\n const { onDetected,cycleCount } = this.options\r\n if(count<cycleCount) return\r\n this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${paths}`,'warn')\r\n if(typeof(onDetected )==='function'){\r\n const result = onDetected(paths,this.computedObject)\r\n if(result==='ignore'){\r\n return\r\n }else if(result==='disable') {\r\n this.computedObject.enable = false\r\n }else{\r\n throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${paths}`)\r\n }\r\n } \r\n } \r\n detect(){\r\n if(this.steps.length>this.options.maxOpereates){\r\n this._watcher.off()\r\n try{\r\n this.analysisCycleSteps()\r\n }finally{ \r\n this.steps=[]\r\n }\r\n }\r\n }\r\n}\r\n\r\n\r\nfunction createCycleDetectExtend(options?:CycleDetectExtendOptions){\r\n return function cycleDetectExtend(store:any){\r\n const { onObserverCreated } = store.options\r\n if(typeof(onObserverCreated) ==='function'){ \r\n // 当store的onObserverCreated选项已经配置时，cycleDetectExtend不能生效\r\n store.log(`Store<${store.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,\"warn\")\r\n }else{\r\n store.options.onObserverCreated = (observerObject:any)=>{\r\n // 只对异步计算属性进行循环依赖检测\r\n if(observerObject.type==='computed' && observerObject.async){\r\n observerObject._cycleDetector = new AsyncCycleDetector(observerObject,options)\r\n const oldRun = observerObject.run\r\n // 封装原始的run方法\r\n observerObject.run = (async function(options:any){\r\n // 在第一次运行时启动循环依赖检测\r\n if(options && options.first===true){\r\n observerObject._cycleDetector.start()\r\n }else{\r\n observerObject._cycleDetector.detect() \r\n }\r\n return await oldRun.apply(observerObject,options)\r\n }).bind(observerObject)\r\n }\r\n }\r\n store.log(\"cycleDetectExtend is already installed\")\r\n }\r\n } \r\n\r\n}\r\n\r\n\r\nexport function installCycleDetectExtend(options?:CycleDetectExtendOptions){\r\n // @ts-ignore\r\n if(!globalThis.__AUTOSTORE_EXTENDS__){\r\n // @ts-ignore\r\n globalThis.__AUTOSTORE_EXTENDS__=[]\r\n }\r\n // @ts-ignore\r\n globalThis.__AUTOSTORE_EXTENDS__.push(createCycleDetectExtend(options))\r\n \r\n}\r\n "]} | ||
| {"version":3,"sources":["../src/utils.ts","../src/cycleDetectExtend.ts"],"names":["isPathEq","a","b","item","index","pathStartsWith","basePath","destPath","p","i","analysisCyclePath","steps","curPath","indexs","prev","cur","groups","v","results","group","j","group2","gKey","n","count","paths","k","AsyncCycleDetector","computedObject","options","event","onDetected","cycleCount","result","createCycleDetectExtend","store","onObserverCreated","observerObject","oldRun","installCycleDetectExtend"],"mappings":"aAwCO,SAASA,CAAAA,CAASC,CAAAA,CAAuBC,CAAAA,CAA+B,CAG7E,OAFG,CAACD,CAAAA,EACD,CAACC,CAAAA,EACDD,CAAAA,CAAE,MAAA,GAASC,CAAAA,CAAE,MAAA,CAAe,MACxBD,CAAAA,CAAE,KAAA,CAAM,CAACE,CAAAA,CAAKC,CAAAA,GAAQD,CAAAA,GAAOD,CAAAA,CAAEE,CAAK,CAAC,CAC9C,CAMO,SAASC,CAAAA,CAAeC,CAAAA,CAAkBC,EAAkB,CACjE,OAAGD,CAAAA,CAAS,MAAA,CAAOC,CAAAA,CAAS,MAAA,CAAe,KAAA,CACpCD,CAAAA,CAAS,KAAA,CAAM,CAACE,CAAAA,CAAEC,CAAAA,GACdD,CAAAA,GAAID,CAAAA,CAASE,CAAC,CACxB,CACH,CAEO,SAASC,CAAAA,CAAkBC,CAAAA,CAAeC,CAAAA,CAA4C,CAE3F,IAAMC,CAAAA,CAASF,CAAAA,CAAM,MAAA,CAAO,CAACG,CAAAA,CAAKC,CAAAA,CAAIX,KAC/BW,CAAAA,GAAMH,CAAAA,EAASE,CAAAA,CAAK,IAAA,CAAKV,CAAK,CAAA,CAC1BU,CAAAA,CAAAA,CACT,EAAc,CAAA,CAEVE,CAAAA,CAASH,CAAAA,CAAO,GAAA,CAAI,CAACI,EAAER,CAAAA,GACtBA,CAAAA,CAAEI,CAAAA,CAAO,MAAA,CAAO,CAAA,CACRF,CAAAA,CAAM,KAAA,CAAMM,CAAAA,CAAEJ,CAAAA,CAAOJ,CAAAA,CAAE,CAAC,CAAC,CAAA,CAEzBE,CAAAA,CAAM,MAAMM,CAAC,CAE3B,CAAA,CAGKC,CAAAA,CAAU,IAAI,GAAA,CACpB,IAAA,IAAQT,CAAAA,CAAE,CAAA,CAAEA,CAAAA,CAAEO,CAAAA,CAAO,MAAA,CAAOP,CAAAA,EAAAA,CAAI,CAC5B,IAAMU,CAAAA,CAAQH,CAAAA,CAAOP,CAAC,CAAA,CACtB,GAAG,EAAAU,CAAAA,CAAM,MAAA,CAAO,CAAA,CAAA,CAChB,IAAA,IAAQC,CAAAA,CAAEX,CAAAA,CAAE,CAAA,CAAEW,CAAAA,CAAEJ,CAAAA,CAAO,OAAOI,CAAAA,EAAAA,CAAI,CAC9B,IAAMC,CAAAA,CAASL,CAAAA,CAAOI,CAAC,CAAA,CACvB,GAAGpB,CAAAA,CAASmB,CAAAA,CAAME,CAAM,CAAA,EAAKhB,CAAAA,CAAec,CAAAA,CAAME,CAAM,CAAA,CAAE,CACtD,IAAMC,CAAAA,CAAOH,CAAAA,CAAM,IAAA,CAAK,IAAI,CAAA,CACxBD,CAAAA,CAAQ,GAAA,CAAII,CAAI,CAAA,EAChBJ,CAAAA,CAAQ,GAAA,CAAII,EAAK,CAAC,CAAA,CAEtB,IAAMC,CAAAA,CAAIL,CAAAA,CAAQ,GAAA,CAAII,CAAI,CAAA,CAC1BJ,CAAAA,CAAQ,GAAA,CAAII,CAAAA,CAAKC,CAAAA,CAAE,CAAC,EACxB,CACJ,CACJ,CAEA,IAAIC,CAAAA,CAAQ,CAAA,CACRC,CAAAA,CACJ,OAAAP,CAAAA,CAAQ,OAAA,CAAQ,CAACD,CAAAA,CAAES,CAAAA,GAAI,CAChBT,CAAAA,CAAE,CAAA,EACFS,EAAE,MAAA,CAAOF,CAAAA,GACVC,CAAAA,CAAQC,CAAAA,CACRF,CAAAA,CAAQP,CAAAA,EAEd,CAAC,CAAA,CACM,CAACQ,CAAAA,CAAMD,CAAK,CAErB,CC5DO,IAAMG,CAAAA,CAAN,KAAwB,CAM3B,WAAA,CAAmBC,CAAAA,CAAmBC,CAAAA,CAA4B,CAA/C,IAAA,CAAA,cAAA,CAAAD,CAAAA,CACf,IAAA,CAAK,IAAA,CAAOA,CAAAA,CAAe,IAAA,CAAK,IAAA,CAAK,GAAG,CAAA,CACxC,KAAK,KAAA,CAAM,IAAA,CAAK,IAAA,CAAK,IAAI,CAAA,CACzB,IAAA,CAAK,OAAA,CAAU,MAAA,CAAO,MAAA,CAAO,CACzB,UAAA,CAAc,CAAA,CACd,YAAA,CAAc,GAAA,CACd,MAAA,CAAO,EACX,CAAA,CAAEC,CAAO,EACb,CAbA,KAAA,CAAiB,EAAC,CAClB,OAAA,CAAkB,KAAA,CACV,QAAA,CACR,IAAA,CACA,OAAA,CAaA,KAAA,EAAO,CACH,IAAA,CAAK,OAAA,CAAU,IAAA,CACf,IAAA,CAAK,KAAA,CAAM,IAAA,CAAK,IAAA,CAAK,IAAI,CAAA,CACzB,IAAA,CAAK,QAAA,CAAW,IAAA,CAAK,cAAA,CAAe,KAAA,CAAM,MAAOC,CAAAA,EAAY,CACtD,IAAA,CAAK,KAAA,CAAM,MAAA,CAAO,GAAA,EACjB,IAAA,CAAK,KAAA,CAAM,IAAA,CAAKA,CAAAA,CAAM,IAAA,CAAK,IAAA,CAAK,GAAG,CAAC,EAE5C,CAAA,CAAE,CAAC,QAAA,CAAS,MAAM,CAAC,EACvB,CAkBQ,kBAAA,EAAoB,CACxB,GAAM,CAACL,CAAAA,CAAMD,CAAK,CAAA,CAAId,CAAAA,CAAkB,IAAA,CAAK,KAAA,CAAM,IAAA,CAAK,IAAI,CAAA,CACtD,CAAE,UAAA,CAAAqB,CAAAA,CAAW,UAAA,CAAAC,CAAW,CAAA,CAAI,IAAA,CAAK,OAAA,CACvC,GAAG,EAAAR,EAAMQ,CAAAA,CAAAA,GACT,IAAA,CAAK,cAAA,CAAe,KAAA,CAAM,GAAA,CAAI,CAAA,yBAAA,EAA4B,IAAA,CAAK,cAAA,CAAe,QAAA,EAAU,CAAA,GAAA,EAAMP,CAAK,CAAA,CAAA,CAAG,MAAM,EACzG,OAAOM,CAAAA,EAAe,UAAA,CAAA,CAAW,CAChC,IAAME,CAAAA,CAASF,CAAAA,CAAWN,CAAAA,CAAM,IAAA,CAAK,cAAc,CAAA,CACnD,GAAGQ,CAAAA,GAAS,QAAA,CACR,OACE,GAAGA,CAAAA,GAAS,SAAA,CACd,IAAA,CAAK,cAAA,CAAe,MAAA,CAAS,KAAA,CAAA,KAE7B,MAAM,IAAI,KAAA,CAAM,CAAA,sBAAA,EAAyB,IAAA,CAAK,cAAA,CAAe,QAAA,EAAU,CAAA,GAAA,EAAMR,CAAK,CAAA,CAAE,CAE5F,CACJ,CACA,MAAA,EAAQ,CACJ,GAAG,IAAA,CAAK,KAAA,CAAM,MAAA,CAAO,IAAA,CAAK,OAAA,CAAQ,YAAA,CAAa,CAC3C,IAAA,CAAK,QAAA,CAAS,GAAA,EAAI,CAClB,GAAG,CACC,IAAA,CAAK,kBAAA,GACT,CAAA,OAAC,CACG,IAAA,CAAK,KAAA,CAAM,GACf,CACJ,CACJ,CACJ,EAGA,SAASS,CAAAA,CAAwBL,CAAAA,CAAkC,CAC/D,OAAO,SAA2BM,CAAAA,CAAU,CACxC,GAAM,CAAE,kBAAAC,CAAkB,CAAA,CAAID,CAAAA,CAAM,OAAA,CACjC,OAAOC,CAAAA,EAAsB,UAAA,CAE5BD,CAAAA,CAAM,GAAA,CAAI,CAAA,MAAA,EAASA,CAAAA,CAAM,EAAE,CAAA,wEAAA,CAAA,CAA2E,MAAM,CAAA,EAE5GA,CAAAA,CAAM,OAAA,CAAQ,iBAAA,CAAqBE,CAAAA,EAAqB,CAEpD,GAAGA,CAAAA,CAAe,IAAA,GAAO,UAAA,EAAcA,CAAAA,CAAe,KAAA,CAAM,CACxDA,CAAAA,CAAe,cAAA,CAAiB,IAAIV,EAAmBU,CAAAA,CAAeR,CAAO,CAAA,CAC7E,IAAMS,CAAAA,CAASD,CAAAA,CAAe,GAAA,CAE9BA,CAAAA,CAAe,GAAA,CAAA,CAAO,eAAeR,CAAAA,CAAY,CAE7C,OAAGA,CAAAA,EAAWA,CAAAA,CAAQ,KAAA,GAAQ,IAAA,CAC1BQ,CAAAA,CAAe,cAAA,CAAe,KAAA,EAAM,CAEpCA,CAAAA,CAAe,cAAA,CAAe,MAAA,EAAO,CAElC,MAAMC,CAAAA,CAAO,KAAA,CAAMD,CAAAA,CAAeR,CAAO,CACpD,CAAA,EAAG,IAAA,CAAKQ,CAAc,EAC1B,CACJ,CAAA,CACAF,CAAAA,CAAM,GAAA,CAAI,wCAAwC,CAAA,EAE1D,CAEJ,CAGO,SAASI,CAAAA,CAAyBV,CAAAA,CAAkC,CAEnE,UAAA,CAAW,qBAAA,GAEX,UAAA,CAAW,qBAAA,CAAsB,EAAC,CAAA,CAGtC,UAAA,CAAW,qBAAA,CAAsB,IAAA,CAAKK,CAAAA,CAAwBL,CAAO,CAAC,EAE1E","file":"cycleDetectExtend.js","sourcesContent":["\nexport class WeakObjectMap<T extends object> {\n private map: Map<string, WeakRef<T>>;\n private finalizationRegistry: FinalizationRegistry<string>;\n \n constructor() {\n this.map = new Map();\n this.finalizationRegistry = new FinalizationRegistry((key) => {\n this.map.delete(key);\n });\n }\n \n set(key: string, value: T): void {\n const weakRef = new WeakRef(value);\n this.map.set(key, weakRef);\n this.finalizationRegistry.register(value, key);\n }\n \n get(key: string): T | undefined {\n const weakRef = this.map.get(key);\n return weakRef ? weakRef.deref() : undefined;\n }\n \n delete(key: string): boolean {\n return this.map.delete(key);\n }\n \n has(key: string): boolean {\n const weakRef = this.map.get(key);\n return weakRef ? weakRef.deref() !== undefined : false;\n }\n}\n/**\n * 判定两个值是否相等\n * \n * 如果两个值都是对象，则判断两个对象是否相等\n * 如果两个值都是数组，则判断两个数组的值是否相等\n * \n */\n\nexport function isPathEq(a:string[] | undefined,b:string[] | undefined):boolean{\n if(!a) return false\n if(!b) return false\n if(a.length!==b.length) return false\n return a.every((item,index)=>item===b[index])\n}\n/**\n * 判断一个路径destPath是否包含另一个路径basePath判断\n * @param basePath \n * @param destPath \n */\nexport function pathStartsWith(basePath:string[],destPath:string[]){\n if(basePath.length>destPath.length) return false\n return basePath.every((p,i)=>{\n return p===destPath[i]\n })\n}\n\nexport function analysisCyclePath(steps:string[],curPath:string):[string | undefined,number] {\n // 使用curPath将steps分割为多个数组\n const indexs = steps.reduce((prev,cur,index)=>{\n if(cur===curPath) prev.push(index) \n return prev\n },[] as number[])\n\n const groups = indexs.map((v,i)=>{\n if(i<indexs.length-1){\n return steps.slice(v,indexs[i+1])\n }else{\n return steps.slice(v)\n } \n })\n\n // 找到groups相同的分组\n const results = new Map<string,number>()\n for(let i=0;i<groups.length;i++){\n const group = groups[i]\n if(group.length<2) continue\n for(let j=i+1;j<groups.length;j++){\n const group2 = groups[j]\n if(isPathEq(group,group2) || pathStartsWith(group,group2)){\n const gKey = group.join('->')\n if(!results.has(gKey)){\n results.set(gKey,1)\n }\n const n = results.get(gKey)! \n results.set(gKey,n+1)\n }\n }\n }\n // 找到results里面路径最长的\n let count = 0\n let paths = undefined\n results.forEach((v,k)=>{\n if(v<3) return\n if(k.length>count){\n paths = k\n count = v \n }\n }) \n return [paths,count]\n\n}\n","/**\n * \n * import { installCycleDetectExtend } from \"@autostore/devtools\"\n * \n * installCycleDetectExtend({....})\n * \n * \n */\nimport { analysisCyclePath } from \"./utils\"\n\n\nexport type CycleDetectExtendOptions = { \n /**\n * 当检测到多少个循环时视为循环依赖 \n */\n cycleCount?:number\n /**\n * \n * 当检测时间操作数量达到此值时，停止检测\n * \n */\n maxOpereates?:number\n /**\n * 指定仅作用于指定的store\n * =[]代表所有store均生效\n */\n stores?:string[]\n /**\n * \n */\n onDetected?:(paths:string[],computedObject:any)=>'ignore'|'throw'|'disable' \n\n}\n\n/**\n * \n * - 在异步计算第一次执行时调用\n * cycleDetector.start()\n * \n * \n * \n */\nexport class AsyncCycleDetector{\n steps:string[] = []\n running:boolean = false \n private _watcher:any\n path:string\n options: Record<string,any>\n constructor(public computedObject:any,options?:Record<string,any>){\n this.path = computedObject.path.join('.')\n this.steps.push(this.path)\n this.options = Object.assign({\n cycleCount : 8,\n maxOpereates: 200,\n stores:[]\n },options)\n } \n /**\n * 本方法应该在异步函数第一次运行时调用\n */\n start(){\n this.running = true\n this.steps.push(this.path)\n this._watcher = this.computedObject.store.watch((event:any)=>{\n if(this.steps.length<500){\n this.steps.push(event.path.join('.'))\n }\n },{operates:'read'}) \n }\n /**\n * \n * 开始检测是否存在循环依赖\n * \n * \n * [\"a\",'d','c','b','a','d','c','b','a']\n * \n * \n * 编写一个函数，检测是否存在循环依赖\n * \n * 逻辑如下：\n * \n * 对this.steps里面是否存在连续的相同的路径，如果存在，则表示存在循环依赖\n * \n * \n * @returns \n */\n private analysisCycleSteps(){\n const [paths,count] = analysisCyclePath(this.steps,this.path)\n const { onDetected,cycleCount } = this.options\n if(count<cycleCount) return\n this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${paths}`,'warn')\n if(typeof(onDetected )==='function'){\n const result = onDetected(paths,this.computedObject)\n if(result==='ignore'){\n return\n }else if(result==='disable') {\n this.computedObject.enable = false\n }else{\n throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${paths}`)\n }\n } \n } \n detect(){\n if(this.steps.length>this.options.maxOpereates){\n this._watcher.off()\n try{\n this.analysisCycleSteps()\n }finally{ \n this.steps=[]\n }\n }\n }\n}\n\n\nfunction createCycleDetectExtend(options?:CycleDetectExtendOptions){\n return function cycleDetectExtend(store:any){\n const { onObserverCreated } = store.options\n if(typeof(onObserverCreated) ==='function'){ \n // 当store的onObserverCreated选项已经配置时，cycleDetectExtend不能生效\n store.log(`Store<${store.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,\"warn\")\n }else{\n store.options.onObserverCreated = (observerObject:any)=>{\n // 只对异步计算属性进行循环依赖检测\n if(observerObject.type==='computed' && observerObject.async){\n observerObject._cycleDetector = new AsyncCycleDetector(observerObject,options)\n const oldRun = observerObject.run\n // 封装原始的run方法\n observerObject.run = (async function(options:any){\n // 在第一次运行时启动循环依赖检测\n if(options && options.first===true){\n observerObject._cycleDetector.start()\n }else{\n observerObject._cycleDetector.detect() \n }\n return await oldRun.apply(observerObject,options)\n }).bind(observerObject)\n }\n }\n store.log(\"cycleDetectExtend is already installed\")\n }\n } \n\n}\n\n\nexport function installCycleDetectExtend(options?:CycleDetectExtendOptions){\n // @ts-ignore\n if(!globalThis.__AUTOSTORE_EXTENDS__){\n // @ts-ignore\n globalThis.__AUTOSTORE_EXTENDS__=[]\n }\n // @ts-ignore\n globalThis.__AUTOSTORE_EXTENDS__.push(createCycleDetectExtend(options))\n \n}\n "]} |
@@ -1,2 +0,2 @@ | ||
| function g(i,e){return !i||!e||i.length!==e.length?false:i.every((n,s)=>n===e[s])}function y(i,e){return i.length>e.length?false:i.every((n,s)=>n===e[s])}function f(i,e){let n=i.reduce((r,a,l)=>(a===e&&r.push(l),r),[]),s=n.map((r,a)=>a<n.length-1?i.slice(r,n[a+1]):i.slice(r)),t=new Map;for(let r=0;r<s.length;r++){let a=s[r];if(!(a.length<2))for(let l=r+1;l<s.length;l++){let h=s[l];if(g(a,h)||y(a,h)){let p=a.join("->");t.has(p)||t.set(p,1);let d=t.get(p);t.set(p,d+1);}}}let o=0,c;return t.forEach((r,a)=>{r<3||a.length>o&&(c=a,o=r);}),[c,o]}var u=class{constructor(e,n){this.computedObject=e;this.path=e.path.join("."),this.steps.push(this.path),this.options=Object.assign({cycleCount:8,maxOpereates:200,stores:[]},n);}steps=[];running=false;_watcher;path;options;start(){this.running=true,this.steps.push(this.path),this._watcher=this.computedObject.store.watch(e=>{this.steps.length<500&&this.steps.push(e.path.join("."));},{operates:"read"});}analysisCycleSteps(){let[e,n]=f(this.steps,this.path),{onDetected:s,cycleCount:t}=this.options;if(!(n<t)&&(this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${e}`,"warn"),typeof s=="function")){let o=s(e,this.computedObject);if(o==="ignore")return;if(o==="disable")this.computedObject.enable=false;else throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${e}`)}}detect(){if(this.steps.length>this.options.maxOpereates){this._watcher.off();try{this.analysisCycleSteps();}finally{this.steps=[];}}}};function m(i){return function(n){let{onObserverCreated:s}=n.options;typeof s=="function"?n.log(`Store<${n.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,"warn"):(n.options.onObserverCreated=t=>{if(t.type==="computed"&&t.async){t._cycleDetector=new u(t,i);let o=t.run;t.run=async function(c){return c&&c.first===true?t._cycleDetector.start():t._cycleDetector.detect(),await o.apply(t,c)}.bind(t);}},n.log("cycleDetectExtend is already installed"));}}function E(i){globalThis.__AUTOSTORE_EXTENDS__||(globalThis.__AUTOSTORE_EXTENDS__=[]),globalThis.__AUTOSTORE_EXTENDS__.push(m(i));}export{u as AsyncCycleDetector,E as installCycleDetectExtend};//# sourceMappingURL=cycleDetectExtend.mjs.map | ||
| function g(i,e){return !i||!e||i.length!==e.length?false:i.every((n,s)=>n===e[s])}function y(i,e){return i.length>e.length?false:i.every((n,s)=>n===e[s])}function f(i,e){let n=i.reduce((r,a,l)=>(a===e&&r.push(l),r),[]),s=n.map((r,a)=>a<n.length-1?i.slice(r,n[a+1]):i.slice(r)),t=new Map;for(let r=0;r<s.length;r++){let a=s[r];if(!(a.length<2))for(let l=r+1;l<s.length;l++){let h=s[l];if(g(a,h)||y(a,h)){let p=a.join("->");t.has(p)||t.set(p,1);let d=t.get(p);t.set(p,d+1);}}}let o=0,c;return t.forEach((r,a)=>{r<3||a.length>o&&(c=a,o=r);}),[c,o]}var u=class{constructor(e,n){this.computedObject=e;this.path=e.path.join("."),this.steps.push(this.path),this.options=Object.assign({cycleCount:8,maxOpereates:200,stores:[]},n);}steps=[];running=false;_watcher;path;options;start(){this.running=true,this.steps.push(this.path),this._watcher=this.computedObject.store.watch(e=>{this.steps.length<500&&this.steps.push(e.path.join("."));},{operates:"read"});}analysisCycleSteps(){let[e,n]=f(this.steps,this.path),{onDetected:s,cycleCount:t}=this.options;if(!(n<t)&&(this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${e}`,"warn"),typeof s=="function")){let o=s(e,this.computedObject);if(o==="ignore")return;if(o==="disable")this.computedObject.enable=false;else throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${e}`)}}detect(){if(this.steps.length>this.options.maxOpereates){this._watcher.off();try{this.analysisCycleSteps();}finally{this.steps=[];}}}};function m(i){return function(n){let{onObserverCreated:s}=n.options;typeof s=="function"?n.log(`Store<${n.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,"warn"):(n.options.onObserverCreated=t=>{if(t.type==="computed"&&t.async){t._cycleDetector=new u(t,i);let o=t.run;t.run=(async function(c){return c&&c.first===true?t._cycleDetector.start():t._cycleDetector.detect(),await o.apply(t,c)}).bind(t);}},n.log("cycleDetectExtend is already installed"));}}function E(i){globalThis.__AUTOSTORE_EXTENDS__||(globalThis.__AUTOSTORE_EXTENDS__=[]),globalThis.__AUTOSTORE_EXTENDS__.push(m(i));}export{u as AsyncCycleDetector,E as installCycleDetectExtend};//# sourceMappingURL=cycleDetectExtend.mjs.map | ||
| //# sourceMappingURL=cycleDetectExtend.mjs.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/utils.ts","../src/cycleDetectExtend.ts"],"names":["isPathEq","a","b","item","index","pathStartsWith","basePath","destPath","p","i","analysisCyclePath","steps","curPath","indexs","prev","cur","groups","v","results","group","j","group2","gKey","n","count","paths","k","AsyncCycleDetector","computedObject","options","event","onDetected","cycleCount","result","createCycleDetectExtend","store","onObserverCreated","observerObject","oldRun","installCycleDetectExtend"],"mappings":"AAwCO,SAASA,CAAAA,CAASC,CAAuBC,CAAAA,CAAAA,CAA+B,CAG7E,OAFG,CAACD,CAAAA,EACD,CAACC,CAAAA,EACDD,CAAE,CAAA,MAAA,GAASC,CAAE,CAAA,MAAA,CAAe,MACxBD,CAAE,CAAA,KAAA,CAAM,CAACE,CAAAA,CAAKC,CAAQD,GAAAA,CAAAA,GAAOD,CAAEE,CAAAA,CAAK,CAAC,CAC9C,CAMO,SAASC,CAAeC,CAAAA,CAAAA,CAAkBC,EAAkB,CACjE,OAAGD,CAAS,CAAA,MAAA,CAAOC,CAAS,CAAA,MAAA,CAAe,KACpCD,CAAAA,CAAAA,CAAS,KAAM,CAAA,CAACE,CAAEC,CAAAA,CAAAA,GACdD,CAAID,GAAAA,CAAAA,CAASE,CAAC,CACxB,CACH,CAEO,SAASC,CAAAA,CAAkBC,CAAeC,CAAAA,CAAAA,CAA4C,CAE3F,IAAMC,CAASF,CAAAA,CAAAA,CAAM,MAAO,CAAA,CAACG,CAAKC,CAAAA,CAAAA,CAAIX,KAC/BW,CAAMH,GAAAA,CAAAA,EAASE,CAAK,CAAA,IAAA,CAAKV,CAAK,CAAA,CAC1BU,CACT,CAAA,CAAA,EAAc,CAAA,CAEVE,CAASH,CAAAA,CAAAA,CAAO,GAAI,CAAA,CAACI,EAAER,CACtBA,GAAAA,CAAAA,CAAEI,CAAO,CAAA,MAAA,CAAO,CACRF,CAAAA,CAAAA,CAAM,KAAMM,CAAAA,CAAAA,CAAEJ,CAAOJ,CAAAA,CAAAA,CAAE,CAAC,CAAC,CAEzBE,CAAAA,CAAAA,CAAM,MAAMM,CAAC,CAE3B,CAGKC,CAAAA,CAAAA,CAAU,IAAI,GAAA,CACpB,IAAQT,IAAAA,CAAAA,CAAE,CAAEA,CAAAA,CAAAA,CAAEO,CAAO,CAAA,MAAA,CAAOP,CAAI,EAAA,CAAA,CAC5B,IAAMU,CAAAA,CAAQH,CAAOP,CAAAA,CAAC,CACtB,CAAA,GAAG,EAAAU,CAAAA,CAAM,MAAO,CAAA,CAAA,CAAA,CAChB,IAAQC,IAAAA,CAAAA,CAAEX,CAAE,CAAA,CAAA,CAAEW,CAAEJ,CAAAA,CAAAA,CAAO,OAAOI,CAAI,EAAA,CAAA,CAC9B,IAAMC,CAAAA,CAASL,CAAOI,CAAAA,CAAC,CACvB,CAAA,GAAGpB,CAASmB,CAAAA,CAAAA,CAAME,CAAM,CAAA,EAAKhB,CAAec,CAAAA,CAAAA,CAAME,CAAM,CAAE,CAAA,CACtD,IAAMC,CAAAA,CAAOH,CAAM,CAAA,IAAA,CAAK,IAAI,CAAA,CACxBD,CAAQ,CAAA,GAAA,CAAII,CAAI,CAAA,EAChBJ,CAAQ,CAAA,GAAA,CAAII,EAAK,CAAC,CAAA,CAEtB,IAAMC,CAAAA,CAAIL,CAAQ,CAAA,GAAA,CAAII,CAAI,CAAA,CAC1BJ,CAAQ,CAAA,GAAA,CAAII,CAAKC,CAAAA,CAAAA,CAAE,CAAC,EACxB,CACJ,CACJ,CAEA,IAAIC,CAAQ,CAAA,CAAA,CACRC,CACJ,CAAA,OAAAP,CAAQ,CAAA,OAAA,CAAQ,CAACD,CAAAA,CAAES,CAAI,GAAA,CAChBT,CAAE,CAAA,CAAA,EACFS,EAAE,MAAOF,CAAAA,CAAAA,GACVC,CAAQC,CAAAA,CAAAA,CACRF,CAAQP,CAAAA,CAAAA,EAEd,CAAC,CAAA,CACM,CAACQ,CAAAA,CAAMD,CAAK,CAErB,CC5DO,IAAMG,CAAN,CAAA,KAAwB,CAM3B,WAAA,CAAmBC,CAAmBC,CAAAA,CAAAA,CAA4B,CAA/C,IAAA,CAAA,cAAA,CAAAD,CACf,CAAA,IAAA,CAAK,IAAOA,CAAAA,CAAAA,CAAe,IAAK,CAAA,IAAA,CAAK,GAAG,CAAA,CACxC,KAAK,KAAM,CAAA,IAAA,CAAK,IAAK,CAAA,IAAI,CACzB,CAAA,IAAA,CAAK,OAAU,CAAA,MAAA,CAAO,MAAO,CAAA,CACzB,UAAc,CAAA,CAAA,CACd,YAAc,CAAA,GAAA,CACd,MAAO,CAAA,EACX,CAAA,CAAEC,CAAO,EACb,CAbA,KAAA,CAAiB,EAAC,CAClB,OAAkB,CAAA,KAAA,CACV,QACR,CAAA,IAAA,CACA,OAaA,CAAA,KAAA,EAAO,CACH,IAAK,CAAA,OAAA,CAAU,IACf,CAAA,IAAA,CAAK,KAAM,CAAA,IAAA,CAAK,IAAK,CAAA,IAAI,CACzB,CAAA,IAAA,CAAK,QAAW,CAAA,IAAA,CAAK,cAAe,CAAA,KAAA,CAAM,MAAOC,CAAY,EAAA,CACtD,IAAK,CAAA,KAAA,CAAM,MAAO,CAAA,GAAA,EACjB,IAAK,CAAA,KAAA,CAAM,IAAKA,CAAAA,CAAAA,CAAM,IAAK,CAAA,IAAA,CAAK,GAAG,CAAC,EAE5C,CAAE,CAAA,CAAC,QAAS,CAAA,MAAM,CAAC,EACvB,CAkBQ,kBAAA,EAAoB,CACxB,GAAM,CAACL,CAAAA,CAAMD,CAAK,CAAA,CAAId,CAAkB,CAAA,IAAA,CAAK,KAAM,CAAA,IAAA,CAAK,IAAI,CAAA,CACtD,CAAE,UAAA,CAAAqB,CAAW,CAAA,UAAA,CAAAC,CAAW,CAAA,CAAI,IAAK,CAAA,OAAA,CACvC,GAAG,EAAAR,EAAMQ,CACT,CAAA,GAAA,IAAA,CAAK,cAAe,CAAA,KAAA,CAAM,GAAI,CAAA,CAAA,yBAAA,EAA4B,IAAK,CAAA,cAAA,CAAe,QAAS,EAAC,CAAMP,GAAAA,EAAAA,CAAK,CAAG,CAAA,CAAA,MAAM,EACzG,OAAOM,CAAAA,EAAe,UAAW,CAAA,CAAA,CAChC,IAAME,CAAAA,CAASF,CAAWN,CAAAA,CAAAA,CAAM,IAAK,CAAA,cAAc,CACnD,CAAA,GAAGQ,CAAS,GAAA,QAAA,CACR,OACE,GAAGA,CAAAA,GAAS,SACd,CAAA,IAAA,CAAK,cAAe,CAAA,MAAA,CAAS,KAE7B,CAAA,KAAA,MAAM,IAAI,KAAA,CAAM,CAAyB,sBAAA,EAAA,IAAA,CAAK,cAAe,CAAA,QAAA,EAAU,CAAA,GAAA,EAAMR,CAAK,CAAA,CAAE,CAE5F,CACJ,CACA,MAAA,EAAQ,CACJ,GAAG,IAAK,CAAA,KAAA,CAAM,MAAO,CAAA,IAAA,CAAK,OAAQ,CAAA,YAAA,CAAa,CAC3C,IAAK,CAAA,QAAA,CAAS,GAAI,EAAA,CAClB,GAAG,CACC,IAAK,CAAA,kBAAA,GACT,CAAA,OAAC,CACG,IAAA,CAAK,KAAM,CAAA,GACf,CACJ,CACJ,CACJ,EAGA,SAASS,CAAAA,CAAwBL,CAAkC,CAAA,CAC/D,OAAO,SAA2BM,CAAU,CAAA,CACxC,GAAM,CAAE,kBAAAC,CAAkB,CAAA,CAAID,CAAM,CAAA,OAAA,CACjC,OAAOC,CAAAA,EAAsB,UAE5BD,CAAAA,CAAAA,CAAM,GAAI,CAAA,CAAA,MAAA,EAASA,CAAM,CAAA,EAAE,CAA2E,wEAAA,CAAA,CAAA,MAAM,CAE5GA,EAAAA,CAAAA,CAAM,OAAQ,CAAA,iBAAA,CAAqBE,CAAqB,EAAA,CAEpD,GAAGA,CAAAA,CAAe,IAAO,GAAA,UAAA,EAAcA,CAAe,CAAA,KAAA,CAAM,CACxDA,CAAAA,CAAe,cAAiB,CAAA,IAAIV,EAAmBU,CAAeR,CAAAA,CAAO,CAC7E,CAAA,IAAMS,CAASD,CAAAA,CAAAA,CAAe,GAE9BA,CAAAA,CAAAA,CAAe,GAAO,CAAA,eAAeR,CAAY,CAAA,CAE7C,OAAGA,CAAAA,EAAWA,CAAQ,CAAA,KAAA,GAAQ,IAC1BQ,CAAAA,CAAAA,CAAe,cAAe,CAAA,KAAA,EAE9BA,CAAAA,CAAAA,CAAe,cAAe,CAAA,MAAA,EAE3B,CAAA,MAAMC,CAAO,CAAA,KAAA,CAAMD,CAAeR,CAAAA,CAAO,CACpD,CAAG,CAAA,IAAA,CAAKQ,CAAc,EAC1B,CACJ,CAAA,CACAF,CAAM,CAAA,GAAA,CAAI,wCAAwC,CAAA,EAE1D,CAEJ,CAGO,SAASI,CAAAA,CAAyBV,CAAkC,CAAA,CAEnE,UAAW,CAAA,qBAAA,GAEX,UAAW,CAAA,qBAAA,CAAsB,EAAC,CAAA,CAGtC,UAAW,CAAA,qBAAA,CAAsB,IAAKK,CAAAA,CAAAA,CAAwBL,CAAO,CAAC,EAE1E","file":"cycleDetectExtend.mjs","sourcesContent":["\r\nexport class WeakObjectMap<T extends object> {\r\n private map: Map<string, WeakRef<T>>;\r\n private finalizationRegistry: FinalizationRegistry<string>;\r\n \r\n constructor() {\r\n this.map = new Map();\r\n this.finalizationRegistry = new FinalizationRegistry((key) => {\r\n this.map.delete(key);\r\n });\r\n }\r\n \r\n set(key: string, value: T): void {\r\n const weakRef = new WeakRef(value);\r\n this.map.set(key, weakRef);\r\n this.finalizationRegistry.register(value, key);\r\n }\r\n \r\n get(key: string): T | undefined {\r\n const weakRef = this.map.get(key);\r\n return weakRef ? weakRef.deref() : undefined;\r\n }\r\n \r\n delete(key: string): boolean {\r\n return this.map.delete(key);\r\n }\r\n \r\n has(key: string): boolean {\r\n const weakRef = this.map.get(key);\r\n return weakRef ? weakRef.deref() !== undefined : false;\r\n }\r\n}\r\n/**\r\n * 判定两个值是否相等\r\n * \r\n * 如果两个值都是对象，则判断两个对象是否相等\r\n * 如果两个值都是数组，则判断两个数组的值是否相等\r\n * \r\n */\r\n\r\nexport function isPathEq(a:string[] | undefined,b:string[] | undefined):boolean{\r\n if(!a) return false\r\n if(!b) return false\r\n if(a.length!==b.length) return false\r\n return a.every((item,index)=>item===b[index])\r\n}\r\n/**\r\n * 判断一个路径destPath是否包含另一个路径basePath判断\r\n * @param basePath \r\n * @param destPath \r\n */\r\nexport function pathStartsWith(basePath:string[],destPath:string[]){\r\n if(basePath.length>destPath.length) return false\r\n return basePath.every((p,i)=>{\r\n return p===destPath[i]\r\n })\r\n}\r\n\r\nexport function analysisCyclePath(steps:string[],curPath:string):[string | undefined,number] {\r\n // 使用curPath将steps分割为多个数组\r\n const indexs = steps.reduce((prev,cur,index)=>{\r\n if(cur===curPath) prev.push(index) \r\n return prev\r\n },[] as number[])\r\n\r\n const groups = indexs.map((v,i)=>{\r\n if(i<indexs.length-1){\r\n return steps.slice(v,indexs[i+1])\r\n }else{\r\n return steps.slice(v)\r\n } \r\n })\r\n\r\n // 找到groups相同的分组\r\n const results = new Map<string,number>()\r\n for(let i=0;i<groups.length;i++){\r\n const group = groups[i]\r\n if(group.length<2) continue\r\n for(let j=i+1;j<groups.length;j++){\r\n const group2 = groups[j]\r\n if(isPathEq(group,group2) || pathStartsWith(group,group2)){\r\n const gKey = group.join('->')\r\n if(!results.has(gKey)){\r\n results.set(gKey,1)\r\n }\r\n const n = results.get(gKey)! \r\n results.set(gKey,n+1)\r\n }\r\n }\r\n }\r\n // 找到results里面路径最长的\r\n let count = 0\r\n let paths = undefined\r\n results.forEach((v,k)=>{\r\n if(v<3) return\r\n if(k.length>count){\r\n paths = k\r\n count = v \r\n }\r\n }) \r\n return [paths,count]\r\n\r\n}\r\n","/**\r\n * \r\n * import { installCycleDetectExtend } from \"@autostore/devtools\"\r\n * \r\n * installCycleDetectExtend({....})\r\n * \r\n * \r\n */\r\nimport { analysisCyclePath } from \"./utils\"\r\n\r\n\r\nexport type CycleDetectExtendOptions = { \r\n /**\r\n * 当检测到多少个循环时视为循环依赖 \r\n */\r\n cycleCount?:number\r\n /**\r\n * \r\n * 当检测时间操作数量达到此值时，停止检测\r\n * \r\n */\r\n maxOpereates?:number\r\n /**\r\n * 指定仅作用于指定的store\r\n * =[]代表所有store均生效\r\n */\r\n stores?:string[]\r\n /**\r\n * \r\n */\r\n onDetected?:(paths:string[],computedObject:any)=>'ignore'|'throw'|'disable' \r\n\r\n}\r\n\r\n/**\r\n * \r\n * - 在异步计算第一次执行时调用\r\n * cycleDetector.start()\r\n * \r\n * \r\n * \r\n */\r\nexport class AsyncCycleDetector{\r\n steps:string[] = []\r\n running:boolean = false \r\n private _watcher:any\r\n path:string\r\n options: Record<string,any>\r\n constructor(public computedObject:any,options?:Record<string,any>){\r\n this.path = computedObject.path.join('.')\r\n this.steps.push(this.path)\r\n this.options = Object.assign({\r\n cycleCount : 8,\r\n maxOpereates: 200,\r\n stores:[]\r\n },options)\r\n } \r\n /**\r\n * 本方法应该在异步函数第一次运行时调用\r\n */\r\n start(){\r\n this.running = true\r\n this.steps.push(this.path)\r\n this._watcher = this.computedObject.store.watch((event:any)=>{\r\n if(this.steps.length<500){\r\n this.steps.push(event.path.join('.'))\r\n }\r\n },{operates:'read'}) \r\n }\r\n /**\r\n * \r\n * 开始检测是否存在循环依赖\r\n * \r\n * \r\n * [\"a\",'d','c','b','a','d','c','b','a']\r\n * \r\n * \r\n * 编写一个函数，检测是否存在循环依赖\r\n * \r\n * 逻辑如下：\r\n * \r\n * 对this.steps里面是否存在连续的相同的路径，如果存在，则表示存在循环依赖\r\n * \r\n * \r\n * @returns \r\n */\r\n private analysisCycleSteps(){\r\n const [paths,count] = analysisCyclePath(this.steps,this.path)\r\n const { onDetected,cycleCount } = this.options\r\n if(count<cycleCount) return\r\n this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${paths}`,'warn')\r\n if(typeof(onDetected )==='function'){\r\n const result = onDetected(paths,this.computedObject)\r\n if(result==='ignore'){\r\n return\r\n }else if(result==='disable') {\r\n this.computedObject.enable = false\r\n }else{\r\n throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${paths}`)\r\n }\r\n } \r\n } \r\n detect(){\r\n if(this.steps.length>this.options.maxOpereates){\r\n this._watcher.off()\r\n try{\r\n this.analysisCycleSteps()\r\n }finally{ \r\n this.steps=[]\r\n }\r\n }\r\n }\r\n}\r\n\r\n\r\nfunction createCycleDetectExtend(options?:CycleDetectExtendOptions){\r\n return function cycleDetectExtend(store:any){\r\n const { onObserverCreated } = store.options\r\n if(typeof(onObserverCreated) ==='function'){ \r\n // 当store的onObserverCreated选项已经配置时，cycleDetectExtend不能生效\r\n store.log(`Store<${store.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,\"warn\")\r\n }else{\r\n store.options.onObserverCreated = (observerObject:any)=>{\r\n // 只对异步计算属性进行循环依赖检测\r\n if(observerObject.type==='computed' && observerObject.async){\r\n observerObject._cycleDetector = new AsyncCycleDetector(observerObject,options)\r\n const oldRun = observerObject.run\r\n // 封装原始的run方法\r\n observerObject.run = (async function(options:any){\r\n // 在第一次运行时启动循环依赖检测\r\n if(options && options.first===true){\r\n observerObject._cycleDetector.start()\r\n }else{\r\n observerObject._cycleDetector.detect() \r\n }\r\n return await oldRun.apply(observerObject,options)\r\n }).bind(observerObject)\r\n }\r\n }\r\n store.log(\"cycleDetectExtend is already installed\")\r\n }\r\n } \r\n\r\n}\r\n\r\n\r\nexport function installCycleDetectExtend(options?:CycleDetectExtendOptions){\r\n // @ts-ignore\r\n if(!globalThis.__AUTOSTORE_EXTENDS__){\r\n // @ts-ignore\r\n globalThis.__AUTOSTORE_EXTENDS__=[]\r\n }\r\n // @ts-ignore\r\n globalThis.__AUTOSTORE_EXTENDS__.push(createCycleDetectExtend(options))\r\n \r\n}\r\n "]} | ||
| {"version":3,"sources":["../src/utils.ts","../src/cycleDetectExtend.ts"],"names":["isPathEq","a","b","item","index","pathStartsWith","basePath","destPath","p","i","analysisCyclePath","steps","curPath","indexs","prev","cur","groups","v","results","group","j","group2","gKey","n","count","paths","k","AsyncCycleDetector","computedObject","options","event","onDetected","cycleCount","result","createCycleDetectExtend","store","onObserverCreated","observerObject","oldRun","installCycleDetectExtend"],"mappings":"AAwCO,SAASA,CAAAA,CAASC,CAAAA,CAAuBC,CAAAA,CAA+B,CAG7E,OAFG,CAACD,CAAAA,EACD,CAACC,CAAAA,EACDD,CAAAA,CAAE,MAAA,GAASC,CAAAA,CAAE,MAAA,CAAe,MACxBD,CAAAA,CAAE,KAAA,CAAM,CAACE,CAAAA,CAAKC,CAAAA,GAAQD,CAAAA,GAAOD,CAAAA,CAAEE,CAAK,CAAC,CAC9C,CAMO,SAASC,CAAAA,CAAeC,CAAAA,CAAkBC,EAAkB,CACjE,OAAGD,CAAAA,CAAS,MAAA,CAAOC,CAAAA,CAAS,MAAA,CAAe,KAAA,CACpCD,CAAAA,CAAS,KAAA,CAAM,CAACE,CAAAA,CAAEC,CAAAA,GACdD,CAAAA,GAAID,CAAAA,CAASE,CAAC,CACxB,CACH,CAEO,SAASC,CAAAA,CAAkBC,CAAAA,CAAeC,CAAAA,CAA4C,CAE3F,IAAMC,CAAAA,CAASF,CAAAA,CAAM,MAAA,CAAO,CAACG,CAAAA,CAAKC,CAAAA,CAAIX,KAC/BW,CAAAA,GAAMH,CAAAA,EAASE,CAAAA,CAAK,IAAA,CAAKV,CAAK,CAAA,CAC1BU,CAAAA,CAAAA,CACT,EAAc,CAAA,CAEVE,CAAAA,CAASH,CAAAA,CAAO,GAAA,CAAI,CAACI,EAAER,CAAAA,GACtBA,CAAAA,CAAEI,CAAAA,CAAO,MAAA,CAAO,CAAA,CACRF,CAAAA,CAAM,KAAA,CAAMM,CAAAA,CAAEJ,CAAAA,CAAOJ,CAAAA,CAAE,CAAC,CAAC,CAAA,CAEzBE,CAAAA,CAAM,MAAMM,CAAC,CAE3B,CAAA,CAGKC,CAAAA,CAAU,IAAI,GAAA,CACpB,IAAA,IAAQT,CAAAA,CAAE,CAAA,CAAEA,CAAAA,CAAEO,CAAAA,CAAO,MAAA,CAAOP,CAAAA,EAAAA,CAAI,CAC5B,IAAMU,CAAAA,CAAQH,CAAAA,CAAOP,CAAC,CAAA,CACtB,GAAG,EAAAU,CAAAA,CAAM,MAAA,CAAO,CAAA,CAAA,CAChB,IAAA,IAAQC,CAAAA,CAAEX,CAAAA,CAAE,CAAA,CAAEW,CAAAA,CAAEJ,CAAAA,CAAO,OAAOI,CAAAA,EAAAA,CAAI,CAC9B,IAAMC,CAAAA,CAASL,CAAAA,CAAOI,CAAC,CAAA,CACvB,GAAGpB,CAAAA,CAASmB,CAAAA,CAAME,CAAM,CAAA,EAAKhB,CAAAA,CAAec,CAAAA,CAAME,CAAM,CAAA,CAAE,CACtD,IAAMC,CAAAA,CAAOH,CAAAA,CAAM,IAAA,CAAK,IAAI,CAAA,CACxBD,CAAAA,CAAQ,GAAA,CAAII,CAAI,CAAA,EAChBJ,CAAAA,CAAQ,GAAA,CAAII,EAAK,CAAC,CAAA,CAEtB,IAAMC,CAAAA,CAAIL,CAAAA,CAAQ,GAAA,CAAII,CAAI,CAAA,CAC1BJ,CAAAA,CAAQ,GAAA,CAAII,CAAAA,CAAKC,CAAAA,CAAE,CAAC,EACxB,CACJ,CACJ,CAEA,IAAIC,CAAAA,CAAQ,CAAA,CACRC,CAAAA,CACJ,OAAAP,CAAAA,CAAQ,OAAA,CAAQ,CAACD,CAAAA,CAAES,CAAAA,GAAI,CAChBT,CAAAA,CAAE,CAAA,EACFS,EAAE,MAAA,CAAOF,CAAAA,GACVC,CAAAA,CAAQC,CAAAA,CACRF,CAAAA,CAAQP,CAAAA,EAEd,CAAC,CAAA,CACM,CAACQ,CAAAA,CAAMD,CAAK,CAErB,CC5DO,IAAMG,CAAAA,CAAN,KAAwB,CAM3B,WAAA,CAAmBC,CAAAA,CAAmBC,CAAAA,CAA4B,CAA/C,IAAA,CAAA,cAAA,CAAAD,CAAAA,CACf,IAAA,CAAK,IAAA,CAAOA,CAAAA,CAAe,IAAA,CAAK,IAAA,CAAK,GAAG,CAAA,CACxC,KAAK,KAAA,CAAM,IAAA,CAAK,IAAA,CAAK,IAAI,CAAA,CACzB,IAAA,CAAK,OAAA,CAAU,MAAA,CAAO,MAAA,CAAO,CACzB,UAAA,CAAc,CAAA,CACd,YAAA,CAAc,GAAA,CACd,MAAA,CAAO,EACX,CAAA,CAAEC,CAAO,EACb,CAbA,KAAA,CAAiB,EAAC,CAClB,OAAA,CAAkB,KAAA,CACV,QAAA,CACR,IAAA,CACA,OAAA,CAaA,KAAA,EAAO,CACH,IAAA,CAAK,OAAA,CAAU,IAAA,CACf,IAAA,CAAK,KAAA,CAAM,IAAA,CAAK,IAAA,CAAK,IAAI,CAAA,CACzB,IAAA,CAAK,QAAA,CAAW,IAAA,CAAK,cAAA,CAAe,KAAA,CAAM,MAAOC,CAAAA,EAAY,CACtD,IAAA,CAAK,KAAA,CAAM,MAAA,CAAO,GAAA,EACjB,IAAA,CAAK,KAAA,CAAM,IAAA,CAAKA,CAAAA,CAAM,IAAA,CAAK,IAAA,CAAK,GAAG,CAAC,EAE5C,CAAA,CAAE,CAAC,QAAA,CAAS,MAAM,CAAC,EACvB,CAkBQ,kBAAA,EAAoB,CACxB,GAAM,CAACL,CAAAA,CAAMD,CAAK,CAAA,CAAId,CAAAA,CAAkB,IAAA,CAAK,KAAA,CAAM,IAAA,CAAK,IAAI,CAAA,CACtD,CAAE,UAAA,CAAAqB,CAAAA,CAAW,UAAA,CAAAC,CAAW,CAAA,CAAI,IAAA,CAAK,OAAA,CACvC,GAAG,EAAAR,EAAMQ,CAAAA,CAAAA,GACT,IAAA,CAAK,cAAA,CAAe,KAAA,CAAM,GAAA,CAAI,CAAA,yBAAA,EAA4B,IAAA,CAAK,cAAA,CAAe,QAAA,EAAU,CAAA,GAAA,EAAMP,CAAK,CAAA,CAAA,CAAG,MAAM,EACzG,OAAOM,CAAAA,EAAe,UAAA,CAAA,CAAW,CAChC,IAAME,CAAAA,CAASF,CAAAA,CAAWN,CAAAA,CAAM,IAAA,CAAK,cAAc,CAAA,CACnD,GAAGQ,CAAAA,GAAS,QAAA,CACR,OACE,GAAGA,CAAAA,GAAS,SAAA,CACd,IAAA,CAAK,cAAA,CAAe,MAAA,CAAS,KAAA,CAAA,KAE7B,MAAM,IAAI,KAAA,CAAM,CAAA,sBAAA,EAAyB,IAAA,CAAK,cAAA,CAAe,QAAA,EAAU,CAAA,GAAA,EAAMR,CAAK,CAAA,CAAE,CAE5F,CACJ,CACA,MAAA,EAAQ,CACJ,GAAG,IAAA,CAAK,KAAA,CAAM,MAAA,CAAO,IAAA,CAAK,OAAA,CAAQ,YAAA,CAAa,CAC3C,IAAA,CAAK,QAAA,CAAS,GAAA,EAAI,CAClB,GAAG,CACC,IAAA,CAAK,kBAAA,GACT,CAAA,OAAC,CACG,IAAA,CAAK,KAAA,CAAM,GACf,CACJ,CACJ,CACJ,EAGA,SAASS,CAAAA,CAAwBL,CAAAA,CAAkC,CAC/D,OAAO,SAA2BM,CAAAA,CAAU,CACxC,GAAM,CAAE,kBAAAC,CAAkB,CAAA,CAAID,CAAAA,CAAM,OAAA,CACjC,OAAOC,CAAAA,EAAsB,UAAA,CAE5BD,CAAAA,CAAM,GAAA,CAAI,CAAA,MAAA,EAASA,CAAAA,CAAM,EAAE,CAAA,wEAAA,CAAA,CAA2E,MAAM,CAAA,EAE5GA,CAAAA,CAAM,OAAA,CAAQ,iBAAA,CAAqBE,CAAAA,EAAqB,CAEpD,GAAGA,CAAAA,CAAe,IAAA,GAAO,UAAA,EAAcA,CAAAA,CAAe,KAAA,CAAM,CACxDA,CAAAA,CAAe,cAAA,CAAiB,IAAIV,EAAmBU,CAAAA,CAAeR,CAAO,CAAA,CAC7E,IAAMS,CAAAA,CAASD,CAAAA,CAAe,GAAA,CAE9BA,CAAAA,CAAe,GAAA,CAAA,CAAO,eAAeR,CAAAA,CAAY,CAE7C,OAAGA,CAAAA,EAAWA,CAAAA,CAAQ,KAAA,GAAQ,IAAA,CAC1BQ,CAAAA,CAAe,cAAA,CAAe,KAAA,EAAM,CAEpCA,CAAAA,CAAe,cAAA,CAAe,MAAA,EAAO,CAElC,MAAMC,CAAAA,CAAO,KAAA,CAAMD,CAAAA,CAAeR,CAAO,CACpD,CAAA,EAAG,IAAA,CAAKQ,CAAc,EAC1B,CACJ,CAAA,CACAF,CAAAA,CAAM,GAAA,CAAI,wCAAwC,CAAA,EAE1D,CAEJ,CAGO,SAASI,CAAAA,CAAyBV,CAAAA,CAAkC,CAEnE,UAAA,CAAW,qBAAA,GAEX,UAAA,CAAW,qBAAA,CAAsB,EAAC,CAAA,CAGtC,UAAA,CAAW,qBAAA,CAAsB,IAAA,CAAKK,CAAAA,CAAwBL,CAAO,CAAC,EAE1E","file":"cycleDetectExtend.mjs","sourcesContent":["\nexport class WeakObjectMap<T extends object> {\n private map: Map<string, WeakRef<T>>;\n private finalizationRegistry: FinalizationRegistry<string>;\n \n constructor() {\n this.map = new Map();\n this.finalizationRegistry = new FinalizationRegistry((key) => {\n this.map.delete(key);\n });\n }\n \n set(key: string, value: T): void {\n const weakRef = new WeakRef(value);\n this.map.set(key, weakRef);\n this.finalizationRegistry.register(value, key);\n }\n \n get(key: string): T | undefined {\n const weakRef = this.map.get(key);\n return weakRef ? weakRef.deref() : undefined;\n }\n \n delete(key: string): boolean {\n return this.map.delete(key);\n }\n \n has(key: string): boolean {\n const weakRef = this.map.get(key);\n return weakRef ? weakRef.deref() !== undefined : false;\n }\n}\n/**\n * 判定两个值是否相等\n * \n * 如果两个值都是对象，则判断两个对象是否相等\n * 如果两个值都是数组，则判断两个数组的值是否相等\n * \n */\n\nexport function isPathEq(a:string[] | undefined,b:string[] | undefined):boolean{\n if(!a) return false\n if(!b) return false\n if(a.length!==b.length) return false\n return a.every((item,index)=>item===b[index])\n}\n/**\n * 判断一个路径destPath是否包含另一个路径basePath判断\n * @param basePath \n * @param destPath \n */\nexport function pathStartsWith(basePath:string[],destPath:string[]){\n if(basePath.length>destPath.length) return false\n return basePath.every((p,i)=>{\n return p===destPath[i]\n })\n}\n\nexport function analysisCyclePath(steps:string[],curPath:string):[string | undefined,number] {\n // 使用curPath将steps分割为多个数组\n const indexs = steps.reduce((prev,cur,index)=>{\n if(cur===curPath) prev.push(index) \n return prev\n },[] as number[])\n\n const groups = indexs.map((v,i)=>{\n if(i<indexs.length-1){\n return steps.slice(v,indexs[i+1])\n }else{\n return steps.slice(v)\n } \n })\n\n // 找到groups相同的分组\n const results = new Map<string,number>()\n for(let i=0;i<groups.length;i++){\n const group = groups[i]\n if(group.length<2) continue\n for(let j=i+1;j<groups.length;j++){\n const group2 = groups[j]\n if(isPathEq(group,group2) || pathStartsWith(group,group2)){\n const gKey = group.join('->')\n if(!results.has(gKey)){\n results.set(gKey,1)\n }\n const n = results.get(gKey)! \n results.set(gKey,n+1)\n }\n }\n }\n // 找到results里面路径最长的\n let count = 0\n let paths = undefined\n results.forEach((v,k)=>{\n if(v<3) return\n if(k.length>count){\n paths = k\n count = v \n }\n }) \n return [paths,count]\n\n}\n","/**\n * \n * import { installCycleDetectExtend } from \"@autostore/devtools\"\n * \n * installCycleDetectExtend({....})\n * \n * \n */\nimport { analysisCyclePath } from \"./utils\"\n\n\nexport type CycleDetectExtendOptions = { \n /**\n * 当检测到多少个循环时视为循环依赖 \n */\n cycleCount?:number\n /**\n * \n * 当检测时间操作数量达到此值时，停止检测\n * \n */\n maxOpereates?:number\n /**\n * 指定仅作用于指定的store\n * =[]代表所有store均生效\n */\n stores?:string[]\n /**\n * \n */\n onDetected?:(paths:string[],computedObject:any)=>'ignore'|'throw'|'disable' \n\n}\n\n/**\n * \n * - 在异步计算第一次执行时调用\n * cycleDetector.start()\n * \n * \n * \n */\nexport class AsyncCycleDetector{\n steps:string[] = []\n running:boolean = false \n private _watcher:any\n path:string\n options: Record<string,any>\n constructor(public computedObject:any,options?:Record<string,any>){\n this.path = computedObject.path.join('.')\n this.steps.push(this.path)\n this.options = Object.assign({\n cycleCount : 8,\n maxOpereates: 200,\n stores:[]\n },options)\n } \n /**\n * 本方法应该在异步函数第一次运行时调用\n */\n start(){\n this.running = true\n this.steps.push(this.path)\n this._watcher = this.computedObject.store.watch((event:any)=>{\n if(this.steps.length<500){\n this.steps.push(event.path.join('.'))\n }\n },{operates:'read'}) \n }\n /**\n * \n * 开始检测是否存在循环依赖\n * \n * \n * [\"a\",'d','c','b','a','d','c','b','a']\n * \n * \n * 编写一个函数，检测是否存在循环依赖\n * \n * 逻辑如下：\n * \n * 对this.steps里面是否存在连续的相同的路径，如果存在，则表示存在循环依赖\n * \n * \n * @returns \n */\n private analysisCycleSteps(){\n const [paths,count] = analysisCyclePath(this.steps,this.path)\n const { onDetected,cycleCount } = this.options\n if(count<cycleCount) return\n this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${paths}`,'warn')\n if(typeof(onDetected )==='function'){\n const result = onDetected(paths,this.computedObject)\n if(result==='ignore'){\n return\n }else if(result==='disable') {\n this.computedObject.enable = false\n }else{\n throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${paths}`)\n }\n } \n } \n detect(){\n if(this.steps.length>this.options.maxOpereates){\n this._watcher.off()\n try{\n this.analysisCycleSteps()\n }finally{ \n this.steps=[]\n }\n }\n }\n}\n\n\nfunction createCycleDetectExtend(options?:CycleDetectExtendOptions){\n return function cycleDetectExtend(store:any){\n const { onObserverCreated } = store.options\n if(typeof(onObserverCreated) ==='function'){ \n // 当store的onObserverCreated选项已经配置时，cycleDetectExtend不能生效\n store.log(`Store<${store.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,\"warn\")\n }else{\n store.options.onObserverCreated = (observerObject:any)=>{\n // 只对异步计算属性进行循环依赖检测\n if(observerObject.type==='computed' && observerObject.async){\n observerObject._cycleDetector = new AsyncCycleDetector(observerObject,options)\n const oldRun = observerObject.run\n // 封装原始的run方法\n observerObject.run = (async function(options:any){\n // 在第一次运行时启动循环依赖检测\n if(options && options.first===true){\n observerObject._cycleDetector.start()\n }else{\n observerObject._cycleDetector.detect() \n }\n return await oldRun.apply(observerObject,options)\n }).bind(observerObject)\n }\n }\n store.log(\"cycleDetectExtend is already installed\")\n }\n } \n\n}\n\n\nexport function installCycleDetectExtend(options?:CycleDetectExtendOptions){\n // @ts-ignore\n if(!globalThis.__AUTOSTORE_EXTENDS__){\n // @ts-ignore\n globalThis.__AUTOSTORE_EXTENDS__=[]\n }\n // @ts-ignore\n globalThis.__AUTOSTORE_EXTENDS__.push(createCycleDetectExtend(options))\n \n}\n "]} |
+1
-1
@@ -1,2 +0,2 @@ | ||
| 'use strict';var redux=require('redux');var u=class{map;finalizationRegistry;constructor(){this.map=new Map,this.finalizationRegistry=new FinalizationRegistry(t=>{this.map.delete(t);});}set(t,e){let s=new WeakRef(e);this.map.set(t,s),this.finalizationRegistry.register(e,t);}get(t){let e=this.map.get(t);return e?e.deref():void 0}delete(t){return this.map.delete(t)}has(t){let e=this.map.get(t);return e?e.deref()!==void 0:false}};function y(i,t){return !i||!t||i.length!==t.length?false:i.every((e,s)=>e===t[s])}function E(i,t){return i.length>t.length?false:i.every((e,s)=>e===t[s])}function g(i,t){let e=i.reduce((r,o,c)=>(o===t&&r.push(c),r),[]),s=e.map((r,o)=>o<e.length-1?i.slice(r,e[o+1]):i.slice(r)),n=new Map;for(let r=0;r<s.length;r++){let o=s[r];if(!(o.length<2))for(let c=r+1;c<s.length;c++){let f=s[c];if(y(o,f)||E(o,f)){let p=o.join("->");n.has(p)||n.set(p,1);let _=n.get(p);n.set(p,_+1);}}}let a=0,l;return n.forEach((r,o)=>{r<3||o.length>a&&(l=o,a=r);}),[l,a]}var h=class{constructor(t,e){this.computedObject=t;this.path=t.path.join("."),this.steps.push(this.path),this.options=Object.assign({cycleCount:8,maxOpereates:200,stores:[]},e);}steps=[];running=false;_watcher;path;options;start(){this.running=true,this.steps.push(this.path),this._watcher=this.computedObject.store.watch(t=>{this.steps.length<500&&this.steps.push(t.path.join("."));},{operates:"read"});}analysisCycleSteps(){let[t,e]=g(this.steps,this.path),{onDetected:s,cycleCount:n}=this.options;if(!(e<n)&&(this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${t}`,"warn"),typeof s=="function")){let a=s(t,this.computedObject);if(a==="ignore")return;if(a==="disable")this.computedObject.enable=false;else throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${t}`)}}detect(){if(this.steps.length>this.options.maxOpereates){this._watcher.off();try{this.analysisCycleSteps();}finally{this.steps=[];}}}};function S(i){return function(e){let{onObserverCreated:s}=e.options;typeof s=="function"?e.log(`Store<${e.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,"warn"):(e.options.onObserverCreated=n=>{if(n.type==="computed"&&n.async){n._cycleDetector=new h(n,i);let a=n.run;n.run=async function(l){return l&&l.first===true?n._cycleDetector.start():n._cycleDetector.detect(),await a.apply(n,l)}.bind(n);}},e.log("cycleDetectExtend is already installed"));}}function w(i){globalThis.__AUTOSTORE_EXTENDS__||(globalThis.__AUTOSTORE_EXTENDS__=[]),globalThis.__AUTOSTORE_EXTENDS__.push(S(i));}var T={},d=class{reduxStore;_installed=false;stores=new u;constructor(){this.install();}add(t){this.stores.set(t.id,t),t.operates.onAny((e,s)=>{e.type!=="get"&&this.reduxStore.dispatch({type:`${e.type}@${s}`,store:t,payload:e});}),this.reduxStore.dispatch({type:"__ADD_STORE__",store:t});}remove(t){this.stores.has(t.id)&&this.stores.delete(t.id);}reducer(t=T,e){return e.type.startsWith("@@")?t:e.type==="__ADD_STORE__"?{...t,[`AutoStore<${e.store.id}>`]:{...e.store.getSnap()}}:{...t,[`AutoStore<${e.store.id}>`]:{...e.store.getSnap()}}}install(){this._installed||(this.reduxStore=redux.legacy_createStore(this.reducer,window.__REDUX_DEVTOOLS_EXTENSION__&&window.__REDUX_DEVTOOLS_EXTENSION__()),this._installed=true,console.info("%c AutoStoreDevTools installed. Please open <Redux devtools> to view. %c","color:red;",""));}};function m(){globalThis.__AUTOSTORE_DEVTOOLS__||(globalThis.__AUTOSTORE_DEVTOOLS__=new d);}m();exports.AsyncCycleDetector=h;exports.AutoStoreDevTools=d;exports.install=m;exports.installCycleDetectExtend=w;//# sourceMappingURL=index.js.map | ||
| 'use strict';var redux=require('redux');var u=class{map;finalizationRegistry;constructor(){this.map=new Map,this.finalizationRegistry=new FinalizationRegistry(t=>{this.map.delete(t);});}set(t,e){let s=new WeakRef(e);this.map.set(t,s),this.finalizationRegistry.register(e,t);}get(t){let e=this.map.get(t);return e?e.deref():void 0}delete(t){return this.map.delete(t)}has(t){let e=this.map.get(t);return e?e.deref()!==void 0:false}};function y(i,t){return !i||!t||i.length!==t.length?false:i.every((e,s)=>e===t[s])}function E(i,t){return i.length>t.length?false:i.every((e,s)=>e===t[s])}function g(i,t){let e=i.reduce((r,o,c)=>(o===t&&r.push(c),r),[]),s=e.map((r,o)=>o<e.length-1?i.slice(r,e[o+1]):i.slice(r)),n=new Map;for(let r=0;r<s.length;r++){let o=s[r];if(!(o.length<2))for(let c=r+1;c<s.length;c++){let f=s[c];if(y(o,f)||E(o,f)){let p=o.join("->");n.has(p)||n.set(p,1);let _=n.get(p);n.set(p,_+1);}}}let a=0,l;return n.forEach((r,o)=>{r<3||o.length>a&&(l=o,a=r);}),[l,a]}var h=class{constructor(t,e){this.computedObject=t;this.path=t.path.join("."),this.steps.push(this.path),this.options=Object.assign({cycleCount:8,maxOpereates:200,stores:[]},e);}steps=[];running=false;_watcher;path;options;start(){this.running=true,this.steps.push(this.path),this._watcher=this.computedObject.store.watch(t=>{this.steps.length<500&&this.steps.push(t.path.join("."));},{operates:"read"});}analysisCycleSteps(){let[t,e]=g(this.steps,this.path),{onDetected:s,cycleCount:n}=this.options;if(!(e<n)&&(this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${t}`,"warn"),typeof s=="function")){let a=s(t,this.computedObject);if(a==="ignore")return;if(a==="disable")this.computedObject.enable=false;else throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${t}`)}}detect(){if(this.steps.length>this.options.maxOpereates){this._watcher.off();try{this.analysisCycleSteps();}finally{this.steps=[];}}}};function S(i){return function(e){let{onObserverCreated:s}=e.options;typeof s=="function"?e.log(`Store<${e.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,"warn"):(e.options.onObserverCreated=n=>{if(n.type==="computed"&&n.async){n._cycleDetector=new h(n,i);let a=n.run;n.run=(async function(l){return l&&l.first===true?n._cycleDetector.start():n._cycleDetector.detect(),await a.apply(n,l)}).bind(n);}},e.log("cycleDetectExtend is already installed"));}}function w(i){globalThis.__AUTOSTORE_EXTENDS__||(globalThis.__AUTOSTORE_EXTENDS__=[]),globalThis.__AUTOSTORE_EXTENDS__.push(S(i));}var T={},d=class{reduxStore;_installed=false;stores=new u;constructor(){this.install();}add(t){this.stores.set(t.id,t),t.operates.onAny((e,s)=>{e.type!=="get"&&this.reduxStore.dispatch({type:`${e.type}@${s}`,store:t,payload:e});}),this.reduxStore.dispatch({type:"__ADD_STORE__",store:t});}remove(t){this.stores.has(t.id)&&this.stores.delete(t.id);}reducer(t=T,e){return e.type.startsWith("@@")?t:e.type==="__ADD_STORE__"?{...t,[`AutoStore<${e.store.id}>`]:{...e.store.getSnap()}}:{...t,[`AutoStore<${e.store.id}>`]:{...e.store.getSnap()}}}install(){this._installed||(this.reduxStore=redux.legacy_createStore(this.reducer,window.__REDUX_DEVTOOLS_EXTENSION__&&window.__REDUX_DEVTOOLS_EXTENSION__()),this._installed=true,console.info("%c AutoStoreDevTools installed. Please open <Redux devtools> to view. %c","color:red;",""));}};function m(){globalThis.__AUTOSTORE_DEVTOOLS__||(globalThis.__AUTOSTORE_DEVTOOLS__=new d);}m();exports.AsyncCycleDetector=h;exports.AutoStoreDevTools=d;exports.install=m;exports.installCycleDetectExtend=w;//# sourceMappingURL=index.js.map | ||
| //# sourceMappingURL=index.js.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/utils.ts","../src/cycleDetectExtend.ts","../src/devTools.ts"],"names":["WeakObjectMap","key","value","weakRef","isPathEq","a","b","item","index","pathStartsWith","basePath","destPath","p","i","analysisCyclePath","steps","curPath","indexs","prev","cur","groups","v","results","group","j","group2","gKey","n","count","paths","k","AsyncCycleDetector","computedObject","options","event","onDetected","cycleCount","result","createCycleDetectExtend","store","onObserverCreated","observerObject","oldRun","installCycleDetectExtend","initialState","AutoStoreDevTools","payload","type","state","action","createStore","install"],"mappings":"wCACO,IAAMA,EAAN,KAAsC,CACjC,IACA,oBAER,CAAA,WAAA,EAAc,CACZ,IAAK,CAAA,GAAA,CAAM,IAAI,GACf,CAAA,IAAA,CAAK,qBAAuB,IAAI,oBAAA,CAAsBC,GAAQ,CAC5D,IAAA,CAAK,IAAI,MAAOA,CAAAA,CAAG,EACrB,CAAC,EACH,CAEA,GAAIA,CAAAA,CAAAA,CAAaC,EAAgB,CAC/B,IAAMC,EAAU,IAAI,OAAA,CAAQD,CAAK,CACjC,CAAA,IAAA,CAAK,IAAI,GAAID,CAAAA,CAAAA,CAAKE,CAAO,CACzB,CAAA,IAAA,CAAK,qBAAqB,QAASD,CAAAA,CAAAA,CAAOD,CAAG,EAC/C,CAEA,IAAIA,CAA4B,CAAA,CAC9B,IAAME,CAAU,CAAA,IAAA,CAAK,IAAI,GAAIF,CAAAA,CAAG,EAChC,OAAOE,CAAAA,CAAUA,EAAQ,KAAM,EAAA,CAAI,MACrC,CAEA,MAAA,CAAOF,EAAsB,CAC3B,OAAO,KAAK,GAAI,CAAA,MAAA,CAAOA,CAAG,CAC5B,CAEA,IAAIA,CAAsB,CAAA,CACxB,IAAME,CAAU,CAAA,IAAA,CAAK,IAAI,GAAIF,CAAAA,CAAG,EAChC,OAAOE,CAAAA,CAAUA,EAAQ,KAAM,EAAA,GAAM,OAAY,KACnD,CACJ,EASO,SAASC,CAAAA,CAASC,EAAuBC,CAA+B,CAAA,CAG7E,OAFG,CAACD,CAAAA,EACD,CAACC,CACDD,EAAAA,CAAAA,CAAE,SAASC,CAAE,CAAA,MAAA,CAAe,MACxBD,CAAE,CAAA,KAAA,CAAM,CAACE,CAAKC,CAAAA,CAAAA,GAAQD,IAAOD,CAAEE,CAAAA,CAAK,CAAC,CAC9C,CAMO,SAASC,CAAeC,CAAAA,CAAAA,CAAkBC,EAAkB,CACjE,OAAGD,EAAS,MAAOC,CAAAA,CAAAA,CAAS,OAAe,KACpCD,CAAAA,CAAAA,CAAS,MAAM,CAACE,CAAAA,CAAEC,IACdD,CAAID,GAAAA,CAAAA,CAASE,CAAC,CACxB,CACH,CAEO,SAASC,CAAAA,CAAkBC,EAAeC,CAA4C,CAAA,CAE3F,IAAMC,CAASF,CAAAA,CAAAA,CAAM,OAAO,CAACG,CAAAA,CAAKC,EAAIX,CAC/BW,IAAAA,CAAAA,GAAMH,GAASE,CAAK,CAAA,IAAA,CAAKV,CAAK,CAC1BU,CAAAA,CAAAA,CAAAA,CACT,EAAc,CAAA,CAEVE,EAASH,CAAO,CAAA,GAAA,CAAI,CAACI,CAAER,CAAAA,CAAAA,GACtBA,EAAEI,CAAO,CAAA,MAAA,CAAO,EACRF,CAAM,CAAA,KAAA,CAAMM,EAAEJ,CAAOJ,CAAAA,CAAAA,CAAE,CAAC,CAAC,CAAA,CAEzBE,EAAM,KAAMM,CAAAA,CAAC,CAE3B,CAGKC,CAAAA,CAAAA,CAAU,IAAI,GAAA,CACpB,QAAQT,CAAE,CAAA,CAAA,CAAEA,EAAEO,CAAO,CAAA,MAAA,CAAOP,IAAI,CAC5B,IAAMU,EAAQH,CAAOP,CAAAA,CAAC,EACtB,GAAG,EAAAU,EAAM,MAAO,CAAA,CAAA,CAAA,CAChB,QAAQC,CAAEX,CAAAA,CAAAA,CAAE,EAAEW,CAAEJ,CAAAA,CAAAA,CAAO,OAAOI,CAAI,EAAA,CAAA,CAC9B,IAAMC,CAASL,CAAAA,CAAAA,CAAOI,CAAC,CACvB,CAAA,GAAGpB,EAASmB,CAAME,CAAAA,CAAM,GAAKhB,CAAec,CAAAA,CAAAA,CAAME,CAAM,CAAE,CAAA,CACtD,IAAMC,CAAOH,CAAAA,CAAAA,CAAM,KAAK,IAAI,CAAA,CACxBD,EAAQ,GAAII,CAAAA,CAAI,GAChBJ,CAAQ,CAAA,GAAA,CAAII,EAAK,CAAC,CAAA,CAEtB,IAAMC,CAAIL,CAAAA,CAAAA,CAAQ,IAAII,CAAI,CAAA,CAC1BJ,EAAQ,GAAII,CAAAA,CAAAA,CAAKC,EAAE,CAAC,EACxB,CACJ,CACJ,CAEA,IAAIC,CAAQ,CAAA,CAAA,CACRC,EACJ,OAAAP,CAAAA,CAAQ,QAAQ,CAACD,CAAAA,CAAES,IAAI,CAChBT,CAAAA,CAAE,GACFS,CAAE,CAAA,MAAA,CAAOF,IACVC,CAAQC,CAAAA,CAAAA,CACRF,EAAQP,CAEd,EAAA,CAAC,EACM,CAACQ,CAAAA,CAAMD,CAAK,CAErB,KC5DaG,CAAN,CAAA,KAAwB,CAM3B,WAAmBC,CAAAA,CAAAA,CAAmBC,EAA4B,CAA/C,IAAA,CAAA,cAAA,CAAAD,EACf,IAAK,CAAA,IAAA,CAAOA,EAAe,IAAK,CAAA,IAAA,CAAK,GAAG,CACxC,CAAA,IAAA,CAAK,MAAM,IAAK,CAAA,IAAA,CAAK,IAAI,CACzB,CAAA,IAAA,CAAK,QAAU,MAAO,CAAA,MAAA,CAAO,CACzB,UAAc,CAAA,CAAA,CACd,aAAc,GACd,CAAA,MAAA,CAAO,EACX,CAAA,CAAEC,CAAO,EACb,CAbA,MAAiB,EAAC,CAClB,QAAkB,KACV,CAAA,QAAA,CACR,KACA,OAaA,CAAA,KAAA,EAAO,CACH,IAAK,CAAA,OAAA,CAAU,KACf,IAAK,CAAA,KAAA,CAAM,KAAK,IAAK,CAAA,IAAI,EACzB,IAAK,CAAA,QAAA,CAAW,KAAK,cAAe,CAAA,KAAA,CAAM,MAAOC,CAAY,EAAA,CACtD,KAAK,KAAM,CAAA,MAAA,CAAO,KACjB,IAAK,CAAA,KAAA,CAAM,KAAKA,CAAM,CAAA,IAAA,CAAK,KAAK,GAAG,CAAC,EAE5C,CAAE,CAAA,CAAC,SAAS,MAAM,CAAC,EACvB,CAkBQ,kBAAA,EAAoB,CACxB,GAAM,CAACL,CAAMD,CAAAA,CAAK,EAAId,CAAkB,CAAA,IAAA,CAAK,MAAM,IAAK,CAAA,IAAI,EACtD,CAAE,UAAA,CAAAqB,EAAW,UAAAC,CAAAA,CAAW,EAAI,IAAK,CAAA,OAAA,CACvC,GAAG,EAAAR,CAAAA,CAAMQ,KACT,IAAK,CAAA,cAAA,CAAe,MAAM,GAAI,CAAA,CAAA,yBAAA,EAA4B,KAAK,cAAe,CAAA,QAAA,EAAU,CAAMP,GAAAA,EAAAA,CAAK,GAAG,MAAM,CAAA,CACzG,OAAOM,CAAe,EAAA,UAAA,CAAA,CAAW,CAChC,IAAME,CAAAA,CAASF,EAAWN,CAAM,CAAA,IAAA,CAAK,cAAc,CACnD,CAAA,GAAGQ,IAAS,QACR,CAAA,OACE,GAAGA,CAAS,GAAA,SAAA,CACd,KAAK,cAAe,CAAA,MAAA,CAAS,WAEvB,MAAA,IAAI,MAAM,CAAyB,sBAAA,EAAA,IAAA,CAAK,eAAe,QAAS,EAAC,MAAMR,CAAK,CAAA,CAAE,CAE5F,CACJ,CACA,QAAQ,CACJ,GAAG,KAAK,KAAM,CAAA,MAAA,CAAO,KAAK,OAAQ,CAAA,YAAA,CAAa,CAC3C,IAAK,CAAA,QAAA,CAAS,KACd,CAAA,GAAG,CACC,IAAK,CAAA,kBAAA,GACT,CAAC,OAAA,CACG,KAAK,KAAM,CAAA,GACf,CACJ,CACJ,CACJ,EAGA,SAASS,EAAwBL,CAAkC,CAAA,CAC/D,OAAO,SAA2BM,CAAAA,CAAU,CACxC,GAAM,CAAE,kBAAAC,CAAkB,CAAA,CAAID,EAAM,OACjC,CAAA,OAAOC,GAAsB,UAE5BD,CAAAA,CAAAA,CAAM,IAAI,CAASA,MAAAA,EAAAA,CAAAA,CAAM,EAAE,CAA2E,wEAAA,CAAA,CAAA,MAAM,GAE5GA,CAAM,CAAA,OAAA,CAAQ,kBAAqBE,CAAqB,EAAA,CAEpD,GAAGA,CAAe,CAAA,IAAA,GAAO,YAAcA,CAAe,CAAA,KAAA,CAAM,CACxDA,CAAe,CAAA,cAAA,CAAiB,IAAIV,CAAmBU,CAAAA,CAAAA,CAAeR,CAAO,CAC7E,CAAA,IAAMS,EAASD,CAAe,CAAA,GAAA,CAE9BA,EAAe,GAAO,CAAA,eAAeR,EAAY,CAE7C,OAAGA,GAAWA,CAAQ,CAAA,KAAA,GAAQ,KAC1BQ,CAAe,CAAA,cAAA,CAAe,OAE9BA,CAAAA,CAAAA,CAAe,eAAe,MAAO,EAAA,CAElC,MAAMC,CAAO,CAAA,KAAA,CAAMD,EAAeR,CAAO,CACpD,EAAG,IAAKQ,CAAAA,CAAc,EAC1B,CACJ,CAAA,CACAF,EAAM,GAAI,CAAA,wCAAwC,GAE1D,CAEJ,CAGO,SAASI,CAAyBV,CAAAA,CAAAA,CAAkC,CAEnE,UAAW,CAAA,qBAAA,GAEX,UAAW,CAAA,qBAAA,CAAsB,EAGrC,CAAA,CAAA,UAAA,CAAW,sBAAsB,IAAKK,CAAAA,CAAAA,CAAwBL,CAAO,CAAC,EAE1E,CCrIA,IAAMW,EAAe,EAErB,CAGaC,EAAN,KAAuB,CAClB,WACA,UAAqB,CAAA,KAAA,CAC7B,OAAS,IAAI7C,CAAAA,CACb,aAAa,CACT,IAAA,CAAK,UACT,CACA,IAAIuC,CAAU,CAAA,CACV,KAAK,MAAO,CAAA,GAAA,CAAIA,EAAM,EAAGA,CAAAA,CAAK,EAC9BA,CAAM,CAAA,QAAA,CAAS,MAAM,CAACO,CAAAA,CAAYC,IAAW,CACtCD,CAAAA,CAAQ,OAAO,KAClB,EAAA,IAAA,CAAK,WAAW,QAAS,CAAA,CACrB,KAAK,CAAGA,EAAAA,CAAAA,CAAQ,IAAI,CAAIC,CAAAA,EAAAA,CAAI,GAC5B,KAAAR,CAAAA,CAAAA,CACA,QAAAO,CACJ,CAAC,EACL,CAAC,CAAA,CACD,KAAK,UAAW,CAAA,QAAA,CAAS,CACrB,IAAK,CAAA,eAAA,CACL,MAAAP,CACJ,CAAC,EACL,CACA,MAAA,CAAOA,EAAU,CACT,IAAA,CAAK,OAAO,GAAIA,CAAAA,CAAAA,CAAM,EAAE,CACxB,EAAA,IAAA,CAAK,OAAO,MAAOA,CAAAA,CAAAA,CAAM,EAAE,EAEnC,CACQ,QAAQS,CAAeJ,CAAAA,CAAAA,CAAcK,EAAW,CACpD,OAAGA,EAAO,IAAK,CAAA,UAAA,CAAW,IAAI,CAAUD,CAAAA,CAAAA,CACrCC,EAAO,IAAO,GAAA,eAAA,CACN,CACH,GAAGD,CAAAA,CACH,CAAC,CAAaC,UAAAA,EAAAA,CAAAA,CAAO,MAAM,EAAE,CAAA,CAAA,CAAG,EAAE,CAAC,GAAGA,EAAO,KAAM,CAAA,OAAA,EAAS,CAChE,CAAA,CAEO,CACH,GAAGD,CAAAA,CACH,CAAC,CAAaC,UAAAA,EAAAA,CAAAA,CAAO,MAAM,EAAE,CAAA,CAAA,CAAG,EAAE,CAAC,GAAGA,EAAO,KAAM,CAAA,OAAA,EAAS,CAChE,CAER,CACQ,OAAS,EAAA,CACV,KAAK,UACR,GAAA,IAAA,CAAK,WAAaC,wBACd,CAAA,IAAA,CAAK,QAEL,MAAO,CAAA,4BAAA,EAAgC,OAAO,4BAA6B,EAC/E,EACA,IAAK,CAAA,UAAA,CAAa,KAClB,OAAQ,CAAA,IAAA,CAAK,2EAA2E,YAAa,CAAA,EAAE,GAC3G,CACJ,EAEO,SAASC,CAAS,EAAA,CAEjB,WAAW,sBAAwB,GAAA,UAAA,CAAW,uBAAyB,IAAIN,CAAAA,EACnF,CAQAM,CAAQ,EAAA","file":"index.js","sourcesContent":["\r\nexport class WeakObjectMap<T extends object> {\r\n private map: Map<string, WeakRef<T>>;\r\n private finalizationRegistry: FinalizationRegistry<string>;\r\n \r\n constructor() {\r\n this.map = new Map();\r\n this.finalizationRegistry = new FinalizationRegistry((key) => {\r\n this.map.delete(key);\r\n });\r\n }\r\n \r\n set(key: string, value: T): void {\r\n const weakRef = new WeakRef(value);\r\n this.map.set(key, weakRef);\r\n this.finalizationRegistry.register(value, key);\r\n }\r\n \r\n get(key: string): T | undefined {\r\n const weakRef = this.map.get(key);\r\n return weakRef ? weakRef.deref() : undefined;\r\n }\r\n \r\n delete(key: string): boolean {\r\n return this.map.delete(key);\r\n }\r\n \r\n has(key: string): boolean {\r\n const weakRef = this.map.get(key);\r\n return weakRef ? weakRef.deref() !== undefined : false;\r\n }\r\n}\r\n/**\r\n * 判定两个值是否相等\r\n * \r\n * 如果两个值都是对象，则判断两个对象是否相等\r\n * 如果两个值都是数组，则判断两个数组的值是否相等\r\n * \r\n */\r\n\r\nexport function isPathEq(a:string[] | undefined,b:string[] | undefined):boolean{\r\n if(!a) return false\r\n if(!b) return false\r\n if(a.length!==b.length) return false\r\n return a.every((item,index)=>item===b[index])\r\n}\r\n/**\r\n * 判断一个路径destPath是否包含另一个路径basePath判断\r\n * @param basePath \r\n * @param destPath \r\n */\r\nexport function pathStartsWith(basePath:string[],destPath:string[]){\r\n if(basePath.length>destPath.length) return false\r\n return basePath.every((p,i)=>{\r\n return p===destPath[i]\r\n })\r\n}\r\n\r\nexport function analysisCyclePath(steps:string[],curPath:string):[string | undefined,number] {\r\n // 使用curPath将steps分割为多个数组\r\n const indexs = steps.reduce((prev,cur,index)=>{\r\n if(cur===curPath) prev.push(index) \r\n return prev\r\n },[] as number[])\r\n\r\n const groups = indexs.map((v,i)=>{\r\n if(i<indexs.length-1){\r\n return steps.slice(v,indexs[i+1])\r\n }else{\r\n return steps.slice(v)\r\n } \r\n })\r\n\r\n // 找到groups相同的分组\r\n const results = new Map<string,number>()\r\n for(let i=0;i<groups.length;i++){\r\n const group = groups[i]\r\n if(group.length<2) continue\r\n for(let j=i+1;j<groups.length;j++){\r\n const group2 = groups[j]\r\n if(isPathEq(group,group2) || pathStartsWith(group,group2)){\r\n const gKey = group.join('->')\r\n if(!results.has(gKey)){\r\n results.set(gKey,1)\r\n }\r\n const n = results.get(gKey)! \r\n results.set(gKey,n+1)\r\n }\r\n }\r\n }\r\n // 找到results里面路径最长的\r\n let count = 0\r\n let paths = undefined\r\n results.forEach((v,k)=>{\r\n if(v<3) return\r\n if(k.length>count){\r\n paths = k\r\n count = v \r\n }\r\n }) \r\n return [paths,count]\r\n\r\n}\r\n","/**\r\n * \r\n * import { installCycleDetectExtend } from \"@autostore/devtools\"\r\n * \r\n * installCycleDetectExtend({....})\r\n * \r\n * \r\n */\r\nimport { analysisCyclePath } from \"./utils\"\r\n\r\n\r\nexport type CycleDetectExtendOptions = { \r\n /**\r\n * 当检测到多少个循环时视为循环依赖 \r\n */\r\n cycleCount?:number\r\n /**\r\n * \r\n * 当检测时间操作数量达到此值时，停止检测\r\n * \r\n */\r\n maxOpereates?:number\r\n /**\r\n * 指定仅作用于指定的store\r\n * =[]代表所有store均生效\r\n */\r\n stores?:string[]\r\n /**\r\n * \r\n */\r\n onDetected?:(paths:string[],computedObject:any)=>'ignore'|'throw'|'disable' \r\n\r\n}\r\n\r\n/**\r\n * \r\n * - 在异步计算第一次执行时调用\r\n * cycleDetector.start()\r\n * \r\n * \r\n * \r\n */\r\nexport class AsyncCycleDetector{\r\n steps:string[] = []\r\n running:boolean = false \r\n private _watcher:any\r\n path:string\r\n options: Record<string,any>\r\n constructor(public computedObject:any,options?:Record<string,any>){\r\n this.path = computedObject.path.join('.')\r\n this.steps.push(this.path)\r\n this.options = Object.assign({\r\n cycleCount : 8,\r\n maxOpereates: 200,\r\n stores:[]\r\n },options)\r\n } \r\n /**\r\n * 本方法应该在异步函数第一次运行时调用\r\n */\r\n start(){\r\n this.running = true\r\n this.steps.push(this.path)\r\n this._watcher = this.computedObject.store.watch((event:any)=>{\r\n if(this.steps.length<500){\r\n this.steps.push(event.path.join('.'))\r\n }\r\n },{operates:'read'}) \r\n }\r\n /**\r\n * \r\n * 开始检测是否存在循环依赖\r\n * \r\n * \r\n * [\"a\",'d','c','b','a','d','c','b','a']\r\n * \r\n * \r\n * 编写一个函数，检测是否存在循环依赖\r\n * \r\n * 逻辑如下：\r\n * \r\n * 对this.steps里面是否存在连续的相同的路径，如果存在，则表示存在循环依赖\r\n * \r\n * \r\n * @returns \r\n */\r\n private analysisCycleSteps(){\r\n const [paths,count] = analysisCyclePath(this.steps,this.path)\r\n const { onDetected,cycleCount } = this.options\r\n if(count<cycleCount) return\r\n this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${paths}`,'warn')\r\n if(typeof(onDetected )==='function'){\r\n const result = onDetected(paths,this.computedObject)\r\n if(result==='ignore'){\r\n return\r\n }else if(result==='disable') {\r\n this.computedObject.enable = false\r\n }else{\r\n throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${paths}`)\r\n }\r\n } \r\n } \r\n detect(){\r\n if(this.steps.length>this.options.maxOpereates){\r\n this._watcher.off()\r\n try{\r\n this.analysisCycleSteps()\r\n }finally{ \r\n this.steps=[]\r\n }\r\n }\r\n }\r\n}\r\n\r\n\r\nfunction createCycleDetectExtend(options?:CycleDetectExtendOptions){\r\n return function cycleDetectExtend(store:any){\r\n const { onObserverCreated } = store.options\r\n if(typeof(onObserverCreated) ==='function'){ \r\n // 当store的onObserverCreated选项已经配置时，cycleDetectExtend不能生效\r\n store.log(`Store<${store.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,\"warn\")\r\n }else{\r\n store.options.onObserverCreated = (observerObject:any)=>{\r\n // 只对异步计算属性进行循环依赖检测\r\n if(observerObject.type==='computed' && observerObject.async){\r\n observerObject._cycleDetector = new AsyncCycleDetector(observerObject,options)\r\n const oldRun = observerObject.run\r\n // 封装原始的run方法\r\n observerObject.run = (async function(options:any){\r\n // 在第一次运行时启动循环依赖检测\r\n if(options && options.first===true){\r\n observerObject._cycleDetector.start()\r\n }else{\r\n observerObject._cycleDetector.detect() \r\n }\r\n return await oldRun.apply(observerObject,options)\r\n }).bind(observerObject)\r\n }\r\n }\r\n store.log(\"cycleDetectExtend is already installed\")\r\n }\r\n } \r\n\r\n}\r\n\r\n\r\nexport function installCycleDetectExtend(options?:CycleDetectExtendOptions){\r\n // @ts-ignore\r\n if(!globalThis.__AUTOSTORE_EXTENDS__){\r\n // @ts-ignore\r\n globalThis.__AUTOSTORE_EXTENDS__=[]\r\n }\r\n // @ts-ignore\r\n globalThis.__AUTOSTORE_EXTENDS__.push(createCycleDetectExtend(options))\r\n \r\n}\r\n ","/**\r\n * \r\n * 基于开发工具\r\n * \r\n * Redux DevTools 是一个实用工具，用于开发和调试 Redux 应用程序。\r\n * AutoStore是基于Redux DevTools 的简单包装，可以让开发者使用Redux DevTools\r\n * 来查看AutoStore的状态变化 \r\n * \r\n * import { createStore } from \"@autostorejs/react\"\r\n * import { install } from \"@autostorejs/devtools\"\r\n * \r\n * \r\n * const store = createStore({})\r\n * \r\n * install()\r\n * \r\n */\r\n\r\n//@ts-ignore\r\nimport { legacy_createStore as createStore } from \"redux\"\r\nimport { WeakObjectMap } from \"./utils\"\r\n \r\nconst initialState = {\r\n \r\n}\r\n\r\n\r\nexport class AutoStoreDevTools{\r\n private reduxStore:any\r\n private _installed:boolean = false\r\n stores = new WeakObjectMap()\r\n constructor(){\r\n this.install()\r\n }\r\n add(store:any){ \r\n this.stores.set(store.id,store)\r\n store.operates.onAny((payload:any,type:any)=>{ \r\n if(payload.type==='get') return \r\n this.reduxStore.dispatch({\r\n type:`${payload.type}@${type}`,\r\n store,\r\n payload \r\n })\r\n })\r\n this.reduxStore.dispatch({\r\n type:\"__ADD_STORE__\",\r\n store\r\n })\r\n }\r\n remove(store:any){ \r\n if( this.stores.has(store.id)){\r\n this.stores.delete(store.id)\r\n }\r\n }\r\n private reducer(state:object = initialState, action:any){\r\n if(action.type.startsWith(\"@@\")) return state\r\n if(action.type==='__ADD_STORE__') {\r\n return {\r\n ...state,\r\n [`AutoStore<${action.store.id}>`]:{...action.store.getSnap()}\r\n }\r\n }else{\r\n return {\r\n ...state,\r\n [`AutoStore<${action.store.id}>`]:{...action.store.getSnap()}\r\n }\r\n } \r\n }\r\n private install(){\r\n if(this._installed) return \r\n this.reduxStore = createStore(\r\n this.reducer,\r\n // @ts-ignore\r\n window.__REDUX_DEVTOOLS_EXTENSION__ && window.__REDUX_DEVTOOLS_EXTENSION__()\r\n ); \r\n this._installed = true\r\n console.info('%c AutoStoreDevTools installed. Please open <Redux devtools> to view. %c',\"color:red;\",'')\r\n }\r\n}\r\n\r\nexport function install(){\r\n // @ts-ignore\r\n if(!globalThis.__AUTOSTORE_DEVTOOLS__) globalThis.__AUTOSTORE_DEVTOOLS__ = new AutoStoreDevTools() \r\n} \r\n\r\ndeclare global{\r\n // @ts-ignore\r\n var __AUTOSTORE_DEVTOOLS__ : AutoStoreDevTools\r\n}\r\n\r\n\r\ninstall()\r\n\r\n"]} | ||
| {"version":3,"sources":["../src/utils.ts","../src/cycleDetectExtend.ts","../src/devTools.ts"],"names":["WeakObjectMap","key","value","weakRef","isPathEq","a","b","item","index","pathStartsWith","basePath","destPath","p","i","analysisCyclePath","steps","curPath","indexs","prev","cur","groups","v","results","group","j","group2","gKey","n","count","paths","k","AsyncCycleDetector","computedObject","options","event","onDetected","cycleCount","result","createCycleDetectExtend","store","onObserverCreated","observerObject","oldRun","installCycleDetectExtend","initialState","AutoStoreDevTools","payload","type","state","action","createStore","install"],"mappings":"wCACO,IAAMA,EAAN,KAAsC,CACjC,IACA,oBAAA,CAER,WAAA,EAAc,CACZ,IAAA,CAAK,GAAA,CAAM,IAAI,GAAA,CACf,IAAA,CAAK,qBAAuB,IAAI,oBAAA,CAAsBC,GAAQ,CAC5D,IAAA,CAAK,IAAI,MAAA,CAAOA,CAAG,EACrB,CAAC,EACH,CAEA,GAAA,CAAIA,CAAAA,CAAaC,EAAgB,CAC/B,IAAMC,EAAU,IAAI,OAAA,CAAQD,CAAK,CAAA,CACjC,IAAA,CAAK,IAAI,GAAA,CAAID,CAAAA,CAAKE,CAAO,CAAA,CACzB,IAAA,CAAK,qBAAqB,QAAA,CAASD,CAAAA,CAAOD,CAAG,EAC/C,CAEA,IAAIA,CAAAA,CAA4B,CAC9B,IAAME,CAAAA,CAAU,IAAA,CAAK,IAAI,GAAA,CAAIF,CAAG,EAChC,OAAOE,CAAAA,CAAUA,EAAQ,KAAA,EAAM,CAAI,MACrC,CAEA,MAAA,CAAOF,EAAsB,CAC3B,OAAO,KAAK,GAAA,CAAI,MAAA,CAAOA,CAAG,CAC5B,CAEA,IAAIA,CAAAA,CAAsB,CACxB,IAAME,CAAAA,CAAU,IAAA,CAAK,IAAI,GAAA,CAAIF,CAAG,EAChC,OAAOE,CAAAA,CAAUA,EAAQ,KAAA,EAAM,GAAM,OAAY,KACnD,CACJ,EASO,SAASC,CAAAA,CAASC,EAAuBC,CAAAA,CAA+B,CAG7E,OAFG,CAACD,CAAAA,EACD,CAACC,CAAAA,EACDD,CAAAA,CAAE,SAASC,CAAAA,CAAE,MAAA,CAAe,MACxBD,CAAAA,CAAE,KAAA,CAAM,CAACE,CAAAA,CAAKC,CAAAA,GAAQD,IAAOD,CAAAA,CAAEE,CAAK,CAAC,CAC9C,CAMO,SAASC,CAAAA,CAAeC,CAAAA,CAAkBC,EAAkB,CACjE,OAAGD,EAAS,MAAA,CAAOC,CAAAA,CAAS,OAAe,KAAA,CACpCD,CAAAA,CAAS,MAAM,CAACE,CAAAA,CAAEC,IACdD,CAAAA,GAAID,CAAAA,CAASE,CAAC,CACxB,CACH,CAEO,SAASC,CAAAA,CAAkBC,EAAeC,CAAAA,CAA4C,CAE3F,IAAMC,CAAAA,CAASF,CAAAA,CAAM,OAAO,CAACG,CAAAA,CAAKC,EAAIX,CAAAA,IAC/BW,CAAAA,GAAMH,GAASE,CAAAA,CAAK,IAAA,CAAKV,CAAK,CAAA,CAC1BU,CAAAA,CAAAA,CACT,EAAc,CAAA,CAEVE,EAASH,CAAAA,CAAO,GAAA,CAAI,CAACI,CAAAA,CAAER,CAAAA,GACtBA,EAAEI,CAAAA,CAAO,MAAA,CAAO,EACRF,CAAAA,CAAM,KAAA,CAAMM,EAAEJ,CAAAA,CAAOJ,CAAAA,CAAE,CAAC,CAAC,CAAA,CAEzBE,EAAM,KAAA,CAAMM,CAAC,CAE3B,CAAA,CAGKC,CAAAA,CAAU,IAAI,GAAA,CACpB,QAAQT,CAAAA,CAAE,CAAA,CAAEA,EAAEO,CAAAA,CAAO,MAAA,CAAOP,IAAI,CAC5B,IAAMU,EAAQH,CAAAA,CAAOP,CAAC,EACtB,GAAG,EAAAU,EAAM,MAAA,CAAO,CAAA,CAAA,CAChB,QAAQC,CAAAA,CAAEX,CAAAA,CAAE,EAAEW,CAAAA,CAAEJ,CAAAA,CAAO,OAAOI,CAAAA,EAAAA,CAAI,CAC9B,IAAMC,CAAAA,CAASL,CAAAA,CAAOI,CAAC,CAAA,CACvB,GAAGpB,EAASmB,CAAAA,CAAME,CAAM,GAAKhB,CAAAA,CAAec,CAAAA,CAAME,CAAM,CAAA,CAAE,CACtD,IAAMC,CAAAA,CAAOH,CAAAA,CAAM,KAAK,IAAI,CAAA,CACxBD,EAAQ,GAAA,CAAII,CAAI,GAChBJ,CAAAA,CAAQ,GAAA,CAAII,EAAK,CAAC,CAAA,CAEtB,IAAMC,CAAAA,CAAIL,CAAAA,CAAQ,IAAII,CAAI,CAAA,CAC1BJ,EAAQ,GAAA,CAAII,CAAAA,CAAKC,EAAE,CAAC,EACxB,CACJ,CACJ,CAEA,IAAIC,CAAAA,CAAQ,CAAA,CACRC,EACJ,OAAAP,CAAAA,CAAQ,QAAQ,CAACD,CAAAA,CAAES,IAAI,CAChBT,CAAAA,CAAE,GACFS,CAAAA,CAAE,MAAA,CAAOF,IACVC,CAAAA,CAAQC,CAAAA,CACRF,EAAQP,CAAAA,EAEd,CAAC,EACM,CAACQ,CAAAA,CAAMD,CAAK,CAErB,KC5DaG,CAAAA,CAAN,KAAwB,CAM3B,WAAA,CAAmBC,CAAAA,CAAmBC,EAA4B,CAA/C,IAAA,CAAA,cAAA,CAAAD,EACf,IAAA,CAAK,IAAA,CAAOA,EAAe,IAAA,CAAK,IAAA,CAAK,GAAG,CAAA,CACxC,IAAA,CAAK,MAAM,IAAA,CAAK,IAAA,CAAK,IAAI,CAAA,CACzB,IAAA,CAAK,QAAU,MAAA,CAAO,MAAA,CAAO,CACzB,UAAA,CAAc,CAAA,CACd,aAAc,GAAA,CACd,MAAA,CAAO,EACX,CAAA,CAAEC,CAAO,EACb,CAbA,MAAiB,EAAC,CAClB,QAAkB,KAAA,CACV,QAAA,CACR,KACA,OAAA,CAaA,KAAA,EAAO,CACH,IAAA,CAAK,OAAA,CAAU,KACf,IAAA,CAAK,KAAA,CAAM,KAAK,IAAA,CAAK,IAAI,EACzB,IAAA,CAAK,QAAA,CAAW,KAAK,cAAA,CAAe,KAAA,CAAM,MAAOC,CAAAA,EAAY,CACtD,KAAK,KAAA,CAAM,MAAA,CAAO,KACjB,IAAA,CAAK,KAAA,CAAM,KAAKA,CAAAA,CAAM,IAAA,CAAK,KAAK,GAAG,CAAC,EAE5C,CAAA,CAAE,CAAC,SAAS,MAAM,CAAC,EACvB,CAkBQ,kBAAA,EAAoB,CACxB,GAAM,CAACL,CAAAA,CAAMD,CAAK,EAAId,CAAAA,CAAkB,IAAA,CAAK,MAAM,IAAA,CAAK,IAAI,EACtD,CAAE,UAAA,CAAAqB,EAAW,UAAA,CAAAC,CAAW,EAAI,IAAA,CAAK,OAAA,CACvC,GAAG,EAAAR,CAAAA,CAAMQ,KACT,IAAA,CAAK,cAAA,CAAe,MAAM,GAAA,CAAI,CAAA,yBAAA,EAA4B,KAAK,cAAA,CAAe,QAAA,EAAU,CAAA,GAAA,EAAMP,CAAK,GAAG,MAAM,CAAA,CACzG,OAAOM,CAAAA,EAAe,UAAA,CAAA,CAAW,CAChC,IAAME,CAAAA,CAASF,EAAWN,CAAAA,CAAM,IAAA,CAAK,cAAc,CAAA,CACnD,GAAGQ,IAAS,QAAA,CACR,OACE,GAAGA,CAAAA,GAAS,SAAA,CACd,KAAK,cAAA,CAAe,MAAA,CAAS,WAE7B,MAAM,IAAI,MAAM,CAAA,sBAAA,EAAyB,IAAA,CAAK,eAAe,QAAA,EAAU,MAAMR,CAAK,CAAA,CAAE,CAE5F,CACJ,CACA,QAAQ,CACJ,GAAG,KAAK,KAAA,CAAM,MAAA,CAAO,KAAK,OAAA,CAAQ,YAAA,CAAa,CAC3C,IAAA,CAAK,QAAA,CAAS,KAAI,CAClB,GAAG,CACC,IAAA,CAAK,kBAAA,GACT,CAAA,OAAC,CACG,KAAK,KAAA,CAAM,GACf,CACJ,CACJ,CACJ,EAGA,SAASS,EAAwBL,CAAAA,CAAkC,CAC/D,OAAO,SAA2BM,CAAAA,CAAU,CACxC,GAAM,CAAE,kBAAAC,CAAkB,CAAA,CAAID,EAAM,OAAA,CACjC,OAAOC,GAAsB,UAAA,CAE5BD,CAAAA,CAAM,IAAI,CAAA,MAAA,EAASA,CAAAA,CAAM,EAAE,CAAA,wEAAA,CAAA,CAA2E,MAAM,GAE5GA,CAAAA,CAAM,OAAA,CAAQ,kBAAqBE,CAAAA,EAAqB,CAEpD,GAAGA,CAAAA,CAAe,IAAA,GAAO,YAAcA,CAAAA,CAAe,KAAA,CAAM,CACxDA,CAAAA,CAAe,cAAA,CAAiB,IAAIV,CAAAA,CAAmBU,CAAAA,CAAeR,CAAO,CAAA,CAC7E,IAAMS,EAASD,CAAAA,CAAe,GAAA,CAE9BA,EAAe,GAAA,CAAA,CAAO,eAAeR,EAAY,CAE7C,OAAGA,GAAWA,CAAAA,CAAQ,KAAA,GAAQ,KAC1BQ,CAAAA,CAAe,cAAA,CAAe,OAAM,CAEpCA,CAAAA,CAAe,eAAe,MAAA,EAAO,CAElC,MAAMC,CAAAA,CAAO,KAAA,CAAMD,EAAeR,CAAO,CACpD,GAAG,IAAA,CAAKQ,CAAc,EAC1B,CACJ,CAAA,CACAF,EAAM,GAAA,CAAI,wCAAwC,GAE1D,CAEJ,CAGO,SAASI,CAAAA,CAAyBV,CAAAA,CAAkC,CAEnE,UAAA,CAAW,qBAAA,GAEX,UAAA,CAAW,qBAAA,CAAsB,EAAC,CAAA,CAGtC,UAAA,CAAW,sBAAsB,IAAA,CAAKK,CAAAA,CAAwBL,CAAO,CAAC,EAE1E,CCrIA,IAAMW,EAAe,EAErB,CAGaC,EAAN,KAAuB,CAClB,WACA,UAAA,CAAqB,KAAA,CAC7B,OAAS,IAAI7C,CAAAA,CACb,aAAa,CACT,IAAA,CAAK,UACT,CACA,IAAIuC,CAAAA,CAAU,CACV,KAAK,MAAA,CAAO,GAAA,CAAIA,EAAM,EAAA,CAAGA,CAAK,EAC9BA,CAAAA,CAAM,QAAA,CAAS,MAAM,CAACO,CAAAA,CAAYC,IAAW,CACtCD,CAAAA,CAAQ,OAAO,KAAA,EAClB,IAAA,CAAK,WAAW,QAAA,CAAS,CACrB,KAAK,CAAA,EAAGA,CAAAA,CAAQ,IAAI,CAAA,CAAA,EAAIC,CAAI,GAC5B,KAAA,CAAAR,CAAAA,CACA,QAAAO,CACJ,CAAC,EACL,CAAC,CAAA,CACD,KAAK,UAAA,CAAW,QAAA,CAAS,CACrB,IAAA,CAAK,eAAA,CACL,MAAAP,CACJ,CAAC,EACL,CACA,MAAA,CAAOA,EAAU,CACT,IAAA,CAAK,OAAO,GAAA,CAAIA,CAAAA,CAAM,EAAE,CAAA,EACxB,IAAA,CAAK,OAAO,MAAA,CAAOA,CAAAA,CAAM,EAAE,EAEnC,CACQ,QAAQS,CAAAA,CAAeJ,CAAAA,CAAcK,EAAW,CACpD,OAAGA,EAAO,IAAA,CAAK,UAAA,CAAW,IAAI,CAAA,CAAUD,CAAAA,CACrCC,EAAO,IAAA,GAAO,eAAA,CACN,CACH,GAAGD,CAAAA,CACH,CAAC,CAAA,UAAA,EAAaC,CAAAA,CAAO,MAAM,EAAE,CAAA,CAAA,CAAG,EAAE,CAAC,GAAGA,EAAO,KAAA,CAAM,OAAA,EAAS,CAChE,CAAA,CAEO,CACH,GAAGD,CAAAA,CACH,CAAC,CAAA,UAAA,EAAaC,CAAAA,CAAO,MAAM,EAAE,CAAA,CAAA,CAAG,EAAE,CAAC,GAAGA,EAAO,KAAA,CAAM,OAAA,EAAS,CAChE,CAER,CACQ,OAAA,EAAS,CACV,KAAK,UAAA,GACR,IAAA,CAAK,WAAaC,wBAAAA,CACd,IAAA,CAAK,QAEL,MAAA,CAAO,4BAAA,EAAgC,OAAO,4BAAA,EAClD,EACA,IAAA,CAAK,UAAA,CAAa,KAClB,OAAA,CAAQ,IAAA,CAAK,2EAA2E,YAAA,CAAa,EAAE,GAC3G,CACJ,EAEO,SAASC,CAAAA,EAAS,CAEjB,WAAW,sBAAA,GAAwB,UAAA,CAAW,uBAAyB,IAAIN,CAAAA,EACnF,CAQAM,CAAAA,EAAQ","file":"index.js","sourcesContent":["\nexport class WeakObjectMap<T extends object> {\n private map: Map<string, WeakRef<T>>;\n private finalizationRegistry: FinalizationRegistry<string>;\n \n constructor() {\n this.map = new Map();\n this.finalizationRegistry = new FinalizationRegistry((key) => {\n this.map.delete(key);\n });\n }\n \n set(key: string, value: T): void {\n const weakRef = new WeakRef(value);\n this.map.set(key, weakRef);\n this.finalizationRegistry.register(value, key);\n }\n \n get(key: string): T | undefined {\n const weakRef = this.map.get(key);\n return weakRef ? weakRef.deref() : undefined;\n }\n \n delete(key: string): boolean {\n return this.map.delete(key);\n }\n \n has(key: string): boolean {\n const weakRef = this.map.get(key);\n return weakRef ? weakRef.deref() !== undefined : false;\n }\n}\n/**\n * 判定两个值是否相等\n * \n * 如果两个值都是对象，则判断两个对象是否相等\n * 如果两个值都是数组，则判断两个数组的值是否相等\n * \n */\n\nexport function isPathEq(a:string[] | undefined,b:string[] | undefined):boolean{\n if(!a) return false\n if(!b) return false\n if(a.length!==b.length) return false\n return a.every((item,index)=>item===b[index])\n}\n/**\n * 判断一个路径destPath是否包含另一个路径basePath判断\n * @param basePath \n * @param destPath \n */\nexport function pathStartsWith(basePath:string[],destPath:string[]){\n if(basePath.length>destPath.length) return false\n return basePath.every((p,i)=>{\n return p===destPath[i]\n })\n}\n\nexport function analysisCyclePath(steps:string[],curPath:string):[string | undefined,number] {\n // 使用curPath将steps分割为多个数组\n const indexs = steps.reduce((prev,cur,index)=>{\n if(cur===curPath) prev.push(index) \n return prev\n },[] as number[])\n\n const groups = indexs.map((v,i)=>{\n if(i<indexs.length-1){\n return steps.slice(v,indexs[i+1])\n }else{\n return steps.slice(v)\n } \n })\n\n // 找到groups相同的分组\n const results = new Map<string,number>()\n for(let i=0;i<groups.length;i++){\n const group = groups[i]\n if(group.length<2) continue\n for(let j=i+1;j<groups.length;j++){\n const group2 = groups[j]\n if(isPathEq(group,group2) || pathStartsWith(group,group2)){\n const gKey = group.join('->')\n if(!results.has(gKey)){\n results.set(gKey,1)\n }\n const n = results.get(gKey)! \n results.set(gKey,n+1)\n }\n }\n }\n // 找到results里面路径最长的\n let count = 0\n let paths = undefined\n results.forEach((v,k)=>{\n if(v<3) return\n if(k.length>count){\n paths = k\n count = v \n }\n }) \n return [paths,count]\n\n}\n","/**\n * \n * import { installCycleDetectExtend } from \"@autostore/devtools\"\n * \n * installCycleDetectExtend({....})\n * \n * \n */\nimport { analysisCyclePath } from \"./utils\"\n\n\nexport type CycleDetectExtendOptions = { \n /**\n * 当检测到多少个循环时视为循环依赖 \n */\n cycleCount?:number\n /**\n * \n * 当检测时间操作数量达到此值时，停止检测\n * \n */\n maxOpereates?:number\n /**\n * 指定仅作用于指定的store\n * =[]代表所有store均生效\n */\n stores?:string[]\n /**\n * \n */\n onDetected?:(paths:string[],computedObject:any)=>'ignore'|'throw'|'disable' \n\n}\n\n/**\n * \n * - 在异步计算第一次执行时调用\n * cycleDetector.start()\n * \n * \n * \n */\nexport class AsyncCycleDetector{\n steps:string[] = []\n running:boolean = false \n private _watcher:any\n path:string\n options: Record<string,any>\n constructor(public computedObject:any,options?:Record<string,any>){\n this.path = computedObject.path.join('.')\n this.steps.push(this.path)\n this.options = Object.assign({\n cycleCount : 8,\n maxOpereates: 200,\n stores:[]\n },options)\n } \n /**\n * 本方法应该在异步函数第一次运行时调用\n */\n start(){\n this.running = true\n this.steps.push(this.path)\n this._watcher = this.computedObject.store.watch((event:any)=>{\n if(this.steps.length<500){\n this.steps.push(event.path.join('.'))\n }\n },{operates:'read'}) \n }\n /**\n * \n * 开始检测是否存在循环依赖\n * \n * \n * [\"a\",'d','c','b','a','d','c','b','a']\n * \n * \n * 编写一个函数，检测是否存在循环依赖\n * \n * 逻辑如下：\n * \n * 对this.steps里面是否存在连续的相同的路径，如果存在，则表示存在循环依赖\n * \n * \n * @returns \n */\n private analysisCycleSteps(){\n const [paths,count] = analysisCyclePath(this.steps,this.path)\n const { onDetected,cycleCount } = this.options\n if(count<cycleCount) return\n this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${paths}`,'warn')\n if(typeof(onDetected )==='function'){\n const result = onDetected(paths,this.computedObject)\n if(result==='ignore'){\n return\n }else if(result==='disable') {\n this.computedObject.enable = false\n }else{\n throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${paths}`)\n }\n } \n } \n detect(){\n if(this.steps.length>this.options.maxOpereates){\n this._watcher.off()\n try{\n this.analysisCycleSteps()\n }finally{ \n this.steps=[]\n }\n }\n }\n}\n\n\nfunction createCycleDetectExtend(options?:CycleDetectExtendOptions){\n return function cycleDetectExtend(store:any){\n const { onObserverCreated } = store.options\n if(typeof(onObserverCreated) ==='function'){ \n // 当store的onObserverCreated选项已经配置时，cycleDetectExtend不能生效\n store.log(`Store<${store.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,\"warn\")\n }else{\n store.options.onObserverCreated = (observerObject:any)=>{\n // 只对异步计算属性进行循环依赖检测\n if(observerObject.type==='computed' && observerObject.async){\n observerObject._cycleDetector = new AsyncCycleDetector(observerObject,options)\n const oldRun = observerObject.run\n // 封装原始的run方法\n observerObject.run = (async function(options:any){\n // 在第一次运行时启动循环依赖检测\n if(options && options.first===true){\n observerObject._cycleDetector.start()\n }else{\n observerObject._cycleDetector.detect() \n }\n return await oldRun.apply(observerObject,options)\n }).bind(observerObject)\n }\n }\n store.log(\"cycleDetectExtend is already installed\")\n }\n } \n\n}\n\n\nexport function installCycleDetectExtend(options?:CycleDetectExtendOptions){\n // @ts-ignore\n if(!globalThis.__AUTOSTORE_EXTENDS__){\n // @ts-ignore\n globalThis.__AUTOSTORE_EXTENDS__=[]\n }\n // @ts-ignore\n globalThis.__AUTOSTORE_EXTENDS__.push(createCycleDetectExtend(options))\n \n}\n ","/**\n * \n * 基于开发工具\n * \n * Redux DevTools 是一个实用工具，用于开发和调试 Redux 应用程序。\n * AutoStore是基于Redux DevTools 的简单包装，可以让开发者使用Redux DevTools\n * 来查看AutoStore的状态变化 \n * \n * import { createStore } from \"@autostorejs/react\"\n * import { install } from \"@autostorejs/devtools\"\n * \n * \n * const store = createStore({})\n * \n * install()\n * \n */\n\n//@ts-ignore\nimport { legacy_createStore as createStore } from \"redux\"\nimport { WeakObjectMap } from \"./utils\"\n \nconst initialState = {\n \n}\n\n\nexport class AutoStoreDevTools{\n private reduxStore:any\n private _installed:boolean = false\n stores = new WeakObjectMap()\n constructor(){\n this.install()\n }\n add(store:any){ \n this.stores.set(store.id,store)\n store.operates.onAny((payload:any,type:any)=>{ \n if(payload.type==='get') return \n this.reduxStore.dispatch({\n type:`${payload.type}@${type}`,\n store,\n payload \n })\n })\n this.reduxStore.dispatch({\n type:\"__ADD_STORE__\",\n store\n })\n }\n remove(store:any){ \n if( this.stores.has(store.id)){\n this.stores.delete(store.id)\n }\n }\n private reducer(state:object = initialState, action:any){\n if(action.type.startsWith(\"@@\")) return state\n if(action.type==='__ADD_STORE__') {\n return {\n ...state,\n [`AutoStore<${action.store.id}>`]:{...action.store.getSnap()}\n }\n }else{\n return {\n ...state,\n [`AutoStore<${action.store.id}>`]:{...action.store.getSnap()}\n }\n } \n }\n private install(){\n if(this._installed) return \n this.reduxStore = createStore(\n this.reducer,\n // @ts-ignore\n window.__REDUX_DEVTOOLS_EXTENSION__ && window.__REDUX_DEVTOOLS_EXTENSION__()\n ); \n this._installed = true\n console.info('%c AutoStoreDevTools installed. Please open <Redux devtools> to view. %c',\"color:red;\",'')\n }\n}\n\nexport function install(){\n // @ts-ignore\n if(!globalThis.__AUTOSTORE_DEVTOOLS__) globalThis.__AUTOSTORE_DEVTOOLS__ = new AutoStoreDevTools() \n} \n\ndeclare global{\n // @ts-ignore\n var __AUTOSTORE_DEVTOOLS__ : AutoStoreDevTools\n}\n\n\ninstall()\n\n"]} |
+1
-1
@@ -1,2 +0,2 @@ | ||
| import {legacy_createStore}from'redux';var u=class{map;finalizationRegistry;constructor(){this.map=new Map,this.finalizationRegistry=new FinalizationRegistry(t=>{this.map.delete(t);});}set(t,e){let s=new WeakRef(e);this.map.set(t,s),this.finalizationRegistry.register(e,t);}get(t){let e=this.map.get(t);return e?e.deref():void 0}delete(t){return this.map.delete(t)}has(t){let e=this.map.get(t);return e?e.deref()!==void 0:false}};function y(i,t){return !i||!t||i.length!==t.length?false:i.every((e,s)=>e===t[s])}function E(i,t){return i.length>t.length?false:i.every((e,s)=>e===t[s])}function g(i,t){let e=i.reduce((r,o,c)=>(o===t&&r.push(c),r),[]),s=e.map((r,o)=>o<e.length-1?i.slice(r,e[o+1]):i.slice(r)),n=new Map;for(let r=0;r<s.length;r++){let o=s[r];if(!(o.length<2))for(let c=r+1;c<s.length;c++){let f=s[c];if(y(o,f)||E(o,f)){let p=o.join("->");n.has(p)||n.set(p,1);let _=n.get(p);n.set(p,_+1);}}}let a=0,l;return n.forEach((r,o)=>{r<3||o.length>a&&(l=o,a=r);}),[l,a]}var h=class{constructor(t,e){this.computedObject=t;this.path=t.path.join("."),this.steps.push(this.path),this.options=Object.assign({cycleCount:8,maxOpereates:200,stores:[]},e);}steps=[];running=false;_watcher;path;options;start(){this.running=true,this.steps.push(this.path),this._watcher=this.computedObject.store.watch(t=>{this.steps.length<500&&this.steps.push(t.path.join("."));},{operates:"read"});}analysisCycleSteps(){let[t,e]=g(this.steps,this.path),{onDetected:s,cycleCount:n}=this.options;if(!(e<n)&&(this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${t}`,"warn"),typeof s=="function")){let a=s(t,this.computedObject);if(a==="ignore")return;if(a==="disable")this.computedObject.enable=false;else throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${t}`)}}detect(){if(this.steps.length>this.options.maxOpereates){this._watcher.off();try{this.analysisCycleSteps();}finally{this.steps=[];}}}};function S(i){return function(e){let{onObserverCreated:s}=e.options;typeof s=="function"?e.log(`Store<${e.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,"warn"):(e.options.onObserverCreated=n=>{if(n.type==="computed"&&n.async){n._cycleDetector=new h(n,i);let a=n.run;n.run=async function(l){return l&&l.first===true?n._cycleDetector.start():n._cycleDetector.detect(),await a.apply(n,l)}.bind(n);}},e.log("cycleDetectExtend is already installed"));}}function w(i){globalThis.__AUTOSTORE_EXTENDS__||(globalThis.__AUTOSTORE_EXTENDS__=[]),globalThis.__AUTOSTORE_EXTENDS__.push(S(i));}var T={},d=class{reduxStore;_installed=false;stores=new u;constructor(){this.install();}add(t){this.stores.set(t.id,t),t.operates.onAny((e,s)=>{e.type!=="get"&&this.reduxStore.dispatch({type:`${e.type}@${s}`,store:t,payload:e});}),this.reduxStore.dispatch({type:"__ADD_STORE__",store:t});}remove(t){this.stores.has(t.id)&&this.stores.delete(t.id);}reducer(t=T,e){return e.type.startsWith("@@")?t:e.type==="__ADD_STORE__"?{...t,[`AutoStore<${e.store.id}>`]:{...e.store.getSnap()}}:{...t,[`AutoStore<${e.store.id}>`]:{...e.store.getSnap()}}}install(){this._installed||(this.reduxStore=legacy_createStore(this.reducer,window.__REDUX_DEVTOOLS_EXTENSION__&&window.__REDUX_DEVTOOLS_EXTENSION__()),this._installed=true,console.info("%c AutoStoreDevTools installed. Please open <Redux devtools> to view. %c","color:red;",""));}};function m(){globalThis.__AUTOSTORE_DEVTOOLS__||(globalThis.__AUTOSTORE_DEVTOOLS__=new d);}m();export{h as AsyncCycleDetector,d as AutoStoreDevTools,m as install,w as installCycleDetectExtend};//# sourceMappingURL=index.mjs.map | ||
| import {legacy_createStore}from'redux';var u=class{map;finalizationRegistry;constructor(){this.map=new Map,this.finalizationRegistry=new FinalizationRegistry(t=>{this.map.delete(t);});}set(t,e){let s=new WeakRef(e);this.map.set(t,s),this.finalizationRegistry.register(e,t);}get(t){let e=this.map.get(t);return e?e.deref():void 0}delete(t){return this.map.delete(t)}has(t){let e=this.map.get(t);return e?e.deref()!==void 0:false}};function y(i,t){return !i||!t||i.length!==t.length?false:i.every((e,s)=>e===t[s])}function E(i,t){return i.length>t.length?false:i.every((e,s)=>e===t[s])}function g(i,t){let e=i.reduce((r,o,c)=>(o===t&&r.push(c),r),[]),s=e.map((r,o)=>o<e.length-1?i.slice(r,e[o+1]):i.slice(r)),n=new Map;for(let r=0;r<s.length;r++){let o=s[r];if(!(o.length<2))for(let c=r+1;c<s.length;c++){let f=s[c];if(y(o,f)||E(o,f)){let p=o.join("->");n.has(p)||n.set(p,1);let _=n.get(p);n.set(p,_+1);}}}let a=0,l;return n.forEach((r,o)=>{r<3||o.length>a&&(l=o,a=r);}),[l,a]}var h=class{constructor(t,e){this.computedObject=t;this.path=t.path.join("."),this.steps.push(this.path),this.options=Object.assign({cycleCount:8,maxOpereates:200,stores:[]},e);}steps=[];running=false;_watcher;path;options;start(){this.running=true,this.steps.push(this.path),this._watcher=this.computedObject.store.watch(t=>{this.steps.length<500&&this.steps.push(t.path.join("."));},{operates:"read"});}analysisCycleSteps(){let[t,e]=g(this.steps,this.path),{onDetected:s,cycleCount:n}=this.options;if(!(e<n)&&(this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${t}`,"warn"),typeof s=="function")){let a=s(t,this.computedObject);if(a==="ignore")return;if(a==="disable")this.computedObject.enable=false;else throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${t}`)}}detect(){if(this.steps.length>this.options.maxOpereates){this._watcher.off();try{this.analysisCycleSteps();}finally{this.steps=[];}}}};function S(i){return function(e){let{onObserverCreated:s}=e.options;typeof s=="function"?e.log(`Store<${e.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,"warn"):(e.options.onObserverCreated=n=>{if(n.type==="computed"&&n.async){n._cycleDetector=new h(n,i);let a=n.run;n.run=(async function(l){return l&&l.first===true?n._cycleDetector.start():n._cycleDetector.detect(),await a.apply(n,l)}).bind(n);}},e.log("cycleDetectExtend is already installed"));}}function w(i){globalThis.__AUTOSTORE_EXTENDS__||(globalThis.__AUTOSTORE_EXTENDS__=[]),globalThis.__AUTOSTORE_EXTENDS__.push(S(i));}var T={},d=class{reduxStore;_installed=false;stores=new u;constructor(){this.install();}add(t){this.stores.set(t.id,t),t.operates.onAny((e,s)=>{e.type!=="get"&&this.reduxStore.dispatch({type:`${e.type}@${s}`,store:t,payload:e});}),this.reduxStore.dispatch({type:"__ADD_STORE__",store:t});}remove(t){this.stores.has(t.id)&&this.stores.delete(t.id);}reducer(t=T,e){return e.type.startsWith("@@")?t:e.type==="__ADD_STORE__"?{...t,[`AutoStore<${e.store.id}>`]:{...e.store.getSnap()}}:{...t,[`AutoStore<${e.store.id}>`]:{...e.store.getSnap()}}}install(){this._installed||(this.reduxStore=legacy_createStore(this.reducer,window.__REDUX_DEVTOOLS_EXTENSION__&&window.__REDUX_DEVTOOLS_EXTENSION__()),this._installed=true,console.info("%c AutoStoreDevTools installed. Please open <Redux devtools> to view. %c","color:red;",""));}};function m(){globalThis.__AUTOSTORE_DEVTOOLS__||(globalThis.__AUTOSTORE_DEVTOOLS__=new d);}m();export{h as AsyncCycleDetector,d as AutoStoreDevTools,m as install,w as installCycleDetectExtend};//# sourceMappingURL=index.mjs.map | ||
| //# sourceMappingURL=index.mjs.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/utils.ts","../src/cycleDetectExtend.ts","../src/devTools.ts"],"names":["WeakObjectMap","key","value","weakRef","isPathEq","a","b","item","index","pathStartsWith","basePath","destPath","p","i","analysisCyclePath","steps","curPath","indexs","prev","cur","groups","v","results","group","j","group2","gKey","n","count","paths","k","AsyncCycleDetector","computedObject","options","event","onDetected","cycleCount","result","createCycleDetectExtend","store","onObserverCreated","observerObject","oldRun","installCycleDetectExtend","initialState","AutoStoreDevTools","payload","type","state","action","createStore","install"],"mappings":"uCACO,IAAMA,EAAN,KAAsC,CACjC,IACA,oBAER,CAAA,WAAA,EAAc,CACZ,IAAK,CAAA,GAAA,CAAM,IAAI,GACf,CAAA,IAAA,CAAK,qBAAuB,IAAI,oBAAA,CAAsBC,GAAQ,CAC5D,IAAA,CAAK,IAAI,MAAOA,CAAAA,CAAG,EACrB,CAAC,EACH,CAEA,GAAIA,CAAAA,CAAAA,CAAaC,EAAgB,CAC/B,IAAMC,EAAU,IAAI,OAAA,CAAQD,CAAK,CACjC,CAAA,IAAA,CAAK,IAAI,GAAID,CAAAA,CAAAA,CAAKE,CAAO,CACzB,CAAA,IAAA,CAAK,qBAAqB,QAASD,CAAAA,CAAAA,CAAOD,CAAG,EAC/C,CAEA,IAAIA,CAA4B,CAAA,CAC9B,IAAME,CAAU,CAAA,IAAA,CAAK,IAAI,GAAIF,CAAAA,CAAG,EAChC,OAAOE,CAAAA,CAAUA,EAAQ,KAAM,EAAA,CAAI,MACrC,CAEA,MAAA,CAAOF,EAAsB,CAC3B,OAAO,KAAK,GAAI,CAAA,MAAA,CAAOA,CAAG,CAC5B,CAEA,IAAIA,CAAsB,CAAA,CACxB,IAAME,CAAU,CAAA,IAAA,CAAK,IAAI,GAAIF,CAAAA,CAAG,EAChC,OAAOE,CAAAA,CAAUA,EAAQ,KAAM,EAAA,GAAM,OAAY,KACnD,CACJ,EASO,SAASC,CAAAA,CAASC,EAAuBC,CAA+B,CAAA,CAG7E,OAFG,CAACD,CAAAA,EACD,CAACC,CACDD,EAAAA,CAAAA,CAAE,SAASC,CAAE,CAAA,MAAA,CAAe,MACxBD,CAAE,CAAA,KAAA,CAAM,CAACE,CAAKC,CAAAA,CAAAA,GAAQD,IAAOD,CAAEE,CAAAA,CAAK,CAAC,CAC9C,CAMO,SAASC,CAAeC,CAAAA,CAAAA,CAAkBC,EAAkB,CACjE,OAAGD,EAAS,MAAOC,CAAAA,CAAAA,CAAS,OAAe,KACpCD,CAAAA,CAAAA,CAAS,MAAM,CAACE,CAAAA,CAAEC,IACdD,CAAID,GAAAA,CAAAA,CAASE,CAAC,CACxB,CACH,CAEO,SAASC,CAAAA,CAAkBC,EAAeC,CAA4C,CAAA,CAE3F,IAAMC,CAASF,CAAAA,CAAAA,CAAM,OAAO,CAACG,CAAAA,CAAKC,EAAIX,CAC/BW,IAAAA,CAAAA,GAAMH,GAASE,CAAK,CAAA,IAAA,CAAKV,CAAK,CAC1BU,CAAAA,CAAAA,CAAAA,CACT,EAAc,CAAA,CAEVE,EAASH,CAAO,CAAA,GAAA,CAAI,CAACI,CAAER,CAAAA,CAAAA,GACtBA,EAAEI,CAAO,CAAA,MAAA,CAAO,EACRF,CAAM,CAAA,KAAA,CAAMM,EAAEJ,CAAOJ,CAAAA,CAAAA,CAAE,CAAC,CAAC,CAAA,CAEzBE,EAAM,KAAMM,CAAAA,CAAC,CAE3B,CAGKC,CAAAA,CAAAA,CAAU,IAAI,GAAA,CACpB,QAAQT,CAAE,CAAA,CAAA,CAAEA,EAAEO,CAAO,CAAA,MAAA,CAAOP,IAAI,CAC5B,IAAMU,EAAQH,CAAOP,CAAAA,CAAC,EACtB,GAAG,EAAAU,EAAM,MAAO,CAAA,CAAA,CAAA,CAChB,QAAQC,CAAEX,CAAAA,CAAAA,CAAE,EAAEW,CAAEJ,CAAAA,CAAAA,CAAO,OAAOI,CAAI,EAAA,CAAA,CAC9B,IAAMC,CAASL,CAAAA,CAAAA,CAAOI,CAAC,CACvB,CAAA,GAAGpB,EAASmB,CAAME,CAAAA,CAAM,GAAKhB,CAAec,CAAAA,CAAAA,CAAME,CAAM,CAAE,CAAA,CACtD,IAAMC,CAAOH,CAAAA,CAAAA,CAAM,KAAK,IAAI,CAAA,CACxBD,EAAQ,GAAII,CAAAA,CAAI,GAChBJ,CAAQ,CAAA,GAAA,CAAII,EAAK,CAAC,CAAA,CAEtB,IAAMC,CAAIL,CAAAA,CAAAA,CAAQ,IAAII,CAAI,CAAA,CAC1BJ,EAAQ,GAAII,CAAAA,CAAAA,CAAKC,EAAE,CAAC,EACxB,CACJ,CACJ,CAEA,IAAIC,CAAQ,CAAA,CAAA,CACRC,EACJ,OAAAP,CAAAA,CAAQ,QAAQ,CAACD,CAAAA,CAAES,IAAI,CAChBT,CAAAA,CAAE,GACFS,CAAE,CAAA,MAAA,CAAOF,IACVC,CAAQC,CAAAA,CAAAA,CACRF,EAAQP,CAEd,EAAA,CAAC,EACM,CAACQ,CAAAA,CAAMD,CAAK,CAErB,KC5DaG,CAAN,CAAA,KAAwB,CAM3B,WAAmBC,CAAAA,CAAAA,CAAmBC,EAA4B,CAA/C,IAAA,CAAA,cAAA,CAAAD,EACf,IAAK,CAAA,IAAA,CAAOA,EAAe,IAAK,CAAA,IAAA,CAAK,GAAG,CACxC,CAAA,IAAA,CAAK,MAAM,IAAK,CAAA,IAAA,CAAK,IAAI,CACzB,CAAA,IAAA,CAAK,QAAU,MAAO,CAAA,MAAA,CAAO,CACzB,UAAc,CAAA,CAAA,CACd,aAAc,GACd,CAAA,MAAA,CAAO,EACX,CAAA,CAAEC,CAAO,EACb,CAbA,MAAiB,EAAC,CAClB,QAAkB,KACV,CAAA,QAAA,CACR,KACA,OAaA,CAAA,KAAA,EAAO,CACH,IAAK,CAAA,OAAA,CAAU,KACf,IAAK,CAAA,KAAA,CAAM,KAAK,IAAK,CAAA,IAAI,EACzB,IAAK,CAAA,QAAA,CAAW,KAAK,cAAe,CAAA,KAAA,CAAM,MAAOC,CAAY,EAAA,CACtD,KAAK,KAAM,CAAA,MAAA,CAAO,KACjB,IAAK,CAAA,KAAA,CAAM,KAAKA,CAAM,CAAA,IAAA,CAAK,KAAK,GAAG,CAAC,EAE5C,CAAE,CAAA,CAAC,SAAS,MAAM,CAAC,EACvB,CAkBQ,kBAAA,EAAoB,CACxB,GAAM,CAACL,CAAMD,CAAAA,CAAK,EAAId,CAAkB,CAAA,IAAA,CAAK,MAAM,IAAK,CAAA,IAAI,EACtD,CAAE,UAAA,CAAAqB,EAAW,UAAAC,CAAAA,CAAW,EAAI,IAAK,CAAA,OAAA,CACvC,GAAG,EAAAR,CAAAA,CAAMQ,KACT,IAAK,CAAA,cAAA,CAAe,MAAM,GAAI,CAAA,CAAA,yBAAA,EAA4B,KAAK,cAAe,CAAA,QAAA,EAAU,CAAMP,GAAAA,EAAAA,CAAK,GAAG,MAAM,CAAA,CACzG,OAAOM,CAAe,EAAA,UAAA,CAAA,CAAW,CAChC,IAAME,CAAAA,CAASF,EAAWN,CAAM,CAAA,IAAA,CAAK,cAAc,CACnD,CAAA,GAAGQ,IAAS,QACR,CAAA,OACE,GAAGA,CAAS,GAAA,SAAA,CACd,KAAK,cAAe,CAAA,MAAA,CAAS,WAEvB,MAAA,IAAI,MAAM,CAAyB,sBAAA,EAAA,IAAA,CAAK,eAAe,QAAS,EAAC,MAAMR,CAAK,CAAA,CAAE,CAE5F,CACJ,CACA,QAAQ,CACJ,GAAG,KAAK,KAAM,CAAA,MAAA,CAAO,KAAK,OAAQ,CAAA,YAAA,CAAa,CAC3C,IAAK,CAAA,QAAA,CAAS,KACd,CAAA,GAAG,CACC,IAAK,CAAA,kBAAA,GACT,CAAC,OAAA,CACG,KAAK,KAAM,CAAA,GACf,CACJ,CACJ,CACJ,EAGA,SAASS,EAAwBL,CAAkC,CAAA,CAC/D,OAAO,SAA2BM,CAAAA,CAAU,CACxC,GAAM,CAAE,kBAAAC,CAAkB,CAAA,CAAID,EAAM,OACjC,CAAA,OAAOC,GAAsB,UAE5BD,CAAAA,CAAAA,CAAM,IAAI,CAASA,MAAAA,EAAAA,CAAAA,CAAM,EAAE,CAA2E,wEAAA,CAAA,CAAA,MAAM,GAE5GA,CAAM,CAAA,OAAA,CAAQ,kBAAqBE,CAAqB,EAAA,CAEpD,GAAGA,CAAe,CAAA,IAAA,GAAO,YAAcA,CAAe,CAAA,KAAA,CAAM,CACxDA,CAAe,CAAA,cAAA,CAAiB,IAAIV,CAAmBU,CAAAA,CAAAA,CAAeR,CAAO,CAC7E,CAAA,IAAMS,EAASD,CAAe,CAAA,GAAA,CAE9BA,EAAe,GAAO,CAAA,eAAeR,EAAY,CAE7C,OAAGA,GAAWA,CAAQ,CAAA,KAAA,GAAQ,KAC1BQ,CAAe,CAAA,cAAA,CAAe,OAE9BA,CAAAA,CAAAA,CAAe,eAAe,MAAO,EAAA,CAElC,MAAMC,CAAO,CAAA,KAAA,CAAMD,EAAeR,CAAO,CACpD,EAAG,IAAKQ,CAAAA,CAAc,EAC1B,CACJ,CAAA,CACAF,EAAM,GAAI,CAAA,wCAAwC,GAE1D,CAEJ,CAGO,SAASI,CAAyBV,CAAAA,CAAAA,CAAkC,CAEnE,UAAW,CAAA,qBAAA,GAEX,UAAW,CAAA,qBAAA,CAAsB,EAGrC,CAAA,CAAA,UAAA,CAAW,sBAAsB,IAAKK,CAAAA,CAAAA,CAAwBL,CAAO,CAAC,EAE1E,CCrIA,IAAMW,EAAe,EAErB,CAGaC,EAAN,KAAuB,CAClB,WACA,UAAqB,CAAA,KAAA,CAC7B,OAAS,IAAI7C,CAAAA,CACb,aAAa,CACT,IAAA,CAAK,UACT,CACA,IAAIuC,CAAU,CAAA,CACV,KAAK,MAAO,CAAA,GAAA,CAAIA,EAAM,EAAGA,CAAAA,CAAK,EAC9BA,CAAM,CAAA,QAAA,CAAS,MAAM,CAACO,CAAAA,CAAYC,IAAW,CACtCD,CAAAA,CAAQ,OAAO,KAClB,EAAA,IAAA,CAAK,WAAW,QAAS,CAAA,CACrB,KAAK,CAAGA,EAAAA,CAAAA,CAAQ,IAAI,CAAIC,CAAAA,EAAAA,CAAI,GAC5B,KAAAR,CAAAA,CAAAA,CACA,QAAAO,CACJ,CAAC,EACL,CAAC,CAAA,CACD,KAAK,UAAW,CAAA,QAAA,CAAS,CACrB,IAAK,CAAA,eAAA,CACL,MAAAP,CACJ,CAAC,EACL,CACA,MAAA,CAAOA,EAAU,CACT,IAAA,CAAK,OAAO,GAAIA,CAAAA,CAAAA,CAAM,EAAE,CACxB,EAAA,IAAA,CAAK,OAAO,MAAOA,CAAAA,CAAAA,CAAM,EAAE,EAEnC,CACQ,QAAQS,CAAeJ,CAAAA,CAAAA,CAAcK,EAAW,CACpD,OAAGA,EAAO,IAAK,CAAA,UAAA,CAAW,IAAI,CAAUD,CAAAA,CAAAA,CACrCC,EAAO,IAAO,GAAA,eAAA,CACN,CACH,GAAGD,CAAAA,CACH,CAAC,CAAaC,UAAAA,EAAAA,CAAAA,CAAO,MAAM,EAAE,CAAA,CAAA,CAAG,EAAE,CAAC,GAAGA,EAAO,KAAM,CAAA,OAAA,EAAS,CAChE,CAAA,CAEO,CACH,GAAGD,CAAAA,CACH,CAAC,CAAaC,UAAAA,EAAAA,CAAAA,CAAO,MAAM,EAAE,CAAA,CAAA,CAAG,EAAE,CAAC,GAAGA,EAAO,KAAM,CAAA,OAAA,EAAS,CAChE,CAER,CACQ,OAAS,EAAA,CACV,KAAK,UACR,GAAA,IAAA,CAAK,WAAaC,kBACd,CAAA,IAAA,CAAK,QAEL,MAAO,CAAA,4BAAA,EAAgC,OAAO,4BAA6B,EAC/E,EACA,IAAK,CAAA,UAAA,CAAa,KAClB,OAAQ,CAAA,IAAA,CAAK,2EAA2E,YAAa,CAAA,EAAE,GAC3G,CACJ,EAEO,SAASC,CAAS,EAAA,CAEjB,WAAW,sBAAwB,GAAA,UAAA,CAAW,uBAAyB,IAAIN,CAAAA,EACnF,CAQAM,CAAQ,EAAA","file":"index.mjs","sourcesContent":["\r\nexport class WeakObjectMap<T extends object> {\r\n private map: Map<string, WeakRef<T>>;\r\n private finalizationRegistry: FinalizationRegistry<string>;\r\n \r\n constructor() {\r\n this.map = new Map();\r\n this.finalizationRegistry = new FinalizationRegistry((key) => {\r\n this.map.delete(key);\r\n });\r\n }\r\n \r\n set(key: string, value: T): void {\r\n const weakRef = new WeakRef(value);\r\n this.map.set(key, weakRef);\r\n this.finalizationRegistry.register(value, key);\r\n }\r\n \r\n get(key: string): T | undefined {\r\n const weakRef = this.map.get(key);\r\n return weakRef ? weakRef.deref() : undefined;\r\n }\r\n \r\n delete(key: string): boolean {\r\n return this.map.delete(key);\r\n }\r\n \r\n has(key: string): boolean {\r\n const weakRef = this.map.get(key);\r\n return weakRef ? weakRef.deref() !== undefined : false;\r\n }\r\n}\r\n/**\r\n * 判定两个值是否相等\r\n * \r\n * 如果两个值都是对象，则判断两个对象是否相等\r\n * 如果两个值都是数组，则判断两个数组的值是否相等\r\n * \r\n */\r\n\r\nexport function isPathEq(a:string[] | undefined,b:string[] | undefined):boolean{\r\n if(!a) return false\r\n if(!b) return false\r\n if(a.length!==b.length) return false\r\n return a.every((item,index)=>item===b[index])\r\n}\r\n/**\r\n * 判断一个路径destPath是否包含另一个路径basePath判断\r\n * @param basePath \r\n * @param destPath \r\n */\r\nexport function pathStartsWith(basePath:string[],destPath:string[]){\r\n if(basePath.length>destPath.length) return false\r\n return basePath.every((p,i)=>{\r\n return p===destPath[i]\r\n })\r\n}\r\n\r\nexport function analysisCyclePath(steps:string[],curPath:string):[string | undefined,number] {\r\n // 使用curPath将steps分割为多个数组\r\n const indexs = steps.reduce((prev,cur,index)=>{\r\n if(cur===curPath) prev.push(index) \r\n return prev\r\n },[] as number[])\r\n\r\n const groups = indexs.map((v,i)=>{\r\n if(i<indexs.length-1){\r\n return steps.slice(v,indexs[i+1])\r\n }else{\r\n return steps.slice(v)\r\n } \r\n })\r\n\r\n // 找到groups相同的分组\r\n const results = new Map<string,number>()\r\n for(let i=0;i<groups.length;i++){\r\n const group = groups[i]\r\n if(group.length<2) continue\r\n for(let j=i+1;j<groups.length;j++){\r\n const group2 = groups[j]\r\n if(isPathEq(group,group2) || pathStartsWith(group,group2)){\r\n const gKey = group.join('->')\r\n if(!results.has(gKey)){\r\n results.set(gKey,1)\r\n }\r\n const n = results.get(gKey)! \r\n results.set(gKey,n+1)\r\n }\r\n }\r\n }\r\n // 找到results里面路径最长的\r\n let count = 0\r\n let paths = undefined\r\n results.forEach((v,k)=>{\r\n if(v<3) return\r\n if(k.length>count){\r\n paths = k\r\n count = v \r\n }\r\n }) \r\n return [paths,count]\r\n\r\n}\r\n","/**\r\n * \r\n * import { installCycleDetectExtend } from \"@autostore/devtools\"\r\n * \r\n * installCycleDetectExtend({....})\r\n * \r\n * \r\n */\r\nimport { analysisCyclePath } from \"./utils\"\r\n\r\n\r\nexport type CycleDetectExtendOptions = { \r\n /**\r\n * 当检测到多少个循环时视为循环依赖 \r\n */\r\n cycleCount?:number\r\n /**\r\n * \r\n * 当检测时间操作数量达到此值时，停止检测\r\n * \r\n */\r\n maxOpereates?:number\r\n /**\r\n * 指定仅作用于指定的store\r\n * =[]代表所有store均生效\r\n */\r\n stores?:string[]\r\n /**\r\n * \r\n */\r\n onDetected?:(paths:string[],computedObject:any)=>'ignore'|'throw'|'disable' \r\n\r\n}\r\n\r\n/**\r\n * \r\n * - 在异步计算第一次执行时调用\r\n * cycleDetector.start()\r\n * \r\n * \r\n * \r\n */\r\nexport class AsyncCycleDetector{\r\n steps:string[] = []\r\n running:boolean = false \r\n private _watcher:any\r\n path:string\r\n options: Record<string,any>\r\n constructor(public computedObject:any,options?:Record<string,any>){\r\n this.path = computedObject.path.join('.')\r\n this.steps.push(this.path)\r\n this.options = Object.assign({\r\n cycleCount : 8,\r\n maxOpereates: 200,\r\n stores:[]\r\n },options)\r\n } \r\n /**\r\n * 本方法应该在异步函数第一次运行时调用\r\n */\r\n start(){\r\n this.running = true\r\n this.steps.push(this.path)\r\n this._watcher = this.computedObject.store.watch((event:any)=>{\r\n if(this.steps.length<500){\r\n this.steps.push(event.path.join('.'))\r\n }\r\n },{operates:'read'}) \r\n }\r\n /**\r\n * \r\n * 开始检测是否存在循环依赖\r\n * \r\n * \r\n * [\"a\",'d','c','b','a','d','c','b','a']\r\n * \r\n * \r\n * 编写一个函数，检测是否存在循环依赖\r\n * \r\n * 逻辑如下：\r\n * \r\n * 对this.steps里面是否存在连续的相同的路径，如果存在，则表示存在循环依赖\r\n * \r\n * \r\n * @returns \r\n */\r\n private analysisCycleSteps(){\r\n const [paths,count] = analysisCyclePath(this.steps,this.path)\r\n const { onDetected,cycleCount } = this.options\r\n if(count<cycleCount) return\r\n this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${paths}`,'warn')\r\n if(typeof(onDetected )==='function'){\r\n const result = onDetected(paths,this.computedObject)\r\n if(result==='ignore'){\r\n return\r\n }else if(result==='disable') {\r\n this.computedObject.enable = false\r\n }else{\r\n throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${paths}`)\r\n }\r\n } \r\n } \r\n detect(){\r\n if(this.steps.length>this.options.maxOpereates){\r\n this._watcher.off()\r\n try{\r\n this.analysisCycleSteps()\r\n }finally{ \r\n this.steps=[]\r\n }\r\n }\r\n }\r\n}\r\n\r\n\r\nfunction createCycleDetectExtend(options?:CycleDetectExtendOptions){\r\n return function cycleDetectExtend(store:any){\r\n const { onObserverCreated } = store.options\r\n if(typeof(onObserverCreated) ==='function'){ \r\n // 当store的onObserverCreated选项已经配置时，cycleDetectExtend不能生效\r\n store.log(`Store<${store.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,\"warn\")\r\n }else{\r\n store.options.onObserverCreated = (observerObject:any)=>{\r\n // 只对异步计算属性进行循环依赖检测\r\n if(observerObject.type==='computed' && observerObject.async){\r\n observerObject._cycleDetector = new AsyncCycleDetector(observerObject,options)\r\n const oldRun = observerObject.run\r\n // 封装原始的run方法\r\n observerObject.run = (async function(options:any){\r\n // 在第一次运行时启动循环依赖检测\r\n if(options && options.first===true){\r\n observerObject._cycleDetector.start()\r\n }else{\r\n observerObject._cycleDetector.detect() \r\n }\r\n return await oldRun.apply(observerObject,options)\r\n }).bind(observerObject)\r\n }\r\n }\r\n store.log(\"cycleDetectExtend is already installed\")\r\n }\r\n } \r\n\r\n}\r\n\r\n\r\nexport function installCycleDetectExtend(options?:CycleDetectExtendOptions){\r\n // @ts-ignore\r\n if(!globalThis.__AUTOSTORE_EXTENDS__){\r\n // @ts-ignore\r\n globalThis.__AUTOSTORE_EXTENDS__=[]\r\n }\r\n // @ts-ignore\r\n globalThis.__AUTOSTORE_EXTENDS__.push(createCycleDetectExtend(options))\r\n \r\n}\r\n ","/**\r\n * \r\n * 基于开发工具\r\n * \r\n * Redux DevTools 是一个实用工具，用于开发和调试 Redux 应用程序。\r\n * AutoStore是基于Redux DevTools 的简单包装，可以让开发者使用Redux DevTools\r\n * 来查看AutoStore的状态变化 \r\n * \r\n * import { createStore } from \"@autostorejs/react\"\r\n * import { install } from \"@autostorejs/devtools\"\r\n * \r\n * \r\n * const store = createStore({})\r\n * \r\n * install()\r\n * \r\n */\r\n\r\n//@ts-ignore\r\nimport { legacy_createStore as createStore } from \"redux\"\r\nimport { WeakObjectMap } from \"./utils\"\r\n \r\nconst initialState = {\r\n \r\n}\r\n\r\n\r\nexport class AutoStoreDevTools{\r\n private reduxStore:any\r\n private _installed:boolean = false\r\n stores = new WeakObjectMap()\r\n constructor(){\r\n this.install()\r\n }\r\n add(store:any){ \r\n this.stores.set(store.id,store)\r\n store.operates.onAny((payload:any,type:any)=>{ \r\n if(payload.type==='get') return \r\n this.reduxStore.dispatch({\r\n type:`${payload.type}@${type}`,\r\n store,\r\n payload \r\n })\r\n })\r\n this.reduxStore.dispatch({\r\n type:\"__ADD_STORE__\",\r\n store\r\n })\r\n }\r\n remove(store:any){ \r\n if( this.stores.has(store.id)){\r\n this.stores.delete(store.id)\r\n }\r\n }\r\n private reducer(state:object = initialState, action:any){\r\n if(action.type.startsWith(\"@@\")) return state\r\n if(action.type==='__ADD_STORE__') {\r\n return {\r\n ...state,\r\n [`AutoStore<${action.store.id}>`]:{...action.store.getSnap()}\r\n }\r\n }else{\r\n return {\r\n ...state,\r\n [`AutoStore<${action.store.id}>`]:{...action.store.getSnap()}\r\n }\r\n } \r\n }\r\n private install(){\r\n if(this._installed) return \r\n this.reduxStore = createStore(\r\n this.reducer,\r\n // @ts-ignore\r\n window.__REDUX_DEVTOOLS_EXTENSION__ && window.__REDUX_DEVTOOLS_EXTENSION__()\r\n ); \r\n this._installed = true\r\n console.info('%c AutoStoreDevTools installed. Please open <Redux devtools> to view. %c',\"color:red;\",'')\r\n }\r\n}\r\n\r\nexport function install(){\r\n // @ts-ignore\r\n if(!globalThis.__AUTOSTORE_DEVTOOLS__) globalThis.__AUTOSTORE_DEVTOOLS__ = new AutoStoreDevTools() \r\n} \r\n\r\ndeclare global{\r\n // @ts-ignore\r\n var __AUTOSTORE_DEVTOOLS__ : AutoStoreDevTools\r\n}\r\n\r\n\r\ninstall()\r\n\r\n"]} | ||
| {"version":3,"sources":["../src/utils.ts","../src/cycleDetectExtend.ts","../src/devTools.ts"],"names":["WeakObjectMap","key","value","weakRef","isPathEq","a","b","item","index","pathStartsWith","basePath","destPath","p","i","analysisCyclePath","steps","curPath","indexs","prev","cur","groups","v","results","group","j","group2","gKey","n","count","paths","k","AsyncCycleDetector","computedObject","options","event","onDetected","cycleCount","result","createCycleDetectExtend","store","onObserverCreated","observerObject","oldRun","installCycleDetectExtend","initialState","AutoStoreDevTools","payload","type","state","action","createStore","install"],"mappings":"uCACO,IAAMA,EAAN,KAAsC,CACjC,IACA,oBAAA,CAER,WAAA,EAAc,CACZ,IAAA,CAAK,GAAA,CAAM,IAAI,GAAA,CACf,IAAA,CAAK,qBAAuB,IAAI,oBAAA,CAAsBC,GAAQ,CAC5D,IAAA,CAAK,IAAI,MAAA,CAAOA,CAAG,EACrB,CAAC,EACH,CAEA,GAAA,CAAIA,CAAAA,CAAaC,EAAgB,CAC/B,IAAMC,EAAU,IAAI,OAAA,CAAQD,CAAK,CAAA,CACjC,IAAA,CAAK,IAAI,GAAA,CAAID,CAAAA,CAAKE,CAAO,CAAA,CACzB,IAAA,CAAK,qBAAqB,QAAA,CAASD,CAAAA,CAAOD,CAAG,EAC/C,CAEA,IAAIA,CAAAA,CAA4B,CAC9B,IAAME,CAAAA,CAAU,IAAA,CAAK,IAAI,GAAA,CAAIF,CAAG,EAChC,OAAOE,CAAAA,CAAUA,EAAQ,KAAA,EAAM,CAAI,MACrC,CAEA,MAAA,CAAOF,EAAsB,CAC3B,OAAO,KAAK,GAAA,CAAI,MAAA,CAAOA,CAAG,CAC5B,CAEA,IAAIA,CAAAA,CAAsB,CACxB,IAAME,CAAAA,CAAU,IAAA,CAAK,IAAI,GAAA,CAAIF,CAAG,EAChC,OAAOE,CAAAA,CAAUA,EAAQ,KAAA,EAAM,GAAM,OAAY,KACnD,CACJ,EASO,SAASC,CAAAA,CAASC,EAAuBC,CAAAA,CAA+B,CAG7E,OAFG,CAACD,CAAAA,EACD,CAACC,CAAAA,EACDD,CAAAA,CAAE,SAASC,CAAAA,CAAE,MAAA,CAAe,MACxBD,CAAAA,CAAE,KAAA,CAAM,CAACE,CAAAA,CAAKC,CAAAA,GAAQD,IAAOD,CAAAA,CAAEE,CAAK,CAAC,CAC9C,CAMO,SAASC,CAAAA,CAAeC,CAAAA,CAAkBC,EAAkB,CACjE,OAAGD,EAAS,MAAA,CAAOC,CAAAA,CAAS,OAAe,KAAA,CACpCD,CAAAA,CAAS,MAAM,CAACE,CAAAA,CAAEC,IACdD,CAAAA,GAAID,CAAAA,CAASE,CAAC,CACxB,CACH,CAEO,SAASC,CAAAA,CAAkBC,EAAeC,CAAAA,CAA4C,CAE3F,IAAMC,CAAAA,CAASF,CAAAA,CAAM,OAAO,CAACG,CAAAA,CAAKC,EAAIX,CAAAA,IAC/BW,CAAAA,GAAMH,GAASE,CAAAA,CAAK,IAAA,CAAKV,CAAK,CAAA,CAC1BU,CAAAA,CAAAA,CACT,EAAc,CAAA,CAEVE,EAASH,CAAAA,CAAO,GAAA,CAAI,CAACI,CAAAA,CAAER,CAAAA,GACtBA,EAAEI,CAAAA,CAAO,MAAA,CAAO,EACRF,CAAAA,CAAM,KAAA,CAAMM,EAAEJ,CAAAA,CAAOJ,CAAAA,CAAE,CAAC,CAAC,CAAA,CAEzBE,EAAM,KAAA,CAAMM,CAAC,CAE3B,CAAA,CAGKC,CAAAA,CAAU,IAAI,GAAA,CACpB,QAAQT,CAAAA,CAAE,CAAA,CAAEA,EAAEO,CAAAA,CAAO,MAAA,CAAOP,IAAI,CAC5B,IAAMU,EAAQH,CAAAA,CAAOP,CAAC,EACtB,GAAG,EAAAU,EAAM,MAAA,CAAO,CAAA,CAAA,CAChB,QAAQC,CAAAA,CAAEX,CAAAA,CAAE,EAAEW,CAAAA,CAAEJ,CAAAA,CAAO,OAAOI,CAAAA,EAAAA,CAAI,CAC9B,IAAMC,CAAAA,CAASL,CAAAA,CAAOI,CAAC,CAAA,CACvB,GAAGpB,EAASmB,CAAAA,CAAME,CAAM,GAAKhB,CAAAA,CAAec,CAAAA,CAAME,CAAM,CAAA,CAAE,CACtD,IAAMC,CAAAA,CAAOH,CAAAA,CAAM,KAAK,IAAI,CAAA,CACxBD,EAAQ,GAAA,CAAII,CAAI,GAChBJ,CAAAA,CAAQ,GAAA,CAAII,EAAK,CAAC,CAAA,CAEtB,IAAMC,CAAAA,CAAIL,CAAAA,CAAQ,IAAII,CAAI,CAAA,CAC1BJ,EAAQ,GAAA,CAAII,CAAAA,CAAKC,EAAE,CAAC,EACxB,CACJ,CACJ,CAEA,IAAIC,CAAAA,CAAQ,CAAA,CACRC,EACJ,OAAAP,CAAAA,CAAQ,QAAQ,CAACD,CAAAA,CAAES,IAAI,CAChBT,CAAAA,CAAE,GACFS,CAAAA,CAAE,MAAA,CAAOF,IACVC,CAAAA,CAAQC,CAAAA,CACRF,EAAQP,CAAAA,EAEd,CAAC,EACM,CAACQ,CAAAA,CAAMD,CAAK,CAErB,KC5DaG,CAAAA,CAAN,KAAwB,CAM3B,WAAA,CAAmBC,CAAAA,CAAmBC,EAA4B,CAA/C,IAAA,CAAA,cAAA,CAAAD,EACf,IAAA,CAAK,IAAA,CAAOA,EAAe,IAAA,CAAK,IAAA,CAAK,GAAG,CAAA,CACxC,IAAA,CAAK,MAAM,IAAA,CAAK,IAAA,CAAK,IAAI,CAAA,CACzB,IAAA,CAAK,QAAU,MAAA,CAAO,MAAA,CAAO,CACzB,UAAA,CAAc,CAAA,CACd,aAAc,GAAA,CACd,MAAA,CAAO,EACX,CAAA,CAAEC,CAAO,EACb,CAbA,MAAiB,EAAC,CAClB,QAAkB,KAAA,CACV,QAAA,CACR,KACA,OAAA,CAaA,KAAA,EAAO,CACH,IAAA,CAAK,OAAA,CAAU,KACf,IAAA,CAAK,KAAA,CAAM,KAAK,IAAA,CAAK,IAAI,EACzB,IAAA,CAAK,QAAA,CAAW,KAAK,cAAA,CAAe,KAAA,CAAM,MAAOC,CAAAA,EAAY,CACtD,KAAK,KAAA,CAAM,MAAA,CAAO,KACjB,IAAA,CAAK,KAAA,CAAM,KAAKA,CAAAA,CAAM,IAAA,CAAK,KAAK,GAAG,CAAC,EAE5C,CAAA,CAAE,CAAC,SAAS,MAAM,CAAC,EACvB,CAkBQ,kBAAA,EAAoB,CACxB,GAAM,CAACL,CAAAA,CAAMD,CAAK,EAAId,CAAAA,CAAkB,IAAA,CAAK,MAAM,IAAA,CAAK,IAAI,EACtD,CAAE,UAAA,CAAAqB,EAAW,UAAA,CAAAC,CAAW,EAAI,IAAA,CAAK,OAAA,CACvC,GAAG,EAAAR,CAAAA,CAAMQ,KACT,IAAA,CAAK,cAAA,CAAe,MAAM,GAAA,CAAI,CAAA,yBAAA,EAA4B,KAAK,cAAA,CAAe,QAAA,EAAU,CAAA,GAAA,EAAMP,CAAK,GAAG,MAAM,CAAA,CACzG,OAAOM,CAAAA,EAAe,UAAA,CAAA,CAAW,CAChC,IAAME,CAAAA,CAASF,EAAWN,CAAAA,CAAM,IAAA,CAAK,cAAc,CAAA,CACnD,GAAGQ,IAAS,QAAA,CACR,OACE,GAAGA,CAAAA,GAAS,SAAA,CACd,KAAK,cAAA,CAAe,MAAA,CAAS,WAE7B,MAAM,IAAI,MAAM,CAAA,sBAAA,EAAyB,IAAA,CAAK,eAAe,QAAA,EAAU,MAAMR,CAAK,CAAA,CAAE,CAE5F,CACJ,CACA,QAAQ,CACJ,GAAG,KAAK,KAAA,CAAM,MAAA,CAAO,KAAK,OAAA,CAAQ,YAAA,CAAa,CAC3C,IAAA,CAAK,QAAA,CAAS,KAAI,CAClB,GAAG,CACC,IAAA,CAAK,kBAAA,GACT,CAAA,OAAC,CACG,KAAK,KAAA,CAAM,GACf,CACJ,CACJ,CACJ,EAGA,SAASS,EAAwBL,CAAAA,CAAkC,CAC/D,OAAO,SAA2BM,CAAAA,CAAU,CACxC,GAAM,CAAE,kBAAAC,CAAkB,CAAA,CAAID,EAAM,OAAA,CACjC,OAAOC,GAAsB,UAAA,CAE5BD,CAAAA,CAAM,IAAI,CAAA,MAAA,EAASA,CAAAA,CAAM,EAAE,CAAA,wEAAA,CAAA,CAA2E,MAAM,GAE5GA,CAAAA,CAAM,OAAA,CAAQ,kBAAqBE,CAAAA,EAAqB,CAEpD,GAAGA,CAAAA,CAAe,IAAA,GAAO,YAAcA,CAAAA,CAAe,KAAA,CAAM,CACxDA,CAAAA,CAAe,cAAA,CAAiB,IAAIV,CAAAA,CAAmBU,CAAAA,CAAeR,CAAO,CAAA,CAC7E,IAAMS,EAASD,CAAAA,CAAe,GAAA,CAE9BA,EAAe,GAAA,CAAA,CAAO,eAAeR,EAAY,CAE7C,OAAGA,GAAWA,CAAAA,CAAQ,KAAA,GAAQ,KAC1BQ,CAAAA,CAAe,cAAA,CAAe,OAAM,CAEpCA,CAAAA,CAAe,eAAe,MAAA,EAAO,CAElC,MAAMC,CAAAA,CAAO,KAAA,CAAMD,EAAeR,CAAO,CACpD,GAAG,IAAA,CAAKQ,CAAc,EAC1B,CACJ,CAAA,CACAF,EAAM,GAAA,CAAI,wCAAwC,GAE1D,CAEJ,CAGO,SAASI,CAAAA,CAAyBV,CAAAA,CAAkC,CAEnE,UAAA,CAAW,qBAAA,GAEX,UAAA,CAAW,qBAAA,CAAsB,EAAC,CAAA,CAGtC,UAAA,CAAW,sBAAsB,IAAA,CAAKK,CAAAA,CAAwBL,CAAO,CAAC,EAE1E,CCrIA,IAAMW,EAAe,EAErB,CAGaC,EAAN,KAAuB,CAClB,WACA,UAAA,CAAqB,KAAA,CAC7B,OAAS,IAAI7C,CAAAA,CACb,aAAa,CACT,IAAA,CAAK,UACT,CACA,IAAIuC,CAAAA,CAAU,CACV,KAAK,MAAA,CAAO,GAAA,CAAIA,EAAM,EAAA,CAAGA,CAAK,EAC9BA,CAAAA,CAAM,QAAA,CAAS,MAAM,CAACO,CAAAA,CAAYC,IAAW,CACtCD,CAAAA,CAAQ,OAAO,KAAA,EAClB,IAAA,CAAK,WAAW,QAAA,CAAS,CACrB,KAAK,CAAA,EAAGA,CAAAA,CAAQ,IAAI,CAAA,CAAA,EAAIC,CAAI,GAC5B,KAAA,CAAAR,CAAAA,CACA,QAAAO,CACJ,CAAC,EACL,CAAC,CAAA,CACD,KAAK,UAAA,CAAW,QAAA,CAAS,CACrB,IAAA,CAAK,eAAA,CACL,MAAAP,CACJ,CAAC,EACL,CACA,MAAA,CAAOA,EAAU,CACT,IAAA,CAAK,OAAO,GAAA,CAAIA,CAAAA,CAAM,EAAE,CAAA,EACxB,IAAA,CAAK,OAAO,MAAA,CAAOA,CAAAA,CAAM,EAAE,EAEnC,CACQ,QAAQS,CAAAA,CAAeJ,CAAAA,CAAcK,EAAW,CACpD,OAAGA,EAAO,IAAA,CAAK,UAAA,CAAW,IAAI,CAAA,CAAUD,CAAAA,CACrCC,EAAO,IAAA,GAAO,eAAA,CACN,CACH,GAAGD,CAAAA,CACH,CAAC,CAAA,UAAA,EAAaC,CAAAA,CAAO,MAAM,EAAE,CAAA,CAAA,CAAG,EAAE,CAAC,GAAGA,EAAO,KAAA,CAAM,OAAA,EAAS,CAChE,CAAA,CAEO,CACH,GAAGD,CAAAA,CACH,CAAC,CAAA,UAAA,EAAaC,CAAAA,CAAO,MAAM,EAAE,CAAA,CAAA,CAAG,EAAE,CAAC,GAAGA,EAAO,KAAA,CAAM,OAAA,EAAS,CAChE,CAER,CACQ,OAAA,EAAS,CACV,KAAK,UAAA,GACR,IAAA,CAAK,WAAaC,kBAAAA,CACd,IAAA,CAAK,QAEL,MAAA,CAAO,4BAAA,EAAgC,OAAO,4BAAA,EAClD,EACA,IAAA,CAAK,UAAA,CAAa,KAClB,OAAA,CAAQ,IAAA,CAAK,2EAA2E,YAAA,CAAa,EAAE,GAC3G,CACJ,EAEO,SAASC,CAAAA,EAAS,CAEjB,WAAW,sBAAA,GAAwB,UAAA,CAAW,uBAAyB,IAAIN,CAAAA,EACnF,CAQAM,CAAAA,EAAQ","file":"index.mjs","sourcesContent":["\nexport class WeakObjectMap<T extends object> {\n private map: Map<string, WeakRef<T>>;\n private finalizationRegistry: FinalizationRegistry<string>;\n \n constructor() {\n this.map = new Map();\n this.finalizationRegistry = new FinalizationRegistry((key) => {\n this.map.delete(key);\n });\n }\n \n set(key: string, value: T): void {\n const weakRef = new WeakRef(value);\n this.map.set(key, weakRef);\n this.finalizationRegistry.register(value, key);\n }\n \n get(key: string): T | undefined {\n const weakRef = this.map.get(key);\n return weakRef ? weakRef.deref() : undefined;\n }\n \n delete(key: string): boolean {\n return this.map.delete(key);\n }\n \n has(key: string): boolean {\n const weakRef = this.map.get(key);\n return weakRef ? weakRef.deref() !== undefined : false;\n }\n}\n/**\n * 判定两个值是否相等\n * \n * 如果两个值都是对象，则判断两个对象是否相等\n * 如果两个值都是数组，则判断两个数组的值是否相等\n * \n */\n\nexport function isPathEq(a:string[] | undefined,b:string[] | undefined):boolean{\n if(!a) return false\n if(!b) return false\n if(a.length!==b.length) return false\n return a.every((item,index)=>item===b[index])\n}\n/**\n * 判断一个路径destPath是否包含另一个路径basePath判断\n * @param basePath \n * @param destPath \n */\nexport function pathStartsWith(basePath:string[],destPath:string[]){\n if(basePath.length>destPath.length) return false\n return basePath.every((p,i)=>{\n return p===destPath[i]\n })\n}\n\nexport function analysisCyclePath(steps:string[],curPath:string):[string | undefined,number] {\n // 使用curPath将steps分割为多个数组\n const indexs = steps.reduce((prev,cur,index)=>{\n if(cur===curPath) prev.push(index) \n return prev\n },[] as number[])\n\n const groups = indexs.map((v,i)=>{\n if(i<indexs.length-1){\n return steps.slice(v,indexs[i+1])\n }else{\n return steps.slice(v)\n } \n })\n\n // 找到groups相同的分组\n const results = new Map<string,number>()\n for(let i=0;i<groups.length;i++){\n const group = groups[i]\n if(group.length<2) continue\n for(let j=i+1;j<groups.length;j++){\n const group2 = groups[j]\n if(isPathEq(group,group2) || pathStartsWith(group,group2)){\n const gKey = group.join('->')\n if(!results.has(gKey)){\n results.set(gKey,1)\n }\n const n = results.get(gKey)! \n results.set(gKey,n+1)\n }\n }\n }\n // 找到results里面路径最长的\n let count = 0\n let paths = undefined\n results.forEach((v,k)=>{\n if(v<3) return\n if(k.length>count){\n paths = k\n count = v \n }\n }) \n return [paths,count]\n\n}\n","/**\n * \n * import { installCycleDetectExtend } from \"@autostore/devtools\"\n * \n * installCycleDetectExtend({....})\n * \n * \n */\nimport { analysisCyclePath } from \"./utils\"\n\n\nexport type CycleDetectExtendOptions = { \n /**\n * 当检测到多少个循环时视为循环依赖 \n */\n cycleCount?:number\n /**\n * \n * 当检测时间操作数量达到此值时，停止检测\n * \n */\n maxOpereates?:number\n /**\n * 指定仅作用于指定的store\n * =[]代表所有store均生效\n */\n stores?:string[]\n /**\n * \n */\n onDetected?:(paths:string[],computedObject:any)=>'ignore'|'throw'|'disable' \n\n}\n\n/**\n * \n * - 在异步计算第一次执行时调用\n * cycleDetector.start()\n * \n * \n * \n */\nexport class AsyncCycleDetector{\n steps:string[] = []\n running:boolean = false \n private _watcher:any\n path:string\n options: Record<string,any>\n constructor(public computedObject:any,options?:Record<string,any>){\n this.path = computedObject.path.join('.')\n this.steps.push(this.path)\n this.options = Object.assign({\n cycleCount : 8,\n maxOpereates: 200,\n stores:[]\n },options)\n } \n /**\n * 本方法应该在异步函数第一次运行时调用\n */\n start(){\n this.running = true\n this.steps.push(this.path)\n this._watcher = this.computedObject.store.watch((event:any)=>{\n if(this.steps.length<500){\n this.steps.push(event.path.join('.'))\n }\n },{operates:'read'}) \n }\n /**\n * \n * 开始检测是否存在循环依赖\n * \n * \n * [\"a\",'d','c','b','a','d','c','b','a']\n * \n * \n * 编写一个函数，检测是否存在循环依赖\n * \n * 逻辑如下：\n * \n * 对this.steps里面是否存在连续的相同的路径，如果存在，则表示存在循环依赖\n * \n * \n * @returns \n */\n private analysisCycleSteps(){\n const [paths,count] = analysisCyclePath(this.steps,this.path)\n const { onDetected,cycleCount } = this.options\n if(count<cycleCount) return\n this.computedObject.store.log(`CycleDepend detected in <${this.computedObject.toString()}>: ${paths}`,'warn')\n if(typeof(onDetected )==='function'){\n const result = onDetected(paths,this.computedObject)\n if(result==='ignore'){\n return\n }else if(result==='disable') {\n this.computedObject.enable = false\n }else{\n throw new Error(`CycleDepend found in <${this.computedObject.toString()}>: ${paths}`)\n }\n } \n } \n detect(){\n if(this.steps.length>this.options.maxOpereates){\n this._watcher.off()\n try{\n this.analysisCycleSteps()\n }finally{ \n this.steps=[]\n }\n }\n }\n}\n\n\nfunction createCycleDetectExtend(options?:CycleDetectExtendOptions){\n return function cycleDetectExtend(store:any){\n const { onObserverCreated } = store.options\n if(typeof(onObserverCreated) ==='function'){ \n // 当store的onObserverCreated选项已经配置时，cycleDetectExtend不能生效\n store.log(`Store<${store.id}> onObserverCreated is already configured, cycleDetectExtend is disabled`,\"warn\")\n }else{\n store.options.onObserverCreated = (observerObject:any)=>{\n // 只对异步计算属性进行循环依赖检测\n if(observerObject.type==='computed' && observerObject.async){\n observerObject._cycleDetector = new AsyncCycleDetector(observerObject,options)\n const oldRun = observerObject.run\n // 封装原始的run方法\n observerObject.run = (async function(options:any){\n // 在第一次运行时启动循环依赖检测\n if(options && options.first===true){\n observerObject._cycleDetector.start()\n }else{\n observerObject._cycleDetector.detect() \n }\n return await oldRun.apply(observerObject,options)\n }).bind(observerObject)\n }\n }\n store.log(\"cycleDetectExtend is already installed\")\n }\n } \n\n}\n\n\nexport function installCycleDetectExtend(options?:CycleDetectExtendOptions){\n // @ts-ignore\n if(!globalThis.__AUTOSTORE_EXTENDS__){\n // @ts-ignore\n globalThis.__AUTOSTORE_EXTENDS__=[]\n }\n // @ts-ignore\n globalThis.__AUTOSTORE_EXTENDS__.push(createCycleDetectExtend(options))\n \n}\n ","/**\n * \n * 基于开发工具\n * \n * Redux DevTools 是一个实用工具，用于开发和调试 Redux 应用程序。\n * AutoStore是基于Redux DevTools 的简单包装，可以让开发者使用Redux DevTools\n * 来查看AutoStore的状态变化 \n * \n * import { createStore } from \"@autostorejs/react\"\n * import { install } from \"@autostorejs/devtools\"\n * \n * \n * const store = createStore({})\n * \n * install()\n * \n */\n\n//@ts-ignore\nimport { legacy_createStore as createStore } from \"redux\"\nimport { WeakObjectMap } from \"./utils\"\n \nconst initialState = {\n \n}\n\n\nexport class AutoStoreDevTools{\n private reduxStore:any\n private _installed:boolean = false\n stores = new WeakObjectMap()\n constructor(){\n this.install()\n }\n add(store:any){ \n this.stores.set(store.id,store)\n store.operates.onAny((payload:any,type:any)=>{ \n if(payload.type==='get') return \n this.reduxStore.dispatch({\n type:`${payload.type}@${type}`,\n store,\n payload \n })\n })\n this.reduxStore.dispatch({\n type:\"__ADD_STORE__\",\n store\n })\n }\n remove(store:any){ \n if( this.stores.has(store.id)){\n this.stores.delete(store.id)\n }\n }\n private reducer(state:object = initialState, action:any){\n if(action.type.startsWith(\"@@\")) return state\n if(action.type==='__ADD_STORE__') {\n return {\n ...state,\n [`AutoStore<${action.store.id}>`]:{...action.store.getSnap()}\n }\n }else{\n return {\n ...state,\n [`AutoStore<${action.store.id}>`]:{...action.store.getSnap()}\n }\n } \n }\n private install(){\n if(this._installed) return \n this.reduxStore = createStore(\n this.reducer,\n // @ts-ignore\n window.__REDUX_DEVTOOLS_EXTENSION__ && window.__REDUX_DEVTOOLS_EXTENSION__()\n ); \n this._installed = true\n console.info('%c AutoStoreDevTools installed. Please open <Redux devtools> to view. %c',\"color:red;\",'')\n }\n}\n\nexport function install(){\n // @ts-ignore\n if(!globalThis.__AUTOSTORE_DEVTOOLS__) globalThis.__AUTOSTORE_DEVTOOLS__ = new AutoStoreDevTools() \n} \n\ndeclare global{\n // @ts-ignore\n var __AUTOSTORE_DEVTOOLS__ : AutoStoreDevTools\n}\n\n\ninstall()\n\n"]} |
+13
-19
| { | ||
| "name": "@autostorejs/devtools", | ||
| "version": "2.0.5", | ||
| "version": "2.0.6", | ||
| "description": "devtools for autostore", | ||
@@ -10,21 +10,12 @@ "repository": { | ||
| "exports": { | ||
| ".": "./src/index.ts", | ||
| "./cycleDetect": "./src/cycleDetect.ts" | ||
| ".": { | ||
| "import": "./dist/index.mjs", | ||
| "require": "./dist/index.js" | ||
| }, | ||
| "./cycleDetect": { | ||
| "import": "./dist/cycleDetect.mjs", | ||
| "require": "./dist/cycleDetect.js" | ||
| } | ||
| }, | ||
| "main": "src/index.ts", | ||
| "publishConfig": { | ||
| "exports": { | ||
| ".": { | ||
| "import": "./dist/index.mjs", | ||
| "require": "./dist/index.js" | ||
| }, | ||
| "./cycleDetect": { | ||
| "import": "./dist/cycleDetect.mjs", | ||
| "require": "./dist/cycleDetect.js" | ||
| } | ||
| } | ||
| }, | ||
| "scripts": { | ||
| "build": "tsup" | ||
| }, | ||
| "keywords": [], | ||
@@ -39,3 +30,6 @@ "author": "", | ||
| "tsup": "^8.5.0" | ||
| }, | ||
| "scripts": { | ||
| "build": "tsup" | ||
| } | ||
| } | ||
| } |
New alerts
Mixed license
LicensePackage contains multiple licenses.
Improved metrics
- Number of package files
22
4.76%Worsened metrics
- Total package byte prevSize
109853
-1.61%- Number of low license alerts
1
Infinity%No dependency changes