xiaowang/kirby/src/Cms/UserActions.php
2023-04-14 16:30:28 +02:00

389 lines
8.5 KiB
PHP

<?php
namespace Kirby\Cms;
use Closure;
use Kirby\Data\Data;
use Kirby\Exception\LogicException;
use Kirby\Exception\PermissionException;
use Kirby\Filesystem\Dir;
use Kirby\Filesystem\F;
use Kirby\Form\Form;
use Kirby\Http\Idn;
use Kirby\Toolkit\Str;
use SensitiveParameter;
use Throwable;
/**
* UserActions
*
* @package Kirby Cms
* @author Bastian Allgeier <bastian@getkirby.com>
* @link https://getkirby.com
* @copyright Bastian Allgeier
* @license https://getkirby.com/license
*/
trait UserActions
{
/**
* Changes the user email address
*
* @param string $email
* @return static
*/
public function changeEmail(string $email)
{
$email = trim($email);
return $this->commit('changeEmail', ['user' => $this, 'email' => Idn::decodeEmail($email)], function ($user, $email) {
$user = $user->clone([
'email' => $email
]);
$user->updateCredentials([
'email' => $email
]);
// update the users collection
$user->kirby()->users()->set($user->id(), $user);
return $user;
});
}
/**
* Changes the user language
*
* @param string $language
* @return static
*/
public function changeLanguage(string $language)
{
return $this->commit('changeLanguage', ['user' => $this, 'language' => $language], function ($user, $language) {
$user = $user->clone([
'language' => $language,
]);
$user->updateCredentials([
'language' => $language
]);
// update the users collection
$user->kirby()->users()->set($user->id(), $user);
return $user;
});
}
/**
* Changes the screen name of the user
*
* @param string $name
* @return static
*/
public function changeName(string $name)
{
$name = trim($name);
return $this->commit('changeName', ['user' => $this, 'name' => $name], function ($user, $name) {
$user = $user->clone([
'name' => $name
]);
$user->updateCredentials([
'name' => $name
]);
// update the users collection
$user->kirby()->users()->set($user->id(), $user);
return $user;
});
}
/**
* Changes the user password
*/
public function changePassword(
#[SensitiveParameter]
string $password
): static {
return $this->commit('changePassword', ['user' => $this, 'password' => $password], function ($user, $password) {
$user = $user->clone([
'password' => $password = User::hashPassword($password)
]);
$user->writePassword($password);
// update the users collection
$user->kirby()->users()->set($user->id(), $user);
return $user;
});
}
/**
* Changes the user role
*
* @param string $role
* @return static
*/
public function changeRole(string $role)
{
return $this->commit('changeRole', ['user' => $this, 'role' => $role], function ($user, $role) {
$user = $user->clone([
'role' => $role,
]);
$user->updateCredentials([
'role' => $role
]);
// update the users collection
$user->kirby()->users()->set($user->id(), $user);
return $user;
});
}
/**
* Commits a user action, by following these steps
*
* 1. checks the action rules
* 2. sends the before hook
* 3. commits the action
* 4. sends the after hook
* 5. returns the result
*
* @param string $action
* @param array $arguments
* @param \Closure $callback
* @return mixed
* @throws \Kirby\Exception\PermissionException
*/
protected function commit(string $action, array $arguments, Closure $callback)
{
if ($this->isKirby() === true) {
throw new PermissionException('The Kirby user cannot be changed');
}
$old = $this->hardcopy();
$kirby = $this->kirby();
$argumentValues = array_values($arguments);
$this->rules()->$action(...$argumentValues);
$kirby->trigger('user.' . $action . ':before', $arguments);
$result = $callback(...$argumentValues);
if ($action === 'create') {
$argumentsAfter = ['user' => $result];
} elseif ($action === 'delete') {
$argumentsAfter = ['status' => $result, 'user' => $old];
} else {
$argumentsAfter = ['newUser' => $result, 'oldUser' => $old];
}
$kirby->trigger('user.' . $action . ':after', $argumentsAfter);
$kirby->cache('pages')->flush();
return $result;
}
/**
* Creates a new User from the given props and returns a new User object
*
* @param array|null $props
* @return static
*/
public static function create(array $props = null)
{
$data = $props;
if (isset($props['email']) === true) {
$data['email'] = Idn::decodeEmail($props['email']);
}
if (isset($props['password']) === true) {
$data['password'] = User::hashPassword($props['password']);
}
$props['role'] = $props['model'] = strtolower($props['role'] ?? 'default');
$user = User::factory($data);
// create a form for the user
$form = Form::for($user, [
'values' => $props['content'] ?? []
]);
// inject the content
$user = $user->clone(['content' => $form->strings(true)]);
// run the hook
return $user->commit('create', ['user' => $user, 'input' => $props], function ($user, $props) {
$user->writeCredentials([
'email' => $user->email(),
'language' => $user->language(),
'name' => $user->name()->value(),
'role' => $user->role()->id(),
]);
$user->writePassword($user->password());
// always create users in the default language
if ($user->kirby()->multilang() === true) {
$languageCode = $user->kirby()->defaultLanguage()->code();
} else {
$languageCode = null;
}
// add the user to users collection
$user->kirby()->users()->add($user);
// write the user data
return $user->save($user->content()->toArray(), $languageCode);
});
}
/**
* Returns a random user id
*
* @return string
*/
public function createId(): string
{
$length = 8;
do {
try {
$id = Str::random($length);
if (UserRules::validId($this, $id) === true) {
return $id;
}
// we can't really test for a random match
// @codeCoverageIgnoreStart
} catch (Throwable) {
$length++;
}
} while (true);
// @codeCoverageIgnoreEnd
}
/**
* Deletes the user
*
* @return bool
* @throws \Kirby\Exception\LogicException
*/
public function delete(): bool
{
return $this->commit('delete', ['user' => $this], function ($user) {
if ($user->exists() === false) {
return true;
}
// delete all public assets for this user
Dir::remove($user->mediaRoot());
// delete the user directory
if (Dir::remove($user->root()) !== true) {
throw new LogicException('The user directory for "' . $user->email() . '" could not be deleted');
}
// remove the user from users collection
$user->kirby()->users()->remove($user);
return true;
});
}
/**
* Read the account information from disk
*
* @return array
*/
protected function readCredentials(): array
{
$path = $this->root() . '/index.php';
if (is_file($path) === true) {
$credentials = F::load($path, allowOutput: false);
return is_array($credentials) === false ? [] : $credentials;
}
return [];
}
/**
* Reads the user password from disk
*
* @return string|false
*/
protected function readPassword()
{
return F::read($this->root() . '/.htpasswd');
}
/**
* Updates the user data
*
* @param array|null $input
* @param string|null $languageCode
* @param bool $validate
* @return static
*/
public function update(array $input = null, string $languageCode = null, bool $validate = false)
{
$user = parent::update($input, $languageCode, $validate);
// set auth user data only if the current user is this user
if ($user->isLoggedIn() === true) {
$this->kirby()->auth()->setUser($user);
}
// update the users collection
$user->kirby()->users()->set($user->id(), $user);
return $user;
}
/**
* This always merges the existing credentials
* with the given input.
*
* @param array $credentials
* @return bool
*/
protected function updateCredentials(array $credentials): bool
{
// normalize the email address
if (isset($credentials['email']) === true) {
$credentials['email'] = Str::lower(trim($credentials['email']));
}
return $this->writeCredentials(array_merge($this->credentials(), $credentials));
}
/**
* Writes the account information to disk
*
* @param array $credentials
* @return bool
*/
protected function writeCredentials(array $credentials): bool
{
return Data::write($this->root() . '/index.php', $credentials);
}
/**
* Writes the password to disk
*/
protected function writePassword(
#[SensitiveParameter]
string $password = null
): bool {
return F::write($this->root() . '/.htpasswd', $password);
}
}