1. <?php
  3. /**
  4. * OO cURL Class
  5. * Object oriented wrapper for the cURL library.
  6. * @author David Hopkins (semlabs.co.uk)
  7. * @version 0.3
  8. */
  9. class CURL
  10. {
  12. public $sessions = array();
  13. public $retry = 0;
  15. /**
  16. * Adds a cURL session to stack
  17. * @param $url string, session's URL
  18. * @param $opts array, optional array of cURL options and values
  19. */
  20. public function addSession( $url, $opts = false )
  21. {
  22. $this->sessions[] = curl_init( $url );
  23. if( $opts != false )
  24. {
  25. $key = count( $this->sessions ) - 1;
  26. $this->setOpts( $opts, $key );
  27. }
  28. }
  30. /**
  31. * Sets an option to a cURL session
  32. * @param $option constant, cURL option
  33. * @param $value mixed, value of option
  34. * @param $key int, session key to set option for
  35. */
  36. public function setOpt( $option, $value, $key = 0 )
  37. {
  38. curl_setopt( $this->sessions[$key], $option, $value );
  39. }
  41. /**
  42. * Sets an array of options to a cURL session
  43. * @param $options array, array of cURL options and values
  44. * @param $key int, session key to set option for
  45. */
  46. public function setOpts( $options, $key = 0 )
  47. {
  48. curl_setopt_array( $this->sessions[$key], $options );
  49. }
  51. /**
  52. * Executes as cURL session
  53. * @param $key int, optional argument if you only want to execute one session
  54. */
  55. public function exec( $key = false )
  56. {
  57. $no = count( $this->sessions );
  59. if( $no == 1 )
  60. $res = $this->execSingle();
  61. elseif( $no > 1 ) {
  62. if( $key === false )
  63. $res = $this->execMulti();
  64. else
  65. $res = $this->execSingle( $key );
  66. }
  68. if( $res )
  69. return $res;
  70. }
  72. /**
  73. * Executes a single cURL session
  74. * @param $key int, id of session to execute
  75. * @return array of content if CURLOPT_RETURNTRANSFER is set
  76. */
  77. public function execSingle( $key = 0 )
  78. {
  79. if( $this->retry > 0 )
  80. {
  81. $retry = $this->retry;
  82. $code = 0;
  83. while( $retry >= 0 && ( $code[0] == 0 || $code[0] >= 400 ) )
  84. {
  85. $res = curl_exec( $this->sessions[$key] );
  86. $code = $this->info( $key, CURLINFO_HTTP_CODE );
  88. $retry--;
  89. }
  90. }
  91. else
  92. $res = curl_exec( $this->sessions[$key] );
  94. return $res;
  95. }
  97. /**
  98. * Executes a stack of sessions
  99. * @return array of content if CURLOPT_RETURNTRANSFER is set
  100. */
  101. public function execMulti()
  102. {
  103. $mh = curl_multi_init();
  105. #Add all sessions to multi handle
  106. foreach ( $this->sessions as $i => $url )
  107. curl_multi_add_handle( $mh, $this->sessions[$i] );
  109. do
  110. $mrc = curl_multi_exec( $mh, $active );
  111. while ( $mrc == CURLM_CALL_MULTI_PERFORM );
  113. while ( $active && $mrc == CURLM_OK )
  114. {
  115. if ( curl_multi_select( $mh ) != -1 )
  116. {
  117. do
  118. $mrc = curl_multi_exec( $mh, $active );
  119. while ( $mrc == CURLM_CALL_MULTI_PERFORM );
  120. }
  121. }
  123. if ( $mrc != CURLM_OK )
  124. echo "Curl multi read error $mrc\n";
  126. #Get content foreach session, retry if applied
  127. foreach ( $this->sessions as $i => $url )
  128. {
  129. $code = $this->info( $i, CURLINFO_HTTP_CODE );
  130. if( $code[0] > 0 && $code[0] < 400 )
  131. $res[] = curl_multi_getcontent( $this->sessions[$i] );
  132. else
  133. {
  134. if( $this->retry > 0 )
  135. {
  136. $retry = $this->retry;
  137. $this->retry -= 1;
  138. $eRes = $this->execSingle( $i );
  140. if( $eRes )
  141. $res[] = $eRes;
  142. else
  143. $res[] = false;
  145. $this->retry = $retry;
  146. echo '1';
  147. }
  148. else
  149. $res[] = false;
  150. }
  152. curl_multi_remove_handle( $mh, $this->sessions[$i] );
  153. }
  155. curl_multi_close( $mh );
  157. return $res;
  158. }
  160. /**
  161. * Closes cURL sessions
  162. * @param $key int, optional session to close
  163. */
  164. public function close( $key = false )
  165. {
  166. if( $key === false )
  167. {
  168. foreach( $this->sessions as $session )
  169. curl_close( $session );
  170. }
  171. else
  172. curl_close( $this->sessions[$key] );
  173. }
  175. /**
  176. * Remove all cURL sessions
  177. */
  178. public function clear()
  179. {
  180. foreach( $this->sessions as $session )
  181. curl_close( $session );
  182. unset( $this->sessions );
  183. }
  185. /**
  186. * Returns an array of session information
  187. * @param $key int, optional session key to return info on
  188. * @param $opt constant, optional option to return
  189. */
  190. public function info( $key = false, $opt = false )
  191. {
  192. if( $key === false )
  193. {
  194. foreach( $this->sessions as $key => $session )
  195. {
  196. if( $opt )
  197. $info[] = curl_getinfo( $this->sessions[$key], $opt );
  198. else
  199. $info[] = curl_getinfo( $this->sessions[$key] );
  200. }
  201. }
  202. else
  203. {
  204. if( $opt )
  205. $info[] = curl_getinfo( $this->sessions[$key], $opt );
  206. else
  207. $info[] = curl_getinfo( $this->sessions[$key] );
  208. }
  210. return $info;
  211. }
  213. /**
  214. * Returns an array of errors
  215. * @param $key int, optional session key to retun error on
  216. * @return array of error messages
  217. */
  218. public function error( $key = false )
  219. {
  220. if( $key === false )
  221. {
  222. foreach( $this->sessions as $session )
  223. $errors[] = curl_error( $session );
  224. }
  225. else
  226. $errors[] = curl_error( $this->sessions[$key] );
  228. return $errors;
  229. }
  231. /**
  232. * Returns an array of session error numbers
  233. * @param $key int, optional session key to retun error on
  234. * @return array of error codes
  235. */
  236. public function errorNo( $key = false )
  237. {
  238. if( $key === false )
  239. {
  240. foreach( $this->sessions as $session )
  241. $errors[] = curl_errno( $session );
  242. }
  243. else
  244. $errors[] = curl_errno( $this->sessions[$key] );
  246. return $errors;
  247. }
  249. }
  251. ?>