Invision Power Services, Inc.
* @copyright (c) Invision Power Services, Inc.
* @license https://www.invisioncommunity.com/legal/standards/
* @package Invision Community
* @since 06 May 2013
*/
namespace IPS\core\modules\admin\overview;
/* To prevent PHP errors (extending class does not exist) revealing path */
use DomainException;
use Exception;
use IPS\Application;
use IPS\Data\Cache;
use IPS\Data\Store;
use IPS\DateTime;
use IPS\Db;
use IPS\Dispatcher;
use IPS\Dispatcher\Controller;
use IPS\File;
use IPS\Helpers\Form;
use IPS\Helpers\Form\Interval;
use IPS\Helpers\Form\Number;
use IPS\Helpers\Form\Radio;
use IPS\Helpers\Form\Select;
use IPS\Helpers\Form\YesNo;
use IPS\Helpers\Table\Db as TableDb;
use IPS\Http\Url;
use IPS\Member;
use IPS\Output;
use IPS\Request;
use IPS\Session;
use IPS\Settings;
use IPS\Task;
use IPS\Theme;
use LogicException;
use OutOfRangeException;
use UnderflowException;
use function count;
use function defined;
use function get_class;
use function in_array;
use function intval;
use function is_array;
use function json_decode;
use function json_encode;
use function sprintf;
use function str_replace;
use const IPS\CIC;
use const IPS\ROOT_PATH;
use const IPS\Helpers\Table\SEARCH_CONTAINS_TEXT;
use const IPS\Helpers\Table\SEARCH_DATE_RANGE;
use const IPS\Helpers\Table\SEARCH_MEMBER;
use const IPS\Helpers\Table\SEARCH_NUMERIC;
if ( !defined( '\IPS\SUITE_UNIQUE_KEY' ) )
{
header( ( $_SERVER['SERVER_PROTOCOL'] ?? 'HTTP/1.0' ) . ' 403 Forbidden' );
exit;
}
/**
* File Settings
*/
class files extends Controller
{
/**
* @brief Has been CSRF-protected
*/
public static bool $csrfProtected = TRUE;
/**
* Manage Attachment Types
*
* @return void
*/
protected function manage() : void
{
/* This method is also called via ACP Member View with a CSRF key inline */
Output::i()->bypassCsrfKeyCheck = true;
Dispatcher::i()->checkAcpPermission( 'files_view' );
Output::i()->title = Member::loggedIn()->language()->addToStack('uploaded_files');
Output::i()->sidebar['actions'] = array();
if ( Member::loggedIn()->hasAcpRestriction( 'core', 'overview', 'files_settings' ) )
{
Output::i()->sidebar['actions']['settings'] = array(
'icon' => 'cog',
'link' => Url::internal( 'app=core&module=overview&controller=files&do=settings' ),
'title' => 'storage_settings',
);
Output::i()->sidebar['actions']['images'] = array(
'icon' => 'cog',
'link' => Url::internal( 'app=core&module=overview&controller=files&do=imagesettings' ),
'title' => 'image_settings',
);
}
/* @todo - This needs fixing but has been temporarily been disabled
if ( \IPS\Member::loggedIn()->hasAcpRestriction( 'core', 'overview', 'orphaned_files' ) )
{
\IPS\Output::i()->sidebar['actions']['orphaned'] = array(
'icon' => 'cog',
'link' => \IPS\Http\Url::internal( 'app=core&module=overview&controller=files&do=orphaned' ),
'title' => 'orphaned_files',
'data' => array( 'confirm' => '', 'confirmMessage' => \IPS\Member::loggedIn()->language()->addToStack('orphaned_files_confirm') )
);
}*/
$table = new TableDb( 'core_attachments', Url::internal( 'app=core&module=overview&controller=files' ) );
$table->tableTemplate = array( Theme::i()->getTemplate( 'dashboard' ), 'fileTable' );
$table->rowsTemplate = array( Theme::i()->getTemplate( 'dashboard' ), 'fileTableRows' );
$table->filters = array(
'images' => "attach_is_image=1",
'files' => "attach_is_image=0",
);
$table->include = array( 'attach_id', 'attach_file', 'attach_filesize', 'attach_date', 'attach_member_id' );
$table->rowClasses = array( 'attach_file' => array( 'ipsTable_wrap' ) );
if ( $table->filter !== 'images' )
{
$table->include[] = 'attach_hits';
}
$table->noSort = array( 'attach_type', 'attach_id' );
$table->quickSearch = 'attach_file';
$table->parsers = array(
'attach_file' => function( $val, $row ) use ( $table )
{
if ( $row['attach_is_image'] and $table->filter === 'images' )
{
$url = Url::external( File::get( 'core_Attachment', $row['attach_location'] )->url );
$alt = $row['attach_file'];
return "
";
}
else
{
$url = Url::external( Settings::i()->base_url . "applications/core/interface/file/attachment.php" )->setQueryString( 'id', $row['attach_id'] );
if ( $row['attach_security_key'] )
{
$url = $url->setQueryString( 'key', $row['attach_security_key'] );
}
$val = htmlentities( $val, ENT_DISALLOWED, 'UTF-8', FALSE );
return "{$val}";
}
},
'attach_filesize' => function( $val )
{
if ( $val < 1024 )
{
return "{$val}B";
}
elseif ( $val < 1048576 )
{
return round( ( $val / 1024 ), 2 ) . 'KB';
}
elseif ( $val < 1073741824 )
{
return round( ( $val / 1048576 ), 2 ) . 'MB';
}
else
{
return round( ( $val / 1073741824 ), 2 ) . 'GB';
}
},
'attach_date' => function( $val )
{
return DateTime::ts( $val );
},
'attach_hits' => function( $val, $row )
{
return $row['attach_is_image'] ? '' : $val;
},
'attach_member_id' => function( $val )
{
if ( $val == 0 )
{
return Member::load( $val )->name;
}
else
{
return "" . htmlentities( Member::load( $val )->name, ENT_DISALLOWED, 'UTF-8', FALSE ) . '';
}
}
);
$table->advancedSearch = array(
'attach_file' => SEARCH_CONTAINS_TEXT,
'attach_ext' => SEARCH_CONTAINS_TEXT,
'attach_hits' => SEARCH_NUMERIC,
'attach_date' => SEARCH_DATE_RANGE,
'attach_member_id' => SEARCH_MEMBER,
'attach_filesize' => SEARCH_NUMERIC,
);
$table->rowButtons = function( $row )
{
$buttons = array();
$buttons['view'] = array(
'icon' => 'search',
'title' => 'attach_view_locations',
'link' => Url::internal( "app=core&module=overview&controller=files&do=lookup&id={$row['attach_id']}" ),
'data' => array( 'ipsDialog' => '', 'ipsDialog-title' => $row['attach_file'] )
);
if ( Member::loggedIn()->hasAcpRestriction( 'core', 'overview', 'files_delete' ) )
{
$buttons['delete'] = array(
'icon' => 'times-circle',
'title' => 'delete',
'link' => Url::internal( "app=core&module=overview&controller=files&do=delete&id={$row['attach_id']}" ),
'data' => array( 'delete' => '' ),
);
}
return $buttons;
};
Output::i()->jsFiles = array_merge( Output::i()->jsFiles, Output::i()->js( 'admin_files.js', 'core', 'admin' ) );
Output::i()->output = (string) $table;
}
/**
* Lookup attachment locations
*
* @return void
*/
public function lookup() : void
{
Dispatcher::i()->checkAcpPermission( 'files_view' );
$loadedExtensions = array();
$locations = array();
foreach ( Db::i()->select( '*', 'core_attachments_map', array( 'attachment_id=?', intval( Request::i()->id ) ) ) as $map )
{
if ( !isset( $loadedExtensions[ $map['location_key'] ] ) )
{
$exploded = explode( '_', $map['location_key'] );
try
{
$extensions = Application::load( $exploded[0] )->extensions( 'core', 'EditorLocations' );
if ( isset( $extensions[ $exploded[1] ] ) )
{
$loadedExtensions[ $map['location_key'] ] = $extensions[ $exploded[1] ];
}
}
catch ( OutOfRangeException $e ){ }
}
if ( isset( $loadedExtensions[ $map['location_key'] ] ) )
{
try
{
if ( $url = $loadedExtensions[ $map['location_key'] ]->attachmentLookup( $map['id1'], $map['id2'], $map['id3'] ) )
{
$locations[] = $url;
}
}
catch ( LogicException | OutOfRangeException $e ) { }
}
}
Output::i()->output = Theme::i()->getTemplate( 'global' )->block( NULL, Theme::i()->getTemplate( 'members', 'core', 'global' )->attachmentLocations( $locations, FALSE ), TRUE, 'i-padding_3' );
}
/**
* Delete attachment
*
* @return void
*/
public function delete() : void
{
Dispatcher::i()->checkAcpPermission( 'files_delete' );
/* Make sure the user confirmed the deletion */
Request::i()->confirmedDelete();
try
{
$attachment = Db::i()->select( '*', 'core_attachments', array( 'attach_id=?', Request::i()->id ) )->first();
try
{
File::get( 'core_Attachment', $attachment['attach_location'] )->delete();
File::get( 'core_Attachment', $attachment['attach_thumb_location'] )->delete();
}
catch ( Exception $e ) { }
Db::i()->delete( 'core_attachments', array( 'attach_id=?', Request::i()->id ) );
Session::i()->log( 'acplogs__file_deleted', array( $attachment['attach_file'] => FALSE ) );
}
catch ( UnderflowException $e ) { }
Output::i()->redirect( Url::internal( "app=core&module=overview&controller=files" ) );
}
/**
* Image Settings
*
* @return void
*/
protected function imagesettings() : void
{
/* Init */
Dispatcher::i()->checkAcpPermission( 'files_settings' );
$form = new Form;
$form->add( new Radio( 'image_suite', class_exists( 'Imagick', FALSE ) ? Settings::i()->image_suite : 'gd', TRUE, array(
'options' => array( 'gd' => 'imagesuite_gd', 'imagemagick' => 'imagesuite_imagemagick' ),
'toggles' => array( 'imagemagick' => array( 'image_jpg_quality', 'imagick_strip_exif' ), 'gd' => array( 'image_jpg_quality', 'image_png_quality_gd' ) ),
'disabled'=> class_exists( 'Imagick', FALSE ) ? array() : array( 'imagemagick' )
) ) );
$form->add( new Number( 'image_jpg_quality', Settings::i()->image_jpg_quality, FALSE, array( 'min' => 0, 'max' => 100, 'range' => TRUE, 'step' => 1 ), NULL, NULL, NULL, 'image_jpg_quality' ) );
$form->add( new Number( 'image_png_quality_gd', Settings::i()->image_png_quality_gd, FALSE, array( 'min' => 0, 'max' => 9, 'range' => TRUE, 'step' => 1 ), NULL, NULL, NULL, 'image_png_quality_gd' ) );
$form->add( new YesNo( 'imagick_strip_exif', Settings::i()->imagick_strip_exif, FALSE, array(), NULL, NULL, NULL, 'imagick_strip_exif' ) );
if ( $values = $form->values() )
{
$form->saveAsSettings();
Session::i()->log( 'acplogs__image_settings_updated' );
Output::i()->redirect( Url::internal( 'app=core&module=overview&controller=files&do=imagesettings' ), 'saved' );
}
/* Display */
Output::i()->title = Member::loggedIn()->language()->addToStack('image_settings');
Output::i()->output = $form;
}
/**
* Upload Settings
*
* @return void
*/
protected function settings() : void
{
/* Init */
Dispatcher::i()->checkAcpPermission( 'files_settings' );
$totalConfigurations = (int) Db::i()->select( 'count(*)', 'core_file_storage' )->first();
$cicConfigurations = 0;
if( CIC )
{
$cicConfigurations = (int) Db::i()->select( 'count(*)', 'core_file_storage', array( "method=? AND configuration LIKE CONCAT( '%', ?, '%' )", 'Amazon', 'ips-cic-filestore' ) )->first();
}
/* If we have only one configuration, don't bother showing the settings tab */
if( $totalConfigurations == 1 )
{
$tabs = [ 'configurations' => 'filestorage_configurations' ];
$activeTab = 'configurations';
}
else
{
$tabs = [ 'settings' => 'filestorage_settings', 'configurations' => 'filestorage_configurations' ];
$activeTab = Request::i()->tab ?? 'settings';
}
/* Settings form */
if ( $activeTab === 'settings' )
{
$settings = json_decode( Settings::i()->upload_settings, TRUE );
$configurations = array();
$cicDisabled = FALSE;
if( CIC )
{
$cicDisabled = array();
}
foreach ( Db::i()->select( '*', 'core_file_storage' ) as $row )
{
$handlers = File::storageHandlers( $row );
$classname = $handlers[ $row['method'] ];
$configurations[ $row['id'] ] = $classname::displayName( json_decode( $row['configuration'], TRUE ) );
if( $row['method'] == 'FileSystem' AND CIC )
{
$cicDisabled[ $row['id'] ] = $row['id'];
}
if ( $row['method'] == 'Amazon' AND CIC AND json_decode( $row['configuration'], TRUE )['bucket'] == 'ips-cic-filestore' )
{
$cicDisabled[ $row['id'] ] = $row['id'];
}
}
$form = new Form;
$form->addMessage( 'filestorage_move_info' );
foreach ( Application::allExtensions( 'core', 'FileStorage', FALSE, NULL, NULL, TRUE ) as $name => $obj )
{
$disabled = ( isset( $settings[ "filestorage__{$name}" ] ) and is_array( $settings[ "filestorage__{$name}" ] ) );
$value = NULL;
if ( isset( $settings[ "filestorage__{$name}" ] ) )
{
if ( is_array( $settings[ "filestorage__{$name}" ] ) )
{
$copyOfSettings = $settings[ "filestorage__{$name}" ];
$value = array_shift( $copyOfSettings );
}
else
{
$value = $settings[ "filestorage__{$name}" ];
}
}
$toggles = array();
foreach( $configurations as $id => $title )
{
if( $id != $value )
{
$toggles[ $id ] = array( 'filestorage_move' );
}
}
$handlerDisabled = $cicDisabled;
if( isset( $handlerDisabled[ $value ] ) )
{
unset( $handlerDisabled[ $value ] );
}
$form->add( new Select( 'filestorage__' . $name, (int) $value, TRUE, array( 'options' => $configurations, 'disabled' => $disabled ?: $handlerDisabled, 'toggles' => $toggles ) ) );
if ( $disabled )
{
Member::loggedIn()->language()->words[ 'filestorage__' . $name . '_warning' ] = Member::loggedIn()->language()->addToStack( 'file_storage_move_in_progress' );
}
}
$form->add( new YesNo( 'filestorage_move', TRUE, FALSE, array(), NULL, NULL, NULL, 'filestorage_move' ) );
if ( $values = $form->values() )
{
/* Block moves to filesystem on CIC */
foreach ( $values as $k => $v )
{
if ( isset( $settings[ $k ] ) AND !is_array( $settings[ $k ] ) )
{
if( $settings[ $k ] != $v AND $k != 'filestorage_move' AND CIC AND in_array( $v, $cicDisabled ) )
{
Output::i()->error( 'file_storage_cic_filesystem', '3C158/7', 403, '' );
}
}
}
if( isset( $values['filestorage_move'] ) AND $values['filestorage_move'] )
{
$rebuild = FALSE;
/* Queue theme first */
if( isset( $values['filestorage__core_Theme'] ) and $settings['filestorage__core_Theme'] != $values['filestorage__core_Theme'] )
{
$rebuild = TRUE;
$extension = new \IPS\core\extensions\core\FileStorage\Theme;
Task::queue( 'core', 'MoveFiles', array( 'storageExtension' => 'filestorage__core_Theme', 'oldConfiguration' => $settings[ 'filestorage__core_Theme' ], 'newConfiguration' => $values[ 'filestorage__core_Theme' ], 'count' => $extension->count() ), 1 );
/* Add to allowed storage methods so when moving files, we can accept old config or new config if move is in progress. Important: order is array(x, y) x is the new location (pos 0), y is the old location (pos 1)*/
$values['filestorage__core_Theme'] = array( $values['filestorage__core_Theme'], $settings['filestorage__core_Theme'] );
}
$totalCount = 0;
foreach ( $values as $k => $v )
{
if ( isset( $settings[$k] ) AND !is_array( $settings[$k] ) )
{
if ( $settings[ $k ] != $v and $k != 'filestorage__core_Theme' AND $k != 'filestorage_move' )
{
/* Do we need to move files at all? */
$configurations = File::getStore();
$exploded = explode( '_', $k );
try
{
$classname = Application::getExtensionClass( $exploded[2], 'FileStorage', $exploded[3] );
}
catch( OutOfRangeException )
{
continue;
}
$extension = new $classname;
$currentClass = File::getClass( intval( $settings[ $k ] ) );
$newClass = File::getClass( intval( $v ) );
if ( ( isset( $configurations[ $v ] ) and isset( $configurations[ $settings[ $k ] ] ) ) and ( get_class( $currentClass ) == get_class( $newClass ) ) and ! $newClass::moveCheck( $newClass->configuration, $currentClass->configuration ) )
{
$rebuild = FALSE;
}
else
{
$rebuild = TRUE;
}
if ( $rebuild )
{
$count = $extension->count();
if ( $count )
{
$totalCount += $count;
Task::queue( 'core', 'MoveFiles', array( 'storageExtension' => $k, 'oldConfiguration' => $settings[ $k ], 'newConfiguration' => $values[ $k ], 'count' => $count ), 2 );
/* Add to allowed storage methods so when moving files, we can accept old config or new config if move is in progress. Important: order is array(x, y) x is the new location (pos 0), y is the old location (pos 1)*/
$values[ $k ] = array( $v, $settings[ $k ] );
}
}
}
}
}
if( $rebuild )
{
Task::queue( 'core', 'DeleteMovedFiles', array( 'delete' => true, 'count' => $totalCount ), 5, array( 'delete' ) ); /* We use a key in the data array just to trigger the code that deletes duplicate tasks */
}
}
/* Update the settings */
Settings::i()->changeValues( array( 'upload_settings' => json_encode( $values ) ) );
/* Clear guest page caches */
Cache::i()->clearAll();
Session::i()->log( 'acplogs__files_config_moved' );
Output::i()->redirect( Url::internal('app=core&module=overview&controller=files&do=settings&tab=settings'), 'saved' );
}
$activeTabContents = $form;
}
/* Or configurations table */
else
{
$table = new TableDb( 'core_file_storage', Url::internal( "app=core&module=overview&controller=files&do=settings&tab=configurations" ) );
$table->include = array( 'filestorage_method' );
$table->noSort = array( 'filestorage_method' );
$table->mainColumn = 'filestorage_method';
$table->parsers = array( 'filestorage_method' => function( $val, $row )
{
$handlers = File::storageHandlers( $row );
$classname = $handlers[ $row['method'] ];
$title = $classname::displayName( json_decode( $row['configuration'], TRUE ) );
if( CIC AND $row['method'] == 'FileSystem' )
{
return Theme::i()->getTemplate( 'dashboard' )->filesystemNotCic( $title );
}
return $title;
} );
/* If we already have a storage configuration, we cannot create any new ones */
if( $totalConfigurations - $cicConfigurations < 2 )
{
$table->rootButtons = array( 'add' => array(
'icon' => 'plus',
'title' => 'add',
'link' => Url::internal( "app=core&module=overview&controller=files&do=configurationForm" )
) );
}
$settings = json_decode( Settings::i()->upload_settings, TRUE );
$table->rowButtons = function( $row ) use ( $settings )
{
$config = json_decode( $row['configuration'], true );
if( CIC AND ( ( $row['method'] == 'Amazon' AND $config['bucket'] == 'ips-cic-filestore' ) OR $row['method'] == 'Cloud' ) )
{
return array(
'log' => array(
'icon' => 'search',
'title' => 'file_config_log_title',
'link' => \IPS\Http\Url::internal( "app=core&module=overview&controller=files&do=configurationLog&id={$row['id']}" )
)
);
}
$buttons = array(
'edit' => array(
'icon' => 'pencil',
'title' => 'edit',
'link' => \IPS\Http\Url::internal( "app=core&module=overview&controller=files&do=configurationForm&id={$row['id']}" )
),
'log' => array(
'icon' => 'search',
'title' => 'file_config_log_title',
'link' => Url::internal( "app=core&module=overview&controller=files&do=configurationLog&id={$row['id']}" )
),
'move' => array(
'icon' => 'arrow-right',
'title' => 'files_type_move',
'link' => Url::internal( "app=core&module=overview&controller=files&do=configurationMove&id={$row['id']}" )
)
);
if( ( !isset( $settings['filestorage_move'] ) or !$settings['filestorage_move'] ) and !in_array( $row['id'], $settings ) )
{
$buttons['delete'] = array(
'icon' => 'times-circle',
'title' => 'delete',
'link' => Url::internal( "app=core&module=overview&controller=files&do=configurationDelete&id={$row['id']}" )->csrf(),
'data' => array( 'confirm' => '' )
);
}
return $buttons;
};
$activeTabContents = $table;
}
/* Add a button for settings */
Output::i()->sidebar['actions'] = array(
'settings' => array(
'title' => 'settings',
'icon' => 'cog',
'link' => Url::internal( 'app=core&module=overview&controller=files&do=fileLogSettings' ),
'data' => array( 'ipsDialog' => '', 'ipsDialog-title' => Member::loggedIn()->language()->addToStack('settings') )
),
);
/* Display */
if ( Request::i()->isAjax() and !isset( Request::i()->ajaxValidate ) )
{
Output::i()->output = $activeTabContents;
}
else
{
Output::i()->title = Member::loggedIn()->language()->addToStack('storage_settings');
if( count( $tabs ) == 1 )
{
Output::i()->output = $activeTabContents;
}
else
{
$message = '';
if( $totalConfigurations - $cicConfigurations >= 2 )
{
$message = Theme::i()->getTemplate( 'global', 'core' )->message( Member::loggedIn()->language()->addToStack( 'multiple_filestorage_error' ), 'info' );
}
Output::i()->output = $message . Theme::i()->getTemplate( 'global' )->tabs( $tabs, $activeTab, $activeTabContents, Url::internal( "app=core&module=overview&controller=files&do=settings" ) );
}
}
}
/**
* Settings
*
* @return void
*/
protected function fileLogSettings() : void
{
$form = new Form;
$form->add( new Interval( 'file_log_pruning', Settings::i()->file_log_pruning, FALSE, array( 'valueAs' => Interval::DAYS, 'unlimited' => 0, 'unlimitedLang' => 'never' ), NULL, Member::loggedIn()->language()->addToStack('after'), NULL, 'file_log_pruning' ) );
if ( $values = $form->values() )
{
$form->saveAsSettings();
Session::i()->log( 'acplog__filelog_settings' );
Output::i()->redirect( Url::internal( 'app=core&module=overview&controller=files&do=settings' ), 'saved' );
}
Output::i()->title = Member::loggedIn()->language()->addToStack('filelog_settings');
Output::i()->output = Theme::i()->getTemplate('global')->block( 'filelog_settings', $form, FALSE );
}
protected function configurationMove() : void
{
/* Get existing */
try
{
$current = Db::i()->select( '*', 'core_file_storage', array( 'id=?', intval( Request::i()->id ) ) )->first();
}
catch ( UnderflowException $e )
{
Output::i()->error( 'node_error', '2C158/3', 404, '' );
}
$currentHandlerSettings = json_decode( $current['configuration'], TRUE );
/* Check if we are in the middle of a move */
foreach ( Db::i()->select( 'data', 'core_queue', array( '`key`=?', 'MoveFiles' ) ) as $data )
{
$data = json_decode( $data, TRUE );
if ( $data['oldConfiguration'] == Request::i()->id )
{
Output::i()->error( 'file_storage_move_out', '1C158/3', 403, '' );
}
elseif ( $data['newConfiguration'] == Request::i()->id )
{
Output::i()->error( 'file_storage_move_in', '1C158/4', 403, '' );
}
}
/* Do we already have more than one file storage location configured? */
$configurations = [];
$currentDisplayName = '';
foreach ( Db::i()->select( '*', 'core_file_storage' ) as $row )
{
$handlers = File::storageHandlers( $row );
$classname = $handlers[ $row['method'] ];
if( $row['id'] == $current['id'] )
{
$currentDisplayName = $classname::displayName( json_decode( $row['configuration'], TRUE ) );
continue;
}
$configurations[ $row['id'] ] = $classname::displayName( json_decode( $row['configuration'], TRUE ) );
}
$form = new Form( 'form', 'move' );
$form->addMessage( 'filestorage_moveall_info', 'ipsMessage ipsMessage--warning' );
$form->addHeader( sprintf( Member::loggedIn()->language()->get( 'filestorage_moveall_from' ), $currentDisplayName ) );
if( count( $configurations ) )
{
$form->add( new Radio( 'files_move_to', null, true, [
'options' => $configurations,
'noDefault' => true,
'disabled' => [ $current['id'] ]
] ) );
}
else
{
/* if we only have one location, allow them to create another one */
$handlers = array();
$handlerSettings = array();
$toggles = array();
foreach ( File::storageHandlers( $current ) as $key => $class )
{
$handlers[ $key ] = 'filehandler__' . $key;
foreach ( $class::settings( $currentHandlerSettings ) as $k => $v )
{
if ( is_array( $v ) )
{
$settingClass = '\IPS\Helpers\Form\\' . $v['type'];
$default = isset( $currentHandlerSettings[ $k ] ) ? str_replace( '{root}', ROOT_PATH, $currentHandlerSettings[ $k ] ) : NULL;
if ( isset( $v['default'] ) and !$default )
{
$default = str_replace( '{root}', ROOT_PATH, $v['default'] );
}
$handlerSettings[ $key ][ $k ] = new $settingClass( "filehandler__{$key}_{$k}", $default, FALSE, $v['options'] ?? array(), $v['validate'] ?? NULL, $v['prefix'] ?? NULL, $v['suffix'] ?? NULL, "{$key}_{$k}" );
}
else
{
$settingClass = '\IPS\Helpers\Form\\' . $v;
$handlerSettings[ $key ][ $k ] = new $settingClass( "filehandler__{$key}_{$k}", $currentHandlerSettings[$k] ?? NULL, FALSE, array(), NULL, NULL, NULL, "{$key}_{$k}" );
}
$toggles[ $key ][ $k ] = "{$key}_{$k}";
}
}
/* Build form */
$form->add( new Radio( 'filestorage_method', $current ? $current['method'] : ( CIC ? 'Amazon' : 'FileSystem' ), TRUE, array( 'options' => $handlers, 'toggles' => $toggles ) ) );
foreach ( $handlerSettings as $handlerKey => $settings )
{
foreach ( $settings as $setting )
{
$form->add( $setting );
}
}
}
/* Handle submissions */
if ( $values = $form->values() )
{
if( isset( $values['files_move_to'] ) )
{
$newStorageId = $values['files_move_to'];
}
else
{
try
{
if ( isset( $toggles[ $values['filestorage_method'] ] ) )
{
foreach ( $toggles[ $values['filestorage_method'] ] as $k => $v )
{
$currentHandlerSettings[ $k ] = ( ROOT_PATH !== '/' ) ? str_replace( ROOT_PATH, '{root}', $values[ 'filehandler__' . $v ] ) : $values[ 'filehandler__' . $v ];
}
}
$classname = File::storageHandlers( $current )[ $values['filestorage_method'] ];
if ( method_exists( $classname, 'testSettings' ) )
{
$classname::testSettings( $currentHandlerSettings );
}
$existingWithSameConfig = false;
/* Make sure there are no other configurations that are exactly the same */
foreach( Db::i()->select( '*', 'core_file_storage', array( 'method=?', $values['filestorage_method'] ) ) as $existing )
{
if ( $current and $current['id'] == $existing['id'] )
{
continue;
}
$existingWithSameConfig = true;
$existingConfiguration = json_decode( $existing['configuration'], true );
foreach( $existingConfiguration as $k => $v )
{
$v = str_replace( ROOT_PATH, '{root}', $v );
if ( array_key_exists( $k, $currentHandlerSettings ) )
{
if ( $v != $currentHandlerSettings[ $k ] )
{
$existingWithSameConfig = false;
}
}
}
}
if ( $existingWithSameConfig )
{
/* Let's not allow this to be saved as someone can start a move to the same location, which will end up deleting the files */
throw new DomainException( Member::loggedIn()->language()->addToStack( 'file_config_is_the_same_as_existing', FALSE ) );
}
/* Create the new location */
$newStorageId = Db::i()->insert( 'core_file_storage', array(
'method' => $values['filestorage_method'],
'configuration' => json_encode( $currentHandlerSettings ),
) );
unset( Store::i()->storageConfigurations );
/* Log the storage addition */
Session::i()->log( 'acplogs__files_config_added' );
}
catch ( LogicException $e )
{
$msg = $e->getMessage();
$form->error = Member::loggedIn()->language()->addToStack( $msg );
}
}
if( isset( $newStorageId ) )
{
$settings = json_decode( Settings::i()->upload_settings, TRUE );
$totalCount = 0;
foreach ( $settings as $k => $v )
{
if ( $v == $current['id'] )
{
$exploded = explode( '_', $k );
try
{
$classname = Application::getExtensionClass( $exploded[2], 'FileStorage', $exploded[3] );
$extension = new $classname;
$count = $extension->count();
/* Don't bother with this task if there is nothing to move */
if( $count > 0 )
{
$totalCount += $count;
Task::queue( 'core', 'MoveFiles', array( 'storageExtension' => $k, 'oldConfiguration' => $v, 'newConfiguration' => $newStorageId, 'count' => $count ), 2 );
}
$settings[ $k ] = $newStorageId;
}
catch( Exception $e ){}
}
}
Settings::i()->changeValues( array( 'upload_settings' => json_encode( $settings ) ) );
Task::queue( 'core', 'DeleteMovedFiles', array( 'delete' => true, 'count' => $totalCount, 'storageToDelete' => $current['id'] ), 5, array( 'delete' ) ); /* We use a key in the data array just to trigger the code that deletes duplicate tasks */
Output::i()->redirect( Url::internal( "app=core&module=overview&controller=files&do=settings" ) );
}
}
/* Display */
Output::i()->title = Member::loggedIn()->language()->addToStack('storage_settings');
Output::i()->breadcrumb[] = array( Url::internal( "&app=core&module=overview&controller=files&do=settings&tab=configurations" ), 'filestorage_settings' );
Output::i()->output = $form;
}
/**
* Add/Edit Configuration
*
* @return void
*/
protected function configurationForm() : void
{
/* Are we allowed to create a new location? */
if ( ! isset( Request::i()->id ) )
{
$totalConfigurations = (int) Db::i()->select( 'count(*)', 'core_file_storage' )->first();
$cicConfigurations = 0;
if( CIC )
{
$cicConfigurations = (int) Db::i()->select( 'count(*)', 'core_file_storage', array( "method=?", 'Cloud' ) )->first();
}
if( $totalConfigurations - $cicConfigurations > 2 )
{
Output::i()->error( 'multiple_filestorage_error', '2C158/3', 403 );
}
}
else
{
/* Before we edit any details, check to make sure we're not processing files in this location */
foreach ( Db::i()->select( 'data', 'core_queue', array( '`key`=?', 'MoveFiles' ) ) as $data )
{
$data = json_decode( $data, true );
if ( $data['oldConfiguration'] == Request::i()->id )
{
Output::i()->error( 'file_storage_move_out', '1C158/3', 403, '' );
}
elseif ( $data['newConfiguration'] == Request::i()->id )
{
Output::i()->error( 'file_storage_move_in', '1C158/4', 403, '' );
}
}
}
try
{
$current = Db::i()->select( '*', 'core_file_storage', ['id=?', intval( Request::i()->id )] )->first();
$currentHandlerSettings = json_decode( $current['configuration'], true );
}
catch ( \UnderflowException $e )
{
$current = NULL;
$currentHandlerSettings = array();
}
/* Get handlers */
$handlers = array();
$handlerSettings = array();
$toggles = array();
foreach ( File::storageHandlers( NULL ) as $key => $class )
{
if ( CIC AND $key == 'Cloud' AND ! Member::loggedIn()->members_bitoptions['is_support_account'] )
{
continue;
}
$handlers[ $key ] = 'filehandler__' . $key;
foreach ( $class::settings( $currentHandlerSettings ) as $k => $v )
{
if ( is_array( $v ) )
{
$settingClass = '\IPS\Helpers\Form\\' . $v['type'];
$default = isset( $currentHandlerSettings[ $k ] ) ? str_replace( '{root}', ROOT_PATH, $currentHandlerSettings[ $k ] ) : NULL;
if ( isset( $v['default'] ) and !$default )
{
$default = str_replace( '{root}', ROOT_PATH, $v['default'] );
}
$handlerSettings[ $key ][ $k ] = new $settingClass( "filehandler__{$key}_{$k}", $default, FALSE, $v['options'] ?? array(), $v['validate'] ?? NULL, $v['prefix'] ?? NULL, $v['suffix'] ?? NULL, "{$key}_{$k}" );
}
else
{
$settingClass = '\IPS\Helpers\Form\\' . $v;
$handlerSettings[ $key ][ $k ] = new $settingClass( "filehandler__{$key}_{$k}", NULL, FALSE, array(), NULL, NULL, NULL, "{$key}_{$k}" );
}
$toggles[ $key ][ $k ] = "{$key}_{$k}";
}
}
/* Build form */
$form = new Form;
if ( $current )
{
$form->addMessage( Member::loggedIn()->language()->addToStack( "filestorage_config_edit_warning", null, [
'sprintf' => Url::internal( 'app=core&module=overview&controller=files&do=configurationMove&id=' . $current['id'] ),
] ), 'ipsMessage ipsMessage--warning' );
}
$form->add( new Radio( 'filestorage_method', $current ? $current['method'] : ( CIC ? 'Amazon' : 'FileSystem' ), TRUE, array( 'disabled' => ( isset( Request::i()->id ) ), 'options' => $handlers, 'toggles' => $toggles ) ) );
foreach ( $handlerSettings as $handlerKey => $settings )
{
foreach ( $settings as $setting )
{
$form->add( $setting );
}
}
/* Handle submissions */
if ( $values = $form->values() )
{
$currentHandlerSettings = [];
try
{
if ( isset( $toggles[ $values['filestorage_method'] ] ) )
{
foreach ( $toggles[ $values['filestorage_method'] ] as $k => $v )
{
$currentHandlerSettings[ $k ] = ( ROOT_PATH !== '/' ) ? str_replace( ROOT_PATH, '{root}', $values[ 'filehandler__' . $v ] ) : $values[ 'filehandler__' . $v ];
}
}
$classname = File::storageHandlers( NULL )[ $values['filestorage_method'] ];
if ( method_exists( $classname, 'testSettings' ) )
{
$classname::testSettings( $currentHandlerSettings );
}
$existingWithSameConfig = false;
/* Make sure there are no other configurations that are exactly the same */
foreach( Db::i()->select( '*', 'core_file_storage', array( 'method=?', $values['filestorage_method'] ) ) as $existing )
{
$existingWithSameConfig = true;
$existingConfiguration = json_decode( $existing['configuration'], true );
foreach( $existingConfiguration as $k => $v )
{
$v = str_replace( ROOT_PATH, '{root}', (string) $v );
if ( array_key_exists( $k, $currentHandlerSettings ) )
{
if ( $v != $currentHandlerSettings[ $k ] )
{
$existingWithSameConfig = false;
}
}
}
}
if ( $existingWithSameConfig and ! Request::i()->id )
{
/* Let's not allow this to be saved as someone can start a move to the same location, which will end up deleting the files */
throw new DomainException( Member::loggedIn()->language()->addToStack( 'file_config_is_the_same_as_existing', FALSE ) );
}
if ( Request::i()->id )
{
Db::i()->update( 'core_file_storage', [
'configuration' => json_encode( $currentHandlerSettings ),
], array( 'id=?', Request::i()->id ) );
}
else
{
Db::i()->insert( 'core_file_storage', [
'method' => $values['filestorage_method'],
'configuration' => json_encode( $currentHandlerSettings ),
] );
}
unset( Store::i()->storageConfigurations );
/* Log the storage addition */
Session::i()->log( 'acplogs__files_config_added' );
Output::i()->redirect( Url::internal( 'app=core&module=overview&controller=files&do=settings&tab=configurations' ), 'saved' );
}
catch ( LogicException $e )
{
$msg = $e->getMessage();
$form->error = Member::loggedIn()->language()->addToStack( $msg );
}
}
/* Display */
Output::i()->title = Member::loggedIn()->language()->addToStack('storage_settings');
Output::i()->output = $form;
}
/**
* Delete a file storage method
*
* @return void
*/
protected function configurationDelete() : void
{
Request::i()->confirmedDelete();
try
{
$storage = Db::i()->select( '*', 'core_file_storage', [ 'id=?', Request::i()->id ] )->first();
}
catch( \UnderflowException )
{
Output::i()->error( 'node_error', '2C158/7', 404 );
}
$settings = json_decode( Settings::i()->upload_settings, TRUE );
if( isset( $settings['filestorage_move'] ) and $settings['filestorage_move'] )
{
Output::i()->error( 'file_storage_delete_move_in_progress', '2C158/8' );
}
if( in_array( $storage['id'], $settings ) )
{
Output::i()->error( 'file_storage_delete_in_use', '2C158/9' );
}
Db::i()->delete( 'core_file_storage', [ 'id=?', Request::i()->id ] );
Output::i()->redirect( Url::internal( "app=core&module=overview&controller=files&do=settings&tab=configurations" ) );
}
/**
* View logs for this configuration
*
* @return void
*/
protected function configurationLog() : void
{
$method = Db::i()->select( '*', 'core_file_storage', array( 'id=?', intval( Request::i()->id ) ) )->first();
$title = Member::loggedIn()->language()->addToStack( 'file_config_log', FALSE, array( 'sprintf' => array( $method['method'] ) ) );
/* Create the table */
$table = new TableDb( 'core_file_logs', Url::internal( 'app=core&module=overview&controller=files&do=configurationLog&id=' . Request::i()->id ), array( array( 'log_configuration_id=?', Request::i()->id ) ) );
$table->langPrefix = 'files_';
$table->title = $title;
$table->quickSearch = 'log_filename';
$table->sortBy = 'log_date';
$table->filters = array(
'files_log_filter_error' => array('log_type=?', 'error' ),
'files_log_filter_move' => array('log_type=?', 'move' )
);
$table->include = array( 'log_date', 'log_type', 'log_action', 'log_msg', 'log_filename' );
$table->parsers = array(
'log_filename' => function( $val, $row )
{
return ( ! empty( $row['log_container'] ) ? $row['log_container'] . '/' : '' ) . $val;
},
'log_date' => function( $val )
{
return DateTime::ts( $val )->localeDate();
},
'log_type' => function( $val )
{
return Member::loggedIn()->language()->addToStack( 'files_type_' . $val );
},
'log_action' => function( $val )
{
return Member::loggedIn()->language()->addToStack( 'files_action_' . $val );
}
);
/* Display */
Output::i()->breadcrumb[] = array( Url::internal( "&app=core&module=overview&controller=files&do=settings&tab=configurations" ), 'filestorage_settings' );
Output::i()->output = (string) $table;
Output::i()->title = $title;
}
/**
* Remove orphaned files
*
* @return void
*/
protected function orphaned() : void
{
Session::i()->csrfCheck();
foreach( Db::i()->select( '*', 'core_file_storage', NULL, 'id' ) as $row )
{
Task::queue( 'core', 'FindOrphanedFiles', array( 'configurationId' => $row['id'] ), 4, array( 'configurationId' ) );
}
Output::i()->redirect( Url::internal( "app=core&module=overview&controller=files" ), 'orphaned_files_tasks_added' );
}
/**
* Multimod
*
* @return void
*/
protected function multimod() : void
{
Dispatcher::i()->checkAcpPermission( 'files_delete' );
Session::i()->csrfCheck();
if( !isset( Request::i()->multimod ) OR !is_array( Request::i()->multimod ) OR !count( Request::i()->multimod ) )
{
Output::i()->error( 'nothing_mm_selected', '2C158/6', 403, '' );
}
foreach ( Db::i()->select( '*', 'core_attachments', Db::i()->in( 'attach_id', array_keys( Request::i()->multimod ) ) ) as $attachment )
{
File::get( 'core_Attachment', $attachment['attach_location'] )->delete();
if( $attachment['attach_thumb_location'] )
{
File::get( 'core_Attachment', $attachment['attach_thumb_location'] )->delete();
}
Session::i()->log( 'acplogs__file_deleted', array( $attachment['attach_file'] => FALSE ) );
}
Db::i()->delete( 'core_attachments', Db::i()->in( 'attach_id', array_keys( Request::i()->multimod ) ) );
$url = Url::internal( "app=core&module=overview&controller=files" );
if( Request::i()->listResort )
{
$url = $url->setQueryString( array( 'listResort' => 1, 'sortby' => Request::i()->sortby, 'sortdirection' => Request::i()->sortdirection ) )->csrf();
}
Output::i()->redirect( $url, 'deleted' );
}
}