| 337 | ***************************************************************************** */var UJq,QJq,dJq,cJq,lJq,nJq,iJq,rJq,oJq,ZM8,PP1,aJq,sJq,c06,tJq,eJq,qMq,KMq,_Mq,zMq,YMq,$Mq,AMq;(function(q){var K=typeof global==="object"?global:typeof self==="object"?self:typeof this==="object"?this:{};if(typeof define==="function"&&define.amd)define("tslib",["exports"],function(z){q(_(K,_(z)))});else if(typeof GM8==="object"&&typeof si$==="object")q(_(K,_(si$)));else q(_(K));function _(z,Y){if(z!==K)if(typeof Object.create==="function")Object.defineProperty(z,"__esModule",{value:!0});else z.__esModule=!0;return function($,A){return z[$]=Y?Y($,A):A}}})(function(q){var K=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(_,z){_.__proto__=z}||function(_,z){for(var Y in z)if(z.hasOwnProperty(Y))_[Y]=z[Y]};UJq=function(_,z){K(_,z);function Y(){this.constructor=_}_.prototype=z===null?Object.create(z):(Y.prototype=z.prototype,new Y)},QJq=Object.assign||function(_){for(var z,Y=1,$=arguments.length;Y<$;Y++){z=arguments[Y];for(var A in z)if(Object.prototype.hasOwnProperty.call(z,A))_[A]=z[A]}return _},dJq=function(_,z){var Y={};for(var $ in _)if(Object.prototype.hasOwnProperty.call(_,$)&&z.indexOf($)<0)Y[$]=_[$];if(_!=null&&typeof Object.getOwnPropertySymbols==="function"){for(var A=0,$=Object.getOwnPropertySymbols(_);A<$.length;A++)if(z.indexOf($[A])<0&&Object.prototype.propertyIsEnumerable.call(_,$[A]))Y[$[A]]=_[$[A]]}return Y},cJq=function(_,z,Y,$){var A=arguments.length,O=A<3?z:$===null?$=Object.getOwnPropertyDescriptor(z,Y):$,w;if(typeof Reflect==="object"&&typeof Reflect.decorate==="function")O=Reflect.decorate(_,z,Y,$);else for(var j=_.length-1;j>=0;j--)if(w=_[j])O=(A<3?w(O):A>3?w(z,Y,O):w(z,Y))||O;return A>3&&O&&Object.defineProperty(z,Y,O),O},lJq=function(_,z){return function(Y,$){z(Y,$,_)}},nJq=function(_,z){if(typeof Reflect==="object"&&typeof Reflect.metadata==="function")return Reflect.metadata(_,z)},iJq=function(_,z,Y,$){function A(O){return O instanceof Y?O:new Y(function(w){w(O)})}return new(Y||(Y=Promise))(function(O,w){function j(M){try{J($.next(M))}catch(X){w(X)}}function H(M){try{J($.throw(M))}catch(X){w(X)}}function J(M){M.done?O(M.value):A(M.value).then(j,H)}J(($=$.apply(_,z||[])).next())})},rJq=function(_,z){var Y={label:0,sent:function(){if(O[0]&1)throw O[1];return O[1]},trys:[],ops:[]},$,A,O,w;return w={next:j(0),throw:j(1),return:j(2)},typeof Symbol==="function"&&(w[Symbol.iterator]=function(){return this}),w;function j(J){return function(M){return H([J,M])}}function H(J){if($)throw TypeError("Generator is already executing.");while(Y)try{if($=1,A&&(O=J[0]&2?A.return:J[0]?A.throw||((O=A.return)&&O.call(A),0):A.next)&&!(O=O.call(A,J[1])).done)return O;if(A=0,O)J=[J[0]&2,O.value];switch(J[0]){case 0:case 1:O=J;break;case 4:return Y.label++,{value:J[1],done:!1};case 5:Y.label++,A=J[1],J=[0];continue;case 7:J=Y.ops.pop(),Y.trys.pop();continue;default:if((O=Y.trys,!(O=O.length>0&&O[O.length-1]))&&(J[0]===6||J[0]===2)){Y=0;continue}if(J[0]===3&&(!O||J[1]>O[0]&&J[1]<O[3])){Y.label=J[1];break}if(J[0]===6&&Y.label<O[1]){Y.label=O[1],O=J;break}if(O&&Y.label<O[2]){Y.label=O[2],Y.ops.push(J);break}if(O[2])Y.ops.pop();Y.trys.pop();continue}J=z.call(_,Y)}catch(M){J=[6,M],A=0}finally{$=O=0}if(J[0]&5)throw J[1];return{value:J[0]?J[1]:void 0,done:!0}}},AMq=function(_,z,Y,$){if($===void 0)$=Y;_[$]=z[Y]},oJq=function(_,z){for(var Y in _)if(Y!=="default"&&!z.hasOwnProperty(Y))z[Y]=_[Y]},ZM8=function(_){var z=typeof Symbol==="function"&&Symbol.iterator,Y=z&&_[z],$=0;if(Y)return Y.call(_);if(_&&typeof _.length==="number")return{next:function(){if(_&&$>=_.length)_=void 0;return{value:_&&_[$++],done:!_}}};throw TypeError(z?"Object is not iterable.":"Symbol.iterator is not defined.")},PP1=function(_,z){var Y=typeof Symbol==="function"&&_[Symbol.iterator];if(!Y)return _;var $=Y.call(_),A,O=[],w;try{while((z===void 0||z-- >0)&&!(A=$.next()).done)O.push(A.value)}catch(j){w={error:j}}finally{try{if(A&&!A.done&&(Y=$.return))Y.call($)}finally{if(w)throw w.error}}return O},aJq=function(){for(var _=[],z=0;z<arguments.length;z++)_=_.concat(PP1(arguments[z]));return _},sJq=function(){for(var _=0,z=0,Y=arguments.length;z<Y;z++)_+=arguments[z].length;for(var $=Array(_),A=0,z=0;z<Y;z++)for(var O=arguments[z],w=0,j=O.length;w<j;w++,A++)$[A]=O[w];return $},c06=function(_){return this instanceof c06?(this.v=_,this):new c06(_)},tJq=function(_,z,Y){if(!Symbol.asyncIterator)throw TypeError("Symbol.asyncIterator is not defined.");var $=Y.apply(_,z||[]),A,O=[];return A={},w("next"),w("throw"),w("return"),A[Symbol.asyncIterator]=function(){return this},A;function w(P){if($[P])A[P]=function(W){return new Promise(function(D,f){O.push([P,W,D,f])>1||j(P,W)})}}function j(P,W){try{H($[P](W))}catch(D){X(O[0][3],D)}}function H(P){P.value instanceof c06?Promise.resolve(P.value.v).then(J,M):X(O[0][2],P)}function J(P){j("next",P)}function M(P){j("throw",P)}function X(P,W){if(P(W),O.shift(),O.length)j(O[0][0],O[0][1])}},eJq=function(_){var z,Y;return z={},$("next"),$("throw",function(A){throw A}),$("return"),z[Symbol.iterator]=function(){return this},z;function $(A,O){z[A]=_[A]?function(w){return(Y=!Y)?{value:c06(_[A](w)),done:A==="return"}:O?O(w):w}:O}},qMq=function(_){if(!Symbol.asyncIterator)throw TypeError("Symbol.asyncIterator is not defined.");var z=_[Symbol.asyncIterator],Y;return z?z.call(_):(_=typeof ZM8==="function"?ZM8(_):_[Symbol.iterator](),Y={},$("next"),$("throw"),$("return"),Y[Symbol.asyncIterator]=function(){return this},Y);function $(O){Y[O]=_[O]&&function(w){return new Promise(function(j,H){w=_[O](w),A(j,H,w.done,w.value)})}}function A(O,w,j,H){Promise.resolve(H).then(function(J){O({value:J,done:j})},w)}},KMq=function(_,z){if(Object.defineProperty)Object.defineProperty(_,"raw",{value:z});else _.raw=z;return _},_Mq=function(_){if(_&&_.__esModule)return _;var z={};if(_!=null){for(var Y in _)if(Object.hasOwnProperty.call(_,Y))z[Y]=_[Y]}return z.default=_,z},zMq=function(_){return _&&_.__esModule?_:{default:_}},YMq=function(_,z){if(!z.has(_))throw TypeError("attempted to get private field on non-instance");return z.get(_)},$Mq=function(_,z,Y){if(!z.has(_))throw TypeError("attempted to set private field on non-instance");return z.set(_,Y),Y},q("__extends",UJq),q("__assign",QJq),q("__rest",dJq),q("__decorate",cJq),q("__param",lJq),q("__metadata",nJq),q("__awaiter",iJq),q("__generator",rJq),q("__exportStar",oJq),q("__createBinding",AMq),q("__values",ZM8),q("__read",PP1),q("__spread",aJq),q("__spreadArrays",sJq),q("__await",c06),q("__asyncGenerator",tJq),q("__asyncDelegator",eJq),q("__asyncValues",qMq),q("__makeTemplateObject",KMq),q("__importStar",_Mq),q("__importDefault",zMq),q("__classPrivateFieldGet",YMq),q("__classPrivateFieldSet",$Mq)})});var jMq=m((OMq)=>{Object.defineProperty(OMq,"__esModule",{value:!0});OMq.convertToBuffer=void 0;var NE9=cX1(),yE9=typeof Buffer<"u"&&Buffer.from?function(q){return Buffer.from(q,"utf8")}:NE9.fromUtf8;function EE9(q){if(q instanceof Uint8Array)return q;if(typeof q==="string")return yE9(q);if(ArrayBuffer.isView(q))return new Uint8Array(q.buffer,q.byteOffset,q.byteLength/Uint8Array.BYTES_PER_ELEMENT);return new Uint8Array(q)}OMq.convertToBuffer=EE9});var MMq=m((HMq)=>{Object.defineProperty(HMq,"__esModule",{value:!0});HMq.isEmptyData=void 0;function LE9(q){if(typeof q==="string")return q.length===0;return q.byteLength===0}HMq.isEmptyData=LE9});var WMq=m((XMq)=>{Object.defineProperty(XMq,"__esModule",{value:!0});XMq.numToUint8=void 0;function RE9(q){return new Uint8Array([(q&4278190080)>>24,(q&16711680)>>16,(q&65280)>>8,q&255])}XMq.numToUint8=RE9});var ZMq=m((DMq)=>{Object.defineProperty(DMq,"__esModule",{value:!0});DMq.uint32ArrayFrom=void 0;function hE9(q){if(!Uint32Array.from){var K=new Uint32Array(q.length),_=0;while(_<q.length)K[_]=q[_],_+=1;return K}return Uint32Array.from(q)}DMq.uint32ArrayFrom=hE9});var DP1=m((l06)=>{Object.defineProperty(l06,"__esModule",{value:!0});l06.uint32ArrayFrom=l06.numToUint8=l06.isEmptyData=l06.convertToBuffer=void 0;var SE9=jMq();Object.defineProperty(l06,"convertToBuffer",{enumerable:!0,get:function(){return SE9.convertToBuffer}});var CE9=MMq();Object.defineProperty(l06,"isEmptyData",{enumerable:!0,get:function(){return CE9.isEmptyData}});var bE9=WMq();Object.defineProperty(l06,"numToUint8",{enumerable:!0,get:function(){return bE9.numToUint8}});var xE9=ZMq();Object.defineProperty(l06,"uint32ArrayFrom",{enumerable:!0,get:function(){return xE9.uint32ArrayFrom}})});var VMq=m((vMq)=>{Object.defineProperty(vMq,"__esModule",{value:!0});vMq.AwsCrc32=void 0;var GMq=WP1(),fP1=DP1(),TMq=TM8(),uE9=function(){function q(){this.crc32=new TMq.Crc32}return q.prototype.update=function(K){if((0,fP1.isEmptyData)(K))return;this.crc32.update((0,fP1.convertToBuffer)(K))},q.prototype.digest=function(){return GMq.__awaiter(this,void 0,void 0,function(){return GMq.__generator(this,function(K){return[2,(0,fP1.numToUint8)(this.crc32.digest())]})})},q.prototype.reset=function(){this.crc32=new TMq.Crc32},q}();vMq.AwsCrc32=uE9});var TM8=m((ZP1)=>{Object.defineProperty(ZP1,"__esModule",{value:!0});ZP1.AwsCrc32=ZP1.Crc32=ZP1.crc32=void 0;var mE9=WP1(),pE9=DP1();function BE9(q){return new NMq().update(q).digest()}ZP1.crc32=BE9;var NMq=function(){function q(){this.checksum=4294967295}return q.prototype.update=function(K){var _,z;try{for(var Y=mE9.__values(K),$=Y.next();!$.done;$=Y.next()){var A=$.value;this.checksum=this.checksum>>>8^FE9[(this.checksum^A)&255]}}catch(O){_={error:O}}finally{try{if($&&!$.done&&(z=Y.return))z.call(Y)}finally{if(_)throw _.error}}return this},q.prototype.digest=function(){return(this.checksum^4294967295)>>>0},q}();ZP1.Crc32=NMq;var gE9=[0,1996959894,3993919788,2567524794,124634137,1886057615,3915621685,2657392035,249268274,2044508324,3772115230,2547177864,162941995,2125561021,3887607047,2428444049,498536548,1789927666,4089016648,2227061214,450548861,1843258603,4107580753,2211677639,325883990,1684777152,4251122042,2321926636,335633487,1661365465,4195302755,2366115317,997073096,1281953886,3579855332,2724688242,1006888145,1258607687,3524101629,2768942443,901097722,1119000684,3686517206,2898065728,853044451,1172266101,3705015759,2882616665,651767980,1373503546,3369554304,3218104598,565507253,1454621731,3485111705,3099436303,671266974,1594198024,3322730930,2970347812,795835527,1483230225,3244367275,3060149565,1994146192,31158534,2563907772,4023717930,1907459465,112637215,2680153253,3904427059,2013776290,251722036,2517215374,3775830040,2137656763,141376813,2439277719,3865271297,1802195444,476864866,2238001368,4066508878,1812370925,453092731,2181625025,4111451223,1706088902,314042704,2344532202,4240017532,1658658271,366619977,2362670323,4224994405,1303535960,984961486,2747007092,3569037538,1256170817,1037604311,2765210733,3554079995,1131014506,879679996,2909243462,3663771856,1141124467,855842277,2852801631,3708648649,1342533948,654459306,3188396048,3373015174,1466479909,544179635,3110523913,3462522015,1591671054,702138776,2966460450,3352799412,1504918807,783551873,3082640443,3233442989,3988292384,2596254646,62317068,1957810842,3939845945,2647816111,81470997,1943803523,3814918930,2489596804,225274430,2053790376,3826175755,2466906013,167816743,2097651377,4027552580,2265490386,503444072,1762050814,4150417245,2154129355,426522225,1852507879,4275313526,2312317920,282753626,1742555852,4189708143,2394877945,397917763,1622183637,3604390888,2714866558,953729732,1340076626,3518719985,2797360999,1068828381,1219638859,3624741850,2936675148,906185462,1090812512,3747672003,2825379669,829329135,1181335161,3412177804,3160834842,628085408,1382605366,3423369109,3138078467,570562233,1426400815,3317316542,2998733608,733239954,1555261956,3268935591,3050360625,752459403,1541320221,2607071920,3965973030,1969922972,40735498,2617837225,3943577151,1913087877,83908371,2512341634,3803740692,2075208622,213261112,2463272603,3855990285,2094854071,198958881,2262029012,4057260610,1759359992,534414190,2176718541,4139329115,1873836001,414664567,2282248934,4279200368,1711684554,285281116,2405801727,4167216745,1634467795,376229701,2685067896,3608007406,1308918612,956543938,2808555105,3495958263,1231636301,1047427035,2932959818,3654703836,1088359270,936918000,2847714899,3736837829,1202900863,817233897,3183342108,3401237130,1404277552,615818150,3134207493,3453421203,1423857449,601450431,3009837614,3294710456,1567103746,711928724,3020668471,3272380065,1510334235,755167117],FE9=(0,pE9.uint32ArrayFrom)(gE9),UE9=VMq();Object.defineProperty(ZP1,"AwsCrc32",{enumerable:!0,get:function(){return UE9.AwsCrc32}})});var CMq=m((wr$,SMq)=>{var{defineProperty:vM8,getOwnPropertyDescriptor:lE9,getOwnPropertyNames:nE9}=Object,iE9=Object.prototype.hasOwnProperty,yMq=(q,K)=>vM8(q,"name",{value:K,configurable:!0}),rE9=(q,K)=>{for(var _ in K)vM8(q,_,{get:K[_],enumerable:!0})},oE9=(q,K,_,z)=>{if(K&&typeof K==="object"||typeof K==="function"){for(let Y of nE9(K))if(!iE9.call(q,Y)&&Y!==_)vM8(q,Y,{get:()=>K[Y],enumerable:!(z=lE9(K,Y))||z.enumerable})}return q},aE9=(q)=>oE9(vM8({},"__esModule",{value:!0}),q),EMq={};rE9(EMq,{fromHex:()=>RMq,toHex:()=>hMq});SMq.exports=aE9(EMq);var LMq={},GP1={};for(let q=0;q<256;q++){let K=q.toString(16).toLowerCase();if(K.length===1)K=`0${K}`;LMq[q]=K,GP1[K]=q}function RMq(q){if(q.length%2!==0)throw Error("Hex encoded strings must have an even number length");let K=new Uint8Array(q.length/2);for(let _=0;_<q.length;_+=2){let z=q.slice(_,_+2).toLowerCase();if(z in GP1)K[_/2]=GP1[z];else throw Error(`Cannot decode unrecognized sequence ${z} as hexadecimal`)}return K}yMq(RMq,"fromHex");function hMq(q){let K="";for(let _=0;_<q.byteLength;_++)K+=LMq[q[_]];return K}yMq(hMq,"toHex")});var lMq=m((jr$,cMq)=>{var{defineProperty:VM8,getOwnPropertyDescriptor:sE9,getOwnPropertyNames:tE9}=Object,eE9=Object.prototype.hasOwnProperty,Xn=(q,K)=>VM8(q,"name",{value:K,configurable:!0}),qL9=(q,K)=>{for(var _ in K)VM8(q,_,{get:K[_],enumerable:!0})},KL9=(q,K,_,z)=>{if(K&&typeof K==="object"||typeof K==="function"){for(let Y of tE9(K))if(!eE9.call(q,Y)&&Y!==_)VM8(q,Y,{get:()=>K[Y],enumerable:!(z=sE9(K,Y))||z.enumerable})}return q},_L9=(q)=>KL9(VM8({},"__esModule",{value:!0}),q),xMq={};qL9(xMq,{EventStreamCodec:()=>WL9,HeaderMarshaller:()=>mMq,Int64:()=>kM8,MessageDecoderStream:()=>DL9,MessageEncoderStream:()=>fL9,SmithyMessageDecoderStream:()=>ZL9,SmithyMessageEncoderStream:()=>GL9});cMq.exports=_L9(xMq);var zL9=TM8(),Qz6=CMq(),IMq=class q{constructor(K){if(this.bytes=K,K.byteLength!==8)throw Error("Int64 buffers must be exactly 8 bytes")}static fromNumber(K){if(K>9223372036854776000||K<-9223372036854776000)throw Error(`${K} is too large (or, if negative, too small) to represent as an Int64`);let _=new Uint8Array(8);for(let z=7,Y=Math.abs(Math.round(K));z>-1&&Y>0;z--,Y/=256)_[z]=Y;if(K<0)TP1(_);return new q(_)}valueOf(){let K=this.bytes.slice(0),_=K[0]&128;if(_)TP1(K);return parseInt((0,Qz6.toHex)(K),16)*(_?-1:1)}toString(){return String(this.valueOf())}};Xn(IMq,"Int64");var kM8=IMq;function TP1(q){for(let K=0;K<8;K++)q[K]^=255;for(let K=7;K>-1;K--)if(q[K]++,q[K]!==0)break}Xn(TP1,"negate");var uMq=class{constructor(K,_){this.toUtf8=K,this.fromUtf8=_}format(K){let _=[];for(let $ of Object.keys(K)){let A=this.fromUtf8($);_.push(Uint8Array.from([A.byteLength]),A,this.formatHeaderValue(K[$]))}let z=new Uint8Array(_.reduce(($,A)=>$+A.byteLength,0)),Y=0;for(let $ of _)z.set($,Y),Y+=$.byteLength;return z}formatHeaderValue(K){switch(K.type){case"boolean":return Uint8Array.from([K.value?0:1]);case"byte":return Uint8Array.from([2,K.value]);case"short":let _=new DataView(new ArrayBuffer(3));return _.setUint8(0,3),_.setInt16(1,K.value,!1),new Uint8Array(_.buffer);case"integer":let z=new DataView(new ArrayBuffer(5));return z.setUint8(0,4),z.setInt32(1,K.value,!1),new Uint8Array(z.buffer);case"long":let Y=new Uint8Array(9);return Y[0]=5,Y.set(K.value.bytes,1),Y;case"binary":let $=new DataView(new ArrayBuffer(3+K.value.byteLength));$.setUint8(0,6),$.setUint16(1,K.value.byteLength,!1);let A=new Uint8Array($.buffer);return A.set(K.value,3),A;case"string":let O=this.fromUtf8(K.value),w=new DataView(new ArrayBuffer(3+O.byteLength));w.setUint8(0,7),w.setUint16(1,O.byteLength,!1);let j=new Uint8Array(w.buffer);return j.set(O,3),j;case"timestamp":let H=new Uint8Array(9);return H[0]=8,H.set(kM8.fromNumber(K.value.valueOf()).bytes,1),H;case"uuid":if(!ML9.test(K.value))throw Error(`Invalid UUID received: ${K.value}`);let J=new Uint8Array(17);return J[0]=9,J.set((0,Qz6.fromHex)(K.value.replace(/\-/g,"")),1),J}}parse(K){let _={},z=0;while(z<K.byteLength){let Y=K.getUint8(z++),$=this.toUtf8(new Uint8Array(K.buffer,K.byteOffset+z,Y));switch(z+=Y,K.getUint8(z++)){case 0:_[$]={type:bMq,value:!0};break;case 1:_[$]={type:bMq,value:!1};break;case 2:_[$]={type:YL9,value:K.getInt8(z++)};break;case 3:_[$]={type:$L9,value:K.getInt16(z,!1)},z+=2;break;case 4:_[$]={type:AL9,value:K.getInt32(z,!1)},z+=4;break;case 5:_[$]={type:OL9,value:new kM8(new Uint8Array(K.buffer,K.byteOffset+z,8))},z+=8;break;case 6:let A=K.getUint16(z,!1);z+=2,_[$]={type:wL9,value:new Uint8Array(K.buffer,K.byteOffset+z,A)},z+=A;break;case 7:let O=K.getUint16(z,!1);z+=2,_[$]={type:jL9,value:this.toUtf8(new Uint8Array(K.buffer,K.byteOffset+z,O))},z+=O;break;case 8:_[$]={type:HL9,value:new Date(new kM8(new Uint8Array(K.buffer,K.byteOffset+z,8)).valueOf())},z+=8;break;case 9:let w=new Uint8Array(K.buffer,K.byteOffset+z,16);z+=16,_[$]={type:JL9,value:`${(0,Qz6.toHex)(w.subarray(0,4))}-${(0,Qz6.toHex)(w.subarray(4,6))}-${(0,Qz6.toHex)(w.subarray(6,8))}-${(0,Qz6.toHex)(w.subarray(8,10))}-${(0,Qz6.toHex)(w.subarray(10))}`};break;default:throw Error("Unrecognized header type tag")}}return _}};Xn(uMq,"HeaderMarshaller");var mMq=uMq,bMq="boolean",YL9="byte",$L9="short",AL9="integer",OL9="long",wL9="binary",jL9="string",HL9="timestamp",JL9="uuid",ML9=/^[a-f0-9]{8}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{12}$/,XL9=TM8(),pMq=4,A86=pMq*2,dz6=4,PL9=A86+dz6*2;function BMq({byteLength:q,byteOffset:K,buffer:_}){if(q<PL9)throw Error("Provided message too short to accommodate event stream message overhead");let z=new DataView(_,K,q),Y=z.getUint32(0,!1);if(q!==Y)throw Error("Reported message length does not match received message length");let $=z.getUint32(pMq,!1),A=z.getUint32(A86,!1),O=z.getUint32(q-dz6,!1),w=new XL9.Crc32().update(new Uint8Array(_,K,A86));if(A!==w.digest())throw Error(`The prelude checksum specified in the message (${A}) does not match the calculated CRC32 checksum (${w.digest()})`);if(w.update(new Uint8Array(_,K+A86,q-(A86+dz6))),O!==w.digest())throw Error(`The message checksum (${w.digest()}) did not match the expected value of ${O}`);return{headers:new DataView(_,K+A86+dz6,$),body:new Uint8Array(_,K+A86+dz6+$,Y-$-(A86+dz6+dz6))}}Xn(BMq,"splitMessage");var gMq=class{constructor(K,_){this.headerMarshaller=new mMq(K,_),this.messageBuffer=[],this.isEndOfStream=!1}feed(K){this.messageBuffer.push(this.decode(K))}endOfStream(){this.isEndOfStream=!0}getMessage(){let K=this.messageBuffer.pop(),_=this.isEndOfStream;return{getMessage(){return K},isEndOfStream(){return _}}}getAvailableMessages(){let K=this.messageBuffer;this.messageBuffer=[];let _=this.isEndOfStream;return{getMessages(){return K},isEndOfStream(){return _}}}encode({headers:K,body:_}){let z=this.headerMarshaller.format(K),Y=z.byteLength+_.byteLength+16,$=new Uint8Array(Y),A=new DataView($.buffer,$.byteOffset,$.byteLength),O=new zL9.Crc32;return A.setUint32(0,Y,!1),A.setUint32(4,z.byteLength,!1),A.setUint32(8,O.update($.subarray(0,8)).digest(),!1),$.set(z,12),$.set(_,z.byteLength+12),A.setUint32(Y-4,O.update($.subarray(8,Y-4)).digest(),!1),$}decode(K){let{headers:_,body:z}=BMq(K);return{headers:this.headerMarshaller.parse(_),body:z}}formatHeaders(K){return this.headerMarshaller.format(K)}};Xn(gMq,"EventStreamCodec");var WL9=gMq,FMq=class{constructor(K){this.options=K}[Symbol.asyncIterator](){return this.asyncIterator()}async*asyncIterator(){for await(let K of this.options.inputStream)yield this.options.decoder.decode(K)}};Xn(FMq,"MessageDecoderStream");var DL9=FMq,UMq=class{constructor(K){this.options=K}[Symbol.asyncIterator](){return this.asyncIterator()}async*asyncIterator(){for await(let K of this.options.messageStream)yield this.options.encoder.encode(K);if(this.options.includeEndFrame)yield new Uint8Array(0)}};Xn(UMq,"MessageEncoderStream");var fL9=UMq,QMq=class{constructor(K){this.options=K}[Symbol.asyncIterator](){return this.asyncIterator()}async*asyncIterator(){for await(let K of this.options.messageStream){let _=await this.options.deserializer(K);if(_===void 0)continue;yield _}}};Xn(QMq,"SmithyMessageDecoderStream");var ZL9=QMq,dMq=class{constructor(K){this.options=K}[Symbol.asyncIterator](){return this.asyncIterator()}async*asyncIterator(){for await(let K of this.options.inputStream)yield this.options.serializer(K)}};Xn(dMq,"SmithyMessageEncoderStream");var GL9=dMq});var tMq=m((Hr$,sMq)=>{var{defineProperty:NM8,getOwnPropertyDescriptor:TL9,getOwnPropertyNames:vL9}=Object,kL9=Object.prototype.hasOwnProperty,n06=(q,K)=>NM8(q,"name",{value:K,configurable:!0}),VL9=(q,K)=>{for(var _ in K)NM8(q,_,{get:K[_],enumerable:!0})},NL9=(q,K,_,z)=>{if(K&&typeof K==="object"||typeof K==="function"){for(let Y of vL9(K))if(!kL9.call(q,Y)&&Y!==_)NM8(q,Y,{get:()=>K[Y],enumerable:!(z=TL9(K,Y))||z.enumerable})}return q},yL9=(q)=>NL9(NM8({},"__esModule",{value:!0}),q),nMq={};VL9(nMq,{EventStreamMarshaller:()=>aMq,eventStreamSerdeProvider:()=>EL9});sMq.exports=yL9(nMq);var iF6=lMq();function iMq(q){let K=0,_=0,z=null,Y=null,$=n06((O)=>{if(typeof O!=="number")throw Error("Attempted to allocate an event message where size was not a number: "+O);K=O,_=4,z=new Uint8Array(O),new DataView(z.buffer).setUint32(0,O,!1)},"allocateMessage"),A=n06(async function*(){let O=q[Symbol.asyncIterator]();while(!0){let{value:w,done:j}=await O.next();if(j){if(!K)return;else if(K===_)yield z;else throw Error("Truncated event message received.");return}let H=w.length,J=0;while(J<H){if(!z){let X=H-J;if(!Y)Y=new Uint8Array(4);let P=Math.min(4-_,X);if(Y.set(w.slice(J,J+P),_),_+=P,J+=P,_<4)break;$(new DataView(Y.buffer).getUint32(0,!1)),Y=null}let M=Math.min(K-_,H-J);if(z.set(w.slice(J,J+M),_),_+=M,J+=M,K&&K===_)yield z,z=null,K=0,_=0}}},"iterator");return{[Symbol.asyncIterator]:A}}n06(iMq,"getChunkedStream");function rMq(q,K){return async function(_){let{value:z}=_.headers[":message-type"];if(z==="error"){let Y=Error(_.headers[":error-message"].value||"UnknownError");throw Y.name=_.headers[":error-code"].value,Y}else if(z==="exception"){let Y=_.headers[":exception-type"].value,$={[Y]:_},A=await q($);if(A.$unknown){let O=Error(K(_.body));throw O.name=Y,O}throw A[Y]}else if(z==="event"){let Y={[_.headers[":event-type"].value]:_},$=await q(Y);if($.$unknown)return;return $}else throw Error(`Unrecognizable event type: ${_.headers[":event-type"].value}`)}}n06(rMq,"getMessageUnmarshaller");var oMq=class{constructor({utf8Encoder:K,utf8Decoder:_}){this.eventStreamCodec=new iF6.EventStreamCodec(K,_),this.utfEncoder=K}deserialize(K,_){let z=iMq(K);return new iF6.SmithyMessageDecoderStream({messageStream:new iF6.MessageDecoderStream({inputStream:z,decoder:this.eventStreamCodec}),deserializer:rMq(_,this.utfEncoder)})}serialize(K,_){return new iF6.MessageEncoderStream({messageStream:new iF6.SmithyMessageEncoderStream({inputStream:K,serializer:_}),encoder:this.eventStreamCodec,includeEndFrame:!0})}};n06(oMq,"EventStreamMarshaller");var aMq=oMq,EL9=n06((q)=>new aMq(q),"eventStreamSerdeProvider")});var YXq=m((Jr$,zXq)=>{var{defineProperty:yM8,getOwnPropertyDescriptor:LL9,getOwnPropertyNames:RL9}=Object,hL9=Object.prototype.hasOwnProperty,vP1=(q,K)=>yM8(q,"name",{value:K,configurable:!0}),SL9=(q,K)=>{for(var _ in K)yM8(q,_,{get:K[_],enumerable:!0})},CL9=(q,K,_,z)=>{if(K&&typeof K==="object"||typeof K==="function"){for(let Y of RL9(K))if(!hL9.call(q,Y)&&Y!==_)yM8(q,Y,{get:()=>K[Y],enumerable:!(z=LL9(K,Y))||z.enumerable})}return q},bL9=(q)=>CL9(yM8({},"__esModule",{value:!0}),q),eMq={};SL9(eMq,{EventStreamMarshaller:()=>_Xq,eventStreamSerdeProvider:()=>uL9});zXq.exports=bL9(eMq);var xL9=tMq(),IL9=U6("stream");async function*qXq(q){let K=!1,_=!1,z=[];q.on("error",(Y)=>{if(!K)K=!0;if(Y)throw Y}),q.on("data",(Y)=>{z.push(Y)}),q.on("end",()=>{K=!0});while(!_){let Y=await new Promise(($)=>setTimeout(()=>$(z.shift()),0));if(Y)yield Y;_=K&&z.length===0}}vP1(qXq,"readabletoIterable");var KXq=class{constructor({utf8Encoder:K,utf8Decoder:_}){this.universalMarshaller=new xL9.EventStreamMarshaller({utf8Decoder:_,utf8Encoder:K})}deserialize(K,_){let z=typeof K[Symbol.asyncIterator]==="function"?K:qXq(K);return this.universalMarshaller.deserialize(z,_)}serialize(K,_){return IL9.Readable.from(this.universalMarshaller.serialize(K,_))}};vP1(KXq,"EventStreamMarshaller");var _Xq=KXq,uL9=vP1((q)=>new _Xq(q),"eventStreamSerdeProvider")});var OXq=m(($Xq)=>{Object.defineProperty($Xq,"__esModule",{value:!0});$Xq.fromBase64=void 0;var mL9=Nz6(),pL9=/^[A-Za-z0-9+/]*={0,2}$/,BL9=(q)=>{if(q.length*3%4!==0)throw TypeError("Incorrect padding on base64 string.");if(!pL9.exec(q))throw TypeError("Invalid base64 string.");let K=(0,mL9.fromString)(q,"base64");return new Uint8Array(K.buffer,K.byteOffset,K.byteLength)};$Xq.fromBase64=BL9});var MXq=m((Xr$,JXq)=>{var{defineProperty:EM8,getOwnPropertyDescriptor:gL9,getOwnPropertyNames:FL9}=Object,UL9=Object.prototype.hasOwnProperty,kP1=(q,K)=>EM8(q,"name",{value:K,configurable:!0}),QL9=(q,K)=>{for(var _ in K)EM8(q,_,{get:K[_],enumerable:!0})},dL9=(q,K,_,z)=>{if(K&&typeof K==="object"||typeof K==="function"){for(let Y of FL9(K))if(!UL9.call(q,Y)&&Y!==_)EM8(q,Y,{get:()=>K[Y],enumerable:!(z=gL9(K,Y))||z.enumerable})}return q},cL9=(q)=>dL9(EM8({},"__esModule",{value:!0}),q),wXq={};QL9(wXq,{fromUtf8:()=>HXq,toUint8Array:()=>lL9,toUtf8:()=>nL9});JXq.exports=cL9(wXq);var jXq=Nz6(),HXq=kP1((q)=>{let K=(0,jXq.fromString)(q,"utf8");return new Uint8Array(K.buffer,K.byteOffset,K.byteLength/Uint8Array.BYTES_PER_ELEMENT)},"fromUtf8"),lL9=kP1((q)=>{if(typeof q==="string")return HXq(q);if(ArrayBuffer.isView(q))return new Uint8Array(q.buffer,q.byteOffset,q.byteLength/Uint8Array.BYTES_PER_ELEMENT);return new Uint8Array(q)},"toUint8Array"),nL9=kP1((q)=>{if(typeof q==="string")return q;if(typeof q!=="object"||typeof q.byteOffset!=="number"||typeof q.byteLength!=="number")throw Error("@smithy/util-utf8: toUtf8 encoder function only accepts string | Uint8Array.");return(0,jXq.fromArrayBuffer)(q.buffer,q.byteOffset,q.byteLength).toString("utf8")},"toUtf8")});var WXq=m((XXq)=>{Object.defineProperty(XXq,"__esModule",{value:!0});XXq.toBase64=void 0;var iL9=Nz6(),rL9=MXq(),oL9=(q)=>{let K;if(typeof q==="string")K=(0,rL9.fromUtf8)(q);else K=q;if(typeof K!=="object"||typeof K.byteOffset!=="number"||typeof K.byteLength!=="number")throw Error("@smithy/util-base64: toBase64 encoder function only accepts string | Uint8Array.");return(0,iL9.fromArrayBuffer)(K.buffer,K.byteOffset,K.byteLength).toString("base64")};XXq.toBase64=oL9});var yP1=m((Wr$,LM8)=>{var{defineProperty:DXq,getOwnPropertyDescriptor:aL9,getOwnPropertyNames:sL9}=Object,tL9=Object.prototype.hasOwnProperty,VP1=(q,K,_,z)=>{if(K&&typeof K==="object"||typeof K==="function"){for(let Y of sL9(K))if(!tL9.call(q,Y)&&Y!==_)DXq(q,Y,{get:()=>K[Y],enumerable:!(z=aL9(K,Y))||z.enumerable})}return q},fXq=(q,K,_)=>(VP1(q,K,"default"),_&&VP1(_,K,"default")),eL9=(q)=>VP1(DXq({},"__esModule",{value:!0}),q),NP1={};LM8.exports=eL9(NP1);fXq(NP1,OXq(),LM8.exports);fXq(NP1,WXq(),LM8.exports)});var kXq=m((Dr$,vXq)=>{var{defineProperty:RM8,getOwnPropertyDescriptor:qR9,getOwnPropertyNames:KR9}=Object,_R9=Object.prototype.hasOwnProperty,MS=(q,K)=>RM8(q,"name",{value:K,configurable:!0}),zR9=(q,K)=>{for(var _ in K)RM8(q,_,{get:K[_],enumerable:!0})},YR9=(q,K,_,z)=>{if(K&&typeof K==="object"||typeof K==="function"){for(let Y of KR9(K))if(!_R9.call(q,Y)&&Y!==_)RM8(q,Y,{get:()=>K[Y],enumerable:!(z=qR9(K,Y))||z.enumerable})}return q},$R9=(q)=>YR9(RM8({},"__esModule",{value:!0}),q),TXq={};zR9(TXq,{constructStack:()=>EP1});vXq.exports=$R9(TXq);var cz6=MS((q,K)=>{let _=[];if(q)_.push(q);if(K)for(let z of K)_.push(z);return _},"getAllAliases"),O86=MS((q,K)=>{return`${q||"anonymous"}${K&&K.length>0?` (a.k.a. ${K.join(",")})`:""}`},"getMiddlewareNameWithAliases"),EP1=MS(()=>{let q=[],K=[],_=!1,z=new Set,Y=MS((J)=>J.sort((M,X)=>ZXq[X.step]-ZXq[M.step]||GXq[X.priority||"normal"]-GXq[M.priority||"normal"]),"sort"),$=MS((J)=>{let M=!1,X=MS((P)=>{let W=cz6(P.name,P.aliases);if(W.includes(J)){M=!0;for(let D of W)z.delete(D);return!1}return!0},"filterCb");return q=q.filter(X),K=K.filter(X),M},"removeByName"),A=MS((J)=>{let M=!1,X=MS((P)=>{if(P.middleware===J){M=!0;for(let W of cz6(P.name,P.aliases))z.delete(W);return!1}return!0},"filterCb");return q=q.filter(X),K=K.filter(X),M},"removeByReference"),O=MS((J)=>{var M;return q.forEach((X)=>{J.add(X.middleware,{...X})}),K.forEach((X)=>{J.addRelativeTo(X.middleware,{...X})}),(M=J.identifyOnResolve)==null||M.call(J,H.identifyOnResolve()),J},"cloneTo"),w=MS((J)=>{let M=[];return J.before.forEach((X)=>{if(X.before.length===0&&X.after.length===0)M.push(X);else M.push(...w(X))}),M.push(J),J.after.reverse().forEach((X)=>{if(X.before.length===0&&X.after.length===0)M.push(X);else M.push(...w(X))}),M},"expandRelativeMiddlewareList"),j=MS((J=!1)=>{let M=[],X=[],P={};return q.forEach((D)=>{let f={...D,before:[],after:[]};for(let G of cz6(f.name,f.aliases))P[G]=f;M.push(f)}),K.forEach((D)=>{let f={...D,before:[],after:[]};for(let G of cz6(f.name,f.aliases))P[G]=f;X.push(f)}),X.forEach((D)=>{if(D.toMiddleware){let f=P[D.toMiddleware];if(f===void 0){if(J)return;throw Error(`${D.toMiddleware} is not found when adding ${O86(D.name,D.aliases)} middleware ${D.relation} ${D.toMiddleware}`)}if(D.relation==="after")f.after.push(D);if(D.relation==="before")f.before.push(D)}}),Y(M).map(w).reduce((D,f)=>{return D.push(...f),D},[])},"getMiddlewareList"),H={add:(J,M={})=>{let{name:X,override:P,aliases:W}=M,D={step:"initialize",priority:"normal",middleware:J,...M},f=cz6(X,W);if(f.length>0){if(f.some((G)=>z.has(G))){if(!P)throw Error(`Duplicate middleware name '${O86(X,W)}'`);for(let G of f){let Z=q.findIndex((v)=>{var V;return v.name===G||((V=v.aliases)==null?void 0:V.some((E)=>E===G))});if(Z===-1)continue;let T=q[Z];if(T.step!==D.step||D.priority!==T.priority)throw Error(`"${O86(T.name,T.aliases)}" middleware with ${T.priority} priority in ${T.step} step cannot be overridden by "${O86(X,W)}" middleware with ${D.priority} priority in ${D.step} step.`);q.splice(Z,1)}}for(let G of f)z.add(G)}q.push(D)},addRelativeTo:(J,M)=>{let{name:X,override:P,aliases:W}=M,D={middleware:J,...M},f=cz6(X,W);if(f.length>0){if(f.some((G)=>z.has(G))){if(!P)throw Error(`Duplicate middleware name '${O86(X,W)}'`);for(let G of f){let Z=K.findIndex((v)=>{var V;return v.name===G||((V=v.aliases)==null?void 0:V.some((E)=>E===G))});if(Z===-1)continue;let T=K[Z];if(T.toMiddleware!==D.toMiddleware||T.relation!==D.relation)throw Error(`"${O86(T.name,T.aliases)}" middleware ${T.relation} "${T.toMiddleware}" middleware cannot be overridden by "${O86(X,W)}" middleware ${D.relation} "${D.toMiddleware}" middleware.`);K.splice(Z,1)}}for(let G of f)z.add(G)}K.push(D)},clone:()=>O(EP1()),use:(J)=>{J.applyToStack(H)},remove:(J)=>{if(typeof J==="string")return $(J);else return A(J)},removeByTag:(J)=>{let M=!1,X=MS((P)=>{let{tags:W,name:D,aliases:f}=P;if(W&&W.includes(J)){let G=cz6(D,f);for(let Z of G)z.delete(Z);return M=!0,!1}return!0},"filterCb");return q=q.filter(X),K=K.filter(X),M},concat:(J)=>{var M;let X=O(EP1());return X.use(J),X.identifyOnResolve(_||X.identifyOnResolve()||(((M=J.identifyOnResolve)==null?void 0:M.call(J))??!1)),X},applyToStack:O,identify:()=>{return j(!0).map((J)=>{let M=J.step??J.relation+" "+J.toMiddleware;return O86(J.name,J.aliases)+" - "+M})},identifyOnResolve(J){if(typeof J==="boolean")_=J;return _},resolve:(J,M)=>{for(let X of j().map((P)=>P.middleware).reverse())J=X(J,M);if(_)console.log(H.identify());return J}};return H},"constructStack"),ZXq={initialize:5,serialize:4,build:3,finalizeRequest:2,deserialize:1},GXq={high:3,normal:2,low:1}});var LXq=m((fr$,EXq)=>{var{defineProperty:hM8,getOwnPropertyDescriptor:AR9,getOwnPropertyNames:OR9}=Object,wR9=Object.prototype.hasOwnProperty,LP1=(q,K)=>hM8(q,"name",{value:K,configurable:!0}),jR9=(q,K)=>{for(var _ in K)hM8(q,_,{get:K[_],enumerable:!0})},HR9=(q,K,_,z)=>{if(K&&typeof K==="object"||typeof K==="function"){for(let Y of OR9(K))if(!wR9.call(q,Y)&&Y!==_)hM8(q,Y,{get:()=>K[Y],enumerable:!(z=AR9(K,Y))||z.enumerable})}return q},JR9=(q)=>HR9(hM8({},"__esModule",{value:!0}),q),VXq={};jR9(VXq,{fromUtf8:()=>yXq,toUint8Array:()=>MR9,toUtf8:()=>XR9});EXq.exports=JR9(VXq);var NXq=Nz6(),yXq=LP1((q)=>{let K=(0,NXq.fromString)(q,"utf8");return new Uint8Array(K.buffer,K.byteOffset,K.byteLength/Uint8Array.BYTES_PER_ELEMENT)},"fromUtf8"),MR9=LP1((q)=>{if(typeof q==="string")return yXq(q);if(ArrayBuffer.isView(q))return new Uint8Array(q.buffer,q.byteOffset,q.byteLength/Uint8Array.BYTES_PER_ELEMENT);return new Uint8Array(q)},"toUint8Array"),XR9=LP1((q)=>{if(typeof q==="string")return q;if(typeof q!=="object"||typeof q.byteOffset!=="number"||typeof q.byteLength!=="number")throw Error("@smithy/util-utf8: toUtf8 encoder function only accepts string | Uint8Array.");return(0,NXq.fromArrayBuffer)(q.buffer,q.byteOffset,q.byteLength).toString("utf8")},"toUtf8")});var SXq=m((RXq)=>{Object.defineProperty(RXq,"__esModule",{value:!0});RXq.getAwsChunkedEncodingStream=void 0;var PR9=U6("stream"),WR9=(q,K)=>{let{base64Encoder:_,bodyLengthChecker:z,checksumAlgorithmFn:Y,checksumLocationName:$,streamHasher:A}=K,O=_!==void 0&&Y!==void 0&&$!==void 0&&A!==void 0,w=O?A(Y,q):void 0,j=new PR9.Readable({read:()=>{}});return q.on("data",(H)=>{let J=z(H)||0;j.push(`${J.toString(16)}\r |