Method createSocks5Connection

deps/undici/undici.js:10955–11021

* Create a SOCKS5 connection to the proxy

(targetHost, targetPort)

       * Create a SOCKS5 connection to the proxy
       */
      async createSocks5Connection(targetHost, targetPort) {
        const proxyHost = this[kProxyUrl].hostname;
        const proxyPort = parseInt(this[kProxyUrl].port) || 1080;
        debug("creating SOCKS5 connection to", proxyHost, proxyPort);
        const socketReady = Promise.withResolvers();
        this[kConnector]({
          hostname: proxyHost,
          host: proxyHost,
          port: proxyPort,
          protocol: this[kProxyProtocol]
        }, (err, socket2) => {
          if (err) {
            socketReady.reject(err);
          } else {
            socketReady.resolve(socket2);
          }
        });
        const socket = await socketReady.promise;
        const socks5Client = new Socks5Client(socket, this[kProxyAuth]);
        socks5Client.on("error", (err) => {
          debug("SOCKS5 error:", err);
          socket.destroy();
        });
        await socks5Client.handshake();
        const authenticationReady = Promise.withResolvers();
        const authenticationTimeout = setTimeout(() => {
          authenticationReady.reject(new Error("SOCKS5 authentication timeout"));
        }, 5e3);
        const onAuthenticated = /* @__PURE__ */ __name(() => {
          clearTimeout(authenticationTimeout);
          socks5Client.removeListener("error", onAuthenticationError);
          authenticationReady.resolve();
        }, "onAuthenticated");
        const onAuthenticationError = /* @__PURE__ */ __name((err) => {
          clearTimeout(authenticationTimeout);
          socks5Client.removeListener("authenticated", onAuthenticated);
          authenticationReady.reject(err);
        }, "onAuthenticationError");
        if (socks5Client.state === STATES.AUTHENTICATED) {
          clearTimeout(authenticationTimeout);
          authenticationReady.resolve();
        } else {
          socks5Client.once("authenticated", onAuthenticated);
          socks5Client.once("error", onAuthenticationError);
        }
        await authenticationReady.promise;
        await socks5Client.connect(targetHost, targetPort);
        const connectionReady = Promise.withResolvers();
        const connectionTimeout = setTimeout(() => {
          connectionReady.reject(new Error("SOCKS5 connection timeout"));
        }, 5e3);
        const onConnected = /* @__PURE__ */ __name((info) => {
          debug("SOCKS5 tunnel established to", targetHost, targetPort, "via", info);
          clearTimeout(connectionTimeout);
          socks5Client.removeListener("error", onConnectionError);
          connectionReady.resolve();
        }, "onConnected");
        const onConnectionError = /* @__PURE__ */ __name((err) => {