use httprequest wrapper to automatically check for errors
[phorkie.git] / src / phorkie / Database / Adapter / Elasticsearch / HTTPRequest.php
1 <?php
2 namespace phorkie;
3
4 class Database_Adapter_Elasticsearch_HTTPRequest extends \HTTP_Request2
5 {
6     public function send()
7     {
8         $res = parent::send();
9         $mainCode = intval($res->getStatus() / 100);
10         if ($mainCode != 2) {
11             $js = json_decode($res->getBody());
12             if (isset($js->error)) {
13                 $error = $js->error;
14             } else {
15                 $error = $res->getBody();
16             }
17             throw new Exception(
18                 'Error in elasticsearch communication: ' . $error
19             );
20         }
21         return $res;
22     }
23 }
24
25 ?>