Test Failed
Push — master ( 3a59e4...6d2ccd )
by PHPLicengine
02:15
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
                                          curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_POSTFIELDS, $this->_json_encoder($params));
135
                            break;
136
                            case 'GET':
137
                                          curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_HTTPGET, true);
138
                                          if (!empty($params)) {
139
                                                 $url .= '?'.http_build_query($params);
140
                                                 curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_URL, $url);
141
                                          }
142
                            break;
143
                     }
144
145
                     curl_setopt(/** @scrutinizer ignore-type */ $ch, CURLOPT_HTTPHEADER, $this->_createHeaders($headers));
146
147
                     $this->request['method'] = strtoupper($method);
148
                     $this->request['headers'] = $this->_createHeaders($headers);
149
                     $this->request['params'] = $params;
150
151
                     $this->response = curl_exec(/** @scrutinizer ignore-type */ $ch);
152
                     if (curl_errno(/** @scrutinizer ignore-type */ $ch)) {
153
                            $this->curlErrno = curl_errno(/** @scrutinizer ignore-type */ $ch);
154
                            $this->curlError = curl_error(/** @scrutinizer ignore-type */ $ch);
155
                            curl_close(/** @scrutinizer ignore-type */ $ch);
156
                            return;
157
                     }
158
                     $this->curlInfo = curl_getinfo(/** @scrutinizer ignore-type */ $ch);
159
                     curl_close(/** @scrutinizer ignore-type */ $ch);
160
                     return new Result($this->_getBody(), $this->_getHeaders(), $this->curlInfo);
161
              }
162
              
163
              private function _json_encoder($params)
164
              {
165
                      if ($this->json === true) {
166
                          return json_encode($params);
167
                      }
168
              }
169
  
170
              private function _createHeaders($headers = null)
171
              {
172
                      $headers[] = $this->_api_key_var.$this->_api_key;
173
                      if ($this->json === true) {
174
                          $headers[] = 'Content-Type: application/json';
175
                      }
176
                      if ($this->accept === true) {
177
                          $headers[] = 'Accept: application/json';
178
                      }
179
                      return $headers;
180
              }
181
  
182
              private function _parseHeaders($raw_headers) 
183
              {
184
                     if (!function_exists('http_parse_headers')) {
185
                            $headers = array();
186
                            $key = '';
187
                            foreach (explode("\n", $raw_headers) as $i => $h) {
188
                                   $h = explode(':', $h, 2);
189
                                   if (isset($h[1])) {
190
                                          if (!isset($headers[$h[0]])) {
191
                                                 $headers[$h[0]] = trim($h[1]);
192
                                          } elseif (is_array($headers[$h[0]])) {
193
                                                 $headers[$h[0]] = array_merge($headers[$h[0]], array(trim($h[1])));
194
                                          } else {
195
                                                 $headers[$h[0]] = array_merge(array($headers[$h[0]]), array(trim($h[1])));
196
                                          }
197
                                          $key = $h[0];
198
                                   } else { 
199
                                          if (substr($h[0], 0, 1) == "\t") {
200
                                                 $headers[$key] .= "\r\n\t".trim($h[0]);
201
                                          } elseif (!$key) {
202
                                                 $headers[0] = trim($h[0]);
203
                                          }
204
                                   }
205
                            }
206
                            return $headers;
207
                     } else {
208
                            return http_parse_headers($raw_headers);
209
                     } 
210
              }
211
212
              private function _getHeaders()
213
              {
214
                     return $this->_parseHeaders(substr($this->response, 0, $this->curlInfo['header_size']));
215
              }
216
217
              private function _getBody()
218
              {
219
                     return substr($this->response, $this->curlInfo['header_size']);
220
              }
221
222
              public function getResponse()
223
              {
224
                     return $this->response;      
225
              }
226
227
              public function getRequest()
228
              {
229
                     return $this->request;
230
              }
231
           
232
              public function get($url, $params = null, $headers = null)
233
              {
234
                     return $this->_call($url, $params, $headers, $method = "GET");      
235
              }
236
           
237
              public function post($url, $params = null, $headers = null)
238
              {
239
                     return $this->_call($url, $params, $headers, $method = "POST");      
240
              }
241
242
              public function delete($url, $params = null, $headers = null) 
243
              {
244
                     return $this->_call($url, $params, $headers, $method = "DELETE");      
245
              }
246
247
              public function put($url, $params = null, $headers = null) 
248
              {
249
                     return $this->_call($url, $params, $headers, $method = "PUT");      
250
              }
251
252
              public function patch($url, $params = null, $headers = null) 
253
              {
254
                     return $this->_call($url, $params, $headers, $method = "PATCH");      
255
              }
256
257
              public function getCurlInfo()
258
              {
259
                     return $this->curlInfo;
260
              }
261
262
              public function isCurlError() 
263
              {
264
                     return (bool) $this->curlErrno;
265
              }
266
267
              public function getCurlErrno() 
268
              {
269
                     return $this->curlErrno;
270
              }
271
272
              public function getCurlError() 
273
              {
274
                     return $this->curlError;
275
              }
276
           
277
}
278