* * @author Joas Schilling * @author Morris Jobke * @author Roeland Jago Douma * * @license GNU AGPL version 3 or any later version * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . * */ namespace OC\Repair\NC11; use OC\BackgroundJob\QueuedJob; use OCP\Files\File; use OCP\Files\Folder; use OCP\Files\IAppData; use OCP\Files\IRootFolder; use OCP\Files\NotFoundException; use OCP\Files\SimpleFS\ISimpleFolder; use OCP\ILogger; use OCP\IUser; use OCP\IUserManager; class MoveAvatarsBackgroundJob extends QueuedJob { /** @var IUserManager */ private $userManager; /** @var IRootFolder */ private $rootFolder; /** @var IAppData */ private $appData; /** @var ILogger */ private $logger; /** * MoveAvatars constructor. */ public function __construct() { $this->userManager = \OC::$server->getUserManager(); $this->rootFolder = \OC::$server->getRootFolder(); $this->logger = \OC::$server->getLogger(); $this->appData = \OC::$server->getAppDataDir('avatar'); } public function run($arguments) { $this->logger->info('Started migrating avatars to AppData folder'); $this->moveAvatars(); $this->logger->info('All avatars migrated to AppData folder'); } private function moveAvatars() { try { $ownCloudAvatars = $this->rootFolder->get('avatars'); } catch (NotFoundException $e) { $ownCloudAvatars = null; } $counter = 0; $this->userManager->callForSeenUsers(function (IUser $user) use ($counter, $ownCloudAvatars) { $uid = $user->getUID(); \OC\Files\Filesystem::initMountPoints($uid); /** @var Folder $userFolder */ $userFolder = $this->rootFolder->get($uid); try { $userData = $this->appData->getFolder($uid); } catch (NotFoundException $e) { $userData = $this->appData->newFolder($uid); } $foundAvatars = $this->copyAvatarsFromFolder($userFolder, $userData); // ownCloud migration? if ($foundAvatars === 0 && $ownCloudAvatars instanceof Folder) { $parts = $this->buildOwnCloudAvatarPath($uid); $userOwnCloudAvatar = $ownCloudAvatars; foreach ($parts as $part) { try { $userOwnCloudAvatar = $userOwnCloudAvatar->get($part); } catch (NotFoundException $e) { return; } } $this->copyAvatarsFromFolder($userOwnCloudAvatar, $userData); } $counter++; if ($counter % 100 === 0) { $this->logger->info('{amount} avatars migrated', ['amount' => $counter]); } }); } /** * @param Folder $source * @param ISimpleFolder $target * @return int * @throws \OCP\Files\NotPermittedException * @throws NotFoundException */ protected function copyAvatarsFromFolder(Folder $source, ISimpleFolder $target) { $foundAvatars = 0; $avatars = $source->getDirectoryListing(); $regex = '/^avatar\.([0-9]+\.)?(jpg|png)$/'; foreach ($avatars as $avatar) { /** @var File $avatar */ if (preg_match($regex, $avatar->getName())) { /* * This is not the most effective but it is the most abstract way * to handle this. Avatars should be small anyways. */ $newAvatar = $target->newFile($avatar->getName()); $newAvatar->putContent($avatar->getContent()); $avatar->delete(); $foundAvatars++; } } return $foundAvatars; } protected function buildOwnCloudAvatarPath($userId) { $avatar = substr_replace(substr_replace(md5($userId), '/', 4, 0), '/', 2, 0); return explode('/', $avatar); } }