1function W(e){return e==="ledger"||e==="legacy_log"}function Z({fallbackRows:e,isError:t=!1,isFetched:r=!1,rows:n,source:i}){const o=W(i);return t||r&&!o?{rows:[],unavailable:!0}:o?{rows:n,unavailable:!1}:{rows:e,unavailable:!1}}const O=Symbol("volt-deferred-retry-attempt"),C=Symbol("volt-deferred-refresh-started-at"),P=Symbol("volt-deferred-request-duration-ms"),x=Symbol("volt-workflow-deferred-retry-attempt"),L=Symbol("volt-workflow-deferred-refresh-started-at"),U=Symbol("volt-workflow-deferred-request-duration-ms"),V=Symbol("volt-confirmed-deferred-retry-attempt"),H=Symbol("volt-confirmed-deferred-refresh-started-at"),Q=Symbol("volt-confirmed-deferred-request-duration-ms"),w=[3e3],s=8e3,b=5*6e4,E=1440*6e4;async function K({confirmed:e,foundations:t=[]}){const r=await Promise.allSettled(t.map(i=>Promise.resolve().then(i))),[n]=await Promise.allSettled([Promise.resolve().then(e)]);return{confirmed:n,foundations:r}}function N(e){return Math.max(0,Number(e)||0)}function h(e){const t=typeof e=="number"?e:Date.parse(e||"");return Number.isFinite(t)?t:null}function g(e=Date.now()){if(!Number.isFinite(e))return Number.NaN;const t=new Date(e);for(t.setUTCHours(20,0,0,0);t.getUTCDay()!==0||t.getTime()>e;)t.setUTCDate(t.getUTCDate()-1);return t.getTime()}function y(e){const t=e.config&&typeof e.config=="object"?e.config:{};return String(e.outcome_key||t.outcome||t.workflow_id||"").trim()}function D(e,t){return t?t.startsWith("brand:")?String(e.brand_id||"")===t.slice(6):!0:!1}function A(e,t){if(e._stats_deferred!==!1||!D(e,t))return null;const r=e._outcome_stats;if(!r||typeof r!="object")return null;const n=Number(r.sent),i=Number(r.pending),o=Date.parse(e._stats_verified_at||""),u=y(e);return!Number.isFinite(n)||!Number.isFinite(i)||!Number.isFinite(o)||!u?null:{agentId:e.id,outcomeId:u,pending:Math.max(0,i),quotaWeekAnchor:g(o),sent:Math.max(0,n),verifiedAt:o}}function m(e,t){const r=t-e.verifiedAt;return r>=0&&r<=E&&e.quotaWeekAnchor===g(t)}function Y(e){const t=typeof e.verifiedAt=="number"?e.verifiedAt:Date.parse(e.verifiedAt),r=Number(e.sent),n=e.pending==null?null:Number(e.pending),i=String(e.agentId||"").trim(),o=String(e.outcomeId||"").trim();return!i||!o||!Number.isFinite(r)||n!=null&&!Number.isFinite(n)||!Number.isFinite(t)?null:{agentId:i,outcomeId:o,...n==null?{}:{pending:Math.max(0,n)},quotaWeekAnchor:g(t),sent:Math.max(0,r),verifiedAt:t}}function v(e,t,r){const n=e==null?void 0:e._client_verified_workflow_delivery;if(!n||n.version!==1||n.scopeKey!==t)return{};const i=new Map(((e==null?void 0:e.agents)||[]).map(u=>[u.id,u])),o={};for(const[u,f]of Object.entries(n.entries||{})){const l=f?i.get(f.agentId):null;f&&f.outcomeId===u&&l&&D(l,t)&&y(l)===u&&Number.isFinite(Number(f.sent))&&(f.pending==null||Number.isFinite(Number(f.pending)))&&m(f,r)&&(o[u]=f)}return o}function j(e,t,r=[],n={}){const i=N(t==null?void 0:t.sent),o=N(t==null?void 0:t.pending),u=h(n.workflowVerifiedAt);if(e!=="send_collab_invites")return{checkedAt:u,pending:o,sent:i,source:"workflow"};const f=r.reduce((c,d)=>d.key==="collab_invite"?c+N(d.count):c,0),l=h(n.collabLedgerVerifiedAt);if(l!=null){const c=u!=null&&Math.abs(l-u)<=b;return{checkedAt:l,pending:c?o:null,sent:f,source:"collab_ledger"}}return{checkedAt:null,pending:o,sent:i,source:"workflow"}}function p(e,t,r=[]){const{pending:n,sent:i}=j(e,t,r);return{pending:n??0,sent:i}}function ee(e,t){const r=String(e||"").trim();if(r)return`brand:${r}`;const n=String(t||"").trim().toLowerCase();return n?`legacy:${n}`:"unscoped"}function te(e,t="7d"){return["volt-live-progress",e,t]}function re(e,t="7d"){return["volt-confirmed-delivery",e,t]}function a(e){const t=Number(e);return Number.isFinite(t)?Math.max(0,Math.floor(t)):0}function ne(e){return e?JSON.stringify([String(e.run_key||""),String(e.run_at||""),a(e.queued),a(e.pending),a(e.sent),a(e.skipped),a(e.failed)]):"unverified"}function ie(e,t="7d"){return["volt-run-history",e,t]}function oe(e,t,r,n){return["volt-run-details",e,t,r,n]}function ue(e,t){if(!e||!t||t==="unscoped")return!1;const r=e.agents||[];
1if(t.startsWith("brand:")){const n=t.slice(6);return!!n&&r.length>0&&r.every(i=>String(i.brand_id||"")===n)}return!1}function B(e,t,r,n=Date.now()){if(!t||t==="unscoped"||!Number.isFinite(n))return e;const i=new Map((e.agents||[]).map(l=>[l.id,l])),o=v(e,t,n);for(const l of r){const c=Y(l),d=c?i.get(c.agentId):null;!c||!d||!D(d,t)||y(d)===c.outcomeId&&m(c,n)&&(o[c.outcomeId]=c)}const u=e._client_verified_workflow_delivery,f={entries:o,scopeKey:t,version:1};return u&&JSON.stringify(u)===JSON.stringify(f)?e:{...e,_client_verified_workflow_delivery:f}}function fe(e,t,r,n,i=Date.now()){var l;if(!e||!t||!r||!n||!Number.isFinite(i))return null;const o=(l=e.agents)==null?void 0:l.find(c=>c.id===n);if(!o||!D(o,t))return null;const u=v(e,t,i)[r];if((u==null?void 0:u.agentId)===n)return{pending:u.pending==null?null:Math.max(0,Number(u.pending)),sent:Math.max(0,Number(u.sent)),verifiedAt:u.verifiedAt};const f=A(o,t);return f&&f.agentId===n&&f.outcomeId===r&&m(f,i)?{pending:f.pending==null?null:f.pending,sent:f.sent,verifiedAt:f.verifiedAt}:null}function le(e,t){const r=new Map;for(const n of e){const i=t(n),o=n._outcome_stats;!i||o==null||r.has(i)||r.set(i,o)}return r}function k(e){var t;return((t=e==null?void 0:e.agents)==null?void 0:t.some(r=>r._stats_deferred===!0))??!1}function ce(e){return!!e&&e._stats_deferred!==!0&&e._stats!=null}function de(e){return(e==null?void 0:e.deferred)===!0||!Array.isArray(e==null?void 0:e.lanes)?null:e.lanes}function G(e,t=Date.now()){if(!e||e.deferred===!0||e.stale===!0||e.week_sent==null||e.week_first_touch_sent==null)return null;const r=Number(e.week_sent),n=Number(e.week_first_touch_sent),i=Date.parse(e.verified_at||""),o=Date.parse(e.week_anchor||""),u=t-i;return!Number.isFinite(r)||!Number.isFinite(n)||!Number.isFinite(i)||!Number.isFinite(o)||!Number.isFinite(t)||u<0||u>b||o!==g(t)||r<0||n<0||n>r?null:{sent:r-n,verifiedAt:i,weekAnchor:o}}function J(e,t=Date.now()){var r;return((r=G(e,t))==null?void 0:r.sent)??null}function ae(e,t=Date.now()){if(!e||e.deferred===!0||e.stale===!0)return null;const r=Number(e.recent_collab_sent),n=Date.parse(e.recent_collab_verified_at||""),i=Date.parse(e.recent_collab_window_start||""),o=Date.parse(e.recent_collab_window_end||""),u=t-n,f=(o-i)/(60*6e4);return!Number.isFinite(r)||r<0||!Number.isFinite(n)||!Number.isFinite(i)||!Number.isFinite(o)||!Number.isFinite(t)||u<0||u>b||o>n||f<=0?null:r/f}function q(e,t,r,n=Date.now()){if(!e||e.deferred===!0||e.stale===!0||String(e.range||"")!==String(r||"")||t.startsWith("brand:")&&String(e.brand_id||"")!==t.slice(6))return null;const i=Number(e.sent),o=Date.parse(e.verified_at||""),u=n-o;return!Number.isFinite(i)||i<0||!Number.isFinite(o)||!Number.isFinite(n)||u<0||u>b?null:i}function se({delivery:e,lastKnown:t,now:r=Date.now(),range:n,scopeKey:i,snapshot:o}){const u=q(e,i,n,r);if(u!=null)return{sent:u,source:"confirmed",verifiedAt:Date.parse((e==null?void 0:e.verified_at)||"")};if(o&&o.snapshot_stale!==!0&&o.outreach_sent_total!=null&&o.snapshot_computed_at&&String(o.scope_key||"")===String(i||"")&&String(o.range||"")===String(n||"")){const d=Number(o.outreach_sent_total),R=Date.parse(o.snapshot_computed_at),S=r-R;if(Number.isFinite(d)&&d>=0&&Number.isFinite(R)&&Number.isFinite(r)&&S>=0&&S<=E)return{sent:d,source:"snapshot",verifiedAt:R}}const f=typeof(t==null?void 0:t.verifiedAt)=="number"?t.verifiedAt:Date.parse((t==null?void 0:t.verifiedAt)||""),l=Number(t==null?void 0:t.sent),c=r-f;return t&&String(t.scopeKey||"")===String(i||"")&&String(t.range||"")===String(n||"")&&Number.isFinite(l)&&l>=0&&Number.isFinite(f)&&Number.isFinite(r)&&c>=0&&c<=E?{sent:l,source:"local",verifiedAt:f}:null}function X(e){var t;return((t=e==null?void 0:e.confirmed_delivery)==null?void 0:t.deferred)===!0||!!e&&!e.confirmed_delivery}function me(e){return J(e==null?void 0:e.quota)==null}function _(e){return e==="workflow"?{attempt:x,duration:U,startedAt:L}:e==="confirmed"?{attempt:V,duration:Q,startedAt:H}:{attempt:O,duration:P,startedAt:C}}function F(e,t){const r=_(t),n=Number(e==null?void 0:e[r.attempt]);return Number.isFinite(n)&&n>0?Math.floor(n):0}function T(e,t){const r=_(t),n=Number(e==null?void 0:e[r.startedAt]);return Number.isFinite(n)&&n>=0?n:null}function $(e,t){const r=_(t),n=Number(e==null?void 0:e[r.duration]);return Number.isFinite(n)&&n>=0?n:0}function z(e,t,r,n={}){if(!r(t))return{...t};const i=Number.isFinite(n.now)?Number(n.now):Date.now(),o=Number.isFinite(n.requestStartedAt)?Math.min(i,Number(n.requestStartedAt)):i,u=n.trackingKey||"default",f=_(u),l=e&&r(e)?F(e,u):0,
1c=e&&r(e)?T(e,u):null;return{...t,[f.startedAt]:c??o,[f.duration]:Math.max(0,i-o),[f.attempt]:l+1}}function be(e,t,r){const n=Number.isFinite(r.now)?Number(r.now):Date.now(),i=z(e,t,k,{...r,trackingKey:"workflow"}),o=[];for(const u of(e==null?void 0:e.agents)||[]){const f=A(u,r.scopeKey);f&&m(f,n)&&o.push(f)}for(const u of Object.values(v(e,r.scopeKey,n)))o.push(u);for(const u of t.agents||[]){const f=A(u,r.scopeKey);if(!f||!m(f,n))continue;const l=v(e,r.scopeKey,n)[f.outcomeId];f.outcomeId==="send_collab_invites"&&(l==null?void 0:l.agentId)===f.agentId&&l.quotaWeekAnchor===f.quotaWeekAnchor&&l.sent>f.sent||o.push(f)}return B(i,r.scopeKey,o,n)}function _e(e){if(!e)return e;const t={...e};for(const r of["default","workflow","confirmed"]){const n=_(r);delete t[n.startedAt],delete t[n.duration],delete t[n.attempt]}return t}function I(e,t,r){const n=Math.max(1,F(e,r)),i=w[n-1];if(i==null)return!1;const o=T(e,r);return o==null?!0:t+i+$(e,r)<=o+s}function M(e,t,r=!1,n=Date.now(),i="default"){if(!e||!t(e)||!Number.isFinite(n)||!I(e,n,i))return r;const o=Math.max(1,F(e,i));return w[o-1]??r}function ve(e,t,r=Date.now(),n="default"){return!!e&&t(e)&&(!Number.isFinite(r)||!I(e,r,n))}function ge(e,t,r=Date.now()){const n=M(e,k,!1,r,"workflow");return typeof n=="number"?n:t?!1:6e4}function De(e,t,r=Date.now()){var u;const n=Date.parse(((u=e==null?void 0:e.confirmed_delivery)==null?void 0:u.verified_at)||""),i=Number.isFinite(n)&&Number.isFinite(r)&&r>=n?r-n:0,o=t?Math.max(1e3,b-i-s-1e3):6e4;return M(e,X,o,r,"confirmed")}async function Re(e,t,r=s){const n=new AbortController;let i=null;const o=new Promise((l,c)=>{i=c}),u=()=>{n.abort(),i==null||i(new DOMException("Volt progress request exceeded its time budget","AbortError"))};t!=null&&t.aborted?u():t==null||t.addEventListener("abort",u,{once:!0});const f=globalThis.setTimeout(u,Math.max(1,Number(r)||s));try{return await Promise.race([e(n.signal),o])}finally{globalThis.clearTimeout(f),t==null||t.removeEventListener("abort",u)}}function Ne(e,t=Date.now()){return Number.isFinite(e)&&Number.isFinite(t)&&Number(t)-Number(e)>=s}function Ee({hasRecentVerifiedValue:e=!1,refreshing:t=!1,unavailable:r=!1}){return r?e?"retained":"unavailable":t?e?"refreshing":"checking":"ready"}function Ae(e){return e==="unavailable"}function ye({configurationOnly:e=!1,laneDeferred:t=!1,laneError:r=!1,laneRetryExhausted:n=!1,progressDeferred:i=!1,progressRetryExhausted:o=!1,sourceError:u=!1,sourceLoading:f=!1}){return e?"ready":u||r||t&&n||i&&o?"unavailable":f||t||i?"loading":"ready"}export{w as DEFERRED_PROGRESS_RETRY_DELAYS_MS,E as LAST_VERIFIED_DISPLAY_MAX_AGE_MS,b as RUNTIME_VERIFIED_SENT_MAX_AGE_MS,s as WORKFLOW_PROGRESS_REFRESH_TIMEOUT_MS,M as deferredResponseRefetchInterval,ve as deferredResponseRetryExhausted,X as hasDeferredConfirmedDelivery,me as hasDeferredQuotaDelivery,k as hasDeferredWorkflowProgress,ce as hasKnownWorkflowDeliveryStats,le as outcomeProgressById,B as preserveVerifiedWorkflowDeliveries,fe as recentVerifiedWorkflowDelivery,K as refreshVoltDeliverySources,_e as resetDeferredResponseTracking,Ee as resolveVoltDeliveryDisplayState,se as resolveVoltRangeSentEvidence,Z as resolveVoltRunHistoryView,ye as resolveWorkflowDeliveryAvailability,j as resolveWorkflowDeliveryEvidence,g as tiktokQuotaWeekAnchor,z as trackDeferredResponse,be as trackDeferredWorkflowResponse,J as verifiedCollabInviteLedgerSent,ae as verifiedCollabInviteRecentHourlyRate,de as verifiedMessagingLanes,q as verifiedVoltRangeSent,re as voltConfirmedDeliveryQueryKey,De as voltConfirmedDeliveryRefetchInterval,te as voltLiveProgressQueryKey,ge as voltLiveProgressRefetchInterval,ue as voltProgressResponseMatchesScope,ee as voltProgressScopeKey,ne as voltRunDeliveryRevision,oe as voltRunDetailsQueryKey,ie as voltRunHistoryQueryKey,W as voltRunHistorySourceIsUsable,Re as withinProgressRequestBudget,p as workflowDeliveryCounts,Ne as workflowProgressRefreshTimedOut,Ae as workflowProgressViewIsUnavailable};
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.