FUCK ERLPACK
This commit is contained in:
parent
0c8bce1778
commit
d74a2202c2
@ -1796,7 +1796,7 @@ u=Object.setPrototypeOf||function(e,t){e.__proto__=t;return e};return u(e,t)}var
|
||||
;if(null===this._onDataReady)throw new Error("Cannot feed unless a data ready callback is registered.");if(!(e instanceof ArrayBuffer))throw new Error("Expected array buffer, but got "+typeof e);var r=new DataView(e),i=r.byteLength>=4&&65535===r.getUint32(r.byteLength-4,!1);n.push(e,!!i&&t.Z_SYNC_FLUSH)};t.close=function(){if(null!=this._inflate){this._inflate.onEnd=null;this._inflate.chunks=[]}this._inflate=null};t.handleFlushEnd=function(e){var t=this._pako,n=this._inflate;if(null!=n){if(e!==t.Z_OK)throw new Error("zlib error, "+e+", "+n.strm.msg);var r,o=n.chunks,a=o.length;if(this._gatewayEncoding.wantsString())r=a>1?o.join(""):o[0];else if(a>1){for(var s=0,u=0;u<a;u++)s+=o[u].length;for(var l=new Uint8Array(s),c=0,d=0;d<a;d++){var _=o[d];l.set(_,c);c+=_.length}r=l}else r=o[0];o.length=0;null!=this._onDataReady&&this._onDataReady(r)}else new i.default("GatewayCompressionHandler").error("flush end happened on closed compression adapter")};return r}(d));c.push(function(e){s(t,e)
|
||||
;function t(){for(var t,r=arguments.length,i=new Array(r),o=0;o<r;o++)i[o]=arguments[o];(t=e.call.apply(e,[this].concat(i))||this)._pako=n(999591);return t}t.canUse=function(){return!0};var r=t.prototype;r.getAlgorithm=function(){return null};r.usesLegacyCompression=function(){return!0};r.feed=function(e){var t=this._pako;e instanceof ArrayBuffer&&this._gatewayEncoding.wantsString()&&(e=t.inflate(e,{to:"string"}));if(null==this._onDataReady)throw new Error("Cannot feed unless a data ready callback is registered.");this._onDataReady(e)};r.close=function(){};return t}(d));c.push(function(e){s(t,e);t.canUse=function(){return!1};function t(t){var n;(n=e.call(this,t)||this)._socketId=null;return n}var n=t.prototype;n.bindWebSocket=function(e){this.close();this._socketId=e._socketId;l.DCDCompressionManager.enableZlibStreamSupport(this._socketId)};n.getAlgorithm=function(){return"zlib-stream"};n.usesLegacyCompression=function(){return!1};n.feed=function(e){
|
||||
if(null==this._onDataReady)throw new Error("Cannot feed unless a data ready callback is registered.");null!==e&&this._onDataReady(e)};n.close=function(){var e=this._socketId;this._socketId=null;null!==e&&l.DCDCompressionManager.disableZlibStreamSupport(e)};return t}(d));var _=function(e){s(t,e);function t(){return e.apply(this,arguments)||this}t.canUse=function(){return!0};var n=t.prototype;n.getAlgorithm=function(){return null};n.usesLegacyCompression=function(){return!1};n.feed=function(e){if(null==this._onDataReady)throw new Error("Cannot feed unless a data ready callback is registered.");this._onDataReady(e)};n.close=function(){};return t}(d);c.push(_);var f=r.default.find(c,(function(e){return e.canUse()}));o.ProcessArgs.isDiscordGatewayPlaintextSet()&&(f=_);var p=f;t.default=p},585349:(e,t,n)=>{"use strict";Object.defineProperty(t,"__esModule",{value:!0});t.default=void 0;var r=n(42031),i=(0,n(394607).getErlpackEncoding)(),o=function(){function e(){}var t=e.prototype
|
||||
;t.pack=function(e){return JSON.stringify(e)};t.unpack=function(e){if("string"!=typeof e)throw new Error("Expected a string to be passed to JSONEncoding.unpack");return JSON.parse(e)};t.getName=function(){return"json"};t.wantsString=function(){return!0};return e}(),a=void 0!==i?i:o;r.ProcessArgs.isDiscordGatewayPlaintextSet()&&(a=o);var s=a;t.default=s},394607:(e,t,n)=>{"use strict";Object.defineProperty(t,"__esModule",{value:!0});t.getErlpackEncoding=function(){if(i.isPlatformEmbedded){var e;try{e=o.default.requireModule("discord_erlpack")}catch(t){try{e=null}catch(e){}}if(null!=e)return function(){function t(){}t.canUse=function(){return null!=e};var n=t.prototype;n.pack=function(t){return e.pack(t).buffer};n.unpack=function(t){t instanceof ArrayBuffer&&(t=new Uint8Array(t));try{return e.unpack(t)}catch(e){new r.default("GatewayEncodingErlpackEncoding").error("Error unpacking",{erlpackUnpackError:e,
|
||||
;t.pack=function(e){return JSON.stringify(e)};t.unpack=function(e){if("string"!=typeof e)throw new Error("Expected a string to be passed to JSONEncoding.unpack");return JSON.parse(e)};t.getName=function(){return"json"};t.wantsString=function(){return!0};return e}(),a=void 0!==i?i:o;r.ProcessArgs.isDiscordGatewayPlaintextSet()&&(a=o);var s=a;t.default=s},394607:(e,t,n)=>{"use strict";Object.defineProperty(t,"__esModule",{value:!0});t.getErlpackEncoding=function(){if(i.isPlatformEmbedded){var e;try{e=null}catch(t){try{e=null}catch(e){}}if(null!=e)return function(){function t(){}t.canUse=function(){return null!=e};var n=t.prototype;n.pack=function(t){return e.pack(t).buffer};n.unpack=function(t){t instanceof ArrayBuffer&&(t=new Uint8Array(t));try{return e.unpack(t)}catch(e){new r.default("GatewayEncodingErlpackEncoding").error("Error unpacking",{erlpackUnpackError:e,
|
||||
erlpackDataPreview:null!=t?Array.from(t.slice(0,32)):null,erlpackDataLength:null!=t?t.length:null});throw e}};n.getName=function(){return"json"};n.wantsString=function(){return!1};return t}()}return};var r=a(n(791548)),i=n(864489),o=a(n(922629));function a(e){return e&&e.__esModule?e:{default:e}}},760069:(e,t,n)=>{"use strict";Object.defineProperty(t,"__esModule",{value:!0});t.default=void 0;var r=A(n(717187)),i=A(n(441143)),o=function(e,t){if(!t&&e&&e.__esModule)return e;if(null===e||"object"!=typeof e&&"function"!=typeof e)return{default:e};var n=g(t);if(n&&n.has(e))return n.get(e);var r={},i=Object.defineProperty&&Object.getOwnPropertyDescriptor;for(var o in e)if("default"!==o&&Object.prototype.hasOwnProperty.call(e,o)){var a=i?Object.getOwnPropertyDescriptor(e,o):null;a&&(a.get||a.set)?Object.defineProperty(r,o,a):r[o]=e[o]}r.default=e;n&&n.set(e,r);return r
|
||||
}(n(999591)),a=A(n(621786)),s=A(n(752970)),u=A(n(536211)),l=A(n(636602)),c=A(n(791548)),d=A(n(752996)),_=A(n(909243)),f=A(n(290482)),p=A(n(308920)),E=A(n(165551)),h=A(n(60022)),T=A(n(604778)),I=A(n(280107)),m=A(n(585349)),v=n(338485),S=n(770348);function g(e){if("function"!=typeof WeakMap)return null;var t=new WeakMap,n=new WeakMap;return(g=function(e){return e?n:t})(e)}function A(e){return e&&e.__esModule?e:{default:e}}function O(){O=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var n=arguments[t];for(var r in n)Object.prototype.hasOwnProperty.call(n,r)&&(e[r]=n[r])}return e};return O.apply(this,arguments)}function y(e,t){var n="undefined"!=typeof Symbol&&e[Symbol.iterator]||e["@@iterator"];if(n)return(n=n.call(e)).next.bind(n);if(Array.isArray(e)||(n=function(e,t){if(!e)return;if("string"==typeof e)return N(e,t);var n=Object.prototype.toString.call(e).slice(8,-1);"Object"===n&&e.constructor&&(n=e.constructor.name);if("Map"===n||"Set"===n)return Array.from(e)
|
||||
;if("Arguments"===n||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n))return N(e,t)}(e))||t&&e&&"number"==typeof e.length){n&&(e=n);var r=0;return function(){return r>=e.length?{done:!0}:{done:!1,value:e[r++]}}}throw new TypeError("Invalid attempt to iterate non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}function N(e,t){(null==t||t>e.length)&&(t=e.length);for(var n=0,r=new Array(t);n<t;n++)r[n]=e[n];return r}function R(e,t){R=Object.setPrototypeOf||function(e,t){e.__proto__=t;return e};return R(e,t)}var C=new m.default;function b(){}var L,D;!function(e){e[e.DISPATCH=0]="DISPATCH";e[e.HEARTBEAT=1]="HEARTBEAT";e[e.IDENTIFY=2]="IDENTIFY";e[e.PRESENCE_UPDATE=3]="PRESENCE_UPDATE";e[e.VOICE_STATE_UPDATE=4]="VOICE_STATE_UPDATE";e[e.VOICE_SERVER_PING=5]="VOICE_SERVER_PING";e[e.RESUME=6]="RESUME";e[e.RECONNECT=7]="RECONNECT";e[e.REQUEST_GUILD_MEMBERS=8]="REQUEST_GUILD_MEMBERS";e[e.INVALID_SESSION=9]="INVALID_SESSION"
|
||||
|
||||
@ -2134,7 +2134,7 @@ return n(new Error("socket responded with pong"))}))})),new Promise((function(e,
|
||||
;break;case h.FRAME:if(!E(e))throw new Error("did not handshake");e.emit("request",o);break;case h.CLOSE:e.end();e.destroy()}b(e)}}var I=function(e){p(t,e);function t(t,n,r){var a;(a=e.call(this,"ipc",n,r)||this)._socket=t;return a}var n=t.prototype;n.send=function(e){_.info("Socket Emit: "+this.id,(0,l.default)(e));this._socket.write(O(h.FRAME,e))};n.close=function(e,t){this._socket.end(O(h.CLOSE,{code:e,message:t}));this._socket.destroy()};return t}(s.default),T=new(function(e){p(t,e);function t(){var t;t=e.call(this)||this;(y=m.net.createServer((function(e){return t.handleConnection(e)}))).on("error",(function(e){return _.error("Error: "+e.message)}));m.getAvailableSocket(S).then((function(e){y.listen(e,(function(){("function"==typeof y.listening?y.listening():y.listening)&&_.info("Starting on "+y.address())}))}));return t}t.prototype.handleConnection=function(e){var t=this;g(e,!1);e.pause();e.on("readable",(function(){try{b(e)}catch(t){e.end(O(h.CLOSE,{
|
||||
code:f.RPCCloseCodes.CLOSE_UNSUPPORTED,message:t.message}));e.destroy()}}));e.once("handshake",(function(n){var r,a=n.client_id,o=+n.v;try{r=new I(e,o,"json")}catch(t){e.end(O(h.CLOSE,{code:t.code,message:t.message}));e.destroy();return}_.info("Socket Opened: "+r.id);e.on("error",(function(e){return _.error("Socket Error: "+e.message)}));e.on("close",(function(){_.info("Socket Close: "+r.id);t.emit("disconnect",r)}));(0,d.validateSocketClient)(r,null,a).then((function(){e.on("request",(function(e){_.info("Socket Message: "+r.id,(0,l.default)(e));t.emit("request",r,e)}));t.emit("connect",r)})).catch((function(e){var t=e.code,n=e.message;return r.close(t,n)}))}))};return t}(a.default));t.Z=T},444287:(e,t,n)=>{"use strict";var r=n(348764).Buffer;({value:!0});t.Z=void 0;var a,o=h(n(717187)),i=h(n(496486)),u=h(n(817673)),l=h(n(608575)),s=h(n(636602)),d=h(n(791548)),f=h(n(909243)),c=h(n(922629)),p=h(n(248369)),v=h(n(318671)),y=h(n(641402)),m=n(367983),_=n(770348);function h(e){
|
||||
return e&&e.__esModule?e:{default:e}}function g(e,t){return function(e){if(Array.isArray(e))return e}(e)||function(e,t){var n=null==e?null:"undefined"!=typeof Symbol&&e[Symbol.iterator]||e["@@iterator"];if(null==n)return;var r,a,o=[],i=!0,u=!1;try{for(n=n.call(e);!(i=(r=n.next()).done);i=!0){o.push(r.value);if(t&&o.length===t)break}}catch(e){u=!0;a=e}finally{try{i||null==n.return||n.return()}finally{if(u)throw a}}return o}(e,t)||function(e,t){if(!e)return;if("string"==typeof e)return E(e,t);var n=Object.prototype.toString.call(e).slice(8,-1);"Object"===n&&e.constructor&&(n=e.constructor.name);if("Map"===n||"Set"===n)return Array.from(e);if("Arguments"===n||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n))return E(e,t)}(e,t)||function(){throw new TypeError("Invalid attempt to destructure non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}()}function E(e,t){(null==t||t>e.length)&&(t=e.length)
|
||||
;for(var n=0,r=new Array(t);n<t;n++)r[n]=e[n];return r}function S(e,t){e.prototype=Object.create(t.prototype);e.prototype.constructor=e;O(e,t)}function O(e,t){O=Object.setPrototypeOf||function(e,t){e.__proto__=t;return e};return O(e,t)}function b(){b=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var n=arguments[t];for(var r in n)Object.prototype.hasOwnProperty.call(n,r)&&(e[r]=n[r])}return e};return b.apply(this,arguments)}try{a=c.default.requireModule("discord_erlpack")}catch(e){try{a=c.default.requireModule("erlpack")}catch(e){}}var I,T=c.default.requireModule("discord_rpc").RPCWebSocket,C=window.GLOBAL_ENV.MARKETING_ENDPOINT,A=new d.default("RPCServer:WSS"),M=[];function N(e){return"function"==typeof e?e():e}function P(e){void 0===e&&(e=0);var t=e>0?void 0:function(){if(N(I.listening)){var e=I.address().port;A.info("Starting on "+e);s.default.dispatch({type:_.ActionTypes.RPC_SERVER_READY,port:e})}};I.listen(_.RPC_STARTING_PORT+e%_.RPC_PORT_RANGE,"127.0.0.1",t)}
|
||||
;for(var n=0,r=new Array(t);n<t;n++)r[n]=e[n];return r}function S(e,t){e.prototype=Object.create(t.prototype);e.prototype.constructor=e;O(e,t)}function O(e,t){O=Object.setPrototypeOf||function(e,t){e.__proto__=t;return e};return O(e,t)}function b(){b=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var n=arguments[t];for(var r in n)Object.prototype.hasOwnProperty.call(n,r)&&(e[r]=n[r])}return e};return b.apply(this,arguments)}try{a=null}catch(e){try{a=null}catch(e){}}var I,T=c.default.requireModule("discord_rpc").RPCWebSocket,C=window.GLOBAL_ENV.MARKETING_ENDPOINT,A=new d.default("RPCServer:WSS"),M=[];function N(e){return"function"==typeof e?e():e}function P(e){void 0===e&&(e=0);var t=e>0?void 0:function(){if(N(I.listening)){var e=I.address().port;A.info("Starting on "+e);s.default.dispatch({type:_.ActionTypes.RPC_SERVER_READY,port:e})}};I.listen(_.RPC_STARTING_PORT+e%_.RPC_PORT_RANGE,"127.0.0.1",t)}
|
||||
function R(e,t,n,a,o){void 0===a&&(a=200);void 0===o&&(o={});var i=N(e.headers).origin?{"Access-Control-Allow-Origin":N(e.headers).origin,"Access-Control-Allow-Credentials":"true","Access-Control-Allow-Methods":"POST, GET, PUT, PATCH, DELETE","Access-Control-Allow-Headers":["Content-Type","Authorization"].join(", ")}:{};n=n?JSON.stringify(n):"";a=200!==a||n.length?a:204;t.setHeader("Content-Length",r.byteLength(n));t.setHeader("Content-Type","application/json");t.writeHead(a,b({},o,{},i));t.end(n)}function w(e,t,n,r,a){void 0===a&&(a=0);R(e,t,{code:a,message:r},n)}var D=function(e){S(t,e);function t(t,n,r){var o;o=e.call(this,"ws",n,r)||this;if(-1===["etf","json"].indexOf(r))throw new p.default(_.RPCCloseCodes.INVALID_ENCODING,"Invalid Encoding: "+r);if("etf"===r&&null==a)throw new p.default(_.RPCCloseCodes.INVALID_ENCODING,"Erlpack cannot be used on this client");o._socket=t;return o}var n=t.prototype;n.send=function(e){
|
||||
(f.default.isLoggingOverlayEvents||e.cmd!==_.RPCCommands.OVERLAY&&e.evt!==_.RPCEvents.OVERLAY)&&A.info("Socket Emit: "+this.id,(0,v.default)(e));this._socket.send(JSON.stringify(e))};n.close=function(e,t){this._socket.close(e,t)};return t}(y.default),L=function(e){S(t,e);function t(t,n,r,a){var o;o=e.call(this,"http",r,a)||this;if("json"!==a)throw new p.default(_.RPCCloseCodes.INVALID_ENCODING,"Invalid Encoding: "+a);o._sendCallback=t;o._closeCallback=n;return o}var n=t.prototype;n.send=function(e){(f.default.isLoggingOverlayEvents||e.cmd!==_.RPCCommands.OVERLAY)&&A.info("Socket Emit: "+this.id,e);this._sendCallback(e)};n.close=function(e,t){this._closeCallback(t,e)};return t}(y.default),k=new(function(e){S(t,e);function t(){var t;t=e.call(this)||this;var n=0;(I=T.http.createServer()).on("error",(function(e){A.error("Error: "+e.message)
|
||||
;("EADDRINUSE"===e.code||e.message.includes("EADDRINUSE"))&&setTimeout((function(){return P(++n)}),1e3)}));I.on("request",t.handleRequest.bind(function(e){if(void 0===e)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return e}(t)));P(n);var r={instanceId:I.instanceId||0,server:I};new T.ws.Server(r).on("connection",(function(e){return t.handleConnection(e)}));return t}var n=t.prototype;n.handleRequest=function(e,t){var n=this,r=g(N(e.url).split("?"),2),a=r[0],o=r[1],i=N(e.method);if("/rpc"!==a||"OPTIONS"!==i){var s="POST"===i;if("/rpc"!==a||"GET"!==i&&!s)w(e,t,404,"Not Found");else{var d=u.default.parse(o),f=s?N(e.headers)["content-type"].split("/")[1]:"json",c=function(){var e=l.default.parse(d.callback),n=e.protocol,r=e.host;n===location.protocol&&r===location.host?t.setHeader("Location",d.callback):t.setHeader("Location",C);t.writeHead(301);t.end()},p=new L(s?R.bind(null,e,t):c,s?w.bind(null,e,t,400):c,+d.v,f);if(s)(0,
|
||||
|
||||
Reference in New Issue
Block a user