aboutsummaryrefslogtreecommitdiff
path: root/sandbox/testAppNevena/Front/node_modules/socks/build/client
diff options
context:
space:
mode:
authorNevena Bojovic <nenabojov@gmail.com>2022-03-01 20:05:50 +0100
committerNevena Bojovic <nenabojov@gmail.com>2022-03-01 20:05:50 +0100
commit291803c31f829fe0d32bb3207bc11def95a7408c (patch)
treec7d43107d79291b19d8c9eceefbe91c9f9a52acf /sandbox/testAppNevena/Front/node_modules/socks/build/client
parent1fa69862057db4db53cfda5be9c24b4228ef63f7 (diff)
Urađena test aplikacija. Povezan front i back.
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/socks/build/client')
-rw-r--r--sandbox/testAppNevena/Front/node_modules/socks/build/client/socksclient.js791
-rw-r--r--sandbox/testAppNevena/Front/node_modules/socks/build/client/socksclient.js.map1
2 files changed, 792 insertions, 0 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/socks/build/client/socksclient.js b/sandbox/testAppNevena/Front/node_modules/socks/build/client/socksclient.js
new file mode 100644
index 00000000..40a82a53
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/socks/build/client/socksclient.js
@@ -0,0 +1,791 @@
+"use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+ function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
+ return new (P || (P = Promise))(function (resolve, reject) {
+ function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+ function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+ function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
+ step((generator = generator.apply(thisArg, _arguments || [])).next());
+ });
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.SocksClientError = exports.SocksClient = void 0;
+const events_1 = require("events");
+const net = require("net");
+const ip = require("ip");
+const smart_buffer_1 = require("smart-buffer");
+const constants_1 = require("../common/constants");
+const helpers_1 = require("../common/helpers");
+const receivebuffer_1 = require("../common/receivebuffer");
+const util_1 = require("../common/util");
+Object.defineProperty(exports, "SocksClientError", { enumerable: true, get: function () { return util_1.SocksClientError; } });
+class SocksClient extends events_1.EventEmitter {
+ constructor(options) {
+ super();
+ this.options = Object.assign({}, options);
+ // Validate SocksClientOptions
+ (0, helpers_1.validateSocksClientOptions)(options);
+ // Default state
+ this.setState(constants_1.SocksClientState.Created);
+ }
+ /**
+ * Creates a new SOCKS connection.
+ *
+ * Note: Supports callbacks and promises. Only supports the connect command.
+ * @param options { SocksClientOptions } Options.
+ * @param callback { Function } An optional callback function.
+ * @returns { Promise }
+ */
+ static createConnection(options, callback) {
+ return new Promise((resolve, reject) => {
+ // Validate SocksClientOptions
+ try {
+ (0, helpers_1.validateSocksClientOptions)(options, ['connect']);
+ }
+ catch (err) {
+ if (typeof callback === 'function') {
+ callback(err);
+ return resolve(err); // Resolves pending promise (prevents memory leaks).
+ }
+ else {
+ return reject(err);
+ }
+ }
+ const client = new SocksClient(options);
+ client.connect(options.existing_socket);
+ client.once('established', (info) => {
+ client.removeAllListeners();
+ if (typeof callback === 'function') {
+ callback(null, info);
+ resolve(info); // Resolves pending promise (prevents memory leaks).
+ }
+ else {
+ resolve(info);
+ }
+ });
+ // Error occurred, failed to establish connection.
+ client.once('error', (err) => {
+ client.removeAllListeners();
+ if (typeof callback === 'function') {
+ callback(err);
+ resolve(err); // Resolves pending promise (prevents memory leaks).
+ }
+ else {
+ reject(err);
+ }
+ });
+ });
+ }
+ /**
+ * Creates a new SOCKS connection chain to a destination host through 2 or more SOCKS proxies.
+ *
+ * Note: Supports callbacks and promises. Only supports the connect method.
+ * Note: Implemented via createConnection() factory function.
+ * @param options { SocksClientChainOptions } Options
+ * @param callback { Function } An optional callback function.
+ * @returns { Promise }
+ */
+ static createConnectionChain(options, callback) {
+ return new Promise((resolve, reject) => __awaiter(this, void 0, void 0, function* () {
+ // Validate SocksClientChainOptions
+ try {
+ (0, helpers_1.validateSocksClientChainOptions)(options);
+ }
+ catch (err) {
+ if (typeof callback === 'function') {
+ callback(err);
+ return resolve(err); // Resolves pending promise (prevents memory leaks).
+ }
+ else {
+ return reject(err);
+ }
+ }
+ let sock;
+ // Shuffle proxies
+ if (options.randomizeChain) {
+ (0, util_1.shuffleArray)(options.proxies);
+ }
+ try {
+ // tslint:disable-next-line:no-increment-decrement
+ for (let i = 0; i < options.proxies.length; i++) {
+ const nextProxy = options.proxies[i];
+ // If we've reached the last proxy in the chain, the destination is the actual destination, otherwise it's the next proxy.
+ const nextDestination = i === options.proxies.length - 1
+ ? options.destination
+ : {
+ host: options.proxies[i + 1].host ||
+ options.proxies[i + 1].ipaddress,
+ port: options.proxies[i + 1].port,
+ };
+ // Creates the next connection in the chain.
+ const result = yield SocksClient.createConnection({
+ command: 'connect',
+ proxy: nextProxy,
+ destination: nextDestination,
+ // Initial connection ignores this as sock is undefined. Subsequent connections re-use the first proxy socket to form a chain.
+ });
+ // If sock is undefined, assign it here.
+ if (!sock) {
+ sock = result.socket;
+ }
+ }
+ if (typeof callback === 'function') {
+ callback(null, { socket: sock });
+ resolve({ socket: sock }); // Resolves pending promise (prevents memory leaks).
+ }
+ else {
+ resolve({ socket: sock });
+ }
+ }
+ catch (err) {
+ if (typeof callback === 'function') {
+ callback(err);
+ resolve(err); // Resolves pending promise (prevents memory leaks).
+ }
+ else {
+ reject(err);
+ }
+ }
+ }));
+ }
+ /**
+ * Creates a SOCKS UDP Frame.
+ * @param options
+ */
+ static createUDPFrame(options) {
+ const buff = new smart_buffer_1.SmartBuffer();
+ buff.writeUInt16BE(0);
+ buff.writeUInt8(options.frameNumber || 0);
+ // IPv4/IPv6/Hostname
+ if (net.isIPv4(options.remoteHost.host)) {
+ buff.writeUInt8(constants_1.Socks5HostType.IPv4);
+ buff.writeUInt32BE(ip.toLong(options.remoteHost.host));
+ }
+ else if (net.isIPv6(options.remoteHost.host)) {
+ buff.writeUInt8(constants_1.Socks5HostType.IPv6);
+ buff.writeBuffer(ip.toBuffer(options.remoteHost.host));
+ }
+ else {
+ buff.writeUInt8(constants_1.Socks5HostType.Hostname);
+ buff.writeUInt8(Buffer.byteLength(options.remoteHost.host));
+ buff.writeString(options.remoteHost.host);
+ }
+ // Port
+ buff.writeUInt16BE(options.remoteHost.port);
+ // Data
+ buff.writeBuffer(options.data);
+ return buff.toBuffer();
+ }
+ /**
+ * Parses a SOCKS UDP frame.
+ * @param data
+ */
+ static parseUDPFrame(data) {
+ const buff = smart_buffer_1.SmartBuffer.fromBuffer(data);
+ buff.readOffset = 2;
+ const frameNumber = buff.readUInt8();
+ const hostType = buff.readUInt8();
+ let remoteHost;
+ if (hostType === constants_1.Socks5HostType.IPv4) {
+ remoteHost = ip.fromLong(buff.readUInt32BE());
+ }
+ else if (hostType === constants_1.Socks5HostType.IPv6) {
+ remoteHost = ip.toString(buff.readBuffer(16));
+ }
+ else {
+ remoteHost = buff.readString(buff.readUInt8());
+ }
+ const remotePort = buff.readUInt16BE();
+ return {
+ frameNumber,
+ remoteHost: {
+ host: remoteHost,
+ port: remotePort,
+ },
+ data: buff.readBuffer(),
+ };
+ }
+ /**
+ * Internal state setter. If the SocksClient is in an error state, it cannot be changed to a non error state.
+ */
+ setState(newState) {
+ if (this.state !== constants_1.SocksClientState.Error) {
+ this.state = newState;
+ }
+ }
+ /**
+ * Starts the connection establishment to the proxy and destination.
+ * @param existingSocket Connected socket to use instead of creating a new one (internal use).
+ */
+ connect(existingSocket) {
+ this.onDataReceived = (data) => this.onDataReceivedHandler(data);
+ this.onClose = () => this.onCloseHandler();
+ this.onError = (err) => this.onErrorHandler(err);
+ this.onConnect = () => this.onConnectHandler();
+ // Start timeout timer (defaults to 30 seconds)
+ const timer = setTimeout(() => this.onEstablishedTimeout(), this.options.timeout || constants_1.DEFAULT_TIMEOUT);
+ // check whether unref is available as it differs from browser to NodeJS (#33)
+ if (timer.unref && typeof timer.unref === 'function') {
+ timer.unref();
+ }
+ // If an existing socket is provided, use it to negotiate SOCKS handshake. Otherwise create a new Socket.
+ if (existingSocket) {
+ this.socket = existingSocket;
+ }
+ else {
+ this.socket = new net.Socket();
+ }
+ // Attach Socket error handlers.
+ this.socket.once('close', this.onClose);
+ this.socket.once('error', this.onError);
+ this.socket.once('connect', this.onConnect);
+ this.socket.on('data', this.onDataReceived);
+ this.setState(constants_1.SocksClientState.Connecting);
+ this.receiveBuffer = new receivebuffer_1.ReceiveBuffer();
+ if (existingSocket) {
+ this.socket.emit('connect');
+ }
+ else {
+ this.socket.connect(this.getSocketOptions());
+ if (this.options.set_tcp_nodelay !== undefined &&
+ this.options.set_tcp_nodelay !== null) {
+ this.socket.setNoDelay(!!this.options.set_tcp_nodelay);
+ }
+ }
+ // Listen for established event so we can re-emit any excess data received during handshakes.
+ this.prependOnceListener('established', (info) => {
+ setImmediate(() => {
+ if (this.receiveBuffer.length > 0) {
+ const excessData = this.receiveBuffer.get(this.receiveBuffer.length);
+ info.socket.emit('data', excessData);
+ }
+ info.socket.resume();
+ });
+ });
+ }
+ // Socket options (defaults host/port to options.proxy.host/options.proxy.port)
+ getSocketOptions() {
+ return Object.assign(Object.assign({}, this.options.socket_options), { host: this.options.proxy.host || this.options.proxy.ipaddress, port: this.options.proxy.port });
+ }
+ /**
+ * Handles internal Socks timeout callback.
+ * Note: If the Socks client is not BoundWaitingForConnection or Established, the connection will be closed.
+ */
+ onEstablishedTimeout() {
+ if (this.state !== constants_1.SocksClientState.Established &&
+ this.state !== constants_1.SocksClientState.BoundWaitingForConnection) {
+ this.closeSocket(constants_1.ERRORS.ProxyConnectionTimedOut);
+ }
+ }
+ /**
+ * Handles Socket connect event.
+ */
+ onConnectHandler() {
+ this.setState(constants_1.SocksClientState.Connected);
+ // Send initial handshake.
+ if (this.options.proxy.type === 4) {
+ this.sendSocks4InitialHandshake();
+ }
+ else {
+ this.sendSocks5InitialHandshake();
+ }
+ this.setState(constants_1.SocksClientState.SentInitialHandshake);
+ }
+ /**
+ * Handles Socket data event.
+ * @param data
+ */
+ onDataReceivedHandler(data) {
+ /*
+ All received data is appended to a ReceiveBuffer.
+ This makes sure that all the data we need is received before we attempt to process it.
+ */
+ this.receiveBuffer.append(data);
+ // Process data that we have.
+ this.processData();
+ }
+ /**
+ * Handles processing of the data we have received.
+ */
+ processData() {
+ // If we have enough data to process the next step in the SOCKS handshake, proceed.
+ while (this.state !== constants_1.SocksClientState.Established &&
+ this.state !== constants_1.SocksClientState.Error &&
+ this.receiveBuffer.length >= this.nextRequiredPacketBufferSize) {
+ // Sent initial handshake, waiting for response.
+ if (this.state === constants_1.SocksClientState.SentInitialHandshake) {
+ if (this.options.proxy.type === 4) {
+ // Socks v4 only has one handshake response.
+ this.handleSocks4FinalHandshakeResponse();
+ }
+ else {
+ // Socks v5 has two handshakes, handle initial one here.
+ this.handleInitialSocks5HandshakeResponse();
+ }
+ // Sent auth request for Socks v5, waiting for response.
+ }
+ else if (this.state === constants_1.SocksClientState.SentAuthentication) {
+ this.handleInitialSocks5AuthenticationHandshakeResponse();
+ // Sent final Socks v5 handshake, waiting for final response.
+ }
+ else if (this.state === constants_1.SocksClientState.SentFinalHandshake) {
+ this.handleSocks5FinalHandshakeResponse();
+ // Socks BIND established. Waiting for remote connection via proxy.
+ }
+ else if (this.state === constants_1.SocksClientState.BoundWaitingForConnection) {
+ if (this.options.proxy.type === 4) {
+ this.handleSocks4IncomingConnectionResponse();
+ }
+ else {
+ this.handleSocks5IncomingConnectionResponse();
+ }
+ }
+ else {
+ this.closeSocket(constants_1.ERRORS.InternalError);
+ break;
+ }
+ }
+ }
+ /**
+ * Handles Socket close event.
+ * @param had_error
+ */
+ onCloseHandler() {
+ this.closeSocket(constants_1.ERRORS.SocketClosed);
+ }
+ /**
+ * Handles Socket error event.
+ * @param err
+ */
+ onErrorHandler(err) {
+ this.closeSocket(err.message);
+ }
+ /**
+ * Removes internal event listeners on the underlying Socket.
+ */
+ removeInternalSocketHandlers() {
+ // Pauses data flow of the socket (this is internally resumed after 'established' is emitted)
+ this.socket.pause();
+ this.socket.removeListener('data', this.onDataReceived);
+ this.socket.removeListener('close', this.onClose);
+ this.socket.removeListener('error', this.onError);
+ this.socket.removeListener('connect', this.onConnect);
+ }
+ /**
+ * Closes and destroys the underlying Socket. Emits an error event.
+ * @param err { String } An error string to include in error event.
+ */
+ closeSocket(err) {
+ // Make sure only one 'error' event is fired for the lifetime of this SocksClient instance.
+ if (this.state !== constants_1.SocksClientState.Error) {
+ // Set internal state to Error.
+ this.setState(constants_1.SocksClientState.Error);
+ // Destroy Socket
+ this.socket.destroy();
+ // Remove internal listeners
+ this.removeInternalSocketHandlers();
+ // Fire 'error' event.
+ this.emit('error', new util_1.SocksClientError(err, this.options));
+ }
+ }
+ /**
+ * Sends initial Socks v4 handshake request.
+ */
+ sendSocks4InitialHandshake() {
+ const userId = this.options.proxy.userId || '';
+ const buff = new smart_buffer_1.SmartBuffer();
+ buff.writeUInt8(0x04);
+ buff.writeUInt8(constants_1.SocksCommand[this.options.command]);
+ buff.writeUInt16BE(this.options.destination.port);
+ // Socks 4 (IPv4)
+ if (net.isIPv4(this.options.destination.host)) {
+ buff.writeBuffer(ip.toBuffer(this.options.destination.host));
+ buff.writeStringNT(userId);
+ // Socks 4a (hostname)
+ }
+ else {
+ buff.writeUInt8(0x00);
+ buff.writeUInt8(0x00);
+ buff.writeUInt8(0x00);
+ buff.writeUInt8(0x01);
+ buff.writeStringNT(userId);
+ buff.writeStringNT(this.options.destination.host);
+ }
+ this.nextRequiredPacketBufferSize =
+ constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks4Response;
+ this.socket.write(buff.toBuffer());
+ }
+ /**
+ * Handles Socks v4 handshake response.
+ * @param data
+ */
+ handleSocks4FinalHandshakeResponse() {
+ const data = this.receiveBuffer.get(8);
+ if (data[1] !== constants_1.Socks4Response.Granted) {
+ this.closeSocket(`${constants_1.ERRORS.Socks4ProxyRejectedConnection} - (${constants_1.Socks4Response[data[1]]})`);
+ }
+ else {
+ // Bind response
+ if (constants_1.SocksCommand[this.options.command] === constants_1.SocksCommand.bind) {
+ const buff = smart_buffer_1.SmartBuffer.fromBuffer(data);
+ buff.readOffset = 2;
+ const remoteHost = {
+ port: buff.readUInt16BE(),
+ host: ip.fromLong(buff.readUInt32BE()),
+ };
+ // If host is 0.0.0.0, set to proxy host.
+ if (remoteHost.host === '0.0.0.0') {
+ remoteHost.host = this.options.proxy.ipaddress;
+ }
+ this.setState(constants_1.SocksClientState.BoundWaitingForConnection);
+ this.emit('bound', { remoteHost, socket: this.socket });
+ // Connect response
+ }
+ else {
+ this.setState(constants_1.SocksClientState.Established);
+ this.removeInternalSocketHandlers();
+ this.emit('established', { socket: this.socket });
+ }
+ }
+ }
+ /**
+ * Handles Socks v4 incoming connection request (BIND)
+ * @param data
+ */
+ handleSocks4IncomingConnectionResponse() {
+ const data = this.receiveBuffer.get(8);
+ if (data[1] !== constants_1.Socks4Response.Granted) {
+ this.closeSocket(`${constants_1.ERRORS.Socks4ProxyRejectedIncomingBoundConnection} - (${constants_1.Socks4Response[data[1]]})`);
+ }
+ else {
+ const buff = smart_buffer_1.SmartBuffer.fromBuffer(data);
+ buff.readOffset = 2;
+ const remoteHost = {
+ port: buff.readUInt16BE(),
+ host: ip.fromLong(buff.readUInt32BE()),
+ };
+ this.setState(constants_1.SocksClientState.Established);
+ this.removeInternalSocketHandlers();
+ this.emit('established', { remoteHost, socket: this.socket });
+ }
+ }
+ /**
+ * Sends initial Socks v5 handshake request.
+ */
+ sendSocks5InitialHandshake() {
+ const buff = new smart_buffer_1.SmartBuffer();
+ // By default we always support no auth.
+ const supportedAuthMethods = [constants_1.Socks5Auth.NoAuth];
+ // We should only tell the proxy we support user/pass auth if auth info is actually provided.
+ // Note: As of Tor v0.3.5.7+, if user/pass auth is an option from the client, by default it will always take priority.
+ if (this.options.proxy.userId || this.options.proxy.password) {
+ supportedAuthMethods.push(constants_1.Socks5Auth.UserPass);
+ }
+ // Custom auth method?
+ if (this.options.proxy.custom_auth_method !== undefined) {
+ supportedAuthMethods.push(this.options.proxy.custom_auth_method);
+ }
+ // Build handshake packet
+ buff.writeUInt8(0x05);
+ buff.writeUInt8(supportedAuthMethods.length);
+ for (const authMethod of supportedAuthMethods) {
+ buff.writeUInt8(authMethod);
+ }
+ this.nextRequiredPacketBufferSize =
+ constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5InitialHandshakeResponse;
+ this.socket.write(buff.toBuffer());
+ this.setState(constants_1.SocksClientState.SentInitialHandshake);
+ }
+ /**
+ * Handles initial Socks v5 handshake response.
+ * @param data
+ */
+ handleInitialSocks5HandshakeResponse() {
+ const data = this.receiveBuffer.get(2);
+ if (data[0] !== 0x05) {
+ this.closeSocket(constants_1.ERRORS.InvalidSocks5IntiailHandshakeSocksVersion);
+ }
+ else if (data[1] === constants_1.SOCKS5_NO_ACCEPTABLE_AUTH) {
+ this.closeSocket(constants_1.ERRORS.InvalidSocks5InitialHandshakeNoAcceptedAuthType);
+ }
+ else {
+ // If selected Socks v5 auth method is no auth, send final handshake request.
+ if (data[1] === constants_1.Socks5Auth.NoAuth) {
+ this.socks5ChosenAuthType = constants_1.Socks5Auth.NoAuth;
+ this.sendSocks5CommandRequest();
+ // If selected Socks v5 auth method is user/password, send auth handshake.
+ }
+ else if (data[1] === constants_1.Socks5Auth.UserPass) {
+ this.socks5ChosenAuthType = constants_1.Socks5Auth.UserPass;
+ this.sendSocks5UserPassAuthentication();
+ // If selected Socks v5 auth method is the custom_auth_method, send custom handshake.
+ }
+ else if (data[1] === this.options.proxy.custom_auth_method) {
+ this.socks5ChosenAuthType = this.options.proxy.custom_auth_method;
+ this.sendSocks5CustomAuthentication();
+ }
+ else {
+ this.closeSocket(constants_1.ERRORS.InvalidSocks5InitialHandshakeUnknownAuthType);
+ }
+ }
+ }
+ /**
+ * Sends Socks v5 user & password auth handshake.
+ *
+ * Note: No auth and user/pass are currently supported.
+ */
+ sendSocks5UserPassAuthentication() {
+ const userId = this.options.proxy.userId || '';
+ const password = this.options.proxy.password || '';
+ const buff = new smart_buffer_1.SmartBuffer();
+ buff.writeUInt8(0x01);
+ buff.writeUInt8(Buffer.byteLength(userId));
+ buff.writeString(userId);
+ buff.writeUInt8(Buffer.byteLength(password));
+ buff.writeString(password);
+ this.nextRequiredPacketBufferSize =
+ constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5UserPassAuthenticationResponse;
+ this.socket.write(buff.toBuffer());
+ this.setState(constants_1.SocksClientState.SentAuthentication);
+ }
+ sendSocks5CustomAuthentication() {
+ return __awaiter(this, void 0, void 0, function* () {
+ this.nextRequiredPacketBufferSize =
+ this.options.proxy.custom_auth_response_size;
+ this.socket.write(yield this.options.proxy.custom_auth_request_handler());
+ this.setState(constants_1.SocksClientState.SentAuthentication);
+ });
+ }
+ handleSocks5CustomAuthHandshakeResponse(data) {
+ return __awaiter(this, void 0, void 0, function* () {
+ return yield this.options.proxy.custom_auth_response_handler(data);
+ });
+ }
+ handleSocks5AuthenticationNoAuthHandshakeResponse(data) {
+ return __awaiter(this, void 0, void 0, function* () {
+ return data[1] === 0x00;
+ });
+ }
+ handleSocks5AuthenticationUserPassHandshakeResponse(data) {
+ return __awaiter(this, void 0, void 0, function* () {
+ return data[1] === 0x00;
+ });
+ }
+ /**
+ * Handles Socks v5 auth handshake response.
+ * @param data
+ */
+ handleInitialSocks5AuthenticationHandshakeResponse() {
+ return __awaiter(this, void 0, void 0, function* () {
+ this.setState(constants_1.SocksClientState.ReceivedAuthenticationResponse);
+ let authResult = false;
+ if (this.socks5ChosenAuthType === constants_1.Socks5Auth.NoAuth) {
+ authResult = yield this.handleSocks5AuthenticationNoAuthHandshakeResponse(this.receiveBuffer.get(2));
+ }
+ else if (this.socks5ChosenAuthType === constants_1.Socks5Auth.UserPass) {
+ authResult =
+ yield this.handleSocks5AuthenticationUserPassHandshakeResponse(this.receiveBuffer.get(2));
+ }
+ else if (this.socks5ChosenAuthType === this.options.proxy.custom_auth_method) {
+ authResult = yield this.handleSocks5CustomAuthHandshakeResponse(this.receiveBuffer.get(this.options.proxy.custom_auth_response_size));
+ }
+ if (!authResult) {
+ this.closeSocket(constants_1.ERRORS.Socks5AuthenticationFailed);
+ }
+ else {
+ this.sendSocks5CommandRequest();
+ }
+ });
+ }
+ /**
+ * Sends Socks v5 final handshake request.
+ */
+ sendSocks5CommandRequest() {
+ const buff = new smart_buffer_1.SmartBuffer();
+ buff.writeUInt8(0x05);
+ buff.writeUInt8(constants_1.SocksCommand[this.options.command]);
+ buff.writeUInt8(0x00);
+ // ipv4, ipv6, domain?
+ if (net.isIPv4(this.options.destination.host)) {
+ buff.writeUInt8(constants_1.Socks5HostType.IPv4);
+ buff.writeBuffer(ip.toBuffer(this.options.destination.host));
+ }
+ else if (net.isIPv6(this.options.destination.host)) {
+ buff.writeUInt8(constants_1.Socks5HostType.IPv6);
+ buff.writeBuffer(ip.toBuffer(this.options.destination.host));
+ }
+ else {
+ buff.writeUInt8(constants_1.Socks5HostType.Hostname);
+ buff.writeUInt8(this.options.destination.host.length);
+ buff.writeString(this.options.destination.host);
+ }
+ buff.writeUInt16BE(this.options.destination.port);
+ this.nextRequiredPacketBufferSize =
+ constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5ResponseHeader;
+ this.socket.write(buff.toBuffer());
+ this.setState(constants_1.SocksClientState.SentFinalHandshake);
+ }
+ /**
+ * Handles Socks v5 final handshake response.
+ * @param data
+ */
+ handleSocks5FinalHandshakeResponse() {
+ // Peek at available data (we need at least 5 bytes to get the hostname length)
+ const header = this.receiveBuffer.peek(5);
+ if (header[0] !== 0x05 || header[1] !== constants_1.Socks5Response.Granted) {
+ this.closeSocket(`${constants_1.ERRORS.InvalidSocks5FinalHandshakeRejected} - ${constants_1.Socks5Response[header[1]]}`);
+ }
+ else {
+ // Read address type
+ const addressType = header[3];
+ let remoteHost;
+ let buff;
+ // IPv4
+ if (addressType === constants_1.Socks5HostType.IPv4) {
+ // Check if data is available.
+ const dataNeeded = constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5ResponseIPv4;
+ if (this.receiveBuffer.length < dataNeeded) {
+ this.nextRequiredPacketBufferSize = dataNeeded;
+ return;
+ }
+ buff = smart_buffer_1.SmartBuffer.fromBuffer(this.receiveBuffer.get(dataNeeded).slice(4));
+ remoteHost = {
+ host: ip.fromLong(buff.readUInt32BE()),
+ port: buff.readUInt16BE(),
+ };
+ // If given host is 0.0.0.0, assume remote proxy ip instead.
+ if (remoteHost.host === '0.0.0.0') {
+ remoteHost.host = this.options.proxy.ipaddress;
+ }
+ // Hostname
+ }
+ else if (addressType === constants_1.Socks5HostType.Hostname) {
+ const hostLength = header[4];
+ const dataNeeded = constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5ResponseHostname(hostLength); // header + host length + host + port
+ // Check if data is available.
+ if (this.receiveBuffer.length < dataNeeded) {
+ this.nextRequiredPacketBufferSize = dataNeeded;
+ return;
+ }
+ buff = smart_buffer_1.SmartBuffer.fromBuffer(this.receiveBuffer.get(dataNeeded).slice(5));
+ remoteHost = {
+ host: buff.readString(hostLength),
+ port: buff.readUInt16BE(),
+ };
+ // IPv6
+ }
+ else if (addressType === constants_1.Socks5HostType.IPv6) {
+ // Check if data is available.
+ const dataNeeded = constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5ResponseIPv6;
+ if (this.receiveBuffer.length < dataNeeded) {
+ this.nextRequiredPacketBufferSize = dataNeeded;
+ return;
+ }
+ buff = smart_buffer_1.SmartBuffer.fromBuffer(this.receiveBuffer.get(dataNeeded).slice(4));
+ remoteHost = {
+ host: ip.toString(buff.readBuffer(16)),
+ port: buff.readUInt16BE(),
+ };
+ }
+ // We have everything we need
+ this.setState(constants_1.SocksClientState.ReceivedFinalResponse);
+ // If using CONNECT, the client is now in the established state.
+ if (constants_1.SocksCommand[this.options.command] === constants_1.SocksCommand.connect) {
+ this.setState(constants_1.SocksClientState.Established);
+ this.removeInternalSocketHandlers();
+ this.emit('established', { remoteHost, socket: this.socket });
+ }
+ else if (constants_1.SocksCommand[this.options.command] === constants_1.SocksCommand.bind) {
+ /* If using BIND, the Socks client is now in BoundWaitingForConnection state.
+ This means that the remote proxy server is waiting for a remote connection to the bound port. */
+ this.setState(constants_1.SocksClientState.BoundWaitingForConnection);
+ this.nextRequiredPacketBufferSize =
+ constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5ResponseHeader;
+ this.emit('bound', { remoteHost, socket: this.socket });
+ /*
+ If using Associate, the Socks client is now Established. And the proxy server is now accepting UDP packets at the
+ given bound port. This initial Socks TCP connection must remain open for the UDP relay to continue to work.
+ */
+ }
+ else if (constants_1.SocksCommand[this.options.command] === constants_1.SocksCommand.associate) {
+ this.setState(constants_1.SocksClientState.Established);
+ this.removeInternalSocketHandlers();
+ this.emit('established', {
+ remoteHost,
+ socket: this.socket,
+ });
+ }
+ }
+ }
+ /**
+ * Handles Socks v5 incoming connection request (BIND).
+ */
+ handleSocks5IncomingConnectionResponse() {
+ // Peek at available data (we need at least 5 bytes to get the hostname length)
+ const header = this.receiveBuffer.peek(5);
+ if (header[0] !== 0x05 || header[1] !== constants_1.Socks5Response.Granted) {
+ this.closeSocket(`${constants_1.ERRORS.Socks5ProxyRejectedIncomingBoundConnection} - ${constants_1.Socks5Response[header[1]]}`);
+ }
+ else {
+ // Read address type
+ const addressType = header[3];
+ let remoteHost;
+ let buff;
+ // IPv4
+ if (addressType === constants_1.Socks5HostType.IPv4) {
+ // Check if data is available.
+ const dataNeeded = constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5ResponseIPv4;
+ if (this.receiveBuffer.length < dataNeeded) {
+ this.nextRequiredPacketBufferSize = dataNeeded;
+ return;
+ }
+ buff = smart_buffer_1.SmartBuffer.fromBuffer(this.receiveBuffer.get(dataNeeded).slice(4));
+ remoteHost = {
+ host: ip.fromLong(buff.readUInt32BE()),
+ port: buff.readUInt16BE(),
+ };
+ // If given host is 0.0.0.0, assume remote proxy ip instead.
+ if (remoteHost.host === '0.0.0.0') {
+ remoteHost.host = this.options.proxy.ipaddress;
+ }
+ // Hostname
+ }
+ else if (addressType === constants_1.Socks5HostType.Hostname) {
+ const hostLength = header[4];
+ const dataNeeded = constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5ResponseHostname(hostLength); // header + host length + port
+ // Check if data is available.
+ if (this.receiveBuffer.length < dataNeeded) {
+ this.nextRequiredPacketBufferSize = dataNeeded;
+ return;
+ }
+ buff = smart_buffer_1.SmartBuffer.fromBuffer(this.receiveBuffer.get(dataNeeded).slice(5));
+ remoteHost = {
+ host: buff.readString(hostLength),
+ port: buff.readUInt16BE(),
+ };
+ // IPv6
+ }
+ else if (addressType === constants_1.Socks5HostType.IPv6) {
+ // Check if data is available.
+ const dataNeeded = constants_1.SOCKS_INCOMING_PACKET_SIZES.Socks5ResponseIPv6;
+ if (this.receiveBuffer.length < dataNeeded) {
+ this.nextRequiredPacketBufferSize = dataNeeded;
+ return;
+ }
+ buff = smart_buffer_1.SmartBuffer.fromBuffer(this.receiveBuffer.get(dataNeeded).slice(4));
+ remoteHost = {
+ host: ip.toString(buff.readBuffer(16)),
+ port: buff.readUInt16BE(),
+ };
+ }
+ this.setState(constants_1.SocksClientState.Established);
+ this.removeInternalSocketHandlers();
+ this.emit('established', { remoteHost, socket: this.socket });
+ }
+ }
+ get socksClientOptions() {
+ return Object.assign({}, this.options);
+ }
+}
+exports.SocksClient = SocksClient;
+//# sourceMappingURL=socksclient.js.map \ No newline at end of file
diff --git a/sandbox/testAppNevena/Front/node_modules/socks/build/client/socksclient.js.map b/sandbox/testAppNevena/Front/node_modules/socks/build/client/socksclient.js.map
new file mode 100644
index 00000000..15d0b565
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/socks/build/client/socksclient.js.map
@@ -0,0 +1 @@
+{"version":3,"file":"socksclient.js","sourceRoot":"","sources":["../../src/client/socksclient.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,mCAAoC;AACpC,2BAA2B;AAC3B,yBAAyB;AACzB,+CAAyC;AACzC,mDAkB6B;AAC7B,+CAG2B;AAC3B,2DAAsD;AACtD,yCAA8D;AAg7B5D,iGAh7BM,uBAAgB,OAg7BN;AAt5BlB,MAAM,WAAY,SAAQ,qBAAY;IAgBpC,YAAY,OAA2B;QACrC,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,OAAO,qBACP,OAAO,CACX,CAAC;QAEF,8BAA8B;QAC9B,IAAA,oCAA0B,EAAC,OAAO,CAAC,CAAC;QAEpC,gBAAgB;QAChB,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,OAAO,CAAC,CAAC;IAC1C,CAAC;IAED;;;;;;;OAOG;IACH,MAAM,CAAC,gBAAgB,CACrB,OAA2B,EAC3B,QAAmB;QAEnB,OAAO,IAAI,OAAO,CAA8B,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YAClE,8BAA8B;YAC9B,IAAI;gBACF,IAAA,oCAA0B,EAAC,OAAO,EAAE,CAAC,SAAS,CAAC,CAAC,CAAC;aAClD;YAAC,OAAO,GAAG,EAAE;gBACZ,IAAI,OAAO,QAAQ,KAAK,UAAU,EAAE;oBAClC,QAAQ,CAAC,GAAG,CAAC,CAAC;oBACd,OAAO,OAAO,CAAC,GAAU,CAAC,CAAC,CAAC,oDAAoD;iBACjF;qBAAM;oBACL,OAAO,MAAM,CAAC,GAAG,CAAC,CAAC;iBACpB;aACF;YAED,MAAM,MAAM,GAAG,IAAI,WAAW,CAAC,OAAO,CAAC,CAAC;YACxC,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,eAAe,CAAC,CAAC;YACxC,MAAM,CAAC,IAAI,CAAC,aAAa,EAAE,CAAC,IAAiC,EAAE,EAAE;gBAC/D,MAAM,CAAC,kBAAkB,EAAE,CAAC;gBAC5B,IAAI,OAAO,QAAQ,KAAK,UAAU,EAAE;oBAClC,QAAQ,CAAC,IAAI,EAAE,IAAI,CAAC,CAAC;oBACrB,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,oDAAoD;iBACpE;qBAAM;oBACL,OAAO,CAAC,IAAI,CAAC,CAAC;iBACf;YACH,CAAC,CAAC,CAAC;YAEH,kDAAkD;YAClD,MAAM,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC,GAAU,EAAE,EAAE;gBAClC,MAAM,CAAC,kBAAkB,EAAE,CAAC;gBAC5B,IAAI,OAAO,QAAQ,KAAK,UAAU,EAAE;oBAClC,QAAQ,CAAC,GAAG,CAAC,CAAC;oBACd,OAAO,CAAC,GAAU,CAAC,CAAC,CAAC,oDAAoD;iBAC1E;qBAAM;oBACL,MAAM,CAAC,GAAG,CAAC,CAAC;iBACb;YACH,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;;;;;;;OAQG;IACH,MAAM,CAAC,qBAAqB,CAC1B,OAAgC,EAChC,QAAmB;QAEnB,OAAO,IAAI,OAAO,CAA8B,CAAO,OAAO,EAAE,MAAM,EAAE,EAAE;YACxE,mCAAmC;YACnC,IAAI;gBACF,IAAA,yCAA+B,EAAC,OAAO,CAAC,CAAC;aAC1C;YAAC,OAAO,GAAG,EAAE;gBACZ,IAAI,OAAO,QAAQ,KAAK,UAAU,EAAE;oBAClC,QAAQ,CAAC,GAAG,CAAC,CAAC;oBACd,OAAO,OAAO,CAAC,GAAU,CAAC,CAAC,CAAC,oDAAoD;iBACjF;qBAAM;oBACL,OAAO,MAAM,CAAC,GAAG,CAAC,CAAC;iBACpB;aACF;YAED,IAAI,IAAgB,CAAC;YAErB,kBAAkB;YAClB,IAAI,OAAO,CAAC,cAAc,EAAE;gBAC1B,IAAA,mBAAY,EAAC,OAAO,CAAC,OAAO,CAAC,CAAC;aAC/B;YAED,IAAI;gBACF,kDAAkD;gBAClD,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,OAAO,CAAC,OAAO,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE;oBAC/C,MAAM,SAAS,GAAG,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;oBAErC,0HAA0H;oBAC1H,MAAM,eAAe,GACnB,CAAC,KAAK,OAAO,CAAC,OAAO,CAAC,MAAM,GAAG,CAAC;wBAC9B,CAAC,CAAC,OAAO,CAAC,WAAW;wBACrB,CAAC,CAAC;4BACE,IAAI,EACF,OAAO,CAAC,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,IAAI;gCAC3B,OAAO,CAAC,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,SAAS;4BAClC,IAAI,EAAE,OAAO,CAAC,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,IAAI;yBAClC,CAAC;oBAER,4CAA4C;oBAC5C,MAAM,MAAM,GAAG,MAAM,WAAW,CAAC,gBAAgB,CAAC;wBAChD,OAAO,EAAE,SAAS;wBAClB,KAAK,EAAE,SAAS;wBAChB,WAAW,EAAE,eAAe;wBAC5B,8HAA8H;qBAC/H,CAAC,CAAC;oBAEH,wCAAwC;oBACxC,IAAI,CAAC,IAAI,EAAE;wBACT,IAAI,GAAG,MAAM,CAAC,MAAM,CAAC;qBACtB;iBACF;gBAED,IAAI,OAAO,QAAQ,KAAK,UAAU,EAAE;oBAClC,QAAQ,CAAC,IAAI,EAAE,EAAC,MAAM,EAAE,IAAI,EAAC,CAAC,CAAC;oBAC/B,OAAO,CAAC,EAAC,MAAM,EAAE,IAAI,EAAC,CAAC,CAAC,CAAC,oDAAoD;iBAC9E;qBAAM;oBACL,OAAO,CAAC,EAAC,MAAM,EAAE,IAAI,EAAC,CAAC,CAAC;iBACzB;aACF;YAAC,OAAO,GAAG,EAAE;gBACZ,IAAI,OAAO,QAAQ,KAAK,UAAU,EAAE;oBAClC,QAAQ,CAAC,GAAG,CAAC,CAAC;oBACd,OAAO,CAAC,GAAU,CAAC,CAAC,CAAC,oDAAoD;iBAC1E;qBAAM;oBACL,MAAM,CAAC,GAAG,CAAC,CAAC;iBACb;aACF;QACH,CAAC,CAAA,CAAC,CAAC;IACL,CAAC;IAED;;;OAGG;IACH,MAAM,CAAC,cAAc,CAAC,OAA6B;QACjD,MAAM,IAAI,GAAG,IAAI,0BAAW,EAAE,CAAC;QAC/B,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAC;QACtB,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,WAAW,IAAI,CAAC,CAAC,CAAC;QAE1C,qBAAqB;QACrB,IAAI,GAAG,CAAC,MAAM,CAAC,OAAO,CAAC,UAAU,CAAC,IAAI,CAAC,EAAE;YACvC,IAAI,CAAC,UAAU,CAAC,0BAAc,CAAC,IAAI,CAAC,CAAC;YACrC,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,MAAM,CAAC,OAAO,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC,CAAC;SACxD;aAAM,IAAI,GAAG,CAAC,MAAM,CAAC,OAAO,CAAC,UAAU,CAAC,IAAI,CAAC,EAAE;YAC9C,IAAI,CAAC,UAAU,CAAC,0BAAc,CAAC,IAAI,CAAC,CAAC;YACrC,IAAI,CAAC,WAAW,CAAC,EAAE,CAAC,QAAQ,CAAC,OAAO,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC,CAAC;SACxD;aAAM;YACL,IAAI,CAAC,UAAU,CAAC,0BAAc,CAAC,QAAQ,CAAC,CAAC;YACzC,IAAI,CAAC,UAAU,CAAC,MAAM,CAAC,UAAU,CAAC,OAAO,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC,CAAC;YAC5D,IAAI,CAAC,WAAW,CAAC,OAAO,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;SAC3C;QAED,OAAO;QACP,IAAI,CAAC,aAAa,CAAC,OAAO,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;QAE5C,OAAO;QACP,IAAI,CAAC,WAAW,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAE/B,OAAO,IAAI,CAAC,QAAQ,EAAE,CAAC;IACzB,CAAC;IAED;;;OAGG;IACH,MAAM,CAAC,aAAa,CAAC,IAAY;QAC/B,MAAM,IAAI,GAAG,0BAAW,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;QAC1C,IAAI,CAAC,UAAU,GAAG,CAAC,CAAC;QAEpB,MAAM,WAAW,GAAG,IAAI,CAAC,SAAS,EAAE,CAAC;QACrC,MAAM,QAAQ,GAAmB,IAAI,CAAC,SAAS,EAAE,CAAC;QAClD,IAAI,UAAU,CAAC;QAEf,IAAI,QAAQ,KAAK,0BAAc,CAAC,IAAI,EAAE;YACpC,UAAU,GAAG,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC,CAAC;SAC/C;aAAM,IAAI,QAAQ,KAAK,0BAAc,CAAC,IAAI,EAAE;YAC3C,UAAU,GAAG,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC,CAAC;SAC/C;aAAM;YACL,UAAU,GAAG,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,SAAS,EAAE,CAAC,CAAC;SAChD;QAED,MAAM,UAAU,GAAG,IAAI,CAAC,YAAY,EAAE,CAAC;QAEvC,OAAO;YACL,WAAW;YACX,UAAU,EAAE;gBACV,IAAI,EAAE,UAAU;gBAChB,IAAI,EAAE,UAAU;aACjB;YACD,IAAI,EAAE,IAAI,CAAC,UAAU,EAAE;SACxB,CAAC;IACJ,CAAC;IAED;;OAEG;IACK,QAAQ,CAAC,QAA0B;QACzC,IAAI,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,KAAK,EAAE;YACzC,IAAI,CAAC,KAAK,GAAG,QAAQ,CAAC;SACvB;IACH,CAAC;IAED;;;OAGG;IACI,OAAO,CAAC,cAAuB;QACpC,IAAI,CAAC,cAAc,GAAG,CAAC,IAAY,EAAE,EAAE,CAAC,IAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,CAAC;QACzE,IAAI,CAAC,OAAO,GAAG,GAAG,EAAE,CAAC,IAAI,CAAC,cAAc,EAAE,CAAC;QAC3C,IAAI,CAAC,OAAO,GAAG,CAAC,GAAU,EAAE,EAAE,CAAC,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,CAAC;QACxD,IAAI,CAAC,SAAS,GAAG,GAAG,EAAE,CAAC,IAAI,CAAC,gBAAgB,EAAE,CAAC;QAE/C,+CAA+C;QAC/C,MAAM,KAAK,GAAG,UAAU,CACtB,GAAG,EAAE,CAAC,IAAI,CAAC,oBAAoB,EAAE,EACjC,IAAI,CAAC,OAAO,CAAC,OAAO,IAAI,2BAAe,CACxC,CAAC;QAEF,8EAA8E;QAC9E,IAAI,KAAK,CAAC,KAAK,IAAI,OAAO,KAAK,CAAC,KAAK,KAAK,UAAU,EAAE;YACpD,KAAK,CAAC,KAAK,EAAE,CAAC;SACf;QAED,yGAAyG;QACzG,IAAI,cAAc,EAAE;YAClB,IAAI,CAAC,MAAM,GAAG,cAAc,CAAC;SAC9B;aAAM;YACL,IAAI,CAAC,MAAM,GAAG,IAAI,GAAG,CAAC,MAAM,EAAE,CAAC;SAChC;QAED,gCAAgC;QAChC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;QACxC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;QACxC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;QAC5C,IAAI,CAAC,MAAM,CAAC,EAAE,CAAC,MAAM,EAAE,IAAI,CAAC,cAAc,CAAC,CAAC;QAE5C,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,UAAU,CAAC,CAAC;QAC3C,IAAI,CAAC,aAAa,GAAG,IAAI,6BAAa,EAAE,CAAC;QAEzC,IAAI,cAAc,EAAE;YAClB,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;SAC7B;aAAM;YACJ,IAAI,CAAC,MAAqB,CAAC,OAAO,CAAC,IAAI,CAAC,gBAAgB,EAAE,CAAC,CAAC;YAE7D,IACE,IAAI,CAAC,OAAO,CAAC,eAAe,KAAK,SAAS;gBAC1C,IAAI,CAAC,OAAO,CAAC,eAAe,KAAK,IAAI,EACrC;gBACC,IAAI,CAAC,MAAqB,CAAC,UAAU,CAAC,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,eAAe,CAAC,CAAC;aACxE;SACF;QAED,6FAA6F;QAC7F,IAAI,CAAC,mBAAmB,CAAC,aAAa,EAAE,CAAC,IAAI,EAAE,EAAE;YAC/C,YAAY,CAAC,GAAG,EAAE;gBAChB,IAAI,IAAI,CAAC,aAAa,CAAC,MAAM,GAAG,CAAC,EAAE;oBACjC,MAAM,UAAU,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;oBAErE,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,MAAM,EAAE,UAAU,CAAC,CAAC;iBACtC;gBACD,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC;YACvB,CAAC,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;IAED,+EAA+E;IACvE,gBAAgB;QACtB,uCACK,IAAI,CAAC,OAAO,CAAC,cAAc,KAC9B,IAAI,EAAE,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,SAAS,EAC7D,IAAI,EAAE,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,IAC7B;IACJ,CAAC;IAED;;;OAGG;IACK,oBAAoB;QAC1B,IACE,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,WAAW;YAC3C,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,yBAAyB,EACzD;YACA,IAAI,CAAC,WAAW,CAAC,kBAAM,CAAC,uBAAuB,CAAC,CAAC;SAClD;IACH,CAAC;IAED;;OAEG;IACK,gBAAgB;QACtB,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,SAAS,CAAC,CAAC;QAE1C,0BAA0B;QAC1B,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,KAAK,CAAC,EAAE;YACjC,IAAI,CAAC,0BAA0B,EAAE,CAAC;SACnC;aAAM;YACL,IAAI,CAAC,0BAA0B,EAAE,CAAC;SACnC;QAED,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,oBAAoB,CAAC,CAAC;IACvD,CAAC;IAED;;;OAGG;IACK,qBAAqB,CAAC,IAAY;QACxC;;;UAGE;QACF,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;QAEhC,6BAA6B;QAC7B,IAAI,CAAC,WAAW,EAAE,CAAC;IACrB,CAAC;IAED;;OAEG;IACK,WAAW;QACjB,mFAAmF;QACnF,OACE,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,WAAW;YAC3C,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,KAAK;YACrC,IAAI,CAAC,aAAa,CAAC,MAAM,IAAI,IAAI,CAAC,4BAA4B,EAC9D;YACA,gDAAgD;YAChD,IAAI,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,oBAAoB,EAAE;gBACxD,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,KAAK,CAAC,EAAE;oBACjC,4CAA4C;oBAC5C,IAAI,CAAC,kCAAkC,EAAE,CAAC;iBAC3C;qBAAM;oBACL,wDAAwD;oBACxD,IAAI,CAAC,oCAAoC,EAAE,CAAC;iBAC7C;gBACD,wDAAwD;aACzD;iBAAM,IAAI,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,kBAAkB,EAAE;gBAC7D,IAAI,CAAC,kDAAkD,EAAE,CAAC;gBAC1D,6DAA6D;aAC9D;iBAAM,IAAI,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,kBAAkB,EAAE;gBAC7D,IAAI,CAAC,kCAAkC,EAAE,CAAC;gBAC1C,mEAAmE;aACpE;iBAAM,IAAI,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,yBAAyB,EAAE;gBACpE,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,KAAK,CAAC,EAAE;oBACjC,IAAI,CAAC,sCAAsC,EAAE,CAAC;iBAC/C;qBAAM;oBACL,IAAI,CAAC,sCAAsC,EAAE,CAAC;iBAC/C;aACF;iBAAM;gBACL,IAAI,CAAC,WAAW,CAAC,kBAAM,CAAC,aAAa,CAAC,CAAC;gBACvC,MAAM;aACP;SACF;IACH,CAAC;IAED;;;OAGG;IACK,cAAc;QACpB,IAAI,CAAC,WAAW,CAAC,kBAAM,CAAC,YAAY,CAAC,CAAC;IACxC,CAAC;IAED;;;OAGG;IACK,cAAc,CAAC,GAAU;QAC/B,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC;IAChC,CAAC;IAED;;OAEG;IACK,4BAA4B;QAClC,6FAA6F;QAC7F,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC;QACpB,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,MAAM,EAAE,IAAI,CAAC,cAAc,CAAC,CAAC;QACxD,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;QAClD,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;QAClD,IAAI,CAAC,MAAM,CAAC,cAAc,CAAC,SAAS,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;IACxD,CAAC;IAED;;;OAGG;IACK,WAAW,CAAC,GAAW;QAC7B,2FAA2F;QAC3F,IAAI,IAAI,CAAC,KAAK,KAAK,4BAAgB,CAAC,KAAK,EAAE;YACzC,+BAA+B;YAC/B,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,KAAK,CAAC,CAAC;YAEtC,iBAAiB;YACjB,IAAI,CAAC,MAAM,CAAC,OAAO,EAAE,CAAC;YAEtB,4BAA4B;YAC5B,IAAI,CAAC,4BAA4B,EAAE,CAAC;YAEpC,sBAAsB;YACtB,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,uBAAgB,CAAC,GAAG,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC;SAC7D;IACH,CAAC;IAED;;OAEG;IACK,0BAA0B;QAChC,MAAM,MAAM,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,MAAM,IAAI,EAAE,CAAC;QAE/C,MAAM,IAAI,GAAG,IAAI,0BAAW,EAAE,CAAC;QAC/B,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;QACtB,IAAI,CAAC,UAAU,CAAC,wBAAY,CAAC,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;QACpD,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;QAElD,iBAAiB;QACjB,IAAI,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,EAAE;YAC7C,IAAI,CAAC,WAAW,CAAC,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC,CAAC;YAC7D,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;YAC3B,sBAAsB;SACvB;aAAM;YACL,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;YACtB,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;YACtB,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;YACtB,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;YACtB,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;YAC3B,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;SACnD;QAED,IAAI,CAAC,4BAA4B;YAC/B,uCAA2B,CAAC,cAAc,CAAC;QAC7C,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC,CAAC;IACrC,CAAC;IAED;;;OAGG;IACK,kCAAkC;QACxC,MAAM,IAAI,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;QAEvC,IAAI,IAAI,CAAC,CAAC,CAAC,KAAK,0BAAc,CAAC,OAAO,EAAE;YACtC,IAAI,CAAC,WAAW,CACd,GAAG,kBAAM,CAAC,6BAA6B,OACrC,0BAAc,CAAC,IAAI,CAAC,CAAC,CAAC,CACxB,GAAG,CACJ,CAAC;SACH;aAAM;YACL,gBAAgB;YAChB,IAAI,wBAAY,CAAC,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,KAAK,wBAAY,CAAC,IAAI,EAAE;gBAC5D,MAAM,IAAI,GAAG,0BAAW,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;gBAC1C,IAAI,CAAC,UAAU,GAAG,CAAC,CAAC;gBAEpB,MAAM,UAAU,GAAoB;oBAClC,IAAI,EAAE,IAAI,CAAC,YAAY,EAAE;oBACzB,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC;iBACvC,CAAC;gBAEF,yCAAyC;gBACzC,IAAI,UAAU,CAAC,IAAI,KAAK,SAAS,EAAE;oBACjC,UAAU,CAAC,IAAI,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,SAAS,CAAC;iBAChD;gBACD,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,yBAAyB,CAAC,CAAC;gBAC1D,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAC,UAAU,EAAE,MAAM,EAAE,IAAI,CAAC,MAAM,EAAC,CAAC,CAAC;gBAEtD,mBAAmB;aACpB;iBAAM;gBACL,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,WAAW,CAAC,CAAC;gBAC5C,IAAI,CAAC,4BAA4B,EAAE,CAAC;gBACpC,IAAI,CAAC,IAAI,CAAC,aAAa,EAAE,EAAC,MAAM,EAAE,IAAI,CAAC,MAAM,EAAC,CAAC,CAAC;aACjD;SACF;IACH,CAAC;IAED;;;OAGG;IACK,sCAAsC;QAC5C,MAAM,IAAI,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;QAEvC,IAAI,IAAI,CAAC,CAAC,CAAC,KAAK,0BAAc,CAAC,OAAO,EAAE;YACtC,IAAI,CAAC,WAAW,CACd,GAAG,kBAAM,CAAC,0CAA0C,OAClD,0BAAc,CAAC,IAAI,CAAC,CAAC,CAAC,CACxB,GAAG,CACJ,CAAC;SACH;aAAM;YACL,MAAM,IAAI,GAAG,0BAAW,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;YAC1C,IAAI,CAAC,UAAU,GAAG,CAAC,CAAC;YAEpB,MAAM,UAAU,GAAoB;gBAClC,IAAI,EAAE,IAAI,CAAC,YAAY,EAAE;gBACzB,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC;aACvC,CAAC;YAEF,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,WAAW,CAAC,CAAC;YAC5C,IAAI,CAAC,4BAA4B,EAAE,CAAC;YACpC,IAAI,CAAC,IAAI,CAAC,aAAa,EAAE,EAAC,UAAU,EAAE,MAAM,EAAE,IAAI,CAAC,MAAM,EAAC,CAAC,CAAC;SAC7D;IACH,CAAC;IAED;;OAEG;IACK,0BAA0B;QAChC,MAAM,IAAI,GAAG,IAAI,0BAAW,EAAE,CAAC;QAE/B,wCAAwC;QACxC,MAAM,oBAAoB,GAAG,CAAC,sBAAU,CAAC,MAAM,CAAC,CAAC;QAEjD,6FAA6F;QAC7F,sHAAsH;QACtH,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,MAAM,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,QAAQ,EAAE;YAC5D,oBAAoB,CAAC,IAAI,CAAC,sBAAU,CAAC,QAAQ,CAAC,CAAC;SAChD;QAED,sBAAsB;QACtB,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,kBAAkB,KAAK,SAAS,EAAE;YACvD,oBAAoB,CAAC,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,kBAAkB,CAAC,CAAC;SAClE;QAED,yBAAyB;QACzB,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;QACtB,IAAI,CAAC,UAAU,CAAC,oBAAoB,CAAC,MAAM,CAAC,CAAC;QAC7C,KAAK,MAAM,UAAU,IAAI,oBAAoB,EAAE;YAC7C,IAAI,CAAC,UAAU,CAAC,UAAU,CAAC,CAAC;SAC7B;QAED,IAAI,CAAC,4BAA4B;YAC/B,uCAA2B,CAAC,8BAA8B,CAAC;QAC7D,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC,CAAC;QACnC,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,oBAAoB,CAAC,CAAC;IACvD,CAAC;IAED;;;OAGG;IACK,oCAAoC;QAC1C,MAAM,IAAI,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;QAEvC,IAAI,IAAI,CAAC,CAAC,CAAC,KAAK,IAAI,EAAE;YACpB,IAAI,CAAC,WAAW,CAAC,kBAAM,CAAC,yCAAyC,CAAC,CAAC;SACpE;aAAM,IAAI,IAAI,CAAC,CAAC,CAAC,KAAK,qCAAyB,EAAE;YAChD,IAAI,CAAC,WAAW,CAAC,kBAAM,CAAC,+CAA+C,CAAC,CAAC;SAC1E;aAAM;YACL,6EAA6E;YAC7E,IAAI,IAAI,CAAC,CAAC,CAAC,KAAK,sBAAU,CAAC,MAAM,EAAE;gBACjC,IAAI,CAAC,oBAAoB,GAAG,sBAAU,CAAC,MAAM,CAAC;gBAC9C,IAAI,CAAC,wBAAwB,EAAE,CAAC;gBAChC,0EAA0E;aAC3E;iBAAM,IAAI,IAAI,CAAC,CAAC,CAAC,KAAK,sBAAU,CAAC,QAAQ,EAAE;gBAC1C,IAAI,CAAC,oBAAoB,GAAG,sBAAU,CAAC,QAAQ,CAAC;gBAChD,IAAI,CAAC,gCAAgC,EAAE,CAAC;gBACxC,qFAAqF;aACtF;iBAAM,IAAI,IAAI,CAAC,CAAC,CAAC,KAAK,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,kBAAkB,EAAE;gBAC5D,IAAI,CAAC,oBAAoB,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,kBAAkB,CAAC;gBAClE,IAAI,CAAC,8BAA8B,EAAE,CAAC;aACvC;iBAAM;gBACL,IAAI,CAAC,WAAW,CAAC,kBAAM,CAAC,4CAA4C,CAAC,CAAC;aACvE;SACF;IACH,CAAC;IAED;;;;OAIG;IACK,gCAAgC;QACtC,MAAM,MAAM,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,MAAM,IAAI,EAAE,CAAC;QAC/C,MAAM,QAAQ,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,QAAQ,IAAI,EAAE,CAAC;QAEnD,MAAM,IAAI,GAAG,IAAI,0BAAW,EAAE,CAAC;QAC/B,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;QACtB,IAAI,CAAC,UAAU,CAAC,MAAM,CAAC,UAAU,CAAC,MAAM,CAAC,CAAC,CAAC;QAC3C,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC;QACzB,IAAI,CAAC,UAAU,CAAC,MAAM,CAAC,UAAU,CAAC,QAAQ,CAAC,CAAC,CAAC;QAC7C,IAAI,CAAC,WAAW,CAAC,QAAQ,CAAC,CAAC;QAE3B,IAAI,CAAC,4BAA4B;YAC/B,uCAA2B,CAAC,oCAAoC,CAAC;QACnE,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC,CAAC;QACnC,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,kBAAkB,CAAC,CAAC;IACrD,CAAC;IAEa,8BAA8B;;YAC1C,IAAI,CAAC,4BAA4B;gBAC/B,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,yBAAyB,CAAC;YAC/C,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,MAAM,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,2BAA2B,EAAE,CAAC,CAAC;YAC1E,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,kBAAkB,CAAC,CAAC;QACrD,CAAC;KAAA;IAEa,uCAAuC,CAAC,IAAY;;YAChE,OAAO,MAAM,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,4BAA4B,CAAC,IAAI,CAAC,CAAC;QACrE,CAAC;KAAA;IAEa,iDAAiD,CAC7D,IAAY;;YAEZ,OAAO,IAAI,CAAC,CAAC,CAAC,KAAK,IAAI,CAAC;QAC1B,CAAC;KAAA;IAEa,mDAAmD,CAC/D,IAAY;;YAEZ,OAAO,IAAI,CAAC,CAAC,CAAC,KAAK,IAAI,CAAC;QAC1B,CAAC;KAAA;IAED;;;OAGG;IACW,kDAAkD;;YAC9D,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,8BAA8B,CAAC,CAAC;YAE/D,IAAI,UAAU,GAAY,KAAK,CAAC;YAEhC,IAAI,IAAI,CAAC,oBAAoB,KAAK,sBAAU,CAAC,MAAM,EAAE;gBACnD,UAAU,GAAG,MAAM,IAAI,CAAC,iDAAiD,CACvE,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,CAC1B,CAAC;aACH;iBAAM,IAAI,IAAI,CAAC,oBAAoB,KAAK,sBAAU,CAAC,QAAQ,EAAE;gBAC5D,UAAU;oBACR,MAAM,IAAI,CAAC,mDAAmD,CAC5D,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,CAC1B,CAAC;aACL;iBAAM,IACL,IAAI,CAAC,oBAAoB,KAAK,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,kBAAkB,EACnE;gBACA,UAAU,GAAG,MAAM,IAAI,CAAC,uCAAuC,CAC7D,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,yBAAyB,CAAC,CACrE,CAAC;aACH;YAED,IAAI,CAAC,UAAU,EAAE;gBACf,IAAI,CAAC,WAAW,CAAC,kBAAM,CAAC,0BAA0B,CAAC,CAAC;aACrD;iBAAM;gBACL,IAAI,CAAC,wBAAwB,EAAE,CAAC;aACjC;QACH,CAAC;KAAA;IAED;;OAEG;IACK,wBAAwB;QAC9B,MAAM,IAAI,GAAG,IAAI,0BAAW,EAAE,CAAC;QAE/B,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;QACtB,IAAI,CAAC,UAAU,CAAC,wBAAY,CAAC,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;QACpD,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,CAAC;QAEtB,sBAAsB;QACtB,IAAI,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,EAAE;YAC7C,IAAI,CAAC,UAAU,CAAC,0BAAc,CAAC,IAAI,CAAC,CAAC;YACrC,IAAI,CAAC,WAAW,CAAC,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC,CAAC;SAC9D;aAAM,IAAI,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,EAAE;YACpD,IAAI,CAAC,UAAU,CAAC,0BAAc,CAAC,IAAI,CAAC,CAAC;YACrC,IAAI,CAAC,WAAW,CAAC,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC,CAAC;SAC9D;aAAM;YACL,IAAI,CAAC,UAAU,CAAC,0BAAc,CAAC,QAAQ,CAAC,CAAC;YACzC,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;YACtD,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;SACjD;QACD,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,IAAI,CAAC,CAAC;QAElD,IAAI,CAAC,4BAA4B;YAC/B,uCAA2B,CAAC,oBAAoB,CAAC;QACnD,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC,CAAC;QACnC,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,kBAAkB,CAAC,CAAC;IACrD,CAAC;IAED;;;OAGG;IACK,kCAAkC;QACxC,+EAA+E;QAC/E,MAAM,MAAM,GAAG,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QAE1C,IAAI,MAAM,CAAC,CAAC,CAAC,KAAK,IAAI,IAAI,MAAM,CAAC,CAAC,CAAC,KAAK,0BAAc,CAAC,OAAO,EAAE;YAC9D,IAAI,CAAC,WAAW,CACd,GAAG,kBAAM,CAAC,mCAAmC,MAC3C,0BAAc,CAAC,MAAM,CAAC,CAAC,CAAC,CAC1B,EAAE,CACH,CAAC;SACH;aAAM;YACL,oBAAoB;YACpB,MAAM,WAAW,GAAG,MAAM,CAAC,CAAC,CAAC,CAAC;YAE9B,IAAI,UAA2B,CAAC;YAChC,IAAI,IAAiB,CAAC;YAEtB,OAAO;YACP,IAAI,WAAW,KAAK,0BAAc,CAAC,IAAI,EAAE;gBACvC,8BAA8B;gBAC9B,MAAM,UAAU,GAAG,uCAA2B,CAAC,kBAAkB,CAAC;gBAClE,IAAI,IAAI,CAAC,aAAa,CAAC,MAAM,GAAG,UAAU,EAAE;oBAC1C,IAAI,CAAC,4BAA4B,GAAG,UAAU,CAAC;oBAC/C,OAAO;iBACR;gBAED,IAAI,GAAG,0BAAW,CAAC,UAAU,CAC3B,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,CAC5C,CAAC;gBAEF,UAAU,GAAG;oBACX,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC;oBACtC,IAAI,EAAE,IAAI,CAAC,YAAY,EAAE;iBAC1B,CAAC;gBAEF,4DAA4D;gBAC5D,IAAI,UAAU,CAAC,IAAI,KAAK,SAAS,EAAE;oBACjC,UAAU,CAAC,IAAI,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,SAAS,CAAC;iBAChD;gBAED,WAAW;aACZ;iBAAM,IAAI,WAAW,KAAK,0BAAc,CAAC,QAAQ,EAAE;gBAClD,MAAM,UAAU,GAAG,MAAM,CAAC,CAAC,CAAC,CAAC;gBAC7B,MAAM,UAAU,GACd,uCAA2B,CAAC,sBAAsB,CAAC,UAAU,CAAC,CAAC,CAAC,qCAAqC;gBAEvG,8BAA8B;gBAC9B,IAAI,IAAI,CAAC,aAAa,CAAC,MAAM,GAAG,UAAU,EAAE;oBAC1C,IAAI,CAAC,4BAA4B,GAAG,UAAU,CAAC;oBAC/C,OAAO;iBACR;gBAED,IAAI,GAAG,0BAAW,CAAC,UAAU,CAC3B,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,CAC5C,CAAC;gBAEF,UAAU,GAAG;oBACX,IAAI,EAAE,IAAI,CAAC,UAAU,CAAC,UAAU,CAAC;oBACjC,IAAI,EAAE,IAAI,CAAC,YAAY,EAAE;iBAC1B,CAAC;gBACF,OAAO;aACR;iBAAM,IAAI,WAAW,KAAK,0BAAc,CAAC,IAAI,EAAE;gBAC9C,8BAA8B;gBAC9B,MAAM,UAAU,GAAG,uCAA2B,CAAC,kBAAkB,CAAC;gBAClE,IAAI,IAAI,CAAC,aAAa,CAAC,MAAM,GAAG,UAAU,EAAE;oBAC1C,IAAI,CAAC,4BAA4B,GAAG,UAAU,CAAC;oBAC/C,OAAO;iBACR;gBAED,IAAI,GAAG,0BAAW,CAAC,UAAU,CAC3B,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,CAC5C,CAAC;gBAEF,UAAU,GAAG;oBACX,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;oBACtC,IAAI,EAAE,IAAI,CAAC,YAAY,EAAE;iBAC1B,CAAC;aACH;YAED,6BAA6B;YAC7B,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,qBAAqB,CAAC,CAAC;YAEtD,gEAAgE;YAChE,IAAI,wBAAY,CAAC,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,KAAK,wBAAY,CAAC,OAAO,EAAE;gBAC/D,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,WAAW,CAAC,CAAC;gBAC5C,IAAI,CAAC,4BAA4B,EAAE,CAAC;gBACpC,IAAI,CAAC,IAAI,CAAC,aAAa,EAAE,EAAC,UAAU,EAAE,MAAM,EAAE,IAAI,CAAC,MAAM,EAAC,CAAC,CAAC;aAC7D;iBAAM,IAAI,wBAAY,CAAC,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,KAAK,wBAAY,CAAC,IAAI,EAAE;gBACnE;mHACmG;gBACnG,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,yBAAyB,CAAC,CAAC;gBAC1D,IAAI,CAAC,4BAA4B;oBAC/B,uCAA2B,CAAC,oBAAoB,CAAC;gBACnD,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAC,UAAU,EAAE,MAAM,EAAE,IAAI,CAAC,MAAM,EAAC,CAAC,CAAC;gBACtD;;;kBAGE;aACH;iBAAM,IACL,wBAAY,CAAC,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,KAAK,wBAAY,CAAC,SAAS,EAC7D;gBACA,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,WAAW,CAAC,CAAC;gBAC5C,IAAI,CAAC,4BAA4B,EAAE,CAAC;gBACpC,IAAI,CAAC,IAAI,CAAC,aAAa,EAAE;oBACvB,UAAU;oBACV,MAAM,EAAE,IAAI,CAAC,MAAM;iBACpB,CAAC,CAAC;aACJ;SACF;IACH,CAAC;IAED;;OAEG;IACK,sCAAsC;QAC5C,+EAA+E;QAC/E,MAAM,MAAM,GAAG,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QAE1C,IAAI,MAAM,CAAC,CAAC,CAAC,KAAK,IAAI,IAAI,MAAM,CAAC,CAAC,CAAC,KAAK,0BAAc,CAAC,OAAO,EAAE;YAC9D,IAAI,CAAC,WAAW,CACd,GAAG,kBAAM,CAAC,0CAA0C,MAClD,0BAAc,CAAC,MAAM,CAAC,CAAC,CAAC,CAC1B,EAAE,CACH,CAAC;SACH;aAAM;YACL,oBAAoB;YACpB,MAAM,WAAW,GAAG,MAAM,CAAC,CAAC,CAAC,CAAC;YAE9B,IAAI,UAA2B,CAAC;YAChC,IAAI,IAAiB,CAAC;YAEtB,OAAO;YACP,IAAI,WAAW,KAAK,0BAAc,CAAC,IAAI,EAAE;gBACvC,8BAA8B;gBAC9B,MAAM,UAAU,GAAG,uCAA2B,CAAC,kBAAkB,CAAC;gBAClE,IAAI,IAAI,CAAC,aAAa,CAAC,MAAM,GAAG,UAAU,EAAE;oBAC1C,IAAI,CAAC,4BAA4B,GAAG,UAAU,CAAC;oBAC/C,OAAO;iBACR;gBAED,IAAI,GAAG,0BAAW,CAAC,UAAU,CAC3B,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,CAC5C,CAAC;gBAEF,UAAU,GAAG;oBACX,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,YAAY,EAAE,CAAC;oBACtC,IAAI,EAAE,IAAI,CAAC,YAAY,EAAE;iBAC1B,CAAC;gBAEF,4DAA4D;gBAC5D,IAAI,UAAU,CAAC,IAAI,KAAK,SAAS,EAAE;oBACjC,UAAU,CAAC,IAAI,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,SAAS,CAAC;iBAChD;gBAED,WAAW;aACZ;iBAAM,IAAI,WAAW,KAAK,0BAAc,CAAC,QAAQ,EAAE;gBAClD,MAAM,UAAU,GAAG,MAAM,CAAC,CAAC,CAAC,CAAC;gBAC7B,MAAM,UAAU,GACd,uCAA2B,CAAC,sBAAsB,CAAC,UAAU,CAAC,CAAC,CAAC,8BAA8B;gBAEhG,8BAA8B;gBAC9B,IAAI,IAAI,CAAC,aAAa,CAAC,MAAM,GAAG,UAAU,EAAE;oBAC1C,IAAI,CAAC,4BAA4B,GAAG,UAAU,CAAC;oBAC/C,OAAO;iBACR;gBAED,IAAI,GAAG,0BAAW,CAAC,UAAU,CAC3B,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,CAC5C,CAAC;gBAEF,UAAU,GAAG;oBACX,IAAI,EAAE,IAAI,CAAC,UAAU,CAAC,UAAU,CAAC;oBACjC,IAAI,EAAE,IAAI,CAAC,YAAY,EAAE;iBAC1B,CAAC;gBACF,OAAO;aACR;iBAAM,IAAI,WAAW,KAAK,0BAAc,CAAC,IAAI,EAAE;gBAC9C,8BAA8B;gBAC9B,MAAM,UAAU,GAAG,uCAA2B,CAAC,kBAAkB,CAAC;gBAClE,IAAI,IAAI,CAAC,aAAa,CAAC,MAAM,GAAG,UAAU,EAAE;oBAC1C,IAAI,CAAC,4BAA4B,GAAG,UAAU,CAAC;oBAC/C,OAAO;iBACR;gBAED,IAAI,GAAG,0BAAW,CAAC,UAAU,CAC3B,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,CAC5C,CAAC;gBAEF,UAAU,GAAG;oBACX,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC;oBACtC,IAAI,EAAE,IAAI,CAAC,YAAY,EAAE;iBAC1B,CAAC;aACH;YAED,IAAI,CAAC,QAAQ,CAAC,4BAAgB,CAAC,WAAW,CAAC,CAAC;YAC5C,IAAI,CAAC,4BAA4B,EAAE,CAAC;YACpC,IAAI,CAAC,IAAI,CAAC,aAAa,EAAE,EAAC,UAAU,EAAE,MAAM,EAAE,IAAI,CAAC,MAAM,EAAC,CAAC,CAAC;SAC7D;IACH,CAAC;IAED,IAAI,kBAAkB;QACpB,yBACK,IAAI,CAAC,OAAO,EACf;IACJ,CAAC;CACF;AAGC,kCAAW"} \ No newline at end of file