Subversion Repositories eFlore/Applications.cel

Rev

Rev 908 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 908 Rev 946
1 
<?php
 1 
<?php
2 
// declare(encoding='UTF-8');
 2 
// declare(encoding='UTF-8');
3 
/**
 3 
/**
4 
* Classe modèle spécifique à l'application, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.
 4 
* Classe modèle spécifique à l'application, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.
5 
*
 5 
*
6 
* @category		php5
 6 
* @category		php5
7 
* @package 		Cel
 7 
* @package 		Cel
8 
* @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
 8 
* @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
9 
* @copyright	2010 Tela-Botanica
 9 
* @copyright	2010 Tela-Botanica
10 
* @license		http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
 10 
* @license		http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
11 
* @license		http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
 11 
* @license		http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
12 
* @version		SVN: $Id$
 12 
* @version		SVN: $Id$
13 
*/
 13 
*/
- 
 
 14 
// TODO : remplacer les trigger_error par des exceptions qui pourrait être attrapées...
14 
class CelRestClient {
 15 
class CelRestClient {
15 
	const HTTP_URL_REQUETE_SEPARATEUR = '&';
 16 
	const HTTP_URL_REQUETE_SEPARATEUR = '&';
16 
	const HTTP_URL_REQUETE_CLE_VALEUR_SEPARATEUR = '=';
 17 
	const HTTP_URL_REQUETE_CLE_VALEUR_SEPARATEUR = '=';
17 
	private $http_methodes = array('GET', 'POST', 'PUT', 'DELETE', 'HEAD', 'OPTIONS', 'CONNECT', 'TRACE');
 18 
	private $http_methodes = array('GET', 'POST', 'PUT', 'DELETE', 'HEAD', 'OPTIONS', 'CONNECT', 'TRACE');
18 
	protected $parametres = null;
 19 
	protected $parametres = null;
19 
	private $url = null;
 20 
	private $url = null;
20 
	private $reponse_entetes = null;
 21 
	private $reponse_entetes = null;
21
22
22 
	//+----------------------------------------------------------------------------------------------------------------+
 23 
	//+----------------------------------------------------------------------------------------------------------------+
23 
	// ACCESSEURS
 24 
	// ACCESSEURS
24
25
25 
	public function getReponseEntetes($cle) {
 26 
	public function getReponseEntetes($cle) {
26 
		return $this->reponse_entetes;
 27 
		return $this->reponse_entetes;
27 
	}
 28 
	}
28
29
29 
	public function getParametre($cle) {
 30 
	public function getParametre($cle) {
30 
		$valeur = (isset($this->parametres[$cle])) ? $this->parametres[$cle] : null;
 31 
		$valeur = (isset($this->parametres[$cle])) ? $this->parametres[$cle] : null;
31 
		return $valeur;
 32 
		return $valeur;
32 
	}
 33 
	}
33
34
34 
	public function ajouterParametre($cle, $valeur) {
 35 
	public function ajouterParametre($cle, $valeur) {
35 
		$this->parametres[$cle] = $valeur;
 36 
		$this->parametres[$cle] = $valeur;
36 
	}
 37 
	}
37
38
38 
	public function supprimerParametre($cle) {
 39 
	public function supprimerParametre($cle) {
39 
		unset($this->parametres[$cle]);
 40 
		unset($this->parametres[$cle]);
40 
	}
 41 
	}
41
42
42 
	public function nettoyerParametres() {
 43 
	public function nettoyerParametres() {
43 
		$this->parametres = null;
 44 
		$this->parametres = null;
44 
	}
 45 
	}
45
46
46 
	//+----------------------------------------------------------------------------------------------------------------+
 47 
	//+----------------------------------------------------------------------------------------------------------------+
47 
	// MÉTHODES
 48 
	// MÉTHODES
48
49
49 
	public function consulter($url) {
 50 
	public function consulter($url) {
50 
		$retour = $this->envoyerRequete($url, 'GET');
 51 
		$retour = $this->envoyerRequete($url, 'GET');
51 
		return $retour;
 52 
		return $retour;
52 
	}
 53 
	}
53
54
54 
	public function ajouter($url, Array $donnees) {
 55 
	public function ajouter($url, Array $donnees) {
55 
		$retour = $this->envoyerRequete($url, 'PUT', $donnees);
 56 
		$retour = $this->envoyerRequete($url, 'PUT', $donnees);
56 
		return $retour;
 57 
		return $retour;
57 
	}
 58 
	}
58
59
59 
	public function modifier($url, Array $donnees) {
 60 
	public function modifier($url, Array $donnees) {
60 
		$retour = $this->envoyerRequete($url, 'POST', $donnees);
 61 
		$retour = $this->envoyerRequete($url, 'POST', $donnees);
61 
		return $retour;
 62 
		return $retour;
62 
	}
 63 
	}
63
64
64 
	public function supprimer($url) {
 65 
	public function supprimer($url) {
65 
		$retour = $this->envoyerRequete($url, 'DELETE');
 66 
		$retour = $this->envoyerRequete($url, 'DELETE');
66 
		return $retour;
 67 
		return $retour;
67 
	}
 68 
	}
68
69
69 
	public function envoyerRequete($url, $mode, Array $donnees = array()) {
 70 
	public function envoyerRequete($url, $mode, Array $donnees = array()) {
70 
		$this->url = $url;
 71 
		$this->url = $url;
71 
		$contenu = false;
 72 
		$contenu = false;
72 
		if (! in_array($mode, $this->http_methodes)) {
 73 
		if (! in_array($mode, $this->http_methodes)) {
73 
			$e = "Le mode de requête '$mode' n'est pas accepté!";
 74 
			$e = "Le mode de requête '$mode' n'est pas accepté!";
74 
			trigger_error($e, E_USER_WARNING);
 75 
			trigger_error($e, E_USER_WARNING);
75 
		} else {
 76 
		} else {
76 
			if ($mode == 'GET') {
 77 
			if ($mode == 'GET') {
77 
				$this->traiterUrlParametres();
 78 
				$this->traiterUrlParametres();
78 
			}
 79 
			}
79 
			$contexte = stream_context_create(array(
 80 
			$contexte = stream_context_create(array(
80 
				'http' => array(
 81 
				'http' => array(
81 
      				'method' => $mode,
 82 
      				'method' => $mode,
82 
					'header' => "Content-type: application/x-www-form-urlencoded\r\n",
 83 
					'header' => "Content-type: application/x-www-form-urlencoded\r\n",
83 
      				'content' => http_build_query($donnees, null, self::HTTP_URL_REQUETE_SEPARATEUR))));
 84 
      				'content' => http_build_query($donnees, null, self::HTTP_URL_REQUETE_SEPARATEUR))));
84 
			$flux = @fopen($this->url, 'r', false, $contexte);
 85 
			$flux = @fopen($this->url, 'r', false, $contexte);
85 
			if (!$flux) {
 86 
			if (!$flux) {
86 
				$this->reponse_entetes = $http_response_header;
 87 
				$this->reponse_entetes = $http_response_header;
87 
				$e = "L'ouverture de l'url '{$this->url}' par la méthode HTTP '$mode' a échoué!";
 88 
				$e = "L'ouverture de l'url '{$this->url}' par la méthode HTTP '$mode' a échoué!";
88 
				trigger_error($e, E_USER_WARNING);
 89 
				trigger_error($e, E_USER_WARNING);
89 
			} else {
 90 
			} else {
90 
				// Informations sur les en-têtes et métadonnées du flux
 91 
				// Informations sur les en-têtes et métadonnées du flux
91 
				$this->reponse_entetes = stream_get_meta_data($flux);
 92 
				$this->reponse_entetes = stream_get_meta_data($flux);
92
93
93 
				// Contenu actuel de $url
 94 
				// Contenu actuel de $url
94 
				$contenu = stream_get_contents($flux);
 95 
				$contenu = stream_get_contents($flux);
95
96
96 
				fclose($flux);
 97 
				fclose($flux);
97 
			}
 98 
			}
98 
			$this->traiterEntete();
 99 
			$this->traiterEntete();
99 
		}
 100 
		}
100 
		$this->reinitialiser();
 101 
		$this->reinitialiser();
101 
		return $contenu;
 102 
		return $contenu;
102 
	}
 103 
	}
103
104
104 
	private function traiterUrlParametres() {
 105 
	private function traiterUrlParametres() {
105 
		$parametres = array();
 106 
		$parametres = array();
106 
		if (count($this->parametres) > 0) {
 107 
		if (count($this->parametres) > 0) {
107 
			foreach ($this->parametres as $cle => $valeur) {
 108 
			foreach ($this->parametres as $cle => $valeur) {
108 
				$cle = rawurlencode($cle);
 109 
				$cle = rawurlencode($cle);
109 
				$valeur = rawurlencode($valeur);
 110 
				$valeur = rawurlencode($valeur);
110 
				$parametres[] = $cle.self::HTTP_URL_REQUETE_CLE_VALEUR_SEPARATEUR.$valeur;
 111 
				$parametres[] = $cle.self::HTTP_URL_REQUETE_CLE_VALEUR_SEPARATEUR.$valeur;
111 
			}
 112 
			}
112 
			$url_parametres = implode(self::HTTP_URL_REQUETE_SEPARATEUR, $parametres);
 113 
			$url_parametres = implode(self::HTTP_URL_REQUETE_SEPARATEUR, $parametres);
113 
			$this->url = $this->url.'?'.$url_parametres;
 114 
			$this->url = $this->url.'?'.$url_parametres;
114 
		}
 115 
		}
115 
	}
 116 
	}
116
117
117 
	private function traiterEntete() {
 118 
	private function traiterEntete() {
118 
		$infos = $this->analyserEntete();
 119 
		$infos = $this->analyserEntete();
119 
		$this->traiterEnteteDebogage($infos);
 120 
		$this->traiterEnteteDebogage($infos);
120 
	}
 121 
	}
121
122
122 
	private function analyserEntete() {
 123 
	private function analyserEntete() {
123 
		$entetes = $this->reponse_entetes;
124 
		$entetes = $this->reponse_entetes;
124 
		$infos = array('date' => null, 'uri' => $this->url, 'debogages' => null);
 125 
		$infos = array('date' => null, 'uri' => $this->url, 'debogages' => null);
125
- 
 
126 
		if (isset($entetes['wrapper_data'])) {
 126 
		if (isset($entetes)) {
127 
			$entetes = $entetes['wrapper_data'];
 127 
			if (isset($entetes['wrapper_data'])) {
128 
		}
 - 
 
129 
		foreach ($entetes as $entete) {
 128 
				$entetes = $entetes['wrapper_data'];
130 
			if (preg_match('/^X_REST_DEBOGAGE_MESSAGES: (.+)$/', $entete, $match)) {
 - 
 
131 
				$infos['debogages'] = json_decode($match[1]);
 - 
 
132 
			}
 129 
			}
- 
 
 130 
			foreach ($entetes as $entete) {
- 
 
 131 
				if (preg_match('/^X_REST_DEBOGAGE_MESSAGES: (.+)$/', $entete, $match)) {
- 
 
 132 
					$infos['debogages'] = json_decode($match[1]);
- 
 
 133 
				}
133 
			if (preg_match('/^Date: .+ ([012][0-9]:[012345][0-9]:[012345][0-9]) .*$/', $entete, $match)) {
 134 
				if (preg_match('/^Date: .+ ([012][0-9]:[012345][0-9]:[012345][0-9]) .*$/', $entete, $match)) {
134 
				$infos['date'] = $match[1];
 135 
					$infos['date'] = $match[1];
- 
 
 136 
				}
135 
			}
 137 
			}
136 
		}
 138 
		}
137 
		return $infos;
 139 
		return $infos;
138 
	}
 140 
	}
139
141
140 
	private function traiterEnteteDebogage($entetes_analyses) {
 142 
	private function traiterEnteteDebogage($entetes_analyses) {
141 
		if (isset($entetes['debogages'])) {
 143 
		if (isset($entetes['debogages'])) {
142 
			$date = $entetes['date'];
 144 
			$date = $entetes['date'];
143 
			$uri = $entetes['uri'];
 145 
			$uri = $entetes['uri'];
144 
			$debogages = $entetes['debogages'];
 146 
			$debogages = $entetes['debogages'];
145 
			foreach ($debogages as $debogage) {
 147 
			foreach ($debogages as $debogage) {
146 
				$e = "DEBOGAGE : $date - $uri :\n$debogage";
 148 
				$e = "DEBOGAGE : $date - $uri :\n$debogage";
147 
				trigger_error($e, E_USER_NOTICE);
 149 
				trigger_error($e, E_USER_NOTICE);
148 
			}
 150 
			}
149 
		}
 151 
		}
150 
	}
 152 
	}
151
153
152 
	private function reinitialiser() {
 154 
	private function reinitialiser() {
153 
		$this->nettoyerParametres();
 155 
		$this->nettoyerParametres();
154 
	}
 156 
	}
155 
}
 157 
}