1
0
Fork 0
mirror of https://github.com/Yetangitu/ampache synced 2025-10-04 18:29:40 +02:00
ampache/lib/install.lib.php
Paul Arthur 649298b241 Clean up remaining direct calls to mysql functions
This makes it theoretically possible to replace Dba with a different
implementation somewhat painlessly.
2012-11-08 14:31:53 -05:00

324 lines
10 KiB
PHP

<?php
/* vim:set tabstop=8 softtabstop=8 shiftwidth=8 noexpandtab: */
/**
* Install Library
*
*
* LICENSE: GNU General Public License, version 2 (GPLv2)
* Copyright (c) 2001 - 2011 Ampache.org All Rights Reserved
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License v2
* as published by the Free Software Foundation.
*
* 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.
*
* @package Ampache
* @copyright 2001 - 2011 Ampache.org
* @license http://opensource.org/licenses/gpl-2.0 GPLv2
* @link http://www.ampache.org/
*/
/**
* split_sql
* splits up a standard SQL dump file into distinct sql queries
*/
function split_sql($sql) {
$sql = trim($sql);
$sql = preg_replace("/\n#[^\n]*\n/", "\n", $sql);
$buffer = array();
$ret = array();
$in_string = false;
for($i=0; $i<strlen($sql)-1; $i++) {
if($sql[$i] == ";" && !$in_string) {
$ret[] = substr($sql, 0, $i);
$sql = substr($sql, $i + 1);
$i = 0;
}
if($in_string && ($sql[$i] == $in_string) && $buffer[1] != "\\") {
$in_string = false;
}
elseif(!$in_string && ($sql[$i] == '"' || $sql[$i] == "'") && (!isset($buffer[0]) || $buffer[0] != "\\")) {
$in_string = $sql[$i];
}
if(isset($buffer[1])) {
$buffer[0] = $buffer[1];
}
$buffer[1] = $sql[$i];
}
if(!empty($sql)) {
$ret[] = $sql;
}
return($ret);
} // split_sql
/**
* install_check_status
* this function checks to see if we actually
* still need to install ampache. This function is
* very important, we don't want to reinstall over top of an existing install
*/
function install_check_status($configfile) {
/*
Check and see if the config file exists
if it does they can't use the web interface
to install ampache.
*/
if (!file_exists($configfile)) {
return true;
} else {
Error::add('general', T_('Config file already exists, install is probably completed'));
}
/*
Check and see if they've got _any_ account
if they don't then they're cool
*/
$results = parse_ini_file($configfile);
Config::set_by_array($results, true);
if (!Dba::check_database()) {
Error::add('general', T_('Unable to connect to database, check your ampache config'));
return false;
}
$sql = 'SELECT * FROM `user`';
$db_results = Dba::read($sql);
if (!$db_results) {
Error::add('general', T_('Unable to query database, check your ampache config'));
return false;
}
if (!Dba::num_rows($db_results)) {
return true;
}
else {
Error::add('general', T_('Existing Database detected, unable to continue installation'));
return false;
}
/* Defaut to no */
return false;
} // install_check_status
/**
* install_insert_db
* this function inserts the database using the username/pass/host provided
* and reading the .sql file
*/
function install_insert_db($username,$password,$hostname,$database,$dbuser=false,$dbpass=false) {
// Make sure that the database name is valid
$is_valid = preg_match("/([^\d\w\_\-])/",$database,$matches);
if (count($matches)) {
Error::add('general', T_('Error: Database name invalid must not be a reserved word, and must be Alphanumeric'));
return false;
}
$data['database_username'] = $username;
$data['database_password'] = $password;
$data['database_hostname'] = $hostname;
$data['database_name'] = $database;
Config::set_by_array($data, true);
unset($data);
if (!Dba::check_database()) {
Error::add('general', sprintf(T_('Error: Unable to make Database Connection %s'), Dba::error()));
return false;
}
$db_exists = Dba::check_database_exists();
if ($db_exists && $_POST['existing_db']) {
// Rien a faire, we've got the db just blow through
}
elseif ($db_exists && !$_POST['overwrite_db']) {
Error::add('general', T_('Error: Database Already exists and Overwrite not checked'));
return false;
}
elseif (!$db_exists) {
$sql = "CREATE DATABASE `" . Dba::escape($database) . "`";
if (!Dba::write($sql)) {
Error::add('general',sprintf(T_('Error: Unable to Create Database %s'), Dba::error()));
return false;
}
} // if db can't be selected
else {
$sql = "DROP DATABASE `" . Dba::escape($database) . "`";
Dba::write($sql);
$sql = "CREATE DATABASE `" . Dba::escape($database) . "`";
if (!Dba::write($sql)) {
Error::add('general', sprintf(T_('Error: Unable to Create Database %s'), Dba::error()));
return false;
}
} // end if selected and overwrite
Dba::disconnect();
/* Check and see if we should create a user here */
if ($_POST['db_user'] == 'create_db_user' || (strlen($dbuser) AND strlen($dbpass))) {
$db_user = $_POST['db_username'] ? scrub_in($_POST['db_username']) : $dbuser;
$db_pass = $_POST['db_password'] ? $_POST['db_password'] : $dbpass;
if (!strlen($db_user) || !strlen($db_pass)) {
Error::add('general', T_('Error: Ampache SQL Username or Password missing'));
return false;
}
$sql = "GRANT ALL PRIVILEGES ON " . Dba::escape($database) . ".* TO " .
"'" . Dba::escape($db_user) . "'@'" . Dba::escape($hostname) . "' IDENTIFIED BY '" . Dba::escape($db_pass) . "' WITH GRANT OPTION";
if (!Dba::write($sql)) {
Error::add('general', sprintf(T_('Error: Unable to Insert %1$s with permissions to %2$s on %3$s %4$s'), $db_user, $database, $hostname, Dba::error()));
return false;
}
} // end if we are creating a user
$sql_file = Config::get('prefix') . '/sql/ampache.sql';
/* Attempt to insert database */
$query = fread(fopen($sql_file, "r"), filesize($sql_file));
$pieces = split_sql($query);
for ($i=0; $i<count($pieces); $i++) {
$pieces[$i] = trim($pieces[$i]);
if(!empty($pieces[$i]) && $pieces[$i] != "#") {
//FIXME: This is for a DB prefix when we get around to it
// $pieces[$i] = str_replace( "#__", $DBPrefix, $pieces[$i]);
if (!$result = Dba::write($pieces[$i])) {
$errors[] = array ( Dba::error(), $pieces[$i] );
} // end if
} // end if
} // end for
$sql = "ALTER DATABASE `" . Dba::escape($database) . "` DEFAULT CHARACTER SET utf8 COLLATE utf8_unicode_ci";
$db_results = Dba::write($sql);
// If they've picked something other then English update default preferences
if (Config::get('lang') != 'en_US') {
$sql = "UPDATE `preference` SET `value`='" . Config::get('lang') . "' WHERE `id`=31";
$db_results = Dba::write($sql);
$sql = "UPDATE `user_preference` SET `value`='" .Config::get('lang') ."' WHERE `preference`=31";
$db_results = Dba::write($sql);
}
return true;
} // install_insert_db
/**
* install_create_config
* attempts to write out the config file or offer it as a download
*/
function install_create_config($web_path,$username,$password,$hostname,$database,$download) {
$config_file = Config::get('prefix') . '/config/ampache.cfg.php';
$data['database_username'] = $username;
$data['database_password'] = $password;
$data['database_hostname'] = $hostname;
$data['database_name'] = $database;
$data['web_path'] = $web_path;
Config::set_by_array($data, true);
/* Attempt to make DB connection */
$dbh = Dba::dbh();
/*
First Test The Variables they've given us to make
sure that they actually work!
*/
// Connect to the DB
if(!Dba::check_database()) {
Error::add('general', T_("Database Connection Failed Check Hostname, Username and Password"));
return false;
}
if (!Dba::check_database_exists()) {
Error::add('general', sprintf(T_('Database selection failed. Check existence of %s'), $database));
return false;
}
$final = generate_config($data);
// Make sure the directory is writable OR the empty config file is
if (!$download) {
if (!check_config_writable()) {
Error::add('general', T_("Config file is not writable"));
return false;
}
else {
// Given that $final is > 0, we can ignore lazy comparison problems
if (!file_put_contents($config_file,$final)) {
Error::add('general', T_("Error Writing config file"));
return false;
}
}
}
else {
$browser = new Horde_Browser();
$browser->downloadHeaders('ampache.cfg.php', 'text/plain', false, strlen($final));
echo $final;
exit();
}
return true;
} // install_create_config
/**
* install_create_account
* this creates your initial account and sets up the preferences for the -1 user and you
*/
function install_create_account($username,$password,$password2) {
if (!strlen($username) OR !strlen($password)) {
Error::add('general', T_('No Username/Password specified'));
return false;
}
if ($password !== $password2) {
Error::add('general', T_('Passwords do not match'));
return false;
}
if (!Dba::check_database()) {
Error::add('general', sprintf(T_('Database Connection Failed: %s'), Dba::error()));
return false;
}
if (!Dba::check_database_inserted()) {
Error::add('general', sprintf(T_('Database Select Failed: %s'), Dba::error()));
return false;
}
$username = Dba::escape($username);
$password = Dba::escape($password);
$insert_id = User::create($username,'Administrator','',$password,'100');
if (!$insert_id) {
Error::add('general', sprintf(T_('Insert of Base User Failed %s'), Dba::error()));
return false;
}
// Fix the system users preferences
User::fix_preferences('-1');
return true;
} // install_create_account
?>