https://www.eviny.no/_next/static/chunks/4668.f333b00bff33f558.js

1"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[4668],{44668:(e,t,r)=>{let n,o;r.r(t),r.d(t,{MessageBusError:()=>p,os:()=>x});var s=r(1969),i=r(7262),a=r(33441),l=r(3649),u=r(45019);let d=["none","error","warn","info","debug"],c=function e({namespace:t,context:r,logLevel:n="info"}={}){function o(e,o,s){if(!(d.indexOf(e)<=d.indexOf(n)))return;let i=r??s?{...r,...s}:void 0,a=[...t?[`[${t}]`]:[],o,...i?[i]:[]];"error"===e?console.error(...a):"warn"===e?console.warn(...a):"info"===e?console.info(...a):console.debug(...a)}return{error:(e,t)=>o("error",e,t),warn:(e,t)=>o("warn",e,t),info:(e,t)=>o("info",e,t),debug:(e,t)=>o("debug",e,t),child:(o,s)=>e({logLevel:n,namespace:t?`${t}:${o}`:o,context:r||s?{...r,...s}:void 0})}}({namespace:"sanity-workbench",logLevel:"debug"});class p extends Error{code;constructor(e,t,r){super(t??e,r),this.name="MessageBusError",this.code=e}}let f={"applications.foreground":{kind:"state",seed:null},"applications.list":{kind:"state",seed:void 0},"auth.token":{kind:"state",seed:void 0},"auth.token.refresh":{kind:"event"},"media-libraries.config":{kind:"state",seed:void 0},"organizations.current":{kind:"state",seed:void 0},"panels.mode":{kind:"state",seed:{ok:!0,value:null}},"panels.mode.set":{kind:"event"},"preferences.color-scheme":{kind:"state",seed:void 0},"users.current":{kind:"state",seed:void 0}},b={},g=Symbol.for("sanity.os.bus"),m=Symbol.for("sanity.os.protocol"),v=Symbol.for("sanity.os.registry"),w=Symbol.for("sanity.os.request"),y=c.child("os"),h="workbench",k=Symbol.for("sanity.os.no-value");function S(e,t){let r=e.stateSubjects.get(t);return r||(y.warn(`state topic "${t}" read before any value was published`),r=new s.t(k),e.stateSubjects.set(t,r)),r}function O(e,t){return e.getCurrent=t,e.firstValue=(0,i._)(e),e}function T(e,t){let r=e.stateSources.get(t);if(!r){let n=S(e,t);r=O(n.pipe((0,a.p)(e=>e!==k)),()=>{let e=n.getValue();return e===k?void 0:e}),e.stateSources.set(t,r)}return r}function _(e,t){for(let[r,n]of Object.entries(t)){let t=e.topics.get(r);if(t&&t!==n.kind)throw new p("PROTOCOL_MISMATCH",`topic "${r}" is declared "${n.kind}" but the installed bus knows it as "${t}"`)}for(let[r,n]of Object.entries(t))e.topics.set(r,n.kind),"state"!==n.kind||e.stateSubjects.has(r)||e.stateSubjects.set(r,new s.t(void 0===n.seed?k:n.seed))}function A(e,t){let r=e.eventSubjects.get(t);return r||(r=new l.B,e.eventSubjects.set(t,r)),r}function C(e,t){e.settled||(e.settled=!0,e.deliver?e.deliver(t):e.capturedOutcome=t)}let E=(e,t)=>"state"===e.topics.get(t);function M(e,t,r,n,o){var s,i,a,l;let u,d,c,f;if(E(e,t)){let n=S(e,t);Object.is(n.getValue(),r)||n.next(r);return}return u=(e.responderCounts.get(t)??0)>0,d={responderAbort:new AbortController,settled:!1},A(e,t).next((s=o,i=t,a=r,l=d,(f={type:i,payload:a,meta:{appId:s,timestamp:Date.now()},reply:e=>{l.settled?y.warn(`reply ignored for "${i}": no waiting caller or already replied`):C(l,{ok:!0,value:e})},get signal(){return l.responderAbort.signal}})[w]=l,f)),c=()=>{var e;return d.replyPromise??=(e={...n,hadResponder:u},new Promise((t,r)=>{let n,o=e=>e.ok?t(e.value):r(e.error);if(d.capturedOutcome){d.responderAbort.abort(),o(d.capturedOutcome);return}if(!e.hadResponder)return void r(new p("NO_RESPONDER"));let s=void 0===e.timeout?5e3:e.timeout,i=()=>C(d,{ok:!1,error:new p("ABORTED")});d.deliver=t=>{void 0!==n&&clearTimeout(n),e.signal?.removeEventListener("abort",i),d.responderAbort.abort(),o(t)},null!==s&&(n=setTimeout(()=>C(d,{ok:!1,error:new p("TIMEOUT")}),s)),e.signal&&(e.signal.aborted?i():e.signal.addEventListener("abort",i,{once:!0}))}))},{then:(e,t)=>c().then(e,t),catch:e=>c().then(void 0,e),finally:e=>c().finally(e)}}function j(e,t,r){let n=T(e,t),o=n.getCurrent();if(void 0!==o)return Promise.resolve(o);let s=r?.signal;return s?.aborted?Promise.reject(new p("ABORTED")):new Promise((e,r)=>{let o=setTimeout(()=>r(new p("TIMEOUT",`query("${t}") timed out`)),5e3),i=()=>{clearTimeout(o),r(new p("ABORTED"))};s?.addEventListener("abort",i,{once:!0}),n.firstValue.then(t=>{clearTimeout(o),s?.removeEventListener("abort",i),e(t)})})}function P(e,t){if(t){if(t.aborted)return void e.unsubscribe();t.addEventListener("abort",()=>e.unsubscribe(),{once:!0})}}function $(e,t,r,n){let o=E(e,t);if(!r)return o?T(e,t):A(e,t).pipe((0,u.T)(e=>e.payload));if(o)return void P(T(e,t).subscribe(r),n?.signal);e.responderCounts.set(t,(e.responderCounts.get(t)??0)+1);let s=A(e,t).subscribe(e=>(function(e,t){let r=t[w],n=e=>{r&&C(r,{ok:!1,error:new p("HANDLER_THREW",void 0,{cause:e})})};try{let r=e(t);r instanceof Promise&&r.catch(n)}catch(e){n(e)}})(r,e));s.add(()=>{let r=e.responderCounts.get(t)??0;r>0&&e.responderCounts.set(t,r-1)}),P(s,n?.signal)}let I=()=>new Map(Object.entries(b));function R(e){let t=new Map;for(let[r,n]of e){let e=1;for(let t of n)t.to>e&&(e=t.to);t.set(r,e)}return t}function L(e,t,r,n){if(!e||0===e.length||r===n)return t;let o=t;if(r<n)for(let t=r;t<n;t++){let r=e.find(e=>e.from===t);r&&(o=r.up(o))}else for(let t=r;t>n;t--){let r=e.find(e=>e.from===t-1);r&&(o=r.down(o))}return o}function D(e){let t=()=>{throw new p("PROTOCOL_MISMATCH",`installed OS bus speaks protocol ${String(e)}, this copy speaks 1`)};return{emit:t,query:t,subscribe:t}}let x=function(e,t={}){var r;let n,o,s,i,a,l,d=t.appId??h,c=e[m];if(1!==c)return y.error(`OS bus protocol mismatch for "${d}": installed ${String(c)}, this copy speaks 1`),D(c);let p=t.migrations??I(),b=e[v];try{_(b,f)}catch(e){return y.error(`OS bus topic manifest conflict for "${d}"`,{error:e}),D(c)}let{toCore:g,toClient:w}=(r=b.migrations,n=R(r),o=R(p),s=e=>o.get(e)??1,i=e=>n.get(e)??1,a=e=>(s(e)>i(e)?p:r).get(e),{toCore:(e,t)=>

1L(a(e),t,s(e),i(e)),toClient:(e,t)=>L(a(e),t,i(e),s(e))}),k=((l=b.appAborts.get(d))||(l=new AbortController,b.appAborts.set(d,l)),l),S=e=>e?AbortSignal.any([e,k.signal]):k.signal,T=new Map,A={emit:(e,t,r)=>M(b,e,g(e,t),{...r,signal:S(r?.signal)},d),query:(e,t)=>j(b,e,{signal:S(t?.signal)}).then(t=>w(e,t)),subscribe:(e,t,r)=>{if(!t){let t=T.get(e);if(!t){var n,o;let s,i,a,l=$(b,e,void 0,r);t=E(b,e)?(n=t=>w(e,t),O(l.pipe((0,u.T)(n)),(o=l.getCurrent,a=!1,()=>{let e=o();if(void 0!==e)return a&&e===s||(s=e,i=n(e),a=!0),i}))):l.pipe((0,u.T)(t=>w(e,t))),T.set(e,t)}return t}let s=E(b,e)?r=>t(w(e,r)):r=>{var n;return t((n=t=>w(e,t),{type:r.type,payload:n(r.payload),meta:r.meta,reply:r.reply,get signal(){return r.signal}}))};return $(b,e,s,{signal:S(r?.signal)})}};return A[v]=b,A[m]=1,A}((o=(n=globalThis)[g])&&m in o?o:(o&&y.warn("replaced a foreign value at the OS bus install key"),n[g]=function(e=h,t={}){let r={appId:e,topics:new Map,stateSubjects:new Map,stateSources:new Map,eventSubjects:new Map,responderCounts:new Map,appAborts:new Map,migrations:t.migrations??I()};_(r,f);let n={emit:(e,t,n)=>M(r,e,t,n,r.appId),query:(e,t)=>j(r,e,t),subscribe:(e,t,n)=>$(r,e,t,n)};return n[v]=r,n[m]=1,n}()),{appId:"string"==typeof __SANITY_APP_ID__?__SANITY_APP_ID__:h})}}]);