1. <?php
    3. /**
    4. * Curl wrapper PHP v2
    5. * @author hackerone
    6. */
    7. class Curl {
    9. // Default options from config.php
    10. public $options = array();
    11. // request specific options - valid only for single request
    12. public $request_options = array();
    13. private $_header, $_headerMap, $_errno, $_error, $_status, $_info;
    14. // default config
    15. private $_config = array(
    16. CURLOPT_NOSIGNAL => true,
    17. CURLOPT_RETURNTRANSFER => true,
    18. CURLOPT_FOLLOWLOCATION => true,
    19. CURLOPT_HEADER => false,
    20. CURLOPT_VERBOSE => true,
    21. CURLOPT_AUTOREFERER => true,
    22. CURLOPT_CONNECTTIMEOUT_MS => 1000,
    23. CURLOPT_TIMEOUT_MS => 5000,
    24. CURLOPT_SSL_VERIFYPEER => false,
    25. CURLOPT_USERAGENT => 'Mozilla/5.0 (compatible; Googlebot/2.1; +http://www.google.com/bot.html)'
    26. );
    28. public static function mergeArray() {
    29. $args = func_get_args();
    30. $res = array_shift($args);
    31. while (!empty($args)) {
    32. $next = array_shift($args);
    33. foreach ($next as $k => $v) {
    34. if (is_array($v) && isset($res[$k]) && is_array($res[$k]))
    35. $res[$k] = self::mergeArray($res[$k], $v);
    36. elseif (is_numeric($k))
    37. isset($res[$k]) ? $res[] = $v : $res[$k] = $v;
    38. else
    39. $res[$k] = $v;
    40. }
    41. }
    42. return $res;
    43. }
    45. public function getOptions() {
    46. $options = self::mergeArray($this->request_options, $this->options, $this->_config);
    47. return $options;
    48. }
    50. public function setOption($key, $value, $default = false) {
    51. if ($default)
    52. $this->options[$key] = $value;
    53. else
    54. $this->request_options[$key] = $value;
    56. return $this;
    57. }
    59. /**
    60. * Clears Options
    61. * This will clear only the request specific options. Default options cannot be cleared.
    62. */
    63. public function resetOptions() {
    64. $this->request_options = array();
    65. return $this;
    66. }
    68. /**
    69. * Resets the Option to Default option
    70. */
    71. public function resetOption($key) {
    72. if (isset($this->request_options[$key]))
    73. unset($this->request_options[$key]);
    74. return $this;
    75. }
    77. public function setOptions($options, $default = false) {
    78. if ($default)
    79. $this->options = $options + $this->request_options;
    80. else
    81. $this->request_options = $options + $this->request_options;
    83. return $this;
    84. }
    86. public function buildUrl($url, $data = array()) {
    87. $parsed = parse_url($url);
    89. isset($parsed['query']) ? parse_str($parsed['query'], $parsed['query']) : $parsed['query'] = array();
    91. $params = isset($parsed['query']) ? $data + $parsed['query'] : $data;
    92. $parsed['query'] = ($params) ? '?' . http_build_query($params) : '';
    93. if (!isset($parsed['path'])) {
    94. $parsed['path'] = '/';
    95. }
    97. $parsed['port'] = isset($parsed['port']) ? ':' . $parsed['port'] : '';
    99. return $parsed['scheme'] . '://' . $parsed['host'] . $parsed['port'] . $parsed['path'] . $parsed['query'];
    100. }
    102. public function exec($url, $options, $debug = false) {
    103. $this->_error = null;
    104. $this->_errno = 0;
    105. $this->_header = null;
    106. $this->_headerMap = null;
    107. $this->_info = null;
    108. $this->_status = null;
    110. $ch = curl_init($url);
    111. curl_setopt_array($ch, $options);
    113. $output = curl_exec($ch);
    115. $this->_status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    117. if (!$output) {
    118. $this->_error = curl_error($ch);
    119. $this->_errno = curl_errno($ch);
    120. $this->_info = curl_getinfo($ch);
    121. } else if ($debug)
    122. $this->_info = curl_getinfo($ch);
    124. if (@$options[CURLOPT_HEADER] == true) {
    125. list($header, $output) = $this->_processHeader($output, curl_getinfo($ch, CURLINFO_HEADER_SIZE));
    126. $this->_header = $header;
    127. }
    128. curl_close($ch);
    130. return $output;
    131. }
    133. public function _processHeader($response, $header_size) {
    134. return array(substr($response, 0, $header_size), substr($response, $header_size));
    135. }
    137. public function get($url, $params = array(), $debug = false) {
    138. $exec_url = $this->buildUrl($url, $params);
    139. $options = $this->getOptions();
    140. return $this->exec($exec_url, $options, $debug);
    141. }
    143. public function post($url, $data, $params = array(), $debug = false) {
    144. $url = $this->buildUrl($url, $params);
    146. $options = $this->getOptions();
    147. $options[CURLOPT_POST] = true;
    148. $options[CURLOPT_POSTFIELDS] = $data;
    150. return $this->exec($url, $options, $debug);
    151. }
    153. public function put($url, $data = null, $params = array(), $debug = false) {
    154. $url = $this->buildUrl($url, $params);
    156. $f = fopen('php://temp', 'rw+');
    157. fwrite($f, $data);
    158. rewind($f);
    160. $options = $this->getOptions();
    161. $options[CURLOPT_PUT] = true;
    162. $options[CURLOPT_INFILE] = $f;
    163. $options[CURLOPT_INFILESIZE] = strlen($data);
    165. return $this->exec($url, $options, $debug);
    166. }
    168. public function patch($url, $data = array(), $params = array(), $debug = false) {
    169. $url = $this->buildUrl($url, $params);
    171. $options = $this->getOptions();
    172. $options[CURLOPT_CUSTOMREQUEST] = 'PATCH';
    173. $options[CURLOPT_POSTFIELDS] = $data;
    175. return $this->exec($url, $options, $debug);
    176. }
    178. public function delete($url, $params = array(), $debug = false) {
    179. $url = $this->buildUrl($url, $params);
    181. $options = $this->getOptions();
    182. $options[CURLOPT_CUSTOMREQUEST] = 'DELETE';
    184. return $this->exec($url, $options, $debug);
    185. }
    187. /**
    188. * Gets header of the last curl call if header was enabled
    189. */
    190. public function getHeaders() {
    191. if (!$this->_header)
    192. return array();
    194. if (!$this->_headerMap) {
    196. $headers = explode("\r\n", trim($this->_header));
    197. $output = array();
    198. $output['http_status'] = array_shift($headers);
    200. foreach ($headers as $line) {
    201. $params = explode(':', $line, 2);
    203. if (!isset($params[1]))
    204. $output['http_status'] = $params[0];
    205. else
    206. $output[trim($params[0])] = trim($params[1]);
    207. }
    209. $this->_headerMap = $output;
    210. }
    211. return $this->_headerMap;
    212. }
    214. public function addHeader($header = array()) {
    215. $h = isset($this->request_options[CURLOPT_HTTPHEADER]) ? $this->request_options[CURLOPT_HTTPHEADER] : array();
    216. foreach ($header as $k => $v) {
    217. $h[] = $k . ': ' . $v;
    218. }
    220. $this->setHeaders($h);
    221. return $this;
    222. }
    224. public function getHeader($key) {
    225. $headers = array_change_key_case($this->getHeaders(), CASE_LOWER);
    226. $key = strtolower($key);
    228. return @$headers[$key];
    229. }
    231. public function setHeaders($header = array(), $default = false) {
    232. if ($this->_isAssoc($header)) {
    233. $out = array();
    234. foreach ($header as $k => $v) {
    235. $out[] = $k . ': ' . $v;
    236. }
    237. $header = $out;
    238. }
    240. $this->setOption(CURLOPT_HTTPHEADER, $header, $default);
    241. return $this;
    242. }
    244. private function _isAssoc($arr) {
    245. return array_keys($arr) !== range(0, count($arr) - 1);
    246. }
    248. public function getErrNo() {
    249. return $this->_errno;
    250. }
    252. public function getError() {
    253. return $this->_error;
    254. }
    256. public function getInfo() {
    257. return $this->_info;
    258. }
    260. public function getStatus() {
    261. return $this->_status;
    262. }
    264. public function init() {
    265. return;
    266. }
    268. }