<?php
/**
 * webtrees: online genealogy
 * Copyright (C) 2018 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([(string)$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 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 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 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 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 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 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 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 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 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 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 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 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 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;
    }

    /**
     * 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 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;
    }
}