| | |
| | | { |
| | | if (!$this->configured) |
| | | return false; |
| | | |
| | | |
| | | $options = array( |
| | | 'use_transactions' => false, |
| | | 'log_line_break' => "\n", |
| | |
| | | 'force_defaults' => false, |
| | | 'portability' => true |
| | | ); |
| | | |
| | | |
| | | $dsnw = $this->config['db_dsnw']; |
| | | $schema = MDB2_Schema::factory($dsnw, $options); |
| | | $schema->db->supported['transactions'] = false; |
| | | |
| | | |
| | | if (PEAR::isError($schema)) { |
| | | $this->raise_error(array('code' => $schema->getCode(), 'message' => $schema->getMessage() . ' ' . $schema->getUserInfo())); |
| | | return false; |
| | |
| | | else { |
| | | $definition = $schema->getDefinitionFromDatabase(); |
| | | $definition['charset'] = 'utf8'; |
| | | |
| | | |
| | | if (PEAR::isError($definition)) { |
| | | $this->raise_error(array('code' => $definition->getCode(), 'message' => $definition->getMessage() . ' ' . $definition->getUserInfo())); |
| | | return false; |
| | | } |
| | | |
| | | |
| | | // load reference schema |
| | | $dsn_arr = MDB2::parseDSN($this->config['db_dsnw']); |
| | | |
| | | $ref_schema = INSTALL_PATH . 'SQL/' . $dsn_arr['phptype'] . '.schema.xml'; |
| | | |
| | | |
| | | if (is_readable($ref_schema)) { |
| | | $reference = $schema->parseDatabaseDefinition($ref_schema, false, array(), $schema->options['fail_on_invalid_names']); |
| | | |
| | | |
| | | if (PEAR::isError($reference)) { |
| | | $this->raise_error(array('code' => $reference->getCode(), 'message' => $reference->getMessage() . ' ' . $reference->getUserInfo())); |
| | | } |
| | | else { |
| | | $diff = $schema->compareDefinitions($reference, $definition); |
| | | |
| | | |
| | | if (empty($diff)) { |
| | | return true; |
| | | } |
| | | else if ($update) { |
| | | // update database schema with the diff from the above check |
| | | $success = $schema->alterDatabase($reference, $definition, $diff); |
| | | |
| | | |
| | | if (PEAR::isError($success)) { |
| | | $this->raise_error(array('code' => $success->getCode(), 'message' => $success->getMessage() . ' ' . $success->getUserInfo())); |
| | | } |
| | |
| | | $this->raise_error(array('message' => "Could not find reference schema file ($ref_schema)")); |
| | | return false; |
| | | } |
| | | |
| | | |
| | | return false; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Getter for the last error message |
| | | * |
| | |
| | | { |
| | | return $this->last_error['message']; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Return a list with all imap hosts configured |
| | | * |
| | |
| | | { |
| | | $default_hosts = (array)$this->getprop('default_host'); |
| | | $out = array(); |
| | | |
| | | |
| | | foreach ($default_hosts as $key => $name) { |
| | | if (!empty($name)) |
| | | $out[] = rcube_parse_host(is_numeric($key) ? $name : $key); |
| | | } |
| | | |
| | | |
| | | return $out; |
| | | } |
| | | |
| | |
| | | '0.5-beta', '0.5', '0.5.1', |
| | | '0.6-beta', '0.6', |
| | | '0.7-beta', '0.7', '0.7.1', '0.7.2', |
| | | '0.8-beta', |
| | | '0.8-beta', '0.8-rc', |
| | | )); |
| | | return $select; |
| | | } |
| | |
| | | } |
| | | return $skins; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Display OK status |
| | | * |
| | |
| | | echo Q($name) . ': <span class="success">OK</span>'; |
| | | $this->_showhint($message); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Display an error status and increase failure count |
| | | * |
| | |
| | | function fail($name, $message = '', $url = '') |
| | | { |
| | | $this->failures++; |
| | | |
| | | |
| | | echo Q($name) . ': <span class="fail">NOT OK</span>'; |
| | | $this->_showhint($message, $url); |
| | | } |
| | |
| | | echo Q($name) . ': <span class="na">NOT OK</span>'; |
| | | $this->_showhint($message, $url); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Display warning status |
| | | * |
| | |
| | | echo Q($name) . ': <span class="na">NOT AVAILABLE</span>'; |
| | | $this->_showhint($message, $url); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | function _showhint($message, $url = '') |
| | | { |
| | | $hint = Q($message); |
| | | |
| | | |
| | | if ($url) |
| | | $hint .= ($hint ? '; ' : '') . 'See <a href="' . Q($url) . '" target="_blank">' . Q($url) . '</a>'; |
| | | |
| | | |
| | | if ($hint) |
| | | echo '<span class="indent">(' . $hint . ')</span>'; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | static function _clean_array($arr) |
| | | { |
| | | $out = array(); |
| | | |
| | | |
| | | foreach (array_unique($arr) as $k => $val) { |
| | | if (!empty($val)) { |
| | | if (is_numeric($k)) |
| | |
| | | $out[$k] = $val; |
| | | } |
| | | } |
| | | |
| | | |
| | | return $out; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | static function _dump_var($var, $name=null) { |
| | | // special values |
| | | switch ($name) { |
| | |
| | | break; |
| | | } |
| | | } |
| | | |
| | | |
| | | if ($isnum) |
| | | return 'array(' . join(', ', array_map(array('rcube_install', '_dump_var'), $var)) . ')'; |
| | | } |
| | | } |
| | | |
| | | |
| | | return var_export($var, true); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Initialize the database with the according schema |
| | | * |
| | |
| | | function init_db($DB) |
| | | { |
| | | $engine = isset($this->db_map[$DB->db_provider]) ? $this->db_map[$DB->db_provider] : $DB->db_provider; |
| | | |
| | | |
| | | // read schema file from /SQL/* |
| | | $fname = INSTALL_PATH . "SQL/$engine.initial.sql"; |
| | | if ($sql = @file_get_contents($fname)) { |
| | |
| | | $this->fail('DB Schema', "Cannot read the schema file: $fname"); |
| | | return false; |
| | | } |
| | | |
| | | |
| | | if ($err = $this->get_error()) { |
| | | $this->fail('DB Schema', "Error creating database schema: $err"); |
| | | return false; |
| | |
| | | |
| | | return true; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Update database with SQL statements from SQL/*.update.sql |
| | | * |
| | |
| | | { |
| | | $version = strtolower($version); |
| | | $engine = isset($this->db_map[$DB->db_provider]) ? $this->db_map[$DB->db_provider] : $DB->db_provider; |
| | | |
| | | |
| | | // read schema file from /SQL/* |
| | | $fname = INSTALL_PATH . "SQL/$engine.update.sql"; |
| | | if ($lines = @file($fname, FILE_SKIP_EMPTY_LINES)) { |
| | |
| | | if ($from && !$is_comment) |
| | | $sql .= $line. "\n"; |
| | | } |
| | | |
| | | |
| | | if ($sql) |
| | | $this->exec_sql($sql, $DB); |
| | | } |
| | |
| | | $this->fail('DB Schema', "Cannot read the update file: $fname"); |
| | | return false; |
| | | } |
| | | |
| | | |
| | | if ($err = $this->get_error()) { |
| | | $this->fail('DB Schema', "Error updating database: $err"); |
| | | return false; |
| | |
| | | |
| | | return true; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Execute the given SQL queries on the database connection |
| | | * |
| | |
| | | foreach (explode("\n", $sql) as $line) { |
| | | if (preg_match('/^--/', $line) || trim($line) == '') |
| | | continue; |
| | | |
| | | |
| | | $buff .= $line . "\n"; |
| | | if (preg_match('/(;|^GO)$/', trim($line))) { |
| | | $DB->query($buff); |
| | |
| | | break; |
| | | } |
| | | } |
| | | |
| | | |
| | | return !$DB->is_error(); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Handler for Roundcube errors |
| | | */ |
| | |
| | | { |
| | | $this->last_error = $p; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Generarte a ramdom string to be used as encryption key |
| | | * |
| | |
| | | { |
| | | $alpha = 'ABCDEFGHIJKLMNOPQERSTUVXYZabcdefghijklmnopqrtsuvwxyz0123456789+*%&?!$-_='; |
| | | $out = ''; |
| | | |
| | | |
| | | for ($i=0; $i < $length; $i++) |
| | | $out .= $alpha{rand(0, strlen($alpha)-1)}; |
| | | |
| | | |
| | | return $out; |
| | | } |
| | | |
| | | |
| | | } |
| | | |