https://app.unjabbed.app/static/js/963.05bc0647.chunk.js

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