https://app.planifypro.com/_app/immutable/chunks/Bql8NCxS.js

1import{r as t}from"./CibDNYrR.js";import{r as e}from"./CXnsTEms.js";import{a,c as r,d as n,i as o,l as u,m as s,o as i,r as l,u as c}from"./CDG9Dzk7.js";import{C as d,g as f}from"./C2N_qCpP.js";import{r as y}from"./L22QZJtN.js";
2//#region src/lib/stores/localBaseShard.js
3var w=t=>`${t}::m`,m=(t,e)=>`${t}::s${e}`;function h(t){return"string"==typeof t&&("getPages"===t||t.startsWith("getPages_"))}async function p(t,e){const a=await r(t,w(e));if(!a||3!==a.v||!Number.isInteger(a.shardCount))return null;const n=new Array(a.pageCount);let u=0;for(let o=0;o<a.shardCount;o++){const s=(await r(t,m(e,o)))?.pages;if(!Array.isArray(s))return null;const i=o*a.shardSize;for(let t=0;t<s.length;t++)n[i+t]=s[t],u++;await y()}if(u!==a.pageCount)return null;if(d){const r=[w(e)];for(let t=0;t<a.shardCount;t++)r.push(m(e,t));o(t,r)}return n}
4//#endregion
5//#region src/components/stores/rxdbStorageWorker.js
6var v=t({batchDeleteLayoutDomsFromRxDB:()=>E,cleanupPlannerDataFromRxDB:()=>S,default:()=>x,deleteLayoutDomFromRxDB:()=>B,getProjectScopedKey:()=>D,loadLayoutDomFromRxDB:()=>A,localStorageWriteSuppressed:()=>k,preprocessForStorage:()=>g,saveBatchToRxDB:()=>C,saveLayoutDomToRxDB:()=>b,savePageRangeToRxDB:()=>I,savePlannerDataToRxDB:()=>R});function g(t){if(null==t||"object"!=typeof t)return t;try{return structuredClone(t)}catch{return JSON.parse(JSON.stringify(t))}}function D(t){if(!["getPages","schema","pagesStore","listingsStore"].includes(t))return t;const e="undefined"!=typeof window?window.__currentProjectId:null;return e?"string"!=typeof e?t:`${t}_${e.replace(/\//g,"_")}`:t}function k(){if("undefined"==typeof window)return!1;if(!0===window.__preventAutoLoad)return!0;try{return e()}catch{return!1}}async function x(t,u,v,x=null){const I=x??D(u);if("setItem"===t&&k())return null;try{const D=await c();if(!D||!D.keyvalue)throw new Error("RxDB database not available");const x=D.keyvalue;if(e()&&("setItem"===t||"removeItem"===t||"clear"===t))return null;switch(t){case"getItem":const e=I;if(h(u)){const t=await p(x,e)??(e!==u?await p(x,u):null);if(t)return t}let c=await r(x,e);if(c||e===u||(c=await r(x,u)),!c&&h(u)&&f)try{await n(x,e)}catch{}return c;case"setItem":if(k())return null;const D=I;if(f&&h(u)&&Array.isArray(v)&&v.length>100)return k()?null:await async function(t,e,a,r=()=>!1){if(r())return!1;const u=a.length,i=Math.ceil(u/50)||0,l=new Array(u);for(let n=0;n<i;n++){const r=50*n,o=a.slice(r,r+50);for(let t=0;t<o.length;t++)l[r+t]=Number(o[t]?.date)||0;if(null==await s(t,m(e,n),{pages:o,i:n}))return!1;await y()}if(null==await s(t,w(e),{v:3,pageCount:u,shardSize:50,shardCount:i,savedAt:Date.now(),dates:l,hasPages:!!a[0]?.pages}))return!1;try{await n(t,e)}catch{}if(d){const a=[w(e)];for(let t=0;t<i;t++)a.push(m(e,t));o(t,a)}return!r()}(x,D,v,k)?("undefined"!=typeof window&&window.dispatchEvent(new CustomEvent("rxdbDataChanged",{detail:{key:D}})),v):null;let b=g(v);return k()||(null==await s(x,D,b)||h(u)&&Array.isArray(v)&&(await async function(t,e){const a=await r(t,w(e));if(a)try{await n(t,w(e));for(let r=0;r<(a.shardCount||0);r++)await n(t,m(e,r))}catch(o){}}(x,D),await r(x,`${D}::m`)))?null:("undefined"!=typeof window&&window.dispatchEvent(new CustomEvent("rxdbDataChanged",{detail:{key:D}})),v);case"removeItem":return await n(x,u),null;case"clear":try{return await l(),null}catch(C){return null}case"keys":try{return await a(x)}catch(C){return[]}case"keysWithPrefix":try{return await a(x,u)}catch(C){return[]}case"length":try{return await x.count().exec()}catch(C){return 0}case"key":try{return(await i(x))[v]?.key||null}catch(C){return null}case"iterate":try{const t=await i(x),e={};return t.forEach(t=>{e[t.key]=t.value}),e}catch(C){return{}}default:throw new Error(`Unknown action: ${t}`)}}catch(C){switch(t){case"getItem":case"key":default:return null;case"keys":case"keysWithPrefix":return[];case"length":return 0;case"iterate":return{}}}}async function I(t,e,a,r){try{const n=performance.now(),o=await c();if(!o||!o.keyvalue)throw new Error("RxDB database not available");const i=o.keyvalue,l=[...await u(i,t)||[]];for(let t=a;t<r&&t<e.length;t++)l[t]=e[t];const d=g(l);if(k())return!1;if(null==await s(i,t,d))return!1;((performance.now()-n)/1e3).toFixed(2);return!0}catch(n){return!1}}async function C(t,e,a=null,r=null){const n=r??D(t);try{const r=performance.now(),o=e;if("pagesStore"===t&&Array.isArray(o)){const t=50,e=o.length,r=[];for(let n=0;n<e;n+=t){const u=Math.min(n+t,e),s=(Math.floor(n/t),Math.ceil(e/t),g(o.slice(n,u)));r.push(...s),a&&a(u,e),n+t<e&&await new Promise(t=>{"undefined"!=typeof window&&window.requestIdleCallback?window.requestIdleCallback(()=>t(),{timeout:100}):setTimeout(t,50)})}const u=await c();if(!u||!u.keyvalue)throw new Error("RxDB database not available");const i=n;

6if(k())return!1;if(null==await s(u.keyvalue,i,r))throw new Error(`Batch save for "${i}" did not land (RxDB unavailable/destroyed)`);"undefined"!=typeof window&&window.dispatchEvent(new CustomEvent("rxdbDataChanged",{detail:{key:i}}))}else if(null==await x("setItem",t,o,n))throw new Error(`Batch save for "${t}" did not land (RxDB unavailable/destroyed)`);((performance.now()-r)/1e3).toFixed(2);return a&&a(1,1),!0}catch(o){return!1}}async function b(t,e,a=!1,r=null){try{if(!t)return!1;const n=await c();if(!n||!n.layoutdomv3)return!1;const o=n.layoutdomv3;return null!=await s(o,t,{id:t,layoutIdDomNode:e,_compressed:a,workspaceIndex:"number"==typeof r?r:-1,lastModified:Date.now()})}catch(n){return!1}}async function A(t){try{if(!t)return null;const e=await c();if(!e||!e.layoutdomv3)return null;const a=await e.layoutdomv3.findOne(t).exec();return a?{layoutIdDomNode:a.layoutIdDomNode,_compressed:a._compressed||!1,workspaceIndex:a.workspaceIndex}:null}catch(e){return null}}async function B(t){try{if(!t)return!1;const e=await c();if(!e||!e.layoutdomv3)return!1;const a=e.layoutdomv3;return await n(a,t),!0}catch(e){return!1}}async function E(t){const e={deleted:0,failed:0};try{if(!t||0===t.length)return e;const a=await c();if(!a||!a.layoutdomv3)return e;const r=a.layoutdomv3,o=10;for(let u=0;u<t.length;u+=o){const a=t.slice(u,u+o).map(async t=>{try{return!!t&&(await n(r,t),!0)}catch(e){return!1}});(await Promise.all(a)).forEach(t=>{t?e.deleted++:e.failed++})}return e}catch(a){return e}}async function R(t,e){try{if(!t)return!1;const a=await c();if(!a||!a.keyvalue)return!1;const r=a.keyvalue;if(e&&e.length>0){const a=`plannerState_${t}`,n=function(t){return Array.isArray(t)?t.map(t=>{const e={};return t?.layoutDomId&&(e.layoutDomId=t.layoutDomId),t?.layout?.layoutDomId&&(e.layout={layoutDomId:t.layout.layoutDomId}),Array.isArray(t?.workspaces)&&(e.workspaces=t.workspaces.filter(t=>t?.layoutDomId).map(t=>({layoutDomId:t.layoutDomId}))),e}):[]}(e);await s(r,a,{pagesStore:n,lastUpdated:Date.now()})}return!0}catch(a){return!1}}async function S(t){try{if(!t)return!1;const e=await c();if(!e||!e.keyvalue)return!1;const a=e.keyvalue,r=`plannerState_${t}`;return await a.findOne(r).exec().then(t=>t?t.remove():null),!0}catch(e){return!1}}
7//#endregion
8export{k as a,v as c,I as d,R as f,A as i,C as l,B as n,g as o,D as r,x as s,S as t,b as u};