https://shibariumscan.io/_next/static/chunks/3120.a99872e459c99e33.js

1"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[3120],{63120:(e,t,o)=>{var r,n;function i(e){return null===e?"null":Array.isArray(e)?"array":typeof e}function a(e){return"object"===i(e)}function s(e,t){return e.length<124?e:t}function l(e){if(!a(e))throw Error(`Message is expected to be an object, but got ${i(e)}`);if(!e.type)throw Error("Message is missing the 'type' property");if("string"!=typeof e.type)throw Error(`Message is expects the 'type' property to be a string, but got ${i(e.type)}`);switch(e.type){case n.ConnectionInit:case n.ConnectionAck:case n.Ping:case n.Pong:if("payload"in e&&!a(e.payload))throw Error(`"${e.type}" message expects the 'payload' property to be an object or missing, but got "${e.payload}"`);break;case n.Subscribe:if("string"!=typeof e.id)throw Error(`"${e.type}" message expects the 'id' property to be a string, but got ${i(e.id)}`);if(!e.id)throw Error(`"${e.type}" message requires a non-empty 'id' property`);if(!a(e.payload))throw Error(`"${e.type}" message expects the 'payload' property to be an object, but got ${i(e.payload)}`);if("string"!=typeof e.payload.query)throw Error(`"${e.type}" message payload expects the 'query' property to be a string, but got ${i(e.payload.query)}`);if(null!=e.payload.variables&&!a(e.payload.variables))throw Error(`"${e.type}" message payload expects the 'variables' property to be a an object or nullish or missing, but got ${i(e.payload.variables)}`);if(null!=e.payload.operationName&&"string"!==i(e.payload.operationName))throw Error(`"${e.type}" message payload expects the 'operationName' property to be a string or nullish or missing, but got ${i(e.payload.operationName)}`);if(null!=e.payload.extensions&&!a(e.payload.extensions))throw Error(`"${e.type}" message payload expects the 'extensions' property to be a an object or nullish or missing, but got ${i(e.payload.extensions)}`);break;case n.Next:if("string"!=typeof e.id)throw Error(`"${e.type}" message expects the 'id' property to be a string, but got ${i(e.id)}`);if(!e.id)throw Error(`"${e.type}" message requires a non-empty 'id' property`);if(!a(e.payload))throw Error(`"${e.type}" message expects the 'payload' property to be an object, but got ${i(e.payload)}`);break;case n.Error:var t;if("string"!=typeof e.id)throw Error(`"${e.type}" message expects the 'id' property to be a string, but got ${i(e.id)}`);if(!e.id)throw Error(`"${e.type}" message requires a non-empty 'id' property`);if(!(Array.isArray(t=e.payload)&&t.length>0&&t.every(e=>"message"in e)))throw Error(`"${e.type}" message expects the 'payload' property to be an array of GraphQL errors, but got ${JSON.stringify(e.payload)}`);break;case n.Complete:if("string"!=typeof e.id)throw Error(`"${e.type}" message expects the 'id' property to be a string, but got ${i(e.id)}`);if(!e.id)throw Error(`"${e.type}" message requires a non-empty 'id' property`);break;default:throw Error(`Invalid message 'type' property "${e.type}"`)}return e}function p(e,t){return l(e),JSON.stringify(e,t)}function c(e){let t;let{url:o,connectionParams:i,lazy:a=!0,onNonLazyError:c=console.error,lazyCloseTimeout:y=0,keepAlive:u=0,disablePong:g,connectionAckWaitTimeout:m=0,retryAttempts:f=5,retryWait:b=async function(e){let t=1e3;for(let o=0;o<e;o++)t*=2;await new Promise(e=>setTimeout(e,t+Math.floor(2700*Math.random()+300)))},shouldRetry:h=d,isFatalConnectionProblem:w,on:x,webSocketImpl:E,generateID:S=function(){return"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,e=>{let t=16*Math.random()|0;return("x"==e?t:3&t|8).toString(16)})},jsonMessageReplacer:C,jsonMessageReviver:v}=e;if(E){var $;if(!("function"==typeof($=E)&&"constructor"in $&&"CLOSED"in $&&"CLOSING"in $&&"CONNECTING"in $&&"OPEN"in $))throw Error("Invalid WebSocket implementation provided");t=E}else"undefined"!=typeof WebSocket?t=WebSocket:"undefined"!=typeof global?t=global.WebSocket||global.MozWebSocket:"undefined"!=typeof window&&(t=window.WebSocket||window.MozWebSocket);if(!t)throw Error("WebSocket implementation missing; on Node you can `import WebSocket from 'ws';` and pass `webSocketImpl: WebSocket` to `createClient`");let k=t,N=(()=>{let e=(()=>{let e={};return{on:(t,o)=>(e[t]=o,()=>{delete e[t]}),emit(t){var o;"id"in t&&(null===(o=e[t.id])||void 0===o||o.call(e,t))}}})(),t={connecting:(null==x?void 0:x.connecting)?[x.connecting]:[],opened:(null==x?void 0:x.opened)?[x.opened]:[],connected:(null==x?void 0:x.connected)?[x.connected]:[],ping:(null==x?void 0:x.ping)?[x.ping]:[],pong:(null==x?void 0:x.pong)?[x.pong]:[],message:(null==x?void 0:x.message)?[e.emit,x.message]:[e.emit],closed:(null==x?void 0:x.closed)?[x.closed]:[],error:(null==x?void 0:x.error)?[x.error]:[]};return{onMessage:e.on,on(e,o){let r=t[e];return r.push(o),()=>{r.splice(r.indexOf(o),1)}},emit(e,...o){for(let r of[...t[e]])r(...o)}}})();function I(e){let t=[N.on("error",o=>

1{t.forEach(e=>e()),e(o)}),N.on("closed",o=>{t.forEach(e=>e()),e(o)})]}let T,A=0,P,M=!1,q=0,O=!1;async function R(){clearTimeout(P);let[e,t]=await (null!=T?T:T=new Promise((e,t)=>(async()=>{let a,c;if(M){if(await b(q),!A)return T=void 0,t({code:1e3,reason:"All Subscriptions Gone"});q++}N.emit("connecting");let y=new k("function"==typeof o?await o():o,"graphql-transport-ws");function f(){isFinite(u)&&u>0&&(clearTimeout(c),c=setTimeout(()=>{y.readyState===k.OPEN&&(y.send(p({type:n.Ping})),N.emit("ping",!1,void 0))},u))}I(e=>{T=void 0,clearTimeout(a),clearTimeout(c),t(e),d(e)&&4499===e.code&&(y.close(4499,"Terminated"),y.onerror=null,y.onclose=null)}),y.onerror=e=>N.emit("error",e),y.onclose=e=>N.emit("closed",e),y.onopen=async()=>{try{N.emit("opened",y);let e="function"==typeof i?await i():i;if(y.readyState!==k.OPEN)return;y.send(p(e?{type:n.ConnectionInit,payload:e}:{type:n.ConnectionInit},C)),isFinite(m)&&m>0&&(a=setTimeout(()=>{y.close(r.ConnectionAcknowledgementTimeout,"Connection acknowledgement timeout")},m)),f()}catch(e){N.emit("error",e),y.close(r.InternalClientError,s(e instanceof Error?e.message:Error(e).message,"Internal client error"))}};let h=!1;y.onmessage=({data:t})=>{try{let o=l("string"==typeof t?JSON.parse(t,v):t);if(N.emit("message",o),"ping"===o.type||"pong"===o.type){N.emit(o.type,!0,o.payload),"pong"===o.type?f():g||(y.send(p(o.payload?{type:n.Pong,payload:o.payload}:{type:n.Pong})),N.emit("pong",!1,o.payload));return}if(h)return;if(o.type!==n.ConnectionAck)throw Error(`First message cannot be of type ${o.type}`);clearTimeout(a),h=!0,N.emit("connected",y,o.payload),M=!1,q=0,e([y,new Promise((e,t)=>I(t))])}catch(e){y.onmessage=null,N.emit("error",e),y.close(r.BadResponse,s(e instanceof Error?e.message:Error(e).message,"Bad response"))}}})()));e.readyState===k.CLOSING&&await t;let a=()=>{},c=new Promise(e=>a=e);return[e,a,Promise.race([c.then(()=>{if(!A){let t=()=>e.close(1e3,"Normal Closure");isFinite(y)&&y>0?P=setTimeout(()=>{e.readyState===k.OPEN&&t()},y):t()}}),t])]}function W(e){var t;if(d(e)&&(![1e3,1001,1006,1005,1012,1013,1013].includes(t=e.code)&&t>=1e3&&t<=1999||[r.InternalServerError,r.InternalClientError,r.BadRequest,r.BadResponse,r.Unauthorized,r.SubprotocolNotAcceptable,r.SubscriberAlreadyExists,r.TooManyInitialisationRequests].includes(e.code)))throw e;if(O)return!1;if(d(e)&&1e3===e.code)return A>0;if(!f||q>=f||!h(e)||(null==w?void 0:w(e)))throw e;return M=!0}return a||(async()=>{for(A++;;)try{let[,,e]=await R();await e}catch(e){try{if(!W(e))return}catch(e){return null==c?void 0:c(e)}}})(),{on:N.on,subscribe(e,t){let o=S(e),r=!1,i=!1,a=()=>{A--,r=!0};return(async()=>{for(A++;;)try{let[s,l,c]=await R();if(r)return l();let d=N.onMessage(o,e=>{switch(e.type){case n.Next:t.next(e.payload);return;case n.Error:i=!0,r=!0,t.error(e.payload),a();return;case n.Complete:r=!0,a();return}});s.send(p({id:o,type:n.Subscribe,payload:e},C)),a=()=>{r||s.readyState!==k.OPEN||s.send(p({id:o,type:n.Complete},C)),A--,r=!0,l()},await c.finally(d);return}catch(e){if(!W(e))return}})().then(()=>{i||t.complete()}).catch(e=>{t.error(e)}),()=>{r||a()}},async dispose(){if(O=!0,T){let[e]=await T;e.close(1e3,"Normal Closure")}},terminate(){T&&N.emit("closed",{code:4499,reason:"Terminated",wasClean:!1})}}}function d(e){return a(e)&&"code"in e&&"reason"in e}o.d(t,{createClient:()=>c}),!function(e){e[e.InternalServerError=4500]="InternalServerError",e[e.InternalClientError=4005]="InternalClientError",e[e.BadRequest=4400]="BadRequest",e[e.BadResponse=4004]="BadResponse",e[e.Unauthorized=4401]="Unauthorized",e[e.Forbidden=4403]="Forbidden",e[e.SubprotocolNotAcceptable=4406]="SubprotocolNotAcceptable",e[e.ConnectionInitialisationTimeout=4408]="ConnectionInitialisationTimeout",e[e.ConnectionAcknowledgementTimeout=4504]="ConnectionAcknowledgementTimeout",e[e.SubscriberAlreadyExists=4409]="SubscriberAlreadyExists",e[e.TooManyInitialisationRequests=4429]="TooManyInitialisationRequests"}(r||(r={})),function(e){e.ConnectionInit="connection_init",e.ConnectionAck="connection_ack",e.Ping="ping",e.Pong="pong",e.Subscribe="subscribe",e.Next="next",e.Error="error",e.Complete="complete"}(n||(n={}))}}]);
2//# sourceMappingURL=3120.a99872e459c99e33.js.map