1 line
87 KiB
JavaScript
1 line
87 KiB
JavaScript
"use strict";exports.id=496,exports.ids=[496],exports.modules={18496:(a,b,c)=>{function d(a,b){if(!a)throw Error(b)}function e(a){if("number"!=typeof a)throw Error("invalid int 32: "+typeof a);if(!Number.isInteger(a)||a>0x7fffffff||a<-0x80000000)throw Error("invalid int 32: "+a)}function f(a){if("number"!=typeof a)throw Error("invalid uint 32: "+typeof a);if(!Number.isInteger(a)||a>0xffffffff||a<0)throw Error("invalid uint 32: "+a)}function g(a){if("number"!=typeof a)throw Error("invalid float 32: "+typeof a);if(Number.isFinite(a)&&(a>34028234663852886e22||a<-34028234663852886e22))throw Error("invalid float 32: "+a)}c.d(b,{mk:()=>cP,iz:()=>cV});let h=Symbol("@bufbuild/protobuf/enum-type");function i(a,b,c,d){a[h]=j(b,c.map(b=>({no:b.no,name:b.name,localName:a[b.no]})),d)}function j(a,b,c){let d=Object.create(null),e=Object.create(null),f=[];for(let a of b){let b=k(a);f.push(b),d[a.name]=b,e[a.no]=b}return{typeName:a,values:f,findName:a=>d[a],findNumber:a=>e[a]}}function k(a){return"localName"in a?a:Object.assign(Object.assign({},a),{localName:a.name})}class l{equals(a){return this.getType().runtime.util.equals(this.getType(),this,a)}clone(){return this.getType().runtime.util.clone(this)}fromBinary(a,b){let c=this.getType().runtime.bin,d=c.makeReadOptions(b);return c.readMessage(this,d.readerFactory(a),a.byteLength,d),this}fromJson(a,b){let c=this.getType(),d=c.runtime.json,e=d.makeReadOptions(b);return d.readMessage(c,a,e,this),this}fromJsonString(a,b){let c;try{c=JSON.parse(a)}catch(a){throw Error(`cannot decode ${this.getType().typeName} from JSON: ${a instanceof Error?a.message:String(a)}`)}return this.fromJson(c,b)}toBinary(a){let b=this.getType().runtime.bin,c=b.makeWriteOptions(a),d=c.writerFactory();return b.writeMessage(this,d,c),d.finish()}toJson(a){let b=this.getType().runtime.json,c=b.makeWriteOptions(a);return b.writeMessage(this,c)}toJsonString(a){var b;return JSON.stringify(this.toJson(a),null,null!=(b=null==a?void 0:a.prettySpaces)?b:0)}toJSON(){return this.toJson({emitDefaultValues:!0})}getType(){return Object.getPrototypeOf(this).constructor}}function m(){let a=0,b=0;for(let c=0;c<28;c+=7){let d=this.buf[this.pos++];if(a|=(127&d)<<c,(128&d)==0)return this.assertBounds(),[a,b]}let c=this.buf[this.pos++];if(a|=(15&c)<<28,b=(112&c)>>4,(128&c)==0)return this.assertBounds(),[a,b];for(let c=3;c<=31;c+=7){let d=this.buf[this.pos++];if(b|=(127&d)<<c,(128&d)==0)return this.assertBounds(),[a,b]}throw Error("invalid varint")}function n(a,b,c){for(let d=0;d<28;d+=7){let e=a>>>d,f=e>>>7!=0||0!=b,g=(f?128|e:e)&255;if(c.push(g),!f)return}let d=a>>>28&15|(7&b)<<4,e=b>>3!=0;if(c.push((e?128|d:d)&255),e){for(let a=3;a<31;a+=7){let d=b>>>a,e=d>>>7!=0,f=(e?128|d:d)&255;if(c.push(f),!e)return}c.push(b>>>31&1)}}function o(a){let b="-"===a[0];b&&(a=a.slice(1));let c=0,d=0;function e(b,e){let f=Number(a.slice(b,e));d*=1e6,(c=1e6*c+f)>=0x100000000&&(d+=c/0x100000000|0,c%=0x100000000)}return e(-24,-18),e(-18,-12),e(-12,-6),e(-6),b?r(c,d):q(c,d)}function p(a,b){if({lo:a,hi:b}={lo:a>>>0,hi:b>>>0},b<=2097151)return String(0x100000000*b+a);let c=0xffffff&a,d=(a>>>24|b<<8)&0xffffff,e=b>>16&65535,f=c+6777216*d+6710656*e,g=d+8147497*e,h=2*e;return f>=1e7&&(g+=Math.floor(f/1e7),f%=1e7),g>=1e7&&(h+=Math.floor(g/1e7),g%=1e7),h.toString()+s(g)+s(f)}function q(a,b){return{lo:0|a,hi:0|b}}function r(a,b){return b=~b,a?a=~a+1:b+=1,q(a,b)}let s=a=>{let b=String(a);return"0000000".slice(b.length)+b};function t(a,b){if(a>=0){for(;a>127;)b.push(127&a|128),a>>>=7;b.push(a)}else{for(let c=0;c<9;c++)b.push(127&a|128),a>>=7;b.push(1)}}function u(){let a=this.buf[this.pos++],b=127&a;if((128&a)==0||(b|=(127&(a=this.buf[this.pos++]))<<7,(128&a)==0)||(b|=(127&(a=this.buf[this.pos++]))<<14,(128&a)==0)||(b|=(127&(a=this.buf[this.pos++]))<<21,(128&a)==0))return this.assertBounds(),b;b|=(15&(a=this.buf[this.pos++]))<<28;for(let b=5;(128&a)!=0&&b<10;b++)a=this.buf[this.pos++];if((128&a)!=0)throw Error("invalid varint");return this.assertBounds(),b>>>0}let v=function(){let a=new DataView(new ArrayBuffer(8));if("function"==typeof BigInt&&"function"==typeof a.getBigInt64&&"function"==typeof a.getBigUint64&&"function"==typeof a.setBigInt64&&"function"==typeof a.setBigUint64&&("object"!=typeof process||"object"!=typeof process.env||"1"!==process.env.BUF_BIGINT_DISABLE)){let b=BigInt("-9223372036854775808"),c=BigInt("9223372036854775807"),d=BigInt("0"),e=BigInt("18446744073709551615");return{zero:BigInt(0),supported:!0,parse(a){let d="bigint"==typeof a?a:BigInt(a);if(d>c||d<b)throw Error(`int64 invalid: ${a}`);return d},uParse(a){let b="bigint"==typeof a?a:BigInt(a);if(b>e||b<d)throw Error(`uint64 invalid: ${a}`);return b},enc(b){return a.setBigInt64(0,this.parse(b),!0),{lo:a.getInt32(0,!0),hi:a.getInt32(4,!0)}},uEnc(b){return a.setBigInt64(0,this.uParse(b),!0),{lo:a.getInt32(0,!0),hi:a.getInt32(4,!0)}},dec:(b,c)=>(a.setInt32(0,b,!0),a.setInt32(4,c,!0),a.getBigInt64(0,!0)),uDec:(b,c)=>(a.setInt32(0,b,!0),a.setInt32(4,c,!0),a.getBigUint64(0,!0))}}let b=a=>d(/^-?[0-9]+$/.test(a),`int64 invalid: ${a}`),c=a=>d(/^[0-9]+$/.test(a),`uint64 invalid: ${a}`);return{zero:"0",supported:!1,parse:a=>("string"!=typeof a&&(a=a.toString()),b(a),a),uParse:a=>("string"!=typeof a&&(a=a.toString()),c(a),a),enc:a=>("string"!=typeof a&&(a=a.toString()),b(a),o(a)),uEnc:a=>("string"!=typeof a&&(a=a.toString()),c(a),o(a)),dec:(a,b)=>(function(a,b){let c=q(a,b),d=0x80000000&c.hi;d&&(c=r(c.lo,c.hi));let e=p(c.lo,c.hi);return d?"-"+e:e})(a,b),uDec:(a,b)=>p(a,b)}}();function w(a,b,c){if(b===c)return!0;if(a==b6.BYTES){if(!(b instanceof Uint8Array)||!(c instanceof Uint8Array)||b.length!==c.length)return!1;for(let a=0;a<b.length;a++)if(b[a]!==c[a])return!1;return!0}switch(a){case b6.UINT64:case b6.FIXED64:case b6.INT64:case b6.SFIXED64:case b6.SINT64:return b==c}return!1}function x(a,b){switch(a){case b6.BOOL:return!1;case b6.UINT64:case b6.FIXED64:case b6.INT64:case b6.SFIXED64:case b6.SINT64:return 0==b?v.zero:"0";case b6.DOUBLE:case b6.FLOAT:return 0;case b6.BYTES:return new Uint8Array(0);case b6.STRING:return"";default:return 0}}function y(a,b){switch(a){case b6.BOOL:return!1===b;case b6.STRING:return""===b;case b6.BYTES:return b instanceof Uint8Array&&!b.byteLength;default:return 0==b}}function z(a){let b=a.field.localName,c=Object.create(null);return c[b]=function(a){let b=a.field;if(b.repeated)return[];if(void 0!==b.default)return b.default;switch(b.kind){case"enum":return b.T.values[0].no;case"scalar":return x(b.T,b.L);case"message":let c=b.T,d=new c;return c.fieldWrapper?c.fieldWrapper.unwrapField(d):d;case"map":throw"map fields are not allowed to be extensions"}}(a),[c,()=>c[b]]}!function(a){a[a.DOUBLE=1]="DOUBLE",a[a.FLOAT=2]="FLOAT",a[a.INT64=3]="INT64",a[a.UINT64=4]="UINT64",a[a.INT32=5]="INT32",a[a.FIXED64=6]="FIXED64",a[a.FIXED32=7]="FIXED32",a[a.BOOL=8]="BOOL",a[a.STRING=9]="STRING",a[a.BYTES=12]="BYTES",a[a.UINT32=13]="UINT32",a[a.SFIXED32=15]="SFIXED32",a[a.SFIXED64=16]="SFIXED64",a[a.SINT32=17]="SINT32",a[a.SINT64=18]="SINT64"}(b6||(b6={})),function(a){a[a.BIGINT=0]="BIGINT",a[a.STRING=1]="STRING"}(b7||(b7={}));let A="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/".split(""),B=[];for(let a=0;a<A.length;a++)B[A[a].charCodeAt(0)]=a;B[45]=A.indexOf("+"),B[95]=A.indexOf("/");let C={dec(a){let b=3*a.length/4;"="==a[a.length-2]?b-=2:"="==a[a.length-1]&&(b-=1);let c=new Uint8Array(b),d=0,e=0,f,g=0;for(let b=0;b<a.length;b++){if(void 0===(f=B[a.charCodeAt(b)]))switch(a[b]){case"=":e=0;case"\n":case"\r":case" ":case" ":continue;default:throw Error("invalid base64 string.")}switch(e){case 0:g=f,e=1;break;case 1:c[d++]=g<<2|(48&f)>>4,g=f,e=2;break;case 2:c[d++]=(15&g)<<4|(60&f)>>2,g=f,e=3;break;case 3:c[d++]=(3&g)<<6|f,e=0}}if(1==e)throw Error("invalid base64 string.");return c.subarray(0,d)},enc(a){let b="",c=0,d,e=0;for(let f=0;f<a.length;f++)switch(d=a[f],c){case 0:b+=A[d>>2],e=(3&d)<<4,c=1;break;case 1:b+=A[e|d>>4],e=(15&d)<<2,c=2;break;case 2:b+=A[e|d>>6],b+=A[63&d],c=0}return c&&(b+=A[e],b+="=",1==c&&(b+="=")),b}};function D(a,b){let c=a.getType();return b.extendee.typeName===c.typeName&&!!c.runtime.bin.listUnknownFields(a).find(a=>a.no==b.field.no)}function E(a,b){d(a.extendee.typeName==b.getType().typeName,`extension ${a.typeName} can only be applied to message ${a.extendee.typeName}`)}function F(a,b){let c=a.localName;if(a.repeated)return b[c].length>0;if(a.oneof)return b[a.oneof.localName].case===c;switch(a.kind){case"enum":case"scalar":if(a.opt||a.req)return void 0!==b[c];if("enum"==a.kind)return b[c]!==a.T.values[0].no;return!y(a.T,b[c]);case"message":return void 0!==b[c];case"map":return Object.keys(b[c]).length>0}}function G(a,b){let c=a.localName,d=!a.opt&&!a.req;if(a.repeated)b[c]=[];else if(a.oneof)b[a.oneof.localName]={case:void 0};else switch(a.kind){case"map":b[c]={};break;case"enum":b[c]=d?a.T.values[0].no:void 0;break;case"scalar":b[c]=d?x(a.T,a.L):void 0;break;case"message":b[c]=void 0}}function H(a,b){if(null===a||"object"!=typeof a||!Object.getOwnPropertyNames(l.prototype).every(b=>b in a&&"function"==typeof a[b]))return!1;let c=a.getType();return null!==c&&"function"==typeof c&&"typeName"in c&&"string"==typeof c.typeName&&(void 0===b||c.typeName==b.typeName)}function I(a,b){return H(b)||!a.fieldWrapper?b:a.fieldWrapper.wrapField(b)}b6.DOUBLE,b6.FLOAT,b6.INT64,b6.UINT64,b6.INT32,b6.UINT32,b6.BOOL,b6.STRING,b6.BYTES;let J={ignoreUnknownFields:!1},K={emitDefaultValues:!1,enumAsInteger:!1,useProtoFieldName:!1,prettySpaces:0},L=Symbol(),M=Symbol();function N(a){if(null===a)return"null";switch(typeof a){case"object":return Array.isArray(a)?"array":"object";case"string":return a.length>100?"string":`"${a.split('"').join('\\"')}"`;default:return String(a)}}function O(a,b,c,e,f){let g=c.localName;if(c.repeated){if(d("map"!=c.kind),null===b)return;if(!Array.isArray(b))throw Error(`cannot decode field ${f.typeName}.${c.name} from JSON: ${N(b)}`);let h=a[g];for(let a of b){if(null===a)throw Error(`cannot decode field ${f.typeName}.${c.name} from JSON: ${N(a)}`);switch(c.kind){case"message":h.push(c.T.fromJson(a,e));break;case"enum":let b=Q(c.T,a,e.ignoreUnknownFields,!0);b!==M&&h.push(b);break;case"scalar":try{h.push(P(c.T,a,c.L,!0))}catch(d){let b=`cannot decode field ${f.typeName}.${c.name} from JSON: ${N(a)}`;throw d instanceof Error&&d.message.length>0&&(b+=`: ${d.message}`),Error(b)}}}}else if("map"==c.kind){if(null===b)return;if("object"!=typeof b||Array.isArray(b))throw Error(`cannot decode field ${f.typeName}.${c.name} from JSON: ${N(b)}`);let d=a[g];for(let[a,g]of Object.entries(b)){let h;if(null===g)throw Error(`cannot decode field ${f.typeName}.${c.name} from JSON: map value null`);try{h=function(a,b){if(a===b6.BOOL)switch(b){case"true":b=!0;break;case"false":b=!1}return P(a,b,b7.BIGINT,!0).toString()}(c.K,a)}catch(d){let a=`cannot decode map key for field ${f.typeName}.${c.name} from JSON: ${N(b)}`;throw d instanceof Error&&d.message.length>0&&(a+=`: ${d.message}`),Error(a)}switch(c.V.kind){case"message":d[h]=c.V.T.fromJson(g,e);break;case"enum":let i=Q(c.V.T,g,e.ignoreUnknownFields,!0);i!==M&&(d[h]=i);break;case"scalar":try{d[h]=P(c.V.T,g,b7.BIGINT,!0)}catch(d){let a=`cannot decode map value for field ${f.typeName}.${c.name} from JSON: ${N(b)}`;throw d instanceof Error&&d.message.length>0&&(a+=`: ${d.message}`),Error(a)}}}}else switch(c.oneof&&(a=a[c.oneof.localName]={case:g},g="value"),c.kind){case"message":let h=c.T;if(null===b&&"google.protobuf.Value"!=h.typeName)return;let i=a[g];H(i)?i.fromJson(b,e):(a[g]=i=h.fromJson(b,e),h.fieldWrapper&&!c.oneof&&(a[g]=h.fieldWrapper.unwrapField(i)));break;case"enum":let j=Q(c.T,b,e.ignoreUnknownFields,!1);switch(j){case L:G(c,a);break;case M:break;default:a[g]=j}break;case"scalar":try{let d=P(c.T,b,c.L,!1);d===L?G(c,a):a[g]=d}catch(d){let a=`cannot decode field ${f.typeName}.${c.name} from JSON: ${N(b)}`;throw d instanceof Error&&d.message.length>0&&(a+=`: ${d.message}`),Error(a)}}}function P(a,b,c,d){if(null===b)return d?x(a,c):L;switch(a){case b6.DOUBLE:case b6.FLOAT:if("NaN"===b)return NaN;if("Infinity"===b)return 1/0;if("-Infinity"===b)return-1/0;if(""===b||"string"==typeof b&&b.trim().length!==b.length||"string"!=typeof b&&"number"!=typeof b)break;let h=Number(b);if(Number.isNaN(h)||!Number.isFinite(h))break;return a==b6.FLOAT&&g(h),h;case b6.INT32:case b6.FIXED32:case b6.SFIXED32:case b6.SINT32:case b6.UINT32:let i;if("number"==typeof b?i=b:"string"==typeof b&&b.length>0&&b.trim().length===b.length&&(i=Number(b)),void 0===i)break;return a==b6.UINT32||a==b6.FIXED32?f(i):e(i),i;case b6.INT64:case b6.SFIXED64:case b6.SINT64:if("number"!=typeof b&&"string"!=typeof b)break;let j=v.parse(b);return c?j.toString():j;case b6.FIXED64:case b6.UINT64:if("number"!=typeof b&&"string"!=typeof b)break;let k=v.uParse(b);return c?k.toString():k;case b6.BOOL:if("boolean"!=typeof b)break;return b;case b6.STRING:if("string"!=typeof b)break;try{encodeURIComponent(b)}catch(a){throw Error("invalid UTF8")}return b;case b6.BYTES:if(""===b)return new Uint8Array(0);if("string"!=typeof b)break;return C.dec(b)}throw Error()}function Q(a,b,c,d){if(null===b)return"google.protobuf.NullValue"==a.typeName?0:d?a.values[0].no:L;switch(typeof b){case"number":if(Number.isInteger(b))return b;break;case"string":let e=a.findName(b);if(void 0!==e)return e.no;if(c)return M}throw Error(`cannot decode enum ${a.typeName} from JSON: ${N(b)}`)}function R(a,b,c){if("map"==a.kind){d("object"==typeof b&&null!=b);let e={},f=Object.entries(b);switch(a.V.kind){case"scalar":for(let[b,c]of f)e[b.toString()]=T(a.V.T,c);break;case"message":for(let[a,b]of f)e[a.toString()]=b.toJson(c);break;case"enum":let g=a.V.T;for(let[a,b]of f)e[a.toString()]=S(g,b,c.enumAsInteger)}return c.emitDefaultValues||f.length>0?e:void 0}if(a.repeated){d(Array.isArray(b));let e=[];switch(a.kind){case"scalar":for(let c=0;c<b.length;c++)e.push(T(a.T,b[c]));break;case"enum":for(let d=0;d<b.length;d++)e.push(S(a.T,b[d],c.enumAsInteger));break;case"message":for(let a=0;a<b.length;a++)e.push(b[a].toJson(c))}return c.emitDefaultValues||e.length>0?e:void 0}switch(a.kind){case"scalar":return T(a.T,b);case"enum":return S(a.T,b,c.enumAsInteger);case"message":return I(a.T,b).toJson(c)}}function S(a,b,c){var e;if(d("number"==typeof b),"google.protobuf.NullValue"==a.typeName)return null;if(c)return b;let f=a.findNumber(b);return null!=(e=null==f?void 0:f.name)?e:b}function T(a,b){switch(a){case b6.INT32:case b6.SFIXED32:case b6.SINT32:case b6.FIXED32:case b6.UINT32:return d("number"==typeof b),b;case b6.FLOAT:case b6.DOUBLE:if(d("number"==typeof b),Number.isNaN(b))return"NaN";if(b===1/0)return"Infinity";if(b===-1/0)return"-Infinity";return b;case b6.STRING:return d("string"==typeof b),b;case b6.BOOL:return d("boolean"==typeof b),b;case b6.UINT64:case b6.FIXED64:case b6.INT64:case b6.SFIXED64:case b6.SINT64:return d("bigint"==typeof b||"string"==typeof b||"number"==typeof b),b.toString();case b6.BYTES:return d(b instanceof Uint8Array),C.enc(b)}}!function(a){a[a.Varint=0]="Varint",a[a.Bit64=1]="Bit64",a[a.LengthDelimited=2]="LengthDelimited",a[a.StartGroup=3]="StartGroup",a[a.EndGroup=4]="EndGroup",a[a.Bit32=5]="Bit32"}(b8||(b8={}));class U{constructor(a){this.stack=[],this.textEncoder=null!=a?a:new TextEncoder,this.chunks=[],this.buf=[]}finish(){this.chunks.push(new Uint8Array(this.buf));let a=0;for(let b=0;b<this.chunks.length;b++)a+=this.chunks[b].length;let b=new Uint8Array(a),c=0;for(let a=0;a<this.chunks.length;a++)b.set(this.chunks[a],c),c+=this.chunks[a].length;return this.chunks=[],b}fork(){return this.stack.push({chunks:this.chunks,buf:this.buf}),this.chunks=[],this.buf=[],this}join(){let a=this.finish(),b=this.stack.pop();if(!b)throw Error("invalid state, fork stack empty");return this.chunks=b.chunks,this.buf=b.buf,this.uint32(a.byteLength),this.raw(a)}tag(a,b){return this.uint32((a<<3|b)>>>0)}raw(a){return this.buf.length&&(this.chunks.push(new Uint8Array(this.buf)),this.buf=[]),this.chunks.push(a),this}uint32(a){for(f(a);a>127;)this.buf.push(127&a|128),a>>>=7;return this.buf.push(a),this}int32(a){return e(a),t(a,this.buf),this}bool(a){return this.buf.push(+!!a),this}bytes(a){return this.uint32(a.byteLength),this.raw(a)}string(a){let b=this.textEncoder.encode(a);return this.uint32(b.byteLength),this.raw(b)}float(a){g(a);let b=new Uint8Array(4);return new DataView(b.buffer).setFloat32(0,a,!0),this.raw(b)}double(a){let b=new Uint8Array(8);return new DataView(b.buffer).setFloat64(0,a,!0),this.raw(b)}fixed32(a){f(a);let b=new Uint8Array(4);return new DataView(b.buffer).setUint32(0,a,!0),this.raw(b)}sfixed32(a){e(a);let b=new Uint8Array(4);return new DataView(b.buffer).setInt32(0,a,!0),this.raw(b)}sint32(a){return e(a),t(a=(a<<1^a>>31)>>>0,this.buf),this}sfixed64(a){let b=new Uint8Array(8),c=new DataView(b.buffer),d=v.enc(a);return c.setInt32(0,d.lo,!0),c.setInt32(4,d.hi,!0),this.raw(b)}fixed64(a){let b=new Uint8Array(8),c=new DataView(b.buffer),d=v.uEnc(a);return c.setInt32(0,d.lo,!0),c.setInt32(4,d.hi,!0),this.raw(b)}int64(a){let b=v.enc(a);return n(b.lo,b.hi,this.buf),this}sint64(a){let b=v.enc(a),c=b.hi>>31;return n(b.lo<<1^c,(b.hi<<1|b.lo>>>31)^c,this.buf),this}uint64(a){let b=v.uEnc(a);return n(b.lo,b.hi,this.buf),this}}class V{constructor(a,b){this.varint64=m,this.uint32=u,this.buf=a,this.len=a.length,this.pos=0,this.view=new DataView(a.buffer,a.byteOffset,a.byteLength),this.textDecoder=null!=b?b:new TextDecoder}tag(){let a=this.uint32(),b=a>>>3,c=7&a;if(b<=0||c<0||c>5)throw Error("illegal tag: field no "+b+" wire type "+c);return[b,c]}skip(a,b){let c=this.pos;switch(a){case b8.Varint:for(;128&this.buf[this.pos++];);break;case b8.Bit64:this.pos+=4;case b8.Bit32:this.pos+=4;break;case b8.LengthDelimited:let d=this.uint32();this.pos+=d;break;case b8.StartGroup:for(;;){let[a,c]=this.tag();if(c===b8.EndGroup){if(void 0!==b&&a!==b)throw Error("invalid end group tag");break}this.skip(c,a)}break;default:throw Error("cant skip wire type "+a)}return this.assertBounds(),this.buf.subarray(c,this.pos)}assertBounds(){if(this.pos>this.len)throw RangeError("premature EOF")}int32(){return 0|this.uint32()}sint32(){let a=this.uint32();return a>>>1^-(1&a)}int64(){return v.dec(...this.varint64())}uint64(){return v.uDec(...this.varint64())}sint64(){let[a,b]=this.varint64(),c=-(1&a);return a=(a>>>1|(1&b)<<31)^c,b=b>>>1^c,v.dec(a,b)}bool(){let[a,b]=this.varint64();return 0!==a||0!==b}fixed32(){return this.view.getUint32((this.pos+=4)-4,!0)}sfixed32(){return this.view.getInt32((this.pos+=4)-4,!0)}fixed64(){return v.uDec(this.sfixed32(),this.sfixed32())}sfixed64(){return v.dec(this.sfixed32(),this.sfixed32())}float(){return this.view.getFloat32((this.pos+=4)-4,!0)}double(){return this.view.getFloat64((this.pos+=8)-8,!0)}bytes(){let a=this.uint32(),b=this.pos;return this.pos+=a,this.assertBounds(),this.buf.subarray(b,b+a)}string(){return this.textDecoder.decode(this.bytes())}}let W=Symbol("@bufbuild/protobuf/unknown-fields"),X={readUnknownFields:!0,readerFactory:a=>new V(a)},Y={writeUnknownFields:!0,writerFactory:()=>new U};function Z(a,b,c,d,e){let{repeated:f,localName:g}=c;switch(c.oneof&&((a=a[c.oneof.localName]).case!=g&&delete a.value,a.case=g,g="value"),c.kind){case"scalar":case"enum":let h="enum"==c.kind?b6.INT32:c.T,i=aa;if("scalar"==c.kind&&c.L>0&&(i=_),f){let c=a[g];if(d==b8.LengthDelimited&&h!=b6.STRING&&h!=b6.BYTES){let a=b.uint32()+b.pos;for(;b.pos<a;)c.push(i(b,h))}else c.push(i(b,h))}else a[g]=i(b,h);break;case"message":let j=c.T;f?a[g].push($(b,new j,e,c)):H(a[g])?$(b,a[g],e,c):(a[g]=$(b,new j,e,c),!j.fieldWrapper||c.oneof||c.repeated||(a[g]=j.fieldWrapper.unwrapField(a[g])));break;case"map":let[k,l]=function(a,b,c){let d,e,f=b.uint32(),g=b.pos+f;for(;b.pos<g;){let[f]=b.tag();switch(f){case 1:d=aa(b,a.K);break;case 2:switch(a.V.kind){case"scalar":e=aa(b,a.V.T);break;case"enum":e=b.int32();break;case"message":e=$(b,new a.V.T,c,void 0)}}}if(void 0===d&&(d=x(a.K,b7.BIGINT)),"string"!=typeof d&&"number"!=typeof d&&(d=d.toString()),void 0===e)switch(a.V.kind){case"scalar":e=x(a.V.T,b7.BIGINT);break;case"enum":e=a.V.T.values[0].no;break;case"message":e=new a.V.T}return[d,e]}(c,b,e);a[g][k]=l}}function $(a,b,c,d){let e=b.getType().runtime.bin,f=null==d?void 0:d.delimited;return e.readMessage(b,a,f?d.no:a.uint32(),c,f),b}function _(a,b){let c=aa(a,b);return"bigint"==typeof c?c.toString():c}function aa(a,b){switch(b){case b6.STRING:return a.string();case b6.BOOL:return a.bool();case b6.DOUBLE:return a.double();case b6.FLOAT:return a.float();case b6.INT32:return a.int32();case b6.INT64:return a.int64();case b6.UINT64:return a.uint64();case b6.FIXED64:return a.fixed64();case b6.BYTES:return a.bytes();case b6.FIXED32:return a.fixed32();case b6.SFIXED32:return a.sfixed32();case b6.SFIXED64:return a.sfixed64();case b6.SINT64:return a.sint64();case b6.UINT32:return a.uint32();case b6.SINT32:return a.sint32()}}function ab(a,b,c,e){d(void 0!==b);let f=a.repeated;switch(a.kind){case"scalar":case"enum":let g="enum"==a.kind?b6.INT32:a.T;if(f)if(d(Array.isArray(b)),a.packed)!function(a,b,c,d){if(!d.length)return;a.tag(c,b8.LengthDelimited).fork();let[,e]=ae(b);for(let b=0;b<d.length;b++)a[e](d[b]);a.join()}(c,g,a.no,b);else for(let d of b)ad(c,g,a.no,d);else ad(c,g,a.no,b);break;case"message":if(f)for(let f of(d(Array.isArray(b)),b))ac(c,e,a,f);else ac(c,e,a,b);break;case"map":for(let[f,g]of(d("object"==typeof b&&null!=b),Object.entries(b)))!function(a,b,c,e,f){a.tag(c.no,b8.LengthDelimited),a.fork();let g=e;switch(c.K){case b6.INT32:case b6.FIXED32:case b6.UINT32:case b6.SFIXED32:case b6.SINT32:g=Number.parseInt(e);break;case b6.BOOL:d("true"==e||"false"==e),g="true"==e}switch(ad(a,c.K,1,g),c.V.kind){case"scalar":ad(a,c.V.T,2,f);break;case"enum":ad(a,b6.INT32,2,f);break;case"message":d(void 0!==f),a.tag(2,b8.LengthDelimited).bytes(f.toBinary(b))}a.join()}(c,e,a,f,g)}}function ac(a,b,c,d){let e=I(c.T,d);c.delimited?a.tag(c.no,b8.StartGroup).raw(e.toBinary(b)).tag(c.no,b8.EndGroup):a.tag(c.no,b8.LengthDelimited).bytes(e.toBinary(b))}function ad(a,b,c,e){d(void 0!==e);let[f,g]=ae(b);a.tag(c,f)[g](e)}function ae(a){let b=b8.Varint;switch(a){case b6.BYTES:case b6.STRING:b=b8.LengthDelimited;break;case b6.DOUBLE:case b6.FIXED64:case b6.SFIXED64:b=b8.Bit64;break;case b6.FIXED32:case b6.SFIXED32:case b6.FLOAT:b=b8.Bit32}return[b,b6[a].toLowerCase()]}function af(a){if(void 0===a)return a;if(H(a))return a.clone();if(a instanceof Uint8Array){let b=new Uint8Array(a.byteLength);return b.set(a),b}return a}function ag(a){return a instanceof Uint8Array?a:new Uint8Array(a)}class ah{constructor(a,b){this._fields=a,this._normalizer=b}findJsonName(a){if(!this.jsonNames){let a={};for(let b of this.list())a[b.jsonName]=a[b.name]=b;this.jsonNames=a}return this.jsonNames[a]}find(a){if(!this.numbers){let a={};for(let b of this.list())a[b.no]=b;this.numbers=a}return this.numbers[a]}list(){return this.all||(this.all=this._normalizer(this._fields)),this.all}byNumber(){return this.numbersAsc||(this.numbersAsc=this.list().concat().sort((a,b)=>a.no-b.no)),this.numbersAsc}byMember(){if(!this.members){let a;this.members=[];let b=this.members;for(let c of this.list())c.oneof?c.oneof!==a&&(a=c.oneof,b.push(a)):b.push(c)}return this.members}}function ai(a,b){let c=ak(a);return b?c:ap(ao(c))}let aj=ak;function ak(a){let b=!1,c=[];for(let d=0;d<a.length;d++){let e=a.charAt(d);switch(e){case"_":b=!0;break;case"0":case"1":case"2":case"3":case"4":case"5":case"6":case"7":case"8":case"9":c.push(e),b=!1;break;default:b&&(b=!1,e=e.toUpperCase()),c.push(e)}}return c.join("")}let al=new Set(["constructor","toString","toJSON","valueOf"]),am=new Set(["getType","clone","equals","fromBinary","fromJson","fromJsonString","toBinary","toJson","toJsonString","toObject"]),an=a=>`${a}$`,ao=a=>am.has(a)?an(a):a,ap=a=>al.has(a)?an(a):a;class aq{constructor(a){this.kind="oneof",this.repeated=!1,this.packed=!1,this.opt=!1,this.req=!1,this.default=void 0,this.fields=[],this.name=a,this.localName=ai(a,!1)}addField(a){d(a.oneof===this,`field ${a.name} not one of ${this.name}`),this.fields.push(a)}findField(a){if(!this._lookup){this._lookup=Object.create(null);for(let a=0;a<this.fields.length;a++)this._lookup[this.fields[a].localName]=this.fields[a]}return this._lookup[a]}}let ar=(b4=a=>new ah(a,a=>(function(a,b){var c,d,e,f,g,h;let i,j=[];for(let k of"function"==typeof a?a():a){if(k.localName=ai(k.name,void 0!==k.oneof),k.jsonName=null!=(c=k.jsonName)?c:aj(k.name),k.repeated=null!=(d=k.repeated)&&d,"scalar"==k.kind&&(k.L=null!=(e=k.L)?e:b7.BIGINT),k.delimited=null!=(f=k.delimited)&&f,k.req=null!=(g=k.req)&&g,k.opt=null!=(h=k.opt)&&h,void 0===k.packed&&(b?k.packed="enum"==k.kind||"scalar"==k.kind&&k.T!=b6.BYTES&&k.T!=b6.STRING:k.packed=!1),void 0!==k.oneof){let a="string"==typeof k.oneof?k.oneof:k.oneof.name;i&&i.name==a||(i=new aq(a)),k.oneof=i,i.addField(k)}j.push(k)}return j})(a,!0)),b5=a=>{for(let b of a.getType().fields.byMember()){if(b.opt)continue;let c=b.localName;if(b.repeated){a[c]=[];continue}switch(b.kind){case"oneof":a[c]={case:void 0};break;case"enum":a[c]=0;break;case"map":a[c]={};break;case"scalar":a[c]=x(b.T,b.L)}}},{syntax:"proto3",json:{makeReadOptions:function(a){return a?Object.assign(Object.assign({},J),a):J},makeWriteOptions:function(a){return a?Object.assign(Object.assign({},K),a):K},readMessage(a,b,c,d){if(null==b||Array.isArray(b)||"object"!=typeof b)throw Error(`cannot decode message ${a.typeName} from JSON: ${N(b)}`);d=null!=d?d:new a;let e=new Map,f=c.typeRegistry;for(let[g,h]of Object.entries(b)){let b=a.fields.findJsonName(g);if(b){if(b.oneof){if(null===h&&"scalar"==b.kind)continue;let c=e.get(b.oneof);if(void 0!==c)throw Error(`cannot decode message ${a.typeName} from JSON: multiple keys for oneof "${b.oneof.name}" present: "${c}", "${g}"`);e.set(b.oneof,g)}O(d,h,b,c,a)}else{let b=!1;if((null==f?void 0:f.findExtension)&&g.startsWith("[")&&g.endsWith("]")){let e=f.findExtension(g.substring(1,g.length-1));if(e&&e.extendee.typeName==a.typeName){b=!0;let[a,f]=z(e);O(a,h,e.field,c,e),function(a,b,c,d){E(b,a);let e=b.runtime.bin.makeReadOptions(d),f=b.runtime.bin.makeWriteOptions(d);if(D(a,b)){let c=a.getType().runtime.bin.listUnknownFields(a).filter(a=>a.no!=b.field.no);for(let b of(a.getType().runtime.bin.discardUnknownFields(a),c))a.getType().runtime.bin.onUnknownField(a,b.no,b.wireType,b.data)}let g=f.writerFactory(),h=b.field;h.opt||h.repeated||"enum"!=h.kind&&"scalar"!=h.kind||(h=Object.assign(Object.assign({},b.field),{opt:!0})),b.runtime.bin.writeField(h,c,g,f);let i=e.readerFactory(g.finish());for(;i.pos<i.len;){let[b,c]=i.tag(),d=i.skip(c,b);a.getType().runtime.bin.onUnknownField(a,b,c,d)}}(d,e,f(),c)}}if(!b&&!c.ignoreUnknownFields)throw Error(`cannot decode message ${a.typeName} from JSON: key "${g}" is unknown`)}}return d},writeMessage(a,b){let c,d=a.getType(),e={};try{for(c of d.fields.byNumber()){if(!F(c,a)){var f;if(c.req)throw"required field not set";if(!b.emitDefaultValues||!((f=c).repeated||"map"==f.kind||!f.oneof&&"message"!=f.kind&&!f.opt&&!f.req))continue}let d=c.oneof?a[c.oneof.localName].value:a[c.localName],g=R(c,d,b);void 0!==g&&(e[b.useProtoFieldName?c.name:c.jsonName]=g)}let g=b.typeRegistry;if(null==g?void 0:g.findExtensionFor)for(let c of d.runtime.bin.listUnknownFields(a)){let f=g.findExtensionFor(d.typeName,c.no);if(f&&D(a,f)){let c=function(a,b,c){E(b,a);let d=b.runtime.bin.makeReadOptions(c),e=function(a,b){if(!b.repeated&&("enum"==b.kind||"scalar"==b.kind)){for(let c=a.length-1;c>=0;--c)if(a[c].no==b.no)return[a[c]];return[]}return a.filter(a=>a.no===b.no)}(a.getType().runtime.bin.listUnknownFields(a),b.field),[f,g]=z(b);for(let a of e)b.runtime.bin.readField(f,d.readerFactory(a.data),b.field,a.wireType,d);return g()}(a,f,b),d=R(f.field,c,b);void 0!==d&&(e[f.field.jsonName]=d)}}}catch(e){let a=c?`cannot encode field ${d.typeName}.${c.name} to JSON`:`cannot encode message ${d.typeName} to JSON`,b=e instanceof Error?e.message:String(e);throw Error(a+(b.length>0?`: ${b}`:""))}return e},readScalar:(a,b,c)=>P(a,b,null!=c?c:b7.BIGINT,!0),writeScalar(a,b,c){if(void 0!==b&&(c||y(a,b)))return T(a,b)},debug:N},bin:{makeReadOptions:function(a){return a?Object.assign(Object.assign({},X),a):X},makeWriteOptions:function(a){return a?Object.assign(Object.assign({},Y),a):Y},listUnknownFields(a){var b;return null!=(b=a[W])?b:[]},discardUnknownFields(a){delete a[W]},writeUnknownFields(a,b){let c=a[W];if(c)for(let a of c)b.tag(a.no,a.wireType).raw(a.data)},onUnknownField(a,b,c,d){Array.isArray(a[W])||(a[W]=[]),a[W].push({no:b,wireType:c,data:d})},readMessage(a,b,c,d,e){let f,g,h=a.getType(),i=e?b.len:b.pos+c;for(;b.pos<i&&([f,g]=b.tag(),!0!==e||g!=b8.EndGroup);){let c=h.fields.find(f);if(!c){let c=b.skip(g,f);d.readUnknownFields&&this.onUnknownField(a,f,g,c);continue}Z(a,b,c,g,d)}if(e&&(g!=b8.EndGroup||f!==c))throw Error("invalid end group tag")},readField:Z,writeMessage(a,b,c){let d=a.getType();for(let e of d.fields.byNumber()){if(!F(e,a)){if(e.req)throw Error(`cannot encode field ${d.typeName}.${e.name} to binary: required field not set`);continue}let f=e.oneof?a[e.oneof.localName].value:a[e.localName];ab(e,f,b,c)}return c.writeUnknownFields&&this.writeUnknownFields(a,b),b},writeField(a,b,c,d){void 0!==b&&ab(a,b,c,d)}},util:Object.assign(Object.assign({},{setEnumType:i,initPartial(a,b){if(void 0!==a)for(let c of b.getType().fields.byMember()){let d=c.localName;if(null!=a[d])switch(c.kind){case"oneof":let e=a[d].case;if(void 0===e)continue;let f=c.findField(e),g=a[d].value;f&&"message"==f.kind&&!H(g,f.T)?g=new f.T(g):f&&"scalar"===f.kind&&f.T===b6.BYTES&&(g=ag(g)),b[d]={case:e,value:g};break;case"scalar":case"enum":let h=a[d];c.T===b6.BYTES&&(h=c.repeated?h.map(ag):ag(h)),b[d]=h;break;case"map":switch(c.V.kind){case"scalar":case"enum":if(c.V.T===b6.BYTES)for(let[c,e]of Object.entries(a[d]))b[d][c]=ag(e);else Object.assign(b[d],a[d]);break;case"message":let i=c.V.T;for(let c of Object.keys(a[d])){let e=a[d][c];i.fieldWrapper||(e=new i(e)),b[d][c]=e}}break;case"message":let j=c.T;if(c.repeated)b[d]=a[d].map(a=>H(a,j)?a:new j(a));else{let c=a[d];j.fieldWrapper?"google.protobuf.BytesValue"===j.typeName?b[d]=ag(c):b[d]=c:b[d]=H(c,j)?c:new j(c)}}}},equals:(a,b,c)=>b===c||!!b&&!!c&&a.fields.byMember().every(a=>{let d=b[a.localName],e=c[a.localName];if(a.repeated){if(d.length!==e.length)return!1;switch(a.kind){case"message":return d.every((b,c)=>a.T.equals(b,e[c]));case"scalar":return d.every((b,c)=>w(a.T,b,e[c]));case"enum":return d.every((a,b)=>w(b6.INT32,a,e[b]))}throw Error(`repeated cannot contain ${a.kind}`)}switch(a.kind){case"message":let f=d,g=e;return a.T.fieldWrapper&&(void 0===f||H(f)||(f=a.T.fieldWrapper.wrapField(f)),void 0===g||H(g)||(g=a.T.fieldWrapper.wrapField(g))),a.T.equals(f,g);case"enum":return w(b6.INT32,d,e);case"scalar":return w(a.T,d,e);case"oneof":if(d.case!==e.case)return!1;let h=a.findField(d.case);if(void 0===h)return!0;switch(h.kind){case"message":return h.T.equals(d.value,e.value);case"enum":return w(b6.INT32,d.value,e.value);case"scalar":return w(h.T,d.value,e.value)}throw Error(`oneof cannot contain ${h.kind}`);case"map":let i=Object.keys(d).concat(Object.keys(e));switch(a.V.kind){case"message":let j=a.V.T;return i.every(a=>j.equals(d[a],e[a]));case"enum":return i.every(a=>w(b6.INT32,d[a],e[a]));case"scalar":let k=a.V.T;return i.every(a=>w(k,d[a],e[a]))}}}),clone(a){let b=a.getType(),c=new b;for(let d of b.fields.byMember()){let b,e=a[d.localName];if(d.repeated)b=e.map(af);else if("map"==d.kind)for(let[a,f]of(b=c[d.localName],Object.entries(e)))b[a]=af(f);else b="oneof"==d.kind?d.findField(e.case)?{case:e.case,value:af(e.value)}:{case:void 0}:af(e);c[d.localName]=b}for(let d of b.runtime.bin.listUnknownFields(a))b.runtime.bin.onUnknownField(c,d.no,d.wireType,d.data);return c}}),{newFieldList:b4,initFields:b5}),makeMessageType(a,b,c){return function(a,b,c,d){var e;let f=null!=(e=null==d?void 0:d.localName)?e:b.substring(b.lastIndexOf(".")+1),g={[f]:function(b){a.util.initFields(this),a.util.initPartial(b,this)}}[f];return Object.setPrototypeOf(g.prototype,new l),Object.assign(g,{runtime:a,typeName:b,fields:a.util.newFieldList(c),fromBinary:(a,b)=>new g().fromBinary(a,b),fromJson:(a,b)=>new g().fromJson(a,b),fromJsonString:(a,b)=>new g().fromJsonString(a,b),equals:(b,c)=>a.util.equals(g,b,c)}),g}(this,a,b,c)},makeEnum:function(a,b,c){let d={};for(let a of b){let b=k(a);d[b.localName]=b.no,d[b.no]=b.localName}return i(d,a,b,c),d},makeEnumType:j,getEnumType:function(a){let b=a[h];return d(b,"missing enum type on enum object"),b},makeExtension(a,b,c){var d;let e;return d=this,{typeName:a,extendee:b,get field(){if(!e){let b="function"==typeof c?c():c;b.name=a.split(".").pop(),b.jsonName=`[${a}]`,e=d.util.newFieldList([b]).list()[0]}return e},runtime:d}}});class as extends l{constructor(a){super(),this.seconds=v.zero,this.nanos=0,ar.util.initPartial(a,this)}fromJson(a,b){if("string"!=typeof a)throw Error(`cannot decode google.protobuf.Duration from JSON: ${ar.json.debug(a)}`);let c=a.match(/^(-?[0-9]+)(?:\.([0-9]+))?s/);if(null===c)throw Error(`cannot decode google.protobuf.Duration from JSON: ${ar.json.debug(a)}`);let d=Number(c[1]);if(d>315576e6||d<-315576e6)throw Error(`cannot decode google.protobuf.Duration from JSON: ${ar.json.debug(a)}`);if(this.seconds=v.parse(d),"string"==typeof c[2]){let a=c[2]+"0".repeat(9-c[2].length);this.nanos=parseInt(a),(d<0||Object.is(d,-0))&&(this.nanos=-this.nanos)}return this}toJson(a){if(Number(this.seconds)>315576e6||-315576e6>Number(this.seconds))throw Error("cannot encode google.protobuf.Duration to JSON: value out of range");let b=this.seconds.toString();if(0!==this.nanos){let a=Math.abs(this.nanos).toString();"000000"===(a="0".repeat(9-a.length)+a).substring(3)?a=a.substring(0,3):"000"===a.substring(6)&&(a=a.substring(0,6)),b+="."+a,this.nanos<0&&0==Number(this.seconds)&&(b="-"+b)}return b+"s"}static fromBinary(a,b){return new as().fromBinary(a,b)}static fromJson(a,b){return new as().fromJson(a,b)}static fromJsonString(a,b){return new as().fromJsonString(a,b)}static equals(a,b){return ar.util.equals(as,a,b)}}as.runtime=ar,as.typeName="google.protobuf.Duration",as.fields=ar.util.newFieldList(()=>[{no:1,name:"seconds",kind:"scalar",T:3},{no:2,name:"nanos",kind:"scalar",T:5}]);let at=ar.makeEnum("livekit.AudioCodec",[{no:0,name:"DEFAULT_AC"},{no:1,name:"OPUS"},{no:2,name:"AAC"},{no:3,name:"AC_MP3"}]),au=ar.makeEnum("livekit.VideoCodec",[{no:0,name:"DEFAULT_VC"},{no:1,name:"H264_BASELINE"},{no:2,name:"H264_MAIN"},{no:3,name:"H264_HIGH"},{no:4,name:"VP8"}]),av=ar.makeEnum("livekit.ImageCodec",[{no:0,name:"IC_DEFAULT"},{no:1,name:"IC_JPEG"}]),aw=ar.makeEnum("livekit.BackupCodecPolicy",[{no:0,name:"PREFER_REGRESSION"},{no:1,name:"SIMULCAST"},{no:2,name:"REGRESSION"}]),ax=ar.makeEnum("livekit.TrackType",[{no:0,name:"AUDIO"},{no:1,name:"VIDEO"},{no:2,name:"DATA"}]),ay=ar.makeEnum("livekit.TrackSource",[{no:0,name:"UNKNOWN"},{no:1,name:"CAMERA"},{no:2,name:"MICROPHONE"},{no:3,name:"SCREEN_SHARE"},{no:4,name:"SCREEN_SHARE_AUDIO"}]),az=ar.makeEnum("livekit.VideoQuality",[{no:0,name:"LOW"},{no:1,name:"MEDIUM"},{no:2,name:"HIGH"},{no:3,name:"OFF"}]),aA=ar.makeEnum("livekit.DisconnectReason",[{no:0,name:"UNKNOWN_REASON"},{no:1,name:"CLIENT_INITIATED"},{no:2,name:"DUPLICATE_IDENTITY"},{no:3,name:"SERVER_SHUTDOWN"},{no:4,name:"PARTICIPANT_REMOVED"},{no:5,name:"ROOM_DELETED"},{no:6,name:"STATE_MISMATCH"},{no:7,name:"JOIN_FAILURE"},{no:8,name:"MIGRATION"},{no:9,name:"SIGNAL_CLOSE"},{no:10,name:"ROOM_CLOSED"},{no:11,name:"USER_UNAVAILABLE"},{no:12,name:"USER_REJECTED"},{no:13,name:"SIP_TRUNK_FAILURE"},{no:14,name:"CONNECTION_TIMEOUT"},{no:15,name:"MEDIA_FAILURE"}]),aB=ar.makeEnum("livekit.AudioTrackFeature",[{no:0,name:"TF_STEREO"},{no:1,name:"TF_NO_DTX"},{no:2,name:"TF_AUTO_GAIN_CONTROL"},{no:3,name:"TF_ECHO_CANCELLATION"},{no:4,name:"TF_NOISE_SUPPRESSION"},{no:5,name:"TF_ENHANCED_NOISE_CANCELLATION"},{no:6,name:"TF_PRECONNECT_BUFFER"}]),aC=(()=>[{no:1,name:"after_id",kind:"scalar",T:9},{no:2,name:"limit",kind:"scalar",T:5}],ar.makeMessageType("livekit.ListUpdate",()=>[{no:1,name:"set",kind:"scalar",T:9,repeated:!0},{no:2,name:"add",kind:"scalar",T:9,repeated:!0},{no:3,name:"remove",kind:"scalar",T:9,repeated:!0},{no:4,name:"clear",kind:"scalar",T:8}])),aD=ar.makeMessageType("livekit.Room",()=>[{no:1,name:"sid",kind:"scalar",T:9},{no:2,name:"name",kind:"scalar",T:9},{no:3,name:"empty_timeout",kind:"scalar",T:13},{no:14,name:"departure_timeout",kind:"scalar",T:13},{no:4,name:"max_participants",kind:"scalar",T:13},{no:5,name:"creation_time",kind:"scalar",T:3},{no:15,name:"creation_time_ms",kind:"scalar",T:3},{no:6,name:"turn_password",kind:"scalar",T:9},{no:7,name:"enabled_codecs",kind:"message",T:aE,repeated:!0},{no:8,name:"metadata",kind:"scalar",T:9},{no:9,name:"num_participants",kind:"scalar",T:13},{no:11,name:"num_publishers",kind:"scalar",T:13},{no:10,name:"active_recording",kind:"scalar",T:8},{no:13,name:"version",kind:"message",T:aR}]),aE=ar.makeMessageType("livekit.Codec",()=>[{no:1,name:"mime",kind:"scalar",T:9},{no:2,name:"fmtp_line",kind:"scalar",T:9}]),aF=ar.makeMessageType("livekit.ParticipantPermission",()=>[{no:1,name:"can_subscribe",kind:"scalar",T:8},{no:2,name:"can_publish",kind:"scalar",T:8},{no:3,name:"can_publish_data",kind:"scalar",T:8},{no:9,name:"can_publish_sources",kind:"enum",T:ar.getEnumType(ay),repeated:!0},{no:7,name:"hidden",kind:"scalar",T:8},{no:8,name:"recorder",kind:"scalar",T:8},{no:10,name:"can_update_metadata",kind:"scalar",T:8},{no:11,name:"agent",kind:"scalar",T:8},{no:12,name:"can_subscribe_metrics",kind:"scalar",T:8}]),aG=ar.makeMessageType("livekit.ParticipantInfo",()=>[{no:1,name:"sid",kind:"scalar",T:9},{no:2,name:"identity",kind:"scalar",T:9},{no:3,name:"state",kind:"enum",T:ar.getEnumType(aH)},{no:4,name:"tracks",kind:"message",T:aM,repeated:!0},{no:5,name:"metadata",kind:"scalar",T:9},{no:6,name:"joined_at",kind:"scalar",T:3},{no:17,name:"joined_at_ms",kind:"scalar",T:3},{no:9,name:"name",kind:"scalar",T:9},{no:10,name:"version",kind:"scalar",T:13},{no:11,name:"permission",kind:"message",T:aF},{no:12,name:"region",kind:"scalar",T:9},{no:13,name:"is_publisher",kind:"scalar",T:8},{no:14,name:"kind",kind:"enum",T:ar.getEnumType(aI)},{no:15,name:"attributes",kind:"map",K:9,V:{kind:"scalar",T:9}},{no:16,name:"disconnect_reason",kind:"enum",T:ar.getEnumType(aA)},{no:18,name:"kind_details",kind:"enum",T:ar.getEnumType(aJ),repeated:!0}]),aH=ar.makeEnum("livekit.ParticipantInfo.State",[{no:0,name:"JOINING"},{no:1,name:"JOINED"},{no:2,name:"ACTIVE"},{no:3,name:"DISCONNECTED"}]),aI=ar.makeEnum("livekit.ParticipantInfo.Kind",[{no:0,name:"STANDARD"},{no:1,name:"INGRESS"},{no:2,name:"EGRESS"},{no:3,name:"SIP"},{no:4,name:"AGENT"},{no:7,name:"CONNECTOR"}]),aJ=ar.makeEnum("livekit.ParticipantInfo.KindDetail",[{no:0,name:"CLOUD_AGENT"},{no:1,name:"FORWARDED"}]),aK=ar.makeEnum("livekit.Encryption.Type",[{no:0,name:"NONE"},{no:1,name:"GCM"},{no:2,name:"CUSTOM"}]),aL=ar.makeMessageType("livekit.SimulcastCodecInfo",()=>[{no:1,name:"mime_type",kind:"scalar",T:9},{no:2,name:"mid",kind:"scalar",T:9},{no:3,name:"cid",kind:"scalar",T:9},{no:4,name:"layers",kind:"message",T:aN,repeated:!0},{no:5,name:"video_layer_mode",kind:"enum",T:ar.getEnumType(aO)},{no:6,name:"sdp_cid",kind:"scalar",T:9}]),aM=ar.makeMessageType("livekit.TrackInfo",()=>[{no:1,name:"sid",kind:"scalar",T:9},{no:2,name:"type",kind:"enum",T:ar.getEnumType(ax)},{no:3,name:"name",kind:"scalar",T:9},{no:4,name:"muted",kind:"scalar",T:8},{no:5,name:"width",kind:"scalar",T:13},{no:6,name:"height",kind:"scalar",T:13},{no:7,name:"simulcast",kind:"scalar",T:8},{no:8,name:"disable_dtx",kind:"scalar",T:8},{no:9,name:"source",kind:"enum",T:ar.getEnumType(ay)},{no:10,name:"layers",kind:"message",T:aN,repeated:!0},{no:11,name:"mime_type",kind:"scalar",T:9},{no:12,name:"mid",kind:"scalar",T:9},{no:13,name:"codecs",kind:"message",T:aL,repeated:!0},{no:14,name:"stereo",kind:"scalar",T:8},{no:15,name:"disable_red",kind:"scalar",T:8},{no:16,name:"encryption",kind:"enum",T:ar.getEnumType(aK)},{no:17,name:"stream",kind:"scalar",T:9},{no:18,name:"version",kind:"message",T:aR},{no:19,name:"audio_features",kind:"enum",T:ar.getEnumType(aB),repeated:!0},{no:20,name:"backup_codec_policy",kind:"enum",T:ar.getEnumType(aw)}]),aN=ar.makeMessageType("livekit.VideoLayer",()=>[{no:1,name:"quality",kind:"enum",T:ar.getEnumType(az)},{no:2,name:"width",kind:"scalar",T:13},{no:3,name:"height",kind:"scalar",T:13},{no:4,name:"bitrate",kind:"scalar",T:13},{no:5,name:"ssrc",kind:"scalar",T:13},{no:6,name:"spatial_layer",kind:"scalar",T:5},{no:7,name:"rid",kind:"scalar",T:9}]),aO=ar.makeEnum("livekit.VideoLayer.Mode",[{no:0,name:"MODE_UNUSED"},{no:1,name:"ONE_SPATIAL_LAYER_PER_STREAM"},{no:2,name:"MULTIPLE_SPATIAL_LAYERS_PER_STREAM"},{no:3,name:"ONE_SPATIAL_LAYER_PER_STREAM_INCOMPLETE_RTCP_SR"}]),aP=ar.makeEnum("livekit.DataPacket.Kind",[{no:0,name:"RELIABLE"},{no:1,name:"LOSSY"}]),aQ=ar.makeMessageType("livekit.ParticipantTracks",()=>[{no:1,name:"participant_sid",kind:"scalar",T:9},{no:2,name:"track_sids",kind:"scalar",T:9,repeated:!0}]),aR=ar.makeMessageType("livekit.TimedVersion",()=>[{no:1,name:"unix_micro",kind:"scalar",T:3},{no:2,name:"ticks",kind:"scalar",T:5}]),aS=ar.makeEnum("livekit.DataStream.OperationType",[{no:0,name:"CREATE"},{no:1,name:"UPDATE"},{no:2,name:"DELETE"},{no:3,name:"REACTION"}]),aT=(()=>[{no:1,name:"operation_type",kind:"enum",T:ar.getEnumType(aS)},{no:2,name:"version",kind:"scalar",T:5},{no:3,name:"reply_to_stream_id",kind:"scalar",T:9},{no:4,name:"attached_stream_ids",kind:"scalar",T:9,repeated:!0},{no:5,name:"generated",kind:"scalar",T:8}],ar.makeMessageType("livekit.FilterParams",()=>[{no:1,name:"include_events",kind:"scalar",T:9,repeated:!0},{no:2,name:"exclude_events",kind:"scalar",T:9,repeated:!0}])),aU=ar.makeMessageType("livekit.WebhookConfig",()=>[{no:1,name:"url",kind:"scalar",T:9},{no:2,name:"signing_key",kind:"scalar",T:9},{no:3,name:"filter_params",kind:"message",T:aT}]),aV=ar.makeEnum("livekit.JobType",[{no:0,name:"JT_ROOM"},{no:1,name:"JT_PUBLISHER"},{no:2,name:"JT_PARTICIPANT"}]),aW=ar.makeEnum("livekit.JobStatus",[{no:0,name:"JS_PENDING"},{no:1,name:"JS_RUNNING"},{no:2,name:"JS_SUCCESS"},{no:3,name:"JS_FAILED"}]),aX=ar.makeMessageType("livekit.Job",()=>[{no:1,name:"id",kind:"scalar",T:9},{no:9,name:"dispatch_id",kind:"scalar",T:9},{no:2,name:"type",kind:"enum",T:ar.getEnumType(aV)},{no:3,name:"room",kind:"message",T:aD},{no:4,name:"participant",kind:"message",T:aG,opt:!0},{no:5,name:"namespace",kind:"scalar",T:9},{no:6,name:"metadata",kind:"scalar",T:9},{no:7,name:"agent_name",kind:"scalar",T:9},{no:8,name:"state",kind:"message",T:aY},{no:10,name:"enable_recording",kind:"scalar",T:8}]),aY=ar.makeMessageType("livekit.JobState",()=>[{no:1,name:"status",kind:"enum",T:ar.getEnumType(aW)},{no:2,name:"error",kind:"scalar",T:9},{no:3,name:"started_at",kind:"scalar",T:3},{no:4,name:"ended_at",kind:"scalar",T:3},{no:5,name:"updated_at",kind:"scalar",T:3},{no:6,name:"participant_identity",kind:"scalar",T:9},{no:7,name:"worker_id",kind:"scalar",T:9},{no:8,name:"agent_id",kind:"scalar",T:9}]),aZ=ar.makeMessageType("livekit.RoomAgentDispatch",()=>[{no:1,name:"agent_name",kind:"scalar",T:9},{no:2,name:"metadata",kind:"scalar",T:9}]),a$=(()=>[{no:1,name:"id",kind:"scalar",T:9},{no:2,name:"agent_name",kind:"scalar",T:9},{no:3,name:"room",kind:"scalar",T:9},{no:4,name:"metadata",kind:"scalar",T:9},{no:5,name:"state",kind:"message",T:a$}],ar.makeMessageType("livekit.AgentDispatchState",()=>[{no:1,name:"jobs",kind:"message",T:aX,repeated:!0},{no:2,name:"created_at",kind:"scalar",T:3},{no:3,name:"deleted_at",kind:"scalar",T:3}])),a_=ar.makeEnum("livekit.EncodedFileType",[{no:0,name:"DEFAULT_FILETYPE"},{no:1,name:"MP4"},{no:2,name:"OGG"},{no:3,name:"MP3"}]),a0=ar.makeEnum("livekit.SegmentedFileProtocol",[{no:0,name:"DEFAULT_SEGMENTED_FILE_PROTOCOL"},{no:1,name:"HLS_PROTOCOL"}]),a1=ar.makeEnum("livekit.SegmentedFileSuffix",[{no:0,name:"INDEX"},{no:1,name:"TIMESTAMP"}]),a2=ar.makeEnum("livekit.ImageFileSuffix",[{no:0,name:"IMAGE_SUFFIX_INDEX"},{no:1,name:"IMAGE_SUFFIX_TIMESTAMP"},{no:2,name:"IMAGE_SUFFIX_NONE_OVERWRITE"}]),a3=ar.makeEnum("livekit.StreamProtocol",[{no:0,name:"DEFAULT_PROTOCOL"},{no:1,name:"RTMP"},{no:2,name:"SRT"}]),a4=ar.makeEnum("livekit.AudioMixing",[{no:0,name:"DEFAULT_MIXING"},{no:1,name:"DUAL_CHANNEL_AGENT"},{no:2,name:"DUAL_CHANNEL_ALTERNATE"}]),a5=ar.makeEnum("livekit.EncodingOptionsPreset",[{no:0,name:"H264_720P_30"},{no:1,name:"H264_720P_60"},{no:2,name:"H264_1080P_30"},{no:3,name:"H264_1080P_60"},{no:4,name:"PORTRAIT_H264_720P_30"},{no:5,name:"PORTRAIT_H264_720P_60"},{no:6,name:"PORTRAIT_H264_1080P_30"},{no:7,name:"PORTRAIT_H264_1080P_60"}]),a6=ar.makeEnum("livekit.EgressStatus",[{no:0,name:"EGRESS_STARTING"},{no:1,name:"EGRESS_ACTIVE"},{no:2,name:"EGRESS_ENDING"},{no:3,name:"EGRESS_COMPLETE"},{no:4,name:"EGRESS_FAILED"},{no:5,name:"EGRESS_ABORTED"},{no:6,name:"EGRESS_LIMIT_REACHED"}]),a7=ar.makeEnum("livekit.EgressSourceType",[{no:0,name:"EGRESS_SOURCE_TYPE_WEB",localName:"WEB"},{no:1,name:"EGRESS_SOURCE_TYPE_SDK",localName:"SDK"}]),a8=ar.makeMessageType("livekit.RoomCompositeEgressRequest",()=>[{no:1,name:"room_name",kind:"scalar",T:9},{no:2,name:"layout",kind:"scalar",T:9},{no:3,name:"audio_only",kind:"scalar",T:8},{no:15,name:"audio_mixing",kind:"enum",T:ar.getEnumType(a4)},{no:4,name:"video_only",kind:"scalar",T:8},{no:5,name:"custom_base_url",kind:"scalar",T:9},{no:6,name:"file",kind:"message",T:bd,oneof:"output"},{no:7,name:"stream",kind:"message",T:bm,oneof:"output"},{no:10,name:"segments",kind:"message",T:be,oneof:"output"},{no:8,name:"preset",kind:"enum",T:ar.getEnumType(a5),oneof:"options"},{no:9,name:"advanced",kind:"message",T:bn,oneof:"options"},{no:11,name:"file_outputs",kind:"message",T:bd,repeated:!0},{no:12,name:"stream_outputs",kind:"message",T:bm,repeated:!0},{no:13,name:"segment_outputs",kind:"message",T:be,repeated:!0},{no:14,name:"image_outputs",kind:"message",T:bg,repeated:!0},{no:16,name:"webhooks",kind:"message",T:aU,repeated:!0}]),a9=ar.makeMessageType("livekit.WebEgressRequest",()=>[{no:1,name:"url",kind:"scalar",T:9},{no:2,name:"audio_only",kind:"scalar",T:8},{no:3,name:"video_only",kind:"scalar",T:8},{no:12,name:"await_start_signal",kind:"scalar",T:8},{no:4,name:"file",kind:"message",T:bd,oneof:"output"},{no:5,name:"stream",kind:"message",T:bm,oneof:"output"},{no:6,name:"segments",kind:"message",T:be,oneof:"output"},{no:7,name:"preset",kind:"enum",T:ar.getEnumType(a5),oneof:"options"},{no:8,name:"advanced",kind:"message",T:bn,oneof:"options"},{no:9,name:"file_outputs",kind:"message",T:bd,repeated:!0},{no:10,name:"stream_outputs",kind:"message",T:bm,repeated:!0},{no:11,name:"segment_outputs",kind:"message",T:be,repeated:!0},{no:13,name:"image_outputs",kind:"message",T:bg,repeated:!0},{no:14,name:"webhooks",kind:"message",T:aU,repeated:!0}]),ba=ar.makeMessageType("livekit.ParticipantEgressRequest",()=>[{no:1,name:"room_name",kind:"scalar",T:9},{no:2,name:"identity",kind:"scalar",T:9},{no:3,name:"screen_share",kind:"scalar",T:8},{no:4,name:"preset",kind:"enum",T:ar.getEnumType(a5),oneof:"options"},{no:5,name:"advanced",kind:"message",T:bn,oneof:"options"},{no:6,name:"file_outputs",kind:"message",T:bd,repeated:!0},{no:7,name:"stream_outputs",kind:"message",T:bm,repeated:!0},{no:8,name:"segment_outputs",kind:"message",T:be,repeated:!0},{no:9,name:"image_outputs",kind:"message",T:bg,repeated:!0},{no:10,name:"webhooks",kind:"message",T:aU,repeated:!0}]),bb=ar.makeMessageType("livekit.TrackCompositeEgressRequest",()=>[{no:1,name:"room_name",kind:"scalar",T:9},{no:2,name:"audio_track_id",kind:"scalar",T:9},{no:3,name:"video_track_id",kind:"scalar",T:9},{no:4,name:"file",kind:"message",T:bd,oneof:"output"},{no:5,name:"stream",kind:"message",T:bm,oneof:"output"},{no:8,name:"segments",kind:"message",T:be,oneof:"output"},{no:6,name:"preset",kind:"enum",T:ar.getEnumType(a5),oneof:"options"},{no:7,name:"advanced",kind:"message",T:bn,oneof:"options"},{no:11,name:"file_outputs",kind:"message",T:bd,repeated:!0},{no:12,name:"stream_outputs",kind:"message",T:bm,repeated:!0},{no:13,name:"segment_outputs",kind:"message",T:be,repeated:!0},{no:14,name:"image_outputs",kind:"message",T:bg,repeated:!0},{no:15,name:"webhooks",kind:"message",T:aU,repeated:!0}]),bc=ar.makeMessageType("livekit.TrackEgressRequest",()=>[{no:1,name:"room_name",kind:"scalar",T:9},{no:2,name:"track_id",kind:"scalar",T:9},{no:3,name:"file",kind:"message",T:bf,oneof:"output"},{no:4,name:"websocket_url",kind:"scalar",T:9,oneof:"output"},{no:5,name:"webhooks",kind:"message",T:aU,repeated:!0}]),bd=ar.makeMessageType("livekit.EncodedFileOutput",()=>[{no:1,name:"file_type",kind:"enum",T:ar.getEnumType(a_)},{no:2,name:"filepath",kind:"scalar",T:9},{no:6,name:"disable_manifest",kind:"scalar",T:8},{no:3,name:"s3",kind:"message",T:bh,oneof:"output"},{no:4,name:"gcp",kind:"message",T:bi,oneof:"output"},{no:5,name:"azure",kind:"message",T:bj,oneof:"output"},{no:7,name:"aliOSS",kind:"message",T:bk,oneof:"output"}]),be=ar.makeMessageType("livekit.SegmentedFileOutput",()=>[{no:1,name:"protocol",kind:"enum",T:ar.getEnumType(a0)},{no:2,name:"filename_prefix",kind:"scalar",T:9},{no:3,name:"playlist_name",kind:"scalar",T:9},{no:11,name:"live_playlist_name",kind:"scalar",T:9},{no:4,name:"segment_duration",kind:"scalar",T:13},{no:10,name:"filename_suffix",kind:"enum",T:ar.getEnumType(a1)},{no:8,name:"disable_manifest",kind:"scalar",T:8},{no:5,name:"s3",kind:"message",T:bh,oneof:"output"},{no:6,name:"gcp",kind:"message",T:bi,oneof:"output"},{no:7,name:"azure",kind:"message",T:bj,oneof:"output"},{no:9,name:"aliOSS",kind:"message",T:bk,oneof:"output"}]),bf=ar.makeMessageType("livekit.DirectFileOutput",()=>[{no:1,name:"filepath",kind:"scalar",T:9},{no:5,name:"disable_manifest",kind:"scalar",T:8},{no:2,name:"s3",kind:"message",T:bh,oneof:"output"},{no:3,name:"gcp",kind:"message",T:bi,oneof:"output"},{no:4,name:"azure",kind:"message",T:bj,oneof:"output"},{no:6,name:"aliOSS",kind:"message",T:bk,oneof:"output"}]),bg=ar.makeMessageType("livekit.ImageOutput",()=>[{no:1,name:"capture_interval",kind:"scalar",T:13},{no:2,name:"width",kind:"scalar",T:5},{no:3,name:"height",kind:"scalar",T:5},{no:4,name:"filename_prefix",kind:"scalar",T:9},{no:5,name:"filename_suffix",kind:"enum",T:ar.getEnumType(a2)},{no:6,name:"image_codec",kind:"enum",T:ar.getEnumType(av)},{no:7,name:"disable_manifest",kind:"scalar",T:8},{no:8,name:"s3",kind:"message",T:bh,oneof:"output"},{no:9,name:"gcp",kind:"message",T:bi,oneof:"output"},{no:10,name:"azure",kind:"message",T:bj,oneof:"output"},{no:11,name:"aliOSS",kind:"message",T:bk,oneof:"output"}]),bh=ar.makeMessageType("livekit.S3Upload",()=>[{no:1,name:"access_key",kind:"scalar",T:9},{no:2,name:"secret",kind:"scalar",T:9},{no:11,name:"session_token",kind:"scalar",T:9},{no:12,name:"assume_role_arn",kind:"scalar",T:9},{no:13,name:"assume_role_external_id",kind:"scalar",T:9},{no:3,name:"region",kind:"scalar",T:9},{no:4,name:"endpoint",kind:"scalar",T:9},{no:5,name:"bucket",kind:"scalar",T:9},{no:6,name:"force_path_style",kind:"scalar",T:8},{no:7,name:"metadata",kind:"map",K:9,V:{kind:"scalar",T:9}},{no:8,name:"tagging",kind:"scalar",T:9},{no:9,name:"content_disposition",kind:"scalar",T:9},{no:10,name:"proxy",kind:"message",T:bl}]),bi=ar.makeMessageType("livekit.GCPUpload",()=>[{no:1,name:"credentials",kind:"scalar",T:9},{no:2,name:"bucket",kind:"scalar",T:9},{no:3,name:"proxy",kind:"message",T:bl}]),bj=ar.makeMessageType("livekit.AzureBlobUpload",()=>[{no:1,name:"account_name",kind:"scalar",T:9},{no:2,name:"account_key",kind:"scalar",T:9},{no:3,name:"container_name",kind:"scalar",T:9}]),bk=ar.makeMessageType("livekit.AliOSSUpload",()=>[{no:1,name:"access_key",kind:"scalar",T:9},{no:2,name:"secret",kind:"scalar",T:9},{no:3,name:"region",kind:"scalar",T:9},{no:4,name:"endpoint",kind:"scalar",T:9},{no:5,name:"bucket",kind:"scalar",T:9}]),bl=ar.makeMessageType("livekit.ProxyConfig",()=>[{no:1,name:"url",kind:"scalar",T:9},{no:2,name:"username",kind:"scalar",T:9},{no:3,name:"password",kind:"scalar",T:9}]),bm=ar.makeMessageType("livekit.StreamOutput",()=>[{no:1,name:"protocol",kind:"enum",T:ar.getEnumType(a3)},{no:2,name:"urls",kind:"scalar",T:9,repeated:!0}]),bn=ar.makeMessageType("livekit.EncodingOptions",()=>[{no:1,name:"width",kind:"scalar",T:5},{no:2,name:"height",kind:"scalar",T:5},{no:3,name:"depth",kind:"scalar",T:5},{no:4,name:"framerate",kind:"scalar",T:5},{no:5,name:"audio_codec",kind:"enum",T:ar.getEnumType(at)},{no:6,name:"audio_bitrate",kind:"scalar",T:5},{no:11,name:"audio_quality",kind:"scalar",T:5},{no:7,name:"audio_frequency",kind:"scalar",T:5},{no:8,name:"video_codec",kind:"enum",T:ar.getEnumType(au)},{no:9,name:"video_bitrate",kind:"scalar",T:5},{no:12,name:"video_quality",kind:"scalar",T:5},{no:10,name:"key_frame_interval",kind:"scalar",T:1}]),bo=(()=>[{no:1,name:"egress_id",kind:"scalar",T:9},{no:2,name:"room_id",kind:"scalar",T:9},{no:13,name:"room_name",kind:"scalar",T:9},{no:26,name:"source_type",kind:"enum",T:ar.getEnumType(a7)},{no:3,name:"status",kind:"enum",T:ar.getEnumType(a6)},{no:10,name:"started_at",kind:"scalar",T:3},{no:11,name:"ended_at",kind:"scalar",T:3},{no:18,name:"updated_at",kind:"scalar",T:3},{no:21,name:"details",kind:"scalar",T:9},{no:9,name:"error",kind:"scalar",T:9},{no:22,name:"error_code",kind:"scalar",T:5},{no:4,name:"room_composite",kind:"message",T:a8,oneof:"request"},{no:14,name:"web",kind:"message",T:a9,oneof:"request"},{no:19,name:"participant",kind:"message",T:ba,oneof:"request"},{no:5,name:"track_composite",kind:"message",T:bb,oneof:"request"},{no:6,name:"track",kind:"message",T:bc,oneof:"request"},{no:7,name:"stream",kind:"message",T:bo,oneof:"result"},{no:8,name:"file",kind:"message",T:br,oneof:"result"},{no:12,name:"segments",kind:"message",T:bs,oneof:"result"},{no:15,name:"stream_results",kind:"message",T:bp,repeated:!0},{no:16,name:"file_results",kind:"message",T:br,repeated:!0},{no:17,name:"segment_results",kind:"message",T:bs,repeated:!0},{no:20,name:"image_results",kind:"message",T:bt,repeated:!0},{no:23,name:"manifest_location",kind:"scalar",T:9},{no:25,name:"backup_storage_used",kind:"scalar",T:8}],ar.makeMessageType("livekit.StreamInfoList",()=>[{no:1,name:"info",kind:"message",T:bp,repeated:!0}])),bp=ar.makeMessageType("livekit.StreamInfo",()=>[{no:1,name:"url",kind:"scalar",T:9},{no:2,name:"started_at",kind:"scalar",T:3},{no:3,name:"ended_at",kind:"scalar",T:3},{no:4,name:"duration",kind:"scalar",T:3},{no:5,name:"status",kind:"enum",T:ar.getEnumType(bq)},{no:6,name:"error",kind:"scalar",T:9}]),bq=ar.makeEnum("livekit.StreamInfo.Status",[{no:0,name:"ACTIVE"},{no:1,name:"FINISHED"},{no:2,name:"FAILED"}]),br=ar.makeMessageType("livekit.FileInfo",()=>[{no:1,name:"filename",kind:"scalar",T:9},{no:2,name:"started_at",kind:"scalar",T:3},{no:3,name:"ended_at",kind:"scalar",T:3},{no:6,name:"duration",kind:"scalar",T:3},{no:4,name:"size",kind:"scalar",T:3},{no:5,name:"location",kind:"scalar",T:9}]),bs=ar.makeMessageType("livekit.SegmentsInfo",()=>[{no:1,name:"playlist_name",kind:"scalar",T:9},{no:8,name:"live_playlist_name",kind:"scalar",T:9},{no:2,name:"duration",kind:"scalar",T:3},{no:3,name:"size",kind:"scalar",T:3},{no:4,name:"playlist_location",kind:"scalar",T:9},{no:9,name:"live_playlist_location",kind:"scalar",T:9},{no:5,name:"segment_count",kind:"scalar",T:3},{no:6,name:"started_at",kind:"scalar",T:3},{no:7,name:"ended_at",kind:"scalar",T:3}]),bt=ar.makeMessageType("livekit.ImagesInfo",()=>[{no:4,name:"filename_prefix",kind:"scalar",T:9},{no:1,name:"image_count",kind:"scalar",T:3},{no:2,name:"started_at",kind:"scalar",T:3},{no:3,name:"ended_at",kind:"scalar",T:3}]),bu=ar.makeMessageType("livekit.AutoParticipantEgress",()=>[{no:1,name:"preset",kind:"enum",T:ar.getEnumType(a5),oneof:"options"},{no:2,name:"advanced",kind:"message",T:bn,oneof:"options"},{no:3,name:"file_outputs",kind:"message",T:bd,repeated:!0},{no:4,name:"segment_outputs",kind:"message",T:be,repeated:!0}]),bv=ar.makeMessageType("livekit.AutoTrackEgress",()=>[{no:1,name:"filepath",kind:"scalar",T:9},{no:5,name:"disable_manifest",kind:"scalar",T:8},{no:2,name:"s3",kind:"message",T:bh,oneof:"output"},{no:3,name:"gcp",kind:"message",T:bi,oneof:"output"},{no:4,name:"azure",kind:"message",T:bj,oneof:"output"},{no:6,name:"aliOSS",kind:"message",T:bk,oneof:"output"}]),bw=ar.makeEnum("livekit.IngressInput",[{no:0,name:"RTMP_INPUT"},{no:1,name:"WHIP_INPUT"},{no:2,name:"URL_INPUT"}]),bx=ar.makeEnum("livekit.IngressAudioEncodingPreset",[{no:0,name:"OPUS_STEREO_96KBPS"},{no:1,name:"OPUS_MONO_64KBS"}]),by=ar.makeEnum("livekit.IngressVideoEncodingPreset",[{no:0,name:"H264_720P_30FPS_3_LAYERS"},{no:1,name:"H264_1080P_30FPS_3_LAYERS"},{no:2,name:"H264_540P_25FPS_2_LAYERS"},{no:3,name:"H264_720P_30FPS_1_LAYER"},{no:4,name:"H264_1080P_30FPS_1_LAYER"},{no:5,name:"H264_720P_30FPS_3_LAYERS_HIGH_MOTION"},{no:6,name:"H264_1080P_30FPS_3_LAYERS_HIGH_MOTION"},{no:7,name:"H264_540P_25FPS_2_LAYERS_HIGH_MOTION"},{no:8,name:"H264_720P_30FPS_1_LAYER_HIGH_MOTION"},{no:9,name:"H264_1080P_30FPS_1_LAYER_HIGH_MOTION"}]),bz=ar.makeMessageType("livekit.IngressAudioOptions",()=>[{no:1,name:"name",kind:"scalar",T:9},{no:2,name:"source",kind:"enum",T:ar.getEnumType(ay)},{no:3,name:"preset",kind:"enum",T:ar.getEnumType(bx),oneof:"encoding_options"},{no:4,name:"options",kind:"message",T:bB,oneof:"encoding_options"}]),bA=ar.makeMessageType("livekit.IngressVideoOptions",()=>[{no:1,name:"name",kind:"scalar",T:9},{no:2,name:"source",kind:"enum",T:ar.getEnumType(ay)},{no:3,name:"preset",kind:"enum",T:ar.getEnumType(by),oneof:"encoding_options"},{no:4,name:"options",kind:"message",T:bC,oneof:"encoding_options"}]),bB=ar.makeMessageType("livekit.IngressAudioEncodingOptions",()=>[{no:1,name:"audio_codec",kind:"enum",T:ar.getEnumType(at)},{no:2,name:"bitrate",kind:"scalar",T:13},{no:3,name:"disable_dtx",kind:"scalar",T:8},{no:4,name:"channels",kind:"scalar",T:13}]),bC=ar.makeMessageType("livekit.IngressVideoEncodingOptions",()=>[{no:1,name:"video_codec",kind:"enum",T:ar.getEnumType(au)},{no:2,name:"frame_rate",kind:"scalar",T:1},{no:3,name:"layers",kind:"message",T:aN,repeated:!0}]),bD=(()=>[{no:1,name:"ingress_id",kind:"scalar",T:9},{no:2,name:"name",kind:"scalar",T:9},{no:3,name:"stream_key",kind:"scalar",T:9},{no:4,name:"url",kind:"scalar",T:9},{no:5,name:"input_type",kind:"enum",T:ar.getEnumType(bw)},{no:13,name:"bypass_transcoding",kind:"scalar",T:8},{no:15,name:"enable_transcoding",kind:"scalar",T:8,opt:!0},{no:6,name:"audio",kind:"message",T:bz},{no:7,name:"video",kind:"message",T:bA},{no:8,name:"room_name",kind:"scalar",T:9},{no:9,name:"participant_identity",kind:"scalar",T:9},{no:10,name:"participant_name",kind:"scalar",T:9},{no:14,name:"participant_metadata",kind:"scalar",T:9},{no:11,name:"reusable",kind:"scalar",T:8},{no:12,name:"state",kind:"message",T:bD},{no:16,name:"enabled",kind:"scalar",T:8,opt:!0}],ar.makeMessageType("livekit.IngressState",()=>[{no:1,name:"status",kind:"enum",T:ar.getEnumType(bE)},{no:2,name:"error",kind:"scalar",T:9},{no:3,name:"video",kind:"message",T:bF},{no:4,name:"audio",kind:"message",T:bG},{no:5,name:"room_id",kind:"scalar",T:9},{no:7,name:"started_at",kind:"scalar",T:3},{no:8,name:"ended_at",kind:"scalar",T:3},{no:10,name:"updated_at",kind:"scalar",T:3},{no:9,name:"resource_id",kind:"scalar",T:9},{no:6,name:"tracks",kind:"message",T:aM,repeated:!0}])),bE=ar.makeEnum("livekit.IngressState.Status",[{no:0,name:"ENDPOINT_INACTIVE"},{no:1,name:"ENDPOINT_BUFFERING"},{no:2,name:"ENDPOINT_PUBLISHING"},{no:3,name:"ENDPOINT_ERROR"},{no:4,name:"ENDPOINT_COMPLETE"}]),bF=ar.makeMessageType("livekit.InputVideoState",()=>[{no:1,name:"mime_type",kind:"scalar",T:9},{no:2,name:"average_bitrate",kind:"scalar",T:13},{no:3,name:"width",kind:"scalar",T:13},{no:4,name:"height",kind:"scalar",T:13},{no:5,name:"framerate",kind:"scalar",T:1}]),bG=ar.makeMessageType("livekit.InputAudioState",()=>[{no:1,name:"mime_type",kind:"scalar",T:9},{no:2,name:"average_bitrate",kind:"scalar",T:13},{no:3,name:"channels",kind:"scalar",T:13},{no:4,name:"sample_rate",kind:"scalar",T:13}]),bH=ar.makeMessageType("livekit.CreateRoomRequest",()=>[{no:1,name:"name",kind:"scalar",T:9},{no:12,name:"room_preset",kind:"scalar",T:9},{no:2,name:"empty_timeout",kind:"scalar",T:13},{no:10,name:"departure_timeout",kind:"scalar",T:13},{no:3,name:"max_participants",kind:"scalar",T:13},{no:4,name:"node_id",kind:"scalar",T:9},{no:5,name:"metadata",kind:"scalar",T:9},{no:6,name:"egress",kind:"message",T:bI},{no:7,name:"min_playout_delay",kind:"scalar",T:13},{no:8,name:"max_playout_delay",kind:"scalar",T:13},{no:9,name:"sync_streams",kind:"scalar",T:8},{no:13,name:"replay_enabled",kind:"scalar",T:8},{no:14,name:"agents",kind:"message",T:aZ,repeated:!0}]),bI=ar.makeMessageType("livekit.RoomEgress",()=>[{no:1,name:"room",kind:"message",T:a8},{no:3,name:"participant",kind:"message",T:bu},{no:2,name:"tracks",kind:"message",T:bv}]),bJ=ar.makeMessageType("livekit.ListRoomsRequest",()=>[{no:1,name:"names",kind:"scalar",T:9,repeated:!0}]),bK=ar.makeMessageType("livekit.ListRoomsResponse",()=>[{no:1,name:"rooms",kind:"message",T:aD,repeated:!0}]),bL=ar.makeMessageType("livekit.DeleteRoomRequest",()=>[{no:1,name:"room",kind:"scalar",T:9}]),bM=ar.makeMessageType("livekit.ListParticipantsRequest",()=>[{no:1,name:"room",kind:"scalar",T:9}]),bN=ar.makeMessageType("livekit.ListParticipantsResponse",()=>[{no:1,name:"participants",kind:"message",T:aG,repeated:!0}]),bO=ar.makeMessageType("livekit.RoomParticipantIdentity",()=>[{no:1,name:"room",kind:"scalar",T:9},{no:2,name:"identity",kind:"scalar",T:9}]),bP=ar.makeMessageType("livekit.MuteRoomTrackRequest",()=>[{no:1,name:"room",kind:"scalar",T:9},{no:2,name:"identity",kind:"scalar",T:9},{no:3,name:"track_sid",kind:"scalar",T:9},{no:4,name:"muted",kind:"scalar",T:8}]),bQ=ar.makeMessageType("livekit.MuteRoomTrackResponse",()=>[{no:1,name:"track",kind:"message",T:aM}]),bR=ar.makeMessageType("livekit.UpdateParticipantRequest",()=>[{no:1,name:"room",kind:"scalar",T:9},{no:2,name:"identity",kind:"scalar",T:9},{no:3,name:"metadata",kind:"scalar",T:9},{no:4,name:"permission",kind:"message",T:aF},{no:5,name:"name",kind:"scalar",T:9},{no:6,name:"attributes",kind:"map",K:9,V:{kind:"scalar",T:9}}]),bS=ar.makeMessageType("livekit.UpdateSubscriptionsRequest",()=>[{no:1,name:"room",kind:"scalar",T:9},{no:2,name:"identity",kind:"scalar",T:9},{no:3,name:"track_sids",kind:"scalar",T:9,repeated:!0},{no:4,name:"subscribe",kind:"scalar",T:8},{no:5,name:"participant_tracks",kind:"message",T:aQ,repeated:!0}]),bT=ar.makeMessageType("livekit.SendDataRequest",()=>[{no:1,name:"room",kind:"scalar",T:9},{no:2,name:"data",kind:"scalar",T:12},{no:3,name:"kind",kind:"enum",T:ar.getEnumType(aP)},{no:4,name:"destination_sids",kind:"scalar",T:9,repeated:!0},{no:6,name:"destination_identities",kind:"scalar",T:9,repeated:!0},{no:5,name:"topic",kind:"scalar",T:9,opt:!0},{no:7,name:"nonce",kind:"scalar",T:12}]),bU=ar.makeMessageType("livekit.UpdateRoomMetadataRequest",()=>[{no:1,name:"room",kind:"scalar",T:9},{no:2,name:"metadata",kind:"scalar",T:9}]),bV=ar.makeMessageType("livekit.RoomConfiguration",()=>[{no:1,name:"name",kind:"scalar",T:9},{no:2,name:"empty_timeout",kind:"scalar",T:13},{no:3,name:"departure_timeout",kind:"scalar",T:13},{no:4,name:"max_participants",kind:"scalar",T:13},{no:11,name:"metadata",kind:"scalar",T:9},{no:5,name:"egress",kind:"message",T:bI},{no:7,name:"min_playout_delay",kind:"scalar",T:13},{no:8,name:"max_playout_delay",kind:"scalar",T:13},{no:9,name:"sync_streams",kind:"scalar",T:8},{no:10,name:"agents",kind:"message",T:aZ,repeated:!0}]),bW=ar.makeMessageType("livekit.ForwardParticipantRequest",()=>[{no:1,name:"room",kind:"scalar",T:9},{no:2,name:"identity",kind:"scalar",T:9},{no:3,name:"destination_room",kind:"scalar",T:9}]),bX=ar.makeMessageType("livekit.MoveParticipantRequest",()=>[{no:1,name:"room",kind:"scalar",T:9},{no:2,name:"identity",kind:"scalar",T:9},{no:3,name:"destination_room",kind:"scalar",T:9}]),bY=ar.makeEnum("livekit.SIPTransport",[{no:0,name:"SIP_TRANSPORT_AUTO"},{no:1,name:"SIP_TRANSPORT_UDP"},{no:2,name:"SIP_TRANSPORT_TCP"},{no:3,name:"SIP_TRANSPORT_TLS"}]),bZ=ar.makeEnum("livekit.SIPHeaderOptions",[{no:0,name:"SIP_NO_HEADERS"},{no:1,name:"SIP_X_HEADERS"},{no:2,name:"SIP_ALL_HEADERS"}]),b$=ar.makeEnum("livekit.SIPMediaEncryption",[{no:0,name:"SIP_MEDIA_ENCRYPT_DISABLE"},{no:1,name:"SIP_MEDIA_ENCRYPT_ALLOW"},{no:2,name:"SIP_MEDIA_ENCRYPT_REQUIRE"}]),b_=(()=>[{no:1,name:"sip_trunk_id",kind:"scalar",T:9},{no:14,name:"kind",kind:"enum",T:ar.getEnumType(b_)},{no:2,name:"inbound_addresses",kind:"scalar",T:9,repeated:!0},{no:3,name:"outbound_address",kind:"scalar",T:9},{no:4,name:"outbound_number",kind:"scalar",T:9},{no:13,name:"transport",kind:"enum",T:ar.getEnumType(bY)},{no:5,name:"inbound_numbers_regex",kind:"scalar",T:9,repeated:!0},{no:10,name:"inbound_numbers",kind:"scalar",T:9,repeated:!0},{no:6,name:"inbound_username",kind:"scalar",T:9},{no:7,name:"inbound_password",kind:"scalar",T:9},{no:8,name:"outbound_username",kind:"scalar",T:9},{no:9,name:"outbound_password",kind:"scalar",T:9},{no:11,name:"name",kind:"scalar",T:9},{no:12,name:"metadata",kind:"scalar",T:9}],ar.makeEnum("livekit.SIPTrunkInfo.TrunkKind",[{no:0,name:"TRUNK_LEGACY"},{no:1,name:"TRUNK_INBOUND"},{no:2,name:"TRUNK_OUTBOUND"}])),b0=(()=>[{no:1,name:"sip_trunk_id",kind:"scalar",T:9},{no:2,name:"name",kind:"scalar",T:9},{no:3,name:"metadata",kind:"scalar",T:9},{no:4,name:"numbers",kind:"scalar",T:9,repeated:!0},{no:5,name:"allowed_addresses",kind:"scalar",T:9,repeated:!0},{no:6,name:"allowed_numbers",kind:"scalar",T:9,repeated:!0},{no:7,name:"auth_username",kind:"scalar",T:9},{no:8,name:"auth_password",kind:"scalar",T:9},{no:9,name:"headers",kind:"map",K:9,V:{kind:"scalar",T:9}},{no:10,name:"headers_to_attributes",kind:"map",K:9,V:{kind:"scalar",T:9}},{no:14,name:"attributes_to_headers",kind:"map",K:9,V:{kind:"scalar",T:9}},{no:15,name:"include_headers",kind:"enum",T:ar.getEnumType(bZ)},{no:11,name:"ringing_timeout",kind:"message",T:as},{no:12,name:"max_call_duration",kind:"message",T:as},{no:13,name:"krisp_enabled",kind:"scalar",T:8},{no:16,name:"media_encryption",kind:"enum",T:ar.getEnumType(b$)}],ar.makeMessageType("livekit.SIPDispatchRuleDirect",()=>[{no:1,name:"room_name",kind:"scalar",T:9},{no:2,name:"pin",kind:"scalar",T:9}])),b1=ar.makeMessageType("livekit.SIPDispatchRuleIndividual",()=>[{no:1,name:"room_prefix",kind:"scalar",T:9},{no:2,name:"pin",kind:"scalar",T:9}]),b2=ar.makeMessageType("livekit.SIPDispatchRuleCallee",()=>[{no:1,name:"room_prefix",kind:"scalar",T:9},{no:2,name:"pin",kind:"scalar",T:9},{no:3,name:"randomize",kind:"scalar",T:8}]),b3=ar.makeMessageType("livekit.SIPDispatchRule",()=>[{no:1,name:"dispatch_rule_direct",kind:"message",T:b0,oneof:"rule"},{no:2,name:"dispatch_rule_individual",kind:"message",T:b1,oneof:"rule"},{no:3,name:"dispatch_rule_callee",kind:"message",T:b2,oneof:"rule"}]);()=>[{no:1,name:"sip_dispatch_rule_id",kind:"scalar",T:9},{no:2,name:"rule",kind:"message",T:b3},{no:3,name:"trunk_ids",kind:"scalar",T:9,repeated:!0},{no:4,name:"hide_phone_number",kind:"scalar",T:8},{no:7,name:"inbound_numbers",kind:"scalar",T:9,repeated:!0},{no:5,name:"name",kind:"scalar",T:9},{no:6,name:"metadata",kind:"scalar",T:9},{no:8,name:"attributes",kind:"map",K:9,V:{kind:"scalar",T:9}},{no:9,name:"room_preset",kind:"scalar",T:9},{no:10,name:"room_config",kind:"message",T:bV},{no:11,name:"krisp_enabled",kind:"scalar",T:8},{no:12,name:"media_encryption",kind:"enum",T:ar.getEnumType(b$)}],()=>[{no:1,name:"hostname",kind:"scalar",T:9},{no:7,name:"destination_country",kind:"scalar",T:9},{no:2,name:"transport",kind:"enum",T:ar.getEnumType(bY)},{no:3,name:"auth_username",kind:"scalar",T:9},{no:4,name:"auth_password",kind:"scalar",T:9},{no:5,name:"headers_to_attributes",kind:"map",K:9,V:{kind:"scalar",T:9}},{no:6,name:"attributes_to_headers",kind:"map",K:9,V:{kind:"scalar",T:9}}];var b4,b5,b6,b7,b8,b9=c(4573);let ca=a=>b9.Buffer.from(a).toString("base64url");var cb=c(77598),cc=c(57975);class cd extends Error{static code="ERR_JOSE_GENERIC";code="ERR_JOSE_GENERIC";constructor(a,b){super(a,b),this.name=this.constructor.name,Error.captureStackTrace?.(this,this.constructor)}}class ce extends cd{static code="ERR_JOSE_NOT_SUPPORTED";code="ERR_JOSE_NOT_SUPPORTED"}class cf extends cd{static code="ERR_JWS_INVALID";code="ERR_JWS_INVALID"}class cg extends cd{static code="ERR_JWT_INVALID";code="ERR_JWT_INVALID"}class ch extends cd{[Symbol.asyncIterator];static code="ERR_JWKS_MULTIPLE_MATCHING_KEYS";code="ERR_JWKS_MULTIPLE_MATCHING_KEYS";constructor(a="multiple matching keys found in the JSON Web Key Set",b){super(a,b)}}let ci=cb.webcrypto,cj=a=>cc.types.isCryptoKey(a),ck=a=>cc.types.isKeyObject(a);function cl(a,b,...c){if((c=c.filter(Boolean)).length>2){let b=c.pop();a+=`one of type ${c.join(", ")}, or ${b}.`}else 2===c.length?a+=`one of type ${c[0]} or ${c[1]}.`:a+=`of type ${c[0]}.`;return null==b?a+=` Received ${b}`:"function"==typeof b&&b.name?a+=` Received function ${b.name}`:"object"==typeof b&&null!=b&&b.constructor?.name&&(a+=` Received an instance of ${b.constructor.name}`),a}let cm=(a,...b)=>cl("Key must be ",a,...b);function cn(a,b,...c){return cl(`Key for the ${a} algorithm must be `,b,...c)}let co=a=>ck(a)||cj(a),cp=["KeyObject"];function cq(a){if("object"!=typeof a||null===a||"[object Object]"!==Object.prototype.toString.call(a))return!1;if(null===Object.getPrototypeOf(a))return!0;let b=a;for(;null!==Object.getPrototypeOf(b);)b=Object.getPrototypeOf(b);return Object.getPrototypeOf(a)===b}function cr(a){return cq(a)&&"string"==typeof a.kty}(globalThis.CryptoKey||ci?.CryptoKey)&&cp.push("CryptoKey"),new WeakMap;let cs=(a,b)=>{let c;try{c=a instanceof cb.KeyObject?a.asymmetricKeyDetails?.modulusLength:Buffer.from(a.n,"base64url").byteLength<<3}catch{}if("number"!=typeof c||c<2048)throw TypeError(`${b} requires key modulusLength to be 2048 bits or larger`)},ct=new Map([["ES256","P-256"],["ES256K","secp256k1"],["ES384","P-384"],["ES512","P-521"]]);function cu(a,b="algorithm.name"){return TypeError(`CryptoKey does not support this operation, its ${b} must be ${a}`)}function cv(a,b){return a.name===b}function cw(a){return parseInt(a.name.slice(4),10)}let cx=(0,cc.promisify)(cb.sign),cy=async(a,b,c)=>{let d=function(a,b,c){if(b instanceof Uint8Array){if(!a.startsWith("HS"))throw TypeError(cm(b,...cp));return(0,cb.createSecretKey)(b)}if(b instanceof cb.KeyObject)return b;if(cj(b))return!function(a,b,...c){switch(b){case"HS256":case"HS384":case"HS512":{if(!cv(a.algorithm,"HMAC"))throw cu("HMAC");let c=parseInt(b.slice(2),10);if(cw(a.algorithm.hash)!==c)throw cu(`SHA-${c}`,"algorithm.hash");break}case"RS256":case"RS384":case"RS512":{if(!cv(a.algorithm,"RSASSA-PKCS1-v1_5"))throw cu("RSASSA-PKCS1-v1_5");let c=parseInt(b.slice(2),10);if(cw(a.algorithm.hash)!==c)throw cu(`SHA-${c}`,"algorithm.hash");break}case"PS256":case"PS384":case"PS512":{if(!cv(a.algorithm,"RSA-PSS"))throw cu("RSA-PSS");let c=parseInt(b.slice(2),10);if(cw(a.algorithm.hash)!==c)throw cu(`SHA-${c}`,"algorithm.hash");break}case"EdDSA":if("Ed25519"!==a.algorithm.name&&"Ed448"!==a.algorithm.name)throw cu("Ed25519 or Ed448");break;case"Ed25519":if(!cv(a.algorithm,"Ed25519"))throw cu("Ed25519");break;case"ES256":case"ES384":case"ES512":{if(!cv(a.algorithm,"ECDSA"))throw cu("ECDSA");let c=function(a){switch(a){case"ES256":return"P-256";case"ES384":return"P-384";case"ES512":return"P-521";default:throw Error("unreachable")}}(b);if(a.algorithm.namedCurve!==c)throw cu(c,"algorithm.namedCurve");break}default:throw TypeError("CryptoKey does not support this operation")}if(c.length&&!c.some(b=>a.usages.includes(b))){let a="CryptoKey does not support this operation, its usages must include ";if(c.length>2){let b=c.pop();a+=`one of ${c.join(", ")}, or ${b}.`}else 2===c.length?a+=`one of ${c[0]} or ${c[1]}.`:a+=`${c[0]}.`;throw TypeError(a)}}(b,a,c),cb.KeyObject.from(b);if(cr(b))return a.startsWith("HS")?(0,cb.createSecretKey)(Buffer.from(b.k,"base64url")):b;throw TypeError(cm(b,...cp,"Uint8Array","JSON Web Key"))}(a,b,"sign");if(a.startsWith("HS")){let b=cb.createHmac(function(a){switch(a){case"HS256":return"sha256";case"HS384":return"sha384";case"HS512":return"sha512";default:throw new ce(`alg ${a} is not supported either by JOSE or your javascript runtime`)}}(a),d);return b.update(c),b.digest()}return cx(function(a){switch(a){case"PS256":case"RS256":case"ES256":case"ES256K":return"sha256";case"PS384":case"RS384":case"ES384":return"sha384";case"PS512":case"RS512":case"ES512":return"sha512";case"Ed25519":case"EdDSA":return;default:throw new ce(`alg ${a} is not supported either by JOSE or your javascript runtime`)}}(a),c,function(a,b){let c,d,e,f;if(b instanceof cb.KeyObject)c=b.asymmetricKeyType,d=b.asymmetricKeyDetails;else switch(e=!0,b.kty){case"RSA":c="rsa";break;case"EC":c="ec";break;case"OKP":if("Ed25519"===b.crv){c="ed25519";break}if("Ed448"===b.crv){c="ed448";break}throw TypeError("Invalid key for this operation, its crv must be Ed25519 or Ed448");default:throw TypeError("Invalid key for this operation, its kty must be RSA, OKP, or EC")}switch(a){case"Ed25519":if("ed25519"!==c)throw TypeError("Invalid key for this operation, its asymmetricKeyType must be ed25519");break;case"EdDSA":if(!["ed25519","ed448"].includes(c))throw TypeError("Invalid key for this operation, its asymmetricKeyType must be ed25519 or ed448");break;case"RS256":case"RS384":case"RS512":if("rsa"!==c)throw TypeError("Invalid key for this operation, its asymmetricKeyType must be rsa");cs(b,a);break;case"PS256":case"PS384":case"PS512":if("rsa-pss"===c){let{hashAlgorithm:b,mgf1HashAlgorithm:c,saltLength:e}=d,f=parseInt(a.slice(-3),10);if(void 0!==b&&(b!==`sha${f}`||c!==b))throw TypeError(`Invalid key for this operation, its RSA-PSS parameters do not meet the requirements of "alg" ${a}`);if(void 0!==e&&e>f>>3)throw TypeError(`Invalid key for this operation, its RSA-PSS parameter saltLength does not meet the requirements of "alg" ${a}`)}else if("rsa"!==c)throw TypeError("Invalid key for this operation, its asymmetricKeyType must be rsa or rsa-pss");cs(b,a),f={padding:cb.constants.RSA_PKCS1_PSS_PADDING,saltLength:cb.constants.RSA_PSS_SALTLEN_DIGEST};break;case"ES256":case"ES256K":case"ES384":case"ES512":{if("ec"!==c)throw TypeError("Invalid key for this operation, its asymmetricKeyType must be ec");let d=((a,b)=>{let c;if(cj(a))c=cb.KeyObject.from(a);else if(ck(a))c=a;else if(cr(a))return a.crv;else throw TypeError(cm(a,...cp));if("secret"===c.type)throw TypeError('only "private" or "public" type keys can be used for this operation');switch(c.asymmetricKeyType){case"ed25519":case"ed448":return`Ed${c.asymmetricKeyType.slice(2)}`;case"x25519":case"x448":return`X${c.asymmetricKeyType.slice(1)}`;case"ec":{let a=c.asymmetricKeyDetails.namedCurve;switch(a){case"prime256v1":return"P-256";case"secp384r1":return"P-384";case"secp521r1":return"P-521";case"secp256k1":return"secp256k1";default:throw new ce("Unsupported key curve for this operation")}}default:throw TypeError("Invalid asymmetric key type for this operation")}})(b),e=ct.get(a);if(d!==e)throw TypeError(`Invalid key curve for the algorithm, its curve must be ${e}, got ${d}`);f={dsaEncoding:"ieee-p1363"};break}default:throw new ce(`alg ${a} is not supported either by JOSE or your javascript runtime`)}return e?{format:"jwk",key:b,...f}:f?{...f,key:b}:b}(a,d))},cz=new TextEncoder,cA=new TextDecoder,cB=a=>a?.[Symbol.toStringTag],cC=(a,b,c)=>{if(void 0!==b.use&&"sig"!==b.use)throw TypeError("Invalid key for this operation, when present its use must be sig");if(void 0!==b.key_ops&&b.key_ops.includes?.(c)!==!0)throw TypeError(`Invalid key for this operation, when present its key_ops must include ${c}`);if(void 0!==b.alg&&b.alg!==a)throw TypeError(`Invalid key for this operation, when present its alg must be ${a}`);return!0};function cD(a,b,c,d){b.startsWith("HS")||"dir"===b||b.startsWith("PBES2")||/^A\d{3}(?:GCM)?KW$/.test(b)?((a,b,c,d)=>{if(!(b instanceof Uint8Array)){if(d&&cr(b)){var e;if(cr(e=b)&&"oct"===e.kty&&"string"==typeof e.k&&cC(a,b,c))return;throw TypeError('JSON Web Key for symmetric algorithms must have JWK "kty" (Key Type) equal to "oct" and the JWK "k" (Key Value) present')}if(!co(b))throw TypeError(cn(a,b,...cp,"Uint8Array",d?"JSON Web Key":null));if("secret"!==b.type)throw TypeError(`${cB(b)} instances for symmetric algorithms must be of type "secret"`)}})(b,c,d,a):((a,b,c,d)=>{var e,f;if(d&&cr(b))switch(c){case"sign":if("oct"!==(e=b).kty&&"string"==typeof e.d&&cC(a,b,c))return;throw TypeError("JSON Web Key for this operation be a private JWK");case"verify":if("oct"!==(f=b).kty&&void 0===f.d&&cC(a,b,c))return;throw TypeError("JSON Web Key for this operation be a public JWK")}if(!co(b))throw TypeError(cn(a,b,...cp,d?"JSON Web Key":null));if("secret"===b.type)throw TypeError(`${cB(b)} instances for asymmetric algorithms must not be of type "secret"`);if("sign"===c&&"public"===b.type)throw TypeError(`${cB(b)} instances for asymmetric algorithm signing must be of type "private"`);if("decrypt"===c&&"public"===b.type)throw TypeError(`${cB(b)} instances for asymmetric algorithm decryption must be of type "private"`);if(b.algorithm&&"verify"===c&&"private"===b.type)throw TypeError(`${cB(b)} instances for asymmetric algorithm verifying must be of type "public"`);if(b.algorithm&&"encrypt"===c&&"private"===b.type)throw TypeError(`${cB(b)} instances for asymmetric algorithm encryption must be of type "public"`)})(b,c,d,a)}cD.bind(void 0,!1);let cE=cD.bind(void 0,!0),cF=function(a,b,c,d,e){let f;if(void 0!==e.crit&&d?.crit===void 0)throw new a('"crit" (Critical) Header Parameter MUST be integrity protected');if(!d||void 0===d.crit)return new Set;if(!Array.isArray(d.crit)||0===d.crit.length||d.crit.some(a=>"string"!=typeof a||0===a.length))throw new a('"crit" (Critical) Header Parameter MUST be an array of non-empty strings when present');for(let g of(f=void 0!==c?new Map([...Object.entries(c),...b.entries()]):b,d.crit)){if(!f.has(g))throw new ce(`Extension Header Parameter "${g}" is not recognized`);if(void 0===e[g])throw new a(`Extension Header Parameter "${g}" is missing`);if(f.get(g)&&void 0===d[g])throw new a(`Extension Header Parameter "${g}" MUST be integrity protected`)}return new Set(d.crit)};class cG{_payload;_protectedHeader;_unprotectedHeader;constructor(a){if(!(a instanceof Uint8Array))throw TypeError("payload must be an instance of Uint8Array");this._payload=a}setProtectedHeader(a){if(this._protectedHeader)throw TypeError("setProtectedHeader can only be called once");return this._protectedHeader=a,this}setUnprotectedHeader(a){if(this._unprotectedHeader)throw TypeError("setUnprotectedHeader can only be called once");return this._unprotectedHeader=a,this}async sign(a,b){let c;if(!this._protectedHeader&&!this._unprotectedHeader)throw new cf("either setProtectedHeader or setUnprotectedHeader must be called before #sign()");if(!((...a)=>{let b,c=a.filter(Boolean);if(0===c.length||1===c.length)return!0;for(let a of c){let c=Object.keys(a);if(!b||0===b.size){b=new Set(c);continue}for(let a of c){if(b.has(a))return!1;b.add(a)}}return!0})(this._protectedHeader,this._unprotectedHeader))throw new cf("JWS Protected and JWS Unprotected Header Parameter names must be disjoint");let d={...this._protectedHeader,...this._unprotectedHeader},e=cF(cf,new Map([["b64",!0]]),b?.crit,this._protectedHeader,d),f=!0;if(e.has("b64")&&"boolean"!=typeof(f=this._protectedHeader.b64))throw new cf('The "b64" (base64url-encode payload) Header Parameter must be a boolean');let{alg:g}=d;if("string"!=typeof g||!g)throw new cf('JWS "alg" (Algorithm) Header Parameter missing or invalid');cE(g,a,"sign");let h=this._payload;f&&(h=cz.encode(ca(h)));let i=function(...a){let b=new Uint8Array(a.reduce((a,{length:b})=>a+b,0)),c=0;for(let d of a)b.set(d,c),c+=d.length;return b}(c=this._protectedHeader?cz.encode(ca(JSON.stringify(this._protectedHeader))):cz.encode(""),cz.encode("."),h),j={signature:ca(await cy(g,a,i)),payload:""};return f&&(j.payload=cA.decode(h)),this._unprotectedHeader&&(j.header=this._unprotectedHeader),this._protectedHeader&&(j.protected=cA.decode(c)),j}}class cH{_flattened;constructor(a){this._flattened=new cG(a)}setProtectedHeader(a){return this._flattened.setProtectedHeader(a),this}async sign(a,b){let c=await this._flattened.sign(a,b);if(void 0===c.payload)throw TypeError("use the flattened module for creating JWS with b64: false");return`${c.protected}.${c.payload}.${c.signature}`}}let cI=a=>Math.floor(a.getTime()/1e3),cJ=/^(\+|\-)? ?(\d+|\d+\.\d+) ?(seconds?|secs?|s|minutes?|mins?|m|hours?|hrs?|h|days?|d|weeks?|w|years?|yrs?|y)(?: (ago|from now))?$/i,cK=a=>{let b,c=cJ.exec(a);if(!c||c[4]&&c[1])throw TypeError("Invalid time period format");let d=parseFloat(c[2]);switch(c[3].toLowerCase()){case"sec":case"secs":case"second":case"seconds":case"s":b=Math.round(d);break;case"minute":case"minutes":case"min":case"mins":case"m":b=Math.round(60*d);break;case"hour":case"hours":case"hr":case"hrs":case"h":b=Math.round(3600*d);break;case"day":case"days":case"d":b=Math.round(86400*d);break;case"week":case"weeks":case"w":b=Math.round(604800*d);break;default:b=Math.round(0x1e187e0*d)}return"-"===c[1]||"ago"===c[4]?-b:b};function cL(a,b){if(!Number.isFinite(b))throw TypeError(`Invalid ${a} input`);return b}class cM{_payload;constructor(a={}){if(!cq(a))throw TypeError("JWT Claims Set MUST be an object");this._payload=a}setIssuer(a){return this._payload={...this._payload,iss:a},this}setSubject(a){return this._payload={...this._payload,sub:a},this}setAudience(a){return this._payload={...this._payload,aud:a},this}setJti(a){return this._payload={...this._payload,jti:a},this}setNotBefore(a){return"number"==typeof a?this._payload={...this._payload,nbf:cL("setNotBefore",a)}:a instanceof Date?this._payload={...this._payload,nbf:cL("setNotBefore",cI(a))}:this._payload={...this._payload,nbf:cI(new Date)+cK(a)},this}setExpirationTime(a){return"number"==typeof a?this._payload={...this._payload,exp:cL("setExpirationTime",a)}:a instanceof Date?this._payload={...this._payload,exp:cL("setExpirationTime",cI(a))}:this._payload={...this._payload,exp:cI(new Date)+cK(a)},this}setIssuedAt(a){return void 0===a?this._payload={...this._payload,iat:cI(new Date)}:a instanceof Date?this._payload={...this._payload,iat:cL("setIssuedAt",cI(a))}:"string"==typeof a?this._payload={...this._payload,iat:cL("setIssuedAt",cI(new Date)+cK(a))}:this._payload={...this._payload,iat:cL("setIssuedAt",a)},this}}class cN extends cM{_protectedHeader;setProtectedHeader(a){return this._protectedHeader=a,this}async sign(a,b){let c=new cH(cz.encode(JSON.stringify(this._payload)));if(c.setProtectedHeader(this._protectedHeader),Array.isArray(this._protectedHeader?.crit)&&this._protectedHeader.crit.includes("b64")&&!1===this._protectedHeader.b64)throw new cg("JWTs MUST NOT use unencoded payload");return c.sign(a,b)}}function cO(a){switch(a){case ay.CAMERA:return"camera";case ay.MICROPHONE:return"microphone";case ay.SCREEN_SHARE:return"screen_share";case ay.SCREEN_SHARE_AUDIO:return"screen_share_audio";default:throw TypeError(`Cannot convert TrackSource ${a} to string`)}}class cP{constructor(a,b,c){if(a||(a=process.env.LIVEKIT_API_KEY),b||(b=process.env.LIVEKIT_API_SECRET),a&&b)"undefined"!=typeof document&&console.error("You should not include your API secret in your web client bundle.\n\nYour web client should request a token from your backend server which should then use the API secret to generate a token. See https://docs.livekit.io/client/connect/");else throw Error("api-key and api-secret must be set");this.apiKey=a,this.apiSecret=b,this.grants={},this.identity=null==c?void 0:c.identity,this.ttl=(null==c?void 0:c.ttl)||"6h","number"==typeof this.ttl&&(this.ttl=`${this.ttl}s`),(null==c?void 0:c.metadata)&&(this.metadata=c.metadata),(null==c?void 0:c.attributes)&&(this.attributes=c.attributes),(null==c?void 0:c.name)&&(this.name=c.name)}addGrant(a){this.grants.video={...this.grants.video??{},...a}}addInferenceGrant(a){this.grants.inference={...this.grants.inference??{},...a}}addSIPGrant(a){this.grants.sip={...this.grants.sip??{},...a}}get name(){return this.grants.name}set name(a){this.grants.name=a}get metadata(){return this.grants.metadata}set metadata(a){this.grants.metadata=a}get attributes(){return this.grants.attributes}set attributes(a){this.grants.attributes=a}get kind(){return this.grants.kind}set kind(a){this.grants.kind=a}get sha256(){return this.grants.sha256}set sha256(a){this.grants.sha256=a}get roomPreset(){return this.grants.roomPreset}set roomPreset(a){this.grants.roomPreset=a}get roomConfig(){return this.grants.roomConfig}set roomConfig(a){this.grants.roomConfig=a}async toJwt(){var a;let b=new TextEncoder().encode(this.apiSecret),c=new cN(function(a){var b;let c={...a};return Array.isArray(null==(b=c.video)?void 0:b.canPublishSources)&&(c.video.canPublishSources=c.video.canPublishSources.map(cO)),c}(this.grants)).setProtectedHeader({alg:"HS256"}).setIssuer(this.apiKey).setExpirationTime(this.ttl).setNotBefore(0);if(this.identity)c.setSubject(this.identity);else if(null==(a=this.grants.video)?void 0:a.roomJoin)throw Error("identity is required for join but not set");return c.sign(b)}}class cQ{constructor(a,b,c){this.apiKey=a,this.secret=b,this.ttl=c||"10m"}async authHeader(a,b){let c=new cP(this.apiKey,this.secret,{ttl:this.ttl});return a&&c.addGrant(a),b&&c.addSIPGrant(b),{Authorization:`Bearer ${await c.toJwt()}`}}}class cR extends Error{constructor(a,b,c,d,e){super(b),this.name=a,this.status=c,this.code=d,this.metadata=e}}class cS{constructor(a,b,c){a.startsWith("ws")&&(a=a.replace("ws","http")),this.host=a,this.pkg=b,this.prefix=c||"/twirp"}async request(a,b,d,e,f=60){let g=new URL(`${this.prefix}/${this.pkg}.${a}/${b}`,this.host),h={method:"POST",headers:{"Content-Type":"application/json;charset=UTF-8",...e},body:JSON.stringify(d)};f&&(h.signal=AbortSignal.timeout(1e3*f));let i=await fetch(g,h);if(!i.ok){let a,b,c="application/json"===i.headers.get("content-type"),d="Unknown internal error";try{if(c){let c=await i.json();"msg"in c&&(d=c.msg),"code"in c&&(a=c.code),"meta"in c&&(b=c.meta)}else d=await i.text()}catch(a){console.debug("Error when trying to parse error message, using defaults",a)}throw new cR(i.statusText,d,i.status,a,b)}let j=await i.json();return(await c.e(37).then(c.bind(c,40037)).then(a=>a.default))(j,{deep:!0})}}async function cT(a=16){return globalThis.crypto?crypto.getRandomValues(new Uint8Array(a)):(await Promise.resolve().then(c.t.bind(c,77598,19))).getRandomValues(new Uint8Array(a))}let cU="RoomService";class cV extends cQ{constructor(a,b,c){super(b,c),this.rpc=new cS(a,"livekit")}async createRoom(a){let b=await this.rpc.request(cU,"CreateRoom",new bH(a).toJson(),await this.authHeader({roomCreate:!0}));return aD.fromJson(b,{ignoreUnknownFields:!0})}async listRooms(a){let b=await this.rpc.request(cU,"ListRooms",new bJ({names:a??[]}).toJson(),await this.authHeader({roomList:!0}));return bK.fromJson(b,{ignoreUnknownFields:!0}).rooms??[]}async deleteRoom(a){await this.rpc.request(cU,"DeleteRoom",new bL({room:a}).toJson(),await this.authHeader({roomCreate:!0}))}async updateRoomMetadata(a,b){let c=await this.rpc.request(cU,"UpdateRoomMetadata",new bU({room:a,metadata:b}).toJson(),await this.authHeader({roomAdmin:!0,room:a}));return aD.fromJson(c,{ignoreUnknownFields:!0})}async listParticipants(a){let b=await this.rpc.request(cU,"ListParticipants",new bM({room:a}).toJson(),await this.authHeader({roomAdmin:!0,room:a}));return bN.fromJson(b,{ignoreUnknownFields:!0}).participants??[]}async getParticipant(a,b){let c=await this.rpc.request(cU,"GetParticipant",new bO({room:a,identity:b}).toJson(),await this.authHeader({roomAdmin:!0,room:a}));return aG.fromJson(c,{ignoreUnknownFields:!0})}async removeParticipant(a,b){await this.rpc.request(cU,"RemoveParticipant",new bO({room:a,identity:b}).toJson(),await this.authHeader({roomAdmin:!0,room:a}))}async forwardParticipant(a,b,c){await this.rpc.request(cU,"ForwardParticipant",new bW({room:a,identity:b,destinationRoom:c}).toJson(),await this.authHeader({roomAdmin:!0,room:a,destinationRoom:c}))}async moveParticipant(a,b,c){await this.rpc.request(cU,"MoveParticipant",new bX({room:a,identity:b,destinationRoom:c}).toJson(),await this.authHeader({roomAdmin:!0,room:a,destinationRoom:c}))}async mutePublishedTrack(a,b,c,d){let e=new bP({room:a,identity:b,trackSid:c,muted:d}).toJson(),f=await this.rpc.request(cU,"MutePublishedTrack",e,await this.authHeader({roomAdmin:!0,room:a}));return bQ.fromJson(f,{ignoreUnknownFields:!0}).track}async updateParticipant(a,b,c,d,e){let f="object"==typeof c,g=f?null==c?void 0:c.metadata:c,h=f?c.permission:d,i=f?c.name:e,j=new bR({room:a,identity:b,attributes:f?c.attributes:{},metadata:g,name:i});h&&(j.permission=new aF(h));let k=await this.rpc.request(cU,"UpdateParticipant",j.toJson(),await this.authHeader({roomAdmin:!0,room:a}));return aG.fromJson(k,{ignoreUnknownFields:!0})}async updateSubscriptions(a,b,c,d){let e=new bS({room:a,identity:b,trackSids:c,subscribe:d,participantTracks:[]}).toJson();await this.rpc.request(cU,"UpdateSubscriptions",e,await this.authHeader({roomAdmin:!0,room:a}))}async sendData(a,b,c,d={}){let e=new bT({room:a,data:b,kind:c,destinationSids:(Array.isArray(d)?d:d.destinationSids)??[],topic:Array.isArray(d)?void 0:d.topic});!Array.isArray(d)&&d.destinationIdentities&&(e.destinationIdentities=d.destinationIdentities),e.nonce=await cT(16),await this.rpc.request(cU,"SendData",e.toJson(),await this.authHeader({roomAdmin:!0,room:a}))}}}}; |