errorHandler = new ErrorHandler($this); $this->log('Loading ManiaControl v' . self::VERSION . '...'); // Load config $this->config = FileUtil::loadConfig('server.xml'); // Load ManiaControl Modules $this->database = new Database($this); $this->callbackManager = new CallbackManager($this); $this->timerManager = new TimerManager($this); $this->fileReader = new AsynchronousFileReader($this); $this->billManager = new BillManager($this); $this->settingManager = new SettingManager($this); $this->statisticManager = new StatisticManager($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->authenticationManager = new AuthenticationManager($this); $this->playerManager = new PlayerManager($this); $this->mapManager = new MapManager($this); $this->configurator = new Configurator($this); $this->pluginManager = new PluginManager($this); $this->updateManager = new UpdateManager($this); //Define Permission Levels $this->authenticationManager->definePermissionLevel(self::SETTING_PERMISSION_SHUTDOWN, AuthenticationManager::AUTH_LEVEL_SUPERADMIN); $this->authenticationManager->definePermissionLevel(self::SETTING_PERMISSION_RESTART, AuthenticationManager::AUTH_LEVEL_SUPERADMIN); // Register for commands $this->commandManager->registerCommandListener('version', $this, 'command_Version'); $this->commandManager->registerCommandListener('restart', $this, 'command_Restart', true); $this->commandManager->registerCommandListener('shutdown', $this, 'command_Shutdown', true); } /** * Print a message to console and log * * @param string $message */ public function log($message, $stripCodes = false) { $date = date("d.M y H:i:s"); if ($stripCodes) { $message = Formatter::stripCodes($message); } logMessage($date . ' ' . $message); } /** * Get the Operating System on which ManiaControl is running * * @param string $compareOS * @return string */ public function getOS($compareOS = null) { $windows = defined('PHP_WINDOWS_VERSION_MAJOR'); if ($compareOS) { // Return bool whether OS equals $compareOS if ($compareOS == self::OS_WIN) { return $windows; } return !$windows; } // Return OS if ($windows) { return self::OS_WIN; } return self::OS_UNIX; } /** * Handle Version Command * * @param array $chatCallback * @param Player $player */ public function command_Version(array $chatCallback, Player $player) { $message = 'This server is using ManiaControl v' . ManiaControl::VERSION . '!'; $this->chat->sendInformation($message, $player->login); } /** * Handle Restart AdminCommand * * @param array $chatCallback * @param Player $player */ public function command_Restart(array $chatCallback, Player $player) { if (!$this->authenticationManager->checkPermission($player, self::SETTING_PERMISSION_RESTART)) { $this->authenticationManager->sendNotAllowed($player); return; } $this->restart("ManiaControl Restart requested by '{$player->login}'!"); } /** * Handle //shutdown command * * @param array $chat * @param Player $player */ public function command_Shutdown(array $chat, Player $player) { if (!$this->authenticationManager->checkPermission($player, self::SETTING_PERMISSION_SHUTDOWN)) { $this->authenticationManager->sendNotAllowed($player); return; } $this->quit("ManiaControl Shutdown requested by '{$player->login}'!"); } /** * Quit ManiaControl and log the given message * * @param string $message */ public function quit($message = null) { if ($message) { $this->log($message); } exit(); } /** * Handle PHP Process Shutdown */ public function handleShutdown() { // OnShutdown callback $this->callbackManager->triggerCallback(CallbackManager::CB_ONSHUTDOWN); // Announce quit $this->chat->sendInformation('ManiaControl shutting down.'); if($this->client){ try{ // Hide manialinks $this->client->sendHideManialinkPage(); // Close the client connection $this->client->delete($this->server->ip, $this->server->port); } catch(FatalException $e){ $this->errorHandler->triggerDebugNotice($e->getMessage() ." File: " . $e->getFile() . " Line: " . $e->getLine()); } } //Check and Trigger Fatal Errors $error = error_get_last(); if ($error && ($error['type'] & E_FATAL)) { $this->errorHandler->errorHandler($error['type'], $error['message'], $error['file'], $error['line']); } //Disable Garbage Collector $this->collectGarbage(); gc_disable(); $this->log('Quitting ManiaControl!'); exit(); } /** * Restart ManiaControl * * @param string $message */ public function restart($message = null) { // Shutdown callback $this->callbackManager->triggerCallback(CallbackManager::CB_ONSHUTDOWN); // Announce restart $this->chat->sendInformation('Restarting ManiaControl...'); if ($message) { $this->log($message); } // Hide widgets $this->client->sendHideManialinkPage(); $this->log('Restarting ManiaControl!'); // Execute start script in background if ($this->getOS(self::OS_UNIX)) { $command = 'sh ' . escapeshellarg(ManiaControlDir . '/ManiaControl.sh') . ' > /dev/null &'; exec($command); } else { $command = escapeshellarg(ManiaControlDir . "\ManiaControl.bat"); system($command); // TODO, windows stucks here as long controller is running } exit(); } /** * Run ManiaControl */ public function run() { $this->log('Starting ManiaControl v' . self::VERSION . '!'); // Register shutdown handler register_shutdown_function(array($this, 'handleShutdown')); // Connect to server $this->connect(); // OnInit callback $this->callbackManager->triggerCallback(CallbackManager::CB_ONINIT); // Load plugins $this->pluginManager->loadPlugins(); // AfterInit callback $this->callbackManager->triggerCallback(CallbackManager::CB_AFTERINIT); //Enable Garbage Collecting gc_enable(); $this->timerManager->registerTimerListening($this, 'collectGarbage', 1000 * 60); // Announce ManiaControl $this->chat->sendInformation('ManiaControl v' . self::VERSION . ' successfully started!'); // Loading finished $this->log('Loading completed!'); $this->log('Link: maniaplanet://#join=' . $this->server->login . '@' . $this->server->titleId); // Main loop while(!$this->shutdownRequested) { $loopStart = microtime(true); // Disable script timeout set_time_limit(self::SCRIPT_TIMEOUT); try { // Manager callbacks $this->callbackManager->manageCallbacks(); } catch(FatalException $e) { $this->quit($e->getMessage()); } // Manage FileReader $this->fileReader->appendData(); // Yield for next tick $loopEnd = microtime(true); $sleepTime = (int)(1000 - $loopEnd + $loopStart); if ($sleepTime > 0) { usleep($sleepTime); } } // Shutdown $this->quit(); } /** * Collect Garbage */ public function collectGarbage() { gc_collect_cycles(); } /** * Connect to ManiaPlanet server */ private function connect() { // Load remote client $host = $this->config->server->xpath('host'); if (!$host) { trigger_error("Invalid server configuration (host).", E_USER_ERROR); } $host = (string)$host[0]; $port = $this->config->server->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}..."); $login = $this->config->server->xpath('login'); if (!$login) { trigger_error("Invalid server configuration (login).", E_USER_ERROR); } $login = (string)$login[0]; $pass = $this->config->server->xpath('pass'); if (!$pass) { trigger_error("Invalid server configuration (password).", E_USER_ERROR); } $pass = (string)$pass[0]; try { $this->client = Connection::factory($host, $port, self::CONNECT_TIMEOUT, $login, $pass); } catch(Exception $e) { trigger_error("Couldn't authenticate on server with user '{$login}'! " . $e->getMessage(), E_USER_ERROR); } // Enable callback system $this->client->enableCallbacks(true); // Wait for server to be ready if (!$this->server->waitForStatus(4)) { trigger_error("Server couldn't get ready!", E_USER_ERROR); } // Connect finished $this->log("Server Connection successfully established!"); // Hide old widgets $this->client->sendHideManialinkPage(); // Enable script callbacks if needed if ($this->server->getGameMode() != 0) { return; } try { $scriptSettings = $this->client->getModeScriptSettings(); } catch(Exception $e) { if ($e->getMessage() == 'Not in script mode.') { return; } throw $e; } if (!array_key_exists('S_UseScriptCallbacks', $scriptSettings)) { return; } $scriptSettings['S_UseScriptCallbacks'] = true; try { $this->client->setModeScriptSettings($scriptSettings); } catch(Exception $e) { trigger_error("Couldn't set mode script settings to enable script callbacks. " . $e->getMessage()); return; } $this->log('Script Callbacks successfully enabled!'); } }