Subversion Repositories Applications.annuaire

Rev

Rev 394 | Rev 400 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
69 aurelien 1 
<?php
2 
/**
3 
 * Classe mère abstraite contenant les méthodes génériques des services.
4 
 * Encodage en entrée : utf8
5 
 * Encodage en sortie : utf8
6 
 *
7 
 * @author Jean-Pascal MILCENT <jpm@tela-botanica.org>
8 
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
9 
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
10 
 * @version $Id$
11 
 * @copyright 2009
12 
 */
13 
abstract class JRestService {
14 
 
15 
	public $config;
16 
	protected $bdd;
331 jpm 17 
	protected $ressources;
69 aurelien 18 
	protected $log = array();
19 
	protected $messages = array();
20 
	protected $debug = array();
21 
	protected $distinct = false;
22 
	protected $orderby = null;
23 
	protected $formatRetour = 'objet';
24 
	protected $start = 0;
25 
	protected $limit = 150;
26 
 
27 
	public function __construct($config, $demarrer_session = true) {
28 
		// Tableau contenant la config de Jrest
29 
		$this->config = $config;
30 
 
31 
		// Connection à la base de données
32 
		$this->bdd = $this->connecterPDO($this->config, 'appli');
33 
 
34 
		// Nettoyage du $_GET (sécurité)
35 
		if (isset($_GET)) {
36 
			$get_params = array('orderby', 'distinct', 'start', 'limit', 'formatRetour');
37 
			foreach ($get_params as $get) {
38 
				$verifier = array('NULL', "\n", "\r", "\\", "'", '"', "\x00", "\x1a", ';');
39 
				$_GET[$get] = str_replace($verifier, '', $_GET[$get]);
40 
				if (isset($_GET[$get]) && $_GET[$get] != '') {
41 
					$this->$get = $_GET[$get];
42 
				} else {
43 
					$_GET[$get] = null;
44 
				}
45 
			}
46 
		}
47 
	}
48 
 
49 
	/**
50 
	 * Méthode appelée quand aucun paramètre n'est passé dans l'url et avec une requête de type GET.
51 
	 */
52 
	public function getRessource() {
53 
		$this->getElement(array());
54 
	}
55 
 
331 jpm 56 
	//+----------------------------------------------------------------------------------------------------------------+
57 
	// GESTION de l'ENVOIE au NAVIGATEUR
58 
 
59 
	protected function envoyerJson($donnees, $encodage = 'utf-8') {
60 
		$contenu = json_encode($donnees);
61 
		$this->envoyer($contenu, 'application/json', $encodage, false);
62 
	}
390 jpm 63 
 
331 jpm 64 
	protected function envoyerJsonVar($variable, $donnees = null, $encodage = 'utf-8') {
65 
		$contenu = "var $variable = ".json_encode($donnees);
66 
		$this->envoyer($contenu, 'text/html', $encodage, false);
67 
	}
390 jpm 68 
 
331 jpm 69 
	protected function envoyerJsonp($donnees = null, $encodage = 'utf-8') {
70 
		$contenu = $_GET['callback'].'('.json_encode($donnees).');';
71 
		$this->envoyer($contenu, 'text/html', $encodage, false);
72 
	}
390 jpm 73 
 
331 jpm 74 
	protected function envoyerTxt($donnees, $encodage = 'utf-8') {
75 
		$this->envoyer($contenu, 'text/html', $encodage, false);
76 
	}
77 
 
69 aurelien 78 
	protected function envoyer($donnees = null, $mime = 'text/html', $encodage = 'utf-8', $json = true) {
79 
		// Traitements des messages d'erreurs et données
80 
		if (count($this->messages) != 0) {
81 
			header('HTTP/1.1 500 Internal Server Error');
82 
			$mime = 'text/html';
83 
			$encodage = 'utf-8';
84 
			$json = true;
85 
			$sortie = $this->messages;
86 
		} else {
87 
			$sortie = $donnees;
88 
			if (is_null($donnees)) {
89 
				$sortie = 'OK';
90 
			}
91 
		}
92 
 
93 
		// Gestion de l'envoie du déboguage
94 
		$this->envoyerDebogage();
95 
 
96 
		// Encodage au format et JSON et envoie sur la sortie standard
97 
		$contenu = $json ? json_encode($sortie) : $sortie;
98 
		$this->envoyerContenu($encodage, $mime, $contenu);
99 
	}
100 
 
331 jpm 101 
	private function envoyerDebogage() {
69 aurelien 102 
		if (!is_array($this->debug)) {
103 
			$this->debug[] = $this->debug;
104 
		}
105 
		if (count($this->debug) != 0) {
106 
			foreach ($this->debug as $cle => $val) {
107 
				if (is_array($val)) {
108 
					$this->debug[$cle] = print_r($val, true);
109 
				}
110 
			}
111 
			header('X-DebugJrest-Data:'.json_encode($this->debug));
112 
		}
113 
	}
114 
 
331 jpm 115 
	private function envoyerContenu($encodage, $mime, $contenu) {
116 
		if (!is_null($mime) && !is_null($encodage)) {
117 
			header("Content-Type: $mime; charset=$encodage");
118 
		} else if (!is_null($mime) && is_null($encodage)) {
119 
			header("Content-Type: $mime");
120 
		}
69 aurelien 121 
		print $contenu;
122 
	}
390 jpm 123 
 
331 jpm 124 
	private function envoyerAuth($message_accueil, $message_echec) {
125 
		header('HTTP/1.0 401 Unauthorized');
126 
		header('WWW-Authenticate: Basic realm="'.mb_convert_encoding($message_accueil, 'ISO-8859-1', 'UTF-8').'"');
127 
		header('Content-type: text/plain; charset=UTF-8');
128 
		print $message_echec;
129 
		exit(0);
130 
	}
390 jpm 131 
 
331 jpm 132 
	//+----------------------------------------------------------------------------------------------------------------+
133 
	// GESTION de la BASE de DONNÉES
390 jpm 134 
 
69 aurelien 135 
	private function connecterPDO($config, $base = 'database') {
390 jpm 136 
  		$cfg = $config[$base];
137 
        // ATTENTION : la connexin à la bdd peut échouer si l'host vaut localhost. Utiliser 127.0.0.1 à la place.
69 aurelien 138 
		$dsn = $cfg['phptype'].':dbname='.$cfg['database'].';host='.$cfg['hostspec'];
139 
		try {
390 jpm 140 
    		// Création de la connexion en UTF-8 à la BDD
141 
			$PDO = new PDO($dsn, $cfg['username'], $cfg['password'], array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'UTF8'"));
69 aurelien 142 
		} catch (PDOException $e) {
390 jpm 143 
    		echo 'La connexion à la base de donnée via PDO a échouée : ' .$dsn. $e->getMessage();
69 aurelien 144 
		}
145 
		// Affiche les erreurs détectées par PDO (sinon mode silencieux => aucune erreur affiché)
146 
		$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
147 
        return $PDO;
148 
	}
149 
 
150 
	protected function getTxt($id) {
151 
		$sortie = '';
152 
		switch ($id) {
153 
			case 'sql_erreur' : $sortie = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s'; break;
154 
			default : $sortie = $id;
155 
		}
156 
		return $sortie;
157 
	}
158 
 
331 jpm 159 
	//+----------------------------------------------------------------------------------------------------------------+
160 
	// TRAITEMENT des URLs et des PARAMÊTRES
390 jpm 161 
 
331 jpm 162 
	protected function traiterNomMethodeGet($nom) {
163 
		$methode = 'get';
164 
		$methode .= str_replace(' ', '', ucwords(str_replace('-', ' ', strtolower($nom))));
165 
		return $methode;
166 
	}
390 jpm 167 
 
347 jpm 168 
	protected function traiterNomMethodePost($nom) {
169 
		$methode = 'update';
170 
		$methode .= str_replace(' ', '', ucwords(str_replace('-', ' ', strtolower($nom))));
171 
		return $methode;
172 
	}
390 jpm 173 
 
394 jpm 174 
	protected function traiterNomMethodePut($nom) {
175 
		$methode = 'create';
176 
		$methode .= str_replace(' ', '', ucwords(str_replace('-', ' ', strtolower($nom))));
177 
		return $methode;
178 
	}
179 
 
69 aurelien 180 
	protected function traiterParametresUrl($params_attendu, $params, $pourBDD = true) {
181 
		$sortie = array();
182 
		foreach ($params_attendu as $num => $nom) {
183 
			if (isset($params[$num]) && $params[$num] != '*') {
184 
				if ($pourBDD) {
185 
					$params[$num] = $this->bdd->quote($params[$num]);
186 
				}
187 
				$sortie[$nom] = $params[$num];
188 
			}
189 
		}
190 
		return $sortie;
191 
	}
192 
 
193 
	protected function traiterParametresPost($params) {
194 
		$sortie = array();
195 
		foreach ($params as $cle => $valeur) {
196 
			$sortie[$cle] = $this->bdd->quote($valeur);
197 
		}
198 
		return $sortie;
199 
	}
200 
 
331 jpm 201 
	//+----------------------------------------------------------------------------------------------------------------+
202 
	// GESTION DE L'IDENTIFICATION
390 jpm 203 
 
69 aurelien 204 
	protected function getIdentification(&$params) {
205 
		// Initialisation des variables
206 
		$utilisateur = array(0, session_id());
207 
 
208 
		// L'id utilisateur est soit passé par le POST soit dans l'url
209 
		if (is_array($params) && isset($params['cmhl_ce_modifier_par'])) {
210 
		   	$utilisateur[0] = $params['cmhl_ce_modifier_par'];
211 
			unset($params['cmhl_ce_modifier_par']);
212 
		} else if (is_string($params)) {
213 
			$utilisateur[0] = $params;
214 
		}
215 
 
216 
		return $utilisateur;
217 
	}
218 
 
219 
	protected function etreAutorise($id_utilisateur) {
220 
		$autorisation = false;
221 
		if (($_SESSION['coel_utilisateur'] != '') && $_SESSION['coel_utilisateur']['id'] != $id_utilisateur) {
222 
			$this->messages[] = 'Accès interdit.';
223 
		} else if ($_SESSION['coel_utilisateur'] == '') {
224 
			$this->messages[] = 'Veuillez vous identifiez pour accéder à cette fonction.';
225 
		} else {
226 
			$autorisation = true;
227 
		}
228 
		return $autorisation;
229 
	}
230 
 
231 
	private function gererIdentificationPermanente() {
232 
		// Pour maintenir l'utilisateur tjrs réellement identifié nous sommes obligé de recréer une SESSION et de le recharger depuis la bdd
233 
		if ($this->getUtilisateur() == ''
234 
				&& isset($_COOKIE['coel_login'])
235 
				&& ($utilisateur = $this->chargerUtilisateur($_COOKIE['coel_login'], $_COOKIE['coel_mot_de_passe']))) {
236 
			$this->setUtilisateur($utilisateur, $_COOKIE['coel_permanence']);
237 
		}
238 
	}
239 
 
240 
	protected function getUtilisateur() {
241 
		return (isset($_SESSION['coel_utilisateur']) ? $_SESSION['coel_utilisateur'] : '');
242 
	}
390 jpm 243 
 
331 jpm 244 
	protected function authentifier() {
245 
		if (!isset($_SERVER['PHP_AUTH_USER'])) {
246 
			header('WWW-Authenticate: Basic realm="www.tela-botanica.org"');
247 
			header('HTTP/1.0 401 Unauthorized');
248 
			header('Content-type: text/html; charset=UTF-8');
249 
			echo 'Accès interdit';
250 
			exit;
251 
		} else {
394 jpm 252 
			if ($this->verifierAcces()) {
331 jpm 253 
				return ;
254 
			} else {
255 
				header('WWW-Authenticate: Basic realm="www.tela-botanica.org"');
256 
				header('HTTP/1.0 401 Unauthorized');
257 
				header('Content-type: text/html; charset=UTF-8');
258 
				echo 'Accès interdit';
259 
				exit ;
260 
			}
261 
		}
262 
	}
69 aurelien 263 
 
394 jpm 264 
	protected function verifierAcces($id = null, $mdp = null) {
265 
		$id = is_null($id) ? $_SERVER['PHP_AUTH_USER'] : $id;
266 
		$mdp = is_null($mdp) ? $_SERVER['PHP_AUTH_PW'] : $mdp;
267 
 
268 
		$requete = 'SELECT '.$this->config['database_ident']['ann_id'].' AS courriel '.
331 jpm 269 
			'FROM '.$this->config['database_ident']['database'].'.'.$this->config['database_ident']['annuaire'].' '.
270 
			'WHERE '.$this->config['database_ident']['ann_id'].' = '.$this->bdd->quote($id).' '.
394 jpm 271 
			'	AND '.$this->config['database_ident']['ann_pwd'].' = '.$this->config['database_ident']['pass_crypt_funct'].'('.$this->bdd->quote($mdp).')' ;
272 
		$resultat = $this->bdd->query($requete)->fetch();
390 jpm 273 
 
394 jpm 274 
		$identifie = false;
275 
		if (isset($resultat['courriel'])) {
276 
			$identifie = true;
331 jpm 277 
		}
394 jpm 278 
		return $identifie;
279 
	}
331 jpm 280 
 
396 jpm 281 
	protected function creerCookiePersistant($duree = null, $id = null, $mdp = null) {
394 jpm 282 
		$id = is_null($id) ? $_SERVER['PHP_AUTH_USER'] : $id;
283 
		$mdp = is_null($mdp) ? $_SERVER['PHP_AUTH_PW'] : $mdp;
396 jpm 284 
		$duree = (int) is_null($duree) ? time()+3600*24*30 : $duree;
331 jpm 285 
 
394 jpm 286 
		$nomCookie = $this->config['database_ident']['nom_cookie_persistant'];
287 
		$valeurCookie = md5($mdp).$id;
396 jpm 288 
 
289 
		setcookie($nomCookie, $valeurCookie, $duree, '/');
331 jpm 290 
	}
390 jpm 291 
 
396 jpm 292 
	protected function creerCookieUtilisateur($duree = null, $id = null) {
293 
		$id = is_null($id) ? $_SERVER['PHP_AUTH_USER'] : $id;
294 
		$duree = (int) is_null($duree) ? 0 : $duree;
295 
 
296 
		$nomCookie = $this->config['database_ident']['nom_cookie_utilisateur'];
297 
		$valeurCookie = $id;
298 
 
299 
		setcookie($nomCookie, $valeurCookie, $duree, '/');
394 jpm 300 
	}
301 
 
388 aurelien 302 
	protected function estAutoriseMessagerie($adresse) {
303 
		$utilisateurs_messagerie = explode(',', $this->config['messagerie']['utilisateurs_autorises']);
304 
		return in_array($adresse, $utilisateurs_messagerie);
305 
	}
394 jpm 306 
 
331 jpm 307 
	//+----------------------------------------------------------------------------------------------------------------+
308 
	// GESTION DES SQUELETTES PHP
390 jpm 309 
 
69 aurelien 310 
	/**
311 
	 * Méthode prenant en paramètre un chemin de fichier squelette et un tableau associatif de données,
312 
	 * en extrait les variables, charge le squelette et retourne le résultat des deux combinés.
313 
	 *
314 
	 * @param String $fichier	le chemin du fichier du squelette
315 
	 * @param Array  $donnees	un tableau associatif contenant les variables a injecter dans le squelette.
316 
	 *
317 
	 * @return boolean false si le squelette n'existe pas, sinon la chaine résultat.
318 
	 */
319 
	public static function traiterSquelettePhp($fichier, Array $donnees = array()) {
320 
		$sortie = false;
321 
		if (file_exists($fichier)) {
322 
			// Extraction des variables du tableau de données
323 
			extract($donnees);
324 
			// Démarage de la bufferisation de sortie
325 
			ob_start();
326 
			// Si les tags courts sont activés
327 
			if ((bool) @ini_get('short_open_tag') === true) {
328 
				// Simple inclusion du squelette
329 
				include $fichier;
330 
			} else {
331 
				// Sinon, remplacement des tags courts par la syntaxe classique avec echo
332 
				$html_et_code_php = self::traiterTagsCourts($fichier);
333 
				// Pour évaluer du php mélangé dans du html il est nécessaire de fermer la balise php ouverte par eval
334 
				$html_et_code_php = '?>'.$html_et_code_php;
335 
				// Interprétation du html et du php dans le buffer
336 
				echo eval($html_et_code_php);
337 
			}
338 
			// Récupèration du contenu du buffer
339 
			$sortie = ob_get_contents();
340 
			// Suppression du buffer
341 
			@ob_end_clean();
342 
		} else {
343 
			$msg = "Le fichier du squelette '$fichier' n'existe pas.";
344 
			trigger_error($msg, E_USER_WARNING);
345 
		}
346 
		// Retourne le contenu
347 
		return $sortie;
348 
	}
349 
 
350 
	/**
351 
	 * Fonction chargeant le contenu du squelette et remplaçant les tags court php (<?= ...) par un tag long avec echo.
352 
	 *
353 
	 * @param String $chemin_squelette le chemin du fichier du squelette
354 
	 *
355 
	 * @return string le contenu du fichier du squelette php avec les tags courts remplacés.
356 
	 */
357 
	private static function traiterTagsCourts($chemin_squelette) {
358 
		$contenu = file_get_contents($chemin_squelette);
359 
		// Remplacement de tags courts par un tag long avec echo
360 
		$contenu = str_replace('<?=', '<?php echo ',  $contenu);
361 
		// Ajout systématique d'un point virgule avant la fermeture php
362 
		$contenu = preg_replace("/;*\s*\?>/", "; ?>", $contenu);
363 
		return $contenu;
364 
	}
365 
}
366 
?>