<?php
/**
 * webtrees: online genealogy
 * Copyright (C) 2017 webtrees development team
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU 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 General Public License for more details.
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */
declare(strict_types=1);

namespace Fisharebest\Webtrees;

use stdclass;

/**
 * Provide an interface to the wt_user table.
 */
class User {
	/** @var  int The primary key of this user. */
	private $user_id;

	/** @var  string The login name of this user. */
	private $user_name;

	/** @var  string The real (display) name of this user. */
	private $real_name;

	/** @var  string The email address of this user. */
	private $email;

	/** @var string[] Cached copy of the wt_user_setting table. */
	private $preferences = [];

	/** @var  User[] Only fetch users from the database once. */
	private static $cache = [];

	/**
	 * Create a new user object from a row in the database.
	 *
	 * @param stdclass $user A row from the wt_user table
	 */
	public function __construct(stdClass $user) {
		$this->user_id   = (int) $user->user_id;
		$this->user_name = $user->user_name;
		$this->real_name = $user->real_name;
		$this->email     = $user->email;
	}

	/**
	 * Create a new user.
	 *
	 * The calling code needs to check for duplicates identifiers before calling
	 * this function.
	 *
	 * @param string $user_name
	 * @param string $real_name
	 * @param string $email
	 * @param string $password
	 *
	 * @return User
	 */
	public static function create($user_name, $real_name, $email, $password) {
		Database::prepare(
			"INSERT INTO `##user` (user_name, real_name, email, password) VALUES (:user_name, :real_name, :email, :password)"
		)->execute([
			'user_name' => $user_name,
			'real_name' => $real_name,
			'email'     => $email,
			'password'  => password_hash($password, PASSWORD_DEFAULT),
		]);

		// Set default blocks for this user
		$user = self::findByIdentifier($user_name);
		Database::prepare(
			"INSERT INTO `##block` (`user_id`, `location`, `block_order`, `module_name`)" .
			" SELECT :user_id , `location`, `block_order`, `module_name` FROM `##block` WHERE `user_id` = -1"
		)->execute(['user_id' => $user->getUserId()]);

		return $user;
	}

	/**
	 * Delete a user
	 */
	public function delete() {
		// Don't delete the logs.
		Database::prepare("UPDATE `##log` SET user_id=NULL WHERE user_id =?")->execute([$this->user_id]);
		// Take over the user’s pending changes. (What else could we do with them?)
		Database::prepare("DELETE FROM `##change` WHERE user_id=? AND status='rejected'")->execute([$this->user_id]);
		Database::prepare("UPDATE `##change` SET user_id=? WHERE user_id=?")->execute([Auth::id(), $this->user_id]);
		Database::prepare("DELETE `##block_setting` FROM `##block_setting` JOIN `##block` USING (block_id) WHERE user_id=?")->execute([$this->user_id]);
		Database::prepare("DELETE FROM `##block` WHERE user_id=?")->execute([$this->user_id]);
		Database::prepare("DELETE FROM `##user_gedcom_setting` WHERE user_id=?")->execute([$this->user_id]);
		Database::prepare("DELETE FROM `##gedcom_setting` WHERE setting_value=? AND setting_name IN ('CONTACT_USER_ID', 'WEBMASTER_USER_ID')")->execute([$this->user_id]);
		Database::prepare("DELETE FROM `##user_setting` WHERE user_id=?")->execute([$this->user_id]);
		Database::prepare("DELETE FROM `##message` WHERE user_id=?")->execute([$this->user_id]);
		Database::prepare("DELETE FROM `##user` WHERE user_id=?")->execute([$this->user_id]);
	}

	/**
	 * Find the user with a specified user_id.
	 *
	 * @param int|null $user_id
	 *
	 * @return User|null
	 */
	public static function find($user_id) {
		if (!array_key_exists($user_id, self::$cache)) {
			$row = Database::prepare(
				"SELECT SQL_CACHE user_id, user_name, real_name, email FROM `##user` WHERE user_id = ?"
			)->execute([$user_id])->fetchOneRow();
			if ($row) {
				self::$cache[$user_id] = new self($row);
			} else {
				self::$cache[$user_id] = null;
			}
		}

		return self::$cache[$user_id];
	}

	/**
	 * Find the user with a specified email address.
	 *
	 * @param string $email
	 *
	 * @return User|null
	 */
	public static function findByEmail($email) {
		$user_id = Database::prepare(
			"SELECT SQL_CACHE user_id FROM `##user` WHERE email = :email"
		)->execute([
			'email' => $email,
		])->fetchOne();

		return self::find($user_id);
	}

	/**
	 * Find the user with a specified user_name or email address.
	 *
	 * @param string $identifier
	 *
	 * @return User|null
	 */
	public static function findByIdentifier($identifier) {
		$user_id = Database::prepare(
			"SELECT SQL_CACHE user_id FROM `##user` WHERE ? IN (user_name, email)"
		)->execute([$identifier])->fetchOne();

		return self::find($user_id);
	}

	/**
	 * Find the user with a specified genealogy record.
	 *
	 * @param Individual $individual
	 *
	 * @return User|null
	 */
	public static function findByIndividual(Individual $individual) {
		$user_id = Database::prepare(
			"SELECT SQL_CACHE user_id" .
			" FROM `##user_gedcom_setting`" .
			" WHERE gedcom_id = :tree_id AND setting_name = 'gedcomid' AND setting_value = :xref"
		)->execute([
			'tree_id' => $individual->getTree()->getTreeId(),
			'xref'    => $individual->getXref(),
		])->fetchOne();

		return self::find($user_id);
	}

	/**
	 * Find the user with a specified user_name.
	 *
	 * @param string $user_name
	 *
	 * @return User|null
	 */
	public static function findByUserName($user_name) {
		$user_id = Database::prepare(
			"SELECT SQL_CACHE user_id FROM `##user` WHERE user_name = :user_name"
		)->execute([
			'user_name' => $user_name,
		])->fetchOne();

		return self::find($user_id);
	}

	/**
	 * Find the latest user to register.
	 *
	 * @return User|null
	 */
	public static function findLatestToRegister() {
		$user_id = Database::prepare(
			"SELECT SQL_CACHE u.user_id" .
			" FROM `##user` u" .
			" LEFT JOIN `##user_setting` us ON (u.user_id=us.user_id AND us.setting_name='reg_timestamp') " .
			" ORDER BY us.setting_value DESC LIMIT 1"
		)->execute()->fetchOne();

		return self::find($user_id);
	}

	/**
	 * Get a list of all users.
	 *
	 * @return User[]
	 */
	public static function all() {
		$rows = Database::prepare(
			"SELECT SQL_CACHE user_id, user_name, real_name, email" .
			" FROM `##user`" .
			" WHERE user_id > 0" .
			" ORDER BY real_name"
		)->fetchAll();

		return array_map(function($row) {
			return new static($row);
		}, $rows);
	}

	/**
	 * Get a list of all administrators.
	 *
	 * @return User[]
	 */
	public static function administrators() {
		$rows = Database::prepare(
			"SELECT SQL_CACHE user_id, user_name, real_name, email" .
			" FROM `##user`" .
			" JOIN `##user_setting` USING (user_id)" .
			" WHERE user_id > 0 AND setting_name = 'canadmin' AND setting_value = '1'" .
			" ORDER BY real_name"
		)->fetchAll();

		return array_map(function($row) {
			return new static($row);
		}, $rows);
	}

	/** Validate a supplied password
	 * @param string $password
	 *
	 * @return bool
	 */
	public function checkPassword($password) {
		$password_hash = Database::prepare(
			"SELECT password FROM `##user` WHERE user_id = ?"
		)->execute([$this->user_id])->fetchOne();

		if (password_verify($password, $password_hash)) {
			if (password_needs_rehash($password_hash, PASSWORD_DEFAULT)) {
				$this->setPassword($password);
			}

			return true;
		} else {
			return false;
		}
	}

	/**
	 * Get a list of all managers.
	 *
	 * @return User[]
	 */
	public static function managers() {
		$rows = Database::prepare(
			"SELECT SQL_CACHE user_id, user_name, real_name, email" .
			" FROM `##user` JOIN `##user_gedcom_setting` USING (user_id)" .
			" WHERE setting_name = 'canedit' AND setting_value='admin'" .
			" GROUP BY user_id, real_name" .
			" ORDER BY real_name"
		)->fetchAll();

		return array_map(function($row) {
			return new static($row);
		}, $rows);
	}

	/**
	 * Get a list of all moderators.
	 *
	 * @return User[]
	 */
	public static function moderators() {
		$rows = Database::prepare(
			"SELECT SQL_CACHE user_id, user_name, real_name, email" .
			" FROM `##user` JOIN `##user_gedcom_setting` USING (user_id)" .
			" WHERE setting_name = 'canedit' AND setting_value='accept'" .
			" GROUP BY user_id, real_name" .
			" ORDER BY real_name"
		)->fetchAll();

		return array_map(function($row) {
			return new static($row);
		}, $rows);
	}

	/**
	 * Get a list of all verified users.
	 *
	 * @return User[]
	 */
	public static function unapproved() {
		$rows = Database::prepare(
			"SELECT SQL_CACHE user_id, user_name, real_name, email" .
			" FROM `##user` JOIN `##user_setting` USING (user_id)" .
			" WHERE setting_name = 'verified_by_admin' AND setting_value = '0'" .
			" ORDER BY real_name"
		)->fetchAll();

		return array_map(function($row) {
			return new static($row);
		}, $rows);
	}

	/**
	 * Get a list of all verified users.
	 *
	 * @return User[]
	 */
	public static function unverified() {
		$rows = Database::prepare(
			"SELECT SQL_CACHE user_id, user_name, real_name, email" .
			" FROM `##user` JOIN `##user_setting` USING (user_id)" .
			" WHERE setting_name = 'verified' AND setting_value = '0'" .
			" ORDER BY real_name"
		)->fetchAll();

		return array_map(function($row) {
			return new static($row);
		}, $rows);
	}

	/**
	 * Get a list of all users who are currently logged in.
	 *
	 * @return User[]
	 */
	public static function allLoggedIn() {
		$rows = Database::prepare(
			"SELECT SQL_NO_CACHE DISTINCT user_id, user_name, real_name, email" .
			" FROM `##user`" .
			" JOIN `##session` USING (user_id)"
		)->fetchAll();

		return array_map(function($row) {
			return new static($row);
		}, $rows);
	}

	/**
	 * Get the numeric ID for this user.
	 *
	 * @return int
	 */
	public function getUserId(): int {
		return $this->user_id;
	}

	/**
	 * Get the login name for this user.
	 *
	 * @return string
	 */
	public function getUserName() {
		return $this->user_name;
	}

	/**
	 * Set the login name for this user.
	 *
	 * @param string $user_name
	 *
	 * @return $this
	 */
	public function setUserName($user_name) {
		if ($this->user_name !== $user_name) {
			$this->user_name = $user_name;
			Database::prepare(
				"UPDATE `##user` SET user_name = ? WHERE user_id = ?"
			)->execute([$user_name, $this->user_id]);
		}

		return $this;
	}

	/**
	 * Get the real name of this user.
	 *
	 * @return string
	 */
	public function getRealName() {
		return $this->real_name;
	}

	/**
	 * Get the real name of this user, for display on screen.
	 *
	 * @return string
	 */
	public function getRealNameHtml() {
		return '<span dir="auto">' . Html::escape($this->real_name) . '</span>';
	}

	/**
	 * Set the real name of this user.
	 *
	 * @param string $real_name
	 *
	 * @return User
	 */
	public function setRealName($real_name) {
		if ($this->real_name !== $real_name) {
			$this->real_name = $real_name;
			Database::prepare(
				"UPDATE `##user` SET real_name = ? WHERE user_id = ?"
			)->execute([$real_name, $this->user_id]);
		}

		return $this;
	}

	/**
	 * Get the email address of this user.
	 *
	 * @return string
	 */
	public function getEmail() {
		return $this->email;
	}

	/**
	 * Set the email address of this user.
	 *
	 * @param string $email
	 *
	 * @return User
	 */
	public function setEmail($email) {
		if ($this->email !== $email) {
			$this->email = $email;
			Database::prepare(
				"UPDATE `##user` SET email = ? WHERE user_id = ?"
			)->execute([$email, $this->user_id]);
		}

		return $this;
	}

	/**
	 * Set the password of this user.
	 *
	 * @param string $password
	 *
	 * @return User
	 */
	public function setPassword($password) {
		Database::prepare(
			"UPDATE `##user` SET password = :password WHERE user_id = :user_id"
		)->execute([
			'password' => password_hash($password, PASSWORD_DEFAULT),
			'user_id'  => $this->user_id,
		]);

		return $this;
	}

	/**
	 * Fetch a user option/setting from the wt_user_setting table.
	 *
	 * Since we'll fetch several settings for each user, and since there aren’t
	 * that many of them, fetch them all in one database query
	 *
	 * @param string $setting_name
	 * @param string $default
	 *
	 * @return string
	 */
	public function getPreference($setting_name, $default = '') {
		if (empty($this->preferences) && $this->user_id !== 0) {
			$this->preferences = Database::prepare(
				"SELECT SQL_CACHE setting_name, setting_value" .
				" FROM `##user_setting`" .
				" WHERE user_id = :user_id"
			)->execute([
				'user_id' => $this->user_id,
			])->fetchAssoc();
		}

		if (!array_key_exists($setting_name, $this->preferences)) {
			$this->preferences[$setting_name] = $default;
		}

		return $this->preferences[$setting_name];
	}

	/**
	 * Update a setting for the user.
	 *
	 * @param string $setting_name
	 * @param string $setting_value
	 *
	 * @return User
	 */
	public function setPreference($setting_name, $setting_value) {
		if ($this->user_id !== 0 && $this->getPreference($setting_name) !== $setting_value) {
			Database::prepare("REPLACE INTO `##user_setting` (user_id, setting_name, setting_value) VALUES (?, ?, LEFT(?, 255))")
				->execute([$this->user_id, $setting_name, $setting_value]);

			$this->preferences[$setting_name] = $setting_value;
		}

		return $this;
	}
}