. * */ /** * Convert target path to source path and pass the function call to the correct storage provider */ class OC_Filestorage_Shared extends OC_Filestorage_Common { private $sharedFolder; private $files = array(); public function __construct($arguments) { $this->sharedFolder = $arguments['sharedFolder']; } /** * @brief Get the source file path and the permissions granted for a shared file * @param string Shared target file path * @return Returns array with the keys path and permissions or false if not found */ private function getFile($target) { $target = $this->sharedFolder.'/'.$target; $target = rtrim($target, '/'); if (isset($this->files[$target])) { return $this->files[$target]; } else { $pos = strpos($target, '/', 8); // Get shared folder name if ($pos !== false) { $itemTarget = substr($target, 0, $pos); } else { $itemTarget = $target; } $file = OCP\Share::getItemSharedWith('file', $itemTarget, OC_Share_Backend_File::FORMAT_SHARED_STORAGE); if ($file) { $this->files[$target]['path'] = $file['path'].substr($target, strlen($itemTarget)); $this->files[$target]['permissions'] = $file['permissions']; return $this->files[$target]; } OCP\Util::writeLog('files_sharing', 'File source not found for: '.$target, OCP\Util::ERROR); return false; } } /** * @brief Get the source file path for a shared file * @param string Shared target file path * @return Returns source file path or false if not found */ private function getSourcePath($target) { $file = $this->getFile($target); if (isset($file['path'])) { return $file['path']; } return false; } /** * @brief Get the permissions granted for a shared file * @param string Shared target file path * @return Returns CRUDS permissions granted or false if not found */ private function getPermissions($target) { $file = $this->getFile($target); if (isset($file['permissions'])) { return $file['permissions']; } return false; } /** * @brief Get the internal path to pass to the storage filesystem call * @param string Source file path * @return Source file path with mount point stripped out */ private function getInternalPath($path) { $mountPoint = OC_Filesystem::getMountPoint($path); $internalPath = substr($path, strlen($mountPoint)); return $internalPath; } public function mkdir($path) { if ($path == '' || $path == '/' || !$this->is_writable(dirname($path))) { return false; } else if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->mkdir($this->getInternalPath($source)); } return false; } public function rmdir($path) { if ($source = $this->getSourcePath($path) && ($this->getPermissions($path) & OCP\Share::PERMISSION_DELETE)) { $storage = OC_Filesystem::getStorage($source); return $storage->rmdir($this->getInternalPath($source)); } 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)) { $storage = OC_Filesystem::getStorage($source); return $storage->opendir($this->getInternalPath($source)); } return false; } public function is_dir($path) { if ($path == '' || $path == '/') { return true; } else if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->is_dir($this->getInternalPath($source)); } return false; } public function is_file($path) { if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->is_file($this->getInternalPath($source)); } return false; } public function stat($path) { if ($path == '' || $path == '/') { $stat['size'] = $this->filesize($path); $stat['mtime'] = $this->filemtime($path); $stat['ctime'] = $this->filectime($path); return $stat; } else if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->stat($this->getInternalPath($source)); } return false; } public function filetype($path) { if ($path == '' || $path == '/') { return 'dir'; } else if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->filetype($this->getInternalPath($source)); } return false; } public function filesize($path) { if ($path == '' || $path == '/' || $this->is_dir($path)) { return 0; } else if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->filesize($this->getInternalPath($source)); } return false; } public function is_readable($path) { return $this->file_exists($path); } public function is_writable($path) { if ($path == '' || $path == '/') { return false; // Folders need CREATE permission to be writable } else if ($this->is_dir($path)) { if ($this->getPermissions($path) & OCP\Share::PERMISSION_CREATE) { return true; } // Files need UPDATE permission to be writable } else if ($this->getPermissions($path) & OCP\Share::PERMISSION_UPDATE) { return true; } return false; } public function file_exists($path) { if ($path == '' || $path == '/') { return true; } else if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->file_exists($this->getInternalPath($source)); } return false; } public function filectime($path) { if ($path == '' || $path == '/') { $ctime = 0; if ($dh = $this->opendir($path)) { while (($filename = readdir($dh)) !== false) { $tempctime = $this->filectime($filename); if ($tempctime < $ctime) { $ctime = $tempctime; } } } return $ctime; } else { $source = $this->getSourcePath($path); if ($source) { $storage = OC_Filesystem::getStorage($source); return $storage->filectime($this->getInternalPath($source)); } } } 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) { $storage = OC_Filesystem::getStorage($source); return $storage->filemtime($this->getInternalPath($source)); } } } public function file_get_contents($path) { $source = $this->getSourcePath($path); if ($source) { $info = array( 'target' => $this->sharedFolder.$path, 'source' => $source, ); OCP\Util::emitHook('OC_Filestorage_Shared', 'file_get_contents', $info); $storage = OC_Filesystem::getStorage($source); return $storage->file_get_contents($this->getInternalPath($source)); } } public function file_put_contents($path, $data) { if ($this->is_writable($path)) { $source = $this->getSourcePath($path); if ($source) { $info = array( 'target' => $this->sharedFolder.$path, 'source' => $source, ); OCP\Util::emitHook('OC_Filestorage_Shared', 'file_put_contents', $info); $storage = OC_Filesystem::getStorage($source); $result = $storage->file_put_contents($this->getInternalPath($source), $data); if ($result) { $this->clearFolderSizeCache($path); } return $result; } } } public function unlink($path) { // TODO } public function rename($path1, $path2) { // TODO } public function copy($path1, $path2) { // TODO } public function fopen($path, $mode) { if ($source = $this->getSourcePath($path)) { $info = array( 'target' => $this->sharedFolder.$path, 'source' => $source, 'mode' => $mode, ); OCP\Util::emitHook('OC_Filestorage_Shared', 'fopen', $info); $storage = OC_Filesystem::getStorage($source); return $storage->fopen($this->getInternalPath($source), $mode); } return false; } public function toTmpFile($path) { if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->toTmpFile($this->getInternalPath($source)); } return false; } public function getMimeType($path) { if ($path == '' || $path == '/') { return 'httpd/unix-directory'; } if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->getMimeType($this->getInternalPath($source)); } return false; } public function hash($type, $path, $raw) { if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->hash($type, $this->getInternalPath($source), $raw); } } public function free_space($path) { $source = $this->getSourcePath($path); if ($source) { $storage = OC_Filesystem::getStorage($source); return $storage->free_space($this->getInternalPath($source)); } } public function getLocalFile($path) { if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->getLocalFile($this->getInternalPath($source)); } return false; } public function touch($path, $mtime = null) { if ($source = $this->getSourcePath($path)) { $storage = OC_Filesystem::getStorage($source); return $storage->touch($this->getInternalPath($source), $mtime); } return false; } public static function setup($options) { $user_dir = $options['user_dir']; OC_Filesystem::mount('OC_Filestorage_Shared', array('sharedFolder' => '/Shared'), $user_dir.'/Shared/'); } /** * check if a file or folder has been updated since $time * @param int $time * @return bool */ public function hasUpdated($path,$time){ //TODO return false; } }