1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197 |
- <?php
- /**
- * SPDX-FileCopyrightText: 2016-2024 Nextcloud GmbH and Nextcloud contributors
- * SPDX-FileCopyrightText: 2016 ownCloud, Inc.
- * SPDX-License-Identifier: AGPL-3.0-only
- */
- namespace OC\Files;
- use Icewind\Streams\CallbackWrapper;
- use OC\Files\Mount\MoveableMount;
- use OC\Files\Storage\Storage;
- use OC\Share\Share;
- use OC\User\LazyUser;
- use OC\User\Manager as UserManager;
- use OC\User\User;
- use OCA\Files_Sharing\SharedMount;
- use OCP\Constants;
- use OCP\Files\Cache\ICacheEntry;
- use OCP\Files\ConnectionLostException;
- use OCP\Files\EmptyFileNameException;
- use OCP\Files\FileNameTooLongException;
- use OCP\Files\ForbiddenException;
- use OCP\Files\InvalidCharacterInPathException;
- use OCP\Files\InvalidDirectoryException;
- use OCP\Files\InvalidPathException;
- use OCP\Files\Mount\IMountPoint;
- use OCP\Files\NotFoundException;
- use OCP\Files\ReservedWordException;
- use OCP\IUser;
- use OCP\Lock\ILockingProvider;
- use OCP\Lock\LockedException;
- use OCP\Server;
- use OCP\Share\IManager;
- use OCP\Share\IShare;
- use Psr\Log\LoggerInterface;
- /**
- * Class to provide access to ownCloud filesystem via a "view", and methods for
- * working with files within that view (e.g. read, write, delete, etc.). Each
- * view is restricted to a set of directories via a virtual root. The default view
- * uses the currently logged in user's data directory as root (parts of
- * OC_Filesystem are merely a wrapper for OC\Files\View).
- *
- * Apps that need to access files outside of the user data folders (to modify files
- * belonging to a user other than the one currently logged in, for example) should
- * use this class directly rather than using OC_Filesystem, or making use of PHP's
- * built-in file manipulation functions. This will ensure all hooks and proxies
- * are triggered correctly.
- *
- * Filesystem functions are not called directly; they are passed to the correct
- * \OC\Files\Storage\Storage object
- */
- class View {
- private string $fakeRoot = '';
- private ILockingProvider $lockingProvider;
- private bool $lockingEnabled;
- private bool $updaterEnabled = true;
- private UserManager $userManager;
- private LoggerInterface $logger;
- /**
- * @throws \Exception If $root contains an invalid path
- */
- public function __construct(string $root = '') {
- if (!Filesystem::isValidPath($root)) {
- throw new \Exception();
- }
- $this->fakeRoot = $root;
- $this->lockingProvider = \OC::$server->get(ILockingProvider::class);
- $this->lockingEnabled = !($this->lockingProvider instanceof \OC\Lock\NoopLockingProvider);
- $this->userManager = \OC::$server->getUserManager();
- $this->logger = \OC::$server->get(LoggerInterface::class);
- }
- /**
- * @param ?string $path
- * @psalm-template S as string|null
- * @psalm-param S $path
- * @psalm-return (S is string ? string : null)
- */
- public function getAbsolutePath($path = '/'): ?string {
- if ($path === null) {
- return null;
- }
- $this->assertPathLength($path);
- if ($path === '') {
- $path = '/';
- }
- if ($path[0] !== '/') {
- $path = '/' . $path;
- }
- return $this->fakeRoot . $path;
- }
- /**
- * Change the root to a fake root
- *
- * @param string $fakeRoot
- */
- public function chroot($fakeRoot): void {
- if (!$fakeRoot == '') {
- if ($fakeRoot[0] !== '/') {
- $fakeRoot = '/' . $fakeRoot;
- }
- }
- $this->fakeRoot = $fakeRoot;
- }
- /**
- * Get the fake root
- */
- public function getRoot(): string {
- return $this->fakeRoot;
- }
- /**
- * get path relative to the root of the view
- *
- * @param string $path
- */
- public function getRelativePath($path): ?string {
- $this->assertPathLength($path);
- if ($this->fakeRoot == '') {
- return $path;
- }
- if (rtrim($path, '/') === rtrim($this->fakeRoot, '/')) {
- return '/';
- }
- // missing slashes can cause wrong matches!
- $root = rtrim($this->fakeRoot, '/') . '/';
- if (!str_starts_with($path, $root)) {
- return null;
- } else {
- $path = substr($path, strlen($this->fakeRoot));
- if (strlen($path) === 0) {
- return '/';
- } else {
- return $path;
- }
- }
- }
- /**
- * Get the mountpoint of the storage object for a path
- * ( note: because a storage is not always mounted inside the fakeroot, the
- * returned mountpoint is relative to the absolute root of the filesystem
- * and does not take the chroot into account )
- *
- * @param string $path
- */
- public function getMountPoint($path): string {
- return Filesystem::getMountPoint($this->getAbsolutePath($path));
- }
- /**
- * Get the mountpoint of the storage object for a path
- * ( note: because a storage is not always mounted inside the fakeroot, the
- * returned mountpoint is relative to the absolute root of the filesystem
- * and does not take the chroot into account )
- *
- * @param string $path
- */
- public function getMount($path): IMountPoint {
- return Filesystem::getMountManager()->find($this->getAbsolutePath($path));
- }
- /**
- * Resolve a path to a storage and internal path
- *
- * @param string $path
- * @return array{?\OCP\Files\Storage\IStorage, string} an array consisting of the storage and the internal path
- */
- public function resolvePath($path): array {
- $a = $this->getAbsolutePath($path);
- $p = Filesystem::normalizePath($a);
- return Filesystem::resolvePath($p);
- }
- /**
- * Return the path to a local version of the file
- * we need this because we can't know if a file is stored local or not from
- * outside the filestorage and for some purposes a local file is needed
- *
- * @param string $path
- */
- public function getLocalFile($path): string|false {
- $parent = substr($path, 0, strrpos($path, '/') ?: 0);
- $path = $this->getAbsolutePath($path);
- [$storage, $internalPath] = Filesystem::resolvePath($path);
- if (Filesystem::isValidPath($parent) && $storage) {
- return $storage->getLocalFile($internalPath);
- } else {
- return false;
- }
- }
- /**
- * the following functions operate with arguments and return values identical
- * to those of their PHP built-in equivalents. Mostly they are merely wrappers
- * for \OC\Files\Storage\Storage via basicOperation().
- */
- public function mkdir($path) {
- return $this->basicOperation('mkdir', $path, ['create', 'write']);
- }
- /**
- * remove mount point
- *
- * @param IMountPoint $mount
- * @param string $path relative to data/
- */
- protected function removeMount($mount, $path): bool {
- if ($mount instanceof MoveableMount) {
- // cut of /user/files to get the relative path to data/user/files
- $pathParts = explode('/', $path, 4);
- $relPath = '/' . $pathParts[3];
- $this->lockFile($relPath, ILockingProvider::LOCK_SHARED, true);
- \OC_Hook::emit(
- Filesystem::CLASSNAME, "umount",
- [Filesystem::signal_param_path => $relPath]
- );
- $this->changeLock($relPath, ILockingProvider::LOCK_EXCLUSIVE, true);
- $result = $mount->removeMount();
- $this->changeLock($relPath, ILockingProvider::LOCK_SHARED, true);
- if ($result) {
- \OC_Hook::emit(
- Filesystem::CLASSNAME, "post_umount",
- [Filesystem::signal_param_path => $relPath]
- );
- }
- $this->unlockFile($relPath, ILockingProvider::LOCK_SHARED, true);
- return $result;
- } else {
- // do not allow deleting the storage's root / the mount point
- // because for some storages it might delete the whole contents
- // but isn't supposed to work that way
- return false;
- }
- }
- public function disableCacheUpdate(): void {
- $this->updaterEnabled = false;
- }
- public function enableCacheUpdate(): void {
- $this->updaterEnabled = true;
- }
- protected function writeUpdate(Storage $storage, string $internalPath, ?int $time = null, ?int $sizeDifference = null): void {
- if ($this->updaterEnabled) {
- if (is_null($time)) {
- $time = time();
- }
- $storage->getUpdater()->update($internalPath, $time, $sizeDifference);
- }
- }
- protected function removeUpdate(Storage $storage, string $internalPath): void {
- if ($this->updaterEnabled) {
- $storage->getUpdater()->remove($internalPath);
- }
- }
- protected function renameUpdate(Storage $sourceStorage, Storage $targetStorage, string $sourceInternalPath, string $targetInternalPath): void {
- if ($this->updaterEnabled) {
- $targetStorage->getUpdater()->renameFromStorage($sourceStorage, $sourceInternalPath, $targetInternalPath);
- }
- }
- /**
- * @param string $path
- * @return bool|mixed
- */
- public function rmdir($path) {
- $absolutePath = $this->getAbsolutePath($path);
- $mount = Filesystem::getMountManager()->find($absolutePath);
- if ($mount->getInternalPath($absolutePath) === '') {
- return $this->removeMount($mount, $absolutePath);
- }
- if ($this->is_dir($path)) {
- $result = $this->basicOperation('rmdir', $path, ['delete']);
- } else {
- $result = false;
- }
- if (!$result && !$this->file_exists($path)) { //clear ghost files from the cache on delete
- $storage = $mount->getStorage();
- $internalPath = $mount->getInternalPath($absolutePath);
- $storage->getUpdater()->remove($internalPath);
- }
- return $result;
- }
- /**
- * @param string $path
- * @return resource|false
- */
- public function opendir($path) {
- return $this->basicOperation('opendir', $path, ['read']);
- }
- /**
- * @param string $path
- * @return bool|mixed
- */
- public function is_dir($path) {
- if ($path == '/') {
- return true;
- }
- return $this->basicOperation('is_dir', $path);
- }
- /**
- * @param string $path
- * @return bool|mixed
- */
- public function is_file($path) {
- if ($path == '/') {
- return false;
- }
- return $this->basicOperation('is_file', $path);
- }
- /**
- * @param string $path
- * @return mixed
- */
- public function stat($path) {
- return $this->basicOperation('stat', $path);
- }
- /**
- * @param string $path
- * @return mixed
- */
- public function filetype($path) {
- return $this->basicOperation('filetype', $path);
- }
- /**
- * @param string $path
- * @return mixed
- */
- public function filesize(string $path) {
- return $this->basicOperation('filesize', $path);
- }
- /**
- * @param string $path
- * @return bool|mixed
- * @throws InvalidPathException
- */
- public function readfile($path) {
- $this->assertPathLength($path);
- if (ob_get_level()) {
- ob_end_clean();
- }
- $handle = $this->fopen($path, 'rb');
- if ($handle) {
- $chunkSize = 524288; // 512 kiB chunks
- while (!feof($handle)) {
- echo fread($handle, $chunkSize);
- flush();
- $this->checkConnectionStatus();
- }
- fclose($handle);
- return $this->filesize($path);
- }
- return false;
- }
- /**
- * @param string $path
- * @param int $from
- * @param int $to
- * @return bool|mixed
- * @throws InvalidPathException
- * @throws \OCP\Files\UnseekableException
- */
- public function readfilePart($path, $from, $to) {
- $this->assertPathLength($path);
- if (ob_get_level()) {
- ob_end_clean();
- }
- $handle = $this->fopen($path, 'rb');
- if ($handle) {
- $chunkSize = 524288; // 512 kiB chunks
- $startReading = true;
- if ($from !== 0 && $from !== '0' && fseek($handle, $from) !== 0) {
- // forward file handle via chunked fread because fseek seem to have failed
- $end = $from + 1;
- while (!feof($handle) && ftell($handle) < $end && ftell($handle) !== $from) {
- $len = $from - ftell($handle);
- if ($len > $chunkSize) {
- $len = $chunkSize;
- }
- $result = fread($handle, $len);
- if ($result === false) {
- $startReading = false;
- break;
- }
- }
- }
- if ($startReading) {
- $end = $to + 1;
- while (!feof($handle) && ftell($handle) < $end) {
- $len = $end - ftell($handle);
- if ($len > $chunkSize) {
- $len = $chunkSize;
- }
- echo fread($handle, $len);
- flush();
- $this->checkConnectionStatus();
- }
- return ftell($handle) - $from;
- }
- throw new \OCP\Files\UnseekableException('fseek error');
- }
- return false;
- }
- private function checkConnectionStatus(): void {
- $connectionStatus = \connection_status();
- if ($connectionStatus !== CONNECTION_NORMAL) {
- throw new ConnectionLostException("Connection lost. Status: $connectionStatus");
- }
- }
- /**
- * @param string $path
- * @return mixed
- */
- public function isCreatable($path) {
- return $this->basicOperation('isCreatable', $path);
- }
- /**
- * @param string $path
- * @return mixed
- */
- public function isReadable($path) {
- return $this->basicOperation('isReadable', $path);
- }
- /**
- * @param string $path
- * @return mixed
- */
- public function isUpdatable($path) {
- return $this->basicOperation('isUpdatable', $path);
- }
- /**
- * @param string $path
- * @return bool|mixed
- */
- public function isDeletable($path) {
- $absolutePath = $this->getAbsolutePath($path);
- $mount = Filesystem::getMountManager()->find($absolutePath);
- if ($mount->getInternalPath($absolutePath) === '') {
- return $mount instanceof MoveableMount;
- }
- return $this->basicOperation('isDeletable', $path);
- }
- /**
- * @param string $path
- * @return mixed
- */
- public function isSharable($path) {
- return $this->basicOperation('isSharable', $path);
- }
- /**
- * @param string $path
- * @return bool|mixed
- */
- public function file_exists($path) {
- if ($path == '/') {
- return true;
- }
- return $this->basicOperation('file_exists', $path);
- }
- /**
- * @param string $path
- * @return mixed
- */
- public function filemtime($path) {
- return $this->basicOperation('filemtime', $path);
- }
- /**
- * @param string $path
- * @param int|string $mtime
- */
- public function touch($path, $mtime = null): bool {
- if (!is_null($mtime) && !is_numeric($mtime)) {
- $mtime = strtotime($mtime);
- }
- $hooks = ['touch'];
- if (!$this->file_exists($path)) {
- $hooks[] = 'create';
- $hooks[] = 'write';
- }
- try {
- $result = $this->basicOperation('touch', $path, $hooks, $mtime);
- } catch (\Exception $e) {
- $this->logger->info('Error while setting modified time', ['app' => 'core', 'exception' => $e]);
- $result = false;
- }
- if (!$result) {
- // If create file fails because of permissions on external storage like SMB folders,
- // check file exists and return false if not.
- if (!$this->file_exists($path)) {
- return false;
- }
- if (is_null($mtime)) {
- $mtime = time();
- }
- //if native touch fails, we emulate it by changing the mtime in the cache
- $this->putFileInfo($path, ['mtime' => floor($mtime)]);
- }
- return true;
- }
- /**
- * @param string $path
- * @return string|false
- * @throws LockedException
- */
- public function file_get_contents($path) {
- return $this->basicOperation('file_get_contents', $path, ['read']);
- }
- protected function emit_file_hooks_pre(bool $exists, string $path, bool &$run): void {
- if (!$exists) {
- \OC_Hook::emit(Filesystem::CLASSNAME, Filesystem::signal_create, [
- Filesystem::signal_param_path => $this->getHookPath($path),
- Filesystem::signal_param_run => &$run,
- ]);
- } else {
- \OC_Hook::emit(Filesystem::CLASSNAME, Filesystem::signal_update, [
- Filesystem::signal_param_path => $this->getHookPath($path),
- Filesystem::signal_param_run => &$run,
- ]);
- }
- \OC_Hook::emit(Filesystem::CLASSNAME, Filesystem::signal_write, [
- Filesystem::signal_param_path => $this->getHookPath($path),
- Filesystem::signal_param_run => &$run,
- ]);
- }
- protected function emit_file_hooks_post(bool $exists, string $path): void {
- if (!$exists) {
- \OC_Hook::emit(Filesystem::CLASSNAME, Filesystem::signal_post_create, [
- Filesystem::signal_param_path => $this->getHookPath($path),
- ]);
- } else {
- \OC_Hook::emit(Filesystem::CLASSNAME, Filesystem::signal_post_update, [
- Filesystem::signal_param_path => $this->getHookPath($path),
- ]);
- }
- \OC_Hook::emit(Filesystem::CLASSNAME, Filesystem::signal_post_write, [
- Filesystem::signal_param_path => $this->getHookPath($path),
- ]);
- }
- /**
- * @param string $path
- * @param string|resource $data
- * @return bool|mixed
- * @throws LockedException
- */
- public function file_put_contents($path, $data) {
- if (is_resource($data)) { //not having to deal with streams in file_put_contents makes life easier
- $absolutePath = Filesystem::normalizePath($this->getAbsolutePath($path));
- if (Filesystem::isValidPath($path)
- && !Filesystem::isFileBlacklisted($path)
- ) {
- $path = $this->getRelativePath($absolutePath);
- if ($path === null) {
- throw new InvalidPathException("Path $absolutePath is not in the expected root");
- }
- $this->lockFile($path, ILockingProvider::LOCK_SHARED);
- $exists = $this->file_exists($path);
- $run = true;
- if ($this->shouldEmitHooks($path)) {
- $this->emit_file_hooks_pre($exists, $path, $run);
- }
- if (!$run) {
- $this->unlockFile($path, ILockingProvider::LOCK_SHARED);
- return false;
- }
- try {
- $this->changeLock($path, ILockingProvider::LOCK_EXCLUSIVE);
- } catch (\Exception $e) {
- // Release the shared lock before throwing.
- $this->unlockFile($path, ILockingProvider::LOCK_SHARED);
- throw $e;
- }
- /** @var Storage $storage */
- [$storage, $internalPath] = $this->resolvePath($path);
- $target = $storage->fopen($internalPath, 'w');
- if ($target) {
- [, $result] = \OC_Helper::streamCopy($data, $target);
- fclose($target);
- fclose($data);
- $this->writeUpdate($storage, $internalPath);
- $this->changeLock($path, ILockingProvider::LOCK_SHARED);
- if ($this->shouldEmitHooks($path) && $result !== false) {
- $this->emit_file_hooks_post($exists, $path);
- }
- $this->unlockFile($path, ILockingProvider::LOCK_SHARED);
- return $result;
- } else {
- $this->unlockFile($path, ILockingProvider::LOCK_EXCLUSIVE);
- return false;
- }
- } else {
- return false;
- }
- } else {
- $hooks = $this->file_exists($path) ? ['update', 'write'] : ['create', 'write'];
- return $this->basicOperation('file_put_contents', $path, $hooks, $data);
- }
- }
- /**
- * @param string $path
- * @return bool|mixed
- */
- public function unlink($path) {
- if ($path === '' || $path === '/') {
- // do not allow deleting the root
- return false;
- }
- $postFix = (substr($path, -1) === '/') ? '/' : '';
- $absolutePath = Filesystem::normalizePath($this->getAbsolutePath($path));
- $mount = Filesystem::getMountManager()->find($absolutePath . $postFix);
- if ($mount->getInternalPath($absolutePath) === '') {
- return $this->removeMount($mount, $absolutePath);
- }
- if ($this->is_dir($path)) {
- $result = $this->basicOperation('rmdir', $path, ['delete']);
- } else {
- $result = $this->basicOperation('unlink', $path, ['delete']);
- }
- if (!$result && !$this->file_exists($path)) { //clear ghost files from the cache on delete
- $storage = $mount->getStorage();
- $internalPath = $mount->getInternalPath($absolutePath);
- $storage->getUpdater()->remove($internalPath);
- return true;
- } else {
- return $result;
- }
- }
- /**
- * @param string $directory
- * @return bool|mixed
- */
- public function deleteAll($directory) {
- return $this->rmdir($directory);
- }
- /**
- * Rename/move a file or folder from the source path to target path.
- *
- * @param string $source source path
- * @param string $target target path
- *
- * @return bool|mixed
- * @throws LockedException
- */
- public function rename($source, $target) {
- $absolutePath1 = Filesystem::normalizePath($this->getAbsolutePath($source));
- $absolutePath2 = Filesystem::normalizePath($this->getAbsolutePath($target));
- if (str_starts_with($absolutePath2, $absolutePath1 . '/')) {
- throw new ForbiddenException("Moving a folder into a child folder is forbidden", false);
- }
- $targetParts = explode('/', $absolutePath2);
- $targetUser = $targetParts[1] ?? null;
- $result = false;
- if (
- Filesystem::isValidPath($target)
- && Filesystem::isValidPath($source)
- && !Filesystem::isFileBlacklisted($target)
- ) {
- $source = $this->getRelativePath($absolutePath1);
- $target = $this->getRelativePath($absolutePath2);
- $exists = $this->file_exists($target);
- if ($source == null || $target == null) {
- return false;
- }
- try {
- $this->verifyPath(dirname($target), basename($target));
- } catch (InvalidPathException) {
- return false;
- }
- $this->lockFile($source, ILockingProvider::LOCK_SHARED, true);
- try {
- $this->lockFile($target, ILockingProvider::LOCK_SHARED, true);
- $run = true;
- if ($this->shouldEmitHooks($source) && (Cache\Scanner::isPartialFile($source) && !Cache\Scanner::isPartialFile($target))) {
- // if it was a rename from a part file to a regular file it was a write and not a rename operation
- $this->emit_file_hooks_pre($exists, $target, $run);
- } elseif ($this->shouldEmitHooks($source)) {
- $sourcePath = $this->getHookPath($source);
- $targetPath = $this->getHookPath($target);
- if ($sourcePath !== null && $targetPath !== null) {
- \OC_Hook::emit(
- Filesystem::CLASSNAME, Filesystem::signal_rename,
- [
- Filesystem::signal_param_oldpath => $sourcePath,
- Filesystem::signal_param_newpath => $targetPath,
- Filesystem::signal_param_run => &$run
- ]
- );
- }
- }
- if ($run) {
- $manager = Filesystem::getMountManager();
- $mount1 = $this->getMount($source);
- $mount2 = $this->getMount($target);
- $storage1 = $mount1->getStorage();
- $storage2 = $mount2->getStorage();
- $internalPath1 = $mount1->getInternalPath($absolutePath1);
- $internalPath2 = $mount2->getInternalPath($absolutePath2);
- $this->changeLock($source, ILockingProvider::LOCK_EXCLUSIVE, true);
- try {
- $this->changeLock($target, ILockingProvider::LOCK_EXCLUSIVE, true);
- if ($internalPath1 === '') {
- if ($mount1 instanceof MoveableMount) {
- $sourceParentMount = $this->getMount(dirname($source));
- if ($sourceParentMount === $mount2 && $this->targetIsNotShared($targetUser, $absolutePath2)) {
- /**
- * @var \OC\Files\Mount\MountPoint | \OC\Files\Mount\MoveableMount $mount1
- */
- $sourceMountPoint = $mount1->getMountPoint();
- $result = $mount1->moveMount($absolutePath2);
- $manager->moveMount($sourceMountPoint, $mount1->getMountPoint());
- } else {
- $result = false;
- }
- } else {
- $result = false;
- }
- // moving a file/folder within the same mount point
- } elseif ($storage1 === $storage2) {
- if ($storage1) {
- $result = $storage1->rename($internalPath1, $internalPath2);
- } else {
- $result = false;
- }
- // moving a file/folder between storages (from $storage1 to $storage2)
- } else {
- $result = $storage2->moveFromStorage($storage1, $internalPath1, $internalPath2);
- }
- if ((Cache\Scanner::isPartialFile($source) && !Cache\Scanner::isPartialFile($target)) && $result !== false) {
- // if it was a rename from a part file to a regular file it was a write and not a rename operation
- $this->writeUpdate($storage2, $internalPath2);
- } elseif ($result) {
- if ($internalPath1 !== '') { // don't do a cache update for moved mounts
- $this->renameUpdate($storage1, $storage2, $internalPath1, $internalPath2);
- }
- }
- } catch (\Exception $e) {
- throw $e;
- } finally {
- $this->changeLock($source, ILockingProvider::LOCK_SHARED, true);
- $this->changeLock($target, ILockingProvider::LOCK_SHARED, true);
- }
- if ((Cache\Scanner::isPartialFile($source) && !Cache\Scanner::isPartialFile($target)) && $result !== false) {
- if ($this->shouldEmitHooks()) {
- $this->emit_file_hooks_post($exists, $target);
- }
- } elseif ($result) {
- if ($this->shouldEmitHooks($source) && $this->shouldEmitHooks($target)) {
- $sourcePath = $this->getHookPath($source);
- $targetPath = $this->getHookPath($target);
- if ($sourcePath !== null && $targetPath !== null) {
- \OC_Hook::emit(
- Filesystem::CLASSNAME,
- Filesystem::signal_post_rename,
- [
- Filesystem::signal_param_oldpath => $sourcePath,
- Filesystem::signal_param_newpath => $targetPath,
- ]
- );
- }
- }
- }
- }
- } catch (\Exception $e) {
- throw $e;
- } finally {
- $this->unlockFile($source, ILockingProvider::LOCK_SHARED, true);
- $this->unlockFile($target, ILockingProvider::LOCK_SHARED, true);
- }
- }
- return $result;
- }
- /**
- * Copy a file/folder from the source path to target path
- *
- * @param string $source source path
- * @param string $target target path
- * @param bool $preserveMtime whether to preserve mtime on the copy
- *
- * @return bool|mixed
- */
- public function copy($source, $target, $preserveMtime = false) {
- $absolutePath1 = Filesystem::normalizePath($this->getAbsolutePath($source));
- $absolutePath2 = Filesystem::normalizePath($this->getAbsolutePath($target));
- $result = false;
- if (
- Filesystem::isValidPath($target)
- && Filesystem::isValidPath($source)
- && !Filesystem::isFileBlacklisted($target)
- ) {
- $source = $this->getRelativePath($absolutePath1);
- $target = $this->getRelativePath($absolutePath2);
- if ($source == null || $target == null) {
- return false;
- }
- $run = true;
- $this->lockFile($target, ILockingProvider::LOCK_SHARED);
- $this->lockFile($source, ILockingProvider::LOCK_SHARED);
- $lockTypePath1 = ILockingProvider::LOCK_SHARED;
- $lockTypePath2 = ILockingProvider::LOCK_SHARED;
- try {
- $exists = $this->file_exists($target);
- if ($this->shouldEmitHooks()) {
- \OC_Hook::emit(
- Filesystem::CLASSNAME,
- Filesystem::signal_copy,
- [
- Filesystem::signal_param_oldpath => $this->getHookPath($source),
- Filesystem::signal_param_newpath => $this->getHookPath($target),
- Filesystem::signal_param_run => &$run
- ]
- );
- $this->emit_file_hooks_pre($exists, $target, $run);
- }
- if ($run) {
- $mount1 = $this->getMount($source);
- $mount2 = $this->getMount($target);
- $storage1 = $mount1->getStorage();
- $internalPath1 = $mount1->getInternalPath($absolutePath1);
- $storage2 = $mount2->getStorage();
- $internalPath2 = $mount2->getInternalPath($absolutePath2);
- $this->changeLock($target, ILockingProvider::LOCK_EXCLUSIVE);
- $lockTypePath2 = ILockingProvider::LOCK_EXCLUSIVE;
- if ($mount1->getMountPoint() == $mount2->getMountPoint()) {
- if ($storage1) {
- $result = $storage1->copy($internalPath1, $internalPath2);
- } else {
- $result = false;
- }
- } else {
- $result = $storage2->copyFromStorage($storage1, $internalPath1, $internalPath2);
- }
- $this->writeUpdate($storage2, $internalPath2);
- $this->changeLock($target, ILockingProvider::LOCK_SHARED);
- $lockTypePath2 = ILockingProvider::LOCK_SHARED;
- if ($this->shouldEmitHooks() && $result !== false) {
- \OC_Hook::emit(
- Filesystem::CLASSNAME,
- Filesystem::signal_post_copy,
- [
- Filesystem::signal_param_oldpath => $this->getHookPath($source),
- Filesystem::signal_param_newpath => $this->getHookPath($target)
- ]
- );
- $this->emit_file_hooks_post($exists, $target);
- }
- }
- } catch (\Exception $e) {
- $this->unlockFile($target, $lockTypePath2);
- $this->unlockFile($source, $lockTypePath1);
- throw $e;
- }
- $this->unlockFile($target, $lockTypePath2);
- $this->unlockFile($source, $lockTypePath1);
- }
- return $result;
- }
- /**
- * @param string $path
- * @param string $mode 'r' or 'w'
- * @return resource|false
- * @throws LockedException
- */
- public function fopen($path, $mode) {
- $mode = str_replace('b', '', $mode); // the binary flag is a windows only feature which we do not support
- $hooks = [];
- switch ($mode) {
- case 'r':
- $hooks[] = 'read';
- break;
- case 'r+':
- case 'w+':
- case 'x+':
- case 'a+':
- $hooks[] = 'read';
- $hooks[] = 'write';
- break;
- case 'w':
- case 'x':
- case 'a':
- $hooks[] = 'write';
- break;
- default:
- $this->logger->error('invalid mode (' . $mode . ') for ' . $path, ['app' => 'core']);
- }
- if ($mode !== 'r' && $mode !== 'w') {
- $this->logger->info('Trying to open a file with a mode other than "r" or "w" can cause severe performance issues with some backends', ['app' => 'core']);
- }
- $handle = $this->basicOperation('fopen', $path, $hooks, $mode);
- if (!is_resource($handle) && $mode === 'r') {
- // trying to read a file that isn't on disk, check if the cache is out of sync and rescan if needed
- $mount = $this->getMount($path);
- $internalPath = $mount->getInternalPath($this->getAbsolutePath($path));
- $storage = $mount->getStorage();
- if ($storage->getCache()->inCache($internalPath) && !$storage->file_exists($path)) {
- $this->writeUpdate($storage, $internalPath);
- }
- }
- return $handle;
- }
- /**
- * @param string $path
- * @throws InvalidPathException
- */
- public function toTmpFile($path): string|false {
- $this->assertPathLength($path);
- if (Filesystem::isValidPath($path)) {
- $source = $this->fopen($path, 'r');
- if ($source) {
- $extension = pathinfo($path, PATHINFO_EXTENSION);
- $tmpFile = \OC::$server->getTempManager()->getTemporaryFile($extension);
- file_put_contents($tmpFile, $source);
- return $tmpFile;
- } else {
- return false;
- }
- } else {
- return false;
- }
- }
- /**
- * @param string $tmpFile
- * @param string $path
- * @return bool|mixed
- * @throws InvalidPathException
- */
- public function fromTmpFile($tmpFile, $path) {
- $this->assertPathLength($path);
- if (Filesystem::isValidPath($path)) {
- // Get directory that the file is going into
- $filePath = dirname($path);
- // Create the directories if any
- if (!$this->file_exists($filePath)) {
- $result = $this->createParentDirectories($filePath);
- if ($result === false) {
- return false;
- }
- }
- $source = fopen($tmpFile, 'r');
- if ($source) {
- $result = $this->file_put_contents($path, $source);
- /**
- * $this->file_put_contents() might have already closed
- * the resource, so we check it, before trying to close it
- * to avoid messages in the error log.
- * @psalm-suppress RedundantCondition false-positive
- */
- if (is_resource($source)) {
- fclose($source);
- }
- unlink($tmpFile);
- return $result;
- } else {
- return false;
- }
- } else {
- return false;
- }
- }
- /**
- * @param string $path
- * @return mixed
- * @throws InvalidPathException
- */
- public function getMimeType($path) {
- $this->assertPathLength($path);
- return $this->basicOperation('getMimeType', $path);
- }
- /**
- * @param string $type
- * @param string $path
- * @param bool $raw
- */
- public function hash($type, $path, $raw = false): string|bool {
- $postFix = (substr($path, -1) === '/') ? '/' : '';
- $absolutePath = Filesystem::normalizePath($this->getAbsolutePath($path));
- if (Filesystem::isValidPath($path)) {
- $path = $this->getRelativePath($absolutePath);
- if ($path == null) {
- return false;
- }
- if ($this->shouldEmitHooks($path)) {
- \OC_Hook::emit(
- Filesystem::CLASSNAME,
- Filesystem::signal_read,
- [Filesystem::signal_param_path => $this->getHookPath($path)]
- );
- }
- /** @var Storage|null $storage */
- [$storage, $internalPath] = Filesystem::resolvePath($absolutePath . $postFix);
- if ($storage) {
- return $storage->hash($type, $internalPath, $raw);
- }
- }
- return false;
- }
- /**
- * @param string $path
- * @return mixed
- * @throws InvalidPathException
- */
- public function free_space($path = '/') {
- $this->assertPathLength($path);
- $result = $this->basicOperation('free_space', $path);
- if ($result === null) {
- throw new InvalidPathException();
- }
- return $result;
- }
- /**
- * abstraction layer for basic filesystem functions: wrapper for \OC\Files\Storage\Storage
- *
- * @param mixed $extraParam (optional)
- * @return mixed
- * @throws LockedException
- *
- * This method takes requests for basic filesystem functions (e.g. reading & writing
- * files), processes hooks and proxies, sanitises paths, and finally passes them on to
- * \OC\Files\Storage\Storage for delegation to a storage backend for execution
- */
- private function basicOperation(string $operation, string $path, array $hooks = [], $extraParam = null) {
- $postFix = (substr($path, -1) === '/') ? '/' : '';
- $absolutePath = Filesystem::normalizePath($this->getAbsolutePath($path));
- if (Filesystem::isValidPath($path)
- && !Filesystem::isFileBlacklisted($path)
- ) {
- $path = $this->getRelativePath($absolutePath);
- if ($path == null) {
- return false;
- }
- if (in_array('write', $hooks) || in_array('delete', $hooks) || in_array('read', $hooks)) {
- // always a shared lock during pre-hooks so the hook can read the file
- $this->lockFile($path, ILockingProvider::LOCK_SHARED);
- }
- $run = $this->runHooks($hooks, $path);
- [$storage, $internalPath] = Filesystem::resolvePath($absolutePath . $postFix);
- if ($run && $storage) {
- /** @var Storage $storage */
- if (in_array('write', $hooks) || in_array('delete', $hooks)) {
- try {
- $this->changeLock($path, ILockingProvider::LOCK_EXCLUSIVE);
- } catch (LockedException $e) {
- // release the shared lock we acquired before quitting
- $this->unlockFile($path, ILockingProvider::LOCK_SHARED);
- throw $e;
- }
- }
- try {
- if (!is_null($extraParam)) {
- $result = $storage->$operation($internalPath, $extraParam);
- } else {
- $result = $storage->$operation($internalPath);
- }
- } catch (\Exception $e) {
- if (in_array('write', $hooks) || in_array('delete', $hooks)) {
- $this->unlockFile($path, ILockingProvider::LOCK_EXCLUSIVE);
- } elseif (in_array('read', $hooks)) {
- $this->unlockFile($path, ILockingProvider::LOCK_SHARED);
- }
- throw $e;
- }
- if ($result !== false && in_array('delete', $hooks)) {
- $this->removeUpdate($storage, $internalPath);
- }
- if ($result !== false && in_array('write', $hooks, true) && $operation !== 'fopen' && $operation !== 'touch') {
- $isCreateOperation = $operation === 'mkdir' || ($operation === 'file_put_contents' && in_array('create', $hooks, true));
- $sizeDifference = $operation === 'mkdir' ? 0 : $result;
- $this->writeUpdate($storage, $internalPath, null, $isCreateOperation ? $sizeDifference : null);
- }
- if ($result !== false && in_array('touch', $hooks)) {
- $this->writeUpdate($storage, $internalPath, $extraParam, 0);
- }
- if ((in_array('write', $hooks) || in_array('delete', $hooks)) && ($operation !== 'fopen' || $result === false)) {
- $this->changeLock($path, ILockingProvider::LOCK_SHARED);
- }
- $unlockLater = false;
- if ($this->lockingEnabled && $operation === 'fopen' && is_resource($result)) {
- $unlockLater = true;
- // make sure our unlocking callback will still be called if connection is aborted
- ignore_user_abort(true);
- $result = CallbackWrapper::wrap($result, null, null, function () use ($hooks, $path) {
- if (in_array('write', $hooks)) {
- $this->unlockFile($path, ILockingProvider::LOCK_EXCLUSIVE);
- } elseif (in_array('read', $hooks)) {
- $this->unlockFile($path, ILockingProvider::LOCK_SHARED);
- }
- });
- }
- if ($this->shouldEmitHooks($path) && $result !== false) {
- if ($operation != 'fopen') { //no post hooks for fopen, the file stream is still open
- $this->runHooks($hooks, $path, true);
- }
- }
- if (!$unlockLater
- && (in_array('write', $hooks) || in_array('delete', $hooks) || in_array('read', $hooks))
- ) {
- $this->unlockFile($path, ILockingProvider::LOCK_SHARED);
- }
- return $result;
- } else {
- $this->unlockFile($path, ILockingProvider::LOCK_SHARED);
- }
- }
- return null;
- }
- /**
- * get the path relative to the default root for hook usage
- *
- * @param string $path
- * @return ?string
- */
- private function getHookPath($path): ?string {
- $view = Filesystem::getView();
- if (!$view) {
- return $path;
- }
- return $view->getRelativePath($this->getAbsolutePath($path));
- }
- private function shouldEmitHooks(string $path = ''): bool {
- if ($path && Cache\Scanner::isPartialFile($path)) {
- return false;
- }
- if (!Filesystem::$loaded) {
- return false;
- }
- $defaultRoot = Filesystem::getRoot();
- if ($defaultRoot === null) {
- return false;
- }
- if ($this->fakeRoot === $defaultRoot) {
- return true;
- }
- $fullPath = $this->getAbsolutePath($path);
- if ($fullPath === $defaultRoot) {
- return true;
- }
- return (strlen($fullPath) > strlen($defaultRoot)) && (substr($fullPath, 0, strlen($defaultRoot) + 1) === $defaultRoot . '/');
- }
- /**
- * @param string[] $hooks
- * @param string $path
- * @param bool $post
- * @return bool
- */
- private function runHooks($hooks, $path, $post = false) {
- $relativePath = $path;
- $path = $this->getHookPath($path);
- $prefix = $post ? 'post_' : '';
- $run = true;
- if ($this->shouldEmitHooks($relativePath)) {
- foreach ($hooks as $hook) {
- if ($hook != 'read') {
- \OC_Hook::emit(
- Filesystem::CLASSNAME,
- $prefix . $hook,
- [
- Filesystem::signal_param_run => &$run,
- Filesystem::signal_param_path => $path
- ]
- );
- } elseif (!$post) {
- \OC_Hook::emit(
- Filesystem::CLASSNAME,
- $prefix . $hook,
- [
- Filesystem::signal_param_path => $path
- ]
- );
- }
- }
- }
- return $run;
- }
- /**
- * check if a file or folder has been updated since $time
- *
- * @param string $path
- * @param int $time
- * @return bool
- */
- public function hasUpdated($path, $time) {
- return $this->basicOperation('hasUpdated', $path, [], $time);
- }
- /**
- * @param string $ownerId
- * @return IUser
- */
- private function getUserObjectForOwner(string $ownerId) {
- return new LazyUser($ownerId, $this->userManager);
- }
- /**
- * Get file info from cache
- *
- * If the file is not in cached it will be scanned
- * If the file has changed on storage the cache will be updated
- *
- * @param Storage $storage
- * @param string $internalPath
- * @param string $relativePath
- * @return ICacheEntry|bool
- */
- private function getCacheEntry($storage, $internalPath, $relativePath) {
- $cache = $storage->getCache($internalPath);
- $data = $cache->get($internalPath);
- $watcher = $storage->getWatcher($internalPath);
- try {
- // if the file is not in the cache or needs to be updated, trigger the scanner and reload the data
- if (!$data || (isset($data['size']) && $data['size'] === -1)) {
- if (!$storage->file_exists($internalPath)) {
- return false;
- }
- // don't need to get a lock here since the scanner does it's own locking
- $scanner = $storage->getScanner($internalPath);
- $scanner->scan($internalPath, Cache\Scanner::SCAN_SHALLOW);
- $data = $cache->get($internalPath);
- } elseif (!Cache\Scanner::isPartialFile($internalPath) && $watcher->needsUpdate($internalPath, $data)) {
- $this->lockFile($relativePath, ILockingProvider::LOCK_SHARED);
- $watcher->update($internalPath, $data);
- $storage->getPropagator()->propagateChange($internalPath, time());
- $data = $cache->get($internalPath);
- $this->unlockFile($relativePath, ILockingProvider::LOCK_SHARED);
- }
- } catch (LockedException $e) {
- // if the file is locked we just use the old cache info
- }
- return $data;
- }
- /**
- * get the filesystem info
- *
- * @param string $path
- * @param bool|string $includeMountPoints true to add mountpoint sizes,
- * 'ext' to add only ext storage mount point sizes. Defaults to true.
- * @return \OC\Files\FileInfo|false False if file does not exist
- */
- public function getFileInfo($path, $includeMountPoints = true) {
- $this->assertPathLength($path);
- if (!Filesystem::isValidPath($path)) {
- return false;
- }
- $relativePath = $path;
- $path = Filesystem::normalizePath($this->fakeRoot . '/' . $path);
- $mount = Filesystem::getMountManager()->find($path);
- $storage = $mount->getStorage();
- $internalPath = $mount->getInternalPath($path);
- if ($storage) {
- $data = $this->getCacheEntry($storage, $internalPath, $relativePath);
- if (!$data instanceof ICacheEntry) {
- if (Cache\Scanner::isPartialFile($relativePath)) {
- return $this->getPartFileInfo($relativePath);
- }
- return false;
- }
- if ($mount instanceof MoveableMount && $internalPath === '') {
- $data['permissions'] |= \OCP\Constants::PERMISSION_DELETE;
- }
- if ($internalPath === '' && $data['name']) {
- $data['name'] = basename($path);
- }
- $ownerId = $storage->getOwner($internalPath);
- $owner = null;
- if ($ownerId !== null && $ownerId !== false) {
- // ownerId might be null if files are accessed with an access token without file system access
- $owner = $this->getUserObjectForOwner($ownerId);
- }
- $info = new FileInfo($path, $storage, $internalPath, $data, $mount, $owner);
- if (isset($data['fileid'])) {
- if ($includeMountPoints && $data['mimetype'] === 'httpd/unix-directory') {
- //add the sizes of other mount points to the folder
- $extOnly = ($includeMountPoints === 'ext');
- $this->addSubMounts($info, $extOnly);
- }
- }
- return $info;
- } else {
- $this->logger->warning('Storage not valid for mountpoint: ' . $mount->getMountPoint(), ['app' => 'core']);
- }
- return false;
- }
- /**
- * Extend a FileInfo that was previously requested with `$includeMountPoints = false` to include the sub mounts
- */
- public function addSubMounts(FileInfo $info, $extOnly = false): void {
- $mounts = Filesystem::getMountManager()->findIn($info->getPath());
- $info->setSubMounts(array_filter($mounts, function (IMountPoint $mount) use ($extOnly) {
- $subStorage = $mount->getStorage();
- return !($extOnly && $subStorage instanceof \OCA\Files_Sharing\SharedStorage);
- }));
- }
- /**
- * get the content of a directory
- *
- * @param string $directory path under datadirectory
- * @param string $mimetype_filter limit returned content to this mimetype or mimepart
- * @return FileInfo[]
- */
- public function getDirectoryContent($directory, $mimetype_filter = '', ?\OCP\Files\FileInfo $directoryInfo = null) {
- $this->assertPathLength($directory);
- if (!Filesystem::isValidPath($directory)) {
- return [];
- }
- $path = $this->getAbsolutePath($directory);
- $path = Filesystem::normalizePath($path);
- $mount = $this->getMount($directory);
- $storage = $mount->getStorage();
- $internalPath = $mount->getInternalPath($path);
- if (!$storage) {
- return [];
- }
- $cache = $storage->getCache($internalPath);
- $user = \OC_User::getUser();
- if (!$directoryInfo) {
- $data = $this->getCacheEntry($storage, $internalPath, $directory);
- if (!$data instanceof ICacheEntry || !isset($data['fileid'])) {
- return [];
- }
- } else {
- $data = $directoryInfo;
- }
- if (!($data->getPermissions() & Constants::PERMISSION_READ)) {
- return [];
- }
- $folderId = $data->getId();
- $contents = $cache->getFolderContentsById($folderId); //TODO: mimetype_filter
- $sharingDisabled = \OCP\Util::isSharingDisabledForUser();
- $fileNames = array_map(function (ICacheEntry $content) {
- return $content->getName();
- }, $contents);
- /**
- * @var \OC\Files\FileInfo[] $fileInfos
- */
- $fileInfos = array_map(function (ICacheEntry $content) use ($path, $storage, $mount, $sharingDisabled) {
- if ($sharingDisabled) {
- $content['permissions'] = $content['permissions'] & ~\OCP\Constants::PERMISSION_SHARE;
- }
- $owner = $this->getUserObjectForOwner($storage->getOwner($content['path']));
- return new FileInfo($path . '/' . $content['name'], $storage, $content['path'], $content, $mount, $owner);
- }, $contents);
- $files = array_combine($fileNames, $fileInfos);
- //add a folder for any mountpoint in this directory and add the sizes of other mountpoints to the folders
- $mounts = Filesystem::getMountManager()->findIn($path);
- // make sure nested mounts are sorted after their parent mounts
- // otherwise doesn't propagate the etag across storage boundaries correctly
- usort($mounts, function (IMountPoint $a, IMountPoint $b) {
- return $a->getMountPoint() <=> $b->getMountPoint();
- });
- $dirLength = strlen($path);
- foreach ($mounts as $mount) {
- $mountPoint = $mount->getMountPoint();
- $subStorage = $mount->getStorage();
- if ($subStorage) {
- $subCache = $subStorage->getCache('');
- $rootEntry = $subCache->get('');
- if (!$rootEntry) {
- $subScanner = $subStorage->getScanner();
- try {
- $subScanner->scanFile('');
- } catch (\OCP\Files\StorageNotAvailableException $e) {
- continue;
- } catch (\OCP\Files\StorageInvalidException $e) {
- continue;
- } catch (\Exception $e) {
- // sometimes when the storage is not available it can be any exception
- $this->logger->error('Exception while scanning storage "' . $subStorage->getId() . '"', [
- 'exception' => $e,
- 'app' => 'core',
- ]);
- continue;
- }
- $rootEntry = $subCache->get('');
- }
- if ($rootEntry && ($rootEntry->getPermissions() & Constants::PERMISSION_READ)) {
- $relativePath = trim(substr($mountPoint, $dirLength), '/');
- if ($pos = strpos($relativePath, '/')) {
- //mountpoint inside subfolder add size to the correct folder
- $entryName = substr($relativePath, 0, $pos);
- // Create parent folders if the mountpoint is inside a subfolder that doesn't exist yet
- if (!isset($files[$entryName]) && $this->mkdir($path . '/' . $entryName) !== false) {
- $info = $this->getFileInfo($path . '/' . $entryName);
- if ($info !== false) {
- $files[$entryName] = $info;
- }
- }
- if (isset($files[$entryName])) {
- $files[$entryName]->addSubEntry($rootEntry, $mountPoint);
- }
- } else { //mountpoint in this folder, add an entry for it
- $rootEntry['name'] = $relativePath;
- $rootEntry['type'] = $rootEntry['mimetype'] === 'httpd/unix-directory' ? 'dir' : 'file';
- $permissions = $rootEntry['permissions'];
- // do not allow renaming/deleting the mount point if they are not shared files/folders
- // for shared files/folders we use the permissions given by the owner
- if ($mount instanceof MoveableMount) {
- $rootEntry['permissions'] = $permissions | \OCP\Constants::PERMISSION_UPDATE | \OCP\Constants::PERMISSION_DELETE;
- } else {
- $rootEntry['permissions'] = $permissions & (\OCP\Constants::PERMISSION_ALL - (\OCP\Constants::PERMISSION_UPDATE | \OCP\Constants::PERMISSION_DELETE));
- }
- $rootEntry['path'] = substr(Filesystem::normalizePath($path . '/' . $rootEntry['name']), strlen($user) + 2); // full path without /$user/
- // if sharing was disabled for the user we remove the share permissions
- if ($sharingDisabled) {
- $rootEntry['permissions'] = $rootEntry['permissions'] & ~\OCP\Constants::PERMISSION_SHARE;
- }
- $owner = $this->getUserObjectForOwner($subStorage->getOwner(''));
- $files[$rootEntry->getName()] = new FileInfo($path . '/' . $rootEntry['name'], $subStorage, '', $rootEntry, $mount, $owner);
- }
- }
- }
- }
- if ($mimetype_filter) {
- $files = array_filter($files, function (FileInfo $file) use ($mimetype_filter) {
- if (strpos($mimetype_filter, '/')) {
- return $file->getMimetype() === $mimetype_filter;
- } else {
- return $file->getMimePart() === $mimetype_filter;
- }
- });
- }
- return array_values($files);
- }
- /**
- * change file metadata
- *
- * @param string $path
- * @param array|\OCP\Files\FileInfo $data
- * @return int
- *
- * returns the fileid of the updated file
- */
- public function putFileInfo($path, $data) {
- $this->assertPathLength($path);
- if ($data instanceof FileInfo) {
- $data = $data->getData();
- }
- $path = Filesystem::normalizePath($this->fakeRoot . '/' . $path);
- /**
- * @var Storage $storage
- * @var string $internalPath
- */
- [$storage, $internalPath] = Filesystem::resolvePath($path);
- if ($storage) {
- $cache = $storage->getCache($path);
- if (!$cache->inCache($internalPath)) {
- $scanner = $storage->getScanner($internalPath);
- $scanner->scan($internalPath, Cache\Scanner::SCAN_SHALLOW);
- }
- return $cache->put($internalPath, $data);
- } else {
- return -1;
- }
- }
- /**
- * search for files with the name matching $query
- *
- * @param string $query
- * @return FileInfo[]
- */
- public function search($query) {
- return $this->searchCommon('search', ['%' . $query . '%']);
- }
- /**
- * search for files with the name matching $query
- *
- * @param string $query
- * @return FileInfo[]
- */
- public function searchRaw($query) {
- return $this->searchCommon('search', [$query]);
- }
- /**
- * search for files by mimetype
- *
- * @param string $mimetype
- * @return FileInfo[]
- */
- public function searchByMime($mimetype) {
- return $this->searchCommon('searchByMime', [$mimetype]);
- }
- /**
- * search for files by tag
- *
- * @param string|int $tag name or tag id
- * @param string $userId owner of the tags
- * @return FileInfo[]
- */
- public function searchByTag($tag, $userId) {
- return $this->searchCommon('searchByTag', [$tag, $userId]);
- }
- /**
- * @param string $method cache method
- * @param array $args
- * @return FileInfo[]
- */
- private function searchCommon($method, $args) {
- $files = [];
- $rootLength = strlen($this->fakeRoot);
- $mount = $this->getMount('');
- $mountPoint = $mount->getMountPoint();
- $storage = $mount->getStorage();
- $userManager = \OC::$server->getUserManager();
- if ($storage) {
- $cache = $storage->getCache('');
- $results = call_user_func_array([$cache, $method], $args);
- foreach ($results as $result) {
- if (substr($mountPoint . $result['path'], 0, $rootLength + 1) === $this->fakeRoot . '/') {
- $internalPath = $result['path'];
- $path = $mountPoint . $result['path'];
- $result['path'] = substr($mountPoint . $result['path'], $rootLength);
- $owner = $userManager->get($storage->getOwner($internalPath));
- $files[] = new FileInfo($path, $storage, $internalPath, $result, $mount, $owner);
- }
- }
- $mounts = Filesystem::getMountManager()->findIn($this->fakeRoot);
- foreach ($mounts as $mount) {
- $mountPoint = $mount->getMountPoint();
- $storage = $mount->getStorage();
- if ($storage) {
- $cache = $storage->getCache('');
- $relativeMountPoint = substr($mountPoint, $rootLength);
- $results = call_user_func_array([$cache, $method], $args);
- if ($results) {
- foreach ($results as $result) {
- $internalPath = $result['path'];
- $result['path'] = rtrim($relativeMountPoint . $result['path'], '/');
- $path = rtrim($mountPoint . $internalPath, '/');
- $owner = $userManager->get($storage->getOwner($internalPath));
- $files[] = new FileInfo($path, $storage, $internalPath, $result, $mount, $owner);
- }
- }
- }
- }
- }
- return $files;
- }
- /**
- * Get the owner for a file or folder
- *
- * @param string $path
- * @return string the user id of the owner
- * @throws NotFoundException
- */
- public function getOwner($path) {
- $info = $this->getFileInfo($path);
- if (!$info) {
- throw new NotFoundException($path . ' not found while trying to get owner');
- }
- if ($info->getOwner() === null) {
- throw new NotFoundException($path . ' has no owner');
- }
- return $info->getOwner()->getUID();
- }
- /**
- * get the ETag for a file or folder
- *
- * @param string $path
- * @return string|false
- */
- public function getETag($path) {
- [$storage, $internalPath] = $this->resolvePath($path);
- if ($storage) {
- return $storage->getETag($internalPath);
- } else {
- return false;
- }
- }
- /**
- * Get the path of a file by id, relative to the view
- *
- * Note that the resulting path is not guaranteed to be unique for the id, multiple paths can point to the same file
- *
- * @param int $id
- * @param int|null $storageId
- * @return string
- * @throws NotFoundException
- */
- public function getPath($id, ?int $storageId = null) {
- $id = (int)$id;
- $manager = Filesystem::getMountManager();
- $mounts = $manager->findIn($this->fakeRoot);
- $mounts[] = $manager->find($this->fakeRoot);
- $mounts = array_filter($mounts);
- // reverse the array, so we start with the storage this view is in
- // which is the most likely to contain the file we're looking for
- $mounts = array_reverse($mounts);
- // put non-shared mounts in front of the shared mount
- // this prevents unneeded recursion into shares
- usort($mounts, function (IMountPoint $a, IMountPoint $b) {
- return $a instanceof SharedMount && (!$b instanceof SharedMount) ? 1 : -1;
- });
- if (!is_null($storageId)) {
- $mounts = array_filter($mounts, function (IMountPoint $mount) use ($storageId) {
- return $mount->getNumericStorageId() === $storageId;
- });
- }
- foreach ($mounts as $mount) {
- /**
- * @var \OC\Files\Mount\MountPoint $mount
- */
- if ($mount->getStorage()) {
- $cache = $mount->getStorage()->getCache();
- $internalPath = $cache->getPathById($id);
- if (is_string($internalPath)) {
- $fullPath = $mount->getMountPoint() . $internalPath;
- if (!is_null($path = $this->getRelativePath($fullPath))) {
- return $path;
- }
- }
- }
- }
- throw new NotFoundException(sprintf('File with id "%s" has not been found.', $id));
- }
- /**
- * @param string $path
- * @throws InvalidPathException
- */
- private function assertPathLength($path): void {
- $maxLen = min(PHP_MAXPATHLEN, 4000);
- // Check for the string length - performed using isset() instead of strlen()
- // because isset() is about 5x-40x faster.
- if (isset($path[$maxLen])) {
- $pathLen = strlen($path);
- throw new InvalidPathException("Path length($pathLen) exceeds max path length($maxLen): $path");
- }
- }
- /**
- * check if it is allowed to move a mount point to a given target.
- * It is not allowed to move a mount point into a different mount point or
- * into an already shared folder
- */
- private function targetIsNotShared(string $user, string $targetPath): bool {
- $providers = [
- IShare::TYPE_USER,
- IShare::TYPE_GROUP,
- IShare::TYPE_EMAIL,
- IShare::TYPE_CIRCLE,
- IShare::TYPE_ROOM,
- IShare::TYPE_DECK,
- IShare::TYPE_SCIENCEMESH
- ];
- $shareManager = Server::get(IManager::class);
- /** @var IShare[] $shares */
- $shares = array_merge(...array_map(function (int $type) use ($shareManager, $user) {
- return $shareManager->getSharesBy($user, $type);
- }, $providers));
- foreach ($shares as $share) {
- $sharedPath = $share->getNode()->getPath();
- if ($targetPath === $sharedPath || str_starts_with($targetPath, $sharedPath . '/')) {
- $this->logger->debug(
- 'It is not allowed to move one mount point into a shared folder',
- ['app' => 'files']);
- return false;
- }
- }
- return true;
- }
- /**
- * Get a fileinfo object for files that are ignored in the cache (part files)
- */
- private function getPartFileInfo(string $path): \OC\Files\FileInfo {
- $mount = $this->getMount($path);
- $storage = $mount->getStorage();
- $internalPath = $mount->getInternalPath($this->getAbsolutePath($path));
- $owner = \OC::$server->getUserManager()->get($storage->getOwner($internalPath));
- return new FileInfo(
- $this->getAbsolutePath($path),
- $storage,
- $internalPath,
- [
- 'fileid' => null,
- 'mimetype' => $storage->getMimeType($internalPath),
- 'name' => basename($path),
- 'etag' => null,
- 'size' => $storage->filesize($internalPath),
- 'mtime' => $storage->filemtime($internalPath),
- 'encrypted' => false,
- 'permissions' => \OCP\Constants::PERMISSION_ALL
- ],
- $mount,
- $owner
- );
- }
- /**
- * @param string $path
- * @param string $fileName
- * @param bool $readonly Check only if the path is allowed for read-only access
- * @throws InvalidPathException
- */
- public function verifyPath($path, $fileName, $readonly = false): void {
- // All of the view's functions disallow '..' in the path so we can short cut if the path is invalid
- if (!Filesystem::isValidPath($path ?: '/')) {
- $l = \OCP\Util::getL10N('lib');
- throw new InvalidPathException($l->t('Path contains invalid segments'));
- }
- // Short cut for read-only validation
- if ($readonly) {
- $validator = \OCP\Server::get(FilenameValidator::class);
- if ($validator->isForbidden($fileName)) {
- $l = \OCP\Util::getL10N('lib');
- throw new InvalidPathException($l->t('Filename is a reserved word'));
- }
- return;
- }
- try {
- /** @type \OCP\Files\Storage $storage */
- [$storage, $internalPath] = $this->resolvePath($path);
- $storage->verifyPath($internalPath, $fileName);
- } catch (ReservedWordException $ex) {
- $l = \OCP\Util::getL10N('lib');
- throw new InvalidPathException($ex->getMessage() ?: $l->t('Filename is a reserved word'));
- } catch (InvalidCharacterInPathException $ex) {
- $l = \OCP\Util::getL10N('lib');
- throw new InvalidPathException($ex->getMessage() ?: $l->t('Filename contains at least one invalid character'));
- } catch (FileNameTooLongException $ex) {
- $l = \OCP\Util::getL10N('lib');
- throw new InvalidPathException($l->t('Filename is too long'));
- } catch (InvalidDirectoryException $ex) {
- $l = \OCP\Util::getL10N('lib');
- throw new InvalidPathException($l->t('Dot files are not allowed'));
- } catch (EmptyFileNameException $ex) {
- $l = \OCP\Util::getL10N('lib');
- throw new InvalidPathException($l->t('Empty filename is not allowed'));
- }
- }
- /**
- * get all parent folders of $path
- *
- * @param string $path
- * @return string[]
- */
- private function getParents($path) {
- $path = trim($path, '/');
- if (!$path) {
- return [];
- }
- $parts = explode('/', $path);
- // remove the single file
- array_pop($parts);
- $result = ['/'];
- $resultPath = '';
- foreach ($parts as $part) {
- if ($part) {
- $resultPath .= '/' . $part;
- $result[] = $resultPath;
- }
- }
- return $result;
- }
- /**
- * Returns the mount point for which to lock
- *
- * @param string $absolutePath absolute path
- * @param bool $useParentMount true to return parent mount instead of whatever
- * is mounted directly on the given path, false otherwise
- * @return IMountPoint mount point for which to apply locks
- */
- private function getMountForLock(string $absolutePath, bool $useParentMount = false): IMountPoint {
- $mount = Filesystem::getMountManager()->find($absolutePath);
- if ($useParentMount) {
- // find out if something is mounted directly on the path
- $internalPath = $mount->getInternalPath($absolutePath);
- if ($internalPath === '') {
- // resolve the parent mount instead
- $mount = Filesystem::getMountManager()->find(dirname($absolutePath));
- }
- }
- return $mount;
- }
- /**
- * Lock the given path
- *
- * @param string $path the path of the file to lock, relative to the view
- * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
- * @param bool $lockMountPoint true to lock the mount point, false to lock the attached mount/storage
- *
- * @return bool False if the path is excluded from locking, true otherwise
- * @throws LockedException if the path is already locked
- */
- private function lockPath($path, $type, $lockMountPoint = false) {
- $absolutePath = $this->getAbsolutePath($path);
- $absolutePath = Filesystem::normalizePath($absolutePath);
- if (!$this->shouldLockFile($absolutePath)) {
- return false;
- }
- $mount = $this->getMountForLock($absolutePath, $lockMountPoint);
- try {
- $storage = $mount->getStorage();
- if ($storage && $storage->instanceOfStorage('\OCP\Files\Storage\ILockingStorage')) {
- $storage->acquireLock(
- $mount->getInternalPath($absolutePath),
- $type,
- $this->lockingProvider
- );
- }
- } catch (LockedException $e) {
- // rethrow with the a human-readable path
- throw new LockedException(
- $this->getPathRelativeToFiles($absolutePath),
- $e,
- $e->getExistingLock()
- );
- }
- return true;
- }
- /**
- * Change the lock type
- *
- * @param string $path the path of the file to lock, relative to the view
- * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
- * @param bool $lockMountPoint true to lock the mount point, false to lock the attached mount/storage
- *
- * @return bool False if the path is excluded from locking, true otherwise
- * @throws LockedException if the path is already locked
- */
- public function changeLock($path, $type, $lockMountPoint = false) {
- $path = Filesystem::normalizePath($path);
- $absolutePath = $this->getAbsolutePath($path);
- $absolutePath = Filesystem::normalizePath($absolutePath);
- if (!$this->shouldLockFile($absolutePath)) {
- return false;
- }
- $mount = $this->getMountForLock($absolutePath, $lockMountPoint);
- try {
- $storage = $mount->getStorage();
- if ($storage && $storage->instanceOfStorage('\OCP\Files\Storage\ILockingStorage')) {
- $storage->changeLock(
- $mount->getInternalPath($absolutePath),
- $type,
- $this->lockingProvider
- );
- }
- } catch (LockedException $e) {
- try {
- // rethrow with the a human-readable path
- throw new LockedException(
- $this->getPathRelativeToFiles($absolutePath),
- $e,
- $e->getExistingLock()
- );
- } catch (\InvalidArgumentException $ex) {
- throw new LockedException(
- $absolutePath,
- $ex,
- $e->getExistingLock()
- );
- }
- }
- return true;
- }
- /**
- * Unlock the given path
- *
- * @param string $path the path of the file to unlock, relative to the view
- * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
- * @param bool $lockMountPoint true to lock the mount point, false to lock the attached mount/storage
- *
- * @return bool False if the path is excluded from locking, true otherwise
- * @throws LockedException
- */
- private function unlockPath($path, $type, $lockMountPoint = false) {
- $absolutePath = $this->getAbsolutePath($path);
- $absolutePath = Filesystem::normalizePath($absolutePath);
- if (!$this->shouldLockFile($absolutePath)) {
- return false;
- }
- $mount = $this->getMountForLock($absolutePath, $lockMountPoint);
- $storage = $mount->getStorage();
- if ($storage && $storage->instanceOfStorage('\OCP\Files\Storage\ILockingStorage')) {
- $storage->releaseLock(
- $mount->getInternalPath($absolutePath),
- $type,
- $this->lockingProvider
- );
- }
- return true;
- }
- /**
- * Lock a path and all its parents up to the root of the view
- *
- * @param string $path the path of the file to lock relative to the view
- * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
- * @param bool $lockMountPoint true to lock the mount point, false to lock the attached mount/storage
- *
- * @return bool False if the path is excluded from locking, true otherwise
- * @throws LockedException
- */
- public function lockFile($path, $type, $lockMountPoint = false) {
- $absolutePath = $this->getAbsolutePath($path);
- $absolutePath = Filesystem::normalizePath($absolutePath);
- if (!$this->shouldLockFile($absolutePath)) {
- return false;
- }
- $this->lockPath($path, $type, $lockMountPoint);
- $parents = $this->getParents($path);
- foreach ($parents as $parent) {
- $this->lockPath($parent, ILockingProvider::LOCK_SHARED);
- }
- return true;
- }
- /**
- * Unlock a path and all its parents up to the root of the view
- *
- * @param string $path the path of the file to lock relative to the view
- * @param int $type \OCP\Lock\ILockingProvider::LOCK_SHARED or \OCP\Lock\ILockingProvider::LOCK_EXCLUSIVE
- * @param bool $lockMountPoint true to lock the mount point, false to lock the attached mount/storage
- *
- * @return bool False if the path is excluded from locking, true otherwise
- * @throws LockedException
- */
- public function unlockFile($path, $type, $lockMountPoint = false) {
- $absolutePath = $this->getAbsolutePath($path);
- $absolutePath = Filesystem::normalizePath($absolutePath);
- if (!$this->shouldLockFile($absolutePath)) {
- return false;
- }
- $this->unlockPath($path, $type, $lockMountPoint);
- $parents = $this->getParents($path);
- foreach ($parents as $parent) {
- $this->unlockPath($parent, ILockingProvider::LOCK_SHARED);
- }
- return true;
- }
- /**
- * Only lock files in data/user/files/
- *
- * @param string $path Absolute path to the file/folder we try to (un)lock
- * @return bool
- */
- protected function shouldLockFile($path) {
- $path = Filesystem::normalizePath($path);
- $pathSegments = explode('/', $path);
- if (isset($pathSegments[2])) {
- // E.g.: /username/files/path-to-file
- return ($pathSegments[2] === 'files') && (count($pathSegments) > 3);
- }
- return !str_starts_with($path, '/appdata_');
- }
- /**
- * Shortens the given absolute path to be relative to
- * "$user/files".
- *
- * @param string $absolutePath absolute path which is under "files"
- *
- * @return string path relative to "files" with trimmed slashes or null
- * if the path was NOT relative to files
- *
- * @throws \InvalidArgumentException if the given path was not under "files"
- * @since 8.1.0
- */
- public function getPathRelativeToFiles($absolutePath) {
- $path = Filesystem::normalizePath($absolutePath);
- $parts = explode('/', trim($path, '/'), 3);
- // "$user", "files", "path/to/dir"
- if (!isset($parts[1]) || $parts[1] !== 'files') {
- $this->logger->error(
- '$absolutePath must be relative to "files", value is "{absolutePath}"',
- [
- 'absolutePath' => $absolutePath,
- ]
- );
- throw new \InvalidArgumentException('$absolutePath must be relative to "files"');
- }
- if (isset($parts[2])) {
- return $parts[2];
- }
- return '';
- }
- /**
- * @param string $filename
- * @return array
- * @throws \OC\User\NoUserException
- * @throws NotFoundException
- */
- public function getUidAndFilename($filename) {
- $info = $this->getFileInfo($filename);
- if (!$info instanceof \OCP\Files\FileInfo) {
- throw new NotFoundException($this->getAbsolutePath($filename) . ' not found');
- }
- $uid = $info->getOwner()->getUID();
- if ($uid != \OC_User::getUser()) {
- Filesystem::initMountPoints($uid);
- $ownerView = new View('/' . $uid . '/files');
- try {
- $filename = $ownerView->getPath($info['fileid']);
- } catch (NotFoundException $e) {
- throw new NotFoundException('File with id ' . $info['fileid'] . ' not found for user ' . $uid);
- }
- }
- return [$uid, $filename];
- }
- /**
- * Creates parent non-existing folders
- *
- * @param string $filePath
- * @return bool
- */
- private function createParentDirectories($filePath) {
- $directoryParts = explode('/', $filePath);
- $directoryParts = array_filter($directoryParts);
- foreach ($directoryParts as $key => $part) {
- $currentPathElements = array_slice($directoryParts, 0, $key);
- $currentPath = '/' . implode('/', $currentPathElements);
- if ($this->is_file($currentPath)) {
- return false;
- }
- if (!$this->file_exists($currentPath)) {
- $this->mkdir($currentPath);
- }
- }
- return true;
- }
- }
|