<?php
//// mysql 4.0.17
//$DB_USER = "firestats";
//$DB_PASS = "firestats";
//$DB_HOST = "127.0.0.1:3310";
//$DB_NAME = "firestats_test";
//$MYSQL_BIN = "~omry/dev/tools/mysql/mysql-4.0.17/use.sh";
//$MYSQL_VER = "4.0";

// mysql 4.1.7
//$DB_USER = "firestats";
//$DB_PASS = "firestats";
//$DB_HOST = "127.0.0.1:3312";
//$DB_NAME = "firestats_test";
//$MYSQL_BIN = "~omry/dev/tools/mysql/mysql-4.1.7/use.sh";
//$MYSQL_VER = "5.0";


// Default mysql
$DB_USER = "firestats";
$DB_PASS = "firestats";
$DB_HOST = "localhost";
$DB_NAME = "firestats_test";
$MYSQL_BIN = "mysql";
$MYSQL_VER = "5.0";


define('FS_COMMIT_MAX_CHUNK_SIZE',1000);
define('FS_AUTOMATIC_COMMIT_INTERVAL_SECONDS',5);

global $OVERRIDE_CONFIG;
$OVERRIDE_CONFIG = true;
global $fs_config;
$fs_config['DB_NAME'] = $DB_NAME;
$fs_config['DB_PREFIX'] = '';
$fs_config['DB_USER'] = $DB_USER;
$fs_config['DB_PASS'] = $DB_PASS;
$fs_config['DB_HOST'] = $DB_HOST;
require_once('../php/constants.php');


require('import-hits-table.php');
require('export-hits-table.php');

$file = "hits-10k.csv.gz";
clear();
fs_import_data($file,FS_COMMIT_MANUAL, true);
backup_tables("manual");

clear();
fs_import_data($file,FS_COMMIT_AUTOMATIC, true);
backup_tables("automatic");

clear();
fs_test_dummy_auth();
fs_update_system_option('commit_strategy', FS_COMMIT_AUTOMATIC);
fs_import_data($file,FS_COMMIT_BY_OPTION, true);
backup_tables("by_option");

//clear();
//fs_import_data($file,FS_COMMIT_IMMEDIATE);
//backup_tables("immediate");

function clear()
{
	global $DB_USER;
	global $DB_PASS;
	global $DB_NAME;
	global $MYSQL_BIN;
	global $MYSQL_VER;
	$cmd = "gunzip -c firestats-1.5-empty-mysql-$MYSQL_VER.sql.gz | $MYSQL_BIN -u $DB_USER --password=$DB_PASS $DB_NAME";
	fs_exec($cmd);
}

function backup_tables($prefix)
{
	global $DB_USER;
	global $DB_PASS;
	global $DB_NAME;
	global $MYSQL_BIN;
	$tables = fs_get_tables_list();
	foreach($tables as $table)
	{
		$new = "$prefix"."_".$table;
		fs_exec("echo 'drop table if exists $new' | $MYSQL_BIN -u $DB_USER --password=$DB_PASS $DB_NAME");
		fs_exec("echo 'alter table $table rename $new' | $MYSQL_BIN -u $DB_USER --password=$DB_PASS  $DB_NAME");
	}
}


function dump($name)
{
	global $DB_USER;
	global $DB_PASS;
	global $DB_NAME;
	
	$descriptorspec = array(
   	0 => array("pipe", "r"),  // stdin is a pipe that the child will read from
   	1 => array("pipe", "w"),  // stdout is a pipe that the child will write to
   	2 => array("pipe", "w")   // stderr is a file to write to
	);
	
	$process = proc_open("mysqldump -u $DB_USER --password=$DB_PASS $DB_NAME > $name", $descriptorspec, $pipes);
	if (is_resource($process)) 
	{
		proc_close($process);
		$fp = fopen("$name","a");
		while(!feof($pipes[1]))
		{
			$str = fgets($pipes[1]);
			if ($str == false) break;
			fputs($fp, $str);	
		}
		fclose($fp);
	}
	else
	{
		echo "Error opening mysqldump";
	}
}

function fs_exec($cmd)
{
	$descriptorspec = array(
   	0 => array("pipe", "r"),  // stdin is a pipe that the child will read from
   	1 => array("pipe", "w"),  // stdout is a pipe that the child will write to
   	2 => array("pipe", "w")   // stderr is a file to write to
	);
	
	$process = proc_open($cmd, $descriptorspec, $pipes);
	if (is_resource($process)) 
	{
		proc_close($process);
		while(!feof($pipes[2]))
		{
			$str = fgets($pipes[2]);
			if ($str == false) break;
			echo $str;	
		}
	}
	else
	{
		echo "Error opening mysqldump";
	}
}

function fs_test_dummy_auth()
{
	$user = new stdClass();
	$user->dummy = true;
	$user->name = "Dummy admin";
	$user->security_level = SEC_ADMIN;
	$res = fs_start_user_session($user);
	if ($res) fs_store_session();
}

?>