szurubooru/src/Api/Jobs/UserJobs/EditUserEmailJob.php

<?php
class EditUserEmailJob extends AbstractJob
{
	protected $userRetriever;

	public function __construct()
	{
		$this->userRetriever = new UserRetriever($this);
	}

	public function execute()
	{
		if (Core::getConfig()->registration->needEmailForRegistering)
			if (!$this->hasArgument(JobArgs::ARG_NEW_EMAIL) or empty($this->getArgument(JobArgs::ARG_NEW_EMAIL)))
				throw new SimpleException('E-mail address is required - you will be sent confirmation e-mail.');

		$user = $this->userRetriever->retrieve();
		$newEmail = $this->getArgument(JobArgs::ARG_NEW_EMAIL);

		$oldEmail = $user->getConfirmedEmail();
		if ($oldEmail == $newEmail)
			return $user;

		$user->setUnconfirmedEmail($newEmail);
		$user->setConfirmedEmail(null);

		if ($this->getContext() == self::CONTEXT_NORMAL)
		{
			UserModel::save($user);
			self::observeSave($user);
		}

		Logger::log('{user} changed {subject}\'s e-mail to {mail}', [
			'user' => TextHelper::reprUser(Auth::getCurrentUser()),
			'subject' => TextHelper::reprUser($user),
			'mail' => $newEmail]);

		return $user;
	}

	public static function observeSave($user)
	{
		if (Access::check(new Privilege(Privilege::ChangeUserEmailNoConfirm), $user))
		{
			$user->confirmEmail();
		}
		else
		{
			if (!empty($user->getUnconfirmedEmail()))
				ActivateUserEmailJob::sendEmail($user);
		}
	}

	public function getRequiredArguments()
	{
		return JobArgs::Conjunction(
			$this->userRetriever->getRequiredArguments(),
			JobArgs::ARG_NEW_EMAIL);
	}

	public function getRequiredPrivileges()
	{
		return new Privilege(
			$this->getContext() == self::CONTEXT_BATCH_ADD
				? Privilege::RegisterAccount
				: Privilege::ChangeUserEmail,
			Access::getIdentity($this->userRetriever->retrieve()));
	}
}