1var F=Object.defineProperty;var j=(s,e,t)=>e in s?F(s,e,{enumerable:!0,configurable:!0,writable:!0,value:t}):s[e]=t;var y=(s,e,t)=>j(s,typeof e!="symbol"?e+"":e,t);import{t as B,f as K,a as q,T as D,b as J}from"./index-Dgd8NXUX.js";import"./chunk-QMGIS6GS-CzCKhjba.js";import"./credits.atom-DuaCpa1X.js";import"./user.atom-3USzP7x8.js";import"./use-upgrade-dialog-DFdsqtdZ.js";import"./room-service-D1rRVcFl.js";import"./image-service-__YyIDuU.js";import"./message-DCiyLIQZ.js";import"./use-permission-BQtW2gfQ.js";import"./acl-service-BFBKBtqh.js";import"./react-D1t0Gy6S.js";import"./jsx-runtime-ocU72h0v.js";const G=new Uint32Array(256);for(let s=0;s<256;++s){let e=s;for(let t=0;t<8;++t)e=e&1?3988292384^e>>>1:e>>>1;G[s]=e>>>0}const C=4294967295;class L{constructor(){y(this,"digestLength",4);y(this,"checksum",C)}update(e){for(let t=0;t<e.length;++t)this.checksum=this.checksum>>>8^G[(this.checksum^e[t])&255]}digestSync(){return(this.checksum^C)>>>0}async digest(){const e=this.digestSync(),t=new Uint8Array(4);return new DataView(t.buffer).setUint32(0,e,!1),t}reset(){this.checksum=C}}class z{constructor(e){y(this,"bytes");if(this.bytes=e,e.byteLength!==8)throw new Error("Int64 buffers must be exactly 8 bytes")}static fromNumber(e){if(e>9223372036854776e3||e<-9223372036854776e3)throw new Error(`${e} is too large (or, if negative, too small) to represent as an Int64`);const 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&&N(t),new z(t)}valueOf(){const e=this.bytes.slice(0),t=e[0]&128;return t&&N(e),parseInt(B(e),16)*(t?-1:1)}toString(){return String(this.valueOf())}}function N(s){for(let e=0;e<8;e++)s[e]^=255;for(let e=7;e>-1&&(s[e]++,s[e]===0);e--);}class W{constructor(e,t){y(this,"toUtf8");y(this,"fromUtf8");this.toUtf8=e,this.fromUtf8=t}format(e){const t=[];for(const n of Object.keys(e)){const c=this.fromUtf8(n);t.push(Uint8Array.from([c.byteLength]),c,this.formatHeaderValue(e[n]))}const r=new Uint8Array(t.reduce((n,c)=>n+c.byteLength,0));let a=0;for(const n of t)r.set(n,a),a+=n.byteLength;return r}formatHeaderValue(e){switch(e.type){case"boolean":return Uint8Array.from([e.value?m.boolTrue:m.boolFalse]);case"byte":return Uint8Array.from([m.byte,e.value]);case"short":const t=new DataView(new ArrayBuffer(3));return t.setUint8(0,m.short),t.setInt16(1,e.value,!1),new Uint8Array(t.buffer);case"integer":const r=new DataView(new ArrayBuffer(5));return r.setUint8(0,m.integer),r.setInt32(1,e.value,!1),new Uint8Array(r.buffer);case"long":const a=new Uint8Array(9);return a[0]=m.long,a.set(e.value.bytes,1),a;case"binary":const n=new DataView(new ArrayBuffer(3+e.value.byteLength));n.setUint8(0,m.byteArray),n.setUint16(1,e.value.byteLength,!1);const c=new Uint8Array(n.buffer);return c.set(e.value,3),c;case"string":const o=this.fromUtf8(e.value),l=new DataView(new ArrayBuffer(3+o.byteLength));l.setUint8(0,m.string),l.setUint16(1,o.byteLength,!1);const b=new Uint8Array(l.buffer);return b.set(o,3),b;case"timestamp":const h=new Uint8Array(9);return h[0]=m.timestamp,h.set(z.fromNumber(e.value.valueOf()).bytes,1),h;case"uuid":if(!Y.test(e.value))throw new Error(`Invalid UUID received: ${e.value}`);const i=new Uint8Array(17);return i[0]=m.uuid,i.set(K(e.value.replace(/-/g,"")),1),i}}parse(e){const t={};let r=0;for(;r<e.byteLength;){const a=e.getUint8(r++),n=this.toUtf8(new Uint8Array(e.buffer,e.byteOffset+r,a));switch(r+=a,e.getUint8(r++)){case m.boolTrue:t[n]={type:$,value:!0};break;case m.boolFalse:t[n]={type:$,value:!1};break;case m.byte:t[n]={type:E,value:e.getInt8(r++)};break;case m.short:t[n]={type:Q,value:e.getInt16(r,!1)},r+=2;break;case m.integer:t[n]={type:V,value:e.getInt32(r,!1)},r+=4;break;case m.long:t[n]={type:X,value:new z(new Uint8Array(e.buffer,e.byteOffset+r,8))},r+=8;break;case m.byteArray:const c=e.getUint16(r,!1);r+=2,t[n]={type:Z,value:new Uint8Array(e.buffer,e.byteOffset+r,c)},r+=c;break;case m.string:const o=e.getUint16(r,!1);r+=2,t[n]={type:H,value:this.toUtf8(new Uint8Array(e.buffer,e.byteOffset+r,o))},r+=o;break;case m.timestamp:t[n]={type:P,value:new Date(new z(new Uint8Array(e.buffer,e.byteOffset+r,8)).valueOf())},r+=8;break;case m.uuid:const l=new Uint8Array(e.buffer,e.byteOffset+r,16);r+=16,t[n]={type:_,value:`${B(l.subarray(0,4))}-${B(l.subarray(4,6))}-${B(l.subarray(6,8))}-${B(l.subarray(8,10))}-${B(l.subarray(10))}`};break;default:throw new Error("Unrecognized header type tag")}}return t}}var m;(function(s){s[s.boolTrue=0]="boolTrue",s[s.boolFalse=1]="boolFalse",s[s.byte=2]="byte",s[s.short=3]="short",s[s.integer=4]="integer",s[s.long=5]="long",s[s.byteArray=6]="byteArray",s[s.string=7]="string",s[s.timestamp=8]="timestamp",s[s.uuid=9]="uuid"})(m||(m={}));const $="boolean",E="byte",Q="short",V="integer",X="long",Z="binary",H="string",P="timestamp",_="uuid",Y=/^[a-f0-9]{8}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{12}$/,R=4,S=R*2,U=4,ee=S+U*2;function te({byteLength:s,byteOffset:e,buffer:t}){if(s<ee)throw new Error("Provided message too short to accommodate event stream message overhead");const r=new DataView(t,e,s),a=r.getUint32(0,!1);if(s!==a)throw new Error("Reported message length does not match received message length");const n=r.getUint32(R,!1),c=r.getUint32(S,!1),o=r.getUint32(s-U,!1),l=new L;if(l.update(new Uint8Array(t,e,S)),c!==l.digestSync())throw new Error(`The prelude checksum specified in the message (${c}) does not match the calculated CRC32 checksum (${l.digestSync()})`);
1if(l.update(new Uint8Array(t,e+S,s-(S+U))),o!==l.digestSync())throw new Error(`The message checksum (${l.digestSync()}) did not match the expected value of ${o}`);return{headers:new DataView(t,e+S+U,n),body:new Uint8Array(t,e+S+U+n,a-n-(S+U+U))}}class re{constructor(e,t){y(this,"headerMarshaller");y(this,"messageBuffer");y(this,"isEndOfStream");this.headerMarshaller=new W(e,t),this.messageBuffer=[],this.isEndOfStream=!1}feed(e){this.messageBuffer.push(this.decode(e))}endOfStream(){this.isEndOfStream=!0}getMessage(){const e=this.messageBuffer.pop(),t=this.isEndOfStream;return{getMessage(){return e},isEndOfStream(){return t}}}getAvailableMessages(){const e=this.messageBuffer;this.messageBuffer=[];const t=this.isEndOfStream;return{getMessages(){return e},isEndOfStream(){return t}}}encode({headers:e,body:t}){const r=this.headerMarshaller.format(e),a=r.byteLength+t.byteLength+16,n=new Uint8Array(a),c=new DataView(n.buffer,n.byteOffset,n.byteLength),o=new L;return c.setUint32(0,a,!1),c.setUint32(4,r.byteLength,!1),o.update(n.subarray(0,8)),c.setUint32(8,o.digestSync(),!1),n.set(r,12),n.set(t,r.byteLength+12),o.update(n.subarray(8,a-4)),c.setUint32(a-4,o.digestSync(),!1),n}decode(e){const{headers:t,body:r}=te(e);return{headers:this.headerMarshaller.parse(t),body:r}}formatHeaders(e){return this.headerMarshaller.format(e)}}class se{constructor(e){y(this,"options");this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async*asyncIterator(){for await(const e of this.options.inputStream)yield this.options.decoder.decode(e)}}class ne{constructor(e){y(this,"options");this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async*asyncIterator(){for await(const e of this.options.messageStream)yield this.options.encoder.encode(e);this.options.includeEndFrame&&(yield new Uint8Array(0))}}class ae{constructor(e){y(this,"options");this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async*asyncIterator(){for await(const e of this.options.messageStream){const t=await this.options.deserializer(e);t!==void 0&&(yield t)}}}class oe{constructor(e){y(this,"options");this.options=e}[Symbol.asyncIterator](){return this.asyncIterator()}async*asyncIterator(){for await(const e of this.options.inputStream)yield this.options.serializer(e)}}function ie(s){let e=0,t=0,r=null,a=null;const n=o=>{if(typeof o!="number")throw new Error("Attempted to allocate an event message where size was not a number: "+o);e=o,t=4,r=new Uint8Array(o),new DataView(r.buffer).setUint32(0,o,!1)},c=async function*(){const o=s[Symbol.asyncIterator]();for(;;){const{value:l,done:b}=await o.next();if(b){if(e)if(e===t)yield r;else throw new Error("Truncated event message received.");else return;return}const h=l.length;let i=0;for(;i<h;){if(!r){const f=h-i;a||(a=new Uint8Array(4));const u=Math.min(4-t,f);if(a.set(l.slice(i,i+u),t),t+=u,i+=u,t<4)break;n(new DataView(a.buffer).getUint32(0,!1)),a=null}const g=Math.min(e-t,h-i);r.set(l.slice(i,i+g),t),t+=g,i+=g,e&&e===t&&(yield r,r=null,e=0,t=0)}}};return{[Symbol.asyncIterator]:c}}function ce(s,e){return async function(t){const{value:r}=t.headers[":message-type"];if(r==="error"){const a=new Error(t.headers[":error-message"].value||"UnknownError");throw a.name=t.headers[":error-code"].value,a}else if(r==="exception"){const a=t.headers[":exception-type"].value,n={[a]:t},c=await s(n);if(c.$unknown){const o=new Error(e(t.body));throw o.name=a,o}throw c[a]}else if(r==="event"){const a={[t.headers[":event-type"].value]:t},n=await s(a);return n.$unknown?void 0:n}else throw Error(`Unrecognizable event type: ${t.headers[":event-type"].value}`)}}let le=class{constructor({utf8Encoder:e,utf8Decoder:t}){y(this,"eventStreamCodec");y(this,"utfEncoder");this.eventStreamCodec=new re(e,t),this.utfEncoder=e}deserialize(e,t){const r=ie(e);return new ae({messageStream:new se({inputStream:r,decoder:this.eventStreamCodec}),deserializer:ce(t,this.utfEncoder)})}serialize(e,t){return new ne({messageStream:new oe({inputStream:e,serializer:t}),encoder:this.eventStreamCodec,includeEndFrame:!0})}};const ue=s=>({[Symbol.asyncIterator]:async function*(){const e=s.getReader();try{for(;;){const{done:t,value:r}=await e.read();if(t)return;yield r}}finally{e.releaseLock()}}}),fe=s=>{const e=s[Symbol.asyncIterator]();return new ReadableStream({async pull(t){const{done:r,value:a}=await e.next();if(r)return t.close();t.enqueue(a)}})};class ye{constructor({utf8Encoder:e,utf8Decoder:t}){y(this,"universalMarshaller");this.universalMarshaller=new le({utf8Decoder:t,utf8Encoder:e})}deserialize(e,t){const r=me(e)?ue(e):e;return this.universalMarshaller.deserialize(r,t)}serialize(e,t){const r=this.universalMarshaller.serialize(e,t);return typeof ReadableStream=="function"?fe(r):r}}const me=s=>typeof ReadableStream=="function"&&s instanceof ReadableStream,ze=s=>new ye(s);class xe{constructor({marshaller:e,serializer:t,deserializer:r,serdeContext:a,defaultContentType:n,compositeErrorRegistry:c}){y(this,"marshaller");y(this,"serializer");y(this,"deserializer");y(this,"serdeContext");y(this,"defaultContentType");y(this,"compositeErrorRegistry");
1this.marshaller=e,this.serializer=t,this.deserializer=r,this.serdeContext=a,this.defaultContentType=n,this.compositeErrorRegistry=c}async serializeEventStream({eventStream:e,requestSchema:t,initialRequest:r}){const a=this.marshaller,n=t.getEventStreamMember(),c=t.getMemberSchema(n),o=this.serializer,l=this.defaultContentType,b=Symbol("initialRequestMarker"),h={async*[Symbol.asyncIterator](){if(r){const i={":event-type":{type:"string",value:"initial-request"},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:l}};o.write(t,r);const g=o.flush();yield{[b]:!0,headers:i,body:g}}for await(const i of e)yield i}};return a.serialize(h,i=>{if(i[b])return{headers:i.headers,body:i.body};let g="";for(const d in i)if(d!=="__type"){g=d;break}const{additionalHeaders:f,body:u,eventType:w,explicitPayloadContentType:k}=this.writeEventBody(g,c,i);return{headers:{":event-type":{type:"string",value:w},":message-type":{type:"string",value:"event"},":content-type":{type:"string",value:k??l},...f},body:u}})}async deserializeEventStream({response:e,responseSchema:t,initialResponseContainer:r}){var g;const a=this.marshaller,n=t.getEventStreamMember(),o=t.getMemberSchema(n).getMemberSchemas(),l=Symbol("initialResponseMarker"),b=a.deserialize(e.body,async f=>{var k,T;let u="";for(const d in f)if(d!=="__type"){u=d;break}const w=f[u].body;if(u==="initial-response"){const d=await this.deserializer.read(t,w);return delete d[n],{[l]:!0,...d}}else if(u in o){const d=o[u];if(d.isStructSchema()){const p={};let x=!1;for(const[v,I]of d.structIterator()){const{eventHeader:O,eventPayload:A}=I.getMergedTraits();if(x=x||!!(O||A),A)I.isBlobSchema()?p[v]=w:I.isStringSchema()?p[v]=(((k=this.serdeContext)==null?void 0:k.utf8Encoder)??q)(w):I.isStructSchema()&&(p[v]=await this.deserializer.read(I,w));else if(O){const M=(T=f[u].headers[v])==null?void 0:T.value;M!=null&&(I.isNumericSchema()?M&&typeof M=="object"&&"bytes"in M?p[v]=BigInt(M.toString()):p[v]=Number(M):p[v]=M)}}return{[u]:await this.readEventMember(d,w,x,p)}}return{[u]:await this.deserializer.read(d,w)}}else return{$unknown:f}}),h=b[Symbol.asyncIterator](),i=await h.next();if(i.done)return b;if((g=i.value)!=null&&g[l]){if(!t)throw new Error("@smithy::core/protocols - initial-response event encountered in event stream but no response schema given.");for(const f in i.value)r[f]=i.value[f]}return{async*[Symbol.asyncIterator](){var f;for((f=i==null?void 0:i.value)!=null&&f[l]||(yield i.value);;){const{done:u,value:w}=await h.next();if(u)break;yield w}}}}async readEventMember(e,t,r,a){var l,b;let n;const c=e.getSchema();if(Array.isArray(c)&&c[0]===-3){const h=c[1],i=D.for(h);(l=this.compositeErrorRegistry)==null||l.copyFrom(i),n=(b=this.compositeErrorRegistry??i)==null?void 0:b.getErrorCtor(c)}const o=r?a:t.byteLength===0?{}:await this.deserializer.read(e,t);if(n){const h=o.message??o.Message??"Unknown",i={},g=e.getMergedTraits().error;return g&&(i.$fault=g),Object.assign(new n({}),i,{message:h},o)}return o}writeEventBody(e,t,r){var g;const a=this.serializer;let n=e,c=null,o;const l=t.getSchema()[4].includes(e),b={};if(l){const f=t.getMemberSchema(e);if(f.isStructSchema()){for(const[u,w]of f.structIterator()){const{eventHeader:k,eventPayload:T}=w.getMergedTraits();if(T)c=u;else if(k){const d=r[e][u];let p="binary";w.isNumericSchema()?(-2)**31<=d&&d<=2**31-1?p="integer":p="long":w.isTimestampSchema()?p="timestamp":w.isStringSchema()?p="string":w.isBooleanSchema()&&(p="boolean"),d!=null&&(b[u]={type:p,value:d},delete r[e][u])}}if(c!==null){const u=f.getMemberSchema(c);u.isBlobSchema()?o="application/octet-stream":u.isStringSchema()&&(o="text/plain"),a.write(u,r[e][c])}else a.write(f,r[e])}else if(f.isUnitSchema())a.write(f,{});else throw new Error("@smithy/core/event-streams - non-struct member not supported in event stream union.")}else{const[f,u]=r[e];n=f,a.write(15,u)}const h=a.flush()??new Uint8Array;return{body:typeof h=="string"?(((g=this.serdeContext)==null?void 0:g.utf8Decoder)??J)(h):h,eventType:n,explicitPayloadContentType:o,additionalHeaders:b}}}export{re as EventStreamCodec,ye as EventStreamMarshaller,xe as EventStreamSerde,W as HeaderMarshaller,z as Int64,se as MessageDecoderStream,ne as MessageEncoder
1Stream,ae as SmithyMessageDecoderStream,oe as SmithyMessageEncoderStream,le as UniversalEventStreamMarshaller,ze as eventStreamSerdeProvider,ie as getChunkedStream,ce as getMessageUnmarshaller,fe as iterableToReadableStream,ue as readableStreamToIterable};
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.