mirror of
https://github.com/phpbb/phpbb.git
synced 2025-06-07 20:08:53 +00:00
573 lines
17 KiB
PHP
573 lines
17 KiB
PHP
<?php
|
|
/**
|
|
*
|
|
* This file is part of the phpBB Forum Software package.
|
|
*
|
|
* @copyright (c) phpBB Limited <https://www.phpbb.com>
|
|
* @license GNU General Public License, version 2 (GPL-2.0)
|
|
*
|
|
* For full copyright and license information, please see
|
|
* the docs/CREDITS.txt file.
|
|
*
|
|
*/
|
|
|
|
use phpbb\db\driver\driver_interface;
|
|
use phpbb\di\service_collection;
|
|
use phpbb\language\language;
|
|
use phpbb\log\log_interface;
|
|
use phpbb\request\request;
|
|
use phpbb\storage\helper;
|
|
use phpbb\storage\state_helper;
|
|
use phpbb\storage\update_type;
|
|
use phpbb\template\template;
|
|
use phpbb\user;
|
|
|
|
/**
|
|
* @ignore
|
|
*/
|
|
if (!defined('IN_PHPBB'))
|
|
{
|
|
exit;
|
|
}
|
|
|
|
class acp_storage
|
|
{
|
|
/** @var driver_interface $db */
|
|
protected $db;
|
|
|
|
/** @var language $log */
|
|
protected $lang;
|
|
|
|
/** @var log_interface $log */
|
|
protected $log;
|
|
|
|
/** @var request */
|
|
protected $request;
|
|
|
|
/** @var template */
|
|
protected $template;
|
|
|
|
/** @var user */
|
|
protected $user;
|
|
|
|
/** @var service_collection */
|
|
protected $provider_collection;
|
|
|
|
/** @var service_collection */
|
|
protected $storage_collection;
|
|
|
|
/** @var \phpbb\filesystem\filesystem */
|
|
protected $filesystem;
|
|
|
|
/** @var string */
|
|
public $page_title;
|
|
|
|
/** @var string */
|
|
public $phpbb_root_path;
|
|
|
|
/** @var string */
|
|
public $tpl_name;
|
|
|
|
/** @var string */
|
|
public $u_action;
|
|
|
|
/** @var state_helper */
|
|
private $state_helper;
|
|
|
|
/** @var helper */
|
|
private $storage_helper;
|
|
|
|
/**
|
|
* @param string $id
|
|
* @param string $mode
|
|
*/
|
|
public function main(string $id, string $mode): void
|
|
{
|
|
global $phpbb_container, $phpbb_dispatcher, $phpbb_root_path;
|
|
|
|
$this->db = $phpbb_container->get('dbal.conn');
|
|
$this->lang = $phpbb_container->get('language');
|
|
$this->log = $phpbb_container->get('log');
|
|
$this->request = $phpbb_container->get('request');
|
|
$this->template = $phpbb_container->get('template');
|
|
$this->user = $phpbb_container->get('user');
|
|
$this->provider_collection = $phpbb_container->get('storage.provider_collection');
|
|
$this->storage_collection = $phpbb_container->get('storage.storage_collection');
|
|
$this->filesystem = $phpbb_container->get('filesystem');
|
|
$this->phpbb_root_path = $phpbb_root_path;
|
|
$this->state_helper = $phpbb_container->get('storage.state_helper');
|
|
$this->storage_helper = $phpbb_container->get('storage.helper');
|
|
|
|
// Add necessary language files
|
|
$this->lang->add_lang(['acp/storage']);
|
|
|
|
/**
|
|
* Add language strings
|
|
*
|
|
* @event core.acp_storage_load
|
|
* @since 4.0.0-a1
|
|
*/
|
|
$phpbb_dispatcher->trigger_event('core.acp_storage_load');
|
|
|
|
switch ($mode)
|
|
{
|
|
case 'settings':
|
|
$this->settings($id, $mode);
|
|
break;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @param string $id
|
|
* @param string $mode
|
|
*/
|
|
private function settings(string $id, string $mode): void
|
|
{
|
|
$action = $this->request->variable('action', '');
|
|
if ($action && !$this->request->is_set_post('cancel'))
|
|
{
|
|
switch ($action)
|
|
{
|
|
case 'progress_bar':
|
|
$this->display_progress_bar();
|
|
break;
|
|
|
|
case 'update':
|
|
$this->update_action();
|
|
break;
|
|
|
|
default:
|
|
trigger_error('NO_ACTION', E_USER_ERROR);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
// If clicked to cancel (acp_storage_update_progress form)
|
|
if ($this->request->is_set_post('cancel'))
|
|
{
|
|
$this->state_helper->clear_state();
|
|
}
|
|
|
|
// There is an updating in progress, show the form to continue or cancel
|
|
if ($this->state_helper->is_action_in_progress())
|
|
{
|
|
$this->update_inprogress($id, $mode);
|
|
}
|
|
else
|
|
{
|
|
$this->settings_form($id, $mode);
|
|
}
|
|
}
|
|
}
|
|
|
|
private function update_action(): void
|
|
{
|
|
// Probably it has sense to disable the forum while this is in progress
|
|
|
|
if (!check_link_hash($this->request->variable('hash', ''), 'acp_storage'))
|
|
{
|
|
trigger_error($this->lang->lang('FORM_INVALID') . adm_back_link($this->u_action), E_USER_WARNING);
|
|
}
|
|
|
|
// If update_type is copy or move, copy files from the old to the new storage
|
|
if (in_array($this->state_helper->update_type(), [update_type::COPY, update_type::MOVE], true))
|
|
{
|
|
$i = 0;
|
|
foreach ($this->state_helper->storages() as $storage_name)
|
|
{
|
|
// Skip storages that have already copied files
|
|
if ($this->state_helper->storage_index() > $i++)
|
|
{
|
|
continue;
|
|
}
|
|
|
|
$sql = 'SELECT file_id, file_path
|
|
FROM ' . STORAGE_TABLE . "
|
|
WHERE storage = '" . $this->db->sql_escape($storage_name) . "'
|
|
AND file_id > " . $this->state_helper->file_index();
|
|
$result = $this->db->sql_query($sql);
|
|
|
|
while ($row = $this->db->sql_fetchrow($result))
|
|
{
|
|
if (!still_on_time())
|
|
{
|
|
$this->db->sql_freeresult($result);
|
|
meta_refresh(1, append_sid($this->u_action . '&action=update&hash=' . generate_link_hash('acp_storage')));
|
|
// Here could be included the current file compared with the number of total files too
|
|
trigger_error($this->lang->lang('STORAGE_UPDATE_REDIRECT', $this->lang->lang('STORAGE_' . strtoupper($storage_name) . '_TITLE'), $i + 1, count($this->state_helper->storages())));
|
|
}
|
|
|
|
// Copy file from old adapter to the new one
|
|
$this->storage_helper->copy_file_to_new_adapter($storage_name, $row['file_path']);
|
|
|
|
$this->state_helper->set_file_index($row['file_id']); // update last file index copied
|
|
}
|
|
|
|
$this->db->sql_freeresult($result);
|
|
|
|
// Copied all files of a storage, increase storage index and reset file index
|
|
$this->state_helper->set_storage_index($this->state_helper->storage_index()+1);
|
|
$this->state_helper->set_file_index(0);
|
|
}
|
|
|
|
// If update_type is move files, remove the old files
|
|
if ($this->state_helper->update_type() === update_type::MOVE)
|
|
{
|
|
$i = 0;
|
|
foreach ($this->state_helper->storages() as $storage_name)
|
|
{
|
|
// Skip storages that have already moved files
|
|
if ($this->state_helper->remove_storage_index() > $i++)
|
|
{
|
|
continue;
|
|
}
|
|
|
|
$sql = 'SELECT file_id, file_path
|
|
FROM ' . STORAGE_TABLE . "
|
|
WHERE storage = '" . $this->db->sql_escape($storage_name) . "'
|
|
AND file_id > " . $this->state_helper->file_index();
|
|
$result = $this->db->sql_query($sql);
|
|
|
|
while ($row = $this->db->sql_fetchrow($result))
|
|
{
|
|
if (!still_on_time())
|
|
{
|
|
$this->db->sql_freeresult($result);
|
|
meta_refresh(1, append_sid($this->u_action . '&action=update&hash=' . generate_link_hash('acp_storage')));
|
|
trigger_error($this->lang->lang('STORAGE_UPDATE_REMOVE_REDIRECT', $this->lang->lang('STORAGE_' . strtoupper($storage_name) . '_TITLE'), $i + 1, count($this->state_helper->storages())));
|
|
}
|
|
|
|
// remove file from old (current) adapter
|
|
$current_adapter = $this->storage_helper->get_current_adapter($storage_name);
|
|
$current_adapter->delete($row['file_path']);
|
|
|
|
$this->state_helper->set_file_index($row['file_id']);
|
|
}
|
|
|
|
$this->db->sql_freeresult($result);
|
|
|
|
// Remove all files of a storage, increase storage index and reset file index
|
|
$this->state_helper->set_remove_storage_index($this->state_helper->remove_storage_index() + 1);
|
|
$this->state_helper->set_file_index(0);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Here all files have been copied/moved, so save new configuration
|
|
foreach ($this->state_helper->storages() as $storage_name)
|
|
{
|
|
$this->storage_helper->update_storage_config($storage_name);
|
|
}
|
|
|
|
$storages = $this->state_helper->storages();
|
|
$this->state_helper->clear_state();
|
|
$this->log->add('admin', $this->user->data['user_id'], $this->user->ip, 'LOG_STORAGE_UPDATE', false, [implode(', ', $storages)]);
|
|
trigger_error($this->lang->lang('STORAGE_UPDATE_SUCCESSFUL') . adm_back_link($this->u_action) . $this->close_popup_js());
|
|
}
|
|
|
|
private function update_inprogress(string $id, string $mode): void
|
|
{
|
|
// Template from adm/style
|
|
$this->tpl_name = 'acp_storage_update_inprogress';
|
|
|
|
// Set page title
|
|
$this->page_title = 'STORAGE_TITLE';
|
|
|
|
$this->template->assign_vars(array(
|
|
'UA_PROGRESS_BAR' => addslashes(append_sid($this->u_action, "action=progress_bar")),
|
|
'U_CONTINUE_UPDATING' => $this->u_action . '&action=update&hash=' . generate_link_hash('acp_storage'),
|
|
'L_CONTINUE' => $this->lang->lang('CONTINUE_UPDATING'),
|
|
'L_CONTINUE_EXPLAIN' => $this->lang->lang('CONTINUE_UPDATING_EXPLAIN'),
|
|
));
|
|
}
|
|
|
|
private function settings_form(string $id, string $mode): void
|
|
{
|
|
$form_key = 'acp_storage';
|
|
add_form_key($form_key);
|
|
|
|
// Process form and create a "state" for the update,
|
|
// then show a confirm form
|
|
if ($this->request->is_set_post('submit'))
|
|
{
|
|
if (!check_form_key($form_key) || !check_link_hash($this->request->variable('hash', ''), 'acp_storage'))
|
|
{
|
|
trigger_error($this->lang->lang('FORM_INVALID') . adm_back_link($this->u_action), E_USER_WARNING);
|
|
}
|
|
|
|
$modified_storages = $this->get_modified_storages();
|
|
|
|
// validate submited paths if they are local
|
|
$messages = [];
|
|
foreach ($modified_storages as $storage_name)
|
|
{
|
|
$this->validate_data($storage_name, $messages);
|
|
}
|
|
if (!empty($messages))
|
|
{
|
|
trigger_error(implode('<br>', $messages) . adm_back_link($this->u_action), E_USER_WARNING);
|
|
}
|
|
|
|
// Start process and show form
|
|
if (!empty($modified_storages))
|
|
{
|
|
// Create state
|
|
$this->state_helper->init(update_type::from((int) $this->request->variable('update_type', update_type::CONFIG->value)), $modified_storages, $this->request);
|
|
|
|
// Show the confirmation form to start the process
|
|
$this->template->assign_vars(array(
|
|
'UA_PROGRESS_BAR' => addslashes(append_sid($this->u_action, "action=progress_bar")),
|
|
'S_CONTINUE_UPDATING' => true,
|
|
'U_CONTINUE_UPDATING' => $this->u_action . '&action=update&hash=' . generate_link_hash('acp_storage'),
|
|
'L_CONTINUE' => $this->lang->lang('START_UPDATING'),
|
|
'L_CONTINUE_EXPLAIN' => $this->lang->lang('START_UPDATING_EXPLAIN'),
|
|
));
|
|
|
|
// Template from adm/style
|
|
$this->tpl_name = 'acp_storage_update_inprogress';
|
|
|
|
// Set page title
|
|
$this->page_title = 'STORAGE_TITLE';
|
|
|
|
return;
|
|
}
|
|
|
|
// If there is no changes
|
|
trigger_error($this->lang->lang('STORAGE_NO_CHANGES') . adm_back_link($this->u_action), E_USER_WARNING);
|
|
}
|
|
|
|
// Template from adm/style
|
|
$this->tpl_name = 'acp_storage';
|
|
|
|
// Set page title
|
|
$this->page_title = 'STORAGE_TITLE';
|
|
|
|
$this->storage_stats(); // Show table with storage stats
|
|
|
|
// Validate local paths to check if everything is fine
|
|
$messages = [];
|
|
foreach ($this->storage_collection as $storage)
|
|
{
|
|
$this->validate_path($storage->get_name(), $messages);
|
|
}
|
|
|
|
$this->template->assign_vars([
|
|
'STORAGES' => $this->storage_collection,
|
|
'PROVIDERS' => $this->provider_collection,
|
|
|
|
'ERROR_MESSAGES' => $messages,
|
|
|
|
'U_ACTION' => $this->u_action . '&hash=' . generate_link_hash('acp_storage'),
|
|
|
|
'STORAGE_UPDATE_TYPE_CONFIG' => update_type::CONFIG->value,
|
|
'STORAGE_UPDATE_TYPE_COPY' => update_type::COPY->value,
|
|
'STORAGE_UPDATE_TYPE_MOVE' => update_type::MOVE->value,
|
|
]);
|
|
}
|
|
|
|
private function get_modified_storages(): array
|
|
{
|
|
$modified_storages = [];
|
|
|
|
foreach ($this->storage_collection as $storage)
|
|
{
|
|
$storage_name = $storage->get_name();
|
|
$options = $this->storage_helper->get_provider_options($this->storage_helper->get_current_provider($storage_name));
|
|
|
|
$modified = false;
|
|
|
|
// Check if provider have been modified
|
|
if ($this->request->variable([$storage_name, 'provider'], '') != $this->storage_helper->get_current_provider($storage_name))
|
|
{
|
|
$modified = true;
|
|
}
|
|
else
|
|
{
|
|
// Check if options have been modified
|
|
foreach (array_keys($options) as $definition)
|
|
{
|
|
if ($this->request->variable([$storage_name, $definition], '') != $this->storage_helper->get_current_definition($storage_name, $definition))
|
|
{
|
|
$modified = true;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
if ($modified)
|
|
{
|
|
$modified_storages[] = $storage_name;
|
|
}
|
|
}
|
|
|
|
return $modified_storages;
|
|
}
|
|
|
|
protected function storage_stats()
|
|
{
|
|
// Top table with stats of each storage
|
|
$storage_stats = [];
|
|
foreach ($this->storage_collection as $storage)
|
|
{
|
|
try
|
|
{
|
|
$free_space = get_formatted_filesize($storage->free_space());
|
|
}
|
|
catch (\phpbb\storage\exception\storage_exception $e)
|
|
{
|
|
$free_space = $this->lang->lang('STORAGE_UNKNOWN');
|
|
}
|
|
|
|
$storage_stats[] = [
|
|
'name' => $this->lang->lang('STORAGE_' . strtoupper($storage->get_name()) . '_TITLE'),
|
|
'files' => $storage->get_num_files(),
|
|
'size' => get_formatted_filesize($storage->get_size()),
|
|
'free_space' => $free_space,
|
|
];
|
|
}
|
|
|
|
$this->template->assign_vars([
|
|
'STORAGE_STATS' => $storage_stats,
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* Display progress bar
|
|
*/
|
|
protected function display_progress_bar() : void
|
|
{
|
|
adm_page_header($this->lang->lang('STORAGE_UPDATE_IN_PROGRESS'));
|
|
$this->template->set_filenames(array(
|
|
'body' => 'progress_bar.html')
|
|
);
|
|
$this->template->assign_vars(array(
|
|
'L_PROGRESS' => $this->lang->lang('STORAGE_UPDATE_IN_PROGRESS'),
|
|
'L_PROGRESS_EXPLAIN' => $this->lang->lang('STORAGE_UPDATE_IN_PROGRESS_EXPLAIN'))
|
|
);
|
|
adm_page_footer();
|
|
}
|
|
|
|
/**
|
|
* Get JS code for closing popup
|
|
*
|
|
* @return string Popup JS code
|
|
*/
|
|
function close_popup_js() : string
|
|
{
|
|
return "<script type=\"text/javascript\">\n" .
|
|
"// <![CDATA[\n" .
|
|
" close_waitscreen = 1;\n" .
|
|
"// ]]>\n" .
|
|
"</script>\n";
|
|
}
|
|
|
|
/**
|
|
* Validates data
|
|
*
|
|
* @param string $storage_name Storage name
|
|
* @param array $messages Reference to messages array
|
|
*/
|
|
protected function validate_data(string $storage_name, array &$messages)
|
|
{
|
|
$storage_title = $this->lang->lang('STORAGE_' . strtoupper($storage_name) . '_TITLE');
|
|
|
|
// Check if provider exists
|
|
try
|
|
{
|
|
$new_provider = $this->provider_collection->get_by_class($this->request->variable([$storage_name, 'provider'], ''));
|
|
}
|
|
catch (\Exception $e)
|
|
{
|
|
$messages[] = $this->lang->lang('STORAGE_PROVIDER_NOT_EXISTS', $storage_title);
|
|
return;
|
|
}
|
|
|
|
// Check if provider is available
|
|
if (!$new_provider->is_available())
|
|
{
|
|
$messages[] = $this->lang->lang('STORAGE_PROVIDER_NOT_AVAILABLE', $storage_title);
|
|
return;
|
|
}
|
|
|
|
// Check options
|
|
$new_options = $this->storage_helper->get_provider_options($this->request->variable([$storage_name, 'provider'], ''));
|
|
|
|
foreach ($new_options as $definition_key => $definition_value)
|
|
{
|
|
$provider = $this->provider_collection->get_by_class($this->request->variable([$storage_name, 'provider'], ''));
|
|
$definition_title = $this->lang->lang('STORAGE_ADAPTER_' . strtoupper($provider->get_name()) . '_OPTION_' . strtoupper($definition_key));
|
|
|
|
$value = $this->request->variable([$storage_name, $definition_key], '');
|
|
|
|
switch ($definition_value['type'])
|
|
{
|
|
case 'email':
|
|
if (!filter_var($value, FILTER_VALIDATE_EMAIL))
|
|
{
|
|
$messages[] = $this->lang->lang('STORAGE_FORM_TYPE_EMAIL_INCORRECT_FORMAT', $definition_title, $storage_title);
|
|
}
|
|
// no break
|
|
|
|
case 'text':
|
|
case 'password':
|
|
$maxlength = isset($definition_value['maxlength']) ? $definition_value['maxlength'] : 255;
|
|
if (strlen($value) > $maxlength)
|
|
{
|
|
$messages[] = $this->lang->lang('STORAGE_FORM_TYPE_TEXT_TOO_LONG', $definition_title, $storage_title);
|
|
}
|
|
|
|
if ($provider->get_name() == 'local' && $definition_key == 'path')
|
|
{
|
|
$path = $value;
|
|
|
|
if (empty($path))
|
|
{
|
|
$messages[] = $this->lang->lang('STORAGE_PATH_NOT_SET', $this->lang->lang('STORAGE_' . strtoupper($storage_name) . '_TITLE'));
|
|
}
|
|
else if (!$this->filesystem->exists($this->phpbb_root_path . $path) || !$this->filesystem->is_writable($this->phpbb_root_path . $path))
|
|
{
|
|
$messages[] = $this->lang->lang('STORAGE_PATH_NOT_EXISTS', $this->lang->lang('STORAGE_' . strtoupper($storage_name) . '_TITLE'));
|
|
}
|
|
}
|
|
break;
|
|
|
|
case 'radio':
|
|
case 'select':
|
|
if (!in_array($value, array_values($definition_value['options'])))
|
|
{
|
|
$messages[] = $this->lang->lang('STORAGE_FORM_TYPE_SELECT_NOT_AVAILABLE', $definition_title, $storage_title);
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Validates path when the filesystem is local
|
|
*
|
|
* @param string $storage_name Storage name
|
|
* @param array $messages Error messages array
|
|
* @return void
|
|
*/
|
|
protected function validate_path(string $storage_name, array &$messages) : void
|
|
{
|
|
$current_provider = $this->storage_helper->get_current_provider($storage_name);
|
|
$options = $this->storage_helper->get_provider_options($current_provider);
|
|
|
|
if ($this->provider_collection->get_by_class($current_provider)->get_name() == 'local' && isset($options['path']))
|
|
{
|
|
$path = $this->storage_helper->get_current_definition($storage_name, 'path');
|
|
|
|
if (empty($path))
|
|
{
|
|
$messages[] = $this->lang->lang('STORAGE_PATH_NOT_SET', $this->lang->lang('STORAGE_' . strtoupper($storage_name) . '_TITLE'));
|
|
}
|
|
else if (!$this->filesystem->exists($this->phpbb_root_path . $path) || !$this->filesystem->is_writable($this->phpbb_root_path . $path))
|
|
{
|
|
$messages[] = $this->lang->lang('STORAGE_PATH_NOT_EXISTS', $this->lang->lang('STORAGE_' . strtoupper($storage_name) . '_TITLE'));
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
}
|