Syscodes\Filesystem\Filesystem

Complexity

Total Complexity

106

Size/Duplication

Total Lines	839
Duplicated Lines	0 %

Importance

Changes	4
Bugs	0	Features	0

43 Methods

Rating	Name	Duplication	Size	Complexity
A	move()	0	4	2
A	moveDirectory()	0	11	5
A	put()	0	3	2
A	copy()	0	3	1
A	directories()	0	11	2
B	copyDirectory()	0	33	8
A	get()	0	7	3
A	lastAccess()	0	7	2
A	isDirectory()	0	3	1
A	exec()	0	3	1
A	read()	0	25	5
A	isReadable()	0	3	1
A	owner()	0	7	2
A	guessExtension()	0	3	1
A	deleteDirectory()	0	24	6
A	getRequireOnce()	0	14	2
A	basename()	0	3	1
A	exists()	0	5	1
A	name()	0	3	1
A	extension()	0	3	1
A	create()	0	9	5
A	perms()	0	7	2
A	makeDirectory()	0	7	2
A	getRequire()	0	14	2
A	dirname()	0	3	1
A	group()	0	7	2
A	getSize()	0	17	5
A	isFile()	0	3	1
A	glob()	0	3	1
A	getMimeType()	0	8	1
A	lastModified()	0	7	2
A	clearStatCache()	0	7	2
A	append()	0	3	1
A	prepend()	0	7	2
A	open()	0	15	5
A	cleanDirectory()	0	3	1
A	delete()	0	22	6
A	type()	0	3	1
A	isWritable()	0	3	1
A	replace()	0	13	2
A	close()	0	7	2
A	replaceText()	0	22	5
A	write()	0	21	6

<?php 

/**
 * Lenevor Framework
 *
 * LICENSE
 *
 * This source file is subject to the new BSD license that is bundled
 * with this package in the file license.md.
 * It is also available through the world-wide-web at this URL:
 * https://lenevor.com/license
 * If you did not receive a copy of the license and are unable to
 * obtain it through the world-wide-web, please send an email
 * to license@Lenevor.com so we can send you a copy immediately.
 *
 * @package     Lenevor
 * @subpackage  Base
 * @link        https://lenevor.com
 * @copyright   Copyright (c) 2019 - 2021 Alexander Campo <jalexcam@gmail.com>
 * @license     https://opensource.org/licenses/BSD-3-Clause New BSD license or see https://lenevor.com/license or see /license.md
 */

namespace Syscodes\Filesystem;

use ErrorException;
use FilesystemIterator;
use Syscodes\Filesystem\Exceptions\FileException;
use Syscodes\Filesystem\Exceptions\FileNotFoundException;
use Syscodes\Filesystem\Exceptions\FileUnableToMoveException;

/**
 * Provides basic utility to manipulate the file system.
 * 
 * @author Alexander Campo <jalexcam@gmail.com>
 */
class Filesystem 
{
	/**
	 * Enable locking for file reading and writing.
	 *
	 * @var null|bool $lock
	 */
	public $lock = null;

	/**
	 * Holds the file handler resource if the file is opened.
	 *
	 * @var resource $handler
	 */
	protected $handler;

	/**
	 * The files size in bytes.
	 *
	 * @var float $size
	 */
	protected $size;

	/**
	 * Append given data string to this file.
	 *
	 * @param  string  $path
	 * @param  string  $data
	 *
	 * @return bool
	 */
	public function append($path, $data)
	{
		return file_put_contents($path, $data, FILE_APPEND);

The expression return file_put_contents($path, $data, Syscodes\Filesystem\FILE_APPEND) returns the type integer which is incompatible with the documented return type boolean.

	}

	/**
	 * Copy a file to a new location.
	 *
	 * @param  string  $path
	 * @param  string  $target
	 * 
	 * @return bool
	 */
	public function copy($path, $target)
	{
		return copy($path, $target);
	}

	/**
	 * Get the contents of a file.
	 *
	 * @param  string  $path
	 * @param  bool  $lock  
	 * @param  bool  $force  
	 *
	 * @return string
	 *
	 * @throws FileNotFoundException
	 */
	public function get($path, $lock = false, $force = false)
	{
		if ($this->isFile($path)) {
			return $lock ? $this->read($path, $force) : file_get_contents($path);
		}

		throw new FileNotFoundException($path);
	}

	/**
	 * Get contents of a file with shared access.
	 *
	 * @param  string  $path
	 * @param  bool  $force  
	 *
	 * @return string
	 */
	protected function read($path, $force = false)
	{
		$contents = '';

		$this->open($path, 'rb', $force);
		
		if ($this->handler) {
			try {
				if (flock($this->handler, LOCK_SH)) {
					$this->clearStatCache($path);

					$contents = fread($this->handler, $this->getSize($path) ?: 1);
					
					while ( ! feof($this->handler)) {
						$contents .= fgets($this->handler, 4096);
					}

					flock($this->handler, LOCK_UN);
				}
			} finally {
				$this->close();
			}
		}

		return trim($contents);
	}

	/**
	 * Opens the current file with a given $mode.
	 *
	 * @param  string  $path
	 * @param  string  $mode  A valid 'fopen' mode string (r|w|a ...)
	 * @param  bool  $force  
	 *
	 * @return bool
	 */
	public function open($path, $mode, $force = false)
	{
		if ( ! $force && is_resource($this->handler)) {
			return true;
		}

		if ($this->exists($path) === false) {
			if ($this->create($path) === false) {
				return false;
			}
		}

		$this->handler = fopen($path, $mode);

		return is_resource($this->handler);
	}

	/**
	 * Creates the file.
	 * 
	 * @param  string  $path
	 * 
	 * @return bool
	 */
	public function create($path)
	{
		if (($this->isDirectory($path)) && ($this->isWritable($path)) || ( ! $this->exists($path))) {

Consider adding parentheses for clarity. Current Interpretation: ($this->isDirectory($path) && $this->isWritable($path)) || ! $this->exists($path), Probably Intended Meaning: $this->isDirectory($path) && ($this->isWritable($path) || ! $this->exists($path))

			if (touch($path)) {
				return true;
			}
		}

		return false;
	}

	/**
	 * Determine if a file exists.
	 *
	 * @param  string  $path
	 *
	 * @return bool
	 */
	public function exists($path)
	{
		$this->clearStatCache($path);

		return file_exists($path);
	}

	/**
	 * Clear PHP's internal stat cache.
	 *
	 * @param  string  $path
	 * @param  bool  $all  Clear all cache or not
	 *
	 * @return void
	 */
	public function clearStatCache($path, $all = false)
	{
		if ($all === false) {
			clearstatcache(true, $path);
		}

		clearstatcache();
	}

	/**
	 * Get the returned value of a file.
	 * 
	 * @param  string  $path
	 * @param  array  $data
	 * 
	 * @return mixed
	 * 
	 * @throws \Syscodes\Filesystem\Exceptions\FileNotFoundException
	 */
	public function getRequire($path, array $data = [])
	{
		if ($this->isFile($path)) {
			$__path = $path;
			$__data = $data;

			return (static function () use ($__path, $__data) {
				extract($__data, EXTR_SKIP);

				return require $__path;
			})();
		}

		throw new FileNotFoundException($path);
	}

	/**
	 * Require the given file once.
	 * 
	 * @param  string  $path
	 * @param  array  $data
	 * 
	 * @return mixed
	 * 
	 * @throws \Syscodes\Filesystem\Exceptions\FileNotFoundException
	 */
	public function getRequireOnce($path, array $data = [])
	{
		if ($this->isFile($path)) {
			$__path = $path;
			$__data = $data;

			return (static function () use ($__path, $__data) {
				extract($__data, EXTR_SKIP);

				return require_once $__path;
			})();
		}

		throw new FileNotFoundException($path);
	}

	/**
	 * Retrieve the file size.
	 *
	 * Implementations SHOULD return the value stored in the "size" key of
	 * the file in the $_FILES array if available, as PHP calculates this
	 * based on the actual size transmitted.
	 *
	 * @param  string  $path
	 * @param  string  $unit  ('b' by default)
	 * 
	 * @return int|null  The file size in bytes or null if unknown
	 */
	public function getSize($path, $unit = 'b')
	{
		if ($this->exists($path)) {
			if (is_null($this->size)) {

The condition is_null($this->size) is always false.

				$this->size = filesize($path);
			}

			switch (strtolower($unit)) {
				case 'kb':
					return number_format($this->size / 1024, 3);

The expression return number_format($this->size / 1024, 3) returns the type string which is incompatible with the documented return type integer|null.

					break;

break is not strictly necessary here and could be removed.

				case 'mb':
					return number_format(($this->size / 1024) / 1024, 3);     

The expression return number_format($this->size / 1024 / 1024, 3) returns the type string which is incompatible with the documented return type integer|null.

					break;
			}

			return $this->size;
		}
	}
	
	/**
	 * Returns the file's group.
	 *
	 * @param  string  $path
	 * 
	 * @return int|bool  The file group, or false in case of an error
	 */
	public function group($path)
	{
		if ($this->exists($path)) {
			return filegroup($path);
		}

		return false;
	}
	
	/**
	 * Returns true if the file is executable.
	 *
	 * @param  string  $path
	 * 
	 * @return bool  True if file is executable, false otherwise
	 */
	public function exec($path)
	{
		return is_executable($path);
	}

	/**
	 * Determine if the given path is a directory.
	 *
	 * @param  string  $directory
	 *
	 * @return bool
	 */
	public function isDirectory($directory)
	{
		return is_dir($directory);
	}

	/**
	 * Determine if the given path is a file.
	 *
	 * @param  string  $file
	 *
	 * @return bool
	 */
	public function isFile($file)
	{
		return is_file($file);
	}

	/**
	 * Determine if the given path is writable.
	 * 
	 * @param  string  $path
	 * 
	 * @return bool
	 */
	public function isWritable($path)
	{
		return is_writable($path);
	}

	/**
	 * Returns if true the file is readable.
	 *
	 * @param  string  $path
	 * 
	 * @return bool  True if file is readable, false otherwise
	 */
	public function isReadable($path)
	{
		return is_readable($path);
	}

	/**
	 * Returns last access time.
	 *
	 * @param  string  $path
	 * 
	 * @return int|bool  Timestamp of last access time, or false in case of an error
	 */
	public function lastAccess($path)
	{
		if ($this->exists($path)) {
			return fileatime($path);
		}

		return false;
	}

	/**
	 * Returns last modified time.
	 *
	 * @param  string  $path
	 * 
	 * @return int|bool  Timestamp of last modified time, or false in case of an error
	 */
	public function lastModified($path)
	{
		if ($this->exists($path)) {
			return filemtime($path);
		}

		return false;
	}

	/**
	 * Get all of the directories within a given directory.
	 * 
	 * @param  string  $directory
	 * 
	 * @return array
	 */
	public function directories($directory)
	{
		$directories = [];

		$iterators = new FilesystemIterator($directory);

		foreach ($iterators as $iterator) {
			$directories[] = trim($iterator->getPathname(), '/').'/';
		}

		return $directories;
	}

	/**
	 * Delete the file at a given path.
	 * 
	 * @param  string  $paths
	 * 
	 * @return bool
	 */
	public function delete($paths)
	{
		if (is_resource($this->handler)) {
			fclose($this->handler);
			$this->handler = null;
		}

		$paths = is_array($paths) ? $paths : func_get_args();

		$success = true;

		foreach ($paths as $path) {
			try {
				if ( ! @unlink($path)) {
					return $success = false;

The assignment to $success is dead and can be removed.

				}
			} catch (ErrorException $e) {
				return $success = false;
			}
		}

		return $success;
	}

	/**
	 * Create a directory.
	 *
	 * @param  string  $path
	 * @param  int  $mode
	 * @param  bool  $recursive
	 * @param  bool  $force
	 *
	 * @return bool
	 * 
	 * @throws FileException
	 */
	public function makeDirectory($path, $mode = 0755, $recursive = false, $force = false)
	{
		if ($force) {
			return @mkdir($path, $mode, $recursive);
		}

		mkdir($path, $mode, $recursive);
	}

	/**
	 * Copy a directory from one location to another.
	 * 
	 * @param  string  $directory
	 * @param  string  $destination
	 * @param  int  $options  
	 * 
	 * @return bool
	 */
	public function copyDirectory($directory, $destination, $options = null)
	{
		if ( ! $this->isDirectory($directory)) return false;

		$options = $options ?: FilesystemIterator::SKIP_DOTS;
		
		// If the destination directory does not actually exist, we will go ahead and
		// create it recursively, which just gets the destination prepared to copy
		// the files over. Once we make the directory we'll proceed the copying.
		if ( ! $this->isdirectory($destination)) {
			$this->makeDirectory($destination, 0777, true);
		}

		$iterators = new FilesystemIterator($directory, $options);

		foreach ($iterators as $iterator) {
			$target = $destination.DIRECTORY_SEPARATOR.$iterator->getBasename();
			
			// As we spin through items, we will check to see if the current file is actually
            // a directory or a file. When it is actually a directory we will need to call
            // back into this function recursively to keep copying these nested folders.
			if ($iterator->isDir()) {
				if ( ! $this->copyDirectory($iterator->getPathname(), $target, $options)) return false;
			}
			// If the current items is just a regular file, we will just copy this to the new
			// location and keep looping. If for some reason the copy fails we'll bail out
			// and return false, so the developer is aware that the copy process failed.
			else {
				if ( ! $this->copy($iterator->getPathname(), $target)) return false;
			}
		}

		return true;
	}

	/**
	 * Recursively delete a directory and optionally you can keep 
	 * the directory if you wish.
	 * 
	 * @param  string  $directory
	 * @param  bool  $keep
	 * 
	 * @return bool
	 */
	public function deleteDirectory($directory, $keep = false)
	{
		if ( ! $this->isDirectory($directory)) return false;

		$iterators = new filesystemIterator($directory);

		foreach ($iterators as $iterator) {
			// If the item is a directory, we can just recurse into the function and delete 
			// that sub-directory otherwise we'll just delete the file and keep iterating 
			// through each file until the directory is cleaned.
			if ($iterator->isDir() && ! $iterator->isLink()) {
				$this->deleteDirectory($iterator->getPathname());
			}
			// If the item is just a file, we can go ahead and delete it since we're
			// just looping through and waxing all of the files in this directory
			// and calling directories recursively, so we delete the real path.
			else {
				$this->delete($iterator->getPathname());
			}
		}

		if ( ! $keep) @rmdir($directory);

It seems like you do not handle an error condition for rmdir(). This can introduce security issues, and is generally not recommended.

		return true;
	}

	/**
	 * Empty the specified directory of all files and folders.
	 * 
	 * 
	 * @param  string  $directory
	 * 
	 * @return bool
	 */
	public function cleanDirectory($directory)
	{
		return $this->deleteDirectory($directory, true);
	}

	/**
	 * Moves a file to a new location.
	 * 
	 * @param  string  $from
	 * @param  string  $to
	 * @param  bool  $overwrite  
	 * 
	 * @return bool
	 */
	public function moveDirectory($from, $to, $overwrite = false)
	{
		if ($overwrite && $this->isDirectory($to) && ! $this->deleteDirectory($to)) return false;

		if (false === @rename($from, $to)) {
			$error = error_get_last();

			throw new FileUnableToMoveException($from, $to, strip_tags($error['message']));
		}

		$this->perms($to, 0777 & ~umask());
	}

	/**
	 * Attempts to determine the file extension based on the trusted
	 * getType() method. If the mime type is unknown, will return null.
	 * 
	 * @param  string  $path
	 * 
	 * @return string|null
	 */
	public function guessExtension($path)
	{
		return FileMimeType::guessExtensionFromType($this->getMimeType($path));
	}

	/**
	 * Retrieve the media type of the file. 
	 * 
	 * @param  string  $path
	 * 
	 * @return string|null
	 */
	public function getMimeType($path)
	{
		$finfo    = finfo_open(FILEINFO_MIME_TYPE);
		$mimeType = finfo_file($finfo, $path);

		finfo_close($finfo);

		return $mimeType;
	}

	/**
	 * Move a file to a new location.
	 *
	 * @param  string  $path
	 * @param  string  $target
	 *
	 * @return bool
	 */
	public function move($path, $target)
	{
		if ($this->exists($path)) {
			return rename($path, $target);
		}
	}

	/**
	 * Extract the file name from a file path.
	 * 
	 * @param  string  $path
	 * 
	 * @return string
	 */
	public function name($path)
	{
		return pathinfo($path, PATHINFO_FILENAME);

The expression return pathinfo($path, Syscodes\Filesystem\PATHINFO_FILENAME) also could return the type array which is incompatible with the documented return type string.

	}

	/**
	 * Extract the trailing name component from a file path.
	 * 
	 * @param  string  $path
	 * 
	 * @return string
	 */
	public function basename($path)
	{
		return pathinfo($path, PATHINFO_BASENAME);

The expression return pathinfo($path, Syscodes\Filesystem\PATHINFO_BASENAME) also could return the type array which is incompatible with the documented return type string.

	}

	/**
	 * Extract the parent directory from a file path.
	 * 
	 * @param  string  $path
	 * 
	 * @return string
	 */
	public function dirname($path)
	{
		return pathinfo($path, PATHINFO_DIRNAME);

The expression return pathinfo($path, Syscodes\Filesystem\PATHINFO_DIRNAME) also could return the type array which is incompatible with the documented return type string.

	}

	/**
	 * Extract the file extension from a file path.
	 * 
	 * @param  string  $path
	 * 
	 * @return string
	 */
	public function extension($path)
	{
		return pathinfo($path, PATHINFO_EXTENSION);

The expression return pathinfo($path, Syscodes\Filesystem\PATHINFO_EXTENSION) also could return the type array which is incompatible with the documented return type string.

	}

	/**
	 *  Find path names matching a given pattern.
	 * 
	 * @param  string  $pattern
	 * @param  int  $flags  (0 by default)
	 * 
	 * @return array
	 */
	public function glob($pattern, $flags = 0)
	{
		return glob($pattern, $flags);
	}

	/**
	 * Returns the file's owner.
	 *
	 * @param  string  $path
	 * 
	 * @return int|bool  The file owner, or false in case of an error
	 */
	public function owner($path)
	{
		if ($this->exists($path)) {
			return fileowner($path);
		}

		return false;
	}

	/**
	 * Returns the "chmod" (permissions) of the file.
	 *
	 * @param  string  $path
	 * @param  int|null  $mode  
	 * 
	 * @return mixed  Permissions for the file, or false in case of an error
	 */
	public function perms($path, $mode = null)
	{
		if ($mode) {

The expression $mode of type integer|null is loosely compared to true; this is ambiguous if the integer can be 0. You might want to explicitly use !== null instead.

			chmod($path, $mode);
		}

		return substr(sprintf('%o', fileperms($path)), -4);
	}

	/**
	 * Prepend to a file.
	 * 
	 * @param  string  $path
	 * @param  string  $data
	 * 
	 * @return int
	 */
	public function prepend($path, $data)
	{
		if ($this->exists($path)) {
			$this->put($path, $data.$this->get($path));
		}

		return $this->put($path, $data);
	}

	/**
	 * Write the content of a file.
	 *
	 * @param  string  $path
	 * @param  string  $contents
	 * @param  bool  $lock  
	 *
	 * @return int
	 */
	public function put($path, $contents, $lock = false)
	{
		return file_put_contents($path, $contents, $lock ? LOCK_EX : 0);
	}

	/**
	 * Get the file type of a given file.
	 * 
	 * @param  string  $path
	 * 
	 * @return string
	 */
	public function type($path)
	{
		return filetype($path);
	}
	
	/**
	 * Write the contents of a file, replacing it atomically if it already exists.
	 * 
	 * @param  string  $path
	 * @param  string  $content
	 * 
	 * @return void
	 */
	public function replace($path, $content)
	{
		$this->clearstatcache($path);
		
		$path = realpath($path) ?: $path;
		
		$tempPath = tempnam(dirname($path), basename($path));
		
		$this->perms($tempPath, 0777 - umask());
		
		$this->put($tempPath, $content);
		
		$this->move($tempPath, $path);
    }

	/**
	 * Searches for a given text and replaces the text if found.
	 *
	 * @param  string  $path
	 * @param  string  $search
	 * @param  string  $replace
	 *
	 * @return bool
	 */
	public function replaceText($path, $search, $replace)
	{
		if ( ! $this->open($path, 'r+')) {
			return false;
		}

		if ($this->lock !== null) {
			if (flock($this->handler, LOCK_EX) === false)
			{
				return false;
			}
		}

		$replaced = $this->write($path, str_replace($search, $replace, $this->get($path)), true);

		if ($this->lock !== null) {
			flock($this->handler, LOCK_UN);
		}

		$this->close();

		return $replaced;
	}	

	/**
	 * Closes the current file if it is opened.
	 *
	 * @return bool
	 */
	public function close()
	{
		if ( ! is_resource($this->handler)) {
			return true;
		}

		return fclose($this->handler);
	}

	/**
	 * Write given data to this file.
	 *
	 * @param  string  $path
	 * @param  string  $data  Data to write to this File
	 * @param  bool  $force  The file to open
	 *
	 * @return bool
	 */
	public function write($path, $data, $force = false)
	{
		$success = false;

		if ($this->open($path, 'w', $force) === true) {
			if ($this->lock !== null) {
				if (flock($this->handler, LOCK_EX) === false) {
					return false;
				}
			}

			if (fwrite($this->handler, $data) !== false) {
				$success = true;
			}

			if ($this->lock !== null) {
				flock($this->handler, LOCK_UN);
			}
		}

		return $success;
	}
}