. */ namespace OC\Files\Cache; class Shared_Updater { // shares which can be removed from oc_share after the delete operation was successful static private $toRemove = array(); /** * @brief walk up the users file tree and update the etags * @param string $user * @param string $path */ static private function correctUsersFolder($user, $path) { // $path points to the mount point which is a virtual folder, so we start with // the parent $path = '/files' . dirname($path); \OC\Files\Filesystem::initMountPoints($user); $view = new \OC\Files\View('/' . $user); if ($view->file_exists($path)) { while ($path !== dirname($path)) { $etag = $view->getETag($path); $view->putFileInfo($path, array('etag' => $etag)); $path = dirname($path); } } else { \OCP\Util::writeLog('files_sharing', 'can not update etags on ' . $path . ' for user ' . $user . '. Path does not exists', \OCP\Util::DEBUG); } } /** * Correct the parent folders' ETags for all users shared the file at $target * * @param string $target */ static public function correctFolders($target) { // ignore part files if (pathinfo($target, PATHINFO_EXTENSION) === 'part') { return false; } // Correct Shared folders of other users shared with $shares = \OCA\Files_Sharing\Helper::getSharesFromItem($target); foreach ($shares as $share) { if ((int)$share['share_type'] === \OCP\Share::SHARE_TYPE_USER) { self::correctUsersFolder($share['share_with'], $share['file_target']); } elseif ((int)$share['share_type'] === \OCP\Share::SHARE_TYPE_GROUP) { $users = \OC_Group::usersInGroup($share['share_with']); foreach ($users as $user) { self::correctUsersFolder($user, $share['file_target']); } } else { //unique name for group share self::correctUsersFolder($share['share_with'], $share['file_target']); } } } /** * @brief remove all shares for a given file if the file was deleted * * @param string $path */ private static function removeShare($path) { $fileSource = self::$toRemove[$path]; if (!\OC\Files\Filesystem::file_exists($path)) { $query = \OC_DB::prepare('DELETE FROM `*PREFIX*share` WHERE `file_source`=?'); try { \OC_DB::executeAudited($query, array($fileSource)); } catch (\Exception $e) { \OCP\Util::writeLog('files_sharing', "can't remove share: " . $e->getMessage(), \OCP\Util::WARN); } } unset(self::$toRemove[$path]); } /** * @param array $params */ static public function writeHook($params) { self::correctFolders($params['path']); } /** * @param array $params */ static public function renameHook($params) { self::correctFolders($params['newpath']); self::correctFolders(pathinfo($params['oldpath'], PATHINFO_DIRNAME)); } /** * @param array $params */ static public function deleteHook($params) { self::correctFolders($params['path']); $fileInfo = \OC\Files\Filesystem::getFileInfo($params['path']); // mark file as deleted so that we can clean up the share table if // the file was deleted successfully self::$toRemove[$params['path']] = $fileInfo['fileid']; } /** * @param array $params */ static public function postDeleteHook($params) { self::removeShare($params['path']); } /** * clean up oc_share table from files which are no longer exists * * This fixes issues from updates from files_sharing < 0.3.5.6 (ownCloud 4.5) * It will just be called during the update of the app */ static public function fixBrokenSharesOnAppUpdate() { // delete all shares where the original file no longer exists $findAndRemoveShares = \OC_DB::prepare('DELETE FROM `*PREFIX*share` ' . 'WHERE `file_source` NOT IN ( ' . 'SELECT `fileid` FROM `*PREFIX*filecache` WHERE `item_type` IN (\'file\', \'folder\'))' ); $findAndRemoveShares->execute(array()); } }