phpBB

<?php

/**

*

* @package install

* @version $Id$

* @copyright (c) 2006 phpBB Group

* @license http://opensource.org/licenses/gpl-license.php GNU Public License

*

*/

/**

*/

if (!defined('IN_INSTALL'))

{

	// Someone has tried to access the file direct. This is not a good idea, so exit

	exit;

}

if (!empty($setmodules))

{

	$module[] = array(

		'module_type'		=> 'install',

		'module_title'		=> 'CONVERT',

		'module_filename'	=> substr(basename(__FILE__), 0, -strlen(PHP_EXT)-1),

		'module_order'		=> 20,

		'module_subs'		=> '',

		'module_stages'		=> array('INTRO', 'SETTINGS', 'IN_PROGRESS', 'FINAL'),

		'module_reqs'		=> ''

	);

}

/**

* Class holding all convertor-specific details.

* @package install

*/

class convert

{

	var $options = array();

	var $convertor_tag = '';

	var $src_dbms = '';

	var $src_dbhost = '';

	var $src_dbport = '';

	var $src_dbuser = '';

	var $src_dbpasswd = '';

	var $src_dbname = '';

	var $src_table_prefix = '';

	var $convertor_data = array();

	var $tables = array();

	var $config_schema = array();

	var $convertor = array();

	var $src_truncate_statement = 'DELETE FROM ';

	var $truncate_statement = 'DELETE FROM ';

	var $fulltext_search;

	// Batch size, can be adjusted by the conversion file

	// For big boards a value of 6000 seems to be optimal

	var $batch_size = 2000;

	// Number of rows to be inserted at once (extended insert) if supported

	// For installations having enough memory a value of 60 may be good.

	var $num_wait_rows = 20;

	// Mysqls internal recoding engine messing up with our (better) functions? We at least support more encodings than mysql so should use it in favor.

	var $mysql_convert = false;

	var $p_master;

	function __construct(&$p_master)

	{

		$this->p_master = &$p_master;

	}

}

/**

* Convert class for conversions

* @package install

*/

class install_convert extends module

{

	/**

	* Variables used while converting, they are accessible from the global variable $convert

	*/

	function install_convert(&$p_master)

	{

		$this->p_master = &$p_master;

	}

	function main($mode, $sub)

	{

		global $lang, $template, $config, $language, $table_prefix;

		global $convert;

		$this->tpl_name = 'install_convert';

		$this->mode = $mode;

		$convert = new convert($this->p_master);

		switch ($sub)

		{

			case 'intro':

				// Try opening config file

				// @todo If phpBB is not installed, we need to do a cut-down installation here

				// For now, we redirect to the installation script instead

				if (@file_exists(PHPBB_ROOT_PATH . 'config.' . PHP_EXT))

				{

					include(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);

				}

				if (!defined('PHPBB_INSTALLED'))

				{

					$template->assign_vars(array(

						'S_NOT_INSTALLED'		=> true,

						'TITLE'					=> $lang['BOARD_NOT_INSTALLED'],

						'BODY'					=> sprintf($lang['BOARD_NOT_INSTALLED_EXPLAIN'], append_sid('install/index', 'mode=install&language=' . $language)),

					));

					return;

				}

				require(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);

				require(PHPBB_ROOT_PATH . 'includes/constants.' . PHP_EXT);

				require(PHPBB_ROOT_PATH . 'includes/db/' . $dbms . '.' . PHP_EXT);

				require(PHPBB_ROOT_PATH . 'includes/functions_convert.' . PHP_EXT);

				$db = new $sql_db();

				$db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, true);

				unset($dbpasswd);

				// We need to fill the config to let internal functions correctly work

				$sql = 'SELECT *

					FROM ' . CONFIG_TABLE;

				$result = $db->sql_query($sql);

				$config = array();

				while ($row = $db->sql_fetchrow($result))

				{

					$config[$row['config_name']] = $row['config_value'];

				}

				$db->sql_freeresult($result);

				// Detect if there is already a conversion in progress at this point and offer to resume

				// It's quite possible that the user will get disconnected during a large conversion so they need to be able to resume it

				$new_conversion = request_var('new_conv', 0);

				if ($new_conversion)

				{

					$config['convert_progress'] = '';

					$config['convert_db_server'] = '';

					$config['convert_db_user'] = '';

					$db->sql_query('DELETE FROM ' . CONFIG_TABLE . "

						WHERE config_name = 'convert_progress'

							OR config_name = 'convert_db_server'

							OR config_name = 'convert_db_user'"

					);

				}

				// Let's see if there is a conversion in the works...

				$options = array();

				if (!empty($config['convert_progress']) && !empty($config['convert_db_server']) && !empty($config['convert_db_user']) && !empty($config['convert_options']))

				{

					$options = unserialize($config['convert_progress']);

					$options = array_merge($options, unserialize($config['convert_db_server']), unserialize($config['convert_db_user']), unserialize($config['convert_options']));

				}

				// This information should have already been checked once, but do it again for safety

				if (!empty($options) && !empty($options['tag']) &&

					isset($options['dbms']) &&

					isset($options['dbhost']) &&

					isset($options['dbport']) &&

					isset($options['dbuser']) &&

					isset($options['dbpasswd']) &&

					isset($options['dbname']) &&

					isset($options['table_prefix']))

				{

					$this->page_title = $lang['CONTINUE_CONVERT'];

					$template->assign_vars(array(

						'TITLE'			=> $lang['CONTINUE_CONVERT'],

						'BODY'			=> $lang['CONTINUE_CONVERT_BODY'],

						'L_NEW'			=> $lang['CONVERT_NEW_CONVERSION'],

						'L_CONTINUE'	=> $lang['CONTINUE_OLD_CONVERSION'],

						'S_CONTINUE'	=> true,

						'U_NEW_ACTION'		=> $this->p_master->module_url . "?mode={$this->mode}&sub=intro&new_conv=1&language=$language",

						'U_CONTINUE_ACTION'	=> $this->p_master->module_url . "?mode={$this->mode}&sub=in_progress&tag={$options['tag']}{$options['step']}&language=$language",

					));

					return;

				}

				$this->list_convertors($sub);

			break;

			case 'settings':

				$this->get_convert_settings($sub);

			break;

			case 'in_progress':

				$this->convert_data($sub);

			break;

			case 'final':

				$this->page_title = $lang['CONVERT_COMPLETE'];

				$template->assign_vars(array(

					'TITLE'		=> $lang['CONVERT_COMPLETE'],

					'BODY'		=> $lang['CONVERT_COMPLETE_EXPLAIN'],

				));

				// If we reached this step (conversion completed) we want to purge the cache and log the user out.

				// This is for making sure the session get not screwed due to the 3.0.x users table being completely new.

				phpbb::$acm->purge();

				require(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);

				require(PHPBB_ROOT_PATH . 'includes/constants.' . PHP_EXT);

				require(PHPBB_ROOT_PATH . 'includes/db/' . $dbms . '.' . PHP_EXT);

				require(PHPBB_ROOT_PATH . 'includes/functions_convert.' . PHP_EXT);

				$db = new $sql_db();

				$db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, true);

				unset($dbpasswd);

				$sql = 'SELECT config_value

					FROM ' . CONFIG_TABLE . '

					WHERE config_name = \'search_type\'';

				$result = $db->sql_query($sql);

				if ($db->sql_fetchfield('config_value') != 'fulltext_mysql')

				{

					$template->assign_vars(array(

						'S_ERROR_BOX'	=> true,

						'ERROR_TITLE'	=> $lang['SEARCH_INDEX_UNCONVERTED'],

						'ERROR_MSG'		=> $lang['SEARCH_INDEX_UNCONVERTED_EXPLAIN'],

					));

				}

				if ($db->truncate)

				{

					$db->sql_query('TRUNCATE TABLE ' . SESSIONS_KEYS_TABLE);

					$db->sql_query('TRUNCATE TABLE ' . SESSIONS_TABLE);

				}

				else

				{

					$db->sql_query('DELETE FROM ' . SESSIONS_KEYS_TABLE);

					$db->sql_query('DELETE FROM ' . SESSIONS_TABLE);

				}

			break;

		}

	}

	/**

	* Generate a list of all available conversion modules

	*/

	function list_convertors($sub)

	{

		global $lang, $language, $template;

		$this->page_title = $lang['SUB_INTRO'];

		$template->assign_vars(array(

			'TITLE'		=> $lang['CONVERT_INTRO'],

			'BODY'		=> $lang['CONVERT_INTRO_BODY'],

			'L_AUTHOR'					=> $lang['AUTHOR'],

			'L_AVAILABLE_CONVERTORS'	=> $lang['AVAILABLE_CONVERTORS'],

			'L_CONVERT'					=> $lang['CONVERT'],

			'L_NO_CONVERTORS'			=> $lang['NO_CONVERTORS'],

			'L_OPTIONS'					=> $lang['CONVERT_OPTIONS'],

			'L_SOFTWARE'				=> $lang['SOFTWARE'],

			'L_VERSION'					=> $lang['VERSION'],

			'S_LIST'	=> true,

		));

		$convertors = $sort = array();

		$get_info = true;

		$handle = @opendir('./convertors/');

		if (!$handle)

		{

			$this->error('Unable to access the convertors directory', __LINE__, __FILE__);

		}

		while ($entry = readdir($handle))

		{

			if (preg_match('/^convert_([a-z0-9_]+).' . PHP_EXT . '$/i', $entry, $m))

			{

				include('./convertors/' . $entry);

				if (isset($convertor_data))

				{

					$sort[strtolower($convertor_data['forum_name'])] = sizeof($convertors);

					$convertors[] = array(

						'tag'			=>	$m[1],

						'forum_name'	=>	$convertor_data['forum_name'],

						'version'		=>	$convertor_data['version'],

						'dbms'			=>	$convertor_data['dbms'],

						'dbhost'		=>	$convertor_data['dbhost'],

						'dbport'		=>	$convertor_data['dbport'],

						'dbuser'		=>	$convertor_data['dbuser'],

						'dbpasswd'		=>	$convertor_data['dbpasswd'],

						'dbname'		=>	$convertor_data['dbname'],

						'table_prefix'	=>	$convertor_data['table_prefix'],

						'author'		=>	$convertor_data['author']

					);

				}

				unset($convertor_data);

			}

		}

		closedir($handle);

		@ksort($sort);

		foreach ($sort as $void => $index)

		{

			$template->assign_block_vars('convertors', array(

				'AUTHOR'	=> $convertors[$index]['author'],

				'SOFTWARE'	=> $convertors[$index]['forum_name'],

				'VERSION'	=> $convertors[$index]['version'],

				'U_CONVERT'	=> $this->p_master->module_url . "?mode={$this->mode}&language=$language&sub=settings&tag=" . $convertors[$index]['tag'],

			));

		}

	}

	/**

	*/

	function get_convert_settings($sub)

	{

		global $lang, $language, $template, $db, $config;

		require(PHPBB_ROOT_PATH . 'config.' . PHP_EXT);

		require(PHPBB_ROOT_PATH . 'includes/constants.' . PHP_EXT);

		require(PHPBB_ROOT_PATH . 'includes/db/' . $dbms . '.' . PHP_EXT);

		require(PHPBB_ROOT_PATH . 'includes/functions_convert.' . PHP_EXT);

		$db = new $sql_db();

		$db->sql_connect($dbhost, $dbuser, $dbpasswd, $dbname, $dbport, false, true);

		unset($dbpasswd);

		$this->page_title = $lang['STAGE_SETTINGS'];

		// We need to fill the config to let internal functions correctly work

		$sql = 'SELECT *

			FROM ' . CONFIG_TABLE;

		$result = $db->sql_query($sql);

		$config = array();

		while ($row = $db->sql_fetchrow($result))

		{

			$config[$row['config_name']] = $row['config_value'];

		}

		$db->sql_freeresult($result);

		$convertor_tag = request_var('tag', '');

		if (empty($convertor_tag))

		{

			$this->p_master->error($lang['NO_CONVERT_SPECIFIED'], __LINE__, __FILE__);

		}

		$get_info = true;

		// check security implications of direct inclusion

		$convertor_tag = basename($convertor_tag);

		if (!file_exists('./convertors/convert_' . $convertor_tag . '.' . PHP_EXT))

		{

			$this->p_master->error($lang['CONVERT_NOT_EXIST'], __LINE__, __FILE__);

		}

		include('./convertors/convert_' . $convertor_tag . '.' . PHP_EXT);

		// The test_file is a file that should be present in the location of the old board.

		if (!isset($test_file))

		{

			$this->p_master->error($lang['DEV_NO_TEST_FILE'], __LINE__, __FILE__);

		}

		$submit = phpbb_request::is_set_post('submit');

		$src_dbms			= request_var('src_dbms', $convertor_data['dbms']);

		$src_dbhost			= request_var('src_dbhost', $convertor_data['dbhost']);

		$src_dbport			= request_var('src_dbport', $convertor_data['dbport']);

		$src_dbuser			= request_var('src_dbuser', $convertor_data['dbuser']);

		$src_dbpasswd		= request_var('src_dbpasswd', $convertor_data['dbpasswd']);

		$src_dbname			= request_var('src_dbname', $convertor_data['dbname']);

		$src_table_prefix	= request_var('src_table_prefix', $convertor_data['table_prefix']);

		$forum_path			= request_var('forum_path', $convertor_data['forum_path']);

		$refresh			= request_var('refresh', 1);

		// Default URL of the old board

		// @todo Are we going to use this for attempting to convert URL references in posts, or should we remove it?

		//		-> We should convert old urls to the new relative urls format

		// $src_url = request_var('src_url', 'Not in use at the moment');

		// strip trailing slash from old forum path

		$forum_path = (strlen($forum_path) && $forum_path[strlen($forum_path) - 1] == '/') ? substr($forum_path, 0, -1) : $forum_path;

		$error = array();

		if ($submit)

		{

			if (!@file_exists('./../' . $forum_path . '/' . $test_file))

			{

				$error[] = sprintf($lang['COULD_NOT_FIND_PATH'], $forum_path);

			}

			$connect_test = false;

			$available_dbms = get_available_dbms(false, true, true);

			if (!isset($available_dbms[$src_dbms]) || !$available_dbms[$src_dbms]['AVAILABLE'])

			{

				$error['db'][] = $lang['INST_ERR_NO_DB'];

				$connect_test = false;

			}

			else

			{

				$connect_test = connect_check_db(true, $error, $available_dbms[$src_dbms], $src_table_prefix, $src_dbhost, $src_dbuser, htmlspecialchars_decode($src_dbpasswd), $src_dbname, $src_dbport, true, ($src_dbms == $dbms) ? false : true, false);

			}

			// The forum prefix of the old and the new forum can only be the same if two different databases are used.

			if ($src_table_prefix == $table_prefix && $src_dbms == $dbms && $src_dbhost == $dbhost && $src_dbport == $dbport && $src_dbname == $dbname)

			{

				$error[] = sprintf($lang['TABLE_PREFIX_SAME'], $src_table_prefix);

			}

			// Check table prefix

			if (!sizeof($error))

			{

				// initiate database connection to old db if old and new db differ