https://horizon-2826.taskade.app/chunks/chunk-IE44PGYO.js

1var __IMPORT_META_ENV={};var __PROCESS_ENV={NODE_ENV:"production"};
2import{f as g}from"/chunks/chunk-QHNK2J7X.js";import{b as _,c as l}from"/chunks/chunk-TMFOLKX4.js";import{b as E,d as O,g as d,h as u,o as M}from"/chunks/chunk-NZAKOVW6.js";var T=new Set(["os-closed","os-completed","os-cancelled","os-refunded"]),b=new Set(["po-received","po-archived","po-refused"]);function $(e){let n=new Date(e);if(isNaN(n.getTime())){let t=new Date;return`${t.getFullYear()}-${String(t.getMonth()+1).padStart(2,"0")}`}return`${n.getFullYear()}-${String(n.getMonth()+1).padStart(2,"0")}`}function m(e){return new Promise(n=>setTimeout(n,e))}async function R(e,n,t){if(!n||n==="undefined"||n.length<10)return!1;try{await E(!0);let{api:i}=await import("/chunks/api-XHOTDSGL.js");return await i.patch(`/projects/${e}/nodes/${n}`,t),!0}catch{return!1}}var S="archive_engine_next_run",D=300*1e3;function H(){try{let e=parseInt(sessionStorage.getItem(S)??"0",10);return Date.now()>=e}catch{return!0}}function y(){try{sessionStorage.setItem(S,String(Date.now()+D))}catch{}}function I(){try{sessionStorage.removeItem(S)}catch{}}var v=!1,p=0,P=6e4,h=3,A=2e4;async function F(){if(v)return;if(window.__importActive){console.info("[ArchiveEngine] Import en cours \u2014 passage ignor\xE9");return}if(O()){console.info("[ArchiveEngine] API gel\xE9e (429) \u2014 passage ignor\xE9");return}if(M()){console.info("[ArchiveEngine] Bulk delete actif \u2014 passage ignor\xE9");return}if(!H()){console.info("[ArchiveEngine] En cooldown \u2014 passage ignor\xE9");return}let e=Date.now();if(p===0&&(p=e+P,console.info(`[ArchiveEngine] Planifi\xE9 dans ${P/1e3}s`)),!(e<p)){v=!0,console.info("[ArchiveEngine] D\xE9marrage \u2014 budget global partag\xE9 avec UI");try{await N(),await k()}catch(n){console.warn("[ArchiveEngine] Erreur archivage:",n),y()}finally{v=!1}}}async function N(){let e=l.getState().allOrders.filter(i=>!i.archiveMonth&&T.has(i.status)&&!!i.createdAt&&!!i.id&&i.id!=="undefined"&&i.id.length>=10);if(e.length===0)return;console.info(`[ArchiveEngine] ${e.length} commande(s) \xE0 archiver \u2014 micro-batches de ${h}`);let n=[],t=0;for(let i=0;i<e.length;i+=h){let o=e.slice(i,i+h);for(let r of o){let s=$(r.createdAt);await R(d.ORDERS,r.id,{[u.O_ARCHIVE_MONTH]:s})?(n.push({id:r.id,archiveMonth:s}),console.info(`[ArchiveEngine] \u2713 ${r.id} \u2192 ${s}`)):(t++,console.warn(`[ArchiveEngine] \u2717 \xE9chec ${r.id}`))}i+h<e.length&&(console.info(`[ArchiveEngine] Pause ${A/1e3}s avant prochain batch`),await m(A))}if(t>0&&t>=e.length/2?(console.warn(`[ArchiveEngine] Trop d'\xE9checs (${t}/${e.length}) \u2192 cooldown`),y()):n.length>0&&I(),n.length>0){let i=new Map(n.map(r=>[r.id,r.archiveMonth])),o=l.getState().allOrders.map(r=>i.has(r.id)?{...r,archiveMonth:i.get(r.id)}:r);l.setState({allOrders:o,orders:o.filter(r=>!r.archiveMonth),archiveGroups:_(o)}),console.info(`[ArchiveEngine] ${n.length}/${e.length} commande(s) archiv\xE9es`)}}async function k(){let e=g.getState().allOrders.filter(t=>!t.archiveMonth&&b.has(t.status)&&!!t.createdAt&&!!t.id&&t.id!=="undefined"&&t.id.length>=10);if(e.length===0)return;console.info(`[ArchiveEngine] ${e.length} r\xE9apro(s) \xE0 archiver`);let n=[];for(let t=0;t<e.length;t+=h){let i=e.slice(t,t+h);for(let o of i){let r=$(o.createdAt);await R(d.PURCHASES,o.id,{[u.PO_ARCHIVE_MONTH]:r})&&n.push({id:o.id,archiveMonth:r})}t+h<e.length&&await m(A)}if(n.length>0){let t=new Map(n.map(o=>[o.id,o.archiveMonth])),i=g.getState().allOrders.map(o=>t.has(o.id)?{...o,archiveMonth:t.get(o.id)}:o);g.setState({allOrders:i}),console.info(`[ArchiveEngine] ${n.length} r\xE9apro(s) archiv\xE9(s)`)}}async function V(e,n,t,i){let{deleteNode:o}=await import("/chunks/api-XHOTDSGL.js"),r=[];if(e==="orders"?r=l.getState().allOrders.filter(a=>a.archiveMonth===n&&(a.channel||"")===t):r=g.getState().allOrders.filter(a=>a.archiveMonth===n&&(a.channel||"")===t),r.length===0)return 0;let s=0,w=e==="orders"?d.ORDERS:d.PURCHASES,f=5;for(let c=0;c<r.length;c+=f){let a=r.slice(c,c+f);await Promise.allSettled(a.map(C=>o(w,C.id).catch(()=>{}))),s+=a.length,i?.(s,r.length),c+f<r.length&&await m(300)}if(e==="orders")try{await l.getState().refresh()}catch{}else try{await g.getState().refresh()}catch{}return s}export{F as a,V as b};