Subversion Repositories Applications.framework

Rev

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

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