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