OGP-Website/includes/database_mysql.php

<?php
/*
 *
 * OGP - Open Game Panel
 * Copyright (C) 2008 - 2015 The OGP Development Team
 *
 * http://www.opengamepanel.org/
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version 2
 * of the License, or any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 *
 */

require_once("includes/database.php");

function real_escape_string_recursive(&$item, $key, $link){
    $item = mysql_real_escape_string($item, $link);
}

class OGPDatabaseMySQL extends OGPDatabase
{
	private $link;

	private $table_prefix;

	function __construct()
	{

	}

	function __destruct() {
		if ( $this->link )
			mysql_close($this->link);
	}

	/// \return TRUE if connection was created successfully.
	/// \return -1 When host is invalid.
	/// \return -11 When connection to database could not be established
	/// \return -12 When database was not valid.
	/// \return -99 When mysql php module is not available.
	public function connect($db_host, $db_user, $db_pass, $db_name, $table_prefix = NULL) {
		if ( !extension_loaded("mysql") )
			return -99;

		$this->table_prefix = $table_prefix;

		/// \todo We might want to do other checks here as well?
		if ( $db_host === NULL )
			return -1;

		$this->link = mysql_connect($db_host, $db_user, $db_pass);

		if ( $this->link === FALSE )
			return -11;

		if ( mysql_select_db($db_name,$this->link) === FALSE )
			return -12;
		
		array_walk_recursive($_POST, 'real_escape_string_recursive', $this->link);
		array_walk_recursive($_GET, 'real_escape_string_recursive', $this->link);
		array_walk_recursive($_REQUEST, 'real_escape_string_recursive', $this->link);
		
		return TRUE;
	}

	private function listQuery($query) {
		if ( !$this->link ) return FALSE;

		++$this->queries_;
		$result = mysql_query($query, $this->link);

		if ( mysql_errno($this->link) > 0 )
			print mysql_error($this->link);

		if ( $result === FALSE )
			return FALSE;

		if ( mysql_num_rows($result) == 0 )
			return FALSE;

		$results = array();

		while ( $row = mysql_fetch_assoc( $result ) )
			array_push($results,$row);

		return $results;
	}

	public function getSettings() {
		if ( !$this->link ) return;
		$query = sprintf("SELECT * FROM `%ssettings`",
			$this->table_prefix);
		++$this->queries_;
		$result = mysql_query($query,$this->link);

		$results = array();

		while ( $row = mysql_fetch_assoc($result) )
			$results[$row['setting']] = strip_real_escape_string($row['value']);

		// Default setting values in case one hasn't been set
		if(!isset($results["login_attempts_before_banned"]) || empty($results["login_attempts_before_banned"]) || !is_numeric($results["login_attempts_before_banned"])){
			$results["login_attempts_before_banned"] = 6;
		}

		return $results;
	}

	public function getSetting($name) {
		if ( !$this->link ) return;
		$query = sprintf("SELECT `value` FROM `%ssettings`
			WHERE `setting` = '%s'",
			$this->table_prefix,
			mysql_real_escape_string($name,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);

		if ( mysql_affected_rows($this->link) !== 1 )
			return FALSE;

		$results = mysql_fetch_assoc($result);

		return strip_real_escape_string($results["value"]);
	}

	public function setSettings($settings) {
		if ( !$this->link ) return FALSE;
		if ( !is_array($settings) ) return FALSE;

		foreach ( $settings as $s_key => $s_value )
		{
			$query = sprintf('INSERT INTO `%1$ssettings` (`setting`,`value`)
				VALUES(\'%2$s\', \'%3$s\') ON DUPLICATE KEY
				UPDATE value=\'%3$s\'',
				$this->table_prefix,
				mysql_real_escape_string($s_key,$this->link),
				mysql_real_escape_string($s_value,$this->link));
			++$this->queries_;
			mysql_query($query,$this->link);
		}
		return TRUE;
	}

	public function getUser($username) {
		if ( !$this->link ) return array();
		$query = sprintf("SELECT * FROM `%susers` WHERE `users_login` = '%s';",
			$this->table_prefix,
			mysql_real_escape_string($username,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);
		return mysql_fetch_assoc($result);
	}

	public function getUserById($user_id) {
		if ( !$this->link ) return array();
		$query = sprintf("SELECT * FROM `%susers` WHERE `user_id` = %d;",
			$this->table_prefix,
			mysql_real_escape_string($user_id,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);
		return mysql_fetch_assoc($result);
	}

	public function getUsersByHomeId($home_id) {
		$query = sprintf('SELECT *
			FROM %1$susers
			NATURAL JOIN %1$suser_homes
			WHERE home_id = %2$s',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link));
		return $this->listQuery($query);
	}
	
	public function getGroupUsersByHomeId($home_id) {
		$query = sprintf('SELECT *
			FROM %1$susers
			NATURAL JOIN %1$suser_groups
			NATURAL JOIN %1$suser_group_homes
			WHERE home_id = %2$s',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link));
		return $this->listQuery($query);
	}
	
	public function getGroupsForHome($home_id) {
		$query = sprintf('SELECT *
			FROM %1$suser_group_homes
			WHERE home_id = %2$s',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link));
		return $this->listQuery($query);
	}
	
	public function getUserByEmail($email) {
		if ( !$this->link ) return FALSE;
		$query = sprintf("SELECT * FROM `%susers` WHERE `users_email` LIKE '%s';",
			$this->table_prefix,
			mysql_real_escape_string($email,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);
		if ( mysql_num_rows($result) != 1 ) return FALSE;
		return mysql_fetch_assoc($result);
	}

	public function updateUsersPassword($user_id, $new_password)
	{
		if ( !$this->link ) return FALSE;
		$query = sprintf("UPDATE %susers SET users_passwd='%s'
			WHERE user_id = %d;",
			$this->table_prefix,
			mysql_real_escape_string($new_password,$this->link),
			mysql_real_escape_string($user_id));
		++$this->queries_;
		$result = mysql_query($query,$this->link);
		if( mysql_affected_rows($this->link) == '0' )
			return FALSE;
		return TRUE;
	}

	public function getGroupById($group_id) {
		if ( !$this->link ) return array();
		$query = sprintf("SELECT * FROM `%suser_group_info` WHERE `group_id` = %d;",
			$this->table_prefix,
			mysql_real_escape_string($group_id,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);
		return mysql_fetch_assoc($result);
	}

	public function getUserList() {
		if ( !$this->link ) return;
		$query = sprintf("SELECT user_id,users_login,users_lang,
			users_role,users_fname,users_lname,users_email,user_expires,users_parent
			FROM %susers",
			$this->table_prefix);

		++$this->queries_;
		$result = mysql_query($query,$this->link);

		$results = array();

		while ( $row = mysql_fetch_assoc( $result ) )
			array_push($results,$row);

		return $results;
	}
	
	public function getUserList_limit($page_user,$limit_user,$search_field) {
		
       $user_get_id = ($page_user - 1) * $limit_user;		
	
		if ( !$this->link ) return;
		$query = sprintf("SELECT user_id,users_login,users_lang,
			users_role,users_fname,users_lname,users_email,user_expires,users_parent
			FROM %susers 
			".($search_field ? "WHERE `user_id` = '$search_field' OR `users_login` = '$search_field' OR `users_lang` = '$search_field'
			OR `users_role` = '$search_field' OR `users_fname` = '$search_field' OR `users_lname` = '$search_field' OR `users_email` = '$search_field'
			OR `user_expires` = '$search_field' OR `users_parent` = '$search_field' " : "" )." 
			ORDER BY users_login ASC LIMIT $user_get_id,$limit_user",
			$this->table_prefix);
		++$this->queries_;
		$result = mysql_query($query,$this->link);
		$results = array();
		while ( $row = mysql_fetch_assoc( $result ) )
			array_push($results,$row);
		return $results;
	}
	
	public function get_user_count($search_field){
		return $this->resultQuery("SELECT COUNT(user_id) AS total FROM `".$this->table_prefix."users`
		".($search_field ? "WHERE `user_id` = '$search_field' OR `users_login` = '$search_field' OR `users_lang` = '$search_field'
			OR `users_role` = '$search_field' OR `users_fname` = '$search_field' OR `users_lname` = '$search_field' OR `users_email` = '$search_field'
			OR `user_expires` = '$search_field' OR `users_parent` = '$search_field' " : "" )."
		
		;");
	}

	public function getGroupList() {
		$query = sprintf("SELECT group_id,group_name
			FROM %suser_group_info",
			$this->table_prefix);
		return $this->listQuery($query);
	}

	public function getUsersGroups($user_id) {
		$query = sprintf("SELECT *
			FROM %suser_groups
			WHERE `user_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($user_id,$this->link));
		return $this->listQuery($query);
	}
	
	public function getUserGroupList($main_user_id) {
		$query = sprintf("SELECT *
			FROM %suser_group_info
			WHERE `main_user_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($main_user_id,$this->link));
		return $this->listQuery($query);
	}

	public function addUser($username,$password,$user_role,$user_email=NULL,$user_parent=NULL){
		$panel_language = isset($GLOBALS['panel_language']) ? $GLOBALS['panel_language'] : $_SESSION['users_lang']; // $_SESSION['users_lang'] is used at install.php
		if ( !$this->link ) return false;
		$query = "INSERT INTO `" . $this->table_prefix . "users` (`users_login`,`users_passwd`,
			`users_lang`,`user_expires`,`users_role`,`users_email`, `users_parent`)
			VALUES('" . mysql_real_escape_string($username,$this->link ) .
			"', MD5('" . mysql_real_escape_string($password,$this->link) .
			"'),'" . mysql_real_escape_string($panel_language,$this->link) . "', 'X', '" .
			mysql_real_escape_string($user_role,$this->link) . "', ";

		if(is_null($user_email)){
			$query .= "NULL, ";
		}else{
			$query .= "'" . mysql_real_escape_string($user_email,$this->link) . "', ";
		}

		if(is_null($user_parent)){
			$query .= "NULL)";
		}else{
			$query .= "'" . mysql_real_escape_string($user_parent,$this->link) . "')";
		}
				
		++$this->queries_;
		mysql_query($query,$this->link);
		
		$user_id = mysql_insert_id($this->link);
		if( !$user_id )
		{
			echo mysql_errno($this->link) . ": " . mysql_error($this->link);
			return false;
		}
		else
		{
			if($this->isModuleInstalled('dashboard'))
				return $this->createUserWidgets($user_id);
			else
				return true;
		}
	}
	
	public function createUserWidgets($user_id){
		$widgets = $this->resultQuery("SELECT * FROM `".$this->table_prefix."widgets`");
		$query = "INSERT INTO `".$this->table_prefix."widgets_users` (`user_id`, `widget_id`, `column_id`, `sort_no`, `collapsed`, `title`) VALUES";
		foreach($widgets as $widget){
			$query .= "(" . $user_id . ", " . $widget['id'] . ", " . $widget['column_id'] . ", " . $widget['sort_no'] . ", " . $widget['collapsed'] . ", '" . $widget['title'] . "'),";
		}
		$query = substr($query, 0, -1);
		$query .= ";";
		++$this->queries_;
		mysql_query($query,$this->link);
		if( mysql_errno($this->link) != 0 )
			return false;
		return true;
	}
	
	public function editUser($fields,$user_id){
		$query = "UPDATE `".$this->table_prefix."users` SET ";
		
		foreach($fields as $key => $value)
		{
			if($value == "")
				$query .= "`$key`=DEFAULT,";
			else
				$query .= "`$key`='".mysql_real_escape_string($value,$this->link)."',";
		}
		
		$query = rtrim($query, ',');
		
		$query .= " WHERE `user_id`=".mysql_real_escape_string($user_id,$this->link).";";
				
		++$this->queries_;
		
		mysql_query($query,$this->link);
				
		if( mysql_errno($this->link) != 0 )
			return false;

		return true;
	}

	public function addUsertoGroup($user_id,$group_id){
		if ( !$this->link ) return false;

		$query = sprintf("INSERT INTO `%suser_groups` (`user_id`,`group_id`) VALUES('%d', '%d')",
			$this->table_prefix,
			mysql_real_escape_string($user_id,$this->link),
			mysql_real_escape_string($group_id,$this->link));

		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
			return false;

		return true;
	}

	public function addServertoGroup($rserver_id,$group_id){
		if ( !$this->link ) return false;

		$query = sprintf("INSERT INTO `%suser_group_remote_servers` (`remote_server_id`,`group_id`) VALUES('%d', '%d')",
			$this->table_prefix,
			mysql_real_escape_string($rserver_id,$this->link),
			mysql_real_escape_string($group_id,$this->link));
		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
			return false;

		return true;
	}

	public function addGroup($group,$main_user_id){
		if ( !$this->link ) return false;

		$query = sprintf("INSERT INTO `%suser_group_info` (`group_id`, `group_name`,`main_user_id` ) VALUES(NULL, '%s', '%d')",
			$this->table_prefix,
			mysql_real_escape_string($group,$this->link),
			mysql_real_escape_string($main_user_id,$this->link));
		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
			return false;

		return true;
	}

	public function delGroup($group_id)
	{
		$queries = array( "DELETE FROM `%suser_group_info` WHERE `group_id` = %d",
			"DELETE FROM `%suser_groups` WHERE `group_id` = %d",
			"DELETE FROM `%suser_group_homes` WHERE `group_id` = %d",
			"DELETE FROM `%suser_group_remote_servers` WHERE `group_id` = %d" );

		foreach ($queries as $query_template)
		{
			$query = sprintf($query_template,
				$this->table_prefix,
				mysql_real_escape_string($group_id,$this->link));
			++$this->queries_;
			mysql_query($query,$this->link)
				or die("Failed to delete group from user_groups: ". mysql_error($this->link));
		}

		return TRUE;
	}

	public function delUserFromGroup($user_id, $group_id)
	{
		$query = sprintf("DELETE FROM `%suser_groups` WHERE `group_id` = '%d'
			AND `user_id` = '%d'",
			$this->table_prefix,
			mysql_real_escape_string($group_id,$this->link),
			mysql_real_escape_string($user_id,$this->link));
		++$this->queries_;
		mysql_query($query,$this->link)
			or die("Failed to delete user from group:".mysql_error($this->link));
		if ( mysql_affected_rows($this->link) != 1 )
			return FALSE;
		return TRUE;
	}

	public function delServerFromGroup($rserver_id, $group_id)
	{
		$query = sprintf("DELETE FROM `%suser_group_remote_servers` WHERE `group_id` = '%d'
			AND `remote_server_id` = '%d'",
			$this->table_prefix,
			mysql_real_escape_string($group_id,$this->link),
			mysql_real_escape_string($rserver_id,$this->link));

		++$this->queries_;
		mysql_query($query,$this->link)
			or die("Failed to delete server from group:".mysql_error($this->link));
		if( mysql_affected_rows($this->link) != 1 )
			return FALSE;
		return TRUE;
	}

	public function getAvailableUsersForGroup($group_id)
	{
		$query = sprintf('SELECT * FROM `%1$susers`
			WHERE `user_id` NOT IN (
				SELECT `user_id` FROM `%1$suser_groups`
				WHERE `group_id` = %2$d
			)
			AND `user_id` NOT IN (
				SELECT `main_user_id` FROM `%1$suser_group_info`
				WHERE `group_id` = %2$d
			)
			AND `users_parent` IS NULL;',
			$this->table_prefix,
			mysql_real_escape_string($group_id,$this->link));
		return $this->listQuery($query);
	}
	
	public function getAvailableSubUsersForGroup($group_id, $userID)
	{
		$query = sprintf('SELECT * FROM `%1$susers`
			WHERE `user_id` NOT IN (
				SELECT `user_id` FROM `%1$suser_groups`
				WHERE `group_id` = %2$d
			) AND `users_parent` = %3$d;',
			$this->table_prefix,
			mysql_real_escape_string($group_id,$this->link),
			mysql_real_escape_string($userID,$this->link)
			);
		return $this->listQuery($query);
	}

	public function listUsersInGroup($group_id)
	{
		$query = sprintf("SELECT `user_id` FROM `%suser_groups` WHERE `group_id` = %d;",
			$this->table_prefix,
			mysql_real_escape_string($group_id,$this->link));
		return $this->listQuery($query);
	}
	
	public function getUsersSubUsersIds($parent_id){
		$query = sprintf("SELECT `user_id` FROM `%susers` WHERE `users_parent` = %d;",
			$this->table_prefix,
			mysql_real_escape_string($parent_id,$this->link));
		$results = $this->listQuery($query);
		
		if($results !== false){
			foreach($results as $result){
				$ids[] = $result['user_id'];
			}
			
			if(is_array($ids) && count($ids) > 0){
				return $ids;
			}
		}
		
		return false;
	}
	
	public function getNumberOfOwnedServersPerUser($userID){
		if($this->isAdmin($userID)){
			$query = sprintf('SELECT COUNT(`home_id`)
			FROM `%1$sserver_homes`;',
			$this->table_prefix);
		}else{
			$query = sprintf('SELECT COUNT(`home_id`)
			FROM `%1$sserver_homes` WHERE `user_id_main` = %2$d;',
			$this->table_prefix,
			mysql_real_escape_string($userID,$this->link));
		}
			
		$result = mysql_query($query,$this->link) or die("Query failed".mysql_error($this->link));
			
		if ( $row = mysql_fetch_row( $result ) ){
			return $row[0];
		}
		
		return 0;
	}

	public function listServersInGroup($group_id)
	{
		$query = sprintf('SELECT `remote_server_id`,`remote_server_name`
			FROM `%1$suser_group_remote_servers` NATURAL JOIN `%1$sremote_servers`
			WHERE `group_id` = %2$d;',
			$this->table_prefix,
			mysql_real_escape_string($group_id,$this->link));
		return $this->listQuery($query);
	}

	public function delUser($user_id)
	{
		// Get list of subusers with current user as parent
		$subusers = $this->getUsersSubUsersIds($user_id);
		if( $subusers !== false )
		{
			foreach ($subusers as $subuser) {
				$this->delUser($subuser);
			}
		}
		
		// Optimization...
		$user_id = mysql_real_escape_string($user_id,$this->link);

		$query = sprintf("SELECT user_id FROM `%susers` WHERE `user_id` = $user_id",
			$this->table_prefix);

		++$this->queries_;
		$result = mysql_query($query,$this->link);
		if( mysql_affected_rows($this->link) == 0 )
			return false;

		$query = sprintf("DELETE FROM `%susers` WHERE `user_id` = $user_id",
			$this->table_prefix);
		++$this->queries_;
		mysql_query($query,$this->link) or die("Failed to delete user:".mysql_error($this->link));
		
		// Deletes any sub-user that may reference this parent username
		$query = sprintf("DELETE FROM `%susers` WHERE users_parent = $user_id;",
			$this->table_prefix);
		++$this->queries_;
		mysql_query($query,$this->link) or die("Failed to delete subuser:".mysql_error($this->link));
		
		 // Deletes entries from user_groups 
		$query = sprintf("DELETE FROM `%suser_groups` WHERE user_id = $user_id;",
			$this->table_prefix);
		++$this->queries_;
		mysql_query($query,$this->link) or die("Failed to delete user:".mysql_error($this->link));
		
		// Deletes group owned by user only if the subuser module is enabled
		$subUsersEnabled = $this->isModuleInstalled("subusers");
		if($subUsersEnabled){
			$query = sprintf("DELETE FROM `%suser_group_info` WHERE main_user_id = $user_id;",
				$this->table_prefix);
			++$this->queries_;
			mysql_query($query,$this->link) or die("Failed to delete group information:".mysql_error($this->link));
		}
		
		$query = sprintf("DELETE FROM `%swidgets_users` WHERE `user_id` = $user_id",
			$this->table_prefix);
		++$this->queries_;
		mysql_query($query,$this->link) or die("Failed to delete user:".mysql_error($this->link));

		$query = sprintf("DELETE FROM `%suser_homes` WHERE user_id = $user_id;",
			$this->table_prefix);
		++$this->queries_;
		mysql_query($query,$this->link) or die("Failed to delete user:".mysql_error($this->link));

		return true;
	}

	public function isAdmin($user_id)
	{
		if ( !$this->link ) return false;
		$query = sprintf("SELECT `users_role` FROM `%susers` WHERE `user_id` = %d AND `users_role` = 'admin'",
			$this->table_prefix,
			mysql_real_escape_string($user_id,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link) or die("Query failed".mysql_error($this->link));

		if(mysql_affected_rows($this->link) == 0)
			return false;

		return true;
	}
	
	public function getAdmins()
	{
		if ( !$this->link ) return false;
		$query = sprintf("SELECT * FROM `%susers` WHERE `users_role` = 'admin'",
			$this->table_prefix);
		++$this->queries_;
		$result = mysql_query($query,$this->link);

		$results = array();

		while ( $row = mysql_fetch_assoc( $result ) )
			array_push($results,$row);

		return $results;
	}
	
	public function isSubUser($user_id)
	{
		if ( !$this->link ) return false;
		$query = sprintf("SELECT `users_role` FROM `%susers` WHERE `user_id` = %d AND `users_role` = 'subuser'",
			$this->table_prefix,
			mysql_real_escape_string($user_id,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link) or die("Query failed".mysql_error($this->link));

		if(mysql_affected_rows($this->link) == 0)
			return false;
			
		return true;
	}

	public function addModule($module_title,$module,$module_version,$db_version)
	{
		if ( !$this->link ) return false;
		$query = sprintf("INSERT INTO `%smodules` VALUES(NULL,'%s','%s','%s', '%d');",
			$this->table_prefix,
			mysql_real_escape_string($module_title,$this->link),
			mysql_real_escape_string($module,$this->link),
			mysql_real_escape_string($module_version,$this->link),
			mysql_real_escape_string($db_version,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);
		return mysql_insert_id($this->link);
	}
	
	public function getModuleMenu($module_id){
		if ( !$this->link ) return false;
		$query = sprintf("SELECT * FROM `%smodule_menus` WHERE `module_id` = '%d'",
			$this->table_prefix,
			mysql_real_escape_string($module_id,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);
		if($result && mysql_num_rows($result) > 0){
			$row = mysql_fetch_assoc($result);
			return $row;
		}
		return false;
	}

	public function addModuleMenu($module_id,$subpage,$group,$name,$pos = 0)
	{
		if ( !$this->link ) return false;
		$query = sprintf("INSERT INTO `%smodule_menus` VALUES( '%d','%s','%s','%s','%d');",
			$this->table_prefix,
			mysql_real_escape_string($module_id,$this->link),
			mysql_real_escape_string($subpage,$this->link),
			mysql_real_escape_string($group,$this->link),
			mysql_real_escape_string($name,$this->link),
			mysql_real_escape_string($pos,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
			return false;

		return true;
	}

	public function delModuleMenu($module_id)
	{
		if ( !$this->link ) return FALSE;
		$query = sprintf("DELETE FROM `%smodule_menus` WHERE `module_id` = %d;",
			$this->table_prefix,
			mysql_real_escape_string($module_id,$this->link));

		++$this->queries_;
		$result = mysql_query($query,$this->link);

		return TRUE;
	}

	public function delModule($module_id)
	{
		if ( !$this->link ) return FALSE;
		$query = sprintf("DELETE FROM `%smodules` WHERE `id` = %d;",
			$this->table_prefix,
			mysql_real_escape_string($module_id,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);

		$query = sprintf("DELETE FROM `%smodule_menus` WHERE `module_id` = %d;",
			$this->table_prefix,
			mysql_real_escape_string($module_id,$this->link));

		++$this->queries_;
		$result = mysql_query($query,$this->link);

		return TRUE;
	}

	public function getMenusForGroup($group)
	{
		$query = sprintf('SELECT `folder` as module, `subpage`, `menu_name`, `pos`, `module_id`
			FROM `%1$smodules`, `%1$smodule_menus`
			WHERE `group` = \'%2$s\'
			AND `id` = `module_id`
			ORDER BY `pos` ASC;',
			$this->table_prefix,
			mysql_real_escape_string($group,$this->link));
		return $this->listQuery($query);
	}
	
	public function changeMenuPosition( $module_id, $new_pos )
	{
		$query = sprintf("UPDATE `%smodule_menus` 
						  SET pos='%d'
						  WHERE module_id = '%d';",
						  $this->table_prefix,
						  mysql_real_escape_string($new_pos, $this->link),
						  mysql_real_escape_string($module_id, $this->link) );
		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
			return FALSE;

		return true;
	}

	public function addGameModCfg($game_id,$mod_key,$mod_name)
	{
		$query = sprintf('INSERT INTO `%1$sconfig_mods` (`mod_cfg_id`, `home_cfg_id`, `mod_key`, `mod_name`)
			VALUES(NULL, \'%2$s\', \'%3$s\', \'%4$s\') ON DUPLICATE KEY UPDATE mod_name=\'%4$s\';',
				$this->table_prefix,
				mysql_real_escape_string($game_id,$this->link),
				mysql_real_escape_string($mod_key,$this->link),
				mysql_real_escape_string($mod_name,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link);
	}

	public function clearGameCfgs($clear_all)
	{
		if ( $clear_all == TRUE )
		{
			++$this->queries_;
			mysql_query("TRUNCATE `".$this->table_prefix."config_homes`;");
			++$this->queries_;
			mysql_query("TRUNCATE `".$this->table_prefix."config_mods`;");
		}
		// mysql_query("TRUNCATE config_homes;");
	}

	public function addGameCfg($config)
	{
		/// \todo Escape the required values and add on duplicate key update.
		$query = "INSERT INTO `".$this->table_prefix."config_homes` (`home_cfg_id`,
			`game_key`, `game_name`, `home_cfg_file` ) VALUES ".
			"(NULL, '".$config->game_key."', '".
			$config->game_name."', '".$config->home_cfg_file."' )
			ON DUPLICATE KEY UPDATE game_name=VALUES(game_name),
				home_cfg_file=VALUES(home_cfg_file);";
		++$this->queries_;

		$result = mysql_query($query,$this->link);

		if ( !$result )
			return FALSE;

		$query = sprintf('SELECT `home_cfg_id` FROM `%1$sconfig_homes` WHERE `game_key` = \'%2$s\';',
			$this->table_prefix,
			$config->game_key);

		++$this->queries_;
		$id_result = mysql_query($query,$this->link);
		$id_result = mysql_fetch_assoc($id_result);
		$config_id = $id_result['home_cfg_id'];

		// Adding mods.
		foreach ( $config->mods->mod as $mod )
		{
			$this->addGameModCfg($config_id,$mod['key'],$mod->name);
		}

		return TRUE;
	}

	public function getGameCfgs()
	{
		$query = sprintf('SELECT * FROM `%sconfig_homes`
			ORDER BY `game_name` ASC',
			$this->table_prefix);
		return $this->listQuery($query);
	}
	
	public function getGameCfg($home_cfg_id)
	{
		$query = sprintf('SELECT * FROM `%sconfig_homes`
			WHERE `home_cfg_id` = %d;',
			$this->table_prefix,
			mysql_real_escape_string($home_cfg_id,$this->link));
		
		++$this->queries_;
		$result = mysql_query($query, $this->link);

		// If there are no servers then we can stop here.
		if ( mysql_num_rows($result) != 1 )
			return FALSE;
		
		return mysql_fetch_assoc($result);
	}
	
	public function delGameCfgAndMods($home_cfg_id)
	{
		$home_cfg_id = mysql_real_escape_string($home_cfg_id, $this->link);
		
		$queries = array("DELETE FROM `%sconfig_mods` WHERE `home_cfg_id` = %d",
						 "DELETE FROM `%sconfig_homes` WHERE `home_cfg_id` = %d");

		foreach ( $queries as $query )
		{
			$query = sprintf($query,$this->table_prefix,$home_cfg_id);
			++$this->queries_;
			$result = mysql_query($query,$this->link);
			$return = (  mysql_affected_rows($this->link) >= 1 ) ? TRUE : FALSE;
			if($return === FALSE)
				break;
		}
		return $return;
	}
	
	public function getCfgMods($home_cfg_id)
	{
		$query = sprintf('SELECT * FROM `%sconfig_mods`
			WHERE `home_cfg_id` = %d;',
			$this->table_prefix,
			mysql_real_escape_string($home_cfg_id,$this->link));
		return $this->listQuery($query);
	}
	
	public function updateHomeCfgId($home_id, $new_home_cfg_id)
	{
		$query = sprintf("UPDATE `%sserver_homes` 
						  SET home_cfg_id='%d'
						  WHERE home_id = '%d';",
						  $this->table_prefix,
						  mysql_real_escape_string($new_home_cfg_id, $this->link),
						  mysql_real_escape_string($home_id, $this->link) );
		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
			return FALSE;

		return true;
	}
	/// \brief Used to make plain query to the database.
	/// \return true if success and false otherwise.
	/// When false is returned user can check error with getError() function.
	public function query( $query )
	{
		if ( !$this->link ) return FALSE;

		$query = str_replace( "OGP_DB_PREFIX", $this->table_prefix, $query );

		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
		{
			return FALSE;
		}

		return TRUE;
	}

	/// \brief This query return array of values or false on failure.
	public function resultQuery( $query ) {
		$query = str_replace( "OGP_DB_PREFIX", $this->table_prefix, $query );
		return $this->listQuery($query);
	}
		
	public function resultInsertId( $table, $fields )
	{
		if ( !$this->link ) return FALSE;
		$keys = "";
		$values = "";
		foreach($fields as $key => $val)
		{
			$keys .= "`$key`,";
			$values .= "'".mysql_real_escape_string($val,$this->link)."',";
		}
		$keys = rtrim($keys,',');
		$values = rtrim($values,',');
		$query = "INSERT INTO `".$this->table_prefix."$table`( ";
		$query .= $keys;
		$query .= " ) VALUES ( ";
		$query .= $values;
		$query .= " );";
				
		mysql_query($query,$this->link);
		
		if ( mysql_affected_rows($this->link) != 1 )
			return FALSE;
		$insert_id = mysql_insert_id($this->link);
		return $insert_id;
	}

	/// \brief Returns the last error message
	public function getError() {
		if ( !$this->link ) return;
		return mysql_error($this->link);
	}

	// Server module functions
	/// \brief Adds remote server to database.
	public function addRemoteServer($rhost_ip,$rhost_name,$rhost_user_name,$rhost_port,$rhost_ftp_ip,$rhost_ftp_port,$encryption_key,$rhost_timeout,$use_nat)
	{
		$rhost_ip = trim($rhost_ip);
		$rhost_port = trim($rhost_port);
		$rhost_user_name = trim($rhost_user_name);
		$rhost_ftp_ip = trim($rhost_ftp_ip);
		$rhost_ftp_port = trim($rhost_ftp_port);
		$encryption_key = trim($encryption_key);
		$rhost_timeout = trim($rhost_timeout);
		$use_nat = trim($use_nat);

		if ( empty($rhost_ip) )
			return false;
		else if ( empty($rhost_port) )
			return false;
		else if ( empty($rhost_user_name) )
			return false;

		$rhost_name = trim($rhost_name);
		$query = sprintf("INSERT INTO `%sremote_servers` (`agent_ip`,remote_server_name,ogp_user,agent_port,ftp_ip,ftp_port,`encryption_key`,timeout,use_nat)
			VALUES('%s','%s','%s','%d','%s','%s','%s','%s','%s');",
				$this->table_prefix,
				mysql_real_escape_string($rhost_ip,$this->link),
				mysql_real_escape_string($rhost_name,$this->link),
				mysql_real_escape_string($rhost_user_name,$this->link),
				mysql_real_escape_string($rhost_port,$this->link),
				mysql_real_escape_string($rhost_ftp_ip,$this->link),
				mysql_real_escape_string($rhost_ftp_port,$this->link),
				mysql_real_escape_string($encryption_key,$this->link),
				mysql_real_escape_string($rhost_timeout,$this->link),
				mysql_real_escape_string($use_nat,$this->link));
		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
		{
			return false;
		}

		return mysql_insert_id($this->link);
	}

	public function getRemoteServer($id) {
		if ( !$this->link ) return FALSE;

		$query = sprintf("SELECT * FROM `%sremote_servers` WHERE `remote_server_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($id,$this->link));

		++$this->queries_;
		$result = mysql_query($query, $this->link);

		// If there are no servers then we can stop here.
		if ( mysql_num_rows($result) != 1 )
			return FALSE;

		return mysql_fetch_assoc( $result );
	}

	/// \brief Get Remote servers
	public function getRemoteServers(){
		$query = sprintf("SELECT * FROM %sremote_servers;",
			$this->table_prefix);
		return $this->listQuery($query);
	}
	
	public function getRemoteServers_ts3($assign_id){
		$query = sprintf("SELECT * FROM ".$this->table_prefix."remote_servers WHERE agent_ip IN (SELECT ip FROM `".$this->table_prefix."ts3_homes` WHERE user_id = $assign_id)");
		return $this->listQuery($query);
	}

	public function removeRemoteServer($remote_server_id) {
		$remote_server_id = mysql_real_escape_string($remote_server_id, $this->link);

		$return = TRUE;

		$queries = array("DELETE FROM `%sremote_servers` WHERE remote_server_id = %d;",
			"DELETE FROM `%smaster_server_homes` WHERE remote_server_id = %d;",
			"DELETE FROM `%suser_group_remote_servers` WHERE remote_server_id = %d;",
			"DELETE FROM `%sts3_homes` WHERE rserver_id = %d;",
			'DELETE FROM %1$sarrange_ports WHERE `ip_id` IN
			(SELECT ip_id FROM `%1$sremote_server_ips` WHERE remote_server_id = %2$d);',
			'DELETE FROM %1$sstatus_cache WHERE `ip_id` IN
			(SELECT ip_id FROM `%1$sremote_server_ips` WHERE remote_server_id = %2$d);',
			"DELETE FROM `%sremote_server_ips` WHERE remote_server_id = %d;",
			'DELETE FROM `%1$suser_homes` WHERE home_id IN
			(SELECT home_id FROM `%1$sserver_homes` WHERE remote_server_id = %2$d);',
			'DELETE FROM `%1$suser_group_homes` WHERE home_id IN
			(SELECT home_id FROM `%1$sserver_homes` WHERE remote_server_id = %2$d);',
			'DELETE FROM `%1$smysql_databases` WHERE home_id IN
			(SELECT home_id FROM `%1$sserver_homes` WHERE remote_server_id = %2$d);',
			'DELETE FROM `%1$sgame_mods` WHERE home_id IN
			(SELECT home_id FROM `%1$sserver_homes` WHERE remote_server_id = %2$d);',
			'DELETE FROM %1$shome_ip_ports WHERE `home_id` IN
			(SELECT home_id FROM `%1$sserver_homes` WHERE remote_server_id = %2$d);',
			"DELETE FROM `%sserver_homes` WHERE remote_server_id = %d;");

		foreach ( $queries as $query )
		{
			$query = sprintf($query,$this->table_prefix,$remote_server_id);
			++$this->queries_;
			$result = mysql_query($query,$this->link);
			$return = ($result === FALSE) ? FALSE : $return;
		}
		return $return;
	}

	public function addRemoteServerIP($remote_server_id, $ip)
	{
		$query = sprintf("INSERT INTO `%sremote_server_ips`
			VALUES (null ,'%d','%s');",
				$this->table_prefix,
				mysql_real_escape_string($remote_server_id, $this->link),
				mysql_real_escape_string($ip, $this->link) );

		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
			return FALSE;

		return true;
	}
	
	public function editRemoteServerIPs($ip_id, $ip)
	{
		$ip_id = mysql_real_escape_string($ip_id,$this->link);
		$ip = mysql_real_escape_string($ip,$this->link);
		
		$return = TRUE;
		
		$queries = array('UPDATE `%1$sts3_homes` SET ip=\'%2$s\' WHERE ip IN
			(SELECT ip FROM `%1$sremote_server_ips` WHERE ip_id = %3$d);',
			"UPDATE `%sremote_server_ips` SET ip='%s' WHERE ip_id = %d;");

		foreach ( $queries as $query )
		{
			$query = sprintf($query,$this->table_prefix,$ip,$ip_id);
			++$this->queries_;
			$result = mysql_query($query,$this->link);
			$return = ($result === FALSE) ? FALSE : $return;
		}
		return $return;
	}

	/// \brief Get remote server IP's
	public function getRemoteServerIPs($server_id){
		$query = sprintf("SELECT ip_id,ip FROM `%sremote_server_ips` WHERE remote_server_id = %d;",
			$this->table_prefix,
			mysql_real_escape_string($server_id,$this->link));
		return $this->listQuery($query);
	}

	public function removeRemoteServerIPs($ip_id) {
		$ip_id = mysql_real_escape_string($ip_id,$this->link);
		$return = TRUE;
		
		$queries = array("DELETE FROM `%sarrange_ports` WHERE ip_id = %d;",
			"DELETE FROM `%sstatus_cache` WHERE ip_id = %d;",
			'DELETE FROM `%1$sts3_homes` WHERE ip IN
			(SELECT ip FROM `%1$sremote_server_ips` WHERE ip_id = %2$d);',
			"DELETE FROM `%sremote_server_ips` WHERE ip_id = %d;");

		foreach ( $queries as $query )
		{
			$query = sprintf($query,$this->table_prefix,$ip_id);
			++$this->queries_;
			$result = mysql_query($query,$this->link);
			$return = ($result === FALSE) ? FALSE : $return;
		}
		return $return;
	}

	public function changeRemoteServerSettings($server_id,
		$agent_ip,$agent_port,$remote_server_name,$remote_server_user_name,$remote_host_ftp_ip,$remote_host_ftp_port,$encryption_key,$remote_timeout,$use_nat)
	{
		$query = sprintf("UPDATE %sremote_servers SET agent_ip='%s',
			agent_port='%s', encryption_key='%s',
			remote_server_name='%s',
			ogp_user='%s',
			ftp_ip='%s',
			ftp_port='%s',
			timeout='%s',
			use_nat='%s'
			WHERE remote_server_id = %d;",
			$this->table_prefix,
			mysql_real_escape_string($agent_ip, $this->link),
			mysql_real_escape_string($agent_port, $this->link),
			mysql_real_escape_string($encryption_key, $this->link),
			mysql_real_escape_string($remote_server_name, $this->link),
			mysql_real_escape_string($remote_server_user_name, $this->link),
			mysql_real_escape_string($remote_host_ftp_ip, $this->link),
			mysql_real_escape_string($remote_host_ftp_port, $this->link),
			mysql_real_escape_string($remote_timeout, $this->link),
			mysql_real_escape_string($use_nat, $this->link),
			mysql_real_escape_string($server_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query, $this->link) === FALSE )
			return FALSE;

		return TRUE;
	}

	// Gamemanager functions
	public function getHomeIpPorts($home_id){
		$query = sprintf("SELECT ip_id,ip,port,force_mod_id
			FROM %shome_ip_ports NATURAL JOIN %sremote_server_ips
			WHERE home_id = %d;",
			$this->table_prefix,
			$this->table_prefix,
			mysql_real_escape_string($home_id,$this->link));
		return $this->listQuery($query);
	}

	public function getHomesFor($id_type,$assign_id){
		if ( $id_type == "admin" )
		{
			$template = 'SELECT	%1$sserver_homes.*, 
								%1$sremote_servers.*, 
								%1$sconfig_homes.*, 
								%1$shome_ip_ports.port,
								%1$shome_ip_ports.force_mod_id,
								%1$sremote_server_ips.ip_id,
								%1$sremote_server_ips.ip,
								%1$sgame_mods.mod_id,
								%1$sgame_mods.mod_cfg_id,
								%1$sgame_mods.max_players,
								%1$sgame_mods.extra_params,
								%1$sgame_mods.cpu_affinity,
								%1$sgame_mods.nice,
								%1$sgame_mods.precmd,
								%1$sgame_mods.postcmd,
								%1$sconfig_mods.mod_key,
								%1$sconfig_mods.mod_name,
								%1$sconfig_mods.def_precmd,
								%1$sconfig_mods.def_postcmd,
								%1$sconfig_mods.mod_cfg_id
						FROM %1$sserver_homes
						NATURAL JOIN %1$sremote_servers
						NATURAL JOIN %1$sconfig_homes
						LEFT JOIN %1$sgame_mods 
							NATURAL JOIN %1$sconfig_mods
							ON %1$sserver_homes.home_id=%1$sgame_mods.home_id
						LEFT JOIN %1$shome_ip_ports 
							NATURAL JOIN %1$sremote_server_ips 
							ON %1$sserver_homes.home_id=%1$shome_ip_ports.home_id
						WHERE `force_mod_id` IN
						(
							SELECT `force_mod_id`
							FROM `%1$shome_ip_ports`
							WHERE `force_mod_id` = %1$sgame_mods.mod_id OR %1$shome_ip_ports.force_mod_id = 0
						)
						OR %1$shome_ip_ports.force_mod_id IS NULL;';
			$template2 = 'SELECT user_expiration_date, home_id FROM %1$suser_homes WHERE user_id = %2$d;';
			$template3 = 'SELECT user_group_expiration_date, home_id FROM %1$suser_group_homes WHERE group_id IN(
							SELECT %1$suser_groups.group_id
							FROM %1$suser_groups
							WHERE %1$suser_groups.user_id=%2$d
						  );';
		}
		else if ( $id_type == "user" )
		{
			$template = 'SELECT %1$sserver_homes.*, %1$suser_homes.access_rights,
				%1$suser_homes.user_expiration_date, %1$sremote_servers.*, %1$sconfig_homes.*
				FROM %1$sremote_servers NATURAL JOIN %1$suser_homes
				NATURAL JOIN %1$sserver_homes NATURAL JOIN %1$sconfig_homes
				WHERE %1$suser_homes.user_id = %2$d ORDER BY home_id ASC;';
		}
		else if ( $id_type == "group" )
		{
			$template = 'SELECT %1$sserver_homes.*, %1$suser_group_homes.access_rights,
				%1$suser_group_homes.user_group_expiration_date, %1$sremote_servers.*, %1$sconfig_homes.*
				FROM %1$sremote_servers NATURAL JOIN %1$suser_group_homes
				NATURAL JOIN %1$sserver_homes NATURAL JOIN %1$sconfig_homes
				WHERE %1$suser_group_homes.group_id = %2$d ORDER BY home_id ASC;';
		}
		else if ( $id_type == "user_and_group" )
		{
			$template = 'SELECT	%1$suser_homes.*, 
								%1$sserver_homes.*, 
								%1$sremote_servers.*, 
								%1$sconfig_homes.*, 
								%1$shome_ip_ports.port,
								%1$shome_ip_ports.force_mod_id,
								%1$sremote_server_ips.ip_id,
								%1$sremote_server_ips.ip,
								%1$sgame_mods.mod_id,
								%1$sgame_mods.mod_cfg_id,
								%1$sgame_mods.max_players,
								%1$sgame_mods.extra_params,
								%1$sgame_mods.cpu_affinity,
								%1$sgame_mods.nice,
								%1$sgame_mods.precmd,
								%1$sgame_mods.postcmd,
								%1$sconfig_mods.mod_key,
								%1$sconfig_mods.mod_name,
								%1$sconfig_mods.def_precmd,
								%1$sconfig_mods.def_postcmd,
								%1$sconfig_mods.mod_cfg_id
						FROM %1$sremote_servers 
						NATURAL JOIN %1$suser_homes 
						NATURAL JOIN %1$sserver_homes 
						NATURAL JOIN %1$sconfig_homes
						LEFT JOIN %1$shome_ip_ports 
							NATURAL JOIN %1$sremote_server_ips 
							ON %1$sserver_homes.home_id=%1$shome_ip_ports.home_id
						LEFT JOIN %1$sgame_mods 
							NATURAL JOIN %1$sconfig_mods
							ON %1$sserver_homes.home_id=%1$sgame_mods.home_id
						WHERE %1$suser_homes.user_id = %2$d
						AND (
							`force_mod_id` IN(
								SELECT `force_mod_id`
								FROM `%1$shome_ip_ports`
								WHERE `force_mod_id` = %1$sgame_mods.mod_id OR %1$shome_ip_ports.force_mod_id = 0
							)
							OR %1$shome_ip_ports.force_mod_id IS NULL
						) 
						UNION
						SELECT	%1$suser_group_homes.*,
								%1$sserver_homes.*, 
								%1$sremote_servers.*, 
								%1$sconfig_homes.*, 
								%1$shome_ip_ports.port,
								%1$shome_ip_ports.force_mod_id,
								%1$sremote_server_ips.ip_id,
								%1$sremote_server_ips.ip,
								%1$sgame_mods.mod_id,
								%1$sgame_mods.mod_cfg_id,
								%1$sgame_mods.max_players,
								%1$sgame_mods.extra_params,
								%1$sgame_mods.cpu_affinity,
								%1$sgame_mods.nice,
								%1$sgame_mods.precmd,
								%1$sgame_mods.postcmd,
								%1$sconfig_mods.mod_key,
								%1$sconfig_mods.mod_name,
								%1$sconfig_mods.def_precmd,
								%1$sconfig_mods.def_postcmd,
								%1$sconfig_mods.mod_cfg_id
						FROM %1$sremote_servers 
						NATURAL JOIN %1$suser_group_homes 
						NATURAL JOIN %1$sserver_homes 
						NATURAL JOIN %1$sconfig_homes
						LEFT JOIN %1$shome_ip_ports 
							NATURAL JOIN %1$sremote_server_ips 
							ON %1$sserver_homes.home_id=%1$shome_ip_ports.home_id
						LEFT JOIN %1$sgame_mods 
							NATURAL JOIN %1$sconfig_mods
							ON %1$sserver_homes.home_id=%1$sgame_mods.home_id
						WHERE %1$suser_group_homes.group_id
						IN(
							SELECT %1$suser_groups.group_id
							FROM %1$suser_groups
							WHERE %1$suser_groups.user_id=%2$d
						)
						AND (
							`force_mod_id` IN(
								SELECT `force_mod_id`
								FROM `%1$shome_ip_ports`
								WHERE `force_mod_id` = %1$sgame_mods.mod_id OR %1$shome_ip_ports.force_mod_id = 0
							)
							OR %1$shome_ip_ports.force_mod_id IS NULL
						);';
		}
		else
		{
			return FALSE;
		}

		if ( $id_type == "admin" )
		{
			$query1 = sprintf($template,
				$this->table_prefix,
				mysql_real_escape_string($assign_id,$this->link) );
			$query2 = sprintf($template2,
				$this->table_prefix,
				mysql_real_escape_string($assign_id,$this->link) );
			$query3 = sprintf($template3,
				$this->table_prefix,
				mysql_real_escape_string($assign_id,$this->link) );
			$servers = $this->listQuery($query1);
			if($servers)
			{
				$user_expiration_dates = $this->listQuery($query2);
				$user_group_expiration_dates = $this->listQuery($query3);
				foreach($servers as $key => $server)
				{
					if($user_expiration_dates)
					{
						foreach($user_expiration_dates as $user_expiration_date)
						{
							if($server['home_id'] == $user_expiration_date['home_id'])
								$servers[$key]['user_expiration_date'] = $user_expiration_date['user_expiration_date'];
						}
					}
					if($user_group_expiration_dates)
					{
						foreach($user_group_expiration_dates as $user_group_expiration_date)
						{
							if($server['home_id'] == $user_group_expiration_date['home_id'])
								$servers[$key]['user_group_expiration_date'] = $user_group_expiration_date['user_group_expiration_date'];
						}
					}
				}
			}
			return $servers;
		}
		else
		{
			$query = sprintf($template,
				$this->table_prefix,
				mysql_real_escape_string($assign_id,$this->link) );
			return $this->listQuery($query);
		}
	}

	public function getHomesFor_count($id_type,$assign_id,$home_cfg_id){
		if ( $id_type == "admin" )
		{
			return $this->resultQuery('SELECT COUNT(home_id) AS total FROM `'.$this->table_prefix.'server_homes`' . ($home_cfg_id ?' WHERE home_cfg_id = '.$home_cfg_id : ''));
		}
		else if ( $id_type == "user_and_group" )
		{
			return $this->resultQuery('SELECT COUNT(home_id) AS total FROM `'.$this->table_prefix.'user_homes` WHERE user_id = '.$assign_id.' ' .($home_cfg_id ? 'AND `home_id` IN (SELECT `home_id` FROM `'.$this->table_prefix.'server_homes` WHERE home_cfg_id = '.$home_cfg_id.' )': ''));
		}
		else if ( $id_type == "subuser" )
		{
			return $this->resultQuery('SELECT COUNT(home_id) AS total FROM `'.$this->table_prefix.'user_group_homes` WHERE group_id IN (SELECT group_id FROM `'.$this->table_prefix.'user_groups` WHERE user_id = '.$assign_id.' )' .($home_cfg_id ? 'AND `home_id` IN (SELECT `home_id` FROM `'.$this->table_prefix.'server_homes` WHERE home_cfg_id = '.$home_cfg_id.' )': ''));
		}		
		
	}
	
	public function getHomesFor_limit($id_type,$assign_id,$home_page,$home_limit,$home_cfg_id){
	$gethome_page_forlimit = ($home_page - 1) * $home_limit;	
		if ( $id_type == "admin" )
		{
			$template = 'SELECT	%1$sserver_homes.*, 
								%1$sremote_servers.*, 
								%1$sconfig_homes.*, 
								%1$shome_ip_ports.port,
								%1$shome_ip_ports.force_mod_id,
								%1$sremote_server_ips.ip_id,
								%1$sremote_server_ips.ip,
								%1$sgame_mods.mod_id,
								%1$sgame_mods.mod_cfg_id,
								%1$sgame_mods.max_players,
								%1$sgame_mods.extra_params,
								%1$sgame_mods.cpu_affinity,
								%1$sgame_mods.nice,
								%1$sgame_mods.precmd,
								%1$sgame_mods.postcmd,
								%1$sconfig_mods.mod_key,
								%1$sconfig_mods.mod_name,
								%1$sconfig_mods.def_precmd,
								%1$sconfig_mods.def_postcmd,
								%1$sconfig_mods.mod_cfg_id
						FROM %1$sserver_homes
						NATURAL JOIN %1$sremote_servers
						NATURAL JOIN %1$sconfig_homes
						LEFT JOIN %1$sgame_mods 
							NATURAL JOIN %1$sconfig_mods
							ON %1$sserver_homes.home_id=%1$sgame_mods.home_id
						LEFT JOIN %1$shome_ip_ports 
							NATURAL JOIN %1$sremote_server_ips 
							ON %1$sserver_homes.home_id=%1$shome_ip_ports.home_id
						WHERE `force_mod_id` IN
						(
							SELECT `force_mod_id`
							FROM `%1$shome_ip_ports`
							WHERE `force_mod_id` = %1$sgame_mods.mod_id OR %1$shome_ip_ports.force_mod_id = 0
						)
						'.($home_cfg_id ? 'AND %1$sserver_homes.home_cfg_id = '.$home_cfg_id : '').'
						OR %1$shome_ip_ports.force_mod_id IS NULL LIMIT '.$gethome_page_forlimit.','.$home_limit.';';
						
			$template2 = 'SELECT user_expiration_date, home_id FROM %1$suser_homes WHERE user_id = %2$d;';
			$template3 = 'SELECT user_group_expiration_date, home_id FROM %1$suser_group_homes WHERE group_id IN(
							SELECT %1$suser_groups.group_id
							FROM %1$suser_groups
							WHERE %1$suser_groups.user_id=%2$d
						  );';
		}
		else if ( $id_type == "user" )
		{
			$template = 'SELECT %1$sserver_homes.*, %1$suser_homes.access_rights,
				%1$suser_homes.user_expiration_date, %1$sremote_servers.*, %1$sconfig_homes.*
				FROM %1$sremote_servers NATURAL JOIN %1$suser_homes
				NATURAL JOIN %1$sserver_homes NATURAL JOIN %1$sconfig_homes
				WHERE %1$suser_homes.user_id = %2$d '.($home_cfg_id ? 'AND %1$sserver_homes.home_cfg_id = '.$home_cfg_id : '').' ORDER BY home_id ASC LIMIT '.$gethome_page_forlimit.','.$home_limit.';';
		}
		else if ( $id_type == "group" )
		{
			$template = 'SELECT %1$sserver_homes.*, %1$suser_group_homes.access_rights,
				%1$suser_group_homes.user_group_expiration_date, %1$sremote_servers.*, %1$sconfig_homes.*
				FROM %1$sremote_servers NATURAL JOIN %1$suser_group_homes
				NATURAL JOIN %1$sserver_homes NATURAL JOIN %1$sconfig_homes
				WHERE %1$suser_group_homes.group_id = %2$d '.($home_cfg_id ? 'AND %1$sserver_homes.home_cfg_id = '.$home_cfg_id : '').' ORDER BY home_id ASC LIMIT '.$gethome_page_forlimit.','.$home_limit.';';
		}
		else if ( $id_type == "user_and_group" )
		{
			$template = 'SELECT	%1$suser_homes.*, 
								%1$sserver_homes.*, 
								%1$sremote_servers.*, 
								%1$sconfig_homes.*, 
								%1$shome_ip_ports.port,
								%1$shome_ip_ports.force_mod_id,
								%1$sremote_server_ips.ip_id,
								%1$sremote_server_ips.ip,
								%1$sgame_mods.mod_id,
								%1$sgame_mods.mod_cfg_id,
								%1$sgame_mods.max_players,
								%1$sgame_mods.extra_params,
								%1$sgame_mods.cpu_affinity,
								%1$sgame_mods.nice,
								%1$sgame_mods.precmd,
								%1$sgame_mods.postcmd,
								%1$sconfig_mods.mod_key,
								%1$sconfig_mods.mod_name,
								%1$sconfig_mods.def_precmd,
								%1$sconfig_mods.def_postcmd,
								%1$sconfig_mods.mod_cfg_id
						FROM %1$sremote_servers 
						NATURAL JOIN %1$suser_homes 
						NATURAL JOIN %1$sserver_homes 
						NATURAL JOIN %1$sconfig_homes
						LEFT JOIN %1$shome_ip_ports 
							NATURAL JOIN %1$sremote_server_ips 
							ON %1$sserver_homes.home_id=%1$shome_ip_ports.home_id
						LEFT JOIN %1$sgame_mods 
							NATURAL JOIN %1$sconfig_mods
							ON %1$sserver_homes.home_id=%1$sgame_mods.home_id
						WHERE %1$suser_homes.user_id = %2$d
						AND (
							`force_mod_id` IN(
								SELECT `force_mod_id`
								FROM `%1$shome_ip_ports`
								WHERE `force_mod_id` = %1$sgame_mods.mod_id OR %1$shome_ip_ports.force_mod_id = 0
							)
							'.($home_cfg_id ? 'AND %1$sserver_homes.home_cfg_id = '.$home_cfg_id : '').'
							OR %1$shome_ip_ports.force_mod_id IS NULL
						)
						UNION
						SELECT	%1$suser_group_homes.*,
								%1$sserver_homes.*, 
								%1$sremote_servers.*, 
								%1$sconfig_homes.*, 
								%1$shome_ip_ports.port,
								%1$shome_ip_ports.force_mod_id,
								%1$sremote_server_ips.ip_id,
								%1$sremote_server_ips.ip,
								%1$sgame_mods.mod_id,
								%1$sgame_mods.mod_cfg_id,
								%1$sgame_mods.max_players,
								%1$sgame_mods.extra_params,
								%1$sgame_mods.cpu_affinity,
								%1$sgame_mods.nice,
								%1$sgame_mods.precmd,
								%1$sgame_mods.postcmd,
								%1$sconfig_mods.mod_key,
								%1$sconfig_mods.mod_name,
								%1$sconfig_mods.def_precmd,
								%1$sconfig_mods.def_postcmd,
								%1$sconfig_mods.mod_cfg_id
						FROM %1$sremote_servers 
						NATURAL JOIN %1$suser_group_homes 
						NATURAL JOIN %1$sserver_homes 
						NATURAL JOIN %1$sconfig_homes
						LEFT JOIN %1$shome_ip_ports 
							NATURAL JOIN %1$sremote_server_ips 
							ON %1$sserver_homes.home_id=%1$shome_ip_ports.home_id
						LEFT JOIN %1$sgame_mods 
							NATURAL JOIN %1$sconfig_mods
							ON %1$sserver_homes.home_id=%1$sgame_mods.home_id
						WHERE %1$suser_group_homes.group_id
						IN(
							SELECT %1$suser_groups.group_id
							FROM %1$suser_groups
							WHERE %1$suser_groups.user_id=%2$d
						)
						AND (
							`force_mod_id` IN(
								SELECT `force_mod_id`
								FROM `%1$shome_ip_ports`
								WHERE `force_mod_id` = %1$sgame_mods.mod_id OR %1$shome_ip_ports.force_mod_id = 0
							)
							'.($home_cfg_id ? 'AND %1$sserver_homes.home_cfg_id = '.$home_cfg_id : '').'
							OR %1$shome_ip_ports.force_mod_id IS NULL 
						) 
						LIMIT '.$gethome_page_forlimit.','.$home_limit.';';
		}
		else
		{
			return FALSE;
		}
		
		if ( $id_type == "admin" )
		{
			$query1 = sprintf($template,
				$this->table_prefix,
				mysql_real_escape_string($assign_id,$this->link) );
			$query2 = sprintf($template2,
				$this->table_prefix,
				mysql_real_escape_string($assign_id,$this->link) );
			$query3 = sprintf($template3,
				$this->table_prefix,
				mysql_real_escape_string($assign_id,$this->link) );
			$servers = $this->listQuery($query1);
			if($servers)
			{
				$user_expiration_dates = $this->listQuery($query2);
				$user_group_expiration_dates = $this->listQuery($query3);
				foreach($servers as $key => $server)
				{
					if($user_expiration_dates)
					{
						foreach($user_expiration_dates as $user_expiration_date)
						{
							if($server['home_id'] == $user_expiration_date['home_id'])
								$servers[$key]['user_expiration_date'] = $user_expiration_date['user_expiration_date'];
						}
					}
					if($user_group_expiration_dates)
					{
						foreach($user_group_expiration_dates as $user_group_expiration_date)
						{
							if($server['home_id'] == $user_group_expiration_date['home_id'])
								$servers[$key]['user_group_expiration_date'] = $user_group_expiration_date['user_group_expiration_date'];
						}
					}
				}
			}
			return $servers;
		}
		else
		{
			$query = sprintf($template,
				$this->table_prefix,
				mysql_real_escape_string($assign_id,$this->link) );
			return $this->listQuery($query);
		}
	}
	
	public function getHomeMods($home_id) {
		$query = sprintf('SELECT %1$sgame_mods.*, %1$sconfig_homes.game_key as gametype,
			%1$sconfig_mods.mod_name
			FROM %1$sgame_mods NATURAL JOIN %1$sconfig_mods NATURAL JOIN %1$sserver_homes
			NATURAL JOIN %1$sconfig_homes
			WHERE %1$sgame_mods.home_id = %2$d;',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link) );
		return $this->listQuery($query);
	}

	public function isIpPortOwnedByUser( $user_id, $ip, $port ) {
		$query = sprintf('SELECT *
			FROM `%1$shome_ip_ports` NATURAL JOIN `%1$sserver_homes`
			NATURAL JOIN `%1$suser_homes`
			WHERE `ip` = \'%2$s\'
			AND `port` = %3$d
			AND `user_id` = %4$d;',
			$this->table_prefix,
			mysql_real_escape_string($ip,$this->link),
			mysql_real_escape_string($port,$this->link),
			mysql_real_escape_string($user_id,$this->link) );

		++$this->queries_;
		$result = mysql_query($query, $this->link);

		// If there are no servers then we can stop here.
		if ( mysql_num_rows($result) != 1 )
			return FALSE;

		$info = mysql_fetch_assoc($result);

		return $info['home_id'];
	}

	public function getCfgHomeById($cfgid){
		$query = sprintf("SELECT *
			FROM `%sconfig_homes`
			WHERE `home_cfg_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($cfgid,$this->link));
		++$this->queries_;
		$result = mysql_query($query, $this->link);
		if ( mysql_num_rows($result) != 1 )
			return FALSE;

		return mysql_fetch_assoc($result);
	}
	
	public function getRemoteServerById($remote_server_id){
		$query = sprintf("SELECT `agent_ip`, `agent_port`, `encryption_key`, `timeout`
			FROM `%sremote_servers`
			WHERE `remote_server_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($remote_server_id,$this->link));
		++$this->queries_;
		$result = mysql_query($query, $this->link);
		if ( mysql_num_rows($result) != 1 )
			return FALSE;

		return mysql_fetch_assoc($result);
	}

	public function getIpPortsForUser($user_id) {
		$query = sprintf('SELECT %1$sremote_server_ips.*,%1$shome_ip_ports.*,%1$sserver_homes.*,
			%1$sremote_servers.*,
			%1$sconfig_homes.*,
			%1$sconfig_mods.*,
			%1$sgame_mods.*
			FROM `%1$shome_ip_ports`
			NATURAL JOIN `%1$sremote_servers`
			NATURAL JOIN `%1$sserver_homes`
			NATURAL JOIN `%1$sconfig_homes`
			NATURAL JOIN `%1$sremote_server_ips`
			NATURAL JOIN `%1$sconfig_mods`
			NATURAL JOIN `%1$sgame_mods`
			WHERE `home_id` IN
			(
				SELECT `home_id`
				FROM `%1$suser_homes`
				WHERE `user_id` = %2$d
				UNION
				SELECT `home_id`
				FROM `%1$suser_groups`
				NATURAL JOIN `%1$suser_group_homes`
				WHERE `user_id` = %2$d
			) 
			AND `force_mod_id` IN
			(
				SELECT `force_mod_id`
				FROM `%1$shome_ip_ports`
				WHERE `force_mod_id` = %1$sgame_mods.mod_id OR `force_mod_id` = "0"
			);',
			$this->table_prefix,
			mysql_real_escape_string($user_id, $this->link) );
							
		return $this->listQuery($query);
	}
	
	public function getIpPortsForUser_limit($user_id,$page_dashboardlist,$limit_dashboardlist) {
		
		$user_request_page = ($page_dashboardlist - 1) * $limit_dashboardlist;
		
		$query = sprintf('SELECT %1$sremote_server_ips.*,%1$shome_ip_ports.*,%1$sserver_homes.*,
			%1$sremote_servers.*,
			%1$sconfig_homes.*,
			%1$sconfig_mods.*,
			%1$sgame_mods.*
			FROM `%1$shome_ip_ports`
			NATURAL JOIN `%1$sremote_servers`
			NATURAL JOIN `%1$sserver_homes`
			NATURAL JOIN `%1$sconfig_homes`
			NATURAL JOIN `%1$sremote_server_ips`
			NATURAL JOIN `%1$sconfig_mods`
			NATURAL JOIN `%1$sgame_mods`
			WHERE `home_id` IN
			(
				SELECT `home_id`
				FROM `%1$suser_homes`
				WHERE `user_id` = %2$d
				UNION
				SELECT `home_id`
				FROM `%1$suser_groups`
				NATURAL JOIN `%1$suser_group_homes`
				WHERE `user_id` = %2$d
			) 
			AND `force_mod_id` IN
			(
				SELECT `force_mod_id`
				FROM `%1$shome_ip_ports`
				WHERE `force_mod_id` = %1$sgame_mods.mod_id OR `force_mod_id` = "0"
			) ORDER BY %1$shome_ip_ports.home_id ASC LIMIT '.$user_request_page.','.$limit_dashboardlist.';',
			$this->table_prefix,
			mysql_real_escape_string($user_id, $this->link) );
							
		return $this->listQuery($query);
	}
	
	public function getIpPorts( $ip_id = 0 ) {
		
		$ip_id_and = $ip_id == 0 ? "" : "`ip_id`='".$ip_id."' AND ";
		$query = sprintf('SELECT %1$sremote_server_ips.*,%1$shome_ip_ports.*,%1$sserver_homes.*,
			%1$sremote_servers.*,
			%1$sconfig_homes.*,
			%1$sconfig_mods.*,
			%1$sgame_mods.*
			FROM `%1$shome_ip_ports`
			NATURAL JOIN `%1$sremote_servers`
			NATURAL JOIN `%1$sserver_homes`
			NATURAL JOIN `%1$sconfig_homes`
			NATURAL JOIN `%1$sremote_server_ips`
			NATURAL JOIN `%1$sconfig_mods`
			NATURAL JOIN `%1$sgame_mods` 
			WHERE `force_mod_id` IN
			(
				SELECT `force_mod_id`
				FROM `%1$shome_ip_ports`
				WHERE '.$ip_id_and.'(`force_mod_id` = %1$sgame_mods.mod_id OR `force_mod_id` = "0")
			) ORDER BY %1$shome_ip_ports.home_id ASC;',
			$this->table_prefix );

		return $this->listQuery($query);
	}
	
	public function getIpPorts_limit($ip_id = 0,$page_dashboardlist,$limit_dashboardlist) {
		
		$user_request_page = ($page_dashboardlist - 1) * $limit_dashboardlist;

		$ip_id_and = $ip_id == 0 ? "" : "`ip_id`='".$ip_id."' AND ";
		$query = sprintf('SELECT %1$sremote_server_ips.*,%1$shome_ip_ports.*,%1$sserver_homes.*,
			%1$sremote_servers.*,
			%1$sconfig_homes.*,
			%1$sconfig_mods.*,
			%1$sgame_mods.*
			FROM `%1$shome_ip_ports`
			NATURAL JOIN `%1$sremote_servers`
			NATURAL JOIN `%1$sserver_homes`
			NATURAL JOIN `%1$sconfig_homes`
			NATURAL JOIN `%1$sremote_server_ips`
			NATURAL JOIN `%1$sconfig_mods`
			NATURAL JOIN `%1$sgame_mods` 
			WHERE `force_mod_id` IN
			(
				SELECT `force_mod_id`
				FROM `%1$shome_ip_ports`
				WHERE '.$ip_id_and.'(`force_mod_id` = %1$sgame_mods.mod_id OR `force_mod_id` = "0")
			) ORDER BY %1$shome_ip_ports.home_id ASC LIMIT '.$user_request_page.','.$limit_dashboardlist.';',
			$this->table_prefix );

		return $this->listQuery($query);
	}
	

	
	public function getIpPorts_count($id_type,$assign_id){
		if ( $id_type == "admin" ){
 		return $this->resultQuery("SELECT COUNT(home_id) AS total FROM `".$this->table_prefix."home_ip_ports`;");
		}
		else if ( $id_type == "user_and_group" ){
		return $this->resultQuery("SELECT COUNT(home_id) AS total FROM `".$this->table_prefix."home_ip_ports` WHERE home_id IN (SELECT home_id FROM `".$this->table_prefix."user_homes` WHERE user_id = $assign_id);");
		}
		else if ( $id_type == "subuser" ){
		return $this->resultQuery("SELECT COUNT(home_id) AS total FROM `".$this->table_prefix."home_ip_ports` WHERE home_id IN (SELECT group_id FROM `".$this->table_prefix."user_groups` WHERE user_id = $assign_id);");
		}
	}

	// Module manager functions

	/// \brief Returns the installed modules.
	public function getInstalledModules() {
		$query = sprintf("SELECT `id`,`title`,`folder`,`version`,`db_version` FROM `%smodules`",
			$this->table_prefix);
		return $this->listQuery($query);
	}
	
	public function getModule($id) {
		$query = sprintf("SELECT `id`,`title`,`folder`,`version`,`db_version` FROM `%smodules` WHERE `id` = '%d'",
			$this->table_prefix,
			mysql_real_escape_string($id,$this->link));
		$result = $this->listQuery($query);
		return $result[0];
	}

	public function getModuleIDByName($name) {
		$query = sprintf("SELECT `id` FROM `%smodules` WHERE `folder` = '%d'",
			$this->table_prefix,
			mysql_real_escape_string($name,$this->link));
		$result = $this->listQuery($query);
		return $result[0];
	}

	public function isModuleInstalled($module_folder)
	{
		$query = sprintf('SELECT * FROM `%smodules`
			WHERE `folder`="%s";',
			$this->table_prefix,
			mysql_real_escape_string($module_folder,$this->link) );
		++$this->queries_;
		mysql_query($query, $this->link);
		if ( mysql_affected_rows($this->link) != 1 )
			return FALSE;

		return TRUE;
	}
	
	public function updateModule($id, $version, $db_version)
	{
		$query = sprintf("UPDATE `%smodules` 
						 SET `version`='%s', `db_version`='%d'
						 WHERE `id` = '%d';",
				$this->table_prefix,
				mysql_real_escape_string($version, $this->link),
				mysql_real_escape_string($db_version, $this->link),
				mysql_real_escape_string($id, $this->link) );

		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
			return FALSE;

		return true;
	}

	// User game functions

	/// \brief Assignes a game home to user.
	public function assignHomeTo($id_type,$assign_id,$home_id,$access_rights)
	{
		if ( $id_type == "user" )
		{
			$template = "INSERT INTO `%suser_homes` ( `user_id`, `home_id`, `access_rights` )
				VALUES (%d,%d,'%s')";
		}
		else if ( $id_type == "group")
		{
			$template = "INSERT INTO `%suser_group_homes` ( `group_id`, `home_id`, `access_rights` )
				VALUES (%d,%d,'%s')";
		}
		else
		{
			return FALSE;
		}

		$query = sprintf($template,
			$this->table_prefix,
			mysql_real_escape_string($assign_id,$this->link),
			mysql_real_escape_string($home_id,$this->link),
			mysql_real_escape_string($access_rights,$this->link));

		++$this->queries_;
		mysql_query($query, $this->link);

		if ( mysql_affected_rows($this->link) != 1 )
			return FALSE;

		return TRUE;
	}

	public function unassignHomeFrom($id_type, $assign_id, $home_id)
	{
		if ( $id_type == "user" )
		{
			$template = "DELETE FROM `%suser_homes` WHERE `user_id` = %d
				AND `home_id` = %d;";
		}
		else if ( $id_type == "group" )
		{
			$template = "DELETE FROM `%suser_group_homes` WHERE `group_id` = %d
				AND `home_id` = %d;";
		}
		else
		{
			return FALSE;
		}

		$query = sprintf($template,
			$this->table_prefix,
			mysql_real_escape_string($assign_id,$this->link),
			mysql_real_escape_string($home_id,$this->link));

		++$this->queries_;
		mysql_query($query, $this->link);

		if ( mysql_affected_rows($this->link) != 1 )
			return FALSE;

		return TRUE;
	}

	/// \brief Adds game home to database.
	/// \return FALSE if failure
	/// \return id of the home in case of success.
	public function addGameHome($rserver_id,$user_id_main,$home_cfg_id,$game_path,$server_name,$control_password,$ftp_password){
		$query = sprintf("INSERT INTO `%sserver_homes`
			( `home_id`, `remote_server_id`, `user_id_main`, `home_cfg_id`, `home_path`, `home_name`,`control_password`,`ftp_password`)
			VALUES(NULL, '%d', '%d', '%d', '%s', '%s', '%s', '%s')",
				$this->table_prefix,
				mysql_real_escape_string($rserver_id,$this->link),
				mysql_real_escape_string($user_id_main,$this->link),
				mysql_real_escape_string($home_cfg_id,$this->link),
				mysql_real_escape_string($game_path,$this->link),
				mysql_real_escape_string($server_name,$this->link),
				mysql_real_escape_string($control_password,$this->link),
				mysql_real_escape_string($ftp_password,$this->link));
		++$this->queries_;
		mysql_query($query, $this->link);
		if ( mysql_affected_rows($this->link) != 1 )
			return FALSE;
		$homeid = mysql_insert_id($this->link);
		$this->changeHomePath($homeid,$game_path.$homeid);
		return $homeid;
	}

	public function getGameHome($home_id) {
		$query = sprintf('SELECT *
			FROM `%1$sremote_servers` 
			NATURAL JOIN `%1$sserver_homes` 
			NATURAL JOIN `%1$sconfig_homes` 
			WHERE `home_id` = %2$d;',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		$result = mysql_query($query);
		if ( mysql_num_rows($result) == 0 )
			return FALSE;

		$game_home = mysql_fetch_assoc($result);

		// Add mods to home.
		$query = sprintf('SELECT *
			FROM `%1$sgame_mods` NATURAL JOIN `%1$sconfig_mods`
			WHERE `home_id` = %2$d',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		$result = mysql_query($query);

		$mods_array = array();

		if ( mysql_num_rows($result) != 0 )
		{
			while ($mod_row = mysql_fetch_assoc($result))
			{
				$mods_array[$mod_row['mod_id']] = $mod_row;
			}
		}
		
		$game_home['mods'] = $mods_array;
		// Since this function is only called for administrators
		// we must give all access rights
		$game_home['access_rights'] = "ufpetc";
		// Return the game home and mods.
		return $game_home;
	}
	
	public function getGameHomeWithoutMods($home_id) {
		$query = sprintf('SELECT *
			FROM `%1$sremote_servers` 
			NATURAL JOIN `%1$sserver_homes` 
			NATURAL JOIN `%1$sconfig_homes`
			WHERE `home_id` = %2$d;',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		$result = mysql_query($query);
		if ( mysql_num_rows($result) == 0 )
			return FALSE;

		$game_home = mysql_fetch_assoc($result);

		return $game_home;
	}
	
	public function getHomeByFtpLogin($remote_server_id,$ftp_login) {
		$query = sprintf('SELECT *
			FROM `%1$sremote_servers` 
			NATURAL JOIN `%1$sserver_homes` 
			NATURAL JOIN `%1$sconfig_homes`
			WHERE `remote_server_id` = "%2$d" AND `ftp_login` = "%3$s";',
			$this->table_prefix,
			mysql_real_escape_string($remote_server_id, $this->link),
			mysql_real_escape_string($ftp_login, $this->link));
		++$this->queries_;
		$result = mysql_query($query);
		if ( mysql_num_rows($result) == 0 )
		{
			$query = sprintf('SELECT *
				FROM `%1$sremote_servers` 
				NATURAL JOIN `%1$sserver_homes` 
				NATURAL JOIN `%1$sconfig_homes`
				WHERE `home_id` = %2$d;',
				$this->table_prefix,
				mysql_real_escape_string($ftp_login, $this->link));
			++$this->queries_;
			$result = mysql_query($query);
			if ( mysql_num_rows($result) == 0 )
				return FALSE;
		}

		$game_home = mysql_fetch_assoc($result);

		return $game_home;
	}
	
	public function getGameHomeByIP($ip, $port){
		$query = sprintf('SELECT *
			FROM `%1$sremote_servers` 
			NATURAL JOIN `%1$sserver_homes` 
			NATURAL JOIN `%1$sconfig_homes` 
			NATURAL JOIN `%1$sconfig_mods` 
			NATURAL JOIN `%1$sgame_mods`
			NATURAL JOIN `%1$sremote_server_ips`
			NATURAL JOIN `%1$shome_ip_ports`
			WHERE `ip` = \'%2$s\' AND `port` = \'%3$s\';',
			$this->table_prefix,
			mysql_real_escape_string($ip),
			mysql_real_escape_string($port));
			
		++$this->queries_;

		$result = mysql_query($query);

		if ( mysql_num_rows($result) == 0 )
			return FALSE;

		$game_home = mysql_fetch_assoc($result);

		// Add mods to home.
		$home_id =  $game_home['home_id'];

		$query = sprintf('SELECT *
			FROM `%1$sgame_mods` NATURAL JOIN `%1$sconfig_mods`
			WHERE `home_id` = %2$d',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link));

		++$this->queries_;

		$result = mysql_query($query);

		$mods_array = array();

		if ( mysql_num_rows($result) != 0 )
		{
			while ($mod_row = mysql_fetch_assoc($result))
			{
				$mods_array[$mod_row['mod_id']] = $mod_row;
			}
		}

		$game_home['mods'] = $mods_array;

		// Return the line with merged rights.
		return $game_home;
	}

	public function getUserGameHome($user_id, $home_id) {
		$query = sprintf('SELECT %1$suser_homes.access_rights as access_rights, %1$sremote_servers.*,
			%1$sserver_homes.*, %1$sconfig_homes.*
			FROM `%1$sremote_servers` 
			NATURAL JOIN `%1$sserver_homes`
			NATURAL JOIN `%1$sconfig_homes` 
			NATURAL JOIN `%1$suser_homes`
			WHERE `home_id` = %2$d
			AND `user_id` = %3$d
			UNION
			SELECT %1$suser_group_homes.access_rights as access_rights, %1$sremote_servers.*,
			%1$sserver_homes.*, %1$sconfig_homes.*
			FROM `%1$sremote_servers` 
			NATURAL JOIN `%1$sserver_homes`
			NATURAL JOIN `%1$sconfig_homes` 
			NATURAL JOIN `%1$suser_group_homes`
			NATURAL JOIN `%1$suser_groups`
			WHERE `home_id` = %2$d
			AND `user_id` = %3$d;',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link),
			mysql_real_escape_string($user_id, $this->link));
		++$this->queries_;
		$result = mysql_query($query);
		if ( mysql_num_rows($result) == 0 )
			return FALSE;

		$game_home = mysql_fetch_assoc($result);

		while ( $tmp_line = mysql_fetch_assoc($result) )
		{
			if(isset($game_home['access_rights']) and isset($tmp_line['access_rights']))
			{
				$current_rights = str_split($game_home['access_rights']);
				$merging_rights = str_split($tmp_line['access_rights']);
				$merged_rights = array_merge($current_rights,$merging_rights);
				$game_home['access_rights'] = implode("",array_unique($merged_rights));
				break;
			}
			
			if(isset($tmp_line['access_rights']))
				$game_home['access_rights'] = $tmp_line['access_rights'];
		}

		// Add mods to home.
		$query = sprintf('SELECT *
			FROM `%1$sgame_mods` NATURAL JOIN `%1$sconfig_mods`
			WHERE `home_id` = %2$d',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		$result = mysql_query($query);

		$mods_array = array();

		if ( mysql_num_rows($result) != 0 )
		{
			while ($mod_row = mysql_fetch_assoc($result))
			{
				$mods_array[$mod_row['mod_id']] = $mod_row;
			}
		}

		$game_home['mods'] = $mods_array;

		// Return the line with merged rights.
		return $game_home;
	}


	/// \brief Deletes the game home.
	public function deleteGameHome($home_id){
		$home_id = mysql_real_escape_string($home_id, $this->link);
		$return = TRUE;

		$queries = array("DELETE FROM `%suser_homes` WHERE `home_id` = %d;",
			"DELETE FROM `%sserver_homes` WHERE `home_id` = %d;",
			"DELETE FROM `%sgame_mods` WHERE `home_id` = %d;",
			"DELETE FROM `%suser_group_homes` WHERE `home_id` = %d;",
			"DELETE FROM `%smysql_databases` WHERE `home_id` = %d;",
			"DELETE FROM `%smaster_server_homes` WHERE `home_id` = %d;",
			'DELETE FROM `%1$sstatus_cache` WHERE (`ip_id`, `port`) IN
			(SELECT ip_id, port FROM `%shome_ip_ports` WHERE `home_id` = %d);',
			"DELETE FROM `%shome_ip_ports` WHERE `home_id` = %d;");

		foreach ( $queries as $query )
		{
			$query = sprintf($query,$this->table_prefix,$home_id);
			++$this->queries_;
			$result = mysql_query($query,$this->link);
			$return = ($result === FALSE) ? FALSE : $return;
		}
		return $return;
	}

	/// \brief Adds game mod to home.
	public function addModToGameHome($home_id, $mod_cfg_id){
		$query = sprintf("INSERT INTO `%sgame_mods` (`mod_id`,`home_id`, `mod_cfg_id`)
			VALUES(NULL,'%d','%d')",
				$this->table_prefix,
				mysql_real_escape_string($home_id, $this->link),
				mysql_real_escape_string($mod_cfg_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;
		$mod_id = mysql_insert_id($this->link);
		return $mod_id;
	}

	public function delGameMod($mod_id){
		$query = sprintf("DELETE FROM `%sgame_mods` WHERE `mod_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($mod_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;
		$query = sprintf("UPDATE `%shome_ip_ports` SET `force_mod_id` = 0 WHERE `force_mod_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($mod_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;
		return TRUE;
	}

	public function changeHomePath($home_id,$path) {
		$query = sprintf("UPDATE `%sserver_homes` SET `home_path` = '%s' WHERE `home_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($path, $this->link),
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}

	public function changeUserIdMain($home_id,$userid) {
		$query = sprintf("UPDATE `%sserver_homes` SET `user_id_main` = '%s' WHERE `home_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($userid, $this->link),
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function changeFtpLogin($home_id,$ftp_login) {
		$query = sprintf("UPDATE `%sserver_homes` SET `ftp_login` = '%s' WHERE `home_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($ftp_login, $this->link),
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function changeFtpPassword($home_id,$password) {
		$query = sprintf("UPDATE `%sserver_homes` SET `ftp_password` = '%s' WHERE `home_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($password, $this->link),
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function changeFtpStatus ($status,$home_id) {
		$status_val = $status == "enabled" ? 1 : 0;
		$query = sprintf("UPDATE `%sserver_homes` SET `ftp_status` = '%d' WHERE `home_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($status_val, $this->link),
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function IsFtpEnabled($home_id) {
		$query = sprintf("SELECT `ftp_status` FROM `%sserver_homes` WHERE `home_id` = %d AND `ftp_status` = 1",
			$this->table_prefix,
			mysql_real_escape_string($home_id,$this->link));
		++$this->queries_;
		$result = mysql_query($query,$this->link) or die("Query failed".mysql_error($this->link));

		if(mysql_affected_rows($this->link) == 0)
			return false;

		return true;
	}
	
	public function setMasterServer($action,$home_id,$home_cfg_id,$remote_server_id) {
		if($action == "add")
		{
			$query = sprintf("INSERT INTO `%smaster_server_homes` (`home_id`,`home_cfg_id`, `remote_server_id`) VALUES('%d','%d','%d')",
					$this->table_prefix,
					mysql_real_escape_string($home_id, $this->link),
					mysql_real_escape_string($home_cfg_id, $this->link),
					mysql_real_escape_string($remote_server_id, $this->link));
		}
		elseif($action == "remove")
		{
			$query = sprintf("DELETE FROM `%smaster_server_homes` WHERE `home_id` = %d AND `home_cfg_id` = %d AND `remote_server_id` = %d",
					$this->table_prefix,
					mysql_real_escape_string($home_id, $this->link),
					mysql_real_escape_string($home_cfg_id, $this->link),
					mysql_real_escape_string($remote_server_id, $this->link));
		}
		++$this->queries_;
			
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function getMasterServer( $remote_server_id, $home_cfg_id ){
		$query = sprintf("SELECT home_id FROM `%smaster_server_homes` WHERE `home_cfg_id` = %d AND `remote_server_id` = %d",
					$this->table_prefix,
					mysql_real_escape_string($home_cfg_id, $this->link),
					mysql_real_escape_string($remote_server_id, $this->link));

		$retval = $this->listQuery($query);
		if( empty( $retval ) )
		{
			print_r($this->getError());
			return FALSE;
		}
		return $retval[0]['home_id'];
	}
	
	/// \brief get available mods for game home.
	public function getAvailableModsForGameHome($home_id){
		$query = sprintf('SELECT `mod_cfg_id`, `mod_key`,`mod_name`
			FROM `%1$sserver_homes` NATURAL JOIN `%1$sconfig_homes` NATURAL JOIN `%1$sconfig_mods`
			WHERE `home_id` = %2$d
			ORDER BY `mod_name` ASC',
			$this->table_prefix,
			mysql_real_escape_string($home_id, $this->link));
		$retval = $this->listQuery($query);
		print_r($this->getError());
		return $retval;
	}

	public function updateGameModParams($max_players,$extra_params,$cpu_affinity,$nice,$home_id,$mod_cfg_id) {
		$max_players = mysql_real_escape_string($max_players, $this->link);
		$extra_params = mysql_real_escape_string($extra_params, $this->link);
		$cpu_affinity = mysql_real_escape_string($cpu_affinity, $this->link);
		$nice = mysql_real_escape_string($nice, $this->link);
		$home_id = mysql_real_escape_string($home_id, $this->link);
		$mod = mysql_real_escape_string($mod_cfg_id, $this->link);
		$query = "UPDATE `".$this->table_prefix."game_mods` SET `max_players` = '$max_players',
			`extra_params` = '$extra_params', `cpu_affinity` = '$cpu_affinity', `nice` = $nice
			WHERE `home_id` = $home_id
			AND `mod_cfg_id` = $mod_cfg_id;";

		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}

	public function addGameIpPort($home_id, $ip, $port) {
		$home_id = mysql_real_escape_string($home_id, $this->link);
		$ip = mysql_real_escape_string($ip, $this->link);
		$port = mysql_real_escape_string($port, $this->link);
		$query = "INSERT INTO `".$this->table_prefix."home_ip_ports` (`ip_id`, `port`, `home_id` )
			VALUES ( '$ip', '$port', '$home_id' );";

		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}

	public function delGameIpPort($home_id, $ip, $port) {
		$home_id = mysql_real_escape_string($home_id, $this->link);
		$ip = mysql_real_escape_string($ip, $this->link);
		$port = mysql_real_escape_string($port, $this->link);
		$query = "DELETE FROM `".$this->table_prefix."home_ip_ports`
			WHERE `ip_id` = '$ip' AND `port` = '$port' AND `home_id` = '$home_id'";

		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function forceModAtAddress($ip_id, $port, $force_mod_id) {
		$force_mod_id = mysql_real_escape_string($force_mod_id,$this->link);
		$ip_id = mysql_real_escape_string($ip_id,$this->link);
		$port = mysql_real_escape_string($port,$this->link);
		$query = "UPDATE `".$this->table_prefix."home_ip_ports` SET `force_mod_id` = '$force_mod_id'
				  WHERE `ip_id` = '$ip_id' AND `port` = '$port'";

		++$this->queries_;
		if ( mysql_query($query,$this->link) === FALSE )
			return FALSE;

		return TRUE;
	}

	public function changeHomeName($home_id, $name) {
		$home_id = mysql_real_escape_string($home_id, $this->link);
		$name = mysql_real_escape_string($name, $this->link);
		$query = "UPDATE `".$this->table_prefix."server_homes` SET `home_name` = '$name'
			WHERE `home_id` = $home_id";

		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}

	public function changeHomeControlPassword($home_id, $control_password)
	{
		$home_id = mysql_real_escape_string($home_id, $this->link);
		$control_password = mysql_real_escape_string($control_password, $this->link);
		$query = "UPDATE `".$this->table_prefix."server_homes` SET `control_password` = '$control_password'
			WHERE `home_id` = $home_id";

		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}

	public function getAvailableHomesFor($id_type, $assign_id) {
		if ( $id_type == "user" )
		{
			$template = 'SELECT * FROM `%1$sserver_homes`
				WHERE `home_id` NOT IN
				(
					SELECT `home_id` FROM `%1$suser_homes`
					WHERE `user_id` = %2$d
				);';
		}
		else if ( $id_type == "group" )
		{
			$template = 'SELECT * FROM `%1$sserver_homes`
				WHERE `home_id` NOT IN
				(
					SELECT `home_id` FROM `%1$suser_group_homes`
					WHERE `group_id` = %2$d
				);';
		}
		else
		{
			return FALSE;
		}

		$query = sprintf($template,
			$this->table_prefix,
			mysql_real_escape_string($assign_id, $this->link));

		return $this->listQuery($query);
	}
	
	public function getAvailableUserHomesFor($id_type, $assign_id, $user_id) {
		if ( $id_type == "group" )
		{
			$template ='SELECT * FROM `%1$sserver_homes`
						WHERE
						`home_id` IN
						(
							SELECT `home_id` FROM `%1$suser_homes`
							WHERE `user_id` = %3$d
						)
						AND
						`home_id` NOT IN
						(
							SELECT `home_id` FROM `%1$suser_group_homes`
							WHERE `group_id` = %2$d
						)';
		}
		else
		{
			return FALSE;
		}

		$query = sprintf($template,
			$this->table_prefix,
			mysql_real_escape_string($assign_id, $this->link),
			mysql_real_escape_string($user_id, $this->link));

		return $this->listQuery($query);
	}

	public function getGameHomes(){
		$query = sprintf('SELECT %1$sserver_homes.*,%1$sremote_servers.*, %1$sconfig_homes.*
			FROM `%1$sserver_homes` NATURAL JOIN `%1$sconfig_homes` NATURAL JOIN `%1$sremote_servers`;',
			$this->table_prefix);
		return $this->listQuery($query);
	}
	
	public function getGameHomes_limit($page_gameHomes,$limit_gameHomes,$search_field){
		$game_home_id = ($page_gameHomes - 1) * $limit_gameHomes;
		$query = sprintf('SELECT %1$sserver_homes.*, %1$sremote_servers.*, %1$sconfig_homes.*
			FROM `%1$sserver_homes` NATURAL JOIN `%1$sconfig_homes` NATURAL JOIN `%1$sremote_servers` 
			'.($search_field ? "WHERE home_id = '$search_field' OR remote_server_id = '$search_field'
			OR user_id_main = '$search_field' OR home_path = '$search_field' OR home_cfg_id = '$search_field'
			OR home_name = '$search_field' OR agent_ip = '$search_field' OR remote_server_name = '$search_field'
			OR user_id_main IN (SELECT `user_id` FROM `".$this->table_prefix."users` WHERE users_login = '$search_field')
			" : "").'
			ORDER BY home_id ASC LIMIT '.$game_home_id.','.$limit_gameHomes.'; ',
			$this->table_prefix);
		return $this->listQuery($query);
	}
	
   public function get_GameHomes_count($search_field){
      return $this->resultQuery("SELECT COUNT(home_id) AS total FROM `".$this->table_prefix."server_homes` NATURAL JOIN `".$this->table_prefix."remote_servers`
	  ".($search_field ? "WHERE home_id = '$search_field' OR remote_server_id = '$search_field'
			OR user_id_main = '$search_field' OR home_path = '$search_field' OR home_cfg_id = '$search_field'
			OR home_name = '$search_field' OR agent_ip = '$search_field' OR remote_server_name = '$search_field'
			OR user_id_main IN (SELECT `user_id` FROM `".$this->table_prefix."users` WHERE users_login = '$search_field')
			" : "")."
	  ;");
   }
	
	public function changeLastParam($home_id,$json) {
		$query = sprintf("UPDATE `%sserver_homes` SET `last_param` = '%s' WHERE `home_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($json, $this->link),
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function getLastParam($home_id) {
		if ( !$this->link ) return FALSE;

		$query = sprintf("SELECT `last_param` FROM `%sserver_homes` WHERE `home_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($home_id,$this->link));

		++$this->queries_;
		$result = mysql_query($query, $this->link);
		
		if ( mysql_num_rows($result) != 1 )
			return FALSE;
			
		$result = mysql_fetch_assoc( $result );

		return $result['last_param'];
	}
	
	public function saveServerStatusCache($ip_id,$port,$status) {
		$query = sprintf("SELECT * FROM `%sstatus_cache` WHERE `ip_id` = %s AND `port` = %s;",
			$this->table_prefix,
			mysql_real_escape_string($ip_id,$this->link),
			mysql_real_escape_string($port,$this->link));

		++$this->queries_;
		$result = mysql_query($query, $this->link);
		
		if ( mysql_num_rows($result) > 0 )
		{
			$query = sprintf("DELETE FROM `%sstatus_cache` WHERE `ip_id` = %s AND `port` = %s;",
				$this->table_prefix,
				mysql_real_escape_string($ip_id,$this->link),
				mysql_real_escape_string($port,$this->link));

			++$this->queries_;
			mysql_query($query, $this->link);	
		}
			
		$now = time();
		$json = json_encode($status);
		$query = sprintf("INSERT INTO `%sstatus_cache` ( `date_timestamp`, `ip_id`, `port`, `server_status_cache` ) VALUES ( '%s', '%s', '%s', '%s' );",
			$this->table_prefix,
			mysql_real_escape_string($now, $this->link),
			mysql_real_escape_string($ip_id, $this->link),
			mysql_real_escape_string($port, $this->link),
			mysql_real_escape_string($json, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function getServerStatusCache($ip_id,$port) {
		if ( !$this->link ) return FALSE;

		$query = sprintf("SELECT * FROM `%sstatus_cache` WHERE `ip_id` = %s AND `port` = %s;",
			$this->table_prefix,
			mysql_real_escape_string($ip_id,$this->link),
			mysql_real_escape_string($port,$this->link));

		++$this->queries_;
		$result = mysql_query($query, $this->link);
		
		if ( mysql_num_rows($result) != 1 )
			return FALSE;
			
		$result = mysql_fetch_assoc( $result );
		
		$cache = json_decode( $result['server_status_cache'], True);
		
		$cache['date_timestamp'] = $result['date_timestamp'];

		return $cache;
	}
	
	public function delServerStatusCache($ip_id,$port) {
		if ( !$this->link ) return FALSE;

		$query = sprintf("DELETE FROM `%sstatus_cache` WHERE `ip_id` = %s AND `port` = %s;",
			$this->table_prefix,
			mysql_real_escape_string($ip_id,$this->link),
			mysql_real_escape_string($port,$this->link));

		++$this->queries_;
		$result = mysql_query($query, $this->link);
		
		if ( mysql_query($query) === FALSE )
			return FALSE;
		
		return TRUE;
	}


	public function is_valid_login($user_id,$password)
	{
		++$this->queries_;
		$query = sprintf("SELECT *
			FROM `%susers`
			WHERE `user_id` = %d AND
			`users_passwd` = MD5('%s');",
				$this->table_prefix,
				mysql_real_escape_string($user_id, $this->link),
				mysql_real_escape_string($password, $this->link));

		$result = mysql_query($query);

		if (mysql_affected_rows() == 1)
			return TRUE;

		return FALSE;
	}
	
	public function addAdminExternalLink($name, $url, $user_id) {
		$name = mysql_real_escape_string($name, $this->link);
		$url = mysql_real_escape_string($url, $this->link);
		$user_id = mysql_real_escape_string($user_id, $this->link);
		$query = "INSERT INTO `".$this->table_prefix."adminExternalLinks` (	`link_id`, `name`, `url`, `user_id` )
			VALUES ( NULL, '$name', '$url', '$user_id' );";

		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function getAdminExternalLinks($user_id) {
		if ( !$this->link ) return;
		$query = sprintf("SELECT * FROM `%sadminExternalLinks` WHERE user_id=".$user_id,
			$this->table_prefix);
		return $this->listQuery($query);
	}
	
	public function delAdminExternalLink($link_id, $user_id){
		$user_id = mysql_real_escape_string($user_id, $this->link);
		$link_id = mysql_real_escape_string($link_id, $this->link);
		$query = "DELETE FROM `".$this->table_prefix."adminExternalLinks`
			WHERE `link_id` = '$link_id' AND `user_id` = '$user_id'";
		
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function addRconPreset($name,$command,$home_cfg_id,$mod_cfg_id)
	{
		$name = mysql_real_escape_string($name, $this->link);
		$command = mysql_real_escape_string($command, $this->link);
		$home_cfg_id = mysql_real_escape_string($home_cfg_id, $this->link);
		$mod_cfg_id = mysql_real_escape_string($mod_cfg_id, $this->link);
		$query = "INSERT INTO `".$this->table_prefix."rcon_presets` (	`preset_id`, `name`, `command`, `home_cfg_id`, `mod_cfg_id` )
			VALUES ( NULL, '$name', '$command', '$home_cfg_id', '$mod_cfg_id' );";

		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function delRconPreset($preset_id)
	{
		$preset_id = mysql_real_escape_string($preset_id, $this->link);
		$query = "DELETE FROM `".$this->table_prefix."rcon_presets`
				  WHERE `preset_id` = '$preset_id'";

		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function changeRconPreset($name,$command,$preset_id)
	{
		$name = mysql_real_escape_string($name, $this->link);
		$command = mysql_real_escape_string($command, $this->link);
		$preset_id = mysql_real_escape_string($preset_id, $this->link);
		$query = "UPDATE `".$this->table_prefix."rcon_presets` SET `name` = '$name',
																   `command` = '$command'
															 WHERE `preset_id` = $preset_id";

		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function getRconPresets($home_cfg_id,$mod_cfg_id)
	{
		if ( !$this->link ) return;
		$query = sprintf("SELECT * FROM `%srcon_presets` WHERE home_cfg_id=".$home_cfg_id." AND mod_cfg_id=".$mod_cfg_id,
			$this->table_prefix);
		return $this->listQuery($query);
	}
		
	public function getTablePrefix()
	{
		return $this->table_prefix;
	}

	public function incrementalNumByHomeId($home_id,$mod_cfg_id,$remote_server_id)
	{
		$mod_cfg_id = mysql_real_escape_string($mod_cfg_id, $this->link);
		$remote_server_id = mysql_real_escape_string($remote_server_id, $this->link);
		$query = "SELECT `home_id` FROM `".$this->table_prefix."server_homes` 
				  NATURAL JOIN `".$this->table_prefix."game_mods`
				  WHERE mod_cfg_id=".$mod_cfg_id." AND remote_server_id=".$remote_server_id;
		$result = $this->listQuery($query);
		
		$position = 0;
		foreach($result as $maching_mod )
		{
			if ( $maching_mod['home_id'] < $home_id )
				$position = $position + 2;
		}

		if ($position <= 9)
			return "00"."$position";
		elseif ($position <= 99)
			return "0"."$position";
		else
			return $position;
	}
	
	public function logger($message){
		$user_id = isset($_SESSION['user_id']) ? $_SESSION['user_id'] : 0;
		$client_ip = getClientIPAddress();
		$message = mysql_real_escape_string($message, $this->link);
		$this->query("INSERT INTO OGP_DB_PREFIXlogger (date, user_id, ip, message) VALUE (FROM_UNIXTIME(UNIX_TIMESTAMP(), '%d-%m-%Y %H:%i:%s'), $user_id, '$client_ip', '$message');");
	}

	public function get_logger_count($search_field){
		return $this->resultQuery("SELECT COUNT(log_id) AS total FROM `".$this->table_prefix."logger` 
		".($search_field ? " WHERE log_id = '$search_field' OR user_id = '$search_field' 
		 OR ip = '$search_field' OR message = '$search_field' OR user_id
		 IN 
		 (SELECT user_id FROM `".$this->table_prefix."users` WHERE users_login = '$search_field')" : "")."
		;");
	}
	
	public function read_logger($page,$limit,$search_field){
		$log_id = ($page - 1) * $limit;
		return $this->resultQuery("SELECT * FROM `".$this->table_prefix."logger` 
		".($search_field ? " WHERE log_id = '$search_field' OR date = '$search_field'
		 OR user_id = '$search_field' OR ip = '$search_field' OR message = '$search_field' OR user_id 
		 IN 
		 (SELECT `user_id` FROM `".$this->table_prefix."users` WHERE users_login = '$search_field')" : "")." 
		ORDER BY log_id DESC LIMIT $log_id,$limit;
		");
	}
	
	public function del_logger_log($log_id){
		return $this->query("DELETE FROM `".$this->table_prefix."logger` WHERE log_id=$log_id;");
	}
	
	public function empty_logger(){
		return $this->query("TRUNCATE `".$this->table_prefix."logger`;");
	}
	
	public function getIpIdByIp($ip){
		$query = sprintf("SELECT ip_id FROM `%sremote_server_ips` WHERE ip = '%s';",
			$this->table_prefix,
			mysql_real_escape_string($ip,$this->link));
		$result = $this->listQuery($query);
		return $result[0]['ip_id'];
	}
	
	public function getIpById($ip_id){
		$query = sprintf("SELECT ip FROM `%sremote_server_ips` WHERE ip_id = '%d';",
			$this->table_prefix,
			mysql_real_escape_string($ip_id,$this->link));
		$result = $this->listQuery($query);
		return $result[0]['ip'];
	}
	
	public function addPortsRange($ip_id,$home_cfg_id,$start_port,$end_port,$port_increment){
		if ( !$this->link ) return false;
		if ($start_port == "" or $end_port == "" or $port_increment == "" or
			$start_port == "0" or $end_port == "0" or $port_increment == "0" or
			$start_port > $end_port)
			return 1;
		$ranges = $this->getPortsRange($ip_id);
		if($ranges != FALSE)
		{
			$used_range_ports = array();
			foreach($ranges as $range)
			{
				for($port = $range['start_port']; $port >= $range['start_port'] and $port <= $range['end_port']; $port++)
				{
					$used_range_ports[] = $port;
				}
			}
			if(!empty($used_range_ports))
			{
				$range_ports = array();
				for($port = $start_port; $port >= $start_port and $port <= $end_port; $port++)
				{
					$range_ports[] = $port;
				}
				foreach($range_ports as $range_port)
				{
					if(in_array($range_port,$used_range_ports))
						return 2;
				}
			}
		}
		$query = sprintf("INSERT INTO `%sarrange_ports` (`ip_id`,`home_cfg_id`,`start_port`,`end_port`,`port_increment`) VALUES('%d','%d', '%d','%d', '%d')",
			$this->table_prefix,
			mysql_real_escape_string($ip_id,$this->link),
			mysql_real_escape_string($home_cfg_id,$this->link),
			mysql_real_escape_string($start_port,$this->link),
			mysql_real_escape_string($end_port,$this->link),
			mysql_real_escape_string($port_increment,$this->link));

		++$this->queries_;
		mysql_query($query,$this->link);

		if( mysql_errno($this->link) != 0 )
			return false;
	
		return true;
	}
	
	public function getPortsRange($ip_id,$home_cfg_id = FALSE){
		if ( !$this->link ) return false;
		$and_cfg_id = $home_cfg_id !== FALSE ? "AND home_cfg_id=$home_cfg_id":"";
		$query = sprintf("SELECT * FROM `%sarrange_ports` WHERE ip_id=%d $and_cfg_id;",
			$this->table_prefix,
			mysql_real_escape_string($ip_id,$this->link));

		++$this->queries_;
		
		return $this->listQuery($query);
	}
	
	public function delPortsRange($range_id){
		$range_id = mysql_real_escape_string($range_id,$this->link);
		return $this->query("DELETE FROM `".$this->table_prefix."arrange_ports` WHERE range_id=$range_id;");
	}
	
	public function editPortsRange($range_id,$ip_id,$start_port,$end_port,$port_increment){
		if ($start_port == "" or $end_port == "" or $port_increment == "" or
			$start_port == "0" or $end_port == "0" or $port_increment == "0" or
			$start_port > $end_port)
			return 1;
		$ranges = $this->getPortsRange($ip_id);
		if($ranges != FALSE)
		{
			$used_range_ports = array();
			foreach($ranges as $range)
			{
				if($range['range_id'] == $range_id)
					continue;
				for($port = $range['start_port']; $port >= $range['start_port'] and $port <= $range['end_port']; $port++)
				{
					$used_range_ports[] = $port;
				}
			}
			if(!empty($used_range_ports))
			{
				$range_ports = array();
				for($port = $start_port; $port >= $start_port and $port <= $end_port; $port++)
				{
					$range_ports[] = $port;
				}
				
				foreach($range_ports as $range_port)
				{
					if(in_array($range_port,$used_range_ports))
						return 2;
				}
			}
		}
		$query = sprintf("UPDATE %sarrange_ports 
								 SET 
								 start_port='%d',
								 end_port='%d',
								 port_increment='%d'
								 WHERE range_id='%d';",
								 $this->table_prefix,
								 mysql_real_escape_string($start_port, $this->link),
								 mysql_real_escape_string($end_port, $this->link),
								 mysql_real_escape_string($port_increment, $this->link),
								 mysql_real_escape_string($range_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query, $this->link) === FALSE )
			return FALSE;

		return TRUE;
	}
		
	public function getNextAvailablePort($ip_id,$home_cfg_id){
		$ranges = $this->getPortsRange($ip_id,$home_cfg_id);
		$range = $ranges[0];
		if(empty($range))
		{
			$ranges = $this->getPortsRange($ip_id,"0");
			$range = $ranges[0];
		}
		if(empty($range))
			$range = array('start_port' => '27015','end_port' => '39915', 'port_increment' => '100');
			
		$home_used_ports = $this->getIpPorts($ip_id);	
		$used_ports = array();
		if(!empty($home_used_ports))
		{
			foreach($home_used_ports as $home_used_port)
			{
				$used_ports[] = $home_used_port['port'];
			}
		}
		
		for($port = $range['start_port']; $port >= $range['start_port'] and $port <= $range['end_port']; $port+=$range['port_increment'])
		{
			if(!in_array($port,$used_ports))
				return $port;
		}
		return FALSE;
	}
	
	public function changeCustomFields($home_id,$json) {
		$query = sprintf("UPDATE `%sserver_homes` SET `custom_fields` = '%s' WHERE `home_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($json, $this->link),
			mysql_real_escape_string($home_id, $this->link));
		++$this->queries_;
		if ( mysql_query($query) === FALSE )
			return FALSE;

		return TRUE;
	}
	
	public function getCustomFields($home_id) {
		if ( !$this->link ) return FALSE;

		$query = sprintf("SELECT `custom_fields` FROM `%sserver_homes` WHERE `home_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($home_id,$this->link));

		++$this->queries_;
		$result = mysql_query($query, $this->link);
		
		if ( mysql_num_rows($result) != 1 )
			return FALSE;
			
		$result = mysql_fetch_assoc( $result );

		return $result['custom_fields'];
	}
	
	public function getFirewallSettings($remote_server_id)
	{
		if ( !$this->link ) return FALSE;
		$query = sprintf("SELECT `firewall_settings` FROM `%sremote_servers` WHERE `remote_server_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($remote_server_id,$this->link));

		++$this->queries_;
		$result = mysql_query($query,$this->link);
		
		if ( !$result )
			$result['firewall_settings'] = NULL;
		else
			$result = mysql_fetch_assoc( $result );
		
		if(!is_null($result['firewall_settings']))
			$firewall_settings = unserialize(base64_decode($result['firewall_settings']));
		if(!isset($firewall_settings['default_allowed']))
		{
			$remote_server = $this->getRemoteServer($remote_server_id);
			$agent_ip = gethostbyname($remote_server['agent_ip']);
			$ftp_ip = gethostbyname($remote_server['ftp_ip']);
		}
		$firewall_settings['status'] = isset($firewall_settings['status']) ?
											 $firewall_settings['status'] :
											 "disable";
		$firewall_settings['default_allowed'] = isset($firewall_settings['default_allowed']) ?
													  $firewall_settings['default_allowed'] :
													  "$agent_ip:$remote_server[agent_port],$ftp_ip:$remote_server[ftp_port],22,25,80";
		$firewall_settings['allow_port_command'] = isset($firewall_settings['allow_port_command']) ?
														 $firewall_settings['allow_port_command'] :
														 "ufw allow %PORT%";
		$firewall_settings['deny_port_command'] = isset($firewall_settings['deny_port_command']) ?
														$firewall_settings['deny_port_command'] :
														"ufw deny %PORT%";
		$firewall_settings['deny_ip_port_command'] = isset($firewall_settings['deny_ip_port_command']) ?
														   $firewall_settings['deny_ip_port_command'] :
														   "ufw deny to %IP% port %PORT%";
		$firewall_settings['allow_ip_port_command'] = isset($firewall_settings['allow_ip_port_command']) ?
															$firewall_settings['allow_ip_port_command'] :
															"ufw allow to %IP% port %PORT%";
		$firewall_settings['enable_firewall_command'] = isset($firewall_settings['enable_firewall_command']) ?
															  $firewall_settings['enable_firewall_command'] :
															  "echo y | ufw enable";
		$firewall_settings['disable_firewall_command'] = isset($firewall_settings['disable_firewall_command']) ? 
														 $firewall_settings['disable_firewall_command'] : 
														 "ufw disable";
		$firewall_settings['get_firewall_status_command'] = isset($firewall_settings['get_firewall_status_command']) ? 
														 $firewall_settings['get_firewall_status_command'] : 
														 "ufw status";
		$firewall_settings['reset_firewall_command'] = isset($firewall_settings['reset_firewall_command']) ? 
														 $firewall_settings['reset_firewall_command'] : 
														 "echo y | ufw reset";
		return $firewall_settings;
	}
	
	public function updateFirewallSettings($remote_server_id,$firewall_settings) {
		$settings = base64_encode(serialize($firewall_settings));
		$query = sprintf("UPDATE `%sremote_servers` SET `firewall_settings` = '%s' WHERE `remote_server_id` = %d",
			$this->table_prefix,
			mysql_real_escape_string($settings,$this->link),
			mysql_real_escape_string($remote_server_id,$this->link));
		++$this->queries_;
		if ( mysql_query($query,$this->link) === FALSE )
			return FALSE;
		return TRUE;
	}
	
	public function real_escape_string($string) {
		return mysql_real_escape_string($string,$this->link);
	}
	
	public function updateExpirationDate($home_id, $expiration_date, $type, $assign_id = NULL) {
		if(preg_match('/^([0-2][0-9]|3[0-1])\/(0[1-9]|1[0-2])\/[1-2][0-9][0-9][0-9][\s|\t]+([0-1][0-9]|2[0-3]):[0-5][0-9]:[0-5][0-9]$/',$expiration_date) or $expiration_date == 'X' or $expiration_date == '')
		{
			if($expiration_date == 'X' or $expiration_date == '')
			{
				$ed = 'X';
			}
			else
			{
				$dateTime = DateTime::createFromFormat('d/m/Y H:i:s', $expiration_date);
				$ed = $dateTime->getTimestamp();
			}
			$type = $type != "group" ? $type : "user_group";
			$query = sprintf("UPDATE `%s${type}_homes` SET `${type}_expiration_date` = '%s' WHERE `home_id` = %d",
				$this->table_prefix,
				$ed,
				mysql_real_escape_string($home_id,$this->link));
			if($assign_id != NULL)
			{
				$id_type = $type == "user" ? "user_id" : "group_id";
				$query .= " AND `$id_type` = $assign_id";
			}
			++$this->queries_;
			if ( mysql_query($query,$this->link) === FALSE )
				return FALSE;
			return TRUE;
		}
		return FALSE;
	}
	
	public function check_expire_date($user_id, $home_id, $types = array('user', 'user_group', 'server')) {
		foreach($types as $type)
		{
			switch ($type) {
				case 'user':
					$query = 'SELECT `%2$s_expiration_date` as `expiration_date` FROM `%1$s%2$s_homes` WHERE `home_id` = %3$d AND `user_id`=%4$d;';
					break;
				case 'user_group':
					$query = 'SELECT `%2$s_expiration_date` as `expiration_date`, `group_id` FROM `%1$s%2$s_homes` WHERE `home_id` = %3$d AND `group_id` IN (
									SELECT group_id
									FROM %1$suser_groups
									WHERE user_id=%4$d
								);';
					break;
				case 'server':
					$query = 'SELECT `%2$s_expiration_date` as `expiration_date` FROM `%1$s%2$s_homes` WHERE `home_id` = %3$d;';
					break;
			}
			
			$query = sprintf( $query,
							  $this->table_prefix,
							  $type,
							  mysql_real_escape_string($home_id,$this->link),
							  mysql_real_escape_string($user_id,$this->link));
			++$this->queries_;
			$result = mysql_query($query,$this->link);
			if($result === FALSE)
				continue;
			$result = mysql_fetch_assoc( $result );
			if(empty($result) OR $result['expiration_date'] == 'X')
				continue;
			if($result['expiration_date'] < time())
			{
				switch ($type) {
					case 'user':
						$user = $this->getUserById($user_id);
						if ( $this->unassignHomeFrom('user',$user_id,$home_id) === TRUE )
							$this->logger(get_lang_f("unassigned_home_from_user", $home_id, $user['users_login']));
						return TRUE;
						break;
					case 'user_group':
						$group = $this->getGroupById($result['group_id']);
						if ( $this->unassignHomeFrom('group',$result['group_id'],$home_id) === TRUE )
							$this->logger(get_lang_f("unassigned_home_from_group", $home_id, $group['group_name']));
						return TRUE;
						break;
					case 'server':
						require_once('includes/lib_remote.php');
						$home_info = $this->getGameHomeWithoutMods($home_id);
						$remote = new OGPRemoteLibrary($home_info['agent_ip'], $home_info['agent_port'], $home_info['encryption_key'], $home_info['timeout']);
						$agent_online = $remote->status_chk() === 1;
						if( $agent_online )
						{
							if( $this->IsFtpEnabled($home_id) )
							{
								$ftp_login = isset($home_info['ftp_login']) ? $home_info['ftp_login'] : $home_id;
								$remote->ftp_mgr("userdel", $ftp_login);
							}
							$assigned = $this->getHomeIpPorts($home_id);
							if( !empty($assigned) )
							{
								foreach($assigned as $address)
								{
									if($remote->rfile_exists( "startups/".$address['ip']."-".$address['port'] ) === 1)
									{
										require_once("modules/gamemanager/home_handling_functions.php");
										require_once("modules/config_games/server_config_parser.php");
										exec_operation('stop', $home_id, FALSE, $address['ip'], $address['port']);
									}
								}
							}
							
							if( $remote->remove_home($home_info['home_path']) == 1 )
							{
								$this->logger(get_lang_f('sucessfully_deleted', $home_info['home_path']));
							}
						}
						if ( $this->deleteGameHome($home_id) )
							$this->logger(get_lang_f('successfully_deleted_game_server_with_id', $home_id));
						return TRUE;
						break;
				}
			}
		}
		return FALSE;
	}
	
	public function getHomeAffinity ($home_id)
	{
		if (is_numeric($home_id) === false)
		{
			return false;
		}
		
		$query = 'SELECT `cpu_affinity` FROM `%sgame_mods` WHERE `home_id` = %2$d;';
		$query = sprintf($query, $this->table_prefix, (int)$home_id);
		
		$result = mysql_query($query, $this->link);
		++$this->queries_;
		
		if($result === false)
		{
			return false;
		}
		
		$tmp = mysql_fetch_row($result);
		return $tmp[0];
	}
}

?>