Subversion Repositories eFlore/Applications.del

<?php
// declare(encoding='UTF-8');
/**
 * Contient les méthodes permettant d'identifier l'utilisateur de l'application DEL.
 *
 * @category  DEL
 * @package   Services
 * @package   Bibliotheque
 * @version   0.1
 * @author    Mathias CHOUET <mathias@tela-botanica.org>
 * @author    Jean-Pascal MILCENT <jpm@tela-botanica.org>
 * @author    Aurelien PERONNET <aurelien@tela-botanica.org>
 * @license   GPL v3 <http://www.gnu.org/licenses/gpl.txt>
 * @license   CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
 * @copyright 1999-2014 Tela Botanica <accueil@tela-botanica.org>
 */
class GestionUtilisateur {

        protected $conteneur;
        protected $contexte;
        protected $bdd;

        protected $utilisateur = array();

        public function __construct(Conteneur $conteneur) {
                $this->conteneur = $conteneur;
                $this->bdd = $this->conteneur->getBdd();
                $this->contexte = $this->conteneur->getContexte();
                $this->chargerUtilisateur();
        }

        /**
         * Charge des données utilisateur : un vrai profil si l'utilisateur est identifié,
         * un profil "anonyme" sinon 
         */
        private function chargerUtilisateur() {
                $this->demarrerSession();
                $infos = $this->getUtilisateurIdentifie();
                $this->utilisateur = ($infos == null) ? $this->getUtilisateurAnonyme() : $infos;
        }

        private function demarrerSession() {
                if (session_id() == '') {
                        // TODO : modifier ce test lors du passage en php 5.4
                        // TODO : expliquer pourquoi SVP :)
                        session_start();
                }
        }

        // rétrocompat avec un vieux machin
        public function getIdAnonymeTemporaire() {
                return $this->utilisateur['session_id'];
        }

        /**
         * Retourne l'utilisateur en cours, chargé dans le constructeur
         * par getutilisateurIdentifié()
         */
        public function getUtilisateur() {
                return $this->utilisateur;
        }

        /**
         * Recherche un jeton SSO dans l'entête HTTP "Authorization", vérifie ce
         * jeton auprès de l'annuaire et en cas de succès charge les informations
         * de l'utilisateur associé
         * 
         * @return Array un profil utilisateur ou null
         */
        public function getUtilisateurIdentifie() {
                $utilisateur = null;
                // lecture du jeton
                $jeton = $this->lireJetonEntete();
                if ($jeton != null) {
                        // validation par l'annuaire
                        $valide = $this->verifierJeton($jeton);
                        if ($valide === true) {
                                // décodage du courriel utilisateur depuis le jeton
                                $donneesJeton = $this->decoderJeton($jeton);
                                if ($donneesJeton != null && $donneesJeton["sub"] != "") {
                                        // récupération de l'utilisateur
                                        $courriel = $donneesJeton["sub"];
                                        $utilisateur = $this->recupererUtilisateurEnBdd($courriel);
                                }
                        }
                }
                if ($utilisateur != null) {
                        $utilisateur = $this->completerInfosUtilisateur($utilisateur);
                }
                return $utilisateur;
        }

        /**
         * Essaye de trouver un jeton JWT non vide dans l'entête HTTP "Authorization"
         * 
         * @return String un jeton JWT ou null
         */
        protected function lireJetonEntete() {
                $jwt = null;
                $headers = apache_request_headers();
                if (isset($headers["Authorization"]) && ($headers["Authorization"] != "")) {
                        $jwt = $headers["Authorization"];
                }
                return $jwt;
        }

        /**
         * Vérifie un jeton auprès de l'annuaire 
         * 
         * @param String $jeton un jeton JWT
         * @return true si le jeton est vérifié, false sinon
         */
        protected function verifierJeton($jeton) {
                $urlServiceVerification = $this->conteneur->getParametre("urlServiceBaseAuth") . "verifierjeton";
                $urlServiceVerification .= "?token=" . $jeton;

                // file_get_contents râle si le certificat HTTPS est auto-signé
                //$retour = file_get_contents($urlServiceVerification);

                // curl avec les options suivantes ignore le pb de certificat (pour tester en local)
                $ch = curl_init();
                $timeout = 5;
                curl_setopt($ch, CURLOPT_URL, $urlServiceVerification);
                curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
                curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
                // équivalent de "-k"
                curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
                curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
                $data = curl_exec($ch);
                curl_close($ch);
                $retour = $data;

                $retour = json_decode($retour, true);

                return ($retour === true);
        }

        /**
         * Décode un jeton JWT (SSO) précédemment validé et retourne les infos
         * qu'il contient (payload / claims)
         * @param String $jeton un jeton JWT précédemment validé
         */
        protected function decoderJeton($jeton) {
                $parts = explode('.', $jeton);
                $payload = $parts[1];
                $payload = $this->urlsafeB64Decode($payload);
                $payload = json_decode($payload, true);

                return $payload;
        }

        /**
         * Decode a string with URL-safe Base64.
         * copié depuis firebase/jwt
         *
         * @param string $input A Base64 encoded string
         * @return string A decoded string
         */
        protected function urlsafeB64Decode($input)     {
                $remainder = strlen($input) % 4;
                if ($remainder) {
                        $padlen = 4 - $remainder;
                        $input .= str_repeat('=', $padlen);
                }
                return base64_decode(strtr($input, '-_', '+/'));
        }

        /**
         * Retourne un profil d'utilisateur non connecté (anonyme), avec un identifiant de session
         * PHP qui permet de suivre son activité
         */
        public function getUtilisateurAnonyme() {
                return array(
                        'connecte' => false,
                        'id_utilisateur' => session_id(),
                        'courriel' => '',
                        'mot_de_passe' => '',
                        'nom' => '',
                        'prenom' => '',
                        'admin' => '0',
                        'session_id' => session_id()
                );
        }

        /**
         * Récupère les données d'un utilisateur dans la BDD depuis son login; considère que
         * l'utilisateur est légitime car il fournit un jeton SSO vérifié par l'annuaire
         * 
         * @param String $login le courriel de l'utilisateur
         * @return array les infos de l'utilisateur
         */
        private function recupererUtilisateurEnBdd($login) {
                $loginP = $this->bdd->proteger($login);

                $requete = 'SELECT du.id_utilisateur, nom, prenom, courriel, dui.admin '.
                        'FROM del_utilisateur AS du '.
                        '       LEFT JOIN del_utilisateur_infos AS dui ON (du.id_utilisateur = dui.id_utilisateur) '.
                        "WHERE courriel = $loginP ".
                        ' -- '.__FILE__.' : '.__LINE__;

                return $this->bdd->recuperer($requete);
        }

        protected function completerInfosUtilisateur($utilisateur) {
                $utilisateur['session_id'] = session_id();
                $utilisateur['connecte'] = true;
                return $utilisateur;
        }

        // @WARNING décompte des derniers événements désactivé pour raisons de perfs
        // Mathias - 2016-10-05 @TODO faire mieux
        protected function getEvenements($id_utilisateur) {
                $sql = $this->conteneur->getSql();

                $date = $this->getDerniereDateConsultationEvenements($id_utilisateur);

                //$requete_activite = $sql->getRequeteNbEvenementsDepuisDate($id_utilisateur, $date);
                //$resultats = $this->bdd->recupererTous($requete_activite);

                $evenements = array();
                //$nb_evenements = $resultats[0]['nb_evenements'];
                //$evenements['nb_evenements'] = $nb_evenements;
                $evenements['date_derniere_consultation_evenements'] = $date;

                return $evenements;
        }

        public function getDerniereDateConsultationEvenements($id_utilisateur) {
                $requete = "SELECT date_derniere_consultation_evenements FROM del_utilisateur_infos ".
                                        "WHERE id_utilisateur = ".$this->bdd->proteger($id_utilisateur);
                $date = $this->bdd->recuperer($requete);
                $date = !empty($date['date_derniere_consultation_evenements']) ? $date['date_derniere_consultation_evenements'] : "0";
                return $date;
        }

        public function setDerniereDateConsultationEvenements($id_utilisateur, $date) { 
                // Vérification que la ligne correspondant à l'utilisateur dans la table
                // infos existe bien (sinon on la crée)
                $infos_utilisateur = $this->obtenirInfosUtilisateur($id_utilisateur);
                if (empty($infos_utilisateur)) {
                        $this->initialiserInfosUtilisateur($id_utilisateur);
                }
                
                $requete = "UPDATE del_utilisateur_infos SET date_derniere_consultation_evenements = ".$this->bdd->proteger($date)." ".
                                        "WHERE id_utilisateur = ".$this->bdd->proteger($id_utilisateur);
                $this->bdd->executer($requete);
        }

        protected function ajouterEvenements(&$utilisateur) {
                $evenements = $this->getEvenements($utilisateur['id_utilisateur']);
                $utilisateur = array_merge($utilisateur, $evenements);
        }

        public function obtenirPreferencesUtilisateur($id_utilisateur) {
                $prefs_utilisateur = $this->obtenirInfosUtilisateur($id_utilisateur);
                if (empty($prefs_utilisateur)) {
                        $this->initialiserInfosUtilisateur($id_utilisateur);
                        $prefs_utilisateur = $this->renvoyerInfosUtilisateurDefaut($id_utilisateur);
                } else {
                        if (empty($prefs_utilisateur['preferences'])) {
                                $prefs_utilisateur['preferences'] = $this->obtenirTableauPreferenceDefaut();
                        } else {
                                $prefs_utilisateur['preferences'] = json_decode($prefs_utilisateur['preferences']);
                        }
                        $prefs_utilisateur['admin'] = $prefs_utilisateur['admin'];
                }
        
                return $prefs_utilisateur;
        }

        private function obtenirTableauPreferenceDefaut() {
                return array('mail_notification_mes_obs' => '1', 'mail_notification_toutes_obs' => '0');
        }

        private function renvoyerInfosUtilisateurDefaut($id_utilisateur) {
                return array('id_utilisateur' => $id_utilisateur,
                                'admin' => '0',
                                'preferences' => $this->obtenirTableauPreferenceDefaut(),
                                'date_premiere_utilisation' => date('Y-m-d H:i:s'),
                                'date_derniere_consultation_evenements' => '0000-00-00 00:00:00');
        }

        public function obtenirInfosUtilisateur($id_utilisateur) {
                $requete = 'SELECT * '.
                                'FROM del_utilisateur_infos '.
                                'WHERE id_utilisateur = '.$this->bdd->proteger($id_utilisateur).' '.
                                ' -- '.__FILE__.' : '.__LINE__;
                $prefs_utilisateur = $this->bdd->recuperer($requete);
                return $prefs_utilisateur;
        }

        public function initialiserInfosUtilisateur($id_utilisateur) {
                $preferences_defaut = $this->obtenirTableauPreferenceDefaut();
                $prefsEncodeesP = $this->bdd->proteger(json_encode($preferences_defaut));
                $idUtilisateurP = $this->bdd->proteger($id_utilisateur);
                $requete = 'INSERT INTO del_utilisateur_infos '.
                                '(id_utilisateur, admin, preferences, date_premiere_utilisation )'.
                                "VALUES ($idUtilisateurP, 0, $prefsEncodeesP, NOW()) ".
                                'ON DUPLICATE KEY UPDATE date_premiere_utilisation = NOW() '.
                                ' -- '.__FILE__.' : '.__LINE__;
                return $this->bdd->executer($requete);
        }

        /**
         * Vérifie qu'un utilisateur connu est identifié (mode non anonyme) et
         * que son identifiant numérique est égal à $id_utilisateur; si non,
         * retourne une erreur HTTP 401 et quitte le programme
         * 
         * @param integer $id_utilisateur l'utilisateur attendu
         */
        public function controleUtilisateurIdentifie($id_utilisateur) {
                $ok = ($this->utilisateur['connecte'] === true && $this->utilisateur['id_utilisateur'] == $id_utilisateur);
                if (! $ok) {
                        $message = "";
                        if ($this->utilisateur['connecte'] === true) {
                                $message = "Vous n'êtes pas propriétaire de la ressource demandée";
                        } else {
                                $message = "Vous n'êtes pas identifié";
                        }
                        $code = RestServeur::HTTP_CODE_ACCES_NON_AUTORISE;
                        throw new Exception($message, $code);
                }
        }

        // rétrocompat'
        public function etreAdmin() {
                return ($this->utilisateur['admin'] >= 1);
        }

        // rétrocompat'
        public function etreUtilisateurAvecDroitAdmin() {
                $etreAdmin = $this->etreAdmin();
                if (! $etreAdmin) {
                        $message = "Vous ne pouvez pas accéder à ce service car vous n'avez pas les droits d'administrateur !\n";
                        $code = RestServeur::HTTP_CODE_ACCES_NON_AUTORISE;
                        throw new Exception($message, $code);
                }
                return $etreAdmin;
        }
}

/**
 * Compatibilité avec nginx - merci http://php.net/manual/fr/function.getallheaders.php
 */
if (! function_exists('apache_request_headers')) {
        function apache_request_headers() {
                $headers = '';
                foreach ($_SERVER as $name => $value) {
                        if (substr($name, 0, 5) == 'HTTP_') {
                                $headers[str_replace(' ', '-', ucwords(strtolower(str_replace('_', ' ', substr($name, 5)))))] = $value;
                        }
                }
                return $headers;
        }
}