WebSVN – Applications.framework – Diff – /trunk/framework/Client.php


<?php
// declare(encoding='UTF-8');
/**
* Classe client permettant d'interroger des services web REST.
*
* @category	php 5.2
* @package 	Framework
* @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
* @copyright	Copyright (c) 2010, Tela Botanica (accueil@tela-botanica.org)
* @license		http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
* @license		http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
* @version		$Id$
*/
class Client {
	const HTTP_URL_REQUETE_SEPARATEUR = '&';
	private $http_methodes = array('GET', 'POST', 'PUT', 'DELETE', 'HEAD', 'OPTIONS', 'CONNECT', 'TRACE');
	protected $parametres = null;
	private $url = null;
	private $reponse_entetes = null;
	
	//+----------------------------------------------------------------------------------------------------------------+
	// ACCESSEURS
	
	public function getReponseEntetes($cle) {
		return $this->reponse_entetes;
	}
	
	public function getParametre($cle) {
		$valeur = (isset($this->parametres[$cle])) ? $this->parametres[$cle] : null;
		return $valeur;
	}
	
	public function ajouterParametre($cle, $valeur) {
		$this->parametres[$cle] = $valeur;
	}
	
	public function supprimerParametre($cle) {
		unset($this->parametres[$cle]);
	}
	
	public function nettoyerParametres() {
		$this->parametres = null;
	}
	
	//+----------------------------------------------------------------------------------------------------------------+
	// MÉTHODES
	
	public function consulter($url) {
		$url = $this->traiterUrlParametres($url);
		$retour = $this->envoyerRequete($url, 'GET');
		return $retour;
	}
	
	public function ajouter($url, Array $donnees) {
		$retour = $this->envoyerRequete($url, 'PUT', $donnees);
		return $retour;
	}
	
	public function modifier($url, Array $donnees) {
		$retour = $this->envoyerRequete($url, 'POST', $donnees);
		return $retour;
	}
	
	public function supprimer($url) {
		$retour = $this->envoyerRequete($url, 'DELETE');
		return $retour;
	}
	
	public function envoyerRequete($url, $mode, Array $donnees = array()) {
		$this->url = $url;
		$contenu = false;
		if (! in_array($mode, $this->http_methodes)) {
			$e = "Le mode de requête '$mode' n'est pas accepté!";
			trigger_error($e, E_USER_WARNING);
		} else {
			$contexte = stream_context_create(array(
				'http' => array(
      				'method' => $mode,
					'header' => "Content-type: application/x-www-form-urlencoded\r\n",
      				'content' => http_build_query($donnees, null, self::HTTP_URL_REQUETE_SEPARATEUR))));
			$flux = @fopen($url, 'r', false, $contexte);
			if (!$flux) {
				$this->reponse_entetes = $http_response_header;
				$e = "L'ouverture de l'url '$url' par la méthode HTTP '$mode' a échoué!";
				trigger_error($e, E_USER_WARNING);
			} else {
				// Informations sur les en-têtes et métadonnées du flux
				$this->reponse_entetes = stream_get_meta_data($flux);
 
				
				// Contenu actuel de $url
				$contenu = stream_get_contents($flux);
				
				fclose($flux);
			}
			$this->traiterEntete();
		}
		$this->reinitialiser();
		return $contenu;
	}
	
	private function traiterUrlParametres($url) {
		$parametres = array();
		if (count($this->parametres) > 0) {
			foreach ($this->parametres as $cle => $valeur) {
				$parametres[] = $cle.self::HTTP_URL_REQUETE_CLE_VALEUR_SEPARATEUR.$valeur;
			}
			$url_parametres = implode(self::HTTP_URL_REQUETE_SEPARATEUR, $parametres);
			$url = $url.'?'.$url_parametres;
		}
		return $url;
	}
	
	private function traiterEntete() {
		$infos = $this->analyserEntete();
		$this->traiterEnteteDebogage($infos);
	}
	
	private function analyserEntete() {
		$entetes = $this->reponse_entetes; 
		$infos = array('date' => null, 'uri' => $this->url, 'debogages' => null);
		
		if (isset($entetes['wrapper_data'])) {
			$entetes = $entetes['wrapper_data'];
		}
		foreach ($entetes as $entete) {
			if (preg_match('/^X_REST_DEBOGAGE_MESSAGES: (.+)$/', $entete, $match)) {
				$infos['debogages'] = json_decode($match[1]);
			}
			if (preg_match('/^Date: .+ ([012][0-9]:[012345][0-9]:[012345][0-9]) .*$/', $entete, $match)) {
				$infos['date'] = $match[1];
			}
		}
		return $infos;
	}
	
	private function traiterEnteteDebogage($entetes_analyses) {
		if (isset($entetes['debogages'])) {
			$date = $entetes['date'];
			$uri = $entetes['uri'];
			$debogages = $entetes['debogages'];
			foreach ($debogages as $debogage) {
				$e = "DEBOGAGE : $date - $uri :\n$debogage";
				trigger_error($e, E_USER_NOTICE);
			}
		}
	}
	
	private function reinitialiser() {
		$this->nettoyerParametres();
	}
}

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

Subversion Repositories Applications.framework

(root)/trunk/framework/Client.php – Rev 252 → 256