| Server IP : 66.29.137.217 / Your IP : 18.116.230.250 Web Server : LiteSpeed System : Linux premium294.web-hosting.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : gltevjme ( 1095) PHP Version : 7.0.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/gltevjme/ideyshare.name.ng/plugins/fileimport/ |
Upload File : |
<?php
// plugin namespace
namespace Plugins\Fileimport;
// core includes
use App\Core\Database;
use App\Models\File;
use App\Helpers\CoreHelper;
use App\Helpers\FileActionHelper;
use App\Helpers\FileHelper;
use App\Helpers\FileFolderHelper;
use App\Helpers\PluginHelper;
use App\Services\Plugin;
use App\Services\Uploader;
use Plugins\Fileimport\PluginConfig;
class PluginFileimport extends Plugin {
// set folder privacy
public $isFolderPublic = 0;
public function __construct() {
// load plugin config
$this->config = (new PluginConfig())->getPluginConfig();
// ensure we're using UTF8
setlocale(LC_ALL, 'en_US.UTF-8');
// don't copy the file itself, only create the DB entry
define('DB_ONLY', true);
}
public function getPluginDetails() {
return $this->config;
}
public function registerRoutes(\FastRoute\RouteCollector $r) {
// register plugin routes
$r->addRoute(['GET', 'POST'], '/' . ADMIN_FOLDER_NAME . '/plugin/' . $this->config['folder_name'] . '/settings', '\plugins\\' . $this->config['folder_name'] . '\controllers\admin\PluginController/pluginSettings');
$r->addRoute(['GET'], '/' . ADMIN_FOLDER_NAME . '/plugin/' . $this->config['folder_name'] . '/ajax/folder_listing', '\plugins\\' . $this->config['folder_name'] . '\controllers\admin\PluginController/ajaxFolderListing');
$r->addRoute(['GET'], '/' . ADMIN_FOLDER_NAME . '/plugin/' . $this->config['folder_name'] . '/download_import_script', '\plugins\\' . $this->config['folder_name'] . '\controllers\admin\PluginController/downloadImportScript');
$r->addRoute(['GET'], '/' . ADMIN_FOLDER_NAME . '/plugin/' . $this->config['folder_name'] . '/process_file_import', '\plugins\\' . $this->config['folder_name'] . '\controllers\admin\PluginController/processFileImport');
}
public function getLowestWritableBasePath() {
// find the lowest folder this setup has access to
// loop path until we can not read any more
$failsafe++;
$baseFolder = DOC_ROOT;
$lastBaseFolder = $baseFolder;
while (is_readable($baseFolder) && $failsafe < 20) {
$lastBaseFolder = $baseFolder;
$baseFolder = dirname($baseFolder);
if (strlen(trim($baseFolder)) == 0) {
$failsafe = 20;
}
$failsafe++;
}
// make sure it ends with a forward slash
if (substr($lastBaseFolder, strlen($lastBaseFolder) - 1, 1) != DIRECTORY_SEPARATOR) {
$lastBaseFolder .= DIRECTORY_SEPARATOR;
}
return $lastBaseFolder;
}
// local functions
public function importFiles($localPath, $userId, $folderId, $folderPath = '') {
// setup database
$db = Database::getDatabase();
// get items
$items = CoreHelper::getDirectoryListing($localPath);
if (count($items)) {
foreach ($items AS $item) {
if (is_dir($item)) {
// directory, first make sure we have the folder
$folderName = basename($item);
$childFolderId = (int) $db->getValue('SELECT id '
. 'FROM file_folder '
. 'WHERE userId = ' . (int) $userId . ' '
. 'AND folderName = ' . $db->quote($folderName) . ' '
. 'AND parentId ' . ((int) $folderId === 0 ? ' IS NULL' : ('=' . (int) $folderId)) . ' '
. 'AND status = "active" '
. 'LIMIT 1');
if (!$childFolderId) {
$db->query('INSERT INTO file_folder '
. '(folderName, isPublic, userId, addedUserId, parentId, urlHash, date_added) VALUES '
. '(:folderName, :isPublic, :userId, :addedUserId, :parentId, :urlHash, NOW())', array(
'folderName' => $folderName,
'isPublic' => $this->isFolderPublic,
'userId' => $userId,
'addedUserId' => $userId,
'urlHash' => FileFolderHelper::generateRandomFolderHash(),
'parentId' => $folderId,
)
);
$childFolderId = $db->insertId();
}
// loop again for files within
$this->importFiles($item, $userId, $childFolderId, $folderPath . '/' . $folderName);
} else {
// file
$rs = $this->importFile($item, $userId, $folderId, $folderPath);
if ($rs) {
$this->output('Imported ' . $item);
} else {
$this->output('Error: File above failed import (' . $item . ')');
}
}
}
}
}
public function importFile($filePath, $userId, $folderId, $folderPath = '') {
// setup database, ensure we reconnect to avoid timeouts
$db = Database::getDatabase(true);
// get original filename
$pathParts = pathinfo($filePath);
$filename = $pathParts['filename'];
if (isset($pathParts['extension']) && strlen($pathParts['extension'])) {
$filename .= '.' . $pathParts['extension'];
}
// remove any invalid characters in the filename
$filename = FileHelper::makeFilenameSafe($filename);
// don't re-import if we already have the file
$foundFile = (int) $db->getValue('SELECT id '
. 'FROM file '
. 'WHERE folderId ' . ((int) $folderId === 0 ? ' IS NULL' : ('=' . (int) $folderId)) . ' '
. 'AND originalFilename = :original_filename '
. 'AND fileSize = :file_size '
. 'AND status = "active" '
. 'LIMIT 1', array(
'original_filename' => $filename,
'file_size' => filesize($filePath),
));
if ($foundFile) {
$this->output('Info: File already exists. (' . $filePath . ')');
return true;
}
// get mime type
$mimeType = FileHelper::estimateMimeTypeFromExtension($filename, 'application/octet-stream');
if (($mimeType == 'application/octet-stream') && (class_exists('finfo', false))) {
$finfo = new \finfo();
$mimeType = $finfo->file($filePath, FILEINFO_MIME);
}
if (DB_ONLY === true) {
// insert entry into the DB rather than move etc
// store in db
$file = File::create();
$file->originalFilename = $filename;
$file->shortUrl = 'temp';
$file->fileType = $mimeType;
$file->extension = strtolower($pathParts['extension']);
$file->fileSize = filesize($filePath);
$file->localFilePath = 'imported' . $folderPath . '/' . $filename;
// only create file md5 for files < 4GB
$fileHash = substr((microtime(true) * 10000) . '-' . md5($filePath . microtime()), 0, 32);
if ($file->fileSize < (1024 * 1024 * 1024 * 4)) {
$fileHash = md5_file($filePath);
}
// add user id if user is logged in
$file->userId = $userId;
$file->uploadedUserId = $userId;
$file->totalDownload = 0;
$file->uploadedIP = CoreHelper::getUsersIPAddress();
$file->uploadedDate = CoreHelper::sqlDateTime();
$file->status = "active";
$file->deleteHash = md5($filename . CoreHelper::getUsersIPAddress() . microtime());
$file->serverId = FileHelper::getCurrentServerId();
$file->fileHash = $fileHash;
$file->adminNotes = '';
$file->folderId = $folderId;
$file->uploadSource = 'fileimport';
$file->keywords = substr(implode(',', FileHelper::getKeywordArrFromString($filename)), 0, 255);
$file->unique_hash = FileHelper::createUniqueFileHashString();
if (!$file->save()) {
$this->output(TranslateHelper::t('classuploader_failed_adding_to_database', 'Failed adding to database. [[[ERROR_MSG]]]', array(
'ERROR_MSG' => $file->errorMsg,
)));
return false;
} else {
// create short url
$tracker = 1;
$shortUrl = FileHelper::createShortUrlPart($tracker . $file->id);
$fileTmp = File::loadOneByShortUrl($shortUrl);
while ($fileTmp) {
$shortUrl = FileHelper::createShortUrlPart($tracker . $file->id);
$fileTmp = File::loadOneByShortUrl($shortUrl);
$tracker++;
}
// update short url
$file->shortUrl = $shortUrl;
$file->save();
}
} else {
// setup uploader
$uploadHandler = new Uploader(array(
'folder_id' => $folderId,
'user_id' => $userId,
'upload_source' => 'fileimport',
));
$fileUpload = new \stdClass();
$fileUpload->name = stripslashes($filename);
$fileUpload->size = filesize($filePath);
$fileUpload->type = $mimeType;
$fileUpload->error = null;
$fileUpload = $uploadHandler->moveIntoStorage($fileUpload, $filePath, true); // keeps the original
if (strlen($fileUpload->error)) {
$this->output('Error: ' . $fileUpload->error);
return false;
}
}
return true;
}
public function output($msg = '', $exit = false) {
echo $msg;
if (defined('CLI_MODE') && CLI_MODE == true) {
echo "\n";
} else {
echo "<br/>";
ob_start();
ob_end_flush();
}
if ($exit == true) {
die();
}
}
}