https://www.basilica.ai/_next/static/chunks/8385.93f8ca5cc4ab0a3c.js

1"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[8385],{8385:function(e,t,s){s.d(t,{withPolkadotSdkCompat:function(){return E}});let a=e=>{let t=null,{send:s,disconnect:a}=e(e=>{t?.(JSON.parse(e))});return e=>(t=e,{send(e){s(JSON.stringify(e))},disconnect(){t=null,a()}})},l=e=>{let t=null,{send:s,disconnect:a}=e(e=>{t?.(JSON.stringify(e))});return e=>(t=e,{send(e){s(JSON.parse(e))},disconnect(){t=null,a()}})},r={body:"",call:"",continue:"",follow:"",header:"",stopOperation:"",storage:"",unfollow:"",unpin:""},n={broadcast:"",stop:""},i={chainName:"",genesisHash:"",properties:""};Object.entries({chainHead:r,chainSpec:i,transaction:n}).forEach(([e,t])=>{Object.keys(t).forEach(s=>{t[s]=`${e}_v1_${s}`})});let o=e=>({jsonrpc:"2.0",...e}),d=(e,t,s,a={})=>o({method:"chainHead_v1_followEvent",params:{subscription:e,result:{event:t,operationId:s,...a}}}),c=e=>{let t=0,s=new Map,a=({id:e,error:t,result:a})=>{let l=s.get(e);return l&&(s.delete(e),t?l(!1,t):l(!0,a)),!l},l=()=>{};return[t=>{let{send:r,disconnect:n}=e(e=>{a(e)&&t(e)});return{send:l=r,disconnect:()=>{s.clear(),n()}}},(e,a,r,n)=>{let i="__INNER_RQ_DesV"+t++;s.set(i,(e,t)=>{(e?r:n)(t)}),l(o({id:i,method:e,params:a}))}]},h=0,p=e=>(t,s,a,l,r)=>{let n=!0,i=!1,o=0,d=e=>{n&&(n=!1,l(e))},c=l=>{e("state_getKeysPaged",[t,1e3,l||void 0,s],t=>{n&&(t.length>0&&(o++,e("state_queryStorageAt",[t,s],([{changes:e}])=>{n&&(o--,a(e),i&&!o&&r())},d)),t.length<1e3?(i=!0,o||r()):c(t.at(-1)))},d)};return c(),()=>{n=!1}},u=new Set(["BodyDone","CallDone","StorageDone","Inaccessible","Error"].map(e=>"operation"+e)),f=e=>u.has(e.params?.result?.event),m=new Set(["newBlock","bestBlockChanged","stop"]),g=e=>({jsonrpc:"2.0",...e}),[w]=n.stop.split("_"),k="unstable",_="rpc_methods",b="__INTERNAL_ID",E=((...e)=>t=>l(e.reduce((e,t)=>t(e),a(t))))(e=>t=>{let s=0,a=new Map,{send:l,disconnect:r}=e(e=>{let{id:s}=e;a.has(s)&&(e.id=a.get(s),a.delete(s)),t(e)});return{send:e=>{"id"in e&&(a.set(s,e.id),e.id=s++),l(e)},disconnect:r}},e=>t=>{let s=!0,a=[],l=e=>{a.push(e)},o=({id:e,result:o,error:h})=>{if(e!==b||!s)return;if(!o){if(console.error(h),u<4){setTimeout(f,200);return}o={methods:[]}}let m=new Set(o.methods),E={};[r,i,n].forEach(e=>{Object.values(e).forEach(e=>{if(m.has(e))E[e]=e;else{let[t,,s]=e.split("_"),a=`${t}_${k}_${s}`;if(m.has(a))E[e]=a,m.delete(a),m.add(e);else if(E[e]=null,t===w){let t;let s="stop"===e?"unwatch":"submitAndWatch";[w+"Watch",w].find(e=>["v1",k].find(a=>m.has(t=`${e}_${a}_${s}`)))&&(E[e]=t,m.add(e))}}})}),d=t;let H=({method:e,...s})=>{if(e===_){Promise.resolve().then(()=>{t(g({id:s.id,result:{methods:[...m]}}))});return}let a=E[e];null===a?"follow"===e.split("_")[2]?(p(),l({method:e,...s})):Promise.resolve().then(()=>{t({error:{code:-32603,message:`Method not found: ${e}`},id:s.id})}):c({method:a||e,...s})},S=[...a];a=[];for(let e=0;s&&e<S.length;e++)H(S[e]);s&&(l=H)},d=o,{send:c,disconnect:h}=e(e=>{d(e)}),p=()=>{s=!0,a=[],l=e=>{a.push(e)},d=o,f()},u=0,f=()=>{u++,c(g({id:b,method:_,params:[]}))};return f(),{send:e=>{l(e)},disconnect(){s=!1,l=d=()=>{},a=[],h()}}},e=>t=>{let s=new Set,a=new Map,l=new Map,n=new Map,{send:i,disconnect:o}=e(e=>{if("id"in e){t(e);let{id:r,result:i}=e;if(s.has(r)){s.delete(r),l.set(i,new Set),n.set(i,new Map);return}let o=a.get(r);if(void 0!==o){a.delete(r);let s=e.result?.operationId;if(void 0!==s&&l.has(o)){let e=l.get(o);e.add(s);let a=n.get(o)?.get(s);a&&(a.forEach(t),n.get(o).delete(s),f(a.at(-1))&&e.delete(s))}}}else{let{subscription:s,result:a}=e.params,r=l.get(s);if(r){let{operationId:t}=e.params.result;if(void 0!==t){if(r.has(t))f(e)&&r.delete(t);else{let a=n.get(s),l=a.get(t)??[];l.push(e),a.set(t,l);return}}else a?.event==="stop"&&(l.delete(s),n.delete(s))}t(e)}});return{send:e=>{let t=e.params[0];switch(e.method){case r.follow:s.add(e.id);break;case r.body:case r.call:case r.storage:a.set(e.id,t);break;case r.unfollow:l.delete(t),n.delete(t);break;case r.stopOperation:l.get(t)?.delete(e.params[1])}i(e)},disconnect:o}},e=>t=>{let{send:s,disconnect:a}=e(t);return{send:e=>{let{method:t,params:a,id:l,...n}=e;

1t==r.unpin&&a&&Array.isArray(a[1])?a[1].forEach((e,r)=>{s({...n,id:0===r?l:`${l}-patched-${r}`,method:t,params:[a[0],e]})}):s(e)},disconnect:a}},e=>t=>e(e=>{let s=e.params?.result;if(!("id"in e)&&s){let{prunedBlockHashes:e,finalizedBlockHash:t,event:a}=s;"finalized"===a&&Array.isArray(e)?s.prunedBlockHashes=[...new Set(s.prunedBlockHashes)]:"initialized"===a&&t&&(s.finalizedBlockHashes=[s.finalizedBlockHash],delete s.finalizedBlockHash)}t(e)}),e=>t=>{let s=new Set,a=new Map,l=new Map,{send:n,disconnect:i}=e(e=>{if("id"in e){t(e);let{id:r,result:n}=e;if(s.has(r)){s.delete(r),a.set(n,new Set),l.set(n,new Map);return}}else{let{subscription:s}=e.params,r=a.get(s),n=l.get(s);if(r){let a=e.params.result,{event:i}=a;if("initialized"===i&&a.finalizedBlockHashes.forEach(e=>{r.add(e)}),"newBlock"===i){let{parentBlockHash:s}=a;if(!r.has(s)){let t=n.get(s)??[];t.push(e),n.set(s,t);return}let l=a.blockHash;r.add(a.blockHash),t(e);let i=n.get(l);i&&(n.delete(l),i.forEach(e=>{r.add(e.params.result.blockHash),t(e)}));return}"stop"===i&&(r.delete(s),l.delete(s))}t(e)}});return{send:e=>{let t=e.params[0];switch(e.method){case r.follow:s.add(e.id);break;case r.unpin:let[i,o]=e.params;o.forEach(e=>{a.get(i)?.delete(e),l.get(i)?.delete(e)});break;case r.unfollow:a.delete(t),l.delete(t)}n(e)},disconnect:i}},e=>t=>{let s=new Set,a=new Map,l=new Map,{send:n,disconnect:i}=e(e=>{if("id"in e){t(e);let{id:r,result:n}=e;if(s.has(r)){s.delete(r),a.set(n,new Set),l.set(n,new Map);return}}else{let{subscription:s}=e.params,r=a.get(s),n=l.get(s);if(r){let a=e.params.result,{event:i}=a;if("initialized"===i&&a.finalizedBlockHashes.forEach(e=>{r.add(e)}),"finalized"===i&&(a.prunedBlockHashes=a.prunedBlockHashes.filter(e=>r.has(e))),"newBlock"===i){r.add(a.blockHash);let s=a.blockHash,l=n.get(s);if(l){n.delete(s),t(e),Promise.resolve().then(()=>{t(l)});return}}if("bestBlockChanged"===i){let t=a.bestBlockHash;if(!r.has(t)){l.get(s).set(t,e);return}}"stop"===i&&(r.delete(s),l.delete(s))}t(e)}});return{send:e=>{let t=e.params[0];switch(e.method){case r.follow:s.add(e.id);break;case r.unpin:let[i,o]=e.params;o.forEach(e=>{a.get(i)?.delete(e),l.get(i)?.delete(e)});break;case r.unfollow:a.delete(t),l.delete(t)}n(e)},disconnect:i}},e=>t=>{let s=new Set,a=new Map,{send:l,disconnect:n}=e(e=>{if("id"in e){let{id:t,result:l}=e;s.has(t)&&(s.delete(t),a.set(l,()=>{a.delete(l)}))}else{let{subscription:s}=e.params,l=a.get(s);if(l){let r=e.params.result,{event:n}=r;if("initialized"===n){let e=setTimeout(()=>{a.delete(s),t(d(s,"bestBlockChanged",void 0,{bestBlockHash:r.finalizedBlockHashes.at(-1)}))},500);a.set(s,()=>{a.delete(s),clearTimeout(e)})}else m.has(n)&&l()}}t(e)});return{send(e){switch(e.method){case r.follow:s.add(e.id);break;case r.unfollow:a.get(e.params[0])?.()}l(e)},disconnect:n}},e=>t=>{let{send:s,disconnect:a}=e(t);return{send:e=>{switch(e.method){case i.chainName:return s({...e,method:"system_chain"});case i.genesisHash:return s({...e,method:"chain_getBlockHash",params:[0]});case i.properties:return s({...e,method:"system_properties"})}s(e)},disconnect:a}},e=>t=>{let[s,a]=c(e),l=p(a),n=new Map,i=new Map,{send:u,disconnect:f}=s(e=>{if("id"in e){let t=n.get(e.id);t&&(n.delete(e.id),"started"===e.result.result&&t(e.result.operationId))}else if(e.params){let{subscription:t,result:s}=e.params,{operationId:a}=s||{},l=i.get(t);l&&"stop"===s.event&&(l.forEach(e=>{e.cancel()}),i.delete(t));let r=l?.get(a);if(r)switch(s.event){case"operationInaccessible":case"operationError":r.cancel();break;case"operationStorageDone":if(r.isInnerDone)l.delete(a);else{r.isOutterDone=!0;return}}}t(e)}),m=(e,s,a)=>r=>{let n=()=>{};i.has(e)||i.set(e,new Map);let c=i.get(e),h={isOutterDone:!1,isInnerDone:!1,cancel:()=>{n()}};c.set(r,h);let p=0,f=a.map(i=>l(i,s,s=>{t(d(e,"operationStorageItems",r,{items:s.map(([e,t])=>({key:e,value:t}))}))},s=>{n(),h.isOutterDone||u(o({method:"chainHead_v1_stopOperation",params:[r]})),t(d(e,"operationError",r,{error:"string"==typeof s?s:JSON.stringify(s)}))},()=>{++p===a.length&&(h.isOutterDone?(n(),t(d(e,"operationStorageDone",r))):h.isInnerDone=!0)}));n=()=>

1{c.delete(r),f.forEach(e=>e())}};return{send:e=>{switch(e.method){case r.storage:{let[s,a,l]=e.params,r=[],d=l.filter(e=>{let t="descendantsValues"===e.type;return t&&r.push(e.key),!t}),c=m(s,a,r);if(d.length)r.length&&n.set(e.id,c);else{let a="__INNER_OP_DesV"+h++;t(o({id:e.id,result:{result:"started",operationId:a}})),c(a),i.get(s).get(a).isOutterDone=!0;return}e.params[2]=d;break}case r.stopOperation:{let[t,s]=e.params,a=i.get(t)?.get(s);if(a&&(a.cancel(),a.isOutterDone))return;break}case r.unfollow:{let[t]=e.params;i.get(t)?.forEach(e=>e.cancel()),i.delete(t)}}u(e)},disconnect:f}})}}]);