log('Loading ManiaControl v' . self::VERSION . '...'); // Load ManiaControl Modules $this->database = new Database($this); $this->callbackManager = new CallbackManager($this); $this->settingManager = new SettingManager($this); $this->manialinkManager = new ManialinkManager($this); $this->actionsMenu = new ActionsMenu($this); $this->chat = new Chat($this); $this->commandManager = new CommandManager($this); $this->server = new Server($this); $this->playerManager = new PlayerManager($this); $this->authenticationManager = new AuthenticationManager($this); $this->mapManager = new MapManager($this); $this->configurator = new Configurator($this); $this->pluginManager = new PluginManager($this); $this->updateManager = new UpdateManager($this); // Register for commands $this->commandManager->registerCommandListener('version', $this, 'command_Version'); } /** * Print a message to console and log * * @param string $message */ public function log($message) { logMessage($message); } /** * Return message composed of client error message and error code * * @param object $client * @return string */ public function getClientErrorText($client = null) { if (is_object($client)) { return $client->getErrorMessage() . ' (' . $client->getErrorCode() . ')'; } return $this->client->getErrorMessage() . ' (' . $this->client->getErrorCode() . ')'; } /** * Send ManiaControl version * * @param array $chat * @param Player $player * @return bool */ public function command_Version(array $chat, Player $player) { $message = 'This server is using ManiaControl v' . ManiaControl::VERSION . '!'; return $this->chat->sendInformation($message, $player->login); } /** * Quit ManiaControl and log the given message * * @param string $message */ public function quit($message = '') { // OnShutdown callback $this->callbackManager->triggerCallback(CallbackManager::CB_MC_ONSHUTDOWN, array(CallbackManager::CB_MC_ONSHUTDOWN)); if ($this->client) { // Announce quit $this->chat->sendInformation('ManiaControl shutting down.'); // Hide manialinks $this->client->query('SendHideManialinkPage'); } // Log quit reason if ($message) { $this->log($message); } // Shutdown if ($this->client) { $this->client->Terminate(); } logMessage('Quitting ManiaControl!'); exit(); } /** * Run ManiaControl */ public function run() { logMessage('Starting ManiaControl v' . self::VERSION . '!'); // Load plugins $this->pluginManager->loadPlugins(); // Connect to server $this->connect(); // Register shutdown handler register_shutdown_function(array($this, 'quit')); // Loading finished $this->log('Loading completed!'); // Announce ManiaControl $this->chat->sendInformation('ManiaControl v' . self::VERSION . ' successfully started!'); // OnInit callback $this->callbackManager->triggerCallback(CallbackManager::CB_MC_ONINIT, array(CallbackManager::CB_MC_ONINIT)); // Main loop while (!$this->shutdownRequested) { $loopStart = microtime(true); // Disable script timeout set_time_limit(30); // Manager callbacks $this->callbackManager->manageCallbacks(); // Yield for next tick $loopEnd = microtime(true); $sleepTime = 300000 - $loopEnd + $loopStart; if ($sleepTime > 0) { usleep($sleepTime); } } // Shutdown $this->quit(); } /** * Connect to ManiaPlanet server */ private function connect() { // Load remote client $this->client = new \IXR_ClientMulticall_Gbx(); $host = $this->server->config->xpath('host'); if (!$host) trigger_error("Invalid server configuration (host).", E_USER_ERROR); $host = (string) $host[0]; $port = $this->server->config->xpath('port'); if (!$host) trigger_error("Invalid server configuration (port).", E_USER_ERROR); $port = (string) $port[0]; $this->log("Connecting to server at {$host}:{$port}..."); // Connect if (!$this->client->InitWithIp($host, $port, 20)) { trigger_error("Couldn't connect to server! " . $this->getClientErrorText(), E_USER_ERROR); } $login = $this->server->config->xpath('login'); if (!$login) trigger_error("Invalid server configuration (login).", E_USER_ERROR); $login = (string) $login[0]; $pass = $this->server->config->xpath('pass'); if (!$pass) trigger_error("Invalid server configuration (password).", E_USER_ERROR); $pass = (string) $pass[0]; // Authenticate if (!$this->client->query('Authenticate', $login, $pass)) { trigger_error("Couldn't authenticate on server with user '{$login}'! " . $this->getClientErrorText(), E_USER_ERROR); } // Enable callback system if (!$this->client->query('EnableCallbacks', true)) { trigger_error("Couldn't enable callbacks! " . $this->getClientErrorText(), E_USER_ERROR); } // Wait for server to be ready if (!$this->server->waitForStatus(4)) { trigger_error("Server couldn't get ready!", E_USER_ERROR); } // Set api version if (!$this->client->query('SetApiVersion', self::API_VERSION)) { trigger_error( "Couldn't set API version '" . self::API_VERSION . "'! This might cause problems. " . $this->getClientErrorText()); } // Connect finished $this->log("Server Connection successfully established!"); // Hide old widgets $this->client->query('SendHideManialinkPage'); // Enable script callbacks if needed if ($this->server->getGameMode() != 0) return; if (!$this->client->query('GetModeScriptSettings')) { trigger_error("Couldn't get mode script settings. " . $this->getClientErrorText()); return; } $scriptSettings = $this->client->getResponse(); if (!array_key_exists('S_UseScriptCallbacks', $scriptSettings)) return; $scriptSettings['S_UseScriptCallbacks'] = true; if (!$this->client->query('SetModeScriptSettings', $scriptSettings)) { trigger_error("Couldn't set mode script settings to enable script callbacks. " . $this->getClientErrorText()); return; } $this->log('Script Callbacks successfully enabled!'); } }