Test Failed
Push — master ( 9c9907...79ea39 )
by PHPLicengine
02:10
created

Api::_json_encoder()   A

Complexity

Conditions 2
Paths 2

Size

Total Lines 4
Code Lines 2

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
cc 2
eloc 2
c 1
b 0
f 0
nc 2
nop 1
dl 0
loc 4
rs 10
1
<?php
2
3
// Api.php
4
#################################################
5
##
6
## PHPLicengine
7
##
8
#################################################
9
## Copyright 2009-{current_year} PHPLicengine
10
## 
11
## Licensed under the Apache License, Version 2.0 (the "License");
12
## you may not use this file except in compliance with the License.
13
## You may obtain a copy of the License at
14
##
15
##    http://www.apache.org/licenses/LICENSE-2.0
16
##
17
## Unless required by applicable law or agreed to in writing, software
18
## distributed under the License is distributed on an "AS IS" BASIS,
19
## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
20
## See the License for the specific language governing permissions and
21
## limitations under the License.
22
#################################################
23
24
namespace PHPLicengine\Api;
25
use PHPLicengine\Exception\CurlException;
26
27
class Api implements ApiInterface {
28
29
              protected $_api_key_var = 'Authorization: Bearer ';
30
              protected $_api_key;
31
              protected $_timeout = 30;
32
              protected $_verify_ssl = true;
33
              protected $_verify_host = 2;
34
              protected $curlErrno = false;
35
              protected $curlError = false;
36
              protected $curlProxy = false;
37
              protected $response;
38
              protected $request = array();
39
              protected $json = true;
40
              protected $accept;
41
              protected $curlInfo;
42
              protected $_curl_callback;
43
44
              public function __construct($api_key = "", $basic = "") 
45
              { 
46
                     if (!function_exists('curl_init')) 
47
                     { 
48
                            throw new CurlException("cURL is not available. This API wrapper cannot be used."); 
49
                     } 
50
                  
51
                     if (isset($api_key))
52
                     {
53
                            $this->setApiKey($api_key);
54
                     } 
55
                  
56
                     if ($basic === true) 
57
                     {
58
                            $this->_api_key_var = 'Authorization: Basic ';
59
                            $this->json = false;
60
                     }
61
              }
62
63
              public function setOAuth()
64
              {
65
                     $this->_api_key_var = '';
66
                     $this->json = false;
67
                     $this->accept = true;
68
              }
69
  
70
              public function enableJson() 
71
              {
72
                     $this->_api_key_var = 'Authorization: Bearer ';
73
                     $this->json = true;
74
              } 
75
           
76
              public function setApiKey($api_key) 
77
              { 
78
                     $this->_api_key = $api_key;
79
              } 
80
81
              public function enableSslVerification() 
82
              { 
83
                     $this->_verify_ssl = true; 
84
                     $this->_verify_host = 2; 
85
              } 
86
  
87
              public function disableSslVerification() 
88
              { 
89
                     $this->_verify_ssl = false; 
90
                     $this->_verify_host = 0; 
91
              } 
92
93
              public function setTimeout($timeout) 
94
              { 
95
                     $this->_timeout = $timeout; 
96
              } 
97
98
              public function setCurlProxy($proxy)  
99
              {  
100
                     $this->curlProxy = $proxy;  
101
              }  
102
103
              public function setCurlCallback($callback) 
104
              { 
105
                     $this->_curl_callback = $callback; 
106
              } 
107
108
              private function _call($url, $params = null, $headers = null, $method = "GET") 
109
              {
110
                     $ch = curl_init();
111
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_URL, $url);
112
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_FOLLOWLOCATION, false);
113
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_TIMEOUT, $this->_timeout);
114
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_RETURNTRANSFER, true);
115
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_SSL_VERIFYPEER, $this->_verify_ssl);
116
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_SSL_VERIFYHOST, $this->_verify_host);
117
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_HEADER, true);
118
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLINFO_HEADER_OUT, true);
119
                     if ($this->curlProxy) {  
120
                            curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_PROXY, $this->curlProxy);  
121
                     }  
122
                     if ($this->_curl_callback) { 
123
                            call_user_func($this->_curl_callback, $ch, $params, $headers, $method); 
124
                     } 
125
                     switch (strtoupper($method)) { 
126
                            case 'PUT':
127
                            case 'PATCH':
128
                            case 'DELETE':
129
                                          curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_CUSTOMREQUEST, strtoupper($method));
130
                                          curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_POSTFIELDS, json_encode($params));
131
                            break;
132
                            case 'POST':
133
                                          curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_POST, true);
134
                                          if ($this->json === true) {
135
                                             $params = json_encode($params);
136
                                          }
137
                                          curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_POSTFIELDS, $params);
138
                            break;
139
                            case 'GET':
140
                                          curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_HTTPGET, true);
141
                                          if (!empty($params)) {
142
                                                 $url .= '?'.http_build_query($params);
143
                                                 curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_URL, $url);
144
                                          }
145
                            break;
146
                     }
147
148
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_HTTPHEADER, $this->_createHeaders($headers));
149
150
                     $this->request['method'] = strtoupper($method);
151
                     $this->request['headers'] = $this->_createHeaders($headers);
152
                     $this->request['params'] = $params;
153
154
                     $this->response = curl_exec(/** @scrutinizer ignore-type */ $ch);
155
                     if (curl_errno(/** @scrutinizer ignore-type */ $ch)) {
156
                            $this->curlErrno = curl_errno(/** @scrutinizer ignore-type */ $ch);
157
                            $this->curlError = curl_error(/** @scrutinizer ignore-type */ $ch);
158
                            curl_close(/** @scrutinizer ignore-type */ $ch);
159
                            return;
160
                     }
161
                     $this->curlInfo = curl_getinfo(/** @scrutinizer ignore-type */ $ch);
162
                     curl_close(/** @scrutinizer ignore-type */ $ch);
163
                     return new Result($this->_getBody(), $this->_getHeaders(), $this->curlInfo);
164
              }
165
              
166
              private function _createHeaders($headers = null)
167
              {
168
                      $headers[] = $this->_api_key_var.$this->_api_key;
169
                      if ($this->json === true) {
170
                          $headers[] = 'Content-Type: application/json';
171
                      }
172
                      if ($this->accept === true) {
173
                          $headers[] = 'Accept: application/json';
174
                      }
175
                      return $headers;
176
              }
177
  
178
              private function _parseHeaders($raw_headers) 
179
              {
180
                     if (!function_exists('http_parse_headers')) {
181
                            $headers = array();
182
                            $key = '';
183
                            foreach (explode("\n", $raw_headers) as $i => $h) {
184
                                   $h = explode(':', $h, 2);
185
                                   if (isset($h[1])) {
186
                                          if (!isset($headers[$h[0]])) {
187
                                                 $headers[$h[0]] = trim($h[1]);
188
                                          } elseif (is_array($headers[$h[0]])) {
189
                                                 $headers[$h[0]] = array_merge($headers[$h[0]], array(trim($h[1])));
190
                                          } else {
191
                                                 $headers[$h[0]] = array_merge(array($headers[$h[0]]), array(trim($h[1])));
192
                                          }
193
                                          $key = $h[0];
194
                                   } else { 
195
                                          if (substr($h[0], 0, 1) == "\t") {
196
                                                 $headers[$key] .= "\r\n\t".trim($h[0]);
197
                                          } elseif (!$key) {
198
                                                 $headers[0] = trim($h[0]);
199
                                          }
200
                                   }
201
                            }
202
                            return $headers;
203
                     } else {
204
                            return http_parse_headers($raw_headers);
205
                     } 
206
              }
207
208
              private function _getHeaders()
209
              {
210
                     return $this->_parseHeaders(substr($this->response, 0, $this->curlInfo['header_size']));
211
              }
212
213
              private function _getBody()
214
              {
215
                     return substr($this->response, $this->curlInfo['header_size']);
216
              }
217
218
              public function getResponse()
219
              {
220
                     return $this->response;      
221
              }
222
223
              public function getRequest()
224
              {
225
                     return $this->request;
226
              }
227
           
228
              public function get($url, $params = null, $headers = null)
229
              {
230
                     return $this->_call($url, $params, $headers, $method = "GET");      
231
              }
232
           
233
              public function post($url, $params = null, $headers = null)
234
              {
235
                     return $this->_call($url, $params, $headers, $method = "POST");      
236
              }
237
238
              public function delete($url, $params = null, $headers = null) 
239
              {
240
                     return $this->_call($url, $params, $headers, $method = "DELETE");      
241
              }
242
243
              public function put($url, $params = null, $headers = null) 
244
              {
245
                     return $this->_call($url, $params, $headers, $method = "PUT");      
246
              }
247
248
              public function patch($url, $params = null, $headers = null) 
249
              {
250
                     return $this->_call($url, $params, $headers, $method = "PATCH");      
251
              }
252
253
              public function getCurlInfo()
254
              {
255
                     return $this->curlInfo;
256
              }
257
258
              public function isCurlError() 
259
              {
260
                     return (bool) $this->curlErrno;
261
              }
262
263
              public function getCurlErrno() 
264
              {
265
                     return $this->curlErrno;
266
              }
267
268
              public function getCurlError() 
269
              {
270
                     return $this->curlError;
271
              }
272
           
273
}
274