. * */ namespace OC\Files\Storage; /** * Convert target path to source path and pass the function call to the correct storage provider */ class Shared extends \OC\Files\Storage\Common { private $sharedFolder; private $files = array(); public function __construct($arguments) { $this->sharedFolder = $arguments['sharedFolder']; } public function getId(){ return 'shared::' . $this->sharedFolder; } /** * @brief Get the source file path, permissions, and owner for a shared file * @param string Shared target file path * @return Returns array with the keys path, permissions, and owner or false if not found */ private function getFile($target) { if (!isset($this->files[$target])) { $source = \OC_Share_Backend_File::getSource($target); if ($source) { $source['path'] = '/'.$source['uid_owner'].'/'.$source['path']; } $this->files[$target] = $source; } return $this->files[$target]; } /** * @brief Get the source file path for a shared file * @param string Shared target file path * @return string source file path or false if not found */ private function getSourcePath($target) { $source = $this->getFile($target); if ($source) { \OC\Files\Filesystem::initMountPoints($source['uid_owner']); return $source['path']; } return false; } /** * @brief Get the permissions granted for a shared file * @param string Shared target file path * @return int CRUDS permissions granted or false if not found */ public function getPermissions($target) { $source = $this->getFile($target); if ($source) { return $source['permissions']; } return false; } public function mkdir($path) { if ($path == '' || $path == '/' || !$this->isCreatable(dirname($path))) { return false; } else if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->mkdir($internalPath); } return false; } public function rmdir($path) { if (($source = $this->getSourcePath($path)) && $this->isDeletable($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->rmdir($internalPath); } return false; } public function opendir($path) { if ($path == '' || $path == '/') { $files = \OCP\Share::getItemsSharedWith('file', \OC_Share_Backend_Folder::FORMAT_OPENDIR); \OC_FakeDirStream::$dirs['shared'] = $files; return opendir('fakedir://shared'); } else if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->opendir($internalPath); } return false; } public function is_dir($path) { if ($path == '' || $path == '/') { return true; } else if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->is_dir($internalPath); } return false; } public function is_file($path) { if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->is_file($internalPath); } return false; } public function stat($path) { if ($path == '' || $path == '/') { $stat['size'] = $this->filesize($path); $stat['mtime'] = $this->filemtime($path); return $stat; } else if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->stat($internalPath); } return false; } public function filetype($path) { if ($path == '' || $path == '/') { return 'dir'; } else if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->filetype($internalPath); } return false; } public function filesize($path) { if ($path == '' || $path == '/' || $this->is_dir($path)) { return 0; } else if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->filesize($internalPath); } return false; } public function isCreatable($path) { if ($path == '') { return false; } return ($this->getPermissions($path) & \OCP\PERMISSION_CREATE); } public function isReadable($path) { return $this->file_exists($path); } public function isUpdatable($path) { if ($path == '') { return false; } return ($this->getPermissions($path) & \OCP\PERMISSION_UPDATE); } public function isDeletable($path) { if ($path == '') { return true; } return ($this->getPermissions($path) & \OCP\PERMISSION_DELETE); } public function isSharable($path) { if ($path == '') { return false; } return ($this->getPermissions($path) & \OCP\PERMISSION_SHARE); } public function file_exists($path) { if ($path == '' || $path == '/') { return true; } else if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->file_exists($internalPath); } return false; } public function filemtime($path) { if ($path == '' || $path == '/') { $mtime = 0; if ($dh = $this->opendir($path)) { while (($filename = readdir($dh)) !== false) { $tempmtime = $this->filemtime($filename); if ($tempmtime > $mtime) { $mtime = $tempmtime; } } } return $mtime; } else { $source = $this->getSourcePath($path); if ($source) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->filemtime($internalPath); } } } public function file_get_contents($path) { $source = $this->getSourcePath($path); if ($source) { $info = array( 'target' => $this->sharedFolder.$path, 'source' => $source, ); \OCP\Util::emitHook('\OC\Files\Storage\Shared', 'file_get_contents', $info); list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->file_get_contents($internalPath); } } public function file_put_contents($path, $data) { if ($source = $this->getSourcePath($path)) { // Check if permission is granted if (($this->file_exists($path) && !$this->isUpdatable($path)) || ($this->is_dir($path) && !$this->isCreatable($path))) { return false; } $info = array( 'target' => $this->sharedFolder.$path, 'source' => $source, ); \OCP\Util::emitHook('\OC\Files\Storage\Shared', 'file_put_contents', $info); list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); $result = $storage->file_put_contents($internalPath, $data); return $result; } return false; } public function unlink($path) { // Delete the file if DELETE permission is granted if ($source = $this->getSourcePath($path)) { if ($this->isDeletable($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->unlink($internalPath); } else if (dirname($path) == '/' || dirname($path) == '.') { // Unshare the file from the user if in the root of the Shared folder if ($this->is_dir($path)) { $itemType = 'folder'; } else { $itemType = 'file'; } return \OCP\Share::unshareFromSelf($itemType, $path); } } return false; } public function rename($path1, $path2) { // Renaming/moving is only allowed within shared folders $pos1 = strpos($path1, '/', 1); $pos2 = strpos($path2, '/', 1); if ($pos1 !== false && $pos2 !== false && ($oldSource = $this->getSourcePath($path1))) { $newSource = $this->getSourcePath(dirname($path2)).'/'.basename($path2); if (dirname($path1) == dirname($path2)) { // Rename the file if UPDATE permission is granted if ($this->isUpdatable($path1)) { list($storage, $oldInternalPath) = \OC\Files\Filesystem::resolvePath($oldSource); list( , $newInternalPath) = \OC\Files\Filesystem::resolvePath($newSource); return $storage->rename($oldInternalPath, $newInternalPath); } } else { // Move the file if DELETE and CREATE permissions are granted if ($this->isDeletable($path1) && $this->isCreatable(dirname($path2))) { // Get the root shared folder $folder1 = substr($path1, 0, $pos1); $folder2 = substr($path2, 0, $pos2); // Copy and unlink the file if it exists in a different shared folder if ($folder1 != $folder2) { if ($this->copy($path1, $path2)) { return $this->unlink($path1); } } else { list($storage, $oldInternalPath) = \OC\Files\Filesystem::resolvePath($oldSource); list( , $newInternalPath) = \OC\Files\Filesystem::resolvePath($newSource); return $storage->rename($oldInternalPath, $newInternalPath); } } } } return false; } public function copy($path1, $path2) { // Copy the file if CREATE permission is granted if ($this->isCreatable(dirname($path2))) { $source = $this->fopen($path1, 'r'); $target = $this->fopen($path2, 'w'); return \OC_Helper::streamCopy($source, $target); } return false; } public function fopen($path, $mode) { if ($source = $this->getSourcePath($path)) { switch ($mode) { case 'r+': case 'rb+': case 'w+': case 'wb+': case 'x+': case 'xb+': case 'a+': case 'ab+': case 'w': case 'wb': case 'x': case 'xb': case 'a': case 'ab': if (!$this->isUpdatable($path)) { return false; } } $info = array( 'target' => $this->sharedFolder.$path, 'source' => $source, 'mode' => $mode, ); \OCP\Util::emitHook('\OC\Files\Storage\Shared', 'fopen', $info); list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->fopen($internalPath, $mode); } return false; } public function getMimeType($path) { if ($path == '' || $path == '/') { return 'httpd/unix-directory'; } if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->getMimeType($internalPath); } return false; } public function free_space($path) { if ($path == '') { return -1; } $source = $this->getSourcePath($path); if ($source) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->free_space($internalPath); } } public function getLocalFile($path) { if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->getLocalFile($internalPath); } return false; } public function touch($path, $mtime = null) { if ($source = $this->getSourcePath($path)) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); return $storage->touch($internalPath, $mtime); } return false; } public static function setup($options) { if (\OCP\Share::getItemsSharedWith('file')) { $user_dir = $options['user_dir']; \OC\Files\Filesystem::mount('\OC\Files\Storage\Shared', array('sharedFolder' => '/Shared'), $user_dir.'/Shared/'); } } public function hasUpdated($path, $time) { if ($path == '') { return false; } return $this->filemtime($path) > $time; } public function getCache($path = '') { return new \OC\Files\Cache\Shared_Cache($this); } public function getScanner($path = '') { if ($path != '' && ($source = $this->getSourcePath($path))) { list($storage, $internalPath) = \OC\Files\Filesystem::resolvePath($source); if ($storage) { return $storage->getScanner($internalPath); } } return new \OC\Files\Cache\Scanner($this); } public function getPermissionsCache($path = '') { return new \OC\Files\Cache\Shared_Permissions($this); } public function getWatcher($path = '') { return new \OC\Files\Cache\Shared_Watcher($this); } public function getOwner($path) { if ($path == '') { return false; } $source = $this->getFile($path); if ($source) { return $source['uid_owner']; } return false; } public function getETag($path) { } }