X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=application%2Fhub%2Fmain%2Ftools%2Fclass_HubTools.php;h=855a59210ba76a55f50dd65623c5d65aac0531f4;hb=57f03d1960de70517f197892375654d5b6dbeab7;hp=bf11d00975b39b1047ed84043fbc47484eadfc1f;hpb=4166af060bf75b8fe9c645ceac1151bec0ce1784;p=hub.git diff --git a/application/hub/main/tools/class_HubTools.php b/application/hub/main/tools/class_HubTools.php index bf11d0097..855a59210 100644 --- a/application/hub/main/tools/class_HubTools.php +++ b/application/hub/main/tools/class_HubTools.php @@ -4,7 +4,7 @@ * * @author Roland Haeder * @version 0.0.0 - * @copyright Copyright (c) 2007, 2008 Roland Haeder, 2009, 2010 Hub Developer Team + * @copyright Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2011 Hub Developer Team * @license GNU GPL 3.0 or any newer version * @link http://www.ship-simu.org * @@ -21,7 +21,7 @@ * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ -class HubTools extends BaseFrameworkSystem { +class HubTools extends BaseHubSystem { // Constants for exceptions const EXCEPTION_SESSION_ID_IS_INVALID = 0x200; const EXCEPTION_HOSTNAME_NOT_FOUND = 0x201; @@ -39,7 +39,7 @@ class HubTools extends BaseFrameworkSystem { /** * Self instance */ - private static $selfInstance = null; + private static $selfInstance = NULL; /** * Protected constructor @@ -59,7 +59,7 @@ class HubTools extends BaseFrameworkSystem { * * @retuen $selfInstance An instance of this class */ - public final static function getInstance () { + public static final function getSelfInstance () { // Is the instance set if (is_null(self::$selfInstance)) { // Then set it @@ -92,10 +92,39 @@ class HubTools extends BaseFrameworkSystem { // And ask it for the session id $recipient = $wrapperInstance->resolveIpPortBySessionId($sessionId); + // Is the recipient invalid? + if ($recipient == 'invalid:invalid') { + // Get the instance, this might throw a NPE + $nodeInstance = Registry::getRegistry()->getInstance('node'); + + // Is the session id the same? + if ($nodeInstance->getSessionId() == $sessionId) { + // Then get the ip:port from it, assume TCP by default + $recipient = self::determineOwnExternalIp() . ':' . $nodeInstance->getConfigInstance()->getConfigEntry('node_tcp_listen_port'); + } // END - if + } // END - if + // Return result return $recipient; } + /** + * Resolves a ip:port combination into a session id + * + * @param $ipPort Ip:port combination + * @return $sessionId Valid session id + */ + public static function resolveSessionIdByIpPort ($ipPort) { + // Get a wrapper instance + $wrapperInstance = DatabaseWrapperFactory::createWrapperByConfiguredName('node_list_db_wrapper_class'); + + // And ask it for the session id + $sessionId = $wrapperInstance->resolveSessionIdByIpPort($ipPort); + + // Return result + return $sessionId; + } + /** * Resolves given session id into an ip:port combination, if ip:port is set, it won't be translated * @@ -106,51 +135,79 @@ class HubTools extends BaseFrameworkSystem { */ public static function resolveSessionId ($sessionId) { // Get an own instance - $selfInstance = self::getInstance(); + $selfInstance = self::getSelfInstance(); // Default is direct ip:port $recipient = $sessionId; // Does it match a direct ip:port? (hint: see www.regexlib.com for the regular expression) - if (!preg_match('/((?:2[0-5]{2}|1\d{2}|[1-9]\d|[1-9])\.(?:(?:2[0-5]{2}|1\d{2}|[1-9]\d|\d)\.){2}(?:2[0-5]{2}|1\d{2}|[1-9]\d|\d)):(\d|[1-9]\d|[1-9]\d{2,3}|[1-5]\d{4}|6[0-4]\d{3}|654\d{2}|655[0-2]\d|6553[0-5])/', $sessionId)) { - // Is it in cache? - if (isset($selfInstance->sessionIdCache[$sessionId])) { - // Debug message - $selfInstance->debugOutput('HUB-TOOLS: Using entry from sessionIdCache[] array.'); - - // Then use it - $recipient = $selfInstance->sessionIdCache[$sessionId]; - } elseif (preg_match('/([a-zA-Z0-9]([a-zA-Z0-9\-]{0,61}[a-zA-Z0-9])?\.)+[a-zA-Z]{2,6}/', $sessionId)) { - // Hostname:port found - $hostnameArray = explode(':', $sessionId); - - // Try to resolve it and add port again - // @TODO We may want to encapsulate this PHP call into an own class - $recipient = gethostbyname($hostnameArray[0]) . ':' . $hostnameArray[1]; - - // Is it valid? - if ($recipient == $sessionId) { - // Resolving hostname->IP failed! - throw new NoValidHostnameException($hostnameArray, self::EXCEPTION_HOSTNAME_NOT_FOUND); - } // END - if - } elseif (!preg_match('/([a-f0-9]{' . $selfInstance->getSessionIdLength() . '})/', $sessionId)) { - // Invalid session id - throw new InvalidSessionIdException($sessionId, self::EXCEPTION_SESSION_ID_IS_INVALID); - } else { - // Debug message - $selfInstance->debugOutput('HUB-TOOLS: Using internal resolver.'); - - // Resolve it here - $recipient = $selfInstance->resolveIpPortBySessionId($sessionId); - } - } // END - if - - // Output message - $selfInstance->debugOutput('HUB-TOOLS: Session id ' . $sessionId . ' resolved to ' . $recipient); + if (preg_match('/((25[0-5]|2[0-4][0-9]|[0-1]{1}[0-9]{2}|[1-9]{1}[0-9]{1}|[1-9])\.(25[0-5]|2[0-4][0-9]|[0-1]{1}[0-9]{2}|[1-9]{1}[0-9]{1}|[1-9]|0)\.(25[0-5]|2[0-4][0-9]|[0-1]{1}[0-9]{2}|[1-9]{1}[0-9]{1}|[1-9]|0)\.(25[0-5]|2[0-4][0-9]|[0-1]{1}[0-9]{2}|[1-9]{1}[0-9]{1}|[0-9])):([0-9]{3,5})/', $sessionId)) { + // Direct ip:port found + $selfInstance->debugOutput('HUB-TOOLS: Direct ip:port ' . $sessionId . ' detected.'); + } elseif (isset($selfInstance->sessionIdCache[$sessionId])) { + // Debug message + $selfInstance->debugOutput('HUB-TOOLS: Using entry from sessionIdCache[] array.'); + + // Found in cache! + $recipient = $selfInstance->sessionIdCache[$sessionId]; + + // Debug message + $selfInstance->debugOutput('HUB-TOOLS: sessionIdCache[' . $sessionId . ']=' . $recipient); + } elseif (preg_match('/([a-zA-Z0-9]([a-zA-Z0-9\-]{0,61}[a-zA-Z0-9])?\.)+[a-zA-Z]{2,6}:([0-9]{3,5})/', $sessionId)) { + // Hostname:port found + $selfInstance->debugOutput('HUB-TOOLS: hostname:port ' . $sessionId . ' detected.'); + + // Hostname:port found + $hostnameArray = explode(':', $sessionId); + + // Try to resolve it and add port again + // @TODO Please try to encapsulate this PHP call into an own class + $recipient = gethostbyname($hostnameArray[0]) . ':' . $hostnameArray[1]; + + // Is it valid? + if ($recipient == $sessionId) { + // Resolving hostname->IP failed! + throw new NoValidHostnameException($hostnameArray, self::EXCEPTION_HOSTNAME_NOT_FOUND); + } // END - if + + // Debug message + $selfInstance->debugOutput('HUB-TOOLS: hostname:port ' . $sessionId . ' resolved to ' . $recipient); + } elseif (preg_match('/([a-f0-9]{' . $selfInstance->getSessionIdLength() . '})/', $sessionId)) { + // Debug message + $selfInstance->debugOutput('HUB-TOOLS: Using internal session id resolver.'); + + // Resolve session id into a ip:port combination + $recipient = $selfInstance->resolveIpPortBySessionId($sessionId); + + // Debug message + $selfInstance->debugOutput('HUB-TOOLS: session id ' . $sessionId . ' resolved to ' . $recipient); + } else { + // Invalid session id + throw new InvalidSessionIdException($sessionId, self::EXCEPTION_SESSION_ID_IS_INVALID); + } // Return it return $recipient; } + + /** + * Determine IP or 'external_ip' if set + * + * @return $ip The determined external ip of this node + */ + public static function determineOwnExternalIp () { + // Is the external_ip config entry set? + if (FrameworkConfiguration::getSelfInstance()->getConfigEntry('external_ip') != '') { + // Use it as external ip + $ip = FrameworkConfiguration::getSelfInstance()->getConfigEntry('external_ip'); + } else { + // Determine own external ip by connecting to my (coder) server at 188.138.90.169 + $ip = ConsoleTools::determineExternalIp(); + } + + // Return it + return $ip; + } } // [EOF]