| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906 |
- import { hasInjectionContext, getCurrentInstance, defineComponent, createElementBlock, ref, inject, h, Suspense, Fragment, createApp, provide, shallowReactive, toRef, onErrorCaptured, onServerPrefetch, unref, createVNode, resolveDynamicComponent, reactive, effectScope, shallowRef, isReadonly, isRef, isShallow, isReactive, toRaw, defineAsyncComponent, mergeProps, getCurrentScope, useSSRContext } from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/vue@3.5.14_typescript@5.8.3/node_modules/vue/index.mjs';
- import ft from 'node:http';
- import Qa from 'node:https';
- import Ye from 'node:zlib';
- import ie, { PassThrough, pipeline } from 'node:stream';
- import { Buffer as Buffer$1 } from 'node:buffer';
- import { promisify, deprecate, types } from 'node:util';
- import { format } from 'node:url';
- import { isIP } from 'node:net';
- import { promises, statSync, createReadStream } from 'node:fs';
- import { basename } from 'node:path';
- import destr from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/destr@2.0.5/node_modules/destr/dist/index.mjs';
- import { hasProtocol, isScriptProtocol, joinURL, withQuery, withBase } from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/ufo@1.6.1/node_modules/ufo/dist/index.mjs';
- import { b as baseURL } from '../_/renderer.mjs';
- import { createHooks } from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/hookable@5.5.3/node_modules/hookable/dist/index.mjs';
- import { getContext, executeAsync } from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/unctx@2.4.1/node_modules/unctx/dist/index.mjs';
- import { sanitizeStatusCode, createError as createError$1, appendHeader } from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/h3@1.15.3/node_modules/h3/dist/index.mjs';
- import { RouterView, createMemoryHistory, createRouter, START_LOCATION } from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/vue-router@4.5.1_vue@3.5.14_typescript@5.8.3_/node_modules/vue-router/dist/vue-router.node.mjs';
- import { toRouteMatcher, createRouter as createRouter$1 } from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/radix3@1.1.2/node_modules/radix3/dist/index.mjs';
- import { defu } from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/defu@6.1.4/node_modules/defu/dist/defu.mjs';
- import { ssrRenderSuspense, ssrRenderComponent, ssrRenderVNode, ssrRenderAttrs, ssrRenderAttr, ssrInterpolate } from 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/vue@3.5.14_typescript@5.8.3/node_modules/vue/server-renderer/index.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/vue-bundle-renderer@2.1.1/node_modules/vue-bundle-renderer/dist/runtime.mjs';
- import '../nitro/nitro.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/ofetch@1.4.1/node_modules/ofetch/dist/node.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/node-mock-http@1.0.0/node_modules/node-mock-http/dist/index.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/unstorage@1.16.0_db0@0.3.2_ioredis@5.6.1/node_modules/unstorage/dist/index.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/unstorage@1.16.0_db0@0.3.2_ioredis@5.6.1/node_modules/unstorage/drivers/fs.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/unstorage@1.16.0_db0@0.3.2_ioredis@5.6.1/node_modules/unstorage/drivers/fs-lite.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/unstorage@1.16.0_db0@0.3.2_ioredis@5.6.1/node_modules/unstorage/drivers/lru-cache.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/ohash@2.0.11/node_modules/ohash/dist/index.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/klona@2.0.6/node_modules/klona/dist/index.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/scule@1.3.0/node_modules/scule/dist/index.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/pathe@2.0.3/node_modules/pathe/dist/index.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/unhead@2.0.9/node_modules/unhead/dist/server.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/devalue@5.1.1/node_modules/devalue/index.js';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/unhead@2.0.9/node_modules/unhead/dist/utils.mjs';
- import 'file:///Users/yuxin/local/code/ccdw-website/node_modules/.pnpm/unhead@2.0.9/node_modules/unhead/dist/plugins.mjs';
- var __typeError = (msg) => {
- throw TypeError(msg);
- };
- var __accessCheck = (obj, member, msg) => member.has(obj) || __typeError("Cannot " + msg);
- var __privateGet = (obj, member, getter) => (__accessCheck(obj, member, "read from private field"), getter ? getter.call(obj) : member.get(obj));
- var __privateAdd = (obj, member, value) => member.has(obj) ? __typeError("Cannot add the same private member more than once") : member instanceof WeakSet ? member.add(obj) : member.set(obj, value);
- var __privateSet = (obj, member, value, setter) => (__accessCheck(obj, member, "write to private field"), member.set(obj, value), value);
- var _e, _t, _r, _n, _a, _e2, _t2, _b, _e3, _c, _e4, _t3, _d, _e5, _f;
- var t = Object.defineProperty;
- var o$1 = (e, l) => t(e, "name", { value: l, configurable: true });
- var n$2 = typeof globalThis < "u" ? globalThis : typeof global < "u" ? global : typeof self < "u" ? self : {};
- function f(e) {
- return e && e.__esModule && Object.prototype.hasOwnProperty.call(e, "default") ? e.default : e;
- }
- o$1(f, "getDefaultExportFromCjs");
- var Va = Object.defineProperty;
- var n$1 = (i, o2) => Va(i, "name", { value: o2, configurable: true });
- function ts(i) {
- if (!/^data:/i.test(i)) throw new TypeError('`uri` does not appear to be a Data URI (must begin with "data:")');
- i = i.replace(/\r?\n/g, "");
- const o2 = i.indexOf(",");
- if (o2 === -1 || o2 <= 4) throw new TypeError("malformed data: URI");
- const a = i.substring(5, o2).split(";");
- let l = "", u = false;
- const m = a[0] || "text/plain";
- let h2 = m;
- for (let A = 1; A < a.length; A++) a[A] === "base64" ? u = true : a[A] && (h2 += `;${a[A]}`, a[A].indexOf("charset=") === 0 && (l = a[A].substring(8)));
- !a[0] && !l.length && (h2 += ";charset=US-ASCII", l = "US-ASCII");
- const S = u ? "base64" : "ascii", E = unescape(i.substring(o2 + 1)), w = Buffer.from(E, S);
- return w.type = m, w.typeFull = h2, w.charset = l, w;
- }
- n$1(ts, "dataUriToBuffer");
- var Eo = {}, ct = { exports: {} };
- /**
- * @license
- * web-streams-polyfill v3.3.3
- * Copyright 2024 Mattias Buelens, Diwank Singh Tomer and other contributors.
- * This code is released under the MIT license.
- * SPDX-License-Identifier: MIT
- */
- var rs = ct.exports, vo;
- function ns() {
- return vo || (vo = 1, function(i, o2) {
- (function(a, l) {
- l(o2);
- })(rs, function(a) {
- function l() {
- }
- n$1(l, "noop");
- function u(e) {
- return typeof e == "object" && e !== null || typeof e == "function";
- }
- n$1(u, "typeIsObject");
- const m = l;
- function h2(e, t2) {
- try {
- Object.defineProperty(e, "name", { value: t2, configurable: true });
- } catch {
- }
- }
- n$1(h2, "setFunctionName");
- const S = Promise, E = Promise.prototype.then, w = Promise.reject.bind(S);
- function A(e) {
- return new S(e);
- }
- n$1(A, "newPromise");
- function T2(e) {
- return A((t2) => t2(e));
- }
- n$1(T2, "promiseResolvedWith");
- function b(e) {
- return w(e);
- }
- n$1(b, "promiseRejectedWith");
- function q(e, t2, r2) {
- return E.call(e, t2, r2);
- }
- n$1(q, "PerformPromiseThen");
- function g(e, t2, r2) {
- q(q(e, t2, r2), void 0, m);
- }
- n$1(g, "uponPromise");
- function V(e, t2) {
- g(e, t2);
- }
- n$1(V, "uponFulfillment");
- function I(e, t2) {
- g(e, void 0, t2);
- }
- n$1(I, "uponRejection");
- function F(e, t2, r2) {
- return q(e, t2, r2);
- }
- n$1(F, "transformPromiseWith");
- function Q(e) {
- q(e, void 0, m);
- }
- n$1(Q, "setPromiseIsHandledToTrue");
- let se = n$1((e) => {
- if (typeof queueMicrotask == "function") se = queueMicrotask;
- else {
- const t2 = T2(void 0);
- se = n$1((r2) => q(t2, r2), "_queueMicrotask");
- }
- return se(e);
- }, "_queueMicrotask");
- function O(e, t2, r2) {
- if (typeof e != "function") throw new TypeError("Argument is not a function");
- return Function.prototype.apply.call(e, t2, r2);
- }
- n$1(O, "reflectCall");
- function z(e, t2, r2) {
- try {
- return T2(O(e, t2, r2));
- } catch (s) {
- return b(s);
- }
- }
- n$1(z, "promiseCall");
- const $ = 16384;
- const _M = class _M {
- constructor() {
- this._cursor = 0, this._size = 0, this._front = { _elements: [], _next: void 0 }, this._back = this._front, this._cursor = 0, this._size = 0;
- }
- get length() {
- return this._size;
- }
- push(t2) {
- const r2 = this._back;
- let s = r2;
- r2._elements.length === $ - 1 && (s = { _elements: [], _next: void 0 }), r2._elements.push(t2), s !== r2 && (this._back = s, r2._next = s), ++this._size;
- }
- shift() {
- const t2 = this._front;
- let r2 = t2;
- const s = this._cursor;
- let f2 = s + 1;
- const c = t2._elements, d = c[s];
- return f2 === $ && (r2 = t2._next, f2 = 0), --this._size, this._cursor = f2, t2 !== r2 && (this._front = r2), c[s] = void 0, d;
- }
- forEach(t2) {
- let r2 = this._cursor, s = this._front, f2 = s._elements;
- for (; (r2 !== f2.length || s._next !== void 0) && !(r2 === f2.length && (s = s._next, f2 = s._elements, r2 = 0, f2.length === 0)); ) t2(f2[r2]), ++r2;
- }
- peek() {
- const t2 = this._front, r2 = this._cursor;
- return t2._elements[r2];
- }
- };
- n$1(_M, "SimpleQueue");
- let M = _M;
- const pt = Symbol("[[AbortSteps]]"), an = Symbol("[[ErrorSteps]]"), ar = Symbol("[[CancelSteps]]"), sr = Symbol("[[PullSteps]]"), ur = Symbol("[[ReleaseSteps]]");
- function sn(e, t2) {
- e._ownerReadableStream = t2, t2._reader = e, t2._state === "readable" ? fr(e) : t2._state === "closed" ? ri(e) : un(e, t2._storedError);
- }
- n$1(sn, "ReadableStreamReaderGenericInitialize");
- function lr(e, t2) {
- const r2 = e._ownerReadableStream;
- return X(r2, t2);
- }
- n$1(lr, "ReadableStreamReaderGenericCancel");
- function ue(e) {
- const t2 = e._ownerReadableStream;
- t2._state === "readable" ? cr(e, new TypeError("Reader was released and can no longer be used to monitor the stream's closedness")) : ni(e, new TypeError("Reader was released and can no longer be used to monitor the stream's closedness")), t2._readableStreamController[ur](), t2._reader = void 0, e._ownerReadableStream = void 0;
- }
- n$1(ue, "ReadableStreamReaderGenericRelease");
- function yt(e) {
- return new TypeError("Cannot " + e + " a stream using a released reader");
- }
- n$1(yt, "readerLockException");
- function fr(e) {
- e._closedPromise = A((t2, r2) => {
- e._closedPromise_resolve = t2, e._closedPromise_reject = r2;
- });
- }
- n$1(fr, "defaultReaderClosedPromiseInitialize");
- function un(e, t2) {
- fr(e), cr(e, t2);
- }
- n$1(un, "defaultReaderClosedPromiseInitializeAsRejected");
- function ri(e) {
- fr(e), ln(e);
- }
- n$1(ri, "defaultReaderClosedPromiseInitializeAsResolved");
- function cr(e, t2) {
- e._closedPromise_reject !== void 0 && (Q(e._closedPromise), e._closedPromise_reject(t2), e._closedPromise_resolve = void 0, e._closedPromise_reject = void 0);
- }
- n$1(cr, "defaultReaderClosedPromiseReject");
- function ni(e, t2) {
- un(e, t2);
- }
- n$1(ni, "defaultReaderClosedPromiseResetToRejected");
- function ln(e) {
- e._closedPromise_resolve !== void 0 && (e._closedPromise_resolve(void 0), e._closedPromise_resolve = void 0, e._closedPromise_reject = void 0);
- }
- n$1(ln, "defaultReaderClosedPromiseResolve");
- const fn = Number.isFinite || function(e) {
- return typeof e == "number" && isFinite(e);
- }, oi = Math.trunc || function(e) {
- return e < 0 ? Math.ceil(e) : Math.floor(e);
- };
- function ii(e) {
- return typeof e == "object" || typeof e == "function";
- }
- n$1(ii, "isDictionary");
- function ne(e, t2) {
- if (e !== void 0 && !ii(e)) throw new TypeError(`${t2} is not an object.`);
- }
- n$1(ne, "assertDictionary");
- function G(e, t2) {
- if (typeof e != "function") throw new TypeError(`${t2} is not a function.`);
- }
- n$1(G, "assertFunction");
- function ai(e) {
- return typeof e == "object" && e !== null || typeof e == "function";
- }
- n$1(ai, "isObject");
- function cn(e, t2) {
- if (!ai(e)) throw new TypeError(`${t2} is not an object.`);
- }
- n$1(cn, "assertObject");
- function le(e, t2, r2) {
- if (e === void 0) throw new TypeError(`Parameter ${t2} is required in '${r2}'.`);
- }
- n$1(le, "assertRequiredArgument");
- function dr(e, t2, r2) {
- if (e === void 0) throw new TypeError(`${t2} is required in '${r2}'.`);
- }
- n$1(dr, "assertRequiredField");
- function hr(e) {
- return Number(e);
- }
- n$1(hr, "convertUnrestrictedDouble");
- function dn(e) {
- return e === 0 ? 0 : e;
- }
- n$1(dn, "censorNegativeZero");
- function si(e) {
- return dn(oi(e));
- }
- n$1(si, "integerPart");
- function mr(e, t2) {
- const s = Number.MAX_SAFE_INTEGER;
- let f2 = Number(e);
- if (f2 = dn(f2), !fn(f2)) throw new TypeError(`${t2} is not a finite number`);
- if (f2 = si(f2), f2 < 0 || f2 > s) throw new TypeError(`${t2} is outside the accepted range of 0 to ${s}, inclusive`);
- return !fn(f2) || f2 === 0 ? 0 : f2;
- }
- n$1(mr, "convertUnsignedLongLongWithEnforceRange");
- function br(e, t2) {
- if (!Te(e)) throw new TypeError(`${t2} is not a ReadableStream.`);
- }
- n$1(br, "assertReadableStream");
- function ze(e) {
- return new ye(e);
- }
- n$1(ze, "AcquireReadableStreamDefaultReader");
- function hn(e, t2) {
- e._reader._readRequests.push(t2);
- }
- n$1(hn, "ReadableStreamAddReadRequest");
- function pr(e, t2, r2) {
- const f2 = e._reader._readRequests.shift();
- r2 ? f2._closeSteps() : f2._chunkSteps(t2);
- }
- n$1(pr, "ReadableStreamFulfillReadRequest");
- function gt(e) {
- return e._reader._readRequests.length;
- }
- n$1(gt, "ReadableStreamGetNumReadRequests");
- function mn(e) {
- const t2 = e._reader;
- return !(t2 === void 0 || !ge(t2));
- }
- n$1(mn, "ReadableStreamHasDefaultReader");
- const _ye = class _ye {
- constructor(t2) {
- if (le(t2, 1, "ReadableStreamDefaultReader"), br(t2, "First parameter"), Ce(t2)) throw new TypeError("This stream has already been locked for exclusive reading by another reader");
- sn(this, t2), this._readRequests = new M();
- }
- get closed() {
- return ge(this) ? this._closedPromise : b(_t4("closed"));
- }
- cancel(t2 = void 0) {
- return ge(this) ? this._ownerReadableStream === void 0 ? b(yt("cancel")) : lr(this, t2) : b(_t4("cancel"));
- }
- read() {
- if (!ge(this)) return b(_t4("read"));
- if (this._ownerReadableStream === void 0) return b(yt("read from"));
- let t2, r2;
- const s = A((c, d) => {
- t2 = c, r2 = d;
- });
- return et(this, { _chunkSteps: n$1((c) => t2({ value: c, done: false }), "_chunkSteps"), _closeSteps: n$1(() => t2({ value: void 0, done: true }), "_closeSteps"), _errorSteps: n$1((c) => r2(c), "_errorSteps") }), s;
- }
- releaseLock() {
- if (!ge(this)) throw _t4("releaseLock");
- this._ownerReadableStream !== void 0 && ui(this);
- }
- };
- n$1(_ye, "ReadableStreamDefaultReader");
- let ye = _ye;
- Object.defineProperties(ye.prototype, { cancel: { enumerable: true }, read: { enumerable: true }, releaseLock: { enumerable: true }, closed: { enumerable: true } }), h2(ye.prototype.cancel, "cancel"), h2(ye.prototype.read, "read"), h2(ye.prototype.releaseLock, "releaseLock"), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(ye.prototype, Symbol.toStringTag, { value: "ReadableStreamDefaultReader", configurable: true });
- function ge(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_readRequests") ? false : e instanceof ye;
- }
- n$1(ge, "IsReadableStreamDefaultReader");
- function et(e, t2) {
- const r2 = e._ownerReadableStream;
- r2._disturbed = true, r2._state === "closed" ? t2._closeSteps() : r2._state === "errored" ? t2._errorSteps(r2._storedError) : r2._readableStreamController[sr](t2);
- }
- n$1(et, "ReadableStreamDefaultReaderRead");
- function ui(e) {
- ue(e);
- const t2 = new TypeError("Reader was released");
- bn(e, t2);
- }
- n$1(ui, "ReadableStreamDefaultReaderRelease");
- function bn(e, t2) {
- const r2 = e._readRequests;
- e._readRequests = new M(), r2.forEach((s) => {
- s._errorSteps(t2);
- });
- }
- n$1(bn, "ReadableStreamDefaultReaderErrorReadRequests");
- function _t4(e) {
- return new TypeError(`ReadableStreamDefaultReader.prototype.${e} can only be used on a ReadableStreamDefaultReader`);
- }
- n$1(_t4, "defaultReaderBrandCheckException");
- const li = Object.getPrototypeOf(Object.getPrototypeOf(async function* () {
- }).prototype);
- const _pn = class _pn {
- constructor(t2, r2) {
- this._ongoingPromise = void 0, this._isFinished = false, this._reader = t2, this._preventCancel = r2;
- }
- next() {
- const t2 = n$1(() => this._nextSteps(), "nextSteps");
- return this._ongoingPromise = this._ongoingPromise ? F(this._ongoingPromise, t2, t2) : t2(), this._ongoingPromise;
- }
- return(t2) {
- const r2 = n$1(() => this._returnSteps(t2), "returnSteps");
- return this._ongoingPromise ? F(this._ongoingPromise, r2, r2) : r2();
- }
- _nextSteps() {
- if (this._isFinished) return Promise.resolve({ value: void 0, done: true });
- const t2 = this._reader;
- let r2, s;
- const f2 = A((d, p) => {
- r2 = d, s = p;
- });
- return et(t2, { _chunkSteps: n$1((d) => {
- this._ongoingPromise = void 0, se(() => r2({ value: d, done: false }));
- }, "_chunkSteps"), _closeSteps: n$1(() => {
- this._ongoingPromise = void 0, this._isFinished = true, ue(t2), r2({ value: void 0, done: true });
- }, "_closeSteps"), _errorSteps: n$1((d) => {
- this._ongoingPromise = void 0, this._isFinished = true, ue(t2), s(d);
- }, "_errorSteps") }), f2;
- }
- _returnSteps(t2) {
- if (this._isFinished) return Promise.resolve({ value: t2, done: true });
- this._isFinished = true;
- const r2 = this._reader;
- if (!this._preventCancel) {
- const s = lr(r2, t2);
- return ue(r2), F(s, () => ({ value: t2, done: true }));
- }
- return ue(r2), T2({ value: t2, done: true });
- }
- };
- n$1(_pn, "ReadableStreamAsyncIteratorImpl");
- let pn = _pn;
- const yn = { next() {
- return gn(this) ? this._asyncIteratorImpl.next() : b(_n2("next"));
- }, return(e) {
- return gn(this) ? this._asyncIteratorImpl.return(e) : b(_n2("return"));
- } };
- Object.setPrototypeOf(yn, li);
- function fi(e, t2) {
- const r2 = ze(e), s = new pn(r2, t2), f2 = Object.create(yn);
- return f2._asyncIteratorImpl = s, f2;
- }
- n$1(fi, "AcquireReadableStreamAsyncIterator");
- function gn(e) {
- if (!u(e) || !Object.prototype.hasOwnProperty.call(e, "_asyncIteratorImpl")) return false;
- try {
- return e._asyncIteratorImpl instanceof pn;
- } catch {
- return false;
- }
- }
- n$1(gn, "IsReadableStreamAsyncIterator");
- function _n2(e) {
- return new TypeError(`ReadableStreamAsyncIterator.${e} can only be used on a ReadableSteamAsyncIterator`);
- }
- n$1(_n2, "streamAsyncIteratorBrandCheckException");
- const Sn = Number.isNaN || function(e) {
- return e !== e;
- };
- var yr, gr, _r2;
- function tt(e) {
- return e.slice();
- }
- n$1(tt, "CreateArrayFromList");
- function wn(e, t2, r2, s, f2) {
- new Uint8Array(e).set(new Uint8Array(r2, s, f2), t2);
- }
- n$1(wn, "CopyDataBlockBytes");
- let fe = n$1((e) => (typeof e.transfer == "function" ? fe = n$1((t2) => t2.transfer(), "TransferArrayBuffer") : typeof structuredClone == "function" ? fe = n$1((t2) => structuredClone(t2, { transfer: [t2] }), "TransferArrayBuffer") : fe = n$1((t2) => t2, "TransferArrayBuffer"), fe(e)), "TransferArrayBuffer"), _e6 = n$1((e) => (typeof e.detached == "boolean" ? _e6 = n$1((t2) => t2.detached, "IsDetachedBuffer") : _e6 = n$1((t2) => t2.byteLength === 0, "IsDetachedBuffer"), _e6(e)), "IsDetachedBuffer");
- function Rn(e, t2, r2) {
- if (e.slice) return e.slice(t2, r2);
- const s = r2 - t2, f2 = new ArrayBuffer(s);
- return wn(f2, 0, e, t2, s), f2;
- }
- n$1(Rn, "ArrayBufferSlice");
- function St(e, t2) {
- const r2 = e[t2];
- if (r2 != null) {
- if (typeof r2 != "function") throw new TypeError(`${String(t2)} is not a function`);
- return r2;
- }
- }
- n$1(St, "GetMethod");
- function ci(e) {
- const t2 = { [Symbol.iterator]: () => e.iterator }, r2 = async function* () {
- return yield* t2;
- }(), s = r2.next;
- return { iterator: r2, nextMethod: s, done: false };
- }
- n$1(ci, "CreateAsyncFromSyncIterator");
- const Sr = (_r2 = (yr = Symbol.asyncIterator) !== null && yr !== void 0 ? yr : (gr = Symbol.for) === null || gr === void 0 ? void 0 : gr.call(Symbol, "Symbol.asyncIterator")) !== null && _r2 !== void 0 ? _r2 : "@@asyncIterator";
- function Tn(e, t2 = "sync", r2) {
- if (r2 === void 0) if (t2 === "async") {
- if (r2 = St(e, Sr), r2 === void 0) {
- const c = St(e, Symbol.iterator), d = Tn(e, "sync", c);
- return ci(d);
- }
- } else r2 = St(e, Symbol.iterator);
- if (r2 === void 0) throw new TypeError("The object is not iterable");
- const s = O(r2, e, []);
- if (!u(s)) throw new TypeError("The iterator method must return an object");
- const f2 = s.next;
- return { iterator: s, nextMethod: f2, done: false };
- }
- n$1(Tn, "GetIterator");
- function di(e) {
- const t2 = O(e.nextMethod, e.iterator, []);
- if (!u(t2)) throw new TypeError("The iterator.next() method must return an object");
- return t2;
- }
- n$1(di, "IteratorNext");
- function hi(e) {
- return !!e.done;
- }
- n$1(hi, "IteratorComplete");
- function mi(e) {
- return e.value;
- }
- n$1(mi, "IteratorValue");
- function bi(e) {
- return !(typeof e != "number" || Sn(e) || e < 0);
- }
- n$1(bi, "IsNonNegativeNumber");
- function Cn(e) {
- const t2 = Rn(e.buffer, e.byteOffset, e.byteOffset + e.byteLength);
- return new Uint8Array(t2);
- }
- n$1(Cn, "CloneAsUint8Array");
- function wr(e) {
- const t2 = e._queue.shift();
- return e._queueTotalSize -= t2.size, e._queueTotalSize < 0 && (e._queueTotalSize = 0), t2.value;
- }
- n$1(wr, "DequeueValue");
- function Rr(e, t2, r2) {
- if (!bi(r2) || r2 === 1 / 0) throw new RangeError("Size must be a finite, non-NaN, non-negative number.");
- e._queue.push({ value: t2, size: r2 }), e._queueTotalSize += r2;
- }
- n$1(Rr, "EnqueueValueWithSize");
- function pi(e) {
- return e._queue.peek().value;
- }
- n$1(pi, "PeekQueueValue");
- function Se(e) {
- e._queue = new M(), e._queueTotalSize = 0;
- }
- n$1(Se, "ResetQueue");
- function Pn(e) {
- return e === DataView;
- }
- n$1(Pn, "isDataViewConstructor");
- function yi(e) {
- return Pn(e.constructor);
- }
- n$1(yi, "isDataView");
- function gi(e) {
- return Pn(e) ? 1 : e.BYTES_PER_ELEMENT;
- }
- n$1(gi, "arrayBufferViewElementSize");
- const _ve = class _ve {
- constructor() {
- throw new TypeError("Illegal constructor");
- }
- get view() {
- if (!Tr(this)) throw Ar("view");
- return this._view;
- }
- respond(t2) {
- if (!Tr(this)) throw Ar("respond");
- if (le(t2, 1, "respond"), t2 = mr(t2, "First parameter"), this._associatedReadableByteStreamController === void 0) throw new TypeError("This BYOB request has been invalidated");
- if (_e6(this._view.buffer)) throw new TypeError("The BYOB request's buffer has been detached and so cannot be used as a response");
- Ct(this._associatedReadableByteStreamController, t2);
- }
- respondWithNewView(t2) {
- if (!Tr(this)) throw Ar("respondWithNewView");
- if (le(t2, 1, "respondWithNewView"), !ArrayBuffer.isView(t2)) throw new TypeError("You can only respond with array buffer views");
- if (this._associatedReadableByteStreamController === void 0) throw new TypeError("This BYOB request has been invalidated");
- if (_e6(t2.buffer)) throw new TypeError("The given view's buffer has been detached and so cannot be used as a response");
- Pt(this._associatedReadableByteStreamController, t2);
- }
- };
- n$1(_ve, "ReadableStreamBYOBRequest");
- let ve = _ve;
- Object.defineProperties(ve.prototype, { respond: { enumerable: true }, respondWithNewView: { enumerable: true }, view: { enumerable: true } }), h2(ve.prototype.respond, "respond"), h2(ve.prototype.respondWithNewView, "respondWithNewView"), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(ve.prototype, Symbol.toStringTag, { value: "ReadableStreamBYOBRequest", configurable: true });
- const _ce = class _ce {
- constructor() {
- throw new TypeError("Illegal constructor");
- }
- get byobRequest() {
- if (!Ae(this)) throw nt("byobRequest");
- return vr(this);
- }
- get desiredSize() {
- if (!Ae(this)) throw nt("desiredSize");
- return Fn(this);
- }
- close() {
- if (!Ae(this)) throw nt("close");
- if (this._closeRequested) throw new TypeError("The stream has already been closed; do not close it again!");
- const t2 = this._controlledReadableByteStream._state;
- if (t2 !== "readable") throw new TypeError(`The stream (in ${t2} state) is not in the readable state and cannot be closed`);
- rt(this);
- }
- enqueue(t2) {
- if (!Ae(this)) throw nt("enqueue");
- if (le(t2, 1, "enqueue"), !ArrayBuffer.isView(t2)) throw new TypeError("chunk must be an array buffer view");
- if (t2.byteLength === 0) throw new TypeError("chunk must have non-zero byteLength");
- if (t2.buffer.byteLength === 0) throw new TypeError("chunk's buffer must have non-zero byteLength");
- if (this._closeRequested) throw new TypeError("stream is closed or draining");
- const r2 = this._controlledReadableByteStream._state;
- if (r2 !== "readable") throw new TypeError(`The stream (in ${r2} state) is not in the readable state and cannot be enqueued to`);
- Tt(this, t2);
- }
- error(t2 = void 0) {
- if (!Ae(this)) throw nt("error");
- Z(this, t2);
- }
- [ar](t2) {
- En(this), Se(this);
- const r2 = this._cancelAlgorithm(t2);
- return Rt(this), r2;
- }
- [sr](t2) {
- const r2 = this._controlledReadableByteStream;
- if (this._queueTotalSize > 0) {
- In(this, t2);
- return;
- }
- const s = this._autoAllocateChunkSize;
- if (s !== void 0) {
- let f2;
- try {
- f2 = new ArrayBuffer(s);
- } catch (d) {
- t2._errorSteps(d);
- return;
- }
- const c = { buffer: f2, bufferByteLength: s, byteOffset: 0, byteLength: s, bytesFilled: 0, minimumFill: 1, elementSize: 1, viewConstructor: Uint8Array, readerType: "default" };
- this._pendingPullIntos.push(c);
- }
- hn(r2, t2), Be(this);
- }
- [ur]() {
- if (this._pendingPullIntos.length > 0) {
- const t2 = this._pendingPullIntos.peek();
- t2.readerType = "none", this._pendingPullIntos = new M(), this._pendingPullIntos.push(t2);
- }
- }
- };
- n$1(_ce, "ReadableByteStreamController");
- let ce = _ce;
- Object.defineProperties(ce.prototype, { close: { enumerable: true }, enqueue: { enumerable: true }, error: { enumerable: true }, byobRequest: { enumerable: true }, desiredSize: { enumerable: true } }), h2(ce.prototype.close, "close"), h2(ce.prototype.enqueue, "enqueue"), h2(ce.prototype.error, "error"), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(ce.prototype, Symbol.toStringTag, { value: "ReadableByteStreamController", configurable: true });
- function Ae(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_controlledReadableByteStream") ? false : e instanceof ce;
- }
- n$1(Ae, "IsReadableByteStreamController");
- function Tr(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_associatedReadableByteStreamController") ? false : e instanceof ve;
- }
- n$1(Tr, "IsReadableStreamBYOBRequest");
- function Be(e) {
- if (!Ti(e)) return;
- if (e._pulling) {
- e._pullAgain = true;
- return;
- }
- e._pulling = true;
- const r2 = e._pullAlgorithm();
- g(r2, () => (e._pulling = false, e._pullAgain && (e._pullAgain = false, Be(e)), null), (s) => (Z(e, s), null));
- }
- n$1(Be, "ReadableByteStreamControllerCallPullIfNeeded");
- function En(e) {
- Pr(e), e._pendingPullIntos = new M();
- }
- n$1(En, "ReadableByteStreamControllerClearPendingPullIntos");
- function Cr(e, t2) {
- let r2 = false;
- e._state === "closed" && (r2 = true);
- const s = vn(t2);
- t2.readerType === "default" ? pr(e, s, r2) : Bi(e, s, r2);
- }
- n$1(Cr, "ReadableByteStreamControllerCommitPullIntoDescriptor");
- function vn(e) {
- const t2 = e.bytesFilled, r2 = e.elementSize;
- return new e.viewConstructor(e.buffer, e.byteOffset, t2 / r2);
- }
- n$1(vn, "ReadableByteStreamControllerConvertPullIntoDescriptor");
- function wt(e, t2, r2, s) {
- e._queue.push({ buffer: t2, byteOffset: r2, byteLength: s }), e._queueTotalSize += s;
- }
- n$1(wt, "ReadableByteStreamControllerEnqueueChunkToQueue");
- function An(e, t2, r2, s) {
- let f2;
- try {
- f2 = Rn(t2, r2, r2 + s);
- } catch (c) {
- throw Z(e, c), c;
- }
- wt(e, f2, 0, s);
- }
- n$1(An, "ReadableByteStreamControllerEnqueueClonedChunkToQueue");
- function Bn(e, t2) {
- t2.bytesFilled > 0 && An(e, t2.buffer, t2.byteOffset, t2.bytesFilled), je(e);
- }
- n$1(Bn, "ReadableByteStreamControllerEnqueueDetachedPullIntoToQueue");
- function Wn(e, t2) {
- const r2 = Math.min(e._queueTotalSize, t2.byteLength - t2.bytesFilled), s = t2.bytesFilled + r2;
- let f2 = r2, c = false;
- const d = s % t2.elementSize, p = s - d;
- p >= t2.minimumFill && (f2 = p - t2.bytesFilled, c = true);
- const R = e._queue;
- for (; f2 > 0; ) {
- const y = R.peek(), C = Math.min(f2, y.byteLength), P = t2.byteOffset + t2.bytesFilled;
- wn(t2.buffer, P, y.buffer, y.byteOffset, C), y.byteLength === C ? R.shift() : (y.byteOffset += C, y.byteLength -= C), e._queueTotalSize -= C, kn(e, C, t2), f2 -= C;
- }
- return c;
- }
- n$1(Wn, "ReadableByteStreamControllerFillPullIntoDescriptorFromQueue");
- function kn(e, t2, r2) {
- r2.bytesFilled += t2;
- }
- n$1(kn, "ReadableByteStreamControllerFillHeadPullIntoDescriptor");
- function qn(e) {
- e._queueTotalSize === 0 && e._closeRequested ? (Rt(e), lt(e._controlledReadableByteStream)) : Be(e);
- }
- n$1(qn, "ReadableByteStreamControllerHandleQueueDrain");
- function Pr(e) {
- e._byobRequest !== null && (e._byobRequest._associatedReadableByteStreamController = void 0, e._byobRequest._view = null, e._byobRequest = null);
- }
- n$1(Pr, "ReadableByteStreamControllerInvalidateBYOBRequest");
- function Er(e) {
- for (; e._pendingPullIntos.length > 0; ) {
- if (e._queueTotalSize === 0) return;
- const t2 = e._pendingPullIntos.peek();
- Wn(e, t2) && (je(e), Cr(e._controlledReadableByteStream, t2));
- }
- }
- n$1(Er, "ReadableByteStreamControllerProcessPullIntoDescriptorsUsingQueue");
- function _i(e) {
- const t2 = e._controlledReadableByteStream._reader;
- for (; t2._readRequests.length > 0; ) {
- if (e._queueTotalSize === 0) return;
- const r2 = t2._readRequests.shift();
- In(e, r2);
- }
- }
- n$1(_i, "ReadableByteStreamControllerProcessReadRequestsUsingQueue");
- function Si(e, t2, r2, s) {
- const f2 = e._controlledReadableByteStream, c = t2.constructor, d = gi(c), { byteOffset: p, byteLength: R } = t2, y = r2 * d;
- let C;
- try {
- C = fe(t2.buffer);
- } catch (B) {
- s._errorSteps(B);
- return;
- }
- const P = { buffer: C, bufferByteLength: C.byteLength, byteOffset: p, byteLength: R, bytesFilled: 0, minimumFill: y, elementSize: d, viewConstructor: c, readerType: "byob" };
- if (e._pendingPullIntos.length > 0) {
- e._pendingPullIntos.push(P), Ln(f2, s);
- return;
- }
- if (f2._state === "closed") {
- const B = new c(P.buffer, P.byteOffset, 0);
- s._closeSteps(B);
- return;
- }
- if (e._queueTotalSize > 0) {
- if (Wn(e, P)) {
- const B = vn(P);
- qn(e), s._chunkSteps(B);
- return;
- }
- if (e._closeRequested) {
- const B = new TypeError("Insufficient bytes to fill elements in the given buffer");
- Z(e, B), s._errorSteps(B);
- return;
- }
- }
- e._pendingPullIntos.push(P), Ln(f2, s), Be(e);
- }
- n$1(Si, "ReadableByteStreamControllerPullInto");
- function wi(e, t2) {
- t2.readerType === "none" && je(e);
- const r2 = e._controlledReadableByteStream;
- if (Br(r2)) for (; Dn(r2) > 0; ) {
- const s = je(e);
- Cr(r2, s);
- }
- }
- n$1(wi, "ReadableByteStreamControllerRespondInClosedState");
- function Ri(e, t2, r2) {
- if (kn(e, t2, r2), r2.readerType === "none") {
- Bn(e, r2), Er(e);
- return;
- }
- if (r2.bytesFilled < r2.minimumFill) return;
- je(e);
- const s = r2.bytesFilled % r2.elementSize;
- if (s > 0) {
- const f2 = r2.byteOffset + r2.bytesFilled;
- An(e, r2.buffer, f2 - s, s);
- }
- r2.bytesFilled -= s, Cr(e._controlledReadableByteStream, r2), Er(e);
- }
- n$1(Ri, "ReadableByteStreamControllerRespondInReadableState");
- function On(e, t2) {
- const r2 = e._pendingPullIntos.peek();
- Pr(e), e._controlledReadableByteStream._state === "closed" ? wi(e, r2) : Ri(e, t2, r2), Be(e);
- }
- n$1(On, "ReadableByteStreamControllerRespondInternal");
- function je(e) {
- return e._pendingPullIntos.shift();
- }
- n$1(je, "ReadableByteStreamControllerShiftPendingPullInto");
- function Ti(e) {
- const t2 = e._controlledReadableByteStream;
- return t2._state !== "readable" || e._closeRequested || !e._started ? false : !!(mn(t2) && gt(t2) > 0 || Br(t2) && Dn(t2) > 0 || Fn(e) > 0);
- }
- n$1(Ti, "ReadableByteStreamControllerShouldCallPull");
- function Rt(e) {
- e._pullAlgorithm = void 0, e._cancelAlgorithm = void 0;
- }
- n$1(Rt, "ReadableByteStreamControllerClearAlgorithms");
- function rt(e) {
- const t2 = e._controlledReadableByteStream;
- if (!(e._closeRequested || t2._state !== "readable")) {
- if (e._queueTotalSize > 0) {
- e._closeRequested = true;
- return;
- }
- if (e._pendingPullIntos.length > 0) {
- const r2 = e._pendingPullIntos.peek();
- if (r2.bytesFilled % r2.elementSize !== 0) {
- const s = new TypeError("Insufficient bytes to fill elements in the given buffer");
- throw Z(e, s), s;
- }
- }
- Rt(e), lt(t2);
- }
- }
- n$1(rt, "ReadableByteStreamControllerClose");
- function Tt(e, t2) {
- const r2 = e._controlledReadableByteStream;
- if (e._closeRequested || r2._state !== "readable") return;
- const { buffer: s, byteOffset: f2, byteLength: c } = t2;
- if (_e6(s)) throw new TypeError("chunk's buffer is detached and so cannot be enqueued");
- const d = fe(s);
- if (e._pendingPullIntos.length > 0) {
- const p = e._pendingPullIntos.peek();
- if (_e6(p.buffer)) throw new TypeError("The BYOB request's buffer has been detached and so cannot be filled with an enqueued chunk");
- Pr(e), p.buffer = fe(p.buffer), p.readerType === "none" && Bn(e, p);
- }
- if (mn(r2)) if (_i(e), gt(r2) === 0) wt(e, d, f2, c);
- else {
- e._pendingPullIntos.length > 0 && je(e);
- const p = new Uint8Array(d, f2, c);
- pr(r2, p, false);
- }
- else Br(r2) ? (wt(e, d, f2, c), Er(e)) : wt(e, d, f2, c);
- Be(e);
- }
- n$1(Tt, "ReadableByteStreamControllerEnqueue");
- function Z(e, t2) {
- const r2 = e._controlledReadableByteStream;
- r2._state === "readable" && (En(e), Se(e), Rt(e), lo(r2, t2));
- }
- n$1(Z, "ReadableByteStreamControllerError");
- function In(e, t2) {
- const r2 = e._queue.shift();
- e._queueTotalSize -= r2.byteLength, qn(e);
- const s = new Uint8Array(r2.buffer, r2.byteOffset, r2.byteLength);
- t2._chunkSteps(s);
- }
- n$1(In, "ReadableByteStreamControllerFillReadRequestFromQueue");
- function vr(e) {
- if (e._byobRequest === null && e._pendingPullIntos.length > 0) {
- const t2 = e._pendingPullIntos.peek(), r2 = new Uint8Array(t2.buffer, t2.byteOffset + t2.bytesFilled, t2.byteLength - t2.bytesFilled), s = Object.create(ve.prototype);
- Pi(s, e, r2), e._byobRequest = s;
- }
- return e._byobRequest;
- }
- n$1(vr, "ReadableByteStreamControllerGetBYOBRequest");
- function Fn(e) {
- const t2 = e._controlledReadableByteStream._state;
- return t2 === "errored" ? null : t2 === "closed" ? 0 : e._strategyHWM - e._queueTotalSize;
- }
- n$1(Fn, "ReadableByteStreamControllerGetDesiredSize");
- function Ct(e, t2) {
- const r2 = e._pendingPullIntos.peek();
- if (e._controlledReadableByteStream._state === "closed") {
- if (t2 !== 0) throw new TypeError("bytesWritten must be 0 when calling respond() on a closed stream");
- } else {
- if (t2 === 0) throw new TypeError("bytesWritten must be greater than 0 when calling respond() on a readable stream");
- if (r2.bytesFilled + t2 > r2.byteLength) throw new RangeError("bytesWritten out of range");
- }
- r2.buffer = fe(r2.buffer), On(e, t2);
- }
- n$1(Ct, "ReadableByteStreamControllerRespond");
- function Pt(e, t2) {
- const r2 = e._pendingPullIntos.peek();
- if (e._controlledReadableByteStream._state === "closed") {
- if (t2.byteLength !== 0) throw new TypeError("The view's length must be 0 when calling respondWithNewView() on a closed stream");
- } else if (t2.byteLength === 0) throw new TypeError("The view's length must be greater than 0 when calling respondWithNewView() on a readable stream");
- if (r2.byteOffset + r2.bytesFilled !== t2.byteOffset) throw new RangeError("The region specified by view does not match byobRequest");
- if (r2.bufferByteLength !== t2.buffer.byteLength) throw new RangeError("The buffer of view has different capacity than byobRequest");
- if (r2.bytesFilled + t2.byteLength > r2.byteLength) throw new RangeError("The region specified by view is larger than byobRequest");
- const f2 = t2.byteLength;
- r2.buffer = fe(t2.buffer), On(e, f2);
- }
- n$1(Pt, "ReadableByteStreamControllerRespondWithNewView");
- function zn(e, t2, r2, s, f2, c, d) {
- t2._controlledReadableByteStream = e, t2._pullAgain = false, t2._pulling = false, t2._byobRequest = null, t2._queue = t2._queueTotalSize = void 0, Se(t2), t2._closeRequested = false, t2._started = false, t2._strategyHWM = c, t2._pullAlgorithm = s, t2._cancelAlgorithm = f2, t2._autoAllocateChunkSize = d, t2._pendingPullIntos = new M(), e._readableStreamController = t2;
- const p = r2();
- g(T2(p), () => (t2._started = true, Be(t2), null), (R) => (Z(t2, R), null));
- }
- n$1(zn, "SetUpReadableByteStreamController");
- function Ci(e, t2, r2) {
- const s = Object.create(ce.prototype);
- let f2, c, d;
- t2.start !== void 0 ? f2 = n$1(() => t2.start(s), "startAlgorithm") : f2 = n$1(() => {
- }, "startAlgorithm"), t2.pull !== void 0 ? c = n$1(() => t2.pull(s), "pullAlgorithm") : c = n$1(() => T2(void 0), "pullAlgorithm"), t2.cancel !== void 0 ? d = n$1((R) => t2.cancel(R), "cancelAlgorithm") : d = n$1(() => T2(void 0), "cancelAlgorithm");
- const p = t2.autoAllocateChunkSize;
- if (p === 0) throw new TypeError("autoAllocateChunkSize must be greater than 0");
- zn(e, s, f2, c, d, r2, p);
- }
- n$1(Ci, "SetUpReadableByteStreamControllerFromUnderlyingSource");
- function Pi(e, t2, r2) {
- e._associatedReadableByteStreamController = t2, e._view = r2;
- }
- n$1(Pi, "SetUpReadableStreamBYOBRequest");
- function Ar(e) {
- return new TypeError(`ReadableStreamBYOBRequest.prototype.${e} can only be used on a ReadableStreamBYOBRequest`);
- }
- n$1(Ar, "byobRequestBrandCheckException");
- function nt(e) {
- return new TypeError(`ReadableByteStreamController.prototype.${e} can only be used on a ReadableByteStreamController`);
- }
- n$1(nt, "byteStreamControllerBrandCheckException");
- function Ei(e, t2) {
- ne(e, t2);
- const r2 = e == null ? void 0 : e.mode;
- return { mode: r2 === void 0 ? void 0 : vi(r2, `${t2} has member 'mode' that`) };
- }
- n$1(Ei, "convertReaderOptions");
- function vi(e, t2) {
- if (e = `${e}`, e !== "byob") throw new TypeError(`${t2} '${e}' is not a valid enumeration value for ReadableStreamReaderMode`);
- return e;
- }
- n$1(vi, "convertReadableStreamReaderMode");
- function Ai(e, t2) {
- var r2;
- ne(e, t2);
- const s = (r2 = e == null ? void 0 : e.min) !== null && r2 !== void 0 ? r2 : 1;
- return { min: mr(s, `${t2} has member 'min' that`) };
- }
- n$1(Ai, "convertByobReadOptions");
- function jn(e) {
- return new we(e);
- }
- n$1(jn, "AcquireReadableStreamBYOBReader");
- function Ln(e, t2) {
- e._reader._readIntoRequests.push(t2);
- }
- n$1(Ln, "ReadableStreamAddReadIntoRequest");
- function Bi(e, t2, r2) {
- const f2 = e._reader._readIntoRequests.shift();
- r2 ? f2._closeSteps(t2) : f2._chunkSteps(t2);
- }
- n$1(Bi, "ReadableStreamFulfillReadIntoRequest");
- function Dn(e) {
- return e._reader._readIntoRequests.length;
- }
- n$1(Dn, "ReadableStreamGetNumReadIntoRequests");
- function Br(e) {
- const t2 = e._reader;
- return !(t2 === void 0 || !We(t2));
- }
- n$1(Br, "ReadableStreamHasBYOBReader");
- const _we = class _we {
- constructor(t2) {
- if (le(t2, 1, "ReadableStreamBYOBReader"), br(t2, "First parameter"), Ce(t2)) throw new TypeError("This stream has already been locked for exclusive reading by another reader");
- if (!Ae(t2._readableStreamController)) throw new TypeError("Cannot construct a ReadableStreamBYOBReader for a stream not constructed with a byte source");
- sn(this, t2), this._readIntoRequests = new M();
- }
- get closed() {
- return We(this) ? this._closedPromise : b(Et("closed"));
- }
- cancel(t2 = void 0) {
- return We(this) ? this._ownerReadableStream === void 0 ? b(yt("cancel")) : lr(this, t2) : b(Et("cancel"));
- }
- read(t2, r2 = {}) {
- if (!We(this)) return b(Et("read"));
- if (!ArrayBuffer.isView(t2)) return b(new TypeError("view must be an array buffer view"));
- if (t2.byteLength === 0) return b(new TypeError("view must have non-zero byteLength"));
- if (t2.buffer.byteLength === 0) return b(new TypeError("view's buffer must have non-zero byteLength"));
- if (_e6(t2.buffer)) return b(new TypeError("view's buffer has been detached"));
- let s;
- try {
- s = Ai(r2, "options");
- } catch (y) {
- return b(y);
- }
- const f2 = s.min;
- if (f2 === 0) return b(new TypeError("options.min must be greater than 0"));
- if (yi(t2)) {
- if (f2 > t2.byteLength) return b(new RangeError("options.min must be less than or equal to view's byteLength"));
- } else if (f2 > t2.length) return b(new RangeError("options.min must be less than or equal to view's length"));
- if (this._ownerReadableStream === void 0) return b(yt("read from"));
- let c, d;
- const p = A((y, C) => {
- c = y, d = C;
- });
- return $n(this, t2, f2, { _chunkSteps: n$1((y) => c({ value: y, done: false }), "_chunkSteps"), _closeSteps: n$1((y) => c({ value: y, done: true }), "_closeSteps"), _errorSteps: n$1((y) => d(y), "_errorSteps") }), p;
- }
- releaseLock() {
- if (!We(this)) throw Et("releaseLock");
- this._ownerReadableStream !== void 0 && Wi(this);
- }
- };
- n$1(_we, "ReadableStreamBYOBReader");
- let we = _we;
- Object.defineProperties(we.prototype, { cancel: { enumerable: true }, read: { enumerable: true }, releaseLock: { enumerable: true }, closed: { enumerable: true } }), h2(we.prototype.cancel, "cancel"), h2(we.prototype.read, "read"), h2(we.prototype.releaseLock, "releaseLock"), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(we.prototype, Symbol.toStringTag, { value: "ReadableStreamBYOBReader", configurable: true });
- function We(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_readIntoRequests") ? false : e instanceof we;
- }
- n$1(We, "IsReadableStreamBYOBReader");
- function $n(e, t2, r2, s) {
- const f2 = e._ownerReadableStream;
- f2._disturbed = true, f2._state === "errored" ? s._errorSteps(f2._storedError) : Si(f2._readableStreamController, t2, r2, s);
- }
- n$1($n, "ReadableStreamBYOBReaderRead");
- function Wi(e) {
- ue(e);
- const t2 = new TypeError("Reader was released");
- Mn(e, t2);
- }
- n$1(Wi, "ReadableStreamBYOBReaderRelease");
- function Mn(e, t2) {
- const r2 = e._readIntoRequests;
- e._readIntoRequests = new M(), r2.forEach((s) => {
- s._errorSteps(t2);
- });
- }
- n$1(Mn, "ReadableStreamBYOBReaderErrorReadIntoRequests");
- function Et(e) {
- return new TypeError(`ReadableStreamBYOBReader.prototype.${e} can only be used on a ReadableStreamBYOBReader`);
- }
- n$1(Et, "byobReaderBrandCheckException");
- function ot(e, t2) {
- const { highWaterMark: r2 } = e;
- if (r2 === void 0) return t2;
- if (Sn(r2) || r2 < 0) throw new RangeError("Invalid highWaterMark");
- return r2;
- }
- n$1(ot, "ExtractHighWaterMark");
- function vt(e) {
- const { size: t2 } = e;
- return t2 || (() => 1);
- }
- n$1(vt, "ExtractSizeAlgorithm");
- function At(e, t2) {
- ne(e, t2);
- const r2 = e == null ? void 0 : e.highWaterMark, s = e == null ? void 0 : e.size;
- return { highWaterMark: r2 === void 0 ? void 0 : hr(r2), size: s === void 0 ? void 0 : ki(s, `${t2} has member 'size' that`) };
- }
- n$1(At, "convertQueuingStrategy");
- function ki(e, t2) {
- return G(e, t2), (r2) => hr(e(r2));
- }
- n$1(ki, "convertQueuingStrategySize");
- function qi(e, t2) {
- ne(e, t2);
- const r2 = e == null ? void 0 : e.abort, s = e == null ? void 0 : e.close, f2 = e == null ? void 0 : e.start, c = e == null ? void 0 : e.type, d = e == null ? void 0 : e.write;
- return { abort: r2 === void 0 ? void 0 : Oi(r2, e, `${t2} has member 'abort' that`), close: s === void 0 ? void 0 : Ii(s, e, `${t2} has member 'close' that`), start: f2 === void 0 ? void 0 : Fi(f2, e, `${t2} has member 'start' that`), write: d === void 0 ? void 0 : zi(d, e, `${t2} has member 'write' that`), type: c };
- }
- n$1(qi, "convertUnderlyingSink");
- function Oi(e, t2, r2) {
- return G(e, r2), (s) => z(e, t2, [s]);
- }
- n$1(Oi, "convertUnderlyingSinkAbortCallback");
- function Ii(e, t2, r2) {
- return G(e, r2), () => z(e, t2, []);
- }
- n$1(Ii, "convertUnderlyingSinkCloseCallback");
- function Fi(e, t2, r2) {
- return G(e, r2), (s) => O(e, t2, [s]);
- }
- n$1(Fi, "convertUnderlyingSinkStartCallback");
- function zi(e, t2, r2) {
- return G(e, r2), (s, f2) => z(e, t2, [s, f2]);
- }
- n$1(zi, "convertUnderlyingSinkWriteCallback");
- function Un(e, t2) {
- if (!Le(e)) throw new TypeError(`${t2} is not a WritableStream.`);
- }
- n$1(Un, "assertWritableStream");
- function ji(e) {
- if (typeof e != "object" || e === null) return false;
- try {
- return typeof e.aborted == "boolean";
- } catch {
- return false;
- }
- }
- n$1(ji, "isAbortSignal");
- const Li = typeof AbortController == "function";
- function Di() {
- if (Li) return new AbortController();
- }
- n$1(Di, "createAbortController");
- const _Re = class _Re {
- constructor(t2 = {}, r2 = {}) {
- t2 === void 0 ? t2 = null : cn(t2, "First parameter");
- const s = At(r2, "Second parameter"), f2 = qi(t2, "First parameter");
- if (Nn(this), f2.type !== void 0) throw new RangeError("Invalid type is specified");
- const d = vt(s), p = ot(s, 1);
- Xi(this, f2, p, d);
- }
- get locked() {
- if (!Le(this)) throw Ot("locked");
- return De(this);
- }
- abort(t2 = void 0) {
- return Le(this) ? De(this) ? b(new TypeError("Cannot abort a stream that already has a writer")) : Bt(this, t2) : b(Ot("abort"));
- }
- close() {
- return Le(this) ? De(this) ? b(new TypeError("Cannot close a stream that already has a writer")) : oe(this) ? b(new TypeError("Cannot close an already-closing stream")) : Hn(this) : b(Ot("close"));
- }
- getWriter() {
- if (!Le(this)) throw Ot("getWriter");
- return xn(this);
- }
- };
- n$1(_Re, "WritableStream");
- let Re = _Re;
- Object.defineProperties(Re.prototype, { abort: { enumerable: true }, close: { enumerable: true }, getWriter: { enumerable: true }, locked: { enumerable: true } }), h2(Re.prototype.abort, "abort"), h2(Re.prototype.close, "close"), h2(Re.prototype.getWriter, "getWriter"), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(Re.prototype, Symbol.toStringTag, { value: "WritableStream", configurable: true });
- function xn(e) {
- return new de(e);
- }
- n$1(xn, "AcquireWritableStreamDefaultWriter");
- function $i(e, t2, r2, s, f2 = 1, c = () => 1) {
- const d = Object.create(Re.prototype);
- Nn(d);
- const p = Object.create($e.prototype);
- return Kn(d, p, e, t2, r2, s, f2, c), d;
- }
- n$1($i, "CreateWritableStream");
- function Nn(e) {
- e._state = "writable", e._storedError = void 0, e._writer = void 0, e._writableStreamController = void 0, e._writeRequests = new M(), e._inFlightWriteRequest = void 0, e._closeRequest = void 0, e._inFlightCloseRequest = void 0, e._pendingAbortRequest = void 0, e._backpressure = false;
- }
- n$1(Nn, "InitializeWritableStream");
- function Le(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_writableStreamController") ? false : e instanceof Re;
- }
- n$1(Le, "IsWritableStream");
- function De(e) {
- return e._writer !== void 0;
- }
- n$1(De, "IsWritableStreamLocked");
- function Bt(e, t2) {
- var r2;
- if (e._state === "closed" || e._state === "errored") return T2(void 0);
- e._writableStreamController._abortReason = t2, (r2 = e._writableStreamController._abortController) === null || r2 === void 0 || r2.abort(t2);
- const s = e._state;
- if (s === "closed" || s === "errored") return T2(void 0);
- if (e._pendingAbortRequest !== void 0) return e._pendingAbortRequest._promise;
- let f2 = false;
- s === "erroring" && (f2 = true, t2 = void 0);
- const c = A((d, p) => {
- e._pendingAbortRequest = { _promise: void 0, _resolve: d, _reject: p, _reason: t2, _wasAlreadyErroring: f2 };
- });
- return e._pendingAbortRequest._promise = c, f2 || kr(e, t2), c;
- }
- n$1(Bt, "WritableStreamAbort");
- function Hn(e) {
- const t2 = e._state;
- if (t2 === "closed" || t2 === "errored") return b(new TypeError(`The stream (in ${t2} state) is not in the writable state and cannot be closed`));
- const r2 = A((f2, c) => {
- const d = { _resolve: f2, _reject: c };
- e._closeRequest = d;
- }), s = e._writer;
- return s !== void 0 && e._backpressure && t2 === "writable" && Dr(s), ea(e._writableStreamController), r2;
- }
- n$1(Hn, "WritableStreamClose");
- function Mi(e) {
- return A((r2, s) => {
- const f2 = { _resolve: r2, _reject: s };
- e._writeRequests.push(f2);
- });
- }
- n$1(Mi, "WritableStreamAddWriteRequest");
- function Wr(e, t2) {
- if (e._state === "writable") {
- kr(e, t2);
- return;
- }
- qr(e);
- }
- n$1(Wr, "WritableStreamDealWithRejection");
- function kr(e, t2) {
- const r2 = e._writableStreamController;
- e._state = "erroring", e._storedError = t2;
- const s = e._writer;
- s !== void 0 && Qn(s, t2), !Vi(e) && r2._started && qr(e);
- }
- n$1(kr, "WritableStreamStartErroring");
- function qr(e) {
- e._state = "errored", e._writableStreamController[an]();
- const t2 = e._storedError;
- if (e._writeRequests.forEach((f2) => {
- f2._reject(t2);
- }), e._writeRequests = new M(), e._pendingAbortRequest === void 0) {
- Wt(e);
- return;
- }
- const r2 = e._pendingAbortRequest;
- if (e._pendingAbortRequest = void 0, r2._wasAlreadyErroring) {
- r2._reject(t2), Wt(e);
- return;
- }
- const s = e._writableStreamController[pt](r2._reason);
- g(s, () => (r2._resolve(), Wt(e), null), (f2) => (r2._reject(f2), Wt(e), null));
- }
- n$1(qr, "WritableStreamFinishErroring");
- function Ui(e) {
- e._inFlightWriteRequest._resolve(void 0), e._inFlightWriteRequest = void 0;
- }
- n$1(Ui, "WritableStreamFinishInFlightWrite");
- function xi(e, t2) {
- e._inFlightWriteRequest._reject(t2), e._inFlightWriteRequest = void 0, Wr(e, t2);
- }
- n$1(xi, "WritableStreamFinishInFlightWriteWithError");
- function Ni(e) {
- e._inFlightCloseRequest._resolve(void 0), e._inFlightCloseRequest = void 0, e._state === "erroring" && (e._storedError = void 0, e._pendingAbortRequest !== void 0 && (e._pendingAbortRequest._resolve(), e._pendingAbortRequest = void 0)), e._state = "closed";
- const r2 = e._writer;
- r2 !== void 0 && to(r2);
- }
- n$1(Ni, "WritableStreamFinishInFlightClose");
- function Hi(e, t2) {
- e._inFlightCloseRequest._reject(t2), e._inFlightCloseRequest = void 0, e._pendingAbortRequest !== void 0 && (e._pendingAbortRequest._reject(t2), e._pendingAbortRequest = void 0), Wr(e, t2);
- }
- n$1(Hi, "WritableStreamFinishInFlightCloseWithError");
- function oe(e) {
- return !(e._closeRequest === void 0 && e._inFlightCloseRequest === void 0);
- }
- n$1(oe, "WritableStreamCloseQueuedOrInFlight");
- function Vi(e) {
- return !(e._inFlightWriteRequest === void 0 && e._inFlightCloseRequest === void 0);
- }
- n$1(Vi, "WritableStreamHasOperationMarkedInFlight");
- function Qi(e) {
- e._inFlightCloseRequest = e._closeRequest, e._closeRequest = void 0;
- }
- n$1(Qi, "WritableStreamMarkCloseRequestInFlight");
- function Yi(e) {
- e._inFlightWriteRequest = e._writeRequests.shift();
- }
- n$1(Yi, "WritableStreamMarkFirstWriteRequestInFlight");
- function Wt(e) {
- e._closeRequest !== void 0 && (e._closeRequest._reject(e._storedError), e._closeRequest = void 0);
- const t2 = e._writer;
- t2 !== void 0 && jr(t2, e._storedError);
- }
- n$1(Wt, "WritableStreamRejectCloseAndClosedPromiseIfNeeded");
- function Or(e, t2) {
- const r2 = e._writer;
- r2 !== void 0 && t2 !== e._backpressure && (t2 ? sa(r2) : Dr(r2)), e._backpressure = t2;
- }
- n$1(Or, "WritableStreamUpdateBackpressure");
- const _de = class _de {
- constructor(t2) {
- if (le(t2, 1, "WritableStreamDefaultWriter"), Un(t2, "First parameter"), De(t2)) throw new TypeError("This stream has already been locked for exclusive writing by another writer");
- this._ownerWritableStream = t2, t2._writer = this;
- const r2 = t2._state;
- if (r2 === "writable") !oe(t2) && t2._backpressure ? Ft(this) : ro(this), It(this);
- else if (r2 === "erroring") Lr(this, t2._storedError), It(this);
- else if (r2 === "closed") ro(this), ia(this);
- else {
- const s = t2._storedError;
- Lr(this, s), eo(this, s);
- }
- }
- get closed() {
- return ke(this) ? this._closedPromise : b(qe("closed"));
- }
- get desiredSize() {
- if (!ke(this)) throw qe("desiredSize");
- if (this._ownerWritableStream === void 0) throw at("desiredSize");
- return Ji(this);
- }
- get ready() {
- return ke(this) ? this._readyPromise : b(qe("ready"));
- }
- abort(t2 = void 0) {
- return ke(this) ? this._ownerWritableStream === void 0 ? b(at("abort")) : Gi(this, t2) : b(qe("abort"));
- }
- close() {
- if (!ke(this)) return b(qe("close"));
- const t2 = this._ownerWritableStream;
- return t2 === void 0 ? b(at("close")) : oe(t2) ? b(new TypeError("Cannot close an already-closing stream")) : Vn(this);
- }
- releaseLock() {
- if (!ke(this)) throw qe("releaseLock");
- this._ownerWritableStream !== void 0 && Yn(this);
- }
- write(t2 = void 0) {
- return ke(this) ? this._ownerWritableStream === void 0 ? b(at("write to")) : Gn(this, t2) : b(qe("write"));
- }
- };
- n$1(_de, "WritableStreamDefaultWriter");
- let de = _de;
- Object.defineProperties(de.prototype, { abort: { enumerable: true }, close: { enumerable: true }, releaseLock: { enumerable: true }, write: { enumerable: true }, closed: { enumerable: true }, desiredSize: { enumerable: true }, ready: { enumerable: true } }), h2(de.prototype.abort, "abort"), h2(de.prototype.close, "close"), h2(de.prototype.releaseLock, "releaseLock"), h2(de.prototype.write, "write"), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(de.prototype, Symbol.toStringTag, { value: "WritableStreamDefaultWriter", configurable: true });
- function ke(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_ownerWritableStream") ? false : e instanceof de;
- }
- n$1(ke, "IsWritableStreamDefaultWriter");
- function Gi(e, t2) {
- const r2 = e._ownerWritableStream;
- return Bt(r2, t2);
- }
- n$1(Gi, "WritableStreamDefaultWriterAbort");
- function Vn(e) {
- const t2 = e._ownerWritableStream;
- return Hn(t2);
- }
- n$1(Vn, "WritableStreamDefaultWriterClose");
- function Zi(e) {
- const t2 = e._ownerWritableStream, r2 = t2._state;
- return oe(t2) || r2 === "closed" ? T2(void 0) : r2 === "errored" ? b(t2._storedError) : Vn(e);
- }
- n$1(Zi, "WritableStreamDefaultWriterCloseWithErrorPropagation");
- function Ki(e, t2) {
- e._closedPromiseState === "pending" ? jr(e, t2) : aa(e, t2);
- }
- n$1(Ki, "WritableStreamDefaultWriterEnsureClosedPromiseRejected");
- function Qn(e, t2) {
- e._readyPromiseState === "pending" ? no(e, t2) : ua(e, t2);
- }
- n$1(Qn, "WritableStreamDefaultWriterEnsureReadyPromiseRejected");
- function Ji(e) {
- const t2 = e._ownerWritableStream, r2 = t2._state;
- return r2 === "errored" || r2 === "erroring" ? null : r2 === "closed" ? 0 : Jn(t2._writableStreamController);
- }
- n$1(Ji, "WritableStreamDefaultWriterGetDesiredSize");
- function Yn(e) {
- const t2 = e._ownerWritableStream, r2 = new TypeError("Writer was released and can no longer be used to monitor the stream's closedness");
- Qn(e, r2), Ki(e, r2), t2._writer = void 0, e._ownerWritableStream = void 0;
- }
- n$1(Yn, "WritableStreamDefaultWriterRelease");
- function Gn(e, t2) {
- const r2 = e._ownerWritableStream, s = r2._writableStreamController, f2 = ta(s, t2);
- if (r2 !== e._ownerWritableStream) return b(at("write to"));
- const c = r2._state;
- if (c === "errored") return b(r2._storedError);
- if (oe(r2) || c === "closed") return b(new TypeError("The stream is closing or closed and cannot be written to"));
- if (c === "erroring") return b(r2._storedError);
- const d = Mi(r2);
- return ra(s, t2, f2), d;
- }
- n$1(Gn, "WritableStreamDefaultWriterWrite");
- const Zn = {};
- const _$e = class _$e {
- constructor() {
- throw new TypeError("Illegal constructor");
- }
- get abortReason() {
- if (!Ir(this)) throw zr("abortReason");
- return this._abortReason;
- }
- get signal() {
- if (!Ir(this)) throw zr("signal");
- if (this._abortController === void 0) throw new TypeError("WritableStreamDefaultController.prototype.signal is not supported");
- return this._abortController.signal;
- }
- error(t2 = void 0) {
- if (!Ir(this)) throw zr("error");
- this._controlledWritableStream._state === "writable" && Xn(this, t2);
- }
- [pt](t2) {
- const r2 = this._abortAlgorithm(t2);
- return kt(this), r2;
- }
- [an]() {
- Se(this);
- }
- };
- n$1(_$e, "WritableStreamDefaultController");
- let $e = _$e;
- Object.defineProperties($e.prototype, { abortReason: { enumerable: true }, signal: { enumerable: true }, error: { enumerable: true } }), typeof Symbol.toStringTag == "symbol" && Object.defineProperty($e.prototype, Symbol.toStringTag, { value: "WritableStreamDefaultController", configurable: true });
- function Ir(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_controlledWritableStream") ? false : e instanceof $e;
- }
- n$1(Ir, "IsWritableStreamDefaultController");
- function Kn(e, t2, r2, s, f2, c, d, p) {
- t2._controlledWritableStream = e, e._writableStreamController = t2, t2._queue = void 0, t2._queueTotalSize = void 0, Se(t2), t2._abortReason = void 0, t2._abortController = Di(), t2._started = false, t2._strategySizeAlgorithm = p, t2._strategyHWM = d, t2._writeAlgorithm = s, t2._closeAlgorithm = f2, t2._abortAlgorithm = c;
- const R = Fr(t2);
- Or(e, R);
- const y = r2(), C = T2(y);
- g(C, () => (t2._started = true, qt(t2), null), (P) => (t2._started = true, Wr(e, P), null));
- }
- n$1(Kn, "SetUpWritableStreamDefaultController");
- function Xi(e, t2, r2, s) {
- const f2 = Object.create($e.prototype);
- let c, d, p, R;
- t2.start !== void 0 ? c = n$1(() => t2.start(f2), "startAlgorithm") : c = n$1(() => {
- }, "startAlgorithm"), t2.write !== void 0 ? d = n$1((y) => t2.write(y, f2), "writeAlgorithm") : d = n$1(() => T2(void 0), "writeAlgorithm"), t2.close !== void 0 ? p = n$1(() => t2.close(), "closeAlgorithm") : p = n$1(() => T2(void 0), "closeAlgorithm"), t2.abort !== void 0 ? R = n$1((y) => t2.abort(y), "abortAlgorithm") : R = n$1(() => T2(void 0), "abortAlgorithm"), Kn(e, f2, c, d, p, R, r2, s);
- }
- n$1(Xi, "SetUpWritableStreamDefaultControllerFromUnderlyingSink");
- function kt(e) {
- e._writeAlgorithm = void 0, e._closeAlgorithm = void 0, e._abortAlgorithm = void 0, e._strategySizeAlgorithm = void 0;
- }
- n$1(kt, "WritableStreamDefaultControllerClearAlgorithms");
- function ea(e) {
- Rr(e, Zn, 0), qt(e);
- }
- n$1(ea, "WritableStreamDefaultControllerClose");
- function ta(e, t2) {
- try {
- return e._strategySizeAlgorithm(t2);
- } catch (r2) {
- return it(e, r2), 1;
- }
- }
- n$1(ta, "WritableStreamDefaultControllerGetChunkSize");
- function Jn(e) {
- return e._strategyHWM - e._queueTotalSize;
- }
- n$1(Jn, "WritableStreamDefaultControllerGetDesiredSize");
- function ra(e, t2, r2) {
- try {
- Rr(e, t2, r2);
- } catch (f2) {
- it(e, f2);
- return;
- }
- const s = e._controlledWritableStream;
- if (!oe(s) && s._state === "writable") {
- const f2 = Fr(e);
- Or(s, f2);
- }
- qt(e);
- }
- n$1(ra, "WritableStreamDefaultControllerWrite");
- function qt(e) {
- const t2 = e._controlledWritableStream;
- if (!e._started || t2._inFlightWriteRequest !== void 0) return;
- if (t2._state === "erroring") {
- qr(t2);
- return;
- }
- if (e._queue.length === 0) return;
- const s = pi(e);
- s === Zn ? na(e) : oa(e, s);
- }
- n$1(qt, "WritableStreamDefaultControllerAdvanceQueueIfNeeded");
- function it(e, t2) {
- e._controlledWritableStream._state === "writable" && Xn(e, t2);
- }
- n$1(it, "WritableStreamDefaultControllerErrorIfNeeded");
- function na(e) {
- const t2 = e._controlledWritableStream;
- Qi(t2), wr(e);
- const r2 = e._closeAlgorithm();
- kt(e), g(r2, () => (Ni(t2), null), (s) => (Hi(t2, s), null));
- }
- n$1(na, "WritableStreamDefaultControllerProcessClose");
- function oa(e, t2) {
- const r2 = e._controlledWritableStream;
- Yi(r2);
- const s = e._writeAlgorithm(t2);
- g(s, () => {
- Ui(r2);
- const f2 = r2._state;
- if (wr(e), !oe(r2) && f2 === "writable") {
- const c = Fr(e);
- Or(r2, c);
- }
- return qt(e), null;
- }, (f2) => (r2._state === "writable" && kt(e), xi(r2, f2), null));
- }
- n$1(oa, "WritableStreamDefaultControllerProcessWrite");
- function Fr(e) {
- return Jn(e) <= 0;
- }
- n$1(Fr, "WritableStreamDefaultControllerGetBackpressure");
- function Xn(e, t2) {
- const r2 = e._controlledWritableStream;
- kt(e), kr(r2, t2);
- }
- n$1(Xn, "WritableStreamDefaultControllerError");
- function Ot(e) {
- return new TypeError(`WritableStream.prototype.${e} can only be used on a WritableStream`);
- }
- n$1(Ot, "streamBrandCheckException$2");
- function zr(e) {
- return new TypeError(`WritableStreamDefaultController.prototype.${e} can only be used on a WritableStreamDefaultController`);
- }
- n$1(zr, "defaultControllerBrandCheckException$2");
- function qe(e) {
- return new TypeError(`WritableStreamDefaultWriter.prototype.${e} can only be used on a WritableStreamDefaultWriter`);
- }
- n$1(qe, "defaultWriterBrandCheckException");
- function at(e) {
- return new TypeError("Cannot " + e + " a stream using a released writer");
- }
- n$1(at, "defaultWriterLockException");
- function It(e) {
- e._closedPromise = A((t2, r2) => {
- e._closedPromise_resolve = t2, e._closedPromise_reject = r2, e._closedPromiseState = "pending";
- });
- }
- n$1(It, "defaultWriterClosedPromiseInitialize");
- function eo(e, t2) {
- It(e), jr(e, t2);
- }
- n$1(eo, "defaultWriterClosedPromiseInitializeAsRejected");
- function ia(e) {
- It(e), to(e);
- }
- n$1(ia, "defaultWriterClosedPromiseInitializeAsResolved");
- function jr(e, t2) {
- e._closedPromise_reject !== void 0 && (Q(e._closedPromise), e._closedPromise_reject(t2), e._closedPromise_resolve = void 0, e._closedPromise_reject = void 0, e._closedPromiseState = "rejected");
- }
- n$1(jr, "defaultWriterClosedPromiseReject");
- function aa(e, t2) {
- eo(e, t2);
- }
- n$1(aa, "defaultWriterClosedPromiseResetToRejected");
- function to(e) {
- e._closedPromise_resolve !== void 0 && (e._closedPromise_resolve(void 0), e._closedPromise_resolve = void 0, e._closedPromise_reject = void 0, e._closedPromiseState = "resolved");
- }
- n$1(to, "defaultWriterClosedPromiseResolve");
- function Ft(e) {
- e._readyPromise = A((t2, r2) => {
- e._readyPromise_resolve = t2, e._readyPromise_reject = r2;
- }), e._readyPromiseState = "pending";
- }
- n$1(Ft, "defaultWriterReadyPromiseInitialize");
- function Lr(e, t2) {
- Ft(e), no(e, t2);
- }
- n$1(Lr, "defaultWriterReadyPromiseInitializeAsRejected");
- function ro(e) {
- Ft(e), Dr(e);
- }
- n$1(ro, "defaultWriterReadyPromiseInitializeAsResolved");
- function no(e, t2) {
- e._readyPromise_reject !== void 0 && (Q(e._readyPromise), e._readyPromise_reject(t2), e._readyPromise_resolve = void 0, e._readyPromise_reject = void 0, e._readyPromiseState = "rejected");
- }
- n$1(no, "defaultWriterReadyPromiseReject");
- function sa(e) {
- Ft(e);
- }
- n$1(sa, "defaultWriterReadyPromiseReset");
- function ua(e, t2) {
- Lr(e, t2);
- }
- n$1(ua, "defaultWriterReadyPromiseResetToRejected");
- function Dr(e) {
- e._readyPromise_resolve !== void 0 && (e._readyPromise_resolve(void 0), e._readyPromise_resolve = void 0, e._readyPromise_reject = void 0, e._readyPromiseState = "fulfilled");
- }
- n$1(Dr, "defaultWriterReadyPromiseResolve");
- function la() {
- if (typeof globalThis < "u") return globalThis;
- if (typeof self < "u") return self;
- if (typeof n$2 < "u") return n$2;
- }
- n$1(la, "getGlobals");
- const $r = la();
- function fa(e) {
- if (!(typeof e == "function" || typeof e == "object") || e.name !== "DOMException") return false;
- try {
- return new e(), true;
- } catch {
- return false;
- }
- }
- n$1(fa, "isDOMExceptionConstructor");
- function ca() {
- const e = $r == null ? void 0 : $r.DOMException;
- return fa(e) ? e : void 0;
- }
- n$1(ca, "getFromGlobal");
- function da() {
- const e = n$1(function(r2, s) {
- this.message = r2 || "", this.name = s || "Error", Error.captureStackTrace && Error.captureStackTrace(this, this.constructor);
- }, "DOMException");
- return h2(e, "DOMException"), e.prototype = Object.create(Error.prototype), Object.defineProperty(e.prototype, "constructor", { value: e, writable: true, configurable: true }), e;
- }
- n$1(da, "createPolyfill");
- const ha = ca() || da();
- function oo(e, t2, r2, s, f2, c) {
- const d = ze(e), p = xn(t2);
- e._disturbed = true;
- let R = false, y = T2(void 0);
- return A((C, P) => {
- let B;
- if (c !== void 0) {
- if (B = n$1(() => {
- const _ = c.reason !== void 0 ? c.reason : new ha("Aborted", "AbortError"), v = [];
- s || v.push(() => t2._state === "writable" ? Bt(t2, _) : T2(void 0)), f2 || v.push(() => e._state === "readable" ? X(e, _) : T2(void 0)), x(() => Promise.all(v.map((W) => W())), true, _);
- }, "abortAlgorithm"), c.aborted) {
- B();
- return;
- }
- c.addEventListener("abort", B);
- }
- function ee() {
- return A((_, v) => {
- function W(Y) {
- Y ? _() : q(Ne(), W, v);
- }
- n$1(W, "next"), W(false);
- });
- }
- n$1(ee, "pipeLoop");
- function Ne() {
- return R ? T2(true) : q(p._readyPromise, () => A((_, v) => {
- et(d, { _chunkSteps: n$1((W) => {
- y = q(Gn(p, W), void 0, l), _(false);
- }, "_chunkSteps"), _closeSteps: n$1(() => _(true), "_closeSteps"), _errorSteps: v });
- }));
- }
- if (n$1(Ne, "pipeStep"), me(e, d._closedPromise, (_) => (s ? K(true, _) : x(() => Bt(t2, _), true, _), null)), me(t2, p._closedPromise, (_) => (f2 ? K(true, _) : x(() => X(e, _), true, _), null)), U(e, d._closedPromise, () => (r2 ? K() : x(() => Zi(p)), null)), oe(t2) || t2._state === "closed") {
- const _ = new TypeError("the destination writable stream closed before all data could be piped to it");
- f2 ? K(true, _) : x(() => X(e, _), true, _);
- }
- Q(ee());
- function Ee() {
- const _ = y;
- return q(y, () => _ !== y ? Ee() : void 0);
- }
- n$1(Ee, "waitForWritesToFinish");
- function me(_, v, W) {
- _._state === "errored" ? W(_._storedError) : I(v, W);
- }
- n$1(me, "isOrBecomesErrored");
- function U(_, v, W) {
- _._state === "closed" ? W() : V(v, W);
- }
- n$1(U, "isOrBecomesClosed");
- function x(_, v, W) {
- if (R) return;
- R = true, t2._state === "writable" && !oe(t2) ? V(Ee(), Y) : Y();
- function Y() {
- return g(_(), () => be(v, W), (He) => be(true, He)), null;
- }
- n$1(Y, "doTheRest");
- }
- n$1(x, "shutdownWithAction");
- function K(_, v) {
- R || (R = true, t2._state === "writable" && !oe(t2) ? V(Ee(), () => be(_, v)) : be(_, v));
- }
- n$1(K, "shutdown");
- function be(_, v) {
- return Yn(p), ue(d), c !== void 0 && c.removeEventListener("abort", B), _ ? P(v) : C(void 0), null;
- }
- n$1(be, "finalize");
- });
- }
- n$1(oo, "ReadableStreamPipeTo");
- const _he = class _he {
- constructor() {
- throw new TypeError("Illegal constructor");
- }
- get desiredSize() {
- if (!zt(this)) throw Lt("desiredSize");
- return Mr(this);
- }
- close() {
- if (!zt(this)) throw Lt("close");
- if (!Ue(this)) throw new TypeError("The stream is not in a state that permits close");
- Oe(this);
- }
- enqueue(t2 = void 0) {
- if (!zt(this)) throw Lt("enqueue");
- if (!Ue(this)) throw new TypeError("The stream is not in a state that permits enqueue");
- return Me(this, t2);
- }
- error(t2 = void 0) {
- if (!zt(this)) throw Lt("error");
- J(this, t2);
- }
- [ar](t2) {
- Se(this);
- const r2 = this._cancelAlgorithm(t2);
- return jt(this), r2;
- }
- [sr](t2) {
- const r2 = this._controlledReadableStream;
- if (this._queue.length > 0) {
- const s = wr(this);
- this._closeRequested && this._queue.length === 0 ? (jt(this), lt(r2)) : st(this), t2._chunkSteps(s);
- } else hn(r2, t2), st(this);
- }
- [ur]() {
- }
- };
- n$1(_he, "ReadableStreamDefaultController");
- let he = _he;
- Object.defineProperties(he.prototype, { close: { enumerable: true }, enqueue: { enumerable: true }, error: { enumerable: true }, desiredSize: { enumerable: true } }), h2(he.prototype.close, "close"), h2(he.prototype.enqueue, "enqueue"), h2(he.prototype.error, "error"), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(he.prototype, Symbol.toStringTag, { value: "ReadableStreamDefaultController", configurable: true });
- function zt(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_controlledReadableStream") ? false : e instanceof he;
- }
- n$1(zt, "IsReadableStreamDefaultController");
- function st(e) {
- if (!io(e)) return;
- if (e._pulling) {
- e._pullAgain = true;
- return;
- }
- e._pulling = true;
- const r2 = e._pullAlgorithm();
- g(r2, () => (e._pulling = false, e._pullAgain && (e._pullAgain = false, st(e)), null), (s) => (J(e, s), null));
- }
- n$1(st, "ReadableStreamDefaultControllerCallPullIfNeeded");
- function io(e) {
- const t2 = e._controlledReadableStream;
- return !Ue(e) || !e._started ? false : !!(Ce(t2) && gt(t2) > 0 || Mr(e) > 0);
- }
- n$1(io, "ReadableStreamDefaultControllerShouldCallPull");
- function jt(e) {
- e._pullAlgorithm = void 0, e._cancelAlgorithm = void 0, e._strategySizeAlgorithm = void 0;
- }
- n$1(jt, "ReadableStreamDefaultControllerClearAlgorithms");
- function Oe(e) {
- if (!Ue(e)) return;
- const t2 = e._controlledReadableStream;
- e._closeRequested = true, e._queue.length === 0 && (jt(e), lt(t2));
- }
- n$1(Oe, "ReadableStreamDefaultControllerClose");
- function Me(e, t2) {
- if (!Ue(e)) return;
- const r2 = e._controlledReadableStream;
- if (Ce(r2) && gt(r2) > 0) pr(r2, t2, false);
- else {
- let s;
- try {
- s = e._strategySizeAlgorithm(t2);
- } catch (f2) {
- throw J(e, f2), f2;
- }
- try {
- Rr(e, t2, s);
- } catch (f2) {
- throw J(e, f2), f2;
- }
- }
- st(e);
- }
- n$1(Me, "ReadableStreamDefaultControllerEnqueue");
- function J(e, t2) {
- const r2 = e._controlledReadableStream;
- r2._state === "readable" && (Se(e), jt(e), lo(r2, t2));
- }
- n$1(J, "ReadableStreamDefaultControllerError");
- function Mr(e) {
- const t2 = e._controlledReadableStream._state;
- return t2 === "errored" ? null : t2 === "closed" ? 0 : e._strategyHWM - e._queueTotalSize;
- }
- n$1(Mr, "ReadableStreamDefaultControllerGetDesiredSize");
- function ma(e) {
- return !io(e);
- }
- n$1(ma, "ReadableStreamDefaultControllerHasBackpressure");
- function Ue(e) {
- const t2 = e._controlledReadableStream._state;
- return !e._closeRequested && t2 === "readable";
- }
- n$1(Ue, "ReadableStreamDefaultControllerCanCloseOrEnqueue");
- function ao(e, t2, r2, s, f2, c, d) {
- t2._controlledReadableStream = e, t2._queue = void 0, t2._queueTotalSize = void 0, Se(t2), t2._started = false, t2._closeRequested = false, t2._pullAgain = false, t2._pulling = false, t2._strategySizeAlgorithm = d, t2._strategyHWM = c, t2._pullAlgorithm = s, t2._cancelAlgorithm = f2, e._readableStreamController = t2;
- const p = r2();
- g(T2(p), () => (t2._started = true, st(t2), null), (R) => (J(t2, R), null));
- }
- n$1(ao, "SetUpReadableStreamDefaultController");
- function ba(e, t2, r2, s) {
- const f2 = Object.create(he.prototype);
- let c, d, p;
- t2.start !== void 0 ? c = n$1(() => t2.start(f2), "startAlgorithm") : c = n$1(() => {
- }, "startAlgorithm"), t2.pull !== void 0 ? d = n$1(() => t2.pull(f2), "pullAlgorithm") : d = n$1(() => T2(void 0), "pullAlgorithm"), t2.cancel !== void 0 ? p = n$1((R) => t2.cancel(R), "cancelAlgorithm") : p = n$1(() => T2(void 0), "cancelAlgorithm"), ao(e, f2, c, d, p, r2, s);
- }
- n$1(ba, "SetUpReadableStreamDefaultControllerFromUnderlyingSource");
- function Lt(e) {
- return new TypeError(`ReadableStreamDefaultController.prototype.${e} can only be used on a ReadableStreamDefaultController`);
- }
- n$1(Lt, "defaultControllerBrandCheckException$1");
- function pa(e, t2) {
- return Ae(e._readableStreamController) ? ga(e) : ya(e);
- }
- n$1(pa, "ReadableStreamTee");
- function ya(e, t2) {
- const r2 = ze(e);
- let s = false, f2 = false, c = false, d = false, p, R, y, C, P;
- const B = A((U) => {
- P = U;
- });
- function ee() {
- return s ? (f2 = true, T2(void 0)) : (s = true, et(r2, { _chunkSteps: n$1((x) => {
- se(() => {
- f2 = false;
- const K = x, be = x;
- c || Me(y._readableStreamController, K), d || Me(C._readableStreamController, be), s = false, f2 && ee();
- });
- }, "_chunkSteps"), _closeSteps: n$1(() => {
- s = false, c || Oe(y._readableStreamController), d || Oe(C._readableStreamController), (!c || !d) && P(void 0);
- }, "_closeSteps"), _errorSteps: n$1(() => {
- s = false;
- }, "_errorSteps") }), T2(void 0));
- }
- n$1(ee, "pullAlgorithm");
- function Ne(U) {
- if (c = true, p = U, d) {
- const x = tt([p, R]), K = X(e, x);
- P(K);
- }
- return B;
- }
- n$1(Ne, "cancel1Algorithm");
- function Ee(U) {
- if (d = true, R = U, c) {
- const x = tt([p, R]), K = X(e, x);
- P(K);
- }
- return B;
- }
- n$1(Ee, "cancel2Algorithm");
- function me() {
- }
- return n$1(me, "startAlgorithm"), y = ut(me, ee, Ne), C = ut(me, ee, Ee), I(r2._closedPromise, (U) => (J(y._readableStreamController, U), J(C._readableStreamController, U), (!c || !d) && P(void 0), null)), [y, C];
- }
- n$1(ya, "ReadableStreamDefaultTee");
- function ga(e) {
- let t2 = ze(e), r2 = false, s = false, f2 = false, c = false, d = false, p, R, y, C, P;
- const B = A((_) => {
- P = _;
- });
- function ee(_) {
- I(_._closedPromise, (v) => (_ !== t2 || (Z(y._readableStreamController, v), Z(C._readableStreamController, v), (!c || !d) && P(void 0)), null));
- }
- n$1(ee, "forwardReaderError");
- function Ne() {
- We(t2) && (ue(t2), t2 = ze(e), ee(t2)), et(t2, { _chunkSteps: n$1((v) => {
- se(() => {
- s = false, f2 = false;
- const W = v;
- let Y = v;
- if (!c && !d) try {
- Y = Cn(v);
- } catch (He) {
- Z(y._readableStreamController, He), Z(C._readableStreamController, He), P(X(e, He));
- return;
- }
- c || Tt(y._readableStreamController, W), d || Tt(C._readableStreamController, Y), r2 = false, s ? me() : f2 && U();
- });
- }, "_chunkSteps"), _closeSteps: n$1(() => {
- r2 = false, c || rt(y._readableStreamController), d || rt(C._readableStreamController), y._readableStreamController._pendingPullIntos.length > 0 && Ct(y._readableStreamController, 0), C._readableStreamController._pendingPullIntos.length > 0 && Ct(C._readableStreamController, 0), (!c || !d) && P(void 0);
- }, "_closeSteps"), _errorSteps: n$1(() => {
- r2 = false;
- }, "_errorSteps") });
- }
- n$1(Ne, "pullWithDefaultReader");
- function Ee(_, v) {
- ge(t2) && (ue(t2), t2 = jn(e), ee(t2));
- const W = v ? C : y, Y = v ? y : C;
- $n(t2, _, 1, { _chunkSteps: n$1((Ve) => {
- se(() => {
- s = false, f2 = false;
- const Qe = v ? d : c;
- if (v ? c : d) Qe || Pt(W._readableStreamController, Ve);
- else {
- let To;
- try {
- To = Cn(Ve);
- } catch (Vr) {
- Z(W._readableStreamController, Vr), Z(Y._readableStreamController, Vr), P(X(e, Vr));
- return;
- }
- Qe || Pt(W._readableStreamController, Ve), Tt(Y._readableStreamController, To);
- }
- r2 = false, s ? me() : f2 && U();
- });
- }, "_chunkSteps"), _closeSteps: n$1((Ve) => {
- r2 = false;
- const Qe = v ? d : c, Vt = v ? c : d;
- Qe || rt(W._readableStreamController), Vt || rt(Y._readableStreamController), Ve !== void 0 && (Qe || Pt(W._readableStreamController, Ve), !Vt && Y._readableStreamController._pendingPullIntos.length > 0 && Ct(Y._readableStreamController, 0)), (!Qe || !Vt) && P(void 0);
- }, "_closeSteps"), _errorSteps: n$1(() => {
- r2 = false;
- }, "_errorSteps") });
- }
- n$1(Ee, "pullWithBYOBReader");
- function me() {
- if (r2) return s = true, T2(void 0);
- r2 = true;
- const _ = vr(y._readableStreamController);
- return _ === null ? Ne() : Ee(_._view, false), T2(void 0);
- }
- n$1(me, "pull1Algorithm");
- function U() {
- if (r2) return f2 = true, T2(void 0);
- r2 = true;
- const _ = vr(C._readableStreamController);
- return _ === null ? Ne() : Ee(_._view, true), T2(void 0);
- }
- n$1(U, "pull2Algorithm");
- function x(_) {
- if (c = true, p = _, d) {
- const v = tt([p, R]), W = X(e, v);
- P(W);
- }
- return B;
- }
- n$1(x, "cancel1Algorithm");
- function K(_) {
- if (d = true, R = _, c) {
- const v = tt([p, R]), W = X(e, v);
- P(W);
- }
- return B;
- }
- n$1(K, "cancel2Algorithm");
- function be() {
- }
- return n$1(be, "startAlgorithm"), y = uo(be, me, x), C = uo(be, U, K), ee(t2), [y, C];
- }
- n$1(ga, "ReadableByteStreamTee");
- function _a2(e) {
- return u(e) && typeof e.getReader < "u";
- }
- n$1(_a2, "isReadableStreamLike");
- function Sa(e) {
- return _a2(e) ? Ra(e.getReader()) : wa(e);
- }
- n$1(Sa, "ReadableStreamFrom");
- function wa(e) {
- let t2;
- const r2 = Tn(e, "async"), s = l;
- function f2() {
- let d;
- try {
- d = di(r2);
- } catch (R) {
- return b(R);
- }
- const p = T2(d);
- return F(p, (R) => {
- if (!u(R)) throw new TypeError("The promise returned by the iterator.next() method must fulfill with an object");
- if (hi(R)) Oe(t2._readableStreamController);
- else {
- const C = mi(R);
- Me(t2._readableStreamController, C);
- }
- });
- }
- n$1(f2, "pullAlgorithm");
- function c(d) {
- const p = r2.iterator;
- let R;
- try {
- R = St(p, "return");
- } catch (P) {
- return b(P);
- }
- if (R === void 0) return T2(void 0);
- let y;
- try {
- y = O(R, p, [d]);
- } catch (P) {
- return b(P);
- }
- const C = T2(y);
- return F(C, (P) => {
- if (!u(P)) throw new TypeError("The promise returned by the iterator.return() method must fulfill with an object");
- });
- }
- return n$1(c, "cancelAlgorithm"), t2 = ut(s, f2, c, 0), t2;
- }
- n$1(wa, "ReadableStreamFromIterable");
- function Ra(e) {
- let t2;
- const r2 = l;
- function s() {
- let c;
- try {
- c = e.read();
- } catch (d) {
- return b(d);
- }
- return F(c, (d) => {
- if (!u(d)) throw new TypeError("The promise returned by the reader.read() method must fulfill with an object");
- if (d.done) Oe(t2._readableStreamController);
- else {
- const p = d.value;
- Me(t2._readableStreamController, p);
- }
- });
- }
- n$1(s, "pullAlgorithm");
- function f2(c) {
- try {
- return T2(e.cancel(c));
- } catch (d) {
- return b(d);
- }
- }
- return n$1(f2, "cancelAlgorithm"), t2 = ut(r2, s, f2, 0), t2;
- }
- n$1(Ra, "ReadableStreamFromDefaultReader");
- function Ta(e, t2) {
- ne(e, t2);
- const r2 = e, s = r2 == null ? void 0 : r2.autoAllocateChunkSize, f2 = r2 == null ? void 0 : r2.cancel, c = r2 == null ? void 0 : r2.pull, d = r2 == null ? void 0 : r2.start, p = r2 == null ? void 0 : r2.type;
- return { autoAllocateChunkSize: s === void 0 ? void 0 : mr(s, `${t2} has member 'autoAllocateChunkSize' that`), cancel: f2 === void 0 ? void 0 : Ca(f2, r2, `${t2} has member 'cancel' that`), pull: c === void 0 ? void 0 : Pa(c, r2, `${t2} has member 'pull' that`), start: d === void 0 ? void 0 : Ea(d, r2, `${t2} has member 'start' that`), type: p === void 0 ? void 0 : va(p, `${t2} has member 'type' that`) };
- }
- n$1(Ta, "convertUnderlyingDefaultOrByteSource");
- function Ca(e, t2, r2) {
- return G(e, r2), (s) => z(e, t2, [s]);
- }
- n$1(Ca, "convertUnderlyingSourceCancelCallback");
- function Pa(e, t2, r2) {
- return G(e, r2), (s) => z(e, t2, [s]);
- }
- n$1(Pa, "convertUnderlyingSourcePullCallback");
- function Ea(e, t2, r2) {
- return G(e, r2), (s) => O(e, t2, [s]);
- }
- n$1(Ea, "convertUnderlyingSourceStartCallback");
- function va(e, t2) {
- if (e = `${e}`, e !== "bytes") throw new TypeError(`${t2} '${e}' is not a valid enumeration value for ReadableStreamType`);
- return e;
- }
- n$1(va, "convertReadableStreamType");
- function Aa(e, t2) {
- return ne(e, t2), { preventCancel: !!(e == null ? void 0 : e.preventCancel) };
- }
- n$1(Aa, "convertIteratorOptions");
- function so(e, t2) {
- ne(e, t2);
- const r2 = e == null ? void 0 : e.preventAbort, s = e == null ? void 0 : e.preventCancel, f2 = e == null ? void 0 : e.preventClose, c = e == null ? void 0 : e.signal;
- return c !== void 0 && Ba(c, `${t2} has member 'signal' that`), { preventAbort: !!r2, preventCancel: !!s, preventClose: !!f2, signal: c };
- }
- n$1(so, "convertPipeOptions");
- function Ba(e, t2) {
- if (!ji(e)) throw new TypeError(`${t2} is not an AbortSignal.`);
- }
- n$1(Ba, "assertAbortSignal");
- function Wa(e, t2) {
- ne(e, t2);
- const r2 = e == null ? void 0 : e.readable;
- dr(r2, "readable", "ReadableWritablePair"), br(r2, `${t2} has member 'readable' that`);
- const s = e == null ? void 0 : e.writable;
- return dr(s, "writable", "ReadableWritablePair"), Un(s, `${t2} has member 'writable' that`), { readable: r2, writable: s };
- }
- n$1(Wa, "convertReadableWritablePair");
- const _L = class _L {
- constructor(t2 = {}, r2 = {}) {
- t2 === void 0 ? t2 = null : cn(t2, "First parameter");
- const s = At(r2, "Second parameter"), f2 = Ta(t2, "First parameter");
- if (Ur(this), f2.type === "bytes") {
- if (s.size !== void 0) throw new RangeError("The strategy for a byte stream cannot have a size function");
- const c = ot(s, 0);
- Ci(this, f2, c);
- } else {
- const c = vt(s), d = ot(s, 1);
- ba(this, f2, d, c);
- }
- }
- get locked() {
- if (!Te(this)) throw Ie("locked");
- return Ce(this);
- }
- cancel(t2 = void 0) {
- return Te(this) ? Ce(this) ? b(new TypeError("Cannot cancel a stream that already has a reader")) : X(this, t2) : b(Ie("cancel"));
- }
- getReader(t2 = void 0) {
- if (!Te(this)) throw Ie("getReader");
- return Ei(t2, "First parameter").mode === void 0 ? ze(this) : jn(this);
- }
- pipeThrough(t2, r2 = {}) {
- if (!Te(this)) throw Ie("pipeThrough");
- le(t2, 1, "pipeThrough");
- const s = Wa(t2, "First parameter"), f2 = so(r2, "Second parameter");
- if (Ce(this)) throw new TypeError("ReadableStream.prototype.pipeThrough cannot be used on a locked ReadableStream");
- if (De(s.writable)) throw new TypeError("ReadableStream.prototype.pipeThrough cannot be used on a locked WritableStream");
- const c = oo(this, s.writable, f2.preventClose, f2.preventAbort, f2.preventCancel, f2.signal);
- return Q(c), s.readable;
- }
- pipeTo(t2, r2 = {}) {
- if (!Te(this)) return b(Ie("pipeTo"));
- if (t2 === void 0) return b("Parameter 1 is required in 'pipeTo'.");
- if (!Le(t2)) return b(new TypeError("ReadableStream.prototype.pipeTo's first argument must be a WritableStream"));
- let s;
- try {
- s = so(r2, "Second parameter");
- } catch (f2) {
- return b(f2);
- }
- return Ce(this) ? b(new TypeError("ReadableStream.prototype.pipeTo cannot be used on a locked ReadableStream")) : De(t2) ? b(new TypeError("ReadableStream.prototype.pipeTo cannot be used on a locked WritableStream")) : oo(this, t2, s.preventClose, s.preventAbort, s.preventCancel, s.signal);
- }
- tee() {
- if (!Te(this)) throw Ie("tee");
- const t2 = pa(this);
- return tt(t2);
- }
- values(t2 = void 0) {
- if (!Te(this)) throw Ie("values");
- const r2 = Aa(t2, "First parameter");
- return fi(this, r2.preventCancel);
- }
- [Sr](t2) {
- return this.values(t2);
- }
- static from(t2) {
- return Sa(t2);
- }
- };
- n$1(_L, "ReadableStream");
- let L = _L;
- Object.defineProperties(L, { from: { enumerable: true } }), Object.defineProperties(L.prototype, { cancel: { enumerable: true }, getReader: { enumerable: true }, pipeThrough: { enumerable: true }, pipeTo: { enumerable: true }, tee: { enumerable: true }, values: { enumerable: true }, locked: { enumerable: true } }), h2(L.from, "from"), h2(L.prototype.cancel, "cancel"), h2(L.prototype.getReader, "getReader"), h2(L.prototype.pipeThrough, "pipeThrough"), h2(L.prototype.pipeTo, "pipeTo"), h2(L.prototype.tee, "tee"), h2(L.prototype.values, "values"), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(L.prototype, Symbol.toStringTag, { value: "ReadableStream", configurable: true }), Object.defineProperty(L.prototype, Sr, { value: L.prototype.values, writable: true, configurable: true });
- function ut(e, t2, r2, s = 1, f2 = () => 1) {
- const c = Object.create(L.prototype);
- Ur(c);
- const d = Object.create(he.prototype);
- return ao(c, d, e, t2, r2, s, f2), c;
- }
- n$1(ut, "CreateReadableStream");
- function uo(e, t2, r2) {
- const s = Object.create(L.prototype);
- Ur(s);
- const f2 = Object.create(ce.prototype);
- return zn(s, f2, e, t2, r2, 0, void 0), s;
- }
- n$1(uo, "CreateReadableByteStream");
- function Ur(e) {
- e._state = "readable", e._reader = void 0, e._storedError = void 0, e._disturbed = false;
- }
- n$1(Ur, "InitializeReadableStream");
- function Te(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_readableStreamController") ? false : e instanceof L;
- }
- n$1(Te, "IsReadableStream");
- function Ce(e) {
- return e._reader !== void 0;
- }
- n$1(Ce, "IsReadableStreamLocked");
- function X(e, t2) {
- if (e._disturbed = true, e._state === "closed") return T2(void 0);
- if (e._state === "errored") return b(e._storedError);
- lt(e);
- const r2 = e._reader;
- if (r2 !== void 0 && We(r2)) {
- const f2 = r2._readIntoRequests;
- r2._readIntoRequests = new M(), f2.forEach((c) => {
- c._closeSteps(void 0);
- });
- }
- const s = e._readableStreamController[ar](t2);
- return F(s, l);
- }
- n$1(X, "ReadableStreamCancel");
- function lt(e) {
- e._state = "closed";
- const t2 = e._reader;
- if (t2 !== void 0 && (ln(t2), ge(t2))) {
- const r2 = t2._readRequests;
- t2._readRequests = new M(), r2.forEach((s) => {
- s._closeSteps();
- });
- }
- }
- n$1(lt, "ReadableStreamClose");
- function lo(e, t2) {
- e._state = "errored", e._storedError = t2;
- const r2 = e._reader;
- r2 !== void 0 && (cr(r2, t2), ge(r2) ? bn(r2, t2) : Mn(r2, t2));
- }
- n$1(lo, "ReadableStreamError");
- function Ie(e) {
- return new TypeError(`ReadableStream.prototype.${e} can only be used on a ReadableStream`);
- }
- n$1(Ie, "streamBrandCheckException$1");
- function fo(e, t2) {
- ne(e, t2);
- const r2 = e == null ? void 0 : e.highWaterMark;
- return dr(r2, "highWaterMark", "QueuingStrategyInit"), { highWaterMark: hr(r2) };
- }
- n$1(fo, "convertQueuingStrategyInit");
- const co = n$1((e) => e.byteLength, "byteLengthSizeFunction");
- h2(co, "size");
- const _Dt = class _Dt {
- constructor(t2) {
- le(t2, 1, "ByteLengthQueuingStrategy"), t2 = fo(t2, "First parameter"), this._byteLengthQueuingStrategyHighWaterMark = t2.highWaterMark;
- }
- get highWaterMark() {
- if (!mo(this)) throw ho("highWaterMark");
- return this._byteLengthQueuingStrategyHighWaterMark;
- }
- get size() {
- if (!mo(this)) throw ho("size");
- return co;
- }
- };
- n$1(_Dt, "ByteLengthQueuingStrategy");
- let Dt = _Dt;
- Object.defineProperties(Dt.prototype, { highWaterMark: { enumerable: true }, size: { enumerable: true } }), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(Dt.prototype, Symbol.toStringTag, { value: "ByteLengthQueuingStrategy", configurable: true });
- function ho(e) {
- return new TypeError(`ByteLengthQueuingStrategy.prototype.${e} can only be used on a ByteLengthQueuingStrategy`);
- }
- n$1(ho, "byteLengthBrandCheckException");
- function mo(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_byteLengthQueuingStrategyHighWaterMark") ? false : e instanceof Dt;
- }
- n$1(mo, "IsByteLengthQueuingStrategy");
- const bo = n$1(() => 1, "countSizeFunction");
- h2(bo, "size");
- const _$t = class _$t {
- constructor(t2) {
- le(t2, 1, "CountQueuingStrategy"), t2 = fo(t2, "First parameter"), this._countQueuingStrategyHighWaterMark = t2.highWaterMark;
- }
- get highWaterMark() {
- if (!yo(this)) throw po("highWaterMark");
- return this._countQueuingStrategyHighWaterMark;
- }
- get size() {
- if (!yo(this)) throw po("size");
- return bo;
- }
- };
- n$1(_$t, "CountQueuingStrategy");
- let $t = _$t;
- Object.defineProperties($t.prototype, { highWaterMark: { enumerable: true }, size: { enumerable: true } }), typeof Symbol.toStringTag == "symbol" && Object.defineProperty($t.prototype, Symbol.toStringTag, { value: "CountQueuingStrategy", configurable: true });
- function po(e) {
- return new TypeError(`CountQueuingStrategy.prototype.${e} can only be used on a CountQueuingStrategy`);
- }
- n$1(po, "countBrandCheckException");
- function yo(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_countQueuingStrategyHighWaterMark") ? false : e instanceof $t;
- }
- n$1(yo, "IsCountQueuingStrategy");
- function ka(e, t2) {
- ne(e, t2);
- const r2 = e == null ? void 0 : e.cancel, s = e == null ? void 0 : e.flush, f2 = e == null ? void 0 : e.readableType, c = e == null ? void 0 : e.start, d = e == null ? void 0 : e.transform, p = e == null ? void 0 : e.writableType;
- return { cancel: r2 === void 0 ? void 0 : Fa(r2, e, `${t2} has member 'cancel' that`), flush: s === void 0 ? void 0 : qa(s, e, `${t2} has member 'flush' that`), readableType: f2, start: c === void 0 ? void 0 : Oa(c, e, `${t2} has member 'start' that`), transform: d === void 0 ? void 0 : Ia(d, e, `${t2} has member 'transform' that`), writableType: p };
- }
- n$1(ka, "convertTransformer");
- function qa(e, t2, r2) {
- return G(e, r2), (s) => z(e, t2, [s]);
- }
- n$1(qa, "convertTransformerFlushCallback");
- function Oa(e, t2, r2) {
- return G(e, r2), (s) => O(e, t2, [s]);
- }
- n$1(Oa, "convertTransformerStartCallback");
- function Ia(e, t2, r2) {
- return G(e, r2), (s, f2) => z(e, t2, [s, f2]);
- }
- n$1(Ia, "convertTransformerTransformCallback");
- function Fa(e, t2, r2) {
- return G(e, r2), (s) => z(e, t2, [s]);
- }
- n$1(Fa, "convertTransformerCancelCallback");
- const _Mt = class _Mt {
- constructor(t2 = {}, r2 = {}, s = {}) {
- t2 === void 0 && (t2 = null);
- const f2 = At(r2, "Second parameter"), c = At(s, "Third parameter"), d = ka(t2, "First parameter");
- if (d.readableType !== void 0) throw new RangeError("Invalid readableType specified");
- if (d.writableType !== void 0) throw new RangeError("Invalid writableType specified");
- const p = ot(c, 0), R = vt(c), y = ot(f2, 1), C = vt(f2);
- let P;
- const B = A((ee) => {
- P = ee;
- });
- za(this, B, y, C, p, R), La(this, d), d.start !== void 0 ? P(d.start(this._transformStreamController)) : P(void 0);
- }
- get readable() {
- if (!go(this)) throw Ro("readable");
- return this._readable;
- }
- get writable() {
- if (!go(this)) throw Ro("writable");
- return this._writable;
- }
- };
- n$1(_Mt, "TransformStream");
- let Mt = _Mt;
- Object.defineProperties(Mt.prototype, { readable: { enumerable: true }, writable: { enumerable: true } }), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(Mt.prototype, Symbol.toStringTag, { value: "TransformStream", configurable: true });
- function za(e, t2, r2, s, f2, c) {
- function d() {
- return t2;
- }
- n$1(d, "startAlgorithm");
- function p(B) {
- return Ma(e, B);
- }
- n$1(p, "writeAlgorithm");
- function R(B) {
- return Ua(e, B);
- }
- n$1(R, "abortAlgorithm");
- function y() {
- return xa(e);
- }
- n$1(y, "closeAlgorithm"), e._writable = $i(d, p, y, R, r2, s);
- function C() {
- return Na(e);
- }
- n$1(C, "pullAlgorithm");
- function P(B) {
- return Ha(e, B);
- }
- n$1(P, "cancelAlgorithm"), e._readable = ut(d, C, P, f2, c), e._backpressure = void 0, e._backpressureChangePromise = void 0, e._backpressureChangePromise_resolve = void 0, Ut(e, true), e._transformStreamController = void 0;
- }
- n$1(za, "InitializeTransformStream");
- function go(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_transformStreamController") ? false : e instanceof Mt;
- }
- n$1(go, "IsTransformStream");
- function _o(e, t2) {
- J(e._readable._readableStreamController, t2), xr(e, t2);
- }
- n$1(_o, "TransformStreamError");
- function xr(e, t2) {
- Nt(e._transformStreamController), it(e._writable._writableStreamController, t2), Nr(e);
- }
- n$1(xr, "TransformStreamErrorWritableAndUnblockWrite");
- function Nr(e) {
- e._backpressure && Ut(e, false);
- }
- n$1(Nr, "TransformStreamUnblockWrite");
- function Ut(e, t2) {
- e._backpressureChangePromise !== void 0 && e._backpressureChangePromise_resolve(), e._backpressureChangePromise = A((r2) => {
- e._backpressureChangePromise_resolve = r2;
- }), e._backpressure = t2;
- }
- n$1(Ut, "TransformStreamSetBackpressure");
- const _Pe = class _Pe {
- constructor() {
- throw new TypeError("Illegal constructor");
- }
- get desiredSize() {
- if (!xt(this)) throw Ht("desiredSize");
- const t2 = this._controlledTransformStream._readable._readableStreamController;
- return Mr(t2);
- }
- enqueue(t2 = void 0) {
- if (!xt(this)) throw Ht("enqueue");
- So(this, t2);
- }
- error(t2 = void 0) {
- if (!xt(this)) throw Ht("error");
- Da(this, t2);
- }
- terminate() {
- if (!xt(this)) throw Ht("terminate");
- $a(this);
- }
- };
- n$1(_Pe, "TransformStreamDefaultController");
- let Pe = _Pe;
- Object.defineProperties(Pe.prototype, { enqueue: { enumerable: true }, error: { enumerable: true }, terminate: { enumerable: true }, desiredSize: { enumerable: true } }), h2(Pe.prototype.enqueue, "enqueue"), h2(Pe.prototype.error, "error"), h2(Pe.prototype.terminate, "terminate"), typeof Symbol.toStringTag == "symbol" && Object.defineProperty(Pe.prototype, Symbol.toStringTag, { value: "TransformStreamDefaultController", configurable: true });
- function xt(e) {
- return !u(e) || !Object.prototype.hasOwnProperty.call(e, "_controlledTransformStream") ? false : e instanceof Pe;
- }
- n$1(xt, "IsTransformStreamDefaultController");
- function ja(e, t2, r2, s, f2) {
- t2._controlledTransformStream = e, e._transformStreamController = t2, t2._transformAlgorithm = r2, t2._flushAlgorithm = s, t2._cancelAlgorithm = f2, t2._finishPromise = void 0, t2._finishPromise_resolve = void 0, t2._finishPromise_reject = void 0;
- }
- n$1(ja, "SetUpTransformStreamDefaultController");
- function La(e, t2) {
- const r2 = Object.create(Pe.prototype);
- let s, f2, c;
- t2.transform !== void 0 ? s = n$1((d) => t2.transform(d, r2), "transformAlgorithm") : s = n$1((d) => {
- try {
- return So(r2, d), T2(void 0);
- } catch (p) {
- return b(p);
- }
- }, "transformAlgorithm"), t2.flush !== void 0 ? f2 = n$1(() => t2.flush(r2), "flushAlgorithm") : f2 = n$1(() => T2(void 0), "flushAlgorithm"), t2.cancel !== void 0 ? c = n$1((d) => t2.cancel(d), "cancelAlgorithm") : c = n$1(() => T2(void 0), "cancelAlgorithm"), ja(e, r2, s, f2, c);
- }
- n$1(La, "SetUpTransformStreamDefaultControllerFromTransformer");
- function Nt(e) {
- e._transformAlgorithm = void 0, e._flushAlgorithm = void 0, e._cancelAlgorithm = void 0;
- }
- n$1(Nt, "TransformStreamDefaultControllerClearAlgorithms");
- function So(e, t2) {
- const r2 = e._controlledTransformStream, s = r2._readable._readableStreamController;
- if (!Ue(s)) throw new TypeError("Readable side is not in a state that permits enqueue");
- try {
- Me(s, t2);
- } catch (c) {
- throw xr(r2, c), r2._readable._storedError;
- }
- ma(s) !== r2._backpressure && Ut(r2, true);
- }
- n$1(So, "TransformStreamDefaultControllerEnqueue");
- function Da(e, t2) {
- _o(e._controlledTransformStream, t2);
- }
- n$1(Da, "TransformStreamDefaultControllerError");
- function wo(e, t2) {
- const r2 = e._transformAlgorithm(t2);
- return F(r2, void 0, (s) => {
- throw _o(e._controlledTransformStream, s), s;
- });
- }
- n$1(wo, "TransformStreamDefaultControllerPerformTransform");
- function $a(e) {
- const t2 = e._controlledTransformStream, r2 = t2._readable._readableStreamController;
- Oe(r2);
- const s = new TypeError("TransformStream terminated");
- xr(t2, s);
- }
- n$1($a, "TransformStreamDefaultControllerTerminate");
- function Ma(e, t2) {
- const r2 = e._transformStreamController;
- if (e._backpressure) {
- const s = e._backpressureChangePromise;
- return F(s, () => {
- const f2 = e._writable;
- if (f2._state === "erroring") throw f2._storedError;
- return wo(r2, t2);
- });
- }
- return wo(r2, t2);
- }
- n$1(Ma, "TransformStreamDefaultSinkWriteAlgorithm");
- function Ua(e, t2) {
- const r2 = e._transformStreamController;
- if (r2._finishPromise !== void 0) return r2._finishPromise;
- const s = e._readable;
- r2._finishPromise = A((c, d) => {
- r2._finishPromise_resolve = c, r2._finishPromise_reject = d;
- });
- const f2 = r2._cancelAlgorithm(t2);
- return Nt(r2), g(f2, () => (s._state === "errored" ? xe(r2, s._storedError) : (J(s._readableStreamController, t2), Hr(r2)), null), (c) => (J(s._readableStreamController, c), xe(r2, c), null)), r2._finishPromise;
- }
- n$1(Ua, "TransformStreamDefaultSinkAbortAlgorithm");
- function xa(e) {
- const t2 = e._transformStreamController;
- if (t2._finishPromise !== void 0) return t2._finishPromise;
- const r2 = e._readable;
- t2._finishPromise = A((f2, c) => {
- t2._finishPromise_resolve = f2, t2._finishPromise_reject = c;
- });
- const s = t2._flushAlgorithm();
- return Nt(t2), g(s, () => (r2._state === "errored" ? xe(t2, r2._storedError) : (Oe(r2._readableStreamController), Hr(t2)), null), (f2) => (J(r2._readableStreamController, f2), xe(t2, f2), null)), t2._finishPromise;
- }
- n$1(xa, "TransformStreamDefaultSinkCloseAlgorithm");
- function Na(e) {
- return Ut(e, false), e._backpressureChangePromise;
- }
- n$1(Na, "TransformStreamDefaultSourcePullAlgorithm");
- function Ha(e, t2) {
- const r2 = e._transformStreamController;
- if (r2._finishPromise !== void 0) return r2._finishPromise;
- const s = e._writable;
- r2._finishPromise = A((c, d) => {
- r2._finishPromise_resolve = c, r2._finishPromise_reject = d;
- });
- const f2 = r2._cancelAlgorithm(t2);
- return Nt(r2), g(f2, () => (s._state === "errored" ? xe(r2, s._storedError) : (it(s._writableStreamController, t2), Nr(e), Hr(r2)), null), (c) => (it(s._writableStreamController, c), Nr(e), xe(r2, c), null)), r2._finishPromise;
- }
- n$1(Ha, "TransformStreamDefaultSourceCancelAlgorithm");
- function Ht(e) {
- return new TypeError(`TransformStreamDefaultController.prototype.${e} can only be used on a TransformStreamDefaultController`);
- }
- n$1(Ht, "defaultControllerBrandCheckException");
- function Hr(e) {
- e._finishPromise_resolve !== void 0 && (e._finishPromise_resolve(), e._finishPromise_resolve = void 0, e._finishPromise_reject = void 0);
- }
- n$1(Hr, "defaultControllerFinishPromiseResolve");
- function xe(e, t2) {
- e._finishPromise_reject !== void 0 && (Q(e._finishPromise), e._finishPromise_reject(t2), e._finishPromise_resolve = void 0, e._finishPromise_reject = void 0);
- }
- n$1(xe, "defaultControllerFinishPromiseReject");
- function Ro(e) {
- return new TypeError(`TransformStream.prototype.${e} can only be used on a TransformStream`);
- }
- n$1(Ro, "streamBrandCheckException"), a.ByteLengthQueuingStrategy = Dt, a.CountQueuingStrategy = $t, a.ReadableByteStreamController = ce, a.ReadableStream = L, a.ReadableStreamBYOBReader = we, a.ReadableStreamBYOBRequest = ve, a.ReadableStreamDefaultController = he, a.ReadableStreamDefaultReader = ye, a.TransformStream = Mt, a.TransformStreamDefaultController = Pe, a.WritableStream = Re, a.WritableStreamDefaultController = $e, a.WritableStreamDefaultWriter = de;
- });
- }(ct, ct.exports)), ct.exports;
- }
- n$1(ns, "requirePonyfill_es2018");
- var Ao;
- function os() {
- if (Ao) return Eo;
- Ao = 1;
- const i = 65536;
- if (!globalThis.ReadableStream) try {
- const o2 = require("node:process"), { emitWarning: a } = o2;
- try {
- o2.emitWarning = () => {
- }, Object.assign(globalThis, require("node:stream/web")), o2.emitWarning = a;
- } catch (l) {
- throw o2.emitWarning = a, l;
- }
- } catch {
- Object.assign(globalThis, ns());
- }
- try {
- const { Blob: o2 } = require("buffer");
- o2 && !o2.prototype.stream && (o2.prototype.stream = n$1(function(l) {
- let u = 0;
- const m = this;
- return new ReadableStream({ type: "bytes", async pull(h2) {
- const E = await m.slice(u, Math.min(m.size, u + i)).arrayBuffer();
- u += E.byteLength, h2.enqueue(new Uint8Array(E)), u === m.size && h2.close();
- } });
- }, "name"));
- } catch {
- }
- return Eo;
- }
- n$1(os, "requireStreams"), os();
- /*! fetch-blob. MIT License. Jimmy Wärting <https://jimmy.warting.se/opensource> */
- const Bo = 65536;
- async function* Qr(i, o2 = true) {
- for (const a of i) if ("stream" in a) yield* a.stream();
- else if (ArrayBuffer.isView(a)) if (o2) {
- let l = a.byteOffset;
- const u = a.byteOffset + a.byteLength;
- for (; l !== u; ) {
- const m = Math.min(u - l, Bo), h2 = a.buffer.slice(l, l + m);
- l += h2.byteLength, yield new Uint8Array(h2);
- }
- } else yield a;
- else {
- let l = 0, u = a;
- for (; l !== u.size; ) {
- const h2 = await u.slice(l, Math.min(u.size, l + Bo)).arrayBuffer();
- l += h2.byteLength, yield new Uint8Array(h2);
- }
- }
- }
- n$1(Qr, "toIterator");
- const Wo = (_a = class {
- constructor(o2 = [], a = {}) {
- __privateAdd(this, _e, []);
- __privateAdd(this, _t, "");
- __privateAdd(this, _r, 0);
- __privateAdd(this, _n, "transparent");
- if (typeof o2 != "object" || o2 === null) throw new TypeError("Failed to construct 'Blob': The provided value cannot be converted to a sequence.");
- if (typeof o2[Symbol.iterator] != "function") throw new TypeError("Failed to construct 'Blob': The object must have a callable @@iterator property.");
- if (typeof a != "object" && typeof a != "function") throw new TypeError("Failed to construct 'Blob': parameter 2 cannot convert to dictionary.");
- a === null && (a = {});
- const l = new TextEncoder();
- for (const m of o2) {
- let h2;
- ArrayBuffer.isView(m) ? h2 = new Uint8Array(m.buffer.slice(m.byteOffset, m.byteOffset + m.byteLength)) : m instanceof ArrayBuffer ? h2 = new Uint8Array(m.slice(0)) : m instanceof _a ? h2 = m : h2 = l.encode(`${m}`), __privateSet(this, _r, __privateGet(this, _r) + (ArrayBuffer.isView(h2) ? h2.byteLength : h2.size)), __privateGet(this, _e).push(h2);
- }
- __privateSet(this, _n, `${a.endings === void 0 ? "transparent" : a.endings}`);
- const u = a.type === void 0 ? "" : String(a.type);
- __privateSet(this, _t, /^[\x20-\x7E]*$/.test(u) ? u : "");
- }
- get size() {
- return __privateGet(this, _r);
- }
- get type() {
- return __privateGet(this, _t);
- }
- async text() {
- const o2 = new TextDecoder();
- let a = "";
- for await (const l of Qr(__privateGet(this, _e), false)) a += o2.decode(l, { stream: true });
- return a += o2.decode(), a;
- }
- async arrayBuffer() {
- const o2 = new Uint8Array(this.size);
- let a = 0;
- for await (const l of Qr(__privateGet(this, _e), false)) o2.set(l, a), a += l.length;
- return o2.buffer;
- }
- stream() {
- const o2 = Qr(__privateGet(this, _e), true);
- return new globalThis.ReadableStream({ type: "bytes", async pull(a) {
- const l = await o2.next();
- l.done ? a.close() : a.enqueue(l.value);
- }, async cancel() {
- await o2.return();
- } });
- }
- slice(o2 = 0, a = this.size, l = "") {
- const { size: u } = this;
- let m = o2 < 0 ? Math.max(u + o2, 0) : Math.min(o2, u), h2 = a < 0 ? Math.max(u + a, 0) : Math.min(a, u);
- const S = Math.max(h2 - m, 0), E = __privateGet(this, _e), w = [];
- let A = 0;
- for (const b of E) {
- if (A >= S) break;
- const q = ArrayBuffer.isView(b) ? b.byteLength : b.size;
- if (m && q <= m) m -= q, h2 -= q;
- else {
- let g;
- ArrayBuffer.isView(b) ? (g = b.subarray(m, Math.min(q, h2)), A += g.byteLength) : (g = b.slice(m, Math.min(q, h2)), A += g.size), h2 -= q, w.push(g), m = 0;
- }
- }
- const T2 = new _a([], { type: String(l).toLowerCase() });
- return __privateSet(T2, _r, S), __privateSet(T2, _e, w), T2;
- }
- get [Symbol.toStringTag]() {
- return "Blob";
- }
- static [Symbol.hasInstance](o2) {
- return o2 && typeof o2 == "object" && typeof o2.constructor == "function" && (typeof o2.stream == "function" || typeof o2.arrayBuffer == "function") && /^(Blob|File)$/.test(o2[Symbol.toStringTag]);
- }
- }, _e = new WeakMap(), _t = new WeakMap(), _r = new WeakMap(), _n = new WeakMap(), n$1(_a, "Blob"), _a);
- Object.defineProperties(Wo.prototype, { size: { enumerable: true }, type: { enumerable: true }, slice: { enumerable: true } });
- const Ze = Wo, is = (_b = class extends Ze {
- constructor(o2, a, l = {}) {
- if (arguments.length < 2) throw new TypeError(`Failed to construct 'File': 2 arguments required, but only ${arguments.length} present.`);
- super(o2, l);
- __privateAdd(this, _e2, 0);
- __privateAdd(this, _t2, "");
- l === null && (l = {});
- const u = l.lastModified === void 0 ? Date.now() : Number(l.lastModified);
- Number.isNaN(u) || __privateSet(this, _e2, u), __privateSet(this, _t2, String(a));
- }
- get name() {
- return __privateGet(this, _t2);
- }
- get lastModified() {
- return __privateGet(this, _e2);
- }
- get [Symbol.toStringTag]() {
- return "File";
- }
- static [Symbol.hasInstance](o2) {
- return !!o2 && o2 instanceof Ze && /^(File)$/.test(o2[Symbol.toStringTag]);
- }
- }, _e2 = new WeakMap(), _t2 = new WeakMap(), n$1(_b, "File"), _b), Yr = is;
- /*! formdata-polyfill. MIT License. Jimmy Wärting <https://jimmy.warting.se/opensource> */
- var { toStringTag: dt, iterator: as, hasInstance: ss } = Symbol, ko = Math.random, us = "append,set,get,getAll,delete,keys,values,entries,forEach,constructor".split(","), qo = n$1((i, o2, a) => (i += "", /^(Blob|File)$/.test(o2 && o2[dt]) ? [(a = a !== void 0 ? a + "" : o2[dt] == "File" ? o2.name : "blob", i), o2.name !== a || o2[dt] == "blob" ? new Yr([o2], a, o2) : o2] : [i, o2 + ""]), "f"), Gr = n$1((i, o2) => (o2 ? i : i.replace(/\r?\n|\r/g, `\r
- `)).replace(/\n/g, "%0A").replace(/\r/g, "%0D").replace(/"/g, "%22"), "e$1"), Fe = n$1((i, o2, a) => {
- if (o2.length < a) throw new TypeError(`Failed to execute '${i}' on 'FormData': ${a} arguments required, but only ${o2.length} present.`);
- }, "x");
- const Zt = (_c = class {
- constructor(...o2) {
- __privateAdd(this, _e3, []);
- if (o2.length) throw new TypeError("Failed to construct 'FormData': parameter 1 is not of type 'HTMLFormElement'.");
- }
- get [dt]() {
- return "FormData";
- }
- [as]() {
- return this.entries();
- }
- static [ss](o2) {
- return o2 && typeof o2 == "object" && o2[dt] === "FormData" && !us.some((a) => typeof o2[a] != "function");
- }
- append(...o2) {
- Fe("append", arguments, 2), __privateGet(this, _e3).push(qo(...o2));
- }
- delete(o2) {
- Fe("delete", arguments, 1), o2 += "", __privateSet(this, _e3, __privateGet(this, _e3).filter(([a]) => a !== o2));
- }
- get(o2) {
- Fe("get", arguments, 1), o2 += "";
- for (var a = __privateGet(this, _e3), l = a.length, u = 0; u < l; u++) if (a[u][0] === o2) return a[u][1];
- return null;
- }
- getAll(o2, a) {
- return Fe("getAll", arguments, 1), a = [], o2 += "", __privateGet(this, _e3).forEach((l) => l[0] === o2 && a.push(l[1])), a;
- }
- has(o2) {
- return Fe("has", arguments, 1), o2 += "", __privateGet(this, _e3).some((a) => a[0] === o2);
- }
- forEach(o2, a) {
- Fe("forEach", arguments, 1);
- for (var [l, u] of this) o2.call(a, u, l, this);
- }
- set(...o2) {
- Fe("set", arguments, 2);
- var a = [], l = true;
- o2 = qo(...o2), __privateGet(this, _e3).forEach((u) => {
- u[0] === o2[0] ? l && (l = !a.push(o2)) : a.push(u);
- }), l && a.push(o2), __privateSet(this, _e3, a);
- }
- *entries() {
- yield* __privateGet(this, _e3);
- }
- *keys() {
- for (var [o2] of this) yield o2;
- }
- *values() {
- for (var [, o2] of this) yield o2;
- }
- }, _e3 = new WeakMap(), n$1(_c, "FormData"), _c);
- function ls(i, o2 = Ze) {
- var a = `${ko()}${ko()}`.replace(/\./g, "").slice(-28).padStart(32, "-"), l = [], u = `--${a}\r
- Content-Disposition: form-data; name="`;
- return i.forEach((m, h2) => typeof m == "string" ? l.push(u + Gr(h2) + `"\r
- \r
- ${m.replace(new RegExp("\\r(?!\\n)|(?<!\\r)\\n", "g"), `\r
- `)}\r
- `) : l.push(u + Gr(h2) + `"; filename="${Gr(m.name, 1)}"\r
- Content-Type: ${m.type || "application/octet-stream"}\r
- \r
- `, m, `\r
- `)), l.push(`--${a}--`), new o2(l, { type: "multipart/form-data; boundary=" + a });
- }
- n$1(ls, "formDataToBlob");
- const _Kt = class _Kt extends Error {
- constructor(o2, a) {
- super(o2), Error.captureStackTrace(this, this.constructor), this.type = a;
- }
- get name() {
- return this.constructor.name;
- }
- get [Symbol.toStringTag]() {
- return this.constructor.name;
- }
- };
- n$1(_Kt, "FetchBaseError");
- let Kt = _Kt;
- const _te = class _te extends Kt {
- constructor(o2, a, l) {
- super(o2, a), l && (this.code = this.errno = l.code, this.erroredSysCall = l.syscall);
- }
- };
- n$1(_te, "FetchError");
- let te = _te;
- const Jt = Symbol.toStringTag, Oo = n$1((i) => typeof i == "object" && typeof i.append == "function" && typeof i.delete == "function" && typeof i.get == "function" && typeof i.getAll == "function" && typeof i.has == "function" && typeof i.set == "function" && typeof i.sort == "function" && i[Jt] === "URLSearchParams", "isURLSearchParameters"), Xt = n$1((i) => i && typeof i == "object" && typeof i.arrayBuffer == "function" && typeof i.type == "string" && typeof i.stream == "function" && typeof i.constructor == "function" && /^(Blob|File)$/.test(i[Jt]), "isBlob"), fs = n$1((i) => typeof i == "object" && (i[Jt] === "AbortSignal" || i[Jt] === "EventTarget"), "isAbortSignal"), cs = n$1((i, o2) => {
- const a = new URL(o2).hostname, l = new URL(i).hostname;
- return a === l || a.endsWith(`.${l}`);
- }, "isDomainOrSubdomain"), ds = n$1((i, o2) => {
- const a = new URL(o2).protocol, l = new URL(i).protocol;
- return a === l;
- }, "isSameProtocol"), hs = promisify(ie.pipeline), N = Symbol("Body internals");
- const _ht = class _ht {
- constructor(o2, { size: a = 0 } = {}) {
- let l = null;
- o2 === null ? o2 = null : Oo(o2) ? o2 = Buffer$1.from(o2.toString()) : Xt(o2) || Buffer$1.isBuffer(o2) || (types.isAnyArrayBuffer(o2) ? o2 = Buffer$1.from(o2) : ArrayBuffer.isView(o2) ? o2 = Buffer$1.from(o2.buffer, o2.byteOffset, o2.byteLength) : o2 instanceof ie || (o2 instanceof Zt ? (o2 = ls(o2), l = o2.type.split("=")[1]) : o2 = Buffer$1.from(String(o2))));
- let u = o2;
- Buffer$1.isBuffer(o2) ? u = ie.Readable.from(o2) : Xt(o2) && (u = ie.Readable.from(o2.stream())), this[N] = { body: o2, stream: u, boundary: l, disturbed: false, error: null }, this.size = a, o2 instanceof ie && o2.on("error", (m) => {
- const h2 = m instanceof Kt ? m : new te(`Invalid response body while trying to fetch ${this.url}: ${m.message}`, "system", m);
- this[N].error = h2;
- });
- }
- get body() {
- return this[N].stream;
- }
- get bodyUsed() {
- return this[N].disturbed;
- }
- async arrayBuffer() {
- const { buffer: o2, byteOffset: a, byteLength: l } = await Zr(this);
- return o2.slice(a, a + l);
- }
- async formData() {
- const o2 = this.headers.get("content-type");
- if (o2.startsWith("application/x-www-form-urlencoded")) {
- const l = new Zt(), u = new URLSearchParams(await this.text());
- for (const [m, h2] of u) l.append(m, h2);
- return l;
- }
- const { toFormData: a } = await import('./multipart-parser-BS1x8A2O.mjs');
- return a(this.body, o2);
- }
- async blob() {
- const o2 = this.headers && this.headers.get("content-type") || this[N].body && this[N].body.type || "", a = await this.arrayBuffer();
- return new Ze([a], { type: o2 });
- }
- async json() {
- const o2 = await this.text();
- return JSON.parse(o2);
- }
- async text() {
- const o2 = await Zr(this);
- return new TextDecoder().decode(o2);
- }
- buffer() {
- return Zr(this);
- }
- };
- n$1(_ht, "Body");
- let ht = _ht;
- ht.prototype.buffer = deprecate(ht.prototype.buffer, "Please use 'response.arrayBuffer()' instead of 'response.buffer()'", "node-fetch#buffer"), Object.defineProperties(ht.prototype, { body: { enumerable: true }, bodyUsed: { enumerable: true }, arrayBuffer: { enumerable: true }, blob: { enumerable: true }, json: { enumerable: true }, text: { enumerable: true }, data: { get: deprecate(() => {
- }, "data doesn't exist, use json(), text(), arrayBuffer(), or body instead", "https://github.com/node-fetch/node-fetch/issues/1000 (response)") } });
- async function Zr(i) {
- if (i[N].disturbed) throw new TypeError(`body used already for: ${i.url}`);
- if (i[N].disturbed = true, i[N].error) throw i[N].error;
- const { body: o2 } = i;
- if (o2 === null) return Buffer$1.alloc(0);
- if (!(o2 instanceof ie)) return Buffer$1.alloc(0);
- const a = [];
- let l = 0;
- try {
- for await (const u of o2) {
- if (i.size > 0 && l + u.length > i.size) {
- const m = new te(`content size at ${i.url} over limit: ${i.size}`, "max-size");
- throw o2.destroy(m), m;
- }
- l += u.length, a.push(u);
- }
- } catch (u) {
- throw u instanceof Kt ? u : new te(`Invalid response body while trying to fetch ${i.url}: ${u.message}`, "system", u);
- }
- if (o2.readableEnded === true || o2._readableState.ended === true) try {
- return a.every((u) => typeof u == "string") ? Buffer$1.from(a.join("")) : Buffer$1.concat(a, l);
- } catch (u) {
- throw new te(`Could not create Buffer from response body for ${i.url}: ${u.message}`, "system", u);
- }
- else throw new te(`Premature close of server response while trying to fetch ${i.url}`);
- }
- n$1(Zr, "consumeBody");
- const Kr = n$1((i, o2) => {
- let a, l, { body: u } = i[N];
- if (i.bodyUsed) throw new Error("cannot clone body after it is used");
- return u instanceof ie && typeof u.getBoundary != "function" && (a = new PassThrough({ highWaterMark: o2 }), l = new PassThrough({ highWaterMark: o2 }), u.pipe(a), u.pipe(l), i[N].stream = a, u = l), u;
- }, "clone"), ms = deprecate((i) => i.getBoundary(), "form-data doesn't follow the spec and requires special treatment. Use alternative package", "https://github.com/node-fetch/node-fetch/issues/1167"), Io = n$1((i, o2) => i === null ? null : typeof i == "string" ? "text/plain;charset=UTF-8" : Oo(i) ? "application/x-www-form-urlencoded;charset=UTF-8" : Xt(i) ? i.type || null : Buffer$1.isBuffer(i) || types.isAnyArrayBuffer(i) || ArrayBuffer.isView(i) ? null : i instanceof Zt ? `multipart/form-data; boundary=${o2[N].boundary}` : i && typeof i.getBoundary == "function" ? `multipart/form-data;boundary=${ms(i)}` : i instanceof ie ? null : "text/plain;charset=UTF-8", "extractContentType"), bs = n$1((i) => {
- const { body: o2 } = i[N];
- return o2 === null ? 0 : Xt(o2) ? o2.size : Buffer$1.isBuffer(o2) ? o2.length : o2 && typeof o2.getLengthSync == "function" && o2.hasKnownLength && o2.hasKnownLength() ? o2.getLengthSync() : null;
- }, "getTotalBytes"), ps = n$1(async (i, { body: o2 }) => {
- o2 === null ? i.end() : await hs(o2, i);
- }, "writeToStream"), er = typeof ft.validateHeaderName == "function" ? ft.validateHeaderName : (i) => {
- if (!/^[\^`\-\w!#$%&'*+.|~]+$/.test(i)) {
- const o2 = new TypeError(`Header name must be a valid HTTP token [${i}]`);
- throw Object.defineProperty(o2, "code", { value: "ERR_INVALID_HTTP_TOKEN" }), o2;
- }
- }, Jr = typeof ft.validateHeaderValue == "function" ? ft.validateHeaderValue : (i, o2) => {
- if (/[^\t\u0020-\u007E\u0080-\u00FF]/.test(o2)) {
- const a = new TypeError(`Invalid character in header content ["${i}"]`);
- throw Object.defineProperty(a, "code", { value: "ERR_INVALID_CHAR" }), a;
- }
- };
- const _ae = class _ae extends URLSearchParams {
- constructor(o2) {
- let a = [];
- if (o2 instanceof _ae) {
- const l = o2.raw();
- for (const [u, m] of Object.entries(l)) a.push(...m.map((h2) => [u, h2]));
- } else if (o2 != null) if (typeof o2 == "object" && !types.isBoxedPrimitive(o2)) {
- const l = o2[Symbol.iterator];
- if (l == null) a.push(...Object.entries(o2));
- else {
- if (typeof l != "function") throw new TypeError("Header pairs must be iterable");
- a = [...o2].map((u) => {
- if (typeof u != "object" || types.isBoxedPrimitive(u)) throw new TypeError("Each header pair must be an iterable object");
- return [...u];
- }).map((u) => {
- if (u.length !== 2) throw new TypeError("Each header pair must be a name/value tuple");
- return [...u];
- });
- }
- } else throw new TypeError("Failed to construct 'Headers': The provided value is not of type '(sequence<sequence<ByteString>> or record<ByteString, ByteString>)");
- return a = a.length > 0 ? a.map(([l, u]) => (er(l), Jr(l, String(u)), [String(l).toLowerCase(), String(u)])) : void 0, super(a), new Proxy(this, { get(l, u, m) {
- switch (u) {
- case "append":
- case "set":
- return (h2, S) => (er(h2), Jr(h2, String(S)), URLSearchParams.prototype[u].call(l, String(h2).toLowerCase(), String(S)));
- case "delete":
- case "has":
- case "getAll":
- return (h2) => (er(h2), URLSearchParams.prototype[u].call(l, String(h2).toLowerCase()));
- case "keys":
- return () => (l.sort(), new Set(URLSearchParams.prototype.keys.call(l)).keys());
- default:
- return Reflect.get(l, u, m);
- }
- } });
- }
- get [Symbol.toStringTag]() {
- return this.constructor.name;
- }
- toString() {
- return Object.prototype.toString.call(this);
- }
- get(o2) {
- const a = this.getAll(o2);
- if (a.length === 0) return null;
- let l = a.join(", ");
- return /^content-encoding$/i.test(o2) && (l = l.toLowerCase()), l;
- }
- forEach(o2, a = void 0) {
- for (const l of this.keys()) Reflect.apply(o2, a, [this.get(l), l, this]);
- }
- *values() {
- for (const o2 of this.keys()) yield this.get(o2);
- }
- *entries() {
- for (const o2 of this.keys()) yield [o2, this.get(o2)];
- }
- [Symbol.iterator]() {
- return this.entries();
- }
- raw() {
- return [...this.keys()].reduce((o2, a) => (o2[a] = this.getAll(a), o2), {});
- }
- [Symbol.for("nodejs.util.inspect.custom")]() {
- return [...this.keys()].reduce((o2, a) => {
- const l = this.getAll(a);
- return a === "host" ? o2[a] = l[0] : o2[a] = l.length > 1 ? l : l[0], o2;
- }, {});
- }
- };
- n$1(_ae, "Headers");
- let ae = _ae;
- Object.defineProperties(ae.prototype, ["get", "entries", "forEach", "values"].reduce((i, o2) => (i[o2] = { enumerable: true }, i), {}));
- function ys(i = []) {
- return new ae(i.reduce((o2, a, l, u) => (l % 2 === 0 && o2.push(u.slice(l, l + 2)), o2), []).filter(([o2, a]) => {
- try {
- return er(o2), Jr(o2, String(a)), true;
- } catch {
- return false;
- }
- }));
- }
- n$1(ys, "fromRawHeaders");
- const gs = /* @__PURE__ */ new Set([301, 302, 303, 307, 308]), Xr = n$1((i) => gs.has(i), "isRedirect"), re = Symbol("Response internals");
- const _H = class _H extends ht {
- constructor(o2 = null, a = {}) {
- super(o2, a);
- const l = a.status != null ? a.status : 200, u = new ae(a.headers);
- if (o2 !== null && !u.has("Content-Type")) {
- const m = Io(o2, this);
- m && u.append("Content-Type", m);
- }
- this[re] = { type: "default", url: a.url, status: l, statusText: a.statusText || "", headers: u, counter: a.counter, highWaterMark: a.highWaterMark };
- }
- get type() {
- return this[re].type;
- }
- get url() {
- return this[re].url || "";
- }
- get status() {
- return this[re].status;
- }
- get ok() {
- return this[re].status >= 200 && this[re].status < 300;
- }
- get redirected() {
- return this[re].counter > 0;
- }
- get statusText() {
- return this[re].statusText;
- }
- get headers() {
- return this[re].headers;
- }
- get highWaterMark() {
- return this[re].highWaterMark;
- }
- clone() {
- return new _H(Kr(this, this.highWaterMark), { type: this.type, url: this.url, status: this.status, statusText: this.statusText, headers: this.headers, ok: this.ok, redirected: this.redirected, size: this.size, highWaterMark: this.highWaterMark });
- }
- static redirect(o2, a = 302) {
- if (!Xr(a)) throw new RangeError('Failed to execute "redirect" on "response": Invalid status code');
- return new _H(null, { headers: { location: new URL(o2).toString() }, status: a });
- }
- static error() {
- const o2 = new _H(null, { status: 0, statusText: "" });
- return o2[re].type = "error", o2;
- }
- static json(o2 = void 0, a = {}) {
- const l = JSON.stringify(o2);
- if (l === void 0) throw new TypeError("data is not JSON serializable");
- const u = new ae(a && a.headers);
- return u.has("content-type") || u.set("content-type", "application/json"), new _H(l, { ...a, headers: u });
- }
- get [Symbol.toStringTag]() {
- return "Response";
- }
- };
- n$1(_H, "Response");
- let H = _H;
- Object.defineProperties(H.prototype, { type: { enumerable: true }, url: { enumerable: true }, status: { enumerable: true }, ok: { enumerable: true }, redirected: { enumerable: true }, statusText: { enumerable: true }, headers: { enumerable: true }, clone: { enumerable: true } });
- const _s = n$1((i) => {
- if (i.search) return i.search;
- const o2 = i.href.length - 1, a = i.hash || (i.href[o2] === "#" ? "#" : "");
- return i.href[o2 - a.length] === "?" ? "?" : "";
- }, "getSearch");
- function Fo(i, o2 = false) {
- return i == null || (i = new URL(i), /^(about|blob|data):$/.test(i.protocol)) ? "no-referrer" : (i.username = "", i.password = "", i.hash = "", o2 && (i.pathname = "", i.search = ""), i);
- }
- n$1(Fo, "stripURLForUseAsAReferrer");
- const zo = /* @__PURE__ */ new Set(["", "no-referrer", "no-referrer-when-downgrade", "same-origin", "origin", "strict-origin", "origin-when-cross-origin", "strict-origin-when-cross-origin", "unsafe-url"]), Ss = "strict-origin-when-cross-origin";
- function ws(i) {
- if (!zo.has(i)) throw new TypeError(`Invalid referrerPolicy: ${i}`);
- return i;
- }
- n$1(ws, "validateReferrerPolicy");
- function Rs(i) {
- if (/^(http|ws)s:$/.test(i.protocol)) return true;
- const o2 = i.host.replace(/(^\[)|(]$)/g, ""), a = isIP(o2);
- return a === 4 && /^127\./.test(o2) || a === 6 && /^(((0+:){7})|(::(0+:){0,6}))0*1$/.test(o2) ? true : i.host === "localhost" || i.host.endsWith(".localhost") ? false : i.protocol === "file:";
- }
- n$1(Rs, "isOriginPotentiallyTrustworthy");
- function Ke(i) {
- return /^about:(blank|srcdoc)$/.test(i) || i.protocol === "data:" || /^(blob|filesystem):$/.test(i.protocol) ? true : Rs(i);
- }
- n$1(Ke, "isUrlPotentiallyTrustworthy");
- function Ts(i, { referrerURLCallback: o2, referrerOriginCallback: a } = {}) {
- if (i.referrer === "no-referrer" || i.referrerPolicy === "") return null;
- const l = i.referrerPolicy;
- if (i.referrer === "about:client") return "no-referrer";
- const u = i.referrer;
- let m = Fo(u), h2 = Fo(u, true);
- m.toString().length > 4096 && (m = h2), o2 && (m = o2(m)), a && (h2 = a(h2));
- const S = new URL(i.url);
- switch (l) {
- case "no-referrer":
- return "no-referrer";
- case "origin":
- return h2;
- case "unsafe-url":
- return m;
- case "strict-origin":
- return Ke(m) && !Ke(S) ? "no-referrer" : h2.toString();
- case "strict-origin-when-cross-origin":
- return m.origin === S.origin ? m : Ke(m) && !Ke(S) ? "no-referrer" : h2;
- case "same-origin":
- return m.origin === S.origin ? m : "no-referrer";
- case "origin-when-cross-origin":
- return m.origin === S.origin ? m : h2;
- case "no-referrer-when-downgrade":
- return Ke(m) && !Ke(S) ? "no-referrer" : m;
- default:
- throw new TypeError(`Invalid referrerPolicy: ${l}`);
- }
- }
- n$1(Ts, "determineRequestsReferrer");
- function Cs(i) {
- const o2 = (i.get("referrer-policy") || "").split(/[,\s]+/);
- let a = "";
- for (const l of o2) l && zo.has(l) && (a = l);
- return a;
- }
- n$1(Cs, "parseReferrerPolicyFromHeader");
- const j = Symbol("Request internals"), mt = n$1((i) => typeof i == "object" && typeof i[j] == "object", "isRequest"), Ps = deprecate(() => {
- }, ".data is not a valid RequestInit property, use .body instead", "https://github.com/node-fetch/node-fetch/issues/1000 (request)");
- const _Xe = class _Xe extends ht {
- constructor(o2, a = {}) {
- let l;
- if (mt(o2) ? l = new URL(o2.url) : (l = new URL(o2), o2 = {}), l.username !== "" || l.password !== "") throw new TypeError(`${l} is an url with embedded credentials.`);
- let u = a.method || o2.method || "GET";
- if (/^(delete|get|head|options|post|put)$/i.test(u) && (u = u.toUpperCase()), !mt(a) && "data" in a && Ps(), (a.body != null || mt(o2) && o2.body !== null) && (u === "GET" || u === "HEAD")) throw new TypeError("Request with GET/HEAD method cannot have body");
- const m = a.body ? a.body : mt(o2) && o2.body !== null ? Kr(o2) : null;
- super(m, { size: a.size || o2.size || 0 });
- const h2 = new ae(a.headers || o2.headers || {});
- if (m !== null && !h2.has("Content-Type")) {
- const w = Io(m, this);
- w && h2.set("Content-Type", w);
- }
- let S = mt(o2) ? o2.signal : null;
- if ("signal" in a && (S = a.signal), S != null && !fs(S)) throw new TypeError("Expected signal to be an instanceof AbortSignal or EventTarget");
- let E = a.referrer == null ? o2.referrer : a.referrer;
- if (E === "") E = "no-referrer";
- else if (E) {
- const w = new URL(E);
- E = /^about:(\/\/)?client$/.test(w) ? "client" : w;
- } else E = void 0;
- this[j] = { method: u, redirect: a.redirect || o2.redirect || "follow", headers: h2, parsedURL: l, signal: S, referrer: E }, this.follow = a.follow === void 0 ? o2.follow === void 0 ? 20 : o2.follow : a.follow, this.compress = a.compress === void 0 ? o2.compress === void 0 ? true : o2.compress : a.compress, this.counter = a.counter || o2.counter || 0, this.agent = a.agent || o2.agent, this.highWaterMark = a.highWaterMark || o2.highWaterMark || 16384, this.insecureHTTPParser = a.insecureHTTPParser || o2.insecureHTTPParser || false, this.referrerPolicy = a.referrerPolicy || o2.referrerPolicy || "";
- }
- get method() {
- return this[j].method;
- }
- get url() {
- return format(this[j].parsedURL);
- }
- get headers() {
- return this[j].headers;
- }
- get redirect() {
- return this[j].redirect;
- }
- get signal() {
- return this[j].signal;
- }
- get referrer() {
- if (this[j].referrer === "no-referrer") return "";
- if (this[j].referrer === "client") return "about:client";
- if (this[j].referrer) return this[j].referrer.toString();
- }
- get referrerPolicy() {
- return this[j].referrerPolicy;
- }
- set referrerPolicy(o2) {
- this[j].referrerPolicy = ws(o2);
- }
- clone() {
- return new _Xe(this);
- }
- get [Symbol.toStringTag]() {
- return "Request";
- }
- };
- n$1(_Xe, "Request");
- let Xe = _Xe;
- Object.defineProperties(Xe.prototype, { method: { enumerable: true }, url: { enumerable: true }, headers: { enumerable: true }, redirect: { enumerable: true }, clone: { enumerable: true }, signal: { enumerable: true }, referrer: { enumerable: true }, referrerPolicy: { enumerable: true } });
- const Es = n$1((i) => {
- const { parsedURL: o2 } = i[j], a = new ae(i[j].headers);
- a.has("Accept") || a.set("Accept", "*/*");
- let l = null;
- if (i.body === null && /^(post|put)$/i.test(i.method) && (l = "0"), i.body !== null) {
- const S = bs(i);
- typeof S == "number" && !Number.isNaN(S) && (l = String(S));
- }
- l && a.set("Content-Length", l), i.referrerPolicy === "" && (i.referrerPolicy = Ss), i.referrer && i.referrer !== "no-referrer" ? i[j].referrer = Ts(i) : i[j].referrer = "no-referrer", i[j].referrer instanceof URL && a.set("Referer", i.referrer), a.has("User-Agent") || a.set("User-Agent", "node-fetch"), i.compress && !a.has("Accept-Encoding") && a.set("Accept-Encoding", "gzip, deflate, br");
- let { agent: u } = i;
- typeof u == "function" && (u = u(o2));
- const m = _s(o2), h2 = { path: o2.pathname + m, method: i.method, headers: a[Symbol.for("nodejs.util.inspect.custom")](), insecureHTTPParser: i.insecureHTTPParser, agent: u };
- return { parsedURL: o2, options: h2 };
- }, "getNodeRequestOptions");
- const _jo = class _jo extends Kt {
- constructor(o2, a = "aborted") {
- super(o2, a);
- }
- };
- n$1(_jo, "AbortError");
- let jo = _jo;
- /*! node-domexception. MIT License. Jimmy Wärting <https://jimmy.warting.se/opensource> */
- var en, Lo;
- function vs() {
- if (Lo) return en;
- if (Lo = 1, !globalThis.DOMException) try {
- const { MessageChannel: i } = require("worker_threads"), o2 = new i().port1, a = new ArrayBuffer();
- o2.postMessage(a, [a, a]);
- } catch (i) {
- i.constructor.name === "DOMException" && (globalThis.DOMException = i.constructor);
- }
- return en = globalThis.DOMException, en;
- }
- n$1(vs, "requireNodeDomexception");
- var As = vs();
- const Bs = f(As), { stat: tn } = promises;
- n$1((i, o2) => Do(statSync(i), i, o2), "blobFromSync");
- n$1((i, o2) => tn(i).then((a) => Do(a, i, o2)), "blobFrom");
- n$1((i, o2) => tn(i).then((a) => $o(a, i, o2)), "fileFrom");
- n$1((i, o2) => $o(statSync(i), i, o2), "fileFromSync");
- const Do = n$1((i, o2, a = "") => new Ze([new ir({ path: o2, size: i.size, lastModified: i.mtimeMs, start: 0 })], { type: a }), "fromBlob"), $o = n$1((i, o2, a = "") => new Yr([new ir({ path: o2, size: i.size, lastModified: i.mtimeMs, start: 0 })], basename(o2), { type: a, lastModified: i.mtimeMs }), "fromFile");
- const _ir = class _ir {
- constructor(o2) {
- __privateAdd(this, _e4);
- __privateAdd(this, _t3);
- __privateSet(this, _e4, o2.path), __privateSet(this, _t3, o2.start), this.size = o2.size, this.lastModified = o2.lastModified;
- }
- slice(o2, a) {
- return new _ir({ path: __privateGet(this, _e4), lastModified: this.lastModified, size: a - o2, start: __privateGet(this, _t3) + o2 });
- }
- async *stream() {
- const { mtimeMs: o2 } = await tn(__privateGet(this, _e4));
- if (o2 > this.lastModified) throw new Bs("The requested file could not be read, typically due to permission problems that have occurred after a reference to a file was acquired.", "NotReadableError");
- yield* createReadStream(__privateGet(this, _e4), { start: __privateGet(this, _t3), end: __privateGet(this, _t3) + this.size - 1 });
- }
- get [Symbol.toStringTag]() {
- return "Blob";
- }
- };
- _e4 = new WeakMap();
- _t3 = new WeakMap();
- n$1(_ir, "BlobDataItem");
- let ir = _ir;
- const Is = /* @__PURE__ */ new Set(["data:", "http:", "https:"]);
- async function Mo(i, o2) {
- return new Promise((a, l) => {
- const u = new Xe(i, o2), { parsedURL: m, options: h2 } = Es(u);
- if (!Is.has(m.protocol)) throw new TypeError(`node-fetch cannot load ${i}. URL scheme "${m.protocol.replace(/:$/, "")}" is not supported.`);
- if (m.protocol === "data:") {
- const g = ts(u.url), V = new H(g, { headers: { "Content-Type": g.typeFull } });
- a(V);
- return;
- }
- const S = (m.protocol === "https:" ? Qa : ft).request, { signal: E } = u;
- let w = null;
- const A = n$1(() => {
- const g = new jo("The operation was aborted.");
- l(g), u.body && u.body instanceof ie.Readable && u.body.destroy(g), !(!w || !w.body) && w.body.emit("error", g);
- }, "abort");
- if (E && E.aborted) {
- A();
- return;
- }
- const T2 = n$1(() => {
- A(), q();
- }, "abortAndFinalize"), b = S(m.toString(), h2);
- E && E.addEventListener("abort", T2);
- const q = n$1(() => {
- b.abort(), E && E.removeEventListener("abort", T2);
- }, "finalize");
- b.on("error", (g) => {
- l(new te(`request to ${u.url} failed, reason: ${g.message}`, "system", g)), q();
- }), Fs(b, (g) => {
- w && w.body && w.body.destroy(g);
- }), process.version < "v14" && b.on("socket", (g) => {
- let V;
- g.prependListener("end", () => {
- V = g._eventsCount;
- }), g.prependListener("close", (I) => {
- if (w && V < g._eventsCount && !I) {
- const F = new Error("Premature close");
- F.code = "ERR_STREAM_PREMATURE_CLOSE", w.body.emit("error", F);
- }
- });
- }), b.on("response", (g) => {
- b.setTimeout(0);
- const V = ys(g.rawHeaders);
- if (Xr(g.statusCode)) {
- const O = V.get("Location");
- let z = null;
- try {
- z = O === null ? null : new URL(O, u.url);
- } catch {
- if (u.redirect !== "manual") {
- l(new te(`uri requested responds with an invalid redirect URL: ${O}`, "invalid-redirect")), q();
- return;
- }
- }
- switch (u.redirect) {
- case "error":
- l(new te(`uri requested responds with a redirect, redirect mode is set to error: ${u.url}`, "no-redirect")), q();
- return;
- case "manual":
- break;
- case "follow": {
- if (z === null) break;
- if (u.counter >= u.follow) {
- l(new te(`maximum redirect reached at: ${u.url}`, "max-redirect")), q();
- return;
- }
- const $ = { headers: new ae(u.headers), follow: u.follow, counter: u.counter + 1, agent: u.agent, compress: u.compress, method: u.method, body: Kr(u), signal: u.signal, size: u.size, referrer: u.referrer, referrerPolicy: u.referrerPolicy };
- if (!cs(u.url, z) || !ds(u.url, z)) for (const pt of ["authorization", "www-authenticate", "cookie", "cookie2"]) $.headers.delete(pt);
- if (g.statusCode !== 303 && u.body && o2.body instanceof ie.Readable) {
- l(new te("Cannot follow redirect with body being a readable stream", "unsupported-redirect")), q();
- return;
- }
- (g.statusCode === 303 || (g.statusCode === 301 || g.statusCode === 302) && u.method === "POST") && ($.method = "GET", $.body = void 0, $.headers.delete("content-length"));
- const M = Cs(V);
- M && ($.referrerPolicy = M), a(Mo(new Xe(z, $))), q();
- return;
- }
- default:
- return l(new TypeError(`Redirect option '${u.redirect}' is not a valid value of RequestRedirect`));
- }
- }
- E && g.once("end", () => {
- E.removeEventListener("abort", T2);
- });
- let I = pipeline(g, new PassThrough(), (O) => {
- O && l(O);
- });
- process.version < "v12.10" && g.on("aborted", T2);
- const F = { url: u.url, status: g.statusCode, statusText: g.statusMessage, headers: V, size: u.size, counter: u.counter, highWaterMark: u.highWaterMark }, Q = V.get("Content-Encoding");
- if (!u.compress || u.method === "HEAD" || Q === null || g.statusCode === 204 || g.statusCode === 304) {
- w = new H(I, F), a(w);
- return;
- }
- const se = { flush: Ye.Z_SYNC_FLUSH, finishFlush: Ye.Z_SYNC_FLUSH };
- if (Q === "gzip" || Q === "x-gzip") {
- I = pipeline(I, Ye.createGunzip(se), (O) => {
- O && l(O);
- }), w = new H(I, F), a(w);
- return;
- }
- if (Q === "deflate" || Q === "x-deflate") {
- const O = pipeline(g, new PassThrough(), (z) => {
- z && l(z);
- });
- O.once("data", (z) => {
- (z[0] & 15) === 8 ? I = pipeline(I, Ye.createInflate(), ($) => {
- $ && l($);
- }) : I = pipeline(I, Ye.createInflateRaw(), ($) => {
- $ && l($);
- }), w = new H(I, F), a(w);
- }), O.once("end", () => {
- w || (w = new H(I, F), a(w));
- });
- return;
- }
- if (Q === "br") {
- I = pipeline(I, Ye.createBrotliDecompress(), (O) => {
- O && l(O);
- }), w = new H(I, F), a(w);
- return;
- }
- w = new H(I, F), a(w);
- }), ps(b, u).catch(l);
- });
- }
- n$1(Mo, "fetch$1");
- function Fs(i, o2) {
- const a = Buffer$1.from(`0\r
- \r
- `);
- let l = false, u = false, m;
- i.on("response", (h2) => {
- const { headers: S } = h2;
- l = S["transfer-encoding"] === "chunked" && !S["content-length"];
- }), i.on("socket", (h2) => {
- const S = n$1(() => {
- if (l && !u) {
- const w = new Error("Premature close");
- w.code = "ERR_STREAM_PREMATURE_CLOSE", o2(w);
- }
- }, "onSocketClose"), E = n$1((w) => {
- u = Buffer$1.compare(w.slice(-5), a) === 0, !u && m && (u = Buffer$1.compare(m.slice(-3), a.slice(0, 3)) === 0 && Buffer$1.compare(w.slice(-2), a.slice(3)) === 0), m = w;
- }, "onData");
- h2.prependListener("close", S), h2.on("data", E), i.on("close", () => {
- h2.removeListener("close", S), h2.removeListener("data", E);
- });
- });
- }
- n$1(Fs, "fixResponseChunkedTransferBadEnding");
- const Uo = /* @__PURE__ */ new WeakMap(), rn = /* @__PURE__ */ new WeakMap();
- function k(i) {
- const o2 = Uo.get(i);
- return console.assert(o2 != null, "'this' is expected an Event object, but got", i), o2;
- }
- n$1(k, "pd");
- function xo(i) {
- if (i.passiveListener != null) {
- typeof console < "u" && typeof console.error == "function" && console.error("Unable to preventDefault inside passive event listener invocation.", i.passiveListener);
- return;
- }
- i.event.cancelable && (i.canceled = true, typeof i.event.preventDefault == "function" && i.event.preventDefault());
- }
- n$1(xo, "setCancelFlag");
- function Je(i, o2) {
- Uo.set(this, { eventTarget: i, event: o2, eventPhase: 2, currentTarget: i, canceled: false, stopped: false, immediateStopped: false, passiveListener: null, timeStamp: o2.timeStamp || Date.now() }), Object.defineProperty(this, "isTrusted", { value: false, enumerable: true });
- const a = Object.keys(o2);
- for (let l = 0; l < a.length; ++l) {
- const u = a[l];
- u in this || Object.defineProperty(this, u, No(u));
- }
- }
- n$1(Je, "Event"), Je.prototype = { get type() {
- return k(this).event.type;
- }, get target() {
- return k(this).eventTarget;
- }, get currentTarget() {
- return k(this).currentTarget;
- }, composedPath() {
- const i = k(this).currentTarget;
- return i == null ? [] : [i];
- }, get NONE() {
- return 0;
- }, get CAPTURING_PHASE() {
- return 1;
- }, get AT_TARGET() {
- return 2;
- }, get BUBBLING_PHASE() {
- return 3;
- }, get eventPhase() {
- return k(this).eventPhase;
- }, stopPropagation() {
- const i = k(this);
- i.stopped = true, typeof i.event.stopPropagation == "function" && i.event.stopPropagation();
- }, stopImmediatePropagation() {
- const i = k(this);
- i.stopped = true, i.immediateStopped = true, typeof i.event.stopImmediatePropagation == "function" && i.event.stopImmediatePropagation();
- }, get bubbles() {
- return !!k(this).event.bubbles;
- }, get cancelable() {
- return !!k(this).event.cancelable;
- }, preventDefault() {
- xo(k(this));
- }, get defaultPrevented() {
- return k(this).canceled;
- }, get composed() {
- return !!k(this).event.composed;
- }, get timeStamp() {
- return k(this).timeStamp;
- }, get srcElement() {
- return k(this).eventTarget;
- }, get cancelBubble() {
- return k(this).stopped;
- }, set cancelBubble(i) {
- if (!i) return;
- const o2 = k(this);
- o2.stopped = true, typeof o2.event.cancelBubble == "boolean" && (o2.event.cancelBubble = true);
- }, get returnValue() {
- return !k(this).canceled;
- }, set returnValue(i) {
- i || xo(k(this));
- }, initEvent() {
- } }, Object.defineProperty(Je.prototype, "constructor", { value: Je, configurable: true, writable: true });
- function No(i) {
- return { get() {
- return k(this).event[i];
- }, set(o2) {
- k(this).event[i] = o2;
- }, configurable: true, enumerable: true };
- }
- n$1(No, "defineRedirectDescriptor");
- function zs(i) {
- return { value() {
- const o2 = k(this).event;
- return o2[i].apply(o2, arguments);
- }, configurable: true, enumerable: true };
- }
- n$1(zs, "defineCallDescriptor");
- function js(i, o2) {
- const a = Object.keys(o2);
- if (a.length === 0) return i;
- function l(u, m) {
- i.call(this, u, m);
- }
- n$1(l, "CustomEvent"), l.prototype = Object.create(i.prototype, { constructor: { value: l, configurable: true, writable: true } });
- for (let u = 0; u < a.length; ++u) {
- const m = a[u];
- if (!(m in i.prototype)) {
- const S = typeof Object.getOwnPropertyDescriptor(o2, m).value == "function";
- Object.defineProperty(l.prototype, m, S ? zs(m) : No(m));
- }
- }
- return l;
- }
- n$1(js, "defineWrapper");
- function Ho(i) {
- if (i == null || i === Object.prototype) return Je;
- let o2 = rn.get(i);
- return o2 == null && (o2 = js(Ho(Object.getPrototypeOf(i)), i), rn.set(i, o2)), o2;
- }
- n$1(Ho, "getWrapper");
- function Ls(i, o2) {
- const a = Ho(Object.getPrototypeOf(o2));
- return new a(i, o2);
- }
- n$1(Ls, "wrapEvent");
- function Ds(i) {
- return k(i).immediateStopped;
- }
- n$1(Ds, "isStopped");
- function $s(i, o2) {
- k(i).eventPhase = o2;
- }
- n$1($s, "setEventPhase");
- function Ms(i, o2) {
- k(i).currentTarget = o2;
- }
- n$1(Ms, "setCurrentTarget");
- function Vo(i, o2) {
- k(i).passiveListener = o2;
- }
- n$1(Vo, "setPassiveListener");
- const Qo = /* @__PURE__ */ new WeakMap(), Yo = 1, Go = 2, tr = 3;
- function rr(i) {
- return i !== null && typeof i == "object";
- }
- n$1(rr, "isObject");
- function bt(i) {
- const o2 = Qo.get(i);
- if (o2 == null) throw new TypeError("'this' is expected an EventTarget object, but got another value.");
- return o2;
- }
- n$1(bt, "getListeners");
- function Us(i) {
- return { get() {
- let a = bt(this).get(i);
- for (; a != null; ) {
- if (a.listenerType === tr) return a.listener;
- a = a.next;
- }
- return null;
- }, set(o2) {
- typeof o2 != "function" && !rr(o2) && (o2 = null);
- const a = bt(this);
- let l = null, u = a.get(i);
- for (; u != null; ) u.listenerType === tr ? l !== null ? l.next = u.next : u.next !== null ? a.set(i, u.next) : a.delete(i) : l = u, u = u.next;
- if (o2 !== null) {
- const m = { listener: o2, listenerType: tr, passive: false, once: false, next: null };
- l === null ? a.set(i, m) : l.next = m;
- }
- }, configurable: true, enumerable: true };
- }
- n$1(Us, "defineEventAttributeDescriptor");
- function Zo(i, o2) {
- Object.defineProperty(i, `on${o2}`, Us(o2));
- }
- n$1(Zo, "defineEventAttribute");
- function Ko(i) {
- function o2() {
- pe.call(this);
- }
- n$1(o2, "CustomEventTarget"), o2.prototype = Object.create(pe.prototype, { constructor: { value: o2, configurable: true, writable: true } });
- for (let a = 0; a < i.length; ++a) Zo(o2.prototype, i[a]);
- return o2;
- }
- n$1(Ko, "defineCustomEventTarget");
- function pe() {
- if (this instanceof pe) {
- Qo.set(this, /* @__PURE__ */ new Map());
- return;
- }
- if (arguments.length === 1 && Array.isArray(arguments[0])) return Ko(arguments[0]);
- if (arguments.length > 0) {
- const i = new Array(arguments.length);
- for (let o2 = 0; o2 < arguments.length; ++o2) i[o2] = arguments[o2];
- return Ko(i);
- }
- throw new TypeError("Cannot call a class as a function");
- }
- n$1(pe, "EventTarget"), pe.prototype = { addEventListener(i, o2, a) {
- if (o2 == null) return;
- if (typeof o2 != "function" && !rr(o2)) throw new TypeError("'listener' should be a function or an object.");
- const l = bt(this), u = rr(a), h2 = (u ? !!a.capture : !!a) ? Yo : Go, S = { listener: o2, listenerType: h2, passive: u && !!a.passive, once: u && !!a.once, next: null };
- let E = l.get(i);
- if (E === void 0) {
- l.set(i, S);
- return;
- }
- let w = null;
- for (; E != null; ) {
- if (E.listener === o2 && E.listenerType === h2) return;
- w = E, E = E.next;
- }
- w.next = S;
- }, removeEventListener(i, o2, a) {
- if (o2 == null) return;
- const l = bt(this), m = (rr(a) ? !!a.capture : !!a) ? Yo : Go;
- let h2 = null, S = l.get(i);
- for (; S != null; ) {
- if (S.listener === o2 && S.listenerType === m) {
- h2 !== null ? h2.next = S.next : S.next !== null ? l.set(i, S.next) : l.delete(i);
- return;
- }
- h2 = S, S = S.next;
- }
- }, dispatchEvent(i) {
- if (i == null || typeof i.type != "string") throw new TypeError('"event.type" should be a string.');
- const o2 = bt(this), a = i.type;
- let l = o2.get(a);
- if (l == null) return true;
- const u = Ls(this, i);
- let m = null;
- for (; l != null; ) {
- if (l.once ? m !== null ? m.next = l.next : l.next !== null ? o2.set(a, l.next) : o2.delete(a) : m = l, Vo(u, l.passive ? l.listener : null), typeof l.listener == "function") try {
- l.listener.call(this, u);
- } catch (h2) {
- typeof console < "u" && typeof console.error == "function" && console.error(h2);
- }
- else l.listenerType !== tr && typeof l.listener.handleEvent == "function" && l.listener.handleEvent(u);
- if (Ds(u)) break;
- l = l.next;
- }
- return Vo(u, null), $s(u, 0), Ms(u, null), !u.defaultPrevented;
- } }, Object.defineProperty(pe.prototype, "constructor", { value: pe, configurable: true, writable: true });
- const _nr = class _nr extends pe {
- constructor() {
- throw super(), new TypeError("AbortSignal cannot be constructed directly");
- }
- get aborted() {
- const o2 = or.get(this);
- if (typeof o2 != "boolean") throw new TypeError(`Expected 'this' to be an 'AbortSignal' object, but got ${this === null ? "null" : typeof this}`);
- return o2;
- }
- };
- n$1(_nr, "AbortSignal");
- let nr = _nr;
- Zo(nr.prototype, "abort");
- function xs() {
- const i = Object.create(nr.prototype);
- return pe.call(i), or.set(i, false), i;
- }
- n$1(xs, "createAbortSignal");
- function Ns(i) {
- or.get(i) === false && (or.set(i, true), i.dispatchEvent({ type: "abort" }));
- }
- n$1(Ns, "abortSignal");
- const or = /* @__PURE__ */ new WeakMap();
- Object.defineProperties(nr.prototype, { aborted: { enumerable: true } }), typeof Symbol == "function" && typeof Symbol.toStringTag == "symbol" && Object.defineProperty(nr.prototype, Symbol.toStringTag, { configurable: true, value: "AbortSignal" });
- let nn = (_d = class {
- constructor() {
- Jo.set(this, xs());
- }
- get signal() {
- return Xo(this);
- }
- abort() {
- Ns(Xo(this));
- }
- }, n$1(_d, "AbortController"), _d);
- const Jo = /* @__PURE__ */ new WeakMap();
- function Xo(i) {
- const o2 = Jo.get(i);
- if (o2 == null) throw new TypeError(`Expected 'this' to be an 'AbortController' object, but got ${i === null ? "null" : typeof i}`);
- return o2;
- }
- n$1(Xo, "getSignal"), Object.defineProperties(nn.prototype, { signal: { enumerable: true }, abort: { enumerable: true } }), typeof Symbol == "function" && typeof Symbol.toStringTag == "symbol" && Object.defineProperty(nn.prototype, Symbol.toStringTag, { configurable: true, value: "AbortController" });
- var Hs = Object.defineProperty, Vs = n$1((i, o2) => Hs(i, "name", { value: o2, configurable: true }), "e");
- const ei = Mo;
- ti();
- function ti() {
- var _a2, _b2, _c2, _d2;
- !((_b2 = (_a2 = globalThis.process) == null ? void 0 : _a2.versions) == null ? void 0 : _b2.node) && !((_d2 = (_c2 = globalThis.process) == null ? void 0 : _c2.env) == null ? void 0 : _d2.DISABLE_NODE_FETCH_NATIVE_WARN) && console.warn("[node-fetch-native] Node.js compatible build of `node-fetch-native` is being used in a non-Node.js environment. Please make sure you are using proper export conditions or report this issue to https://github.com/unjs/node-fetch-native. You can set `process.env.DISABLE_NODE_FETCH_NATIVE_WARN` to disable this warning.");
- }
- n$1(ti, "s"), Vs(ti, "checkNodeEnvironment");
- const o = !!((_f = (_e5 = globalThis.process) == null ? void 0 : _e5.env) == null ? void 0 : _f.FORCE_NODE_FETCH), r = !o && globalThis.fetch || ei, n = !o && globalThis.Headers || ae, T = !o && globalThis.AbortController || nn;
- class FetchError extends Error {
- constructor(message, opts) {
- super(message, opts);
- this.name = "FetchError";
- if ((opts == null ? void 0 : opts.cause) && !this.cause) {
- this.cause = opts.cause;
- }
- }
- }
- function createFetchError(ctx) {
- var _a2, _b2, _c2, _d2, _e6;
- const errorMessage = ((_a2 = ctx.error) == null ? void 0 : _a2.message) || ((_b2 = ctx.error) == null ? void 0 : _b2.toString()) || "";
- const method = ((_c2 = ctx.request) == null ? void 0 : _c2.method) || ((_d2 = ctx.options) == null ? void 0 : _d2.method) || "GET";
- const url = ((_e6 = ctx.request) == null ? void 0 : _e6.url) || String(ctx.request) || "/";
- const requestStr = `[${method}] ${JSON.stringify(url)}`;
- const statusStr = ctx.response ? `${ctx.response.status} ${ctx.response.statusText}` : "<no response>";
- const message = `${requestStr}: ${statusStr}${errorMessage ? ` ${errorMessage}` : ""}`;
- const fetchError = new FetchError(
- message,
- ctx.error ? { cause: ctx.error } : void 0
- );
- for (const key of ["request", "options", "response"]) {
- Object.defineProperty(fetchError, key, {
- get() {
- return ctx[key];
- }
- });
- }
- for (const [key, refKey] of [
- ["data", "_data"],
- ["status", "status"],
- ["statusCode", "status"],
- ["statusText", "statusText"],
- ["statusMessage", "statusText"]
- ]) {
- Object.defineProperty(fetchError, key, {
- get() {
- return ctx.response && ctx.response[refKey];
- }
- });
- }
- return fetchError;
- }
- const payloadMethods = new Set(
- Object.freeze(["PATCH", "POST", "PUT", "DELETE"])
- );
- function isPayloadMethod(method = "GET") {
- return payloadMethods.has(method.toUpperCase());
- }
- function isJSONSerializable(value) {
- if (value === void 0) {
- return false;
- }
- const t2 = typeof value;
- if (t2 === "string" || t2 === "number" || t2 === "boolean" || t2 === null) {
- return true;
- }
- if (t2 !== "object") {
- return false;
- }
- if (Array.isArray(value)) {
- return true;
- }
- if (value.buffer) {
- return false;
- }
- return value.constructor && value.constructor.name === "Object" || typeof value.toJSON === "function";
- }
- const textTypes = /* @__PURE__ */ new Set([
- "image/svg",
- "application/xml",
- "application/xhtml",
- "application/html"
- ]);
- const JSON_RE = /^application\/(?:[\w!#$%&*.^`~-]*\+)?json(;.+)?$/i;
- function detectResponseType(_contentType = "") {
- if (!_contentType) {
- return "json";
- }
- const contentType = _contentType.split(";").shift() || "";
- if (JSON_RE.test(contentType)) {
- return "json";
- }
- if (textTypes.has(contentType) || contentType.startsWith("text/")) {
- return "text";
- }
- return "blob";
- }
- function resolveFetchOptions(request, input, defaults, Headers2) {
- const headers = mergeHeaders(
- (input == null ? void 0 : input.headers) ?? (request == null ? void 0 : request.headers),
- defaults == null ? void 0 : defaults.headers,
- Headers2
- );
- let query;
- if ((defaults == null ? void 0 : defaults.query) || (defaults == null ? void 0 : defaults.params) || (input == null ? void 0 : input.params) || (input == null ? void 0 : input.query)) {
- query = {
- ...defaults == null ? void 0 : defaults.params,
- ...defaults == null ? void 0 : defaults.query,
- ...input == null ? void 0 : input.params,
- ...input == null ? void 0 : input.query
- };
- }
- return {
- ...defaults,
- ...input,
- query,
- params: query,
- headers
- };
- }
- function mergeHeaders(input, defaults, Headers2) {
- if (!defaults) {
- return new Headers2(input);
- }
- const headers = new Headers2(defaults);
- if (input) {
- for (const [key, value] of Symbol.iterator in input || Array.isArray(input) ? input : new Headers2(input)) {
- headers.set(key, value);
- }
- }
- return headers;
- }
- async function callHooks(context, hooks) {
- if (hooks) {
- if (Array.isArray(hooks)) {
- for (const hook of hooks) {
- await hook(context);
- }
- } else {
- await hooks(context);
- }
- }
- }
- const retryStatusCodes = /* @__PURE__ */ new Set([
- 408,
- // Request Timeout
- 409,
- // Conflict
- 425,
- // Too Early (Experimental)
- 429,
- // Too Many Requests
- 500,
- // Internal Server Error
- 502,
- // Bad Gateway
- 503,
- // Service Unavailable
- 504
- // Gateway Timeout
- ]);
- const nullBodyResponses = /* @__PURE__ */ new Set([101, 204, 205, 304]);
- function createFetch(globalOptions = {}) {
- const {
- fetch: fetch2 = globalThis.fetch,
- Headers: Headers2 = globalThis.Headers,
- AbortController: AbortController2 = globalThis.AbortController
- } = globalOptions;
- async function onError(context) {
- const isAbort = context.error && context.error.name === "AbortError" && !context.options.timeout || false;
- if (context.options.retry !== false && !isAbort) {
- let retries;
- if (typeof context.options.retry === "number") {
- retries = context.options.retry;
- } else {
- retries = isPayloadMethod(context.options.method) ? 0 : 1;
- }
- const responseCode = context.response && context.response.status || 500;
- if (retries > 0 && (Array.isArray(context.options.retryStatusCodes) ? context.options.retryStatusCodes.includes(responseCode) : retryStatusCodes.has(responseCode))) {
- const retryDelay = typeof context.options.retryDelay === "function" ? context.options.retryDelay(context) : context.options.retryDelay || 0;
- if (retryDelay > 0) {
- await new Promise((resolve) => setTimeout(resolve, retryDelay));
- }
- return $fetchRaw(context.request, {
- ...context.options,
- retry: retries - 1
- });
- }
- }
- const error = createFetchError(context);
- if (Error.captureStackTrace) {
- Error.captureStackTrace(error, $fetchRaw);
- }
- throw error;
- }
- const $fetchRaw = async function $fetchRaw2(_request, _options = {}) {
- const context = {
- request: _request,
- options: resolveFetchOptions(
- _request,
- _options,
- globalOptions.defaults,
- Headers2
- ),
- response: void 0,
- error: void 0
- };
- if (context.options.method) {
- context.options.method = context.options.method.toUpperCase();
- }
- if (context.options.onRequest) {
- await callHooks(context, context.options.onRequest);
- }
- if (typeof context.request === "string") {
- if (context.options.baseURL) {
- context.request = withBase(context.request, context.options.baseURL);
- }
- if (context.options.query) {
- context.request = withQuery(context.request, context.options.query);
- delete context.options.query;
- }
- if ("query" in context.options) {
- delete context.options.query;
- }
- if ("params" in context.options) {
- delete context.options.params;
- }
- }
- if (context.options.body && isPayloadMethod(context.options.method)) {
- if (isJSONSerializable(context.options.body)) {
- context.options.body = typeof context.options.body === "string" ? context.options.body : JSON.stringify(context.options.body);
- context.options.headers = new Headers2(context.options.headers || {});
- if (!context.options.headers.has("content-type")) {
- context.options.headers.set("content-type", "application/json");
- }
- if (!context.options.headers.has("accept")) {
- context.options.headers.set("accept", "application/json");
- }
- } else if (
- // ReadableStream Body
- "pipeTo" in context.options.body && typeof context.options.body.pipeTo === "function" || // Node.js Stream Body
- typeof context.options.body.pipe === "function"
- ) {
- if (!("duplex" in context.options)) {
- context.options.duplex = "half";
- }
- }
- }
- let abortTimeout;
- if (!context.options.signal && context.options.timeout) {
- const controller = new AbortController2();
- abortTimeout = setTimeout(() => {
- const error = new Error(
- "[TimeoutError]: The operation was aborted due to timeout"
- );
- error.name = "TimeoutError";
- error.code = 23;
- controller.abort(error);
- }, context.options.timeout);
- context.options.signal = controller.signal;
- }
- try {
- context.response = await fetch2(
- context.request,
- context.options
- );
- } catch (error) {
- context.error = error;
- if (context.options.onRequestError) {
- await callHooks(
- context,
- context.options.onRequestError
- );
- }
- return await onError(context);
- } finally {
- if (abortTimeout) {
- clearTimeout(abortTimeout);
- }
- }
- const hasBody = (context.response.body || // https://github.com/unjs/ofetch/issues/324
- // https://github.com/unjs/ofetch/issues/294
- // https://github.com/JakeChampion/fetch/issues/1454
- context.response._bodyInit) && !nullBodyResponses.has(context.response.status) && context.options.method !== "HEAD";
- if (hasBody) {
- const responseType = (context.options.parseResponse ? "json" : context.options.responseType) || detectResponseType(context.response.headers.get("content-type") || "");
- switch (responseType) {
- case "json": {
- const data = await context.response.text();
- const parseFunction = context.options.parseResponse || destr;
- context.response._data = parseFunction(data);
- break;
- }
- case "stream": {
- context.response._data = context.response.body || context.response._bodyInit;
- break;
- }
- default: {
- context.response._data = await context.response[responseType]();
- }
- }
- }
- if (context.options.onResponse) {
- await callHooks(
- context,
- context.options.onResponse
- );
- }
- if (!context.options.ignoreResponseError && context.response.status >= 400 && context.response.status < 600) {
- if (context.options.onResponseError) {
- await callHooks(
- context,
- context.options.onResponseError
- );
- }
- return await onError(context);
- }
- return context.response;
- };
- const $fetch2 = async function $fetch22(request, options) {
- const r2 = await $fetchRaw(request, options);
- return r2._data;
- };
- $fetch2.raw = $fetchRaw;
- $fetch2.native = (...args) => fetch2(...args);
- $fetch2.create = (defaultOptions = {}, customGlobalOptions = {}) => createFetch({
- ...globalOptions,
- ...customGlobalOptions,
- defaults: {
- ...globalOptions.defaults,
- ...customGlobalOptions.defaults,
- ...defaultOptions
- }
- });
- return $fetch2;
- }
- function createNodeFetch() {
- const useKeepAlive = JSON.parse(process.env.FETCH_KEEP_ALIVE || "false");
- if (!useKeepAlive) {
- return r;
- }
- const agentOptions = { keepAlive: true };
- const httpAgent = new ft.Agent(agentOptions);
- const httpsAgent = new Qa.Agent(agentOptions);
- const nodeFetchOptions = {
- agent(parsedURL) {
- return parsedURL.protocol === "http:" ? httpAgent : httpsAgent;
- }
- };
- return function nodeFetchWithKeepAlive(input, init) {
- return r(input, { ...nodeFetchOptions, ...init });
- };
- }
- const fetch = globalThis.fetch ? (...args) => globalThis.fetch(...args) : createNodeFetch();
- const Headers = globalThis.Headers || n;
- const AbortController$1 = globalThis.AbortController || T;
- const ofetch = createFetch({ fetch, Headers, AbortController: AbortController$1 });
- const $fetch = ofetch;
- if (!globalThis.$fetch) {
- globalThis.$fetch = $fetch.create({
- baseURL: baseURL()
- });
- }
- if (!("global" in globalThis)) {
- globalThis.global = globalThis;
- }
- const nuxtLinkDefaults = { "componentName": "NuxtLink" };
- const appId = "nuxt-app";
- function getNuxtAppCtx(id = appId) {
- return getContext(id, {
- asyncContext: false
- });
- }
- const NuxtPluginIndicator = "__nuxt_plugin";
- function createNuxtApp(options) {
- var _a2;
- let hydratingCount = 0;
- const nuxtApp = {
- _id: options.id || appId || "nuxt-app",
- _scope: effectScope(),
- provide: void 0,
- globalName: "nuxt",
- versions: {
- get nuxt() {
- return "3.17.4";
- },
- get vue() {
- return nuxtApp.vueApp.version;
- }
- },
- payload: shallowReactive({
- ...((_a2 = options.ssrContext) == null ? void 0 : _a2.payload) || {},
- data: shallowReactive({}),
- state: reactive({}),
- once: /* @__PURE__ */ new Set(),
- _errors: shallowReactive({})
- }),
- static: {
- data: {}
- },
- runWithContext(fn) {
- if (nuxtApp._scope.active && !getCurrentScope()) {
- return nuxtApp._scope.run(() => callWithNuxt(nuxtApp, fn));
- }
- return callWithNuxt(nuxtApp, fn);
- },
- isHydrating: false,
- deferHydration() {
- if (!nuxtApp.isHydrating) {
- return () => {
- };
- }
- hydratingCount++;
- let called = false;
- return () => {
- if (called) {
- return;
- }
- called = true;
- hydratingCount--;
- if (hydratingCount === 0) {
- nuxtApp.isHydrating = false;
- return nuxtApp.callHook("app:suspense:resolve");
- }
- };
- },
- _asyncDataPromises: {},
- _asyncData: shallowReactive({}),
- _payloadRevivers: {},
- ...options
- };
- {
- nuxtApp.payload.serverRendered = true;
- }
- if (nuxtApp.ssrContext) {
- nuxtApp.payload.path = nuxtApp.ssrContext.url;
- nuxtApp.ssrContext.nuxt = nuxtApp;
- nuxtApp.ssrContext.payload = nuxtApp.payload;
- nuxtApp.ssrContext.config = {
- public: nuxtApp.ssrContext.runtimeConfig.public,
- app: nuxtApp.ssrContext.runtimeConfig.app
- };
- }
- nuxtApp.hooks = createHooks();
- nuxtApp.hook = nuxtApp.hooks.hook;
- {
- const contextCaller = async function(hooks, args) {
- for (const hook of hooks) {
- await nuxtApp.runWithContext(() => hook(...args));
- }
- };
- nuxtApp.hooks.callHook = (name, ...args) => nuxtApp.hooks.callHookWith(contextCaller, name, ...args);
- }
- nuxtApp.callHook = nuxtApp.hooks.callHook;
- nuxtApp.provide = (name, value) => {
- const $name = "$" + name;
- defineGetter(nuxtApp, $name, value);
- defineGetter(nuxtApp.vueApp.config.globalProperties, $name, value);
- };
- defineGetter(nuxtApp.vueApp, "$nuxt", nuxtApp);
- defineGetter(nuxtApp.vueApp.config.globalProperties, "$nuxt", nuxtApp);
- const runtimeConfig = options.ssrContext.runtimeConfig;
- nuxtApp.provide("config", runtimeConfig);
- return nuxtApp;
- }
- function registerPluginHooks(nuxtApp, plugin2) {
- if (plugin2.hooks) {
- nuxtApp.hooks.addHooks(plugin2.hooks);
- }
- }
- async function applyPlugin(nuxtApp, plugin2) {
- if (typeof plugin2 === "function") {
- const { provide: provide2 } = await nuxtApp.runWithContext(() => plugin2(nuxtApp)) || {};
- if (provide2 && typeof provide2 === "object") {
- for (const key in provide2) {
- nuxtApp.provide(key, provide2[key]);
- }
- }
- }
- }
- async function applyPlugins(nuxtApp, plugins2) {
- var _a2, _b2, _c2, _d2;
- const resolvedPlugins = /* @__PURE__ */ new Set();
- const unresolvedPlugins = [];
- const parallels = [];
- const errors = [];
- let promiseDepth = 0;
- async function executePlugin(plugin2) {
- var _a3;
- const unresolvedPluginsForThisPlugin = ((_a3 = plugin2.dependsOn) == null ? void 0 : _a3.filter((name) => plugins2.some((p) => p._name === name) && !resolvedPlugins.has(name))) ?? [];
- if (unresolvedPluginsForThisPlugin.length > 0) {
- unresolvedPlugins.push([new Set(unresolvedPluginsForThisPlugin), plugin2]);
- } else {
- const promise = applyPlugin(nuxtApp, plugin2).then(async () => {
- if (plugin2._name) {
- resolvedPlugins.add(plugin2._name);
- await Promise.all(unresolvedPlugins.map(async ([dependsOn, unexecutedPlugin]) => {
- if (dependsOn.has(plugin2._name)) {
- dependsOn.delete(plugin2._name);
- if (dependsOn.size === 0) {
- promiseDepth++;
- await executePlugin(unexecutedPlugin);
- }
- }
- }));
- }
- });
- if (plugin2.parallel) {
- parallels.push(promise.catch((e) => errors.push(e)));
- } else {
- await promise;
- }
- }
- }
- for (const plugin2 of plugins2) {
- if (((_a2 = nuxtApp.ssrContext) == null ? void 0 : _a2.islandContext) && ((_b2 = plugin2.env) == null ? void 0 : _b2.islands) === false) {
- continue;
- }
- registerPluginHooks(nuxtApp, plugin2);
- }
- for (const plugin2 of plugins2) {
- if (((_c2 = nuxtApp.ssrContext) == null ? void 0 : _c2.islandContext) && ((_d2 = plugin2.env) == null ? void 0 : _d2.islands) === false) {
- continue;
- }
- await executePlugin(plugin2);
- }
- await Promise.all(parallels);
- if (promiseDepth) {
- for (let i = 0; i < promiseDepth; i++) {
- await Promise.all(parallels);
- }
- }
- if (errors.length) {
- throw errors[0];
- }
- }
- // @__NO_SIDE_EFFECTS__
- function defineNuxtPlugin(plugin2) {
- if (typeof plugin2 === "function") {
- return plugin2;
- }
- const _name = plugin2._name || plugin2.name;
- delete plugin2.name;
- return Object.assign(plugin2.setup || (() => {
- }), plugin2, { [NuxtPluginIndicator]: true, _name });
- }
- function callWithNuxt(nuxt, setup, args) {
- const fn = () => setup();
- const nuxtAppCtx = getNuxtAppCtx(nuxt._id);
- {
- return nuxt.vueApp.runWithContext(() => nuxtAppCtx.callAsync(nuxt, fn));
- }
- }
- function tryUseNuxtApp(id) {
- var _a2;
- let nuxtAppInstance;
- if (hasInjectionContext()) {
- nuxtAppInstance = (_a2 = getCurrentInstance()) == null ? void 0 : _a2.appContext.app.$nuxt;
- }
- nuxtAppInstance || (nuxtAppInstance = getNuxtAppCtx(id).tryUse());
- return nuxtAppInstance || null;
- }
- function useNuxtApp(id) {
- const nuxtAppInstance = tryUseNuxtApp(id);
- if (!nuxtAppInstance) {
- {
- throw new Error("[nuxt] instance unavailable");
- }
- }
- return nuxtAppInstance;
- }
- // @__NO_SIDE_EFFECTS__
- function useRuntimeConfig(_event) {
- return useNuxtApp().$config;
- }
- function defineGetter(obj, key, val) {
- Object.defineProperty(obj, key, { get: () => val });
- }
- const LayoutMetaSymbol = Symbol("layout-meta");
- const PageRouteSymbol = Symbol("route");
- const useRouter = () => {
- var _a2;
- return (_a2 = useNuxtApp()) == null ? void 0 : _a2.$router;
- };
- const useRoute = () => {
- if (hasInjectionContext()) {
- return inject(PageRouteSymbol, useNuxtApp()._route);
- }
- return useNuxtApp()._route;
- };
- // @__NO_SIDE_EFFECTS__
- function defineNuxtRouteMiddleware(middleware) {
- return middleware;
- }
- const isProcessingMiddleware = () => {
- try {
- if (useNuxtApp()._processingMiddleware) {
- return true;
- }
- } catch {
- return false;
- }
- return false;
- };
- const URL_QUOTE_RE = /"/g;
- const navigateTo = (to, options) => {
- to || (to = "/");
- const toPath = typeof to === "string" ? to : "path" in to ? resolveRouteObject(to) : useRouter().resolve(to).href;
- const isExternalHost = hasProtocol(toPath, { acceptRelative: true });
- const isExternal = (options == null ? void 0 : options.external) || isExternalHost;
- if (isExternal) {
- if (!(options == null ? void 0 : options.external)) {
- throw new Error("Navigating to an external URL is not allowed by default. Use `navigateTo(url, { external: true })`.");
- }
- const { protocol } = new URL(toPath, "http://localhost");
- if (protocol && isScriptProtocol(protocol)) {
- throw new Error(`Cannot navigate to a URL with '${protocol}' protocol.`);
- }
- }
- const inMiddleware = isProcessingMiddleware();
- const router = useRouter();
- const nuxtApp = useNuxtApp();
- {
- if (nuxtApp.ssrContext) {
- const fullPath = typeof to === "string" || isExternal ? toPath : router.resolve(to).fullPath || "/";
- const location2 = isExternal ? toPath : joinURL((/* @__PURE__ */ useRuntimeConfig()).app.baseURL, fullPath);
- const redirect = async function(response) {
- await nuxtApp.callHook("app:redirected");
- const encodedLoc = location2.replace(URL_QUOTE_RE, "%22");
- const encodedHeader = encodeURL(location2, isExternalHost);
- nuxtApp.ssrContext._renderResponse = {
- statusCode: sanitizeStatusCode((options == null ? void 0 : options.redirectCode) || 302, 302),
- body: `<!DOCTYPE html><html><head><meta http-equiv="refresh" content="0; url=${encodedLoc}"></head></html>`,
- headers: { location: encodedHeader }
- };
- return response;
- };
- if (!isExternal && inMiddleware) {
- router.afterEach((final) => final.fullPath === fullPath ? redirect(false) : void 0);
- return to;
- }
- return redirect(!inMiddleware ? void 0 : (
- /* abort route navigation */
- false
- ));
- }
- }
- if (isExternal) {
- nuxtApp._scope.stop();
- if (options == null ? void 0 : options.replace) {
- (void 0).replace(toPath);
- } else {
- (void 0).href = toPath;
- }
- if (inMiddleware) {
- if (!nuxtApp.isHydrating) {
- return false;
- }
- return new Promise(() => {
- });
- }
- return Promise.resolve();
- }
- return (options == null ? void 0 : options.replace) ? router.replace(to) : router.push(to);
- };
- function resolveRouteObject(to) {
- return withQuery(to.path || "", to.query || {}) + (to.hash || "");
- }
- function encodeURL(location2, isExternalHost = false) {
- const url = new URL(location2, "http://localhost");
- if (!isExternalHost) {
- return url.pathname + url.search + url.hash;
- }
- if (location2.startsWith("//")) {
- return url.toString().replace(url.protocol, "");
- }
- return url.toString();
- }
- const NUXT_ERROR_SIGNATURE = "__nuxt_error";
- const useError = () => toRef(useNuxtApp().payload, "error");
- const showError = (error) => {
- const nuxtError = createError(error);
- try {
- const nuxtApp = useNuxtApp();
- const error2 = useError();
- if (false) ;
- error2.value || (error2.value = nuxtError);
- } catch {
- throw nuxtError;
- }
- return nuxtError;
- };
- const isNuxtError = (error) => !!error && typeof error === "object" && NUXT_ERROR_SIGNATURE in error;
- const createError = (error) => {
- const nuxtError = createError$1(error);
- Object.defineProperty(nuxtError, NUXT_ERROR_SIGNATURE, {
- value: true,
- configurable: false,
- writable: false
- });
- return nuxtError;
- };
- const unhead_v5ac8_aYQVlP6KGZHvlpq6x2XWXwze6_1FIL8VEzXsY = /* @__PURE__ */ defineNuxtPlugin({
- name: "nuxt:head",
- enforce: "pre",
- setup(nuxtApp) {
- const head = nuxtApp.ssrContext.head;
- nuxtApp.vueApp.use(head);
- }
- });
- function toArray$1(value) {
- return Array.isArray(value) ? value : [value];
- }
- async function getRouteRules(arg) {
- const path = typeof arg === "string" ? arg : arg.path;
- {
- useNuxtApp().ssrContext._preloadManifest = true;
- const _routeRulesMatcher = toRouteMatcher(
- createRouter$1({ routes: (/* @__PURE__ */ useRuntimeConfig()).nitro.routeRules })
- );
- return defu({}, ..._routeRulesMatcher.matchAll(path).reverse());
- }
- }
- const _routes = [
- {
- name: "index",
- path: "/",
- component: () => import('./index-C7bUMxuK.mjs')
- }
- ];
- const ROUTE_KEY_PARENTHESES_RE = /(:\w+)\([^)]+\)/g;
- const ROUTE_KEY_SYMBOLS_RE = /(:\w+)[?+*]/g;
- const ROUTE_KEY_NORMAL_RE = /:\w+/g;
- function generateRouteKey(route) {
- const source = (route == null ? void 0 : route.meta.key) ?? route.path.replace(ROUTE_KEY_PARENTHESES_RE, "$1").replace(ROUTE_KEY_SYMBOLS_RE, "$1").replace(ROUTE_KEY_NORMAL_RE, (r2) => {
- var _a2;
- return ((_a2 = route.params[r2.slice(1)]) == null ? void 0 : _a2.toString()) || "";
- });
- return typeof source === "function" ? source(route) : source;
- }
- function isChangingPage(to, from) {
- if (to === from || from === START_LOCATION) {
- return false;
- }
- if (generateRouteKey(to) !== generateRouteKey(from)) {
- return true;
- }
- const areComponentsSame = to.matched.every(
- (comp, index) => {
- var _a2, _b2;
- return comp.components && comp.components.default === ((_b2 = (_a2 = from.matched[index]) == null ? void 0 : _a2.components) == null ? void 0 : _b2.default);
- }
- );
- if (areComponentsSame) {
- return false;
- }
- return true;
- }
- const routerOptions0 = {
- scrollBehavior(to, from, savedPosition) {
- var _a2;
- const nuxtApp = useNuxtApp();
- const behavior = ((_a2 = useRouter().options) == null ? void 0 : _a2.scrollBehaviorType) ?? "auto";
- if (to.path === from.path) {
- if (from.hash && !to.hash) {
- return { left: 0, top: 0 };
- }
- if (to.hash) {
- return { el: to.hash, top: _getHashElementScrollMarginTop(to.hash), behavior };
- }
- return false;
- }
- const routeAllowsScrollToTop = typeof to.meta.scrollToTop === "function" ? to.meta.scrollToTop(to, from) : to.meta.scrollToTop;
- if (routeAllowsScrollToTop === false) {
- return false;
- }
- let position = savedPosition || void 0;
- if (!position && isChangingPage(to, from)) {
- position = { left: 0, top: 0 };
- }
- const hookToWait = nuxtApp._runningTransition ? "page:transition:finish" : "page:loading:end";
- return new Promise((resolve) => {
- if (from === START_LOCATION) {
- resolve(_calculatePosition(to, "instant", position));
- return;
- }
- nuxtApp.hooks.hookOnce(hookToWait, () => {
- requestAnimationFrame(() => resolve(_calculatePosition(to, "instant", position)));
- });
- });
- }
- };
- function _getHashElementScrollMarginTop(selector) {
- try {
- const elem = (void 0).querySelector(selector);
- if (elem) {
- return (Number.parseFloat(getComputedStyle(elem).scrollMarginTop) || 0) + (Number.parseFloat(getComputedStyle((void 0).documentElement).scrollPaddingTop) || 0);
- }
- } catch {
- }
- return 0;
- }
- function _calculatePosition(to, scrollBehaviorType, position) {
- if (position) {
- return position;
- }
- if (to.hash) {
- return {
- el: to.hash,
- top: _getHashElementScrollMarginTop(to.hash),
- behavior: scrollBehaviorType
- };
- }
- return { left: 0, top: 0, behavior: scrollBehaviorType };
- }
- const configRouterOptions = {
- hashMode: false,
- scrollBehaviorType: "auto"
- };
- const routerOptions = {
- ...configRouterOptions,
- ...routerOptions0
- };
- const validate = /* @__PURE__ */ defineNuxtRouteMiddleware(async (to, from) => {
- var _a2;
- let __temp, __restore;
- if (!((_a2 = to.meta) == null ? void 0 : _a2.validate)) {
- return;
- }
- const result = ([__temp, __restore] = executeAsync(() => Promise.resolve(to.meta.validate(to))), __temp = await __temp, __restore(), __temp);
- if (result === true) {
- return;
- }
- const error = createError({
- fatal: false,
- statusCode: result && result.statusCode || 404,
- statusMessage: result && result.statusMessage || `Page Not Found: ${to.fullPath}`,
- data: {
- path: to.fullPath
- }
- });
- return error;
- });
- const manifest_45route_45rule = /* @__PURE__ */ defineNuxtRouteMiddleware(async (to) => {
- {
- return;
- }
- });
- const globalMiddleware = [
- validate,
- manifest_45route_45rule
- ];
- const namedMiddleware = {};
- const plugin = /* @__PURE__ */ defineNuxtPlugin({
- name: "nuxt:router",
- enforce: "pre",
- async setup(nuxtApp) {
- var _a2, _b2, _c2;
- let __temp, __restore;
- let routerBase = (/* @__PURE__ */ useRuntimeConfig()).app.baseURL;
- const history = ((_a2 = routerOptions.history) == null ? void 0 : _a2.call(routerOptions, routerBase)) ?? createMemoryHistory(routerBase);
- const routes2 = routerOptions.routes ? ([__temp, __restore] = executeAsync(() => routerOptions.routes(_routes)), __temp = await __temp, __restore(), __temp) ?? _routes : _routes;
- let startPosition;
- const router = createRouter({
- ...routerOptions,
- scrollBehavior: (to, from, savedPosition) => {
- if (from === START_LOCATION) {
- startPosition = savedPosition;
- return;
- }
- if (routerOptions.scrollBehavior) {
- router.options.scrollBehavior = routerOptions.scrollBehavior;
- if ("scrollRestoration" in (void 0).history) {
- const unsub = router.beforeEach(() => {
- unsub();
- (void 0).history.scrollRestoration = "manual";
- });
- }
- return routerOptions.scrollBehavior(to, START_LOCATION, startPosition || savedPosition);
- }
- },
- history,
- routes: routes2
- });
- nuxtApp.vueApp.use(router);
- const previousRoute = shallowRef(router.currentRoute.value);
- router.afterEach((_to, from) => {
- previousRoute.value = from;
- });
- Object.defineProperty(nuxtApp.vueApp.config.globalProperties, "previousRoute", {
- get: () => previousRoute.value
- });
- const initialURL = nuxtApp.ssrContext.url;
- const _route = shallowRef(router.currentRoute.value);
- const syncCurrentRoute = () => {
- _route.value = router.currentRoute.value;
- };
- nuxtApp.hook("page:finish", syncCurrentRoute);
- router.afterEach((to, from) => {
- var _a3, _b3, _c3, _d2;
- if (((_b3 = (_a3 = to.matched[0]) == null ? void 0 : _a3.components) == null ? void 0 : _b3.default) === ((_d2 = (_c3 = from.matched[0]) == null ? void 0 : _c3.components) == null ? void 0 : _d2.default)) {
- syncCurrentRoute();
- }
- });
- const route = {};
- for (const key in _route.value) {
- Object.defineProperty(route, key, {
- get: () => _route.value[key],
- enumerable: true
- });
- }
- nuxtApp._route = shallowReactive(route);
- nuxtApp._middleware || (nuxtApp._middleware = {
- global: [],
- named: {}
- });
- useError();
- if (!((_b2 = nuxtApp.ssrContext) == null ? void 0 : _b2.islandContext)) {
- router.afterEach(async (to, _from, failure) => {
- delete nuxtApp._processingMiddleware;
- if (failure) {
- await nuxtApp.callHook("page:loading:end");
- }
- if ((failure == null ? void 0 : failure.type) === 4) {
- return;
- }
- if (to.redirectedFrom && to.fullPath !== initialURL) {
- await nuxtApp.runWithContext(() => navigateTo(to.fullPath || "/"));
- }
- });
- }
- try {
- if (true) {
- ;
- [__temp, __restore] = executeAsync(() => router.push(initialURL)), await __temp, __restore();
- ;
- }
- ;
- [__temp, __restore] = executeAsync(() => router.isReady()), await __temp, __restore();
- ;
- } catch (error2) {
- [__temp, __restore] = executeAsync(() => nuxtApp.runWithContext(() => showError(error2))), await __temp, __restore();
- }
- const resolvedInitialRoute = router.currentRoute.value;
- syncCurrentRoute();
- if ((_c2 = nuxtApp.ssrContext) == null ? void 0 : _c2.islandContext) {
- return { provide: { router } };
- }
- const initialLayout = nuxtApp.payload.state._layout;
- router.beforeEach(async (to, from) => {
- var _a3, _b3;
- await nuxtApp.callHook("page:loading:start");
- to.meta = reactive(to.meta);
- if (nuxtApp.isHydrating && initialLayout && !isReadonly(to.meta.layout)) {
- to.meta.layout = initialLayout;
- }
- nuxtApp._processingMiddleware = true;
- if (!((_a3 = nuxtApp.ssrContext) == null ? void 0 : _a3.islandContext)) {
- const middlewareEntries = /* @__PURE__ */ new Set([...globalMiddleware, ...nuxtApp._middleware.global]);
- for (const component of to.matched) {
- const componentMiddleware = component.meta.middleware;
- if (!componentMiddleware) {
- continue;
- }
- for (const entry2 of toArray$1(componentMiddleware)) {
- middlewareEntries.add(entry2);
- }
- }
- {
- const routeRules = await nuxtApp.runWithContext(() => getRouteRules({ path: to.path }));
- if (routeRules.appMiddleware) {
- for (const key in routeRules.appMiddleware) {
- if (routeRules.appMiddleware[key]) {
- middlewareEntries.add(key);
- } else {
- middlewareEntries.delete(key);
- }
- }
- }
- }
- for (const entry2 of middlewareEntries) {
- const middleware = typeof entry2 === "string" ? nuxtApp._middleware.named[entry2] || await ((_b3 = namedMiddleware[entry2]) == null ? void 0 : _b3.call(namedMiddleware).then((r2) => r2.default || r2)) : entry2;
- if (!middleware) {
- throw new Error(`Unknown route middleware: '${entry2}'.`);
- }
- try {
- const result = await nuxtApp.runWithContext(() => middleware(to, from));
- if (true) {
- if (result === false || result instanceof Error) {
- const error2 = result || createError({
- statusCode: 404,
- statusMessage: `Page Not Found: ${initialURL}`
- });
- await nuxtApp.runWithContext(() => showError(error2));
- return false;
- }
- }
- if (result === true) {
- continue;
- }
- if (result === false) {
- return result;
- }
- if (result) {
- if (isNuxtError(result) && result.fatal) {
- await nuxtApp.runWithContext(() => showError(result));
- }
- return result;
- }
- } catch (err) {
- const error2 = createError(err);
- if (error2.fatal) {
- await nuxtApp.runWithContext(() => showError(error2));
- }
- return error2;
- }
- }
- }
- });
- router.onError(async () => {
- delete nuxtApp._processingMiddleware;
- await nuxtApp.callHook("page:loading:end");
- });
- router.afterEach(async (to, _from) => {
- if (to.matched.length === 0) {
- await nuxtApp.runWithContext(() => showError(createError({
- statusCode: 404,
- fatal: false,
- statusMessage: `Page not found: ${to.fullPath}`,
- data: {
- path: to.fullPath
- }
- })));
- }
- });
- nuxtApp.hooks.hookOnce("app:created", async () => {
- try {
- if ("name" in resolvedInitialRoute) {
- resolvedInitialRoute.name = void 0;
- }
- await router.replace({
- ...resolvedInitialRoute,
- force: true
- });
- router.options.scrollBehavior = routerOptions.scrollBehavior;
- } catch (error2) {
- await nuxtApp.runWithContext(() => showError(error2));
- }
- });
- return { provide: { router } };
- }
- });
- function definePayloadReducer(name, reduce) {
- {
- useNuxtApp().ssrContext._payloadReducers[name] = reduce;
- }
- }
- const reducers = [
- ["NuxtError", (data) => isNuxtError(data) && data.toJSON()],
- ["EmptyShallowRef", (data) => isRef(data) && isShallow(data) && !data.value && (typeof data.value === "bigint" ? "0n" : JSON.stringify(data.value) || "_")],
- ["EmptyRef", (data) => isRef(data) && !data.value && (typeof data.value === "bigint" ? "0n" : JSON.stringify(data.value) || "_")],
- ["ShallowRef", (data) => isRef(data) && isShallow(data) && data.value],
- ["ShallowReactive", (data) => isReactive(data) && isShallow(data) && toRaw(data)],
- ["Ref", (data) => isRef(data) && data.value],
- ["Reactive", (data) => isReactive(data) && toRaw(data)]
- ];
- const revive_payload_server_cOgQ3s4LyKn2YZ80ucX0OsNM3PTOSwPOL2UA48dmxm0 = /* @__PURE__ */ defineNuxtPlugin({
- name: "nuxt:revive-payload:server",
- setup() {
- for (const [reducer, fn] of reducers) {
- definePayloadReducer(reducer, fn);
- }
- }
- });
- const components_plugin_z4hgvsiddfKkfXTP6M8M4zG5Cb7sGnDhcryKVM45Di4 = /* @__PURE__ */ defineNuxtPlugin({
- name: "nuxt:global-components"
- });
- function toArray(value) {
- return Array.isArray(value) ? value : [value];
- }
- function useRequestEvent(nuxtApp) {
- var _a2;
- nuxtApp || (nuxtApp = useNuxtApp());
- return (_a2 = nuxtApp.ssrContext) == null ? void 0 : _a2.event;
- }
- function prerenderRoutes(path) {
- const paths = toArray(path);
- appendHeader(useRequestEvent(), "x-nitro-prerender", paths.map((p) => encodeURIComponent(p)).join(", "));
- }
- let routes;
- const prerender_server_cKsUmC_SYa3MXwAfdS__3ZJssblZZqdZAiVNsGcVEcY = /* @__PURE__ */ defineNuxtPlugin(async () => {
- let __temp, __restore;
- if (routes && !routes.length) {
- return;
- }
- (/* @__PURE__ */ useRuntimeConfig()).nitro.routeRules;
- routes || (routes = Array.from(processRoutes(([__temp, __restore] = executeAsync(() => {
- var _a2;
- return (_a2 = routerOptions.routes) == null ? void 0 : _a2.call(routerOptions, _routes);
- }), __temp = await __temp, __restore(), __temp) ?? _routes)));
- const batch = routes.splice(0, 10);
- prerenderRoutes(batch);
- });
- const OPTIONAL_PARAM_RE = /^\/?:.*(?:\?|\(\.\*\)\*)$/;
- function shouldPrerender(path) {
- return true;
- }
- function processRoutes(routes2, currentPath = "/", routesToPrerender = /* @__PURE__ */ new Set()) {
- var _a2;
- for (const route of routes2) {
- if (OPTIONAL_PARAM_RE.test(route.path) && !((_a2 = route.children) == null ? void 0 : _a2.length) && shouldPrerender()) {
- routesToPrerender.add(currentPath);
- }
- if (route.path.includes(":")) {
- continue;
- }
- const fullPath = joinURL(currentPath, route.path);
- {
- routesToPrerender.add(fullPath);
- }
- if (route.children) {
- processRoutes(route.children, fullPath, routesToPrerender);
- }
- }
- return routesToPrerender;
- }
- const plugins = [
- unhead_v5ac8_aYQVlP6KGZHvlpq6x2XWXwze6_1FIL8VEzXsY,
- plugin,
- revive_payload_server_cOgQ3s4LyKn2YZ80ucX0OsNM3PTOSwPOL2UA48dmxm0,
- components_plugin_z4hgvsiddfKkfXTP6M8M4zG5Cb7sGnDhcryKVM45Di4,
- prerender_server_cKsUmC_SYa3MXwAfdS__3ZJssblZZqdZAiVNsGcVEcY
- ];
- const __nuxt_component_0 = defineComponent({
- name: "ServerPlaceholder",
- render() {
- return createElementBlock("div");
- }
- });
- const defineRouteProvider = (name = "RouteProvider") => defineComponent({
- name,
- props: {
- vnode: {
- type: Object,
- required: true
- },
- route: {
- type: Object,
- required: true
- },
- vnodeRef: Object,
- renderKey: String,
- trackRootNodes: Boolean
- },
- setup(props) {
- const previousKey = props.renderKey;
- const previousRoute = props.route;
- const route = {};
- for (const key in props.route) {
- Object.defineProperty(route, key, {
- get: () => previousKey === props.renderKey ? props.route[key] : previousRoute[key],
- enumerable: true
- });
- }
- provide(PageRouteSymbol, shallowReactive(route));
- return () => {
- return h(props.vnode, { ref: props.vnodeRef });
- };
- }
- });
- const RouteProvider = defineRouteProvider();
- const __nuxt_component_1 = defineComponent({
- name: "NuxtPage",
- inheritAttrs: false,
- props: {
- name: {
- type: String
- },
- transition: {
- type: [Boolean, Object],
- default: void 0
- },
- keepalive: {
- type: [Boolean, Object],
- default: void 0
- },
- route: {
- type: Object
- },
- pageKey: {
- type: [Function, String],
- default: null
- }
- },
- setup(props, { attrs, slots, expose }) {
- const nuxtApp = useNuxtApp();
- const pageRef = ref();
- inject(PageRouteSymbol, null);
- expose({ pageRef });
- inject(LayoutMetaSymbol, null);
- nuxtApp.deferHydration();
- return () => {
- return h(RouterView, { name: props.name, route: props.route, ...attrs }, {
- default: (routeProps) => {
- return h(Suspense, { suspensible: true }, {
- default() {
- return h(RouteProvider, {
- vnode: slots.default ? normalizeSlot(slots.default, routeProps) : routeProps.Component,
- route: routeProps.route,
- vnodeRef: pageRef
- });
- }
- });
- }
- });
- };
- }
- });
- function normalizeSlot(slot, data) {
- const slotContent = slot(data);
- return slotContent.length === 1 ? h(slotContent[0]) : h(Fragment, void 0, slotContent);
- }
- const _imports_0 = "" + __buildAssetsURL("ccdw_logo_2025.5.DSzOQ1td.png");
- const _export_sfc = (sfc, props) => {
- const target = sfc.__vccOpts || sfc;
- for (const [key, val] of props) {
- target[key] = val;
- }
- return target;
- };
- const _sfc_main$2 = {};
- function _sfc_ssrRender(_ctx, _push, _parent, _attrs) {
- const _component_NuxtRouteAnnouncer = __nuxt_component_0;
- const _component_NuxtPage = __nuxt_component_1;
- _push(`<div${ssrRenderAttrs(_attrs)}>`);
- _push(ssrRenderComponent(_component_NuxtRouteAnnouncer, null, null, _parent));
- _push(`<header class="site-header"><img${ssrRenderAttr("src", _imports_0)} alt="CCDW Logo" class="logo"><h1>CCDW = 纯粹的玩</h1></header><main class="site-main">`);
- _push(ssrRenderComponent(_component_NuxtPage, null, null, _parent));
- _push(`</main><footer class="site-footer"><p>© ${ssrInterpolate((/* @__PURE__ */ new Date()).getFullYear())} CCDW (纯粹的玩). 不保留所有权利.</p><p>杭州纯粹的玩品牌科技有限公司 坐落于 浙江省杭州市西湖区转塘街道云腾丝路中心5号楼商业208室</p></footer></div>`);
- }
- const _sfc_setup$2 = _sfc_main$2.setup;
- _sfc_main$2.setup = (props, ctx) => {
- const ssrContext = useSSRContext();
- (ssrContext.modules || (ssrContext.modules = /* @__PURE__ */ new Set())).add("app.vue");
- return _sfc_setup$2 ? _sfc_setup$2(props, ctx) : void 0;
- };
- const AppComponent = /* @__PURE__ */ _export_sfc(_sfc_main$2, [["ssrRender", _sfc_ssrRender]]);
- const _sfc_main$1 = {
- __name: "nuxt-error-page",
- __ssrInlineRender: true,
- props: {
- error: Object
- },
- setup(__props) {
- const props = __props;
- const _error = props.error;
- _error.stack ? _error.stack.split("\n").splice(1).map((line) => {
- const text = line.replace("webpack:/", "").replace(".vue", ".js").trim();
- return {
- text,
- internal: line.includes("node_modules") && !line.includes(".cache") || line.includes("internal") || line.includes("new Promise")
- };
- }).map((i) => `<span class="stack${i.internal ? " internal" : ""}">${i.text}</span>`).join("\n") : "";
- const statusCode = Number(_error.statusCode || 500);
- const is404 = statusCode === 404;
- const statusMessage = _error.statusMessage ?? (is404 ? "Page Not Found" : "Internal Server Error");
- const description = _error.message || _error.toString();
- const stack = void 0;
- const _Error404 = defineAsyncComponent(() => import('./error-404-BRnVQQNb.mjs'));
- const _Error = defineAsyncComponent(() => import('./error-500-CNX-wKnS.mjs'));
- const ErrorTemplate = is404 ? _Error404 : _Error;
- return (_ctx, _push, _parent, _attrs) => {
- _push(ssrRenderComponent(unref(ErrorTemplate), mergeProps({ statusCode: unref(statusCode), statusMessage: unref(statusMessage), description: unref(description), stack: unref(stack) }, _attrs), null, _parent));
- };
- }
- };
- const _sfc_setup$1 = _sfc_main$1.setup;
- _sfc_main$1.setup = (props, ctx) => {
- const ssrContext = useSSRContext();
- (ssrContext.modules || (ssrContext.modules = /* @__PURE__ */ new Set())).add("node_modules/.pnpm/nuxt@3.17.4_@parcel+watcher@2.5.1_@types+node@22.15.21_db0@0.3.2_ioredis@5.6.1_magicast_e2b60321bafda6f7a9390f7ac7478d38/node_modules/nuxt/dist/app/components/nuxt-error-page.vue");
- return _sfc_setup$1 ? _sfc_setup$1(props, ctx) : void 0;
- };
- const _sfc_main = {
- __name: "nuxt-root",
- __ssrInlineRender: true,
- setup(__props) {
- const IslandRenderer = () => null;
- const nuxtApp = useNuxtApp();
- nuxtApp.deferHydration();
- nuxtApp.ssrContext.url;
- const SingleRenderer = false;
- provide(PageRouteSymbol, useRoute());
- nuxtApp.hooks.callHookWith((hooks) => hooks.map((hook) => hook()), "vue:setup");
- const error = useError();
- const abortRender = error.value && !nuxtApp.ssrContext.error;
- onErrorCaptured((err, target, info) => {
- nuxtApp.hooks.callHook("vue:error", err, target, info).catch((hookError) => console.error("[nuxt] Error in `vue:error` hook", hookError));
- {
- const p = nuxtApp.runWithContext(() => showError(err));
- onServerPrefetch(() => p);
- return false;
- }
- });
- const islandContext = nuxtApp.ssrContext.islandContext;
- return (_ctx, _push, _parent, _attrs) => {
- ssrRenderSuspense(_push, {
- default: () => {
- if (unref(abortRender)) {
- _push(`<div></div>`);
- } else if (unref(error)) {
- _push(ssrRenderComponent(unref(_sfc_main$1), { error: unref(error) }, null, _parent));
- } else if (unref(islandContext)) {
- _push(ssrRenderComponent(unref(IslandRenderer), { context: unref(islandContext) }, null, _parent));
- } else if (unref(SingleRenderer)) {
- ssrRenderVNode(_push, createVNode(resolveDynamicComponent(unref(SingleRenderer)), null, null), _parent);
- } else {
- _push(ssrRenderComponent(unref(AppComponent), null, null, _parent));
- }
- },
- _: 1
- });
- };
- }
- };
- const _sfc_setup = _sfc_main.setup;
- _sfc_main.setup = (props, ctx) => {
- const ssrContext = useSSRContext();
- (ssrContext.modules || (ssrContext.modules = /* @__PURE__ */ new Set())).add("node_modules/.pnpm/nuxt@3.17.4_@parcel+watcher@2.5.1_@types+node@22.15.21_db0@0.3.2_ioredis@5.6.1_magicast_e2b60321bafda6f7a9390f7ac7478d38/node_modules/nuxt/dist/app/components/nuxt-root.vue");
- return _sfc_setup ? _sfc_setup(props, ctx) : void 0;
- };
- let entry;
- {
- entry = async function createNuxtAppServer(ssrContext) {
- var _a2;
- const vueApp = createApp(_sfc_main);
- const nuxt = createNuxtApp({ vueApp, ssrContext });
- try {
- await applyPlugins(nuxt, plugins);
- await nuxt.hooks.callHook("app:created", vueApp);
- } catch (error) {
- await nuxt.hooks.callHook("app:error", error);
- (_a2 = nuxt.payload).error || (_a2.error = createError(error));
- }
- if (ssrContext == null ? void 0 : ssrContext._renderResponse) {
- throw new Error("skipping render");
- }
- return vueApp;
- };
- }
- const entry$1 = (ssrContext) => entry(ssrContext);
- export { Yr as Y, Zt as Z, _export_sfc as _, useNuxtApp as a, useRuntimeConfig as b, nuxtLinkDefaults as c, entry$1 as default, navigateTo as n, resolveRouteObject as r, tryUseNuxtApp as t, useRouter as u };
- //# sourceMappingURL=server.mjs.map
|