nextcloud/lib/private/Repair/Owncloud/MoveAvatarsBackgroundJob.php

<?php
/**
 * @copyright 2016 Roeland Jago Douma <roeland@famdouma.nl>
 *
 * @author Joas Schilling <coding@schilljs.com>
 * @author Morris Jobke <hey@morrisjobke.de>
 * @author Roeland Jago Douma <roeland@famdouma.nl>
 *
 * @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 <http://www.gnu.org/licenses/>.
 *
 */
namespace OC\Repair\Owncloud;

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) {
			$this->logger->info('No legacy avatars available, skipping migration');
			return;
		}

		$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);
	}
}