2806 |
aurelien |
1 |
<?php
|
|
|
2 |
// declare(encoding='UTF-8');
|
|
|
3 |
/**
|
|
|
4 |
* Classe de gestion des utilisateurs
|
|
|
5 |
*
|
|
|
6 |
*
|
|
|
7 |
* @internal Mininum PHP version : 5.2
|
|
|
8 |
* @category CEL
|
|
|
9 |
* @package Services
|
|
|
10 |
* @subpackage Bibliothèques
|
|
|
11 |
* @version 0.1
|
|
|
12 |
* @author Aurelien PERONNET <aurelien@tela-botanica.org>
|
|
|
13 |
* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
|
|
|
14 |
* @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
|
|
|
15 |
* @copyright 1999-2015 Tela Botanica <accueil@tela-botanica.org>
|
|
|
16 |
*/
|
|
|
17 |
class GestionUtilisateur extends Cel {
|
3027 |
mathias |
18 |
|
|
|
19 |
/** contient le jeton SSO décodé, si une authentification a eu lieu avec succès */
|
|
|
20 |
protected $token_decode;
|
|
|
21 |
|
2823 |
mathias |
22 |
public function obtenirIdentiteConnectee() {
|
3058 |
mathias |
23 |
echo "coucou2\n";
|
2823 |
mathias |
24 |
$login_utilisateur = $this->getLoginUtilisateurVerifie();
|
|
|
25 |
if ($login_utilisateur) {
|
|
|
26 |
$utilisateur = $this->chargerInfosUtilisateur($login_utilisateur);
|
|
|
27 |
$utilisateur['connecte'] = true;
|
|
|
28 |
} else {
|
|
|
29 |
$utilisateur = $this->getUtilisateurAnonyme();
|
2806 |
aurelien |
30 |
}
|
2823 |
mathias |
31 |
return $utilisateur;
|
|
|
32 |
}
|
|
|
33 |
|
|
|
34 |
public function obtenirUtilisateurSiExiste($login_utilisateur) {
|
|
|
35 |
$utilisateur = $this->getUtilisateurAnonyme();
|
|
|
36 |
if ($utilisateur_existe = $this->chargerInfosUtilisateur($login_utilisateur)) {
|
|
|
37 |
$utilisateur = $utilisateur_existe;
|
|
|
38 |
$utilisateur['connecte'] = true;
|
|
|
39 |
}
|
|
|
40 |
return $utilisateur;
|
|
|
41 |
}
|
3027 |
mathias |
42 |
|
3028 |
mathias |
43 |
/**
|
|
|
44 |
* Retourne les informations contenues dans la table cel_utilisateurs_infos,
|
|
|
45 |
* pour un login (adresse courriel) donné
|
|
|
46 |
*/
|
|
|
47 |
protected function lireCelUtilisateursInfos($login) {
|
2823 |
mathias |
48 |
$requete = 'SELECT * '.
|
3027 |
mathias |
49 |
'FROM cel_utilisateurs_infos AS cu '.
|
2823 |
mathias |
50 |
'WHERE courriel = '.Cel::db()->proteger($login).' '.
|
|
|
51 |
' -- '.__FILE__.':'.__LINE__;
|
|
|
52 |
$resultats = Cel::db()->requeter($requete);
|
3027 |
mathias |
53 |
|
2823 |
mathias |
54 |
if (is_array($resultats) && count($resultats) > 0) {
|
3028 |
mathias |
55 |
return $resultats[0];
|
3027 |
mathias |
56 |
} else {
|
3028 |
mathias |
57 |
return false;
|
|
|
58 |
}
|
|
|
59 |
}
|
|
|
60 |
|
|
|
61 |
/**
|
|
|
62 |
* Retourne true si le profil local stocké dans cel_utilisateurs_infos
|
|
|
63 |
* n'est plus à jour par rapport aux informations du jeton SSO; si le
|
|
|
64 |
* jeton est vide, retourne false pour éviter de tout casser
|
|
|
65 |
*/
|
|
|
66 |
protected function profilAChange($infosCUI) {
|
|
|
67 |
$aChange = false;
|
|
|
68 |
if ($this->token_decode != null) {
|
|
|
69 |
$aChange = ($this->token_decode['nom'] != $infosCUI['nom'])
|
|
|
70 |
|| ($this->token_decode['intitule'] != $infosCUI['intitule'])
|
|
|
71 |
|| ($this->token_decode['prenom'] != $infosCUI['prenom']);
|
|
|
72 |
}
|
|
|
73 |
//var_dump($aChange);
|
|
|
74 |
return $aChange;
|
|
|
75 |
}
|
|
|
76 |
|
|
|
77 |
/**
|
|
|
78 |
* Met à jour cel_utilisateurs_infos en fonction des informations
|
|
|
79 |
* contenues par le jeton SSO; si ce dernier est vide, ne fait
|
|
|
80 |
* rien (boulette-proof)
|
|
|
81 |
*/
|
|
|
82 |
protected function mettreAJourProfilLocal() {
|
|
|
83 |
//echo "Mise à jour profil local !!";
|
|
|
84 |
if ($this->token_decode != null && $this->token_decode['id'] != '') {
|
|
|
85 |
$requete = 'UPDATE cel_utilisateurs_infos SET'
|
|
|
86 |
. ' nom = ' . Cel::db()->proteger($this->token_decode['nom']) . ', '
|
|
|
87 |
. ' intitule = ' . Cel::db()->proteger($this->token_decode['intitule']) . ', '
|
|
|
88 |
. ' prenom = ' . Cel::db()->proteger($this->token_decode['prenom'])
|
|
|
89 |
. ' WHERE id_utilisateur = ' . Cel::db()->proteger($this->token_decode['id'])
|
|
|
90 |
. ' -- '.__FILE__.':'.__LINE__
|
|
|
91 |
;
|
|
|
92 |
//var_dump($requete);
|
|
|
93 |
Cel::db()->executer($requete);
|
|
|
94 |
}
|
|
|
95 |
}
|
|
|
96 |
|
|
|
97 |
/**
|
|
|
98 |
* Répercute le nom et le prénom contenus dans le jeton SSO (si au
|
|
|
99 |
* moins un des deux n'est pas vide) dans toutes les observations
|
|
|
100 |
* et images de l'auteur; si le jeton SSO est vide, ne fait rien
|
|
|
101 |
* (boulette-proof)
|
|
|
102 |
*
|
|
|
103 |
* @TODO gérer l'intitulé un jour
|
|
|
104 |
*/
|
|
|
105 |
protected function mettreAJourCoordonneesDansObsEtImages() {
|
|
|
106 |
//echo "Mise à jour obs et images !!";
|
|
|
107 |
if ($this->token_decode != null && $this->token_decode['id'] != '' && ($this->token_decode['nom'] != '' || $this->token_decode['prenom'] != '')) {
|
|
|
108 |
$requete = 'UPDATE cel_obs SET'
|
|
|
109 |
. ' nom_utilisateur = ' . Cel::db()->proteger($this->token_decode['nom']) . ', '
|
|
|
110 |
. ' prenom_utilisateur = ' . Cel::db()->proteger($this->token_decode['prenom'])
|
|
|
111 |
. ' WHERE ce_utilisateur = ' . Cel::db()->proteger($this->token_decode['id']) // s'assurer qu'il y a des ' autour de l'ID sans quoi les hash MD5 matcheront !
|
|
|
112 |
. ' -- '.__FILE__.':'.__LINE__
|
|
|
113 |
;
|
|
|
114 |
//var_dump($requete);
|
|
|
115 |
Cel::db()->executer($requete);
|
|
|
116 |
$requete = 'UPDATE cel_images SET'
|
|
|
117 |
. ' nom_utilisateur = ' . Cel::db()->proteger($this->token_decode['nom']) . ', '
|
|
|
118 |
. ' prenom_utilisateur = ' . Cel::db()->proteger($this->token_decode['prenom'])
|
|
|
119 |
. ' WHERE ce_utilisateur = ' . Cel::db()->proteger($this->token_decode['id']) // s'assurer qu'il y a des ' autour de l'ID sans quoi les hash MD5 matcheront !
|
|
|
120 |
. ' -- '.__FILE__.':'.__LINE__
|
|
|
121 |
;
|
|
|
122 |
//var_dump($requete);
|
|
|
123 |
Cel::db()->executer($requete);
|
|
|
124 |
}
|
|
|
125 |
}
|
|
|
126 |
|
|
|
127 |
/**
|
|
|
128 |
* Charge l'état de l'utilisateur en fonction du jeton SSO avec lequel celui-ci
|
|
|
129 |
* est identifié; si c'est la première fois que l'utilisateur se connecte au CeL,
|
3032 |
mathias |
130 |
* crée un profil local dans cel_utilisateurs_infos; si le profil a changé depuis
|
|
|
131 |
* la dernière connexion, le met à jour ainsi que les coordonnées dans les images
|
3028 |
mathias |
132 |
* et observations
|
|
|
133 |
*
|
3058 |
mathias |
134 |
* Si l'utilisateur n'est pas identifié, retourne false (pour le widget de saisie par ex.)
|
|
|
135 |
*
|
3028 |
mathias |
136 |
* @param string $login le login (adresse courriel) de l'utilisateur
|
|
|
137 |
*/
|
|
|
138 |
private function chargerInfosUtilisateur($login) {
|
|
|
139 |
//var_dump($this->token_decode);
|
3058 |
mathias |
140 |
// si l'utilisateur n'est pas connecté (pas porteur d'un jeton), au revoir
|
|
|
141 |
if ($this->token_decode == null) {
|
|
|
142 |
return false;
|
|
|
143 |
}
|
|
|
144 |
|
|
|
145 |
// sinon, si on a affaire à quelqu'un de connecté :
|
3028 |
mathias |
146 |
$infosCUI = $this->lireCelUtilisateursInfos($login);
|
|
|
147 |
|
|
|
148 |
$retour = false;
|
|
|
149 |
if ($infosCUI !== false) {
|
|
|
150 |
// Les données du profil ont-elles changé depuis la dernière connexion ?
|
|
|
151 |
if ($this->profilAChange($infosCUI)) {
|
|
|
152 |
// mise à jour du profil local
|
|
|
153 |
$this->mettreAJourProfilLocal();
|
|
|
154 |
// mise à jour des obs et images
|
|
|
155 |
$this->mettreAJourCoordonneesDansObsEtImages();
|
|
|
156 |
// re-lecture du nouveau profil local (permet de détecter si la mise à jour s'est mal passée)
|
|
|
157 |
$retour = $this->lireCelUtilisateursInfos($login);
|
|
|
158 |
} else {
|
|
|
159 |
$retour = $infosCUI;
|
|
|
160 |
}
|
|
|
161 |
} else {
|
3027 |
mathias |
162 |
// première connexion au CeL !
|
|
|
163 |
$this->initialiserInfosUtilisateur();
|
2823 |
mathias |
164 |
$this->affecterDonneesWidgetSaisie($login, $retour);
|
|
|
165 |
}
|
2806 |
aurelien |
166 |
// booleanisation des valeurs
|
|
|
167 |
$retour['admin'] = ($retour['admin'] == 1);
|
2823 |
mathias |
168 |
$retour['licence_acceptee'] = (isset($retour['licence_acceptee']) && ($retour['licence_acceptee'] == 1));
|
3027 |
mathias |
169 |
|
2823 |
mathias |
170 |
return $retour;
|
|
|
171 |
}
|
3027 |
mathias |
172 |
|
2823 |
mathias |
173 |
private function utilisateurEstAutorise($id_utilisateur) {
|
|
|
174 |
$autorise = false;
|
2806 |
aurelien |
175 |
$token = $this->getToken();
|
2823 |
mathias |
176 |
// TODO: tester si le jeton contient réelement quelque chose ?
|
|
|
177 |
if($token) {
|
|
|
178 |
// On demande à l'annuaire si le jeton est bien valide
|
|
|
179 |
$valide = file_get_contents($this->config['identification']['sso_url'].'/verifierjeton?token='.$token);
|
|
|
180 |
$token_decode = $this->decoderToken($token);
|
|
|
181 |
|
|
|
182 |
// Si l'utilisateur du token est bien le même que celui sur lequel on veut agir : OK
|
|
|
183 |
if($token_decode['id'] == $id_utilisateur) {
|
|
|
184 |
$autorise = true;
|
|
|
185 |
} else {
|
|
|
186 |
// Sinon on vérifie que l'utilisateur est admin
|
3027 |
mathias |
187 |
$requete = "SELECT admin FROM cel_utilisateurs_infos WHERE id_utilisateur = ".Cel::db()->proteger($token_decode['id']);
|
2823 |
mathias |
188 |
$resultat = Cel::db()->requeter($requete);
|
|
|
189 |
|
|
|
190 |
$admin = false;
|
|
|
191 |
if ($resultat && count($resultat) > 0) {
|
|
|
192 |
$autorise = ($resultat[0]['admin'] == 1);
|
|
|
193 |
}
|
|
|
194 |
}
|
|
|
195 |
} else {
|
|
|
196 |
// pas de token, on vérifie bien qu'il s'agit d'une session temporaire
|
|
|
197 |
$autorise = ($id_utilisateur == session_id());
|
|
|
198 |
}
|
|
|
199 |
return $autorise;
|
2806 |
aurelien |
200 |
}
|
2823 |
mathias |
201 |
|
|
|
202 |
// renvoie false ou bien le login utilisateur actuel
|
|
|
203 |
private function getLoginUtilisateurVerifie() {
|
|
|
204 |
$token = $this->getToken();
|
|
|
205 |
$login = false;
|
|
|
206 |
if($token) {
|
|
|
207 |
// On demande à l'annuaire si le jeton est bien valide
|
2846 |
mathias |
208 |
|
|
|
209 |
// curl avec les options suivantes ignore le pb de certificat (pour tester en local)
|
|
|
210 |
// @TODO CHANGER !
|
|
|
211 |
$ch = curl_init();
|
|
|
212 |
$timeout = 5;
|
3027 |
mathias |
213 |
$url = $this->config['identification']['sso_url'].'/verifierjeton?token='.$token;
|
|
|
214 |
curl_setopt($ch, CURLOPT_URL, $url);
|
2846 |
mathias |
215 |
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
|
|
216 |
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
|
|
|
217 |
// équivalent de "-k"
|
|
|
218 |
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
|
|
|
219 |
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
|
|
220 |
$valide = curl_exec($ch);
|
|
|
221 |
curl_close($ch);
|
|
|
222 |
|
|
|
223 |
//$valide = file_get_contents($this->config['identification']['sso_url'].'/verifierjeton?token='.$token);
|
2823 |
mathias |
224 |
$login = ($valide === "true") ? $this->obtenirLoginParToken($token) : false;
|
|
|
225 |
}
|
|
|
226 |
|
|
|
227 |
return $login;
|
|
|
228 |
}
|
3027 |
mathias |
229 |
|
|
|
230 |
// @WTF doublon avec la méthode du dessus ? Qu'est-ce que c'est que ce bins ?
|
2846 |
mathias |
231 |
protected function verifierJeton($jeton) {
|
|
|
232 |
$urlServiceVerification = $this->conteneur->getParametre("urlServiceBaseAuth") . "verifierjeton";
|
|
|
233 |
$urlServiceVerification .= "?token=" . $jeton;
|
|
|
234 |
|
|
|
235 |
// file_get_contents râle si le certificat HTTPS est auto-signé
|
|
|
236 |
//$retour = file_get_contents($urlServiceVerification);
|
|
|
237 |
|
|
|
238 |
// curl avec les options suivantes ignore le pb de certificat (pour tester en local)
|
|
|
239 |
$ch = curl_init();
|
|
|
240 |
$timeout = 5;
|
|
|
241 |
curl_setopt($ch, CURLOPT_URL, $urlServiceVerification);
|
|
|
242 |
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
|
|
243 |
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
|
|
|
244 |
// équivalent de "-k"
|
|
|
245 |
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
|
|
|
246 |
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
|
|
247 |
$data = curl_exec($ch);
|
|
|
248 |
curl_close($ch);
|
|
|
249 |
$retour = $data;
|
|
|
250 |
|
|
|
251 |
$retour = json_decode($retour, true);
|
|
|
252 |
|
|
|
253 |
return ($retour === true);
|
|
|
254 |
}
|
2823 |
mathias |
255 |
|
|
|
256 |
private function decoderToken($token) {
|
|
|
257 |
$token_parts = explode('.', $token);
|
3024 |
mathias |
258 |
return json_decode($this->urlsafeB64Decode($token_parts[1]), true);
|
2823 |
mathias |
259 |
}
|
3024 |
mathias |
260 |
|
|
|
261 |
/**
|
|
|
262 |
* Decode a string with URL-safe Base64.
|
|
|
263 |
* copié depuis firebase/jwt
|
|
|
264 |
*
|
|
|
265 |
* @param string $input A Base64 encoded string
|
|
|
266 |
* @return string A decoded string
|
|
|
267 |
*/
|
|
|
268 |
protected function urlsafeB64Decode($input) {
|
|
|
269 |
$remainder = strlen($input) % 4;
|
|
|
270 |
if ($remainder) {
|
|
|
271 |
$padlen = 4 - $remainder;
|
|
|
272 |
$input .= str_repeat('=', $padlen);
|
|
|
273 |
}
|
|
|
274 |
return base64_decode(strtr($input, '-_', '+/'));
|
|
|
275 |
}
|
2823 |
mathias |
276 |
|
|
|
277 |
private function obtenirLoginParToken($token) {
|
3027 |
mathias |
278 |
$this->token_decode = $this->decoderToken($token);
|
|
|
279 |
return $this->token_decode['sub'];
|
2823 |
mathias |
280 |
}
|
|
|
281 |
|
|
|
282 |
private function getToken() {
|
|
|
283 |
// Premier essai, dans le header
|
|
|
284 |
$headers = apache_request_headers();
|
|
|
285 |
$token = !empty($headers['Authorization']) ? $headers['Authorization'] : null;
|
|
|
286 |
|
|
|
287 |
// Sinon dans $_REQUEST ?
|
|
|
288 |
if($token == null) {
|
|
|
289 |
$token = !empty($_REQUEST['Authorization']) ? $_REQUEST['Authorization'] : null;
|
|
|
290 |
}
|
|
|
291 |
|
|
|
292 |
return $token;
|
|
|
293 |
}
|
|
|
294 |
|
|
|
295 |
private function getUtilisateurAnonyme() {
|
|
|
296 |
return array('connecte' => false,
|
|
|
297 |
'id_utilisateur' => session_id(),
|
|
|
298 |
'courriel' => '',
|
|
|
299 |
'mot_de_passe' => '',
|
|
|
300 |
'nom' => '',
|
|
|
301 |
'prenom' => '',
|
|
|
302 |
'licence_acceptee' => false,
|
|
|
303 |
'preferences_utilisateur' => '',
|
|
|
304 |
'admin' => false
|
|
|
305 |
);
|
|
|
306 |
}
|
3027 |
mathias |
307 |
|
|
|
308 |
/**
|
|
|
309 |
* Lors de la première connexion au CeL, remplis la table cel_utilisateurs_infos avec
|
|
|
310 |
* les données du jeton SSO
|
|
|
311 |
*/
|
|
|
312 |
private function initialiserInfosUtilisateur() {
|
|
|
313 |
$requete = 'INSERT INTO cel_utilisateurs_infos'
|
|
|
314 |
. ' (id_utilisateur, intitule, prenom, nom, courriel, admin, licence_acceptee, preferences, date_premiere_utilisation )'
|
|
|
315 |
. ' VALUES ('
|
|
|
316 |
. Cel::db()->proteger($this->token_decode['id']) . ', '
|
|
|
317 |
. Cel::db()->proteger($this->token_decode['intitule']) . ', '
|
|
|
318 |
. Cel::db()->proteger($this->token_decode['prenom']) . ', '
|
|
|
319 |
. Cel::db()->proteger($this->token_decode['nom']) . ', '
|
|
|
320 |
. Cel::db()->proteger($this->token_decode['sub']) . ', '
|
|
|
321 |
. "'0', '0', NULL, NOW()"
|
|
|
322 |
. ' ) ON DUPLICATE KEY UPDATE date_premiere_utilisation = NOW()'
|
|
|
323 |
. ' -- '.__FILE__.':'.__LINE__
|
|
|
324 |
;
|
2823 |
mathias |
325 |
Cel::db()->executer($requete);
|
|
|
326 |
}
|
|
|
327 |
|
|
|
328 |
/**
|
|
|
329 |
* Lors de la première connection au cel d'un utilisateur, affecte à son compte ses observations saisies
|
|
|
330 |
* dans les widgets de saisie, où seul son mail avait été conservé en attendant
|
|
|
331 |
* Enter description here ...
|
|
|
332 |
* @param string $mail_utilisateur
|
|
|
333 |
* @param array $infos_utilisateur
|
|
|
334 |
*/
|
|
|
335 |
private function affecterDonneesWidgetSaisie($mail_utilisateur, $infos_utilisateur) {
|
|
|
336 |
//TODO tout ceci pourrait être simplifié sans avoir besoin d'instancier quoi que ce soit
|
|
|
337 |
$gestion_obs = new GestionObservation($this->config);
|
|
|
338 |
$gestion_img = new GestionImage($this->config);
|
|
|
339 |
|
|
|
340 |
$gestion_obs->migrerObservationsMailVersId($mail_utilisateur, $infos_utilisateur);
|
|
|
341 |
$gestion_img->migrerImagesMailVersId($mail_utilisateur, $infos_utilisateur);
|
|
|
342 |
GestionMotsClesChemin::migrerMotsClesMailVersId($mail_utilisateur, $infos_utilisateur);
|
|
|
343 |
}
|
2806 |
aurelien |
344 |
}
|
2808 |
mathias |
345 |
|
|
|
346 |
/**
|
|
|
347 |
* Compatibilité avec nginx - merci http://php.net/manual/fr/function.getallheaders.php
|
|
|
348 |
*/
|
|
|
349 |
if (! function_exists('apache_request_headers')) {
|
|
|
350 |
function apache_request_headers() {
|
|
|
351 |
$headers = '';
|
|
|
352 |
foreach ($_SERVER as $name => $value) {
|
|
|
353 |
if (substr($name, 0, 5) == 'HTTP_') {
|
|
|
354 |
$headers[str_replace(' ', '-', ucwords(strtolower(str_replace('_', ' ', substr($name, 5)))))] = $value;
|
|
|
355 |
}
|
|
|
356 |
}
|
|
|
357 |
return $headers;
|
|
|
358 |
}
|
|
|
359 |
}
|
3024 |
mathias |
360 |
?>
|