2015-07-11 03:59:39 +02:00
|
|
|
<?php
|
|
|
|
|
2015-08-05 16:55:56 +02:00
|
|
|
namespace Amp\File;
|
2015-07-11 03:59:39 +02:00
|
|
|
|
|
|
|
/**
|
2015-07-30 15:07:01 +02:00
|
|
|
* Retrieve the application-wide filesystem instance
|
2015-07-11 03:59:39 +02:00
|
|
|
*
|
2015-08-07 18:03:39 +02:00
|
|
|
* @param \Amp\File\Driver $assign Use the specified object as the application-wide filesystem instance
|
|
|
|
* @return \Amp\File\Driver
|
2015-07-11 03:59:39 +02:00
|
|
|
*/
|
2015-07-30 16:10:53 +02:00
|
|
|
function filesystem(Driver $assign = null) {
|
|
|
|
static $driver;
|
2015-07-11 03:59:39 +02:00
|
|
|
if ($assign) {
|
2015-07-30 16:10:53 +02:00
|
|
|
return ($driver = $assign);
|
|
|
|
} elseif ($driver) {
|
|
|
|
return $driver;
|
2015-07-30 15:07:01 +02:00
|
|
|
} else {
|
2015-07-30 16:10:53 +02:00
|
|
|
return ($driver = driver());
|
2015-07-30 15:07:01 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
2015-07-30 16:10:53 +02:00
|
|
|
* Create a new filesystem driver best-suited for the current environment
|
2015-07-30 15:07:01 +02:00
|
|
|
*
|
2015-08-07 18:03:39 +02:00
|
|
|
* @return \Amp\File\Driver
|
2015-07-30 15:07:01 +02:00
|
|
|
*/
|
2015-07-30 16:10:53 +02:00
|
|
|
function driver() {
|
|
|
|
$reactor = \Amp\reactor();
|
|
|
|
if ($reactor instanceof \Amp\UvReactor) {
|
|
|
|
return new UvDriver($reactor);
|
2015-07-18 18:08:50 +02:00
|
|
|
} elseif (\extension_loaded("eio")) {
|
2015-07-30 16:10:53 +02:00
|
|
|
return new EioDriver;
|
2015-07-11 03:59:39 +02:00
|
|
|
} else {
|
2015-08-01 03:15:53 +02:00
|
|
|
return new BlockingDriver;
|
2015-07-11 03:59:39 +02:00
|
|
|
}
|
|
|
|
}
|
2015-07-30 15:07:01 +02:00
|
|
|
|
|
|
|
/**
|
|
|
|
* Execute a file stat operation
|
|
|
|
*
|
|
|
|
* If the requested path does not exist the resulting Promise will resolve to NULL.
|
|
|
|
*
|
|
|
|
* @param string $path The file system path to stat
|
|
|
|
* @return \Amp\Promise A promise resolving to an associative array upon successful resolution
|
|
|
|
*/
|
|
|
|
function stat($path) {
|
|
|
|
return filesystem()->stat($path);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Same as stat() except if the path is a link then the link's data is returned
|
|
|
|
*
|
|
|
|
* @param string $path The file system path to stat
|
|
|
|
* @return \Amp\Promise A promise resolving to an associative array upon successful resolution
|
|
|
|
*/
|
|
|
|
function lstat($path) {
|
|
|
|
return filesystem()->lstat($path);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Create a symlink $link pointing to the file/directory located at $target
|
|
|
|
*
|
|
|
|
* @param string $target
|
|
|
|
* @param string $link
|
|
|
|
* @return \Amp\Promise
|
|
|
|
*/
|
|
|
|
function symlink($target, $link) {
|
|
|
|
return filesystem()->symlink($target, $link);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Rename a file or directory
|
|
|
|
*
|
|
|
|
* @param string $from
|
|
|
|
* @param string $to
|
|
|
|
* @return \Amp\Promise
|
|
|
|
*/
|
|
|
|
function rename($from, $to) {
|
|
|
|
return filesystem()->rename($from, $to);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Delete a file
|
|
|
|
*
|
|
|
|
* @param string $path
|
|
|
|
* @return \Amp\Promise
|
|
|
|
*/
|
|
|
|
function unlink($path) {
|
|
|
|
return filesystem()->unlink($path);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Create a director
|
|
|
|
*
|
|
|
|
* @param string $path
|
|
|
|
* @param int $mode
|
|
|
|
* @return \Amp\Promise
|
|
|
|
*/
|
|
|
|
function mkdir($path, $mode = 0644) {
|
|
|
|
return filesystem()->mkdir($path, $mode);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Delete a directory
|
|
|
|
*
|
|
|
|
* @param string $path
|
|
|
|
* @return \Amp\Promise
|
|
|
|
*/
|
|
|
|
function rmdir($path) {
|
|
|
|
return filesystem()->rmdir($path);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Retrieve an array of files and directories inside the specified path
|
|
|
|
*
|
|
|
|
* Dot entries are not included in the resulting array (i.e. "." and "..").
|
|
|
|
*
|
|
|
|
* @param string $path
|
|
|
|
* @return \Amp\Promise
|
|
|
|
*/
|
|
|
|
function scandir($path) {
|
|
|
|
return filesystem()->scandir($path);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* chmod a file or directory
|
|
|
|
*
|
|
|
|
* @param string $path
|
|
|
|
* @param int $mode
|
|
|
|
* @return \Amp\Promise
|
|
|
|
*/
|
|
|
|
function chmod($path, $mode) {
|
|
|
|
return filesystem()->chmod($path, $mode);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* chown a file or directory
|
|
|
|
*
|
|
|
|
* @param string $path
|
|
|
|
* @param int $uid
|
|
|
|
* @param int $gid
|
|
|
|
* @return \Amp\Promise
|
|
|
|
*/
|
|
|
|
function chown($path, $uid, $gid) {
|
|
|
|
return filesystem()->chown($path, $uid, $gid);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Update the access and modification time of the specified path
|
|
|
|
*
|
|
|
|
* If the file does not exist it will be created automatically.
|
|
|
|
*
|
|
|
|
* @param string $path
|
|
|
|
* @return \Amp\Promise
|
|
|
|
*/
|
|
|
|
function touch($path) {
|
|
|
|
return filesystem()->touch($path);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Buffer the specified file's contents
|
|
|
|
*
|
|
|
|
* @param string $path The file path from which to buffer contents
|
|
|
|
* @return \Amp\Promise A promise resolving to a string upon successful resolution
|
|
|
|
*/
|
|
|
|
function get($path) {
|
|
|
|
return filesystem()->get($path);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Write the contents string to the specified path.
|
|
|
|
*
|
|
|
|
* @param string $path The file path to which to $contents should be written
|
|
|
|
* @param string $contents The data to write to the specified $path
|
|
|
|
* @return \Amp\Promise A promise resolving to the integer length written upon success
|
|
|
|
*/
|
|
|
|
function put($path, $contents) {
|
|
|
|
return filesystem()->put($path, $contents);
|
|
|
|
}
|