https://www.ncoa.org/_next/static/chunks/9945.12d76dd257e0927f.js

1"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[9945],{29945:(e,t,r)=>{r.d(t,{EventStreamSerde:()=>B,eventStreamSerdeProvider:()=>x});let a=new Uint32Array(256);for(let e=0;e<256;++e){let t=e;for(let e=0;e<8;++e)t=1&t?0xedb88320^t>>>1:t>>>1;a[e]=t>>>0}class s{digestLength=4;checksum=0xffffffff;update(e){for(let t=0;t<e.length;++t)this.checksum=this.checksum>>>8^a[(this.checksum^e[t])&255]}digestSync(){return(0xffffffff^this.checksum)>>>0}async digest(){let e=this.digestSync(),t=new Uint8Array(4);return new DataView(t.buffer).setUint32(0,e,!1),t}reset(){this.checksum=0xffffffff}}var n,i=r(86959);class l{bytes;constructor(e){if(this.bytes=e,8!==e.byteLength)throw Error("Int64 buffers must be exactly 8 bytes")}static fromNumber(e){if(e>0x8000000000000000||e<-0x8000000000000000)throw Error(`${e} is too large (or, if negative, too small) to represent as an Int64`);let t=new Uint8Array(8);for(let r=7,a=Math.abs(Math.round(e));r>-1&&a>0;r--,a/=256)t[r]=a;return e<0&&o(t),new l(t)}valueOf(){let e=this.bytes.slice(0),t=128&e[0];return t&&o(e),parseInt((0,i.n)(e),16)*(t?-1:1)}toString(){return String(this.valueOf())}}function o(e){for(let t=0;t<8;t++)e[t]^=255;for(let t=7;t>-1&&(e[t]++,0===e[t]);t--);}class u{toUtf8;fromUtf8;constructor(e,t){this.toUtf8=e,this.fromUtf8=t}format(e){let t=[];for(let r of Object.keys(e)){let a=this.fromUtf8(r);t.push(Uint8Array.from([a.byteLength]),a,this.formatHeaderValue(e[r]))}let r=new Uint8Array(t.reduce((e,t)=>e+t.byteLength,0)),a=0;for(let e of t)r.set(e,a),a+=e.byteLength;return r}formatHeaderValue(e){switch(e.type){case"boolean":return Uint8Array.from([+!e.value]);case"byte":return Uint8Array.from([2,e.value]);case"short":let t=new DataView(new ArrayBuffer(3));return t.setUint8(0,3),t.setInt16(1,e.value,!1),new Uint8Array(t.buffer);case"integer":let r=new DataView(new ArrayBuffer(5));return r.setUint8(0,4),r.setInt32(1,e.value,!1),new Uint8Array(r.buffer);case"long":let a=new Uint8Array(9);return a[0]=5,a.set(e.value.bytes,1),a;case"binary":let s=new DataView(new ArrayBuffer(3+e.value.byteLength));s.setUint8(0,6),s.setUint16(1,e.value.byteLength,!1);let n=new Uint8Array(s.buffer);return n.set(e.value,3),n;case"string":let o=this.fromUtf8(e.value),u=new DataView(new ArrayBuffer(3+o.byteLength));u.setUint8(0,7),u.setUint16(1,o.byteLength,!1);let f=new Uint8Array(u.buffer);return f.set(o,3),f;case"timestamp":let c=new Uint8Array(9);return c[0]=8,c.set(l.fromNumber(e.value.valueOf()).bytes,1),c;case"uuid":if(!p.test(e.value))throw Error(`Invalid UUID received: ${e.value}`);let h=new Uint8Array(17);return h[0]=9,h.set((0,i.a)(e.value.replace(/\-/g,"")),1),h}}parse(e){let t={},r=0;for(;r<e.byteLength;){let a=e.getUint8(r++),s=this.toUtf8(new Uint8Array(e.buffer,e.byteOffset+r,a));switch(r+=a,e.getUint8(r++)){case 0:t[s]={type:f,value:!0};break;case 1:t[s]={type:f,value:!1};break;case 2:t[s]={type:c,value:e.getInt8(r++)};break;case 3:t[s]={type:h,value:e.getInt16(r,!1)},r+=2;break;case 4:t[s]={type:y,value:e.getInt32(r,!1)},r+=4;break;case 5:t[s]={type:d,value:new l(new Uint8Array(e.buffer,e.byteOffset+r,8))},r+=8;break;case 6:let n=e.getUint16(r,!1);r+=2,t[s]={type:m,value:new Uint8Array(e.buffer,e.byteOffset+r,n)},r+=n;break;case 7:let o=e.getUint16(r,!1);r+=2,t[s]={type:b,value:this.toUtf8(new Uint8Array(e.buffer,e.byteOffset+r,o))},r+=o;break;case 8:t[s]={type:g,value:new Date(new l(new Uint8Array(e.buffer,e.byteOffset+r,8)).valueOf())},r+=8;break;case 9:let u=new Uint8Array(e.buffer,e.byteOffset+r,16);r+=16,t[s]={type:w,value:`${(0,i.n)(u.subarray(0,4))}-${(0,i.n)(u.subarray(4,6))}-${(0,i.n)(u.subarray(6,8))}-${(0,i.n)(u.subarray(8,10))}-${(0,i.n)(u.subarray(10))}`};break;default:throw Error("Unrecognized header type tag")}}return t}}!function(e){e[e.boolTrue=0]="boolTrue",e[e.boolFalse=1]="boolFalse",e[e.byte=2]="byte",e[e.short=3]="short",e[e.integer=4]="integer",e[e.long=5]="long",e[e.byteArray=6]="byteArray",e[e.string=7]="string",e[e.timestamp=8]="timestamp",e[e.uuid=9]="uuid"}(n||(n={}));let f="boolean",c="byte",h="short",y="integer",d="long",m="binary",b="string",g="timestamp",w="uuid",p=/^[a-f0-9]{8}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{12}$/,v=16;class S{headerMarshaller;messageBuffer;isEndOfStream;constructor(e,t){this.headerMarshaller=new u(e,t),this.messageBuffer=[],this.isEndOfStream=!1}feed(e){this.messageBuffer.push(this.decode(e))}endOfStream(){this.isEndOfStream=!0}getMessage(){let e=this.messageBuffer.pop(),t=this.isEndOfStream;return{getMessage:()=>

1e,isEndOfStream:()=>t}}getAvailableMessages(){let e=this.messageBuffer;this.messageBuffer=[];let t=this.isEndOfStream;return{getMessages:()=>e,isEndOfStream:()=>t}}encode({headers:e,body:t}){let r=this.headerMarshaller.format(e),a=r.byteLength+t.byteLength+16,n=new Uint8Array(a),i=new DataView(n.buffer,n.byteOffset,n.byteLength),l=new s;return i.setUint32(0,a,!1),i.setUint32(4,r.byteLength,!1),l.update(n.subarray(0,8)),i.setUint32(8,l.digestSync(),!1),n.set(r,12),n.set(t,r.byteLength+12),l.update(n.subarray(8,a-4)),i.setUint32(a-4,l.digestSync(),!1),n}decode(e){let{headers:t,body:r}=function({byteLength:e,byteOffset:t,buffer:r}){if(e<v)throw Error("Provided message too short to accommodate event stream message overhead");let a=new DataView(r,t,e),n=a.getUint32(0,!1);if(e!==n)throw Error("Reported message length does not match received message length");let i=a.getUint32(4,!1),l=a.getUint32(8,!1),o=a.getUint32(e-4,!1),u=new s;if(u.update(new Uint8Array(r,t,8)),l!==u.digestSync())throw Error(`The prelude checksum specified in the message (${l}) does not match the calculated CRC32 checksum (${u.digestSync()})`);if(u.update(new Uint8Array(r,t+8,e-12)),o!==u.digestSync())throw Error(`The message checksum (${u.digestSync()}) did not match the expected value of ${o}`);return{headers:new DataView(r,t+8+4,i),body:new Uint8Array(r,t+8+4+i,n-i-16)}}(e);return{headers:this.headerMarshaller.parse(t),body:r}}formatHeaders(e){return this.headerMarshaller.format(e)}}class U{options;constructor(e){this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async *asyncIterator(){for await(let e of this.options.inputStream){let t=this.options.decoder.decode(e);yield t}}}class E{options;constructor(e){this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async *asyncIterator(){for await(let e of this.options.messageStream){let t=this.options.encoder.encode(e);yield t}this.options.includeEndFrame&&(yield new Uint8Array(0))}}class A{options;constructor(e){this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async *asyncIterator(){for await(let e of this.options.messageStream){let t=await this.options.deserializer(e);void 0!==t&&(yield t)}}}class k{options;constructor(e){this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async *asyncIterator(){for await(let e of this.options.inputStream){let t=this.options.serializer(e);yield t}}}class I{eventStreamCodec;utfEncoder;constructor({utf8Encoder:e,utf8Decoder:t}){this.eventStreamCodec=new S(e,t),this.utfEncoder=e}deserialize(e,t){var r;return new A({messageStream:new U({inputStream:function(e){let t=0,r=0,a=null,s=null,n=e=>{if("number"!=typeof e)throw Error("Attempted to allocate an event message where size was not a number: "+e);t=e,r=4,new DataView((a=new Uint8Array(e)).buffer).setUint32(0,e,!1)};return{[Symbol.asyncIterator]:async function*(){let i=e[Symbol.asyncIterator]();for(;;){let{value:e,done:l}=await i.next();if(l){if(t)if(t===r)yield a;else throw Error("Truncated event message received.");return}let o=e.length,u=0;for(;u<o;){if(!a){let t=o-u;s||(s=new Uint8Array(4));let a=Math.min(4-r,t);if(s.set(e.slice(u,u+a),r),r+=a,u+=a,r<4)break;n(new DataView(s.buffer).getUint32(0,!1)),s=null}let i=Math.min(t-r,o-u);a.set(e.slice(u,u+i),r),r+=i,u+=i,t&&t===r&&(yield a,a=null,t=0,r=0)}}}}}(e),decoder:this.eventStreamCodec}),deserializer:(r=this.utfEncoder,async function(e){let{value:a}=e.headers[":message-type"];if("error"===a){let t=Error(e.headers[":error-message"].value||"UnknownError");throw t.name=e.headers[":error-code"].value,t}if("exception"===a){let a=e.headers[":exception-type"].value,s=await t({[a]:e});if(s.$unknown){let t=Error(r(e.body));throw t.name=a,t}throw s[a]}if("event"===a){let r={[e.headers[":event-type"].value]:e},a=await t(r);if(a.$unknown)return;return a}throw Error(`Unrecognizable event type: ${e.headers[":event-type"].value}`)})})}serialize(e,t){return new E({messageStream:new k({inputStream:e,serializer:t}),encoder:this.eventStreamCodec,includeEndFrame:!0})}}class M{universalMarshaller;constructor({utf8Encoder:e,utf8Decoder:t}){this.universalMarshaller=new I({utf8Decoder:t,utf8Encoder:e})}deserialize(e,t){let r=z(e)?{[Symbol.asyncIterator]:async function*(){let t=e.getReader();try{for(;;){let{done:e,value:r}=await t.read();if(e)return;yield r}}finally{t.releaseLock()}}}:e;return this.universalMarshaller.deserialize(r,t)}serialize(e,t){let r=this.universalMarshaller.serialize(e,t);return"function"==typeof ReadableStream?(e=>{let t=e[Symbol.asyncIterator]();return new ReadableStream({async pull(e){let{done:r,value:a}=await t.next();if(r)return e.close();e.enqueue(a)}})})(r):r}}let z=e=>"function"==typeof ReadableStream&&e instanceof ReadableStream,x=e=>new M(e);var O=r(3744),L=r(88869);class B{marshaller;

1serializer;deserializer;serdeContext;defaultContentType;constructor({marshaller:e,serializer:t,deserializer:r,serdeContext:a,defaultContentType:s}){this.marshaller=e,this.serializer=t,this.deserializer=r,this.serdeContext=a,this.defaultContentType=s}async serializeEventStream({eventStream:e,requestSchema:t,initialRequest:r}){let a=this.marshaller,s=t.getEventStreamMember(),n=t.getMemberSchema(s),i=this.serializer,l=this.defaultContentType,o=Symbol("initialRequestMarker"),u={async *[Symbol.asyncIterator](){if(r){i.write(t,r);let e=i.flush();yield{[o]:!0,headers:{":event-type":{type:"string",value:"initial-request"},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:l}},body:e}}for await(let t of e)yield t}};return a.serialize(u,e=>{if(e[o])return{headers:e.headers,body:e.body};let t="";for(let r in e)if("__type"!==r){t=r;break}let{additionalHeaders:r,body:a,eventType:s,explicitPayloadContentType:i}=this.writeEventBody(t,n,e);return{headers:{":event-type":{type:"string",value:s},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:i??l},...r},body:a}})}async deserializeEventStream({response:e,responseSchema:t,initialResponseContainer:r}){let a=this.marshaller,s=t.getEventStreamMember(),n=t.getMemberSchema(s).getMemberSchemas(),i=Symbol("initialResponseMarker"),l=a.deserialize(e.body,async e=>{let r="";for(let t in e)if("__type"!==t){r=t;break}let a=e[r].body;if("initial-response"===r){let e=await this.deserializer.read(t,a);return delete e[s],{[i]:!0,...e}}if(!(r in n))return{$unknown:e};{let t=n[r];if(t.isStructSchema()){let s={},n=!1;for(let[i,l]of t.structIterator()){let{eventHeader:t,eventPayload:o}=l.getMergedTraits();if(n=n||!!(t||o),o)l.isBlobSchema()?s[i]=a:l.isStringSchema()?s[i]=(this.serdeContext?.utf8Encoder??O.P)(a):l.isStructSchema()&&(s[i]=await this.deserializer.read(l,a));else if(t){let t=e[r].headers[i]?.value;null!=t&&(l.isNumericSchema()?t&&"object"==typeof t&&"bytes"in t?s[i]=BigInt(t.toString()):s[i]=Number(t):s[i]=t)}}if(n)return{[r]:s};if(0===a.byteLength)return{[r]:{}}}return{[r]:await this.deserializer.read(t,a)}}}),o=l[Symbol.asyncIterator](),u=await o.next();if(u.done)return l;if(u.value?.[i]){if(!t)throw Error("@smithy::core/protocols - initial-response event encountered in event stream but no response schema given.");for(let e in u.value)r[e]=u.value[e]}return{async *[Symbol.asyncIterator](){for(u?.value?.[i]||(yield u.value);;){let{done:e,value:t}=await o.next();if(e)break;yield t}}}}writeEventBody(e,t,r){let a,s=this.serializer,n=e,i=null,l=t.getSchema()[4].includes(e),o={};if(l){let n=t.getMemberSchema(e);if(n.isStructSchema()){for(let[t,a]of n.structIterator()){let{eventHeader:s,eventPayload:n}=a.getMergedTraits();if(n)i=t;else if(s){let s=r[e][t],n="binary";a.isNumericSchema()?n=-0x80000000<=s&&s<=0x80000000-1?"integer":"long":a.isTimestampSchema()?n="timestamp":a.isStringSchema()?n="string":a.isBooleanSchema()&&(n="boolean"),null!=s&&(o[t]={type:n,value:s},delete r[e][t])}}if(null!==i){let t=n.getMemberSchema(i);t.isBlobSchema()?a="application/octet-stream":t.isStringSchema()&&(a="text/plain"),s.write(t,r[e][i])}else s.write(n,r[e])}else if(n.isUnitSchema())s.write(n,{});else throw Error("@smithy/core/event-streams - non-struct member not supported in event stream union.")}else{let[t,a]=r[e];n=t,s.write(15,a)}let u=s.flush()??new Uint8Array;return{body:"string"==typeof u?(this.serdeContext?.utf8Decoder??L.a)(u):u,eventType:n,explicitPayloadContentType:a,additionalHeaders:o}}}}}]);