git.m6w6.name Git - m6w6/ext-http/blob - http_request_api.c

   1 /*
   2    +----------------------------------------------------------------------+
   3    | PECL :: http                                                         |
   4    +----------------------------------------------------------------------+
   5    | This source file is subject to version 3.0 of the PHP license, that  |
   6    | is bundled with this package in the file LICENSE, and is available   |
   7    | through the world-wide-web at http://www.php.net/license/3_0.txt.    |
   8    | If you did not receive a copy of the PHP license and are unable to   |
   9    | obtain it through the world-wide-web, please send a note to          |
  10    | license@php.net so we can mail you a copy immediately.               |
  11    +----------------------------------------------------------------------+
  12    | Copyright (c) 2004-2005 Michael Wallner <mike@php.net>               |
  13    +----------------------------------------------------------------------+
  14 */
  15
  16 /* $Id$ */
  17
  18 #ifdef HAVE_CONFIG_H
  19 #       include "config.h"
  20 #endif
  21
  22 #ifdef PHP_WIN32
  23 #       include <winsock2.h>
  24 #endif
  25
  26 #include <curl/curl.h>
  27
  28 #include "phpstr/phpstr.h"
  29
  30 #include "php.h"
  31 #include "php_http.h"
  32 #include "php_http_std_defs.h"
  33 #include "php_http_api.h"
  34 #include "php_http_request_api.h"
  35 #include "php_http_url_api.h"
  36
  37 #ifndef HTTP_CURL_USE_ZEND_MM
  38 #       define HTTP_CURL_USE_ZEND_MM 0
  39 #endif
  40
  41 ZEND_EXTERN_MODULE_GLOBALS(http)
  42
  43 #if LIBCURL_VERSION_NUM < 0x070c00
  44 #       define curl_easy_strerror(code) HTTP_G(request).error
  45 #endif
  46
  47 #define HTTP_CURL_INFO(I) HTTP_CURL_INFO_EX(I, I)
  48 #define HTTP_CURL_INFO_EX(I, X) \
  49         switch (CURLINFO_ ##I & ~CURLINFO_MASK) \
  50         { \
  51                 case CURLINFO_STRING: \
  52                 { \
  53                         char *c; \
  54                         if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_ ##I, &c)) { \
  55                                 add_assoc_string(&array, pretty_key(http_request_data_copy(COPY_STRING, #X), sizeof(#X)-1, 0, 0), c ? c : "", 1); \
  56                         } \
  57                 } \
  58                 break; \
  59 \
  60                 case CURLINFO_DOUBLE: \
  61                 { \
  62                         double d; \
  63                         if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_ ##I, &d)) { \
  64                                 add_assoc_double(&array, pretty_key(http_request_data_copy(COPY_STRING, #X), sizeof(#X)-1, 0, 0), d); \
  65                         } \
  66                 } \
  67                 break; \
  68 \
  69                 case CURLINFO_LONG: \
  70                 { \
  71                         long l; \
  72                         if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_ ##I, &l)) { \
  73                                 add_assoc_long(&array, pretty_key(http_request_data_copy(COPY_STRING, #X), sizeof(#X)-1, 0, 0), l); \
  74                         } \
  75                 } \
  76                 break; \
  77         }
  78
  79 #define HTTP_CURL_OPT(OPTION, p) curl_easy_setopt(ch, CURLOPT_##OPTION, (p))
  80 #define HTTP_CURL_OPT_STRING(keyname) HTTP_CURL_OPT_STRING_EX(keyname, keyname)
  81 #define HTTP_CURL_OPT_SSL_STRING(keyname) HTTP_CURL_OPT_STRING_EX(keyname, SSL##keyname)
  82 #define HTTP_CURL_OPT_SSL_STRING_(keyname) HTTP_CURL_OPT_STRING_EX(keyname, SSL_##keyname)
  83 #define HTTP_CURL_OPT_STRING_EX(keyname, optname) \
  84         if (!strcasecmp(key, #keyname)) { \
  85                 convert_to_string_ex(param); \
  86                 HTTP_CURL_OPT(optname, http_request_data_copy(COPY_STRING, Z_STRVAL_PP(param))); \
  87                 key = NULL; \
  88                 continue; \
  89         }
  90 #define HTTP_CURL_OPT_LONG(keyname) HTTP_OPT_SSL_LONG_EX(keyname, keyname)
  91 #define HTTP_CURL_OPT_SSL_LONG(keyname) HTTP_CURL_OPT_LONG_EX(keyname, SSL##keyname)
  92 #define HTTP_CURL_OPT_SSL_LONG_(keyname) HTTP_CURL_OPT_LONG_EX(keyname, SSL_##keyname)
  93 #define HTTP_CURL_OPT_LONG_EX(keyname, optname) \
  94         if (!strcasecmp(key, #keyname)) { \
  95                 convert_to_long_ex(param); \
  96                 HTTP_CURL_OPT(optname, Z_LVAL_PP(param)); \
  97                 key = NULL; \
  98                 continue; \
  99         }
 100
 101
 102 static const char *const http_request_methods[HTTP_MAX_REQUEST_METHOD + 1];
 103 #define http_curl_getopt(o, k, t) _http_curl_getopt_ex((o), (k), sizeof(k), (t) TSRMLS_CC)
 104 #define http_curl_getopt_ex(o, k, l, t) _http_curl_getopt_ex((o), (k), (l), (t) TSRMLS_CC)
 105 static inline zval *_http_curl_getopt_ex(HashTable *options, char *key, size_t keylen, int type TSRMLS_DC);
 106 static size_t http_curl_write_callback(char *, size_t, size_t, void *);
 107 static size_t http_curl_read_callback(void *, size_t, size_t, void *);
 108 static int http_curl_progress_callback(void *, double, double, double, double);
 109 static int http_curl_debug_callback(CURL *, curl_infotype, char *, size_t, void *);
 110
 111 #define HTTP_CURL_CALLBACK_DATA(from, type, var) \
 112         http_curl_callback_ctx *__CTX = (http_curl_callback_ctx *) (from); \
 113         TSRMLS_FETCH_FROM_CTX(__CTX->tsrm_ctx); \
 114         type (var) = (type) (__CTX->data)
 115
 116 #define http_curl_callback_data(data) _http_curl_callback_data((data) TSRMLS_CC)
 117 static http_curl_callback_ctx *_http_curl_callback_data(void *data TSRMLS_DC);
 118
 119
 120 #if HTTP_CURL_USE_ZEND_MM
 121 static void http_curl_free(void *p)                                     { efree(p); }
 122 static char *http_curl_strdup(const char *p)            { return estrdup(p); }
 123 static void *http_curl_malloc(size_t s)                         { return emalloc(s); }
 124 static void *http_curl_realloc(void *p, size_t s)       { return erealloc(p, s); }
 125 static void *http_curl_calloc(size_t n, size_t s)       { return ecalloc(n, s); }
 126 #endif
 127
 128 /* {{{ STATUS http_request_global_init() */
 129 STATUS _http_request_global_init(void)
 130 {
 131 #if HTTP_CURL_USE_ZEND_MM
 132         if (CURLE_OK != curl_global_init_mem(CURL_GLOBAL_ALL,
 133                         http_curl_malloc,
 134                         http_curl_free,
 135                         http_curl_realloc,
 136                         http_curl_strdup,
 137                         http_curl_calloc)) {
 138                 return FAILURE;
 139         }
 140 #else
 141         if (CURLE_OK != curl_global_init(CURL_GLOBAL_ALL)) {
 142                 return FAILURE;
 143         }
 144 #endif
 145         return SUCCESS;
 146 }
 147 /* }}} */
 148
 149 /* {{{ void *http_request_data_copy(int, void *) */
 150 void *_http_request_data_copy(int type, void *data TSRMLS_DC)
 151 {
 152         switch (type)
 153         {
 154                 case COPY_STRING:
 155                 {
 156                         char *new_str = estrdup(data);
 157                         zend_llist_add_element(&HTTP_G(request).copies.strings, &new_str);
 158                         return new_str;
 159                 }
 160
 161                 case COPY_SLIST:
 162                 {
 163                         zend_llist_add_element(&HTTP_G(request).copies.slists, &data);
 164                         return data;
 165                 }
 166
 167                 case COPY_CONTEXT:
 168                 {
 169                         zend_llist_add_element(&HTTP_G(request).copies.contexts, &data);
 170                         return data;
 171                 }
 172
 173                 default:
 174                 {
 175                         return data;
 176                 }
 177         }
 178 }
 179 /* }}} */
 180
 181 /* {{{ void http_request_data_free_string(char **) */
 182 void _http_request_data_free_string(void *string)
 183 {
 184         efree(*((char **)string));
 185 }
 186 /* }}} */
 187
 188 /* {{{ void http_request_data_free_slist(struct curl_slist **) */
 189 void _http_request_data_free_slist(void *list)
 190 {
 191         curl_slist_free_all(*((struct curl_slist **) list));
 192 }
 193 /* }}} */
 194
 195 /* {{{ _http_request_data_free_context(http_curl_callback_ctx **) */
 196 void _http_request_data_free_context(void *context)
 197 {
 198         efree(*((http_curl_callback_ctx **) context));
 199 }
 200 /* }}} */
 201
 202 /* {{{ http_request_body *http_request_body_new() */
 203 PHP_HTTP_API http_request_body *_http_request_body_new(TSRMLS_D)
 204 {
 205         http_request_body *body = ecalloc(1, sizeof(http_request_body));
 206         return body;
 207 }
 208 /* }}} */
 209
 210 /* {{{ STATUS http_request_body_fill(http_request_body *body, HashTable *, HashTable *) */
 211 PHP_HTTP_API STATUS _http_request_body_fill(http_request_body *body, HashTable *fields, HashTable *files TSRMLS_DC)
 212 {
 213         if (files && (zend_hash_num_elements(files) > 0)) {
 214                 char *key = NULL;
 215                 ulong idx;
 216                 zval **data;
 217                 struct curl_httppost *http_post_data[2] = {NULL, NULL};
 218
 219                 /* normal data */
 220                 FOREACH_HASH_KEYVAL(fields, key, idx, data) {
 221                         CURLcode err;
 222                         if (key) {
 223                                 convert_to_string_ex(data);
 224                                 err = curl_formadd(&http_post_data[0], &http_post_data[1],
 225                                         CURLFORM_COPYNAME,                      key,
 226                                         CURLFORM_COPYCONTENTS,          Z_STRVAL_PP(data),
 227                                         CURLFORM_CONTENTSLENGTH,        Z_STRLEN_PP(data),
 228                                         CURLFORM_END
 229                                 );
 230                                 if (CURLE_OK != err) {
 231                                         http_error_ex(E_WARNING, HTTP_E_CURL, "Could not encode post fields: %s", curl_easy_strerror(err));
 232                                         curl_formfree(http_post_data[0]);
 233                                         return FAILURE;
 234                                 }
 235
 236                                 /* reset */
 237                                 key = NULL;
 238                         }
 239                 }
 240
 241                 /* file data */
 242                 FOREACH_HASH_VAL(files, data) {
 243                         CURLcode err;
 244                         zval **file, **type, **name;
 245                         if (    SUCCESS == zend_hash_find(Z_ARRVAL_PP(data), "name", sizeof("name"), (void **) &name) &&
 246                                         SUCCESS == zend_hash_find(Z_ARRVAL_PP(data), "type", sizeof("type"), (void **) &type) &&
 247                                         SUCCESS == zend_hash_find(Z_ARRVAL_PP(data), "file", sizeof("file"), (void **) &file)) {
 248                                 err = curl_formadd(&http_post_data[0], &http_post_data[1],
 249                                         CURLFORM_COPYNAME,              Z_STRVAL_PP(name),
 250                                         CURLFORM_FILE,                  Z_STRVAL_PP(file),
 251                                         CURLFORM_CONTENTTYPE,   Z_STRVAL_PP(type),
 252                                         CURLFORM_END
 253                                 );
 254                                 if (CURLE_OK != err) {
 255                                         http_error_ex(E_WARNING, HTTP_E_CURL, "Could not encode post files: %s", curl_easy_strerror(err));
 256                                         curl_formfree(http_post_data[0]);
 257                                         return FAILURE;
 258                                 }
 259                         } else {
 260                                 http_error(E_NOTICE, HTTP_E_PARAM, "Post file array entry misses either 'name', 'type' or 'file' entry");
 261                         }
 262                 }
 263
 264                 body->type = HTTP_REQUEST_BODY_CURLPOST;
 265                 body->data = http_post_data[0];
 266                 body->size = 0;
 267
 268         } else {
 269                 char *encoded;
 270                 size_t encoded_len;
 271
 272                 if (SUCCESS != http_urlencode_hash_ex(fields, 1, NULL, 0, &encoded, &encoded_len)) {
 273                         http_error(E_WARNING, HTTP_E_ENCODE, "Could not encode post data");
 274                         return FAILURE;
 275                 }
 276
 277                 body->type = HTTP_REQUEST_BODY_CSTRING;
 278                 body->data = encoded;
 279                 body->size = encoded_len;
 280         }
 281
 282         return SUCCESS;
 283 }
 284 /* }}} */
 285
 286 /* {{{ void http_request_body_dtor(http_request_body *) */
 287 PHP_HTTP_API void _http_request_body_dtor(http_request_body *body TSRMLS_DC)
 288 {
 289         if (body) {
 290                 switch (body->type)
 291                 {
 292                         case HTTP_REQUEST_BODY_CSTRING:
 293                                 if (body->data) {
 294                                         efree(body->data);
 295                                 }
 296                         break;
 297
 298                         case HTTP_REQUEST_BODY_CURLPOST:
 299                                 curl_formfree(body->data);
 300                         break;
 301
 302                         case HTTP_REQUEST_BODY_UPLOADFILE:
 303                                 php_stream_close(body->data);
 304                         break;
 305                 }
 306         }
 307 }
 308 /* }}} */
 309
 310 /* {{{ void http_request_body_free(http_request_body *) */
 311 PHP_HTTP_API void _http_request_body_free(http_request_body *body TSRMLS_DC)
 312 {
 313         if (body) {
 314                 http_request_body_dtor(body);
 315                 efree(body);
 316         }
 317 }
 318 /* }}} */
 319
 320 /* {{{ STATUS http_request_init(CURL *, http_request_method, char *, http_request_body *, HashTable *, phpstr *) */
 321 PHP_HTTP_API STATUS _http_request_init(CURL *ch, http_request_method meth, char *url, http_request_body *body, HashTable *options, phpstr *response TSRMLS_DC)
 322 {
 323         zval *zoption;
 324         zend_bool range_req = 0;
 325
 326         /* reset CURL handle */
 327 #if LIBCURL_VERSION_NUM >= 0x070c01
 328         curl_easy_reset(ch);
 329 #endif
 330
 331         /* set options */
 332         if (url) {
 333                 HTTP_CURL_OPT(URL, http_request_data_copy(COPY_STRING, url));
 334         }
 335
 336         if (response) {
 337                 http_curl_callback_ctx *response_ctx = http_curl_callback_data(response);
 338                 HTTP_CURL_OPT(WRITEDATA, response_ctx);
 339                 HTTP_CURL_OPT(WRITEHEADER, response_ctx);
 340         }
 341
 342         HTTP_CURL_OPT(HEADER, 0);
 343         HTTP_CURL_OPT(FILETIME, 1);
 344         HTTP_CURL_OPT(AUTOREFERER, 1);
 345         HTTP_CURL_OPT(READFUNCTION, http_curl_read_callback);
 346         HTTP_CURL_OPT(WRITEFUNCTION, http_curl_write_callback);
 347         HTTP_CURL_OPT(HEADERFUNCTION, http_curl_write_callback);
 348
 349 #if defined(ZTS) && (LIBCURL_VERSION_NUM >= 0x070a00)
 350         HTTP_CURL_OPT(NOSIGNAL, 1);
 351 #endif
 352 #if LIBCURL_VERSION_NUM < 0x070c00
 353         HTTP_CURL_OPT(ERRORBUFFER, HTTP_G(request).error);
 354 #endif
 355
 356         /* progress callback */
 357         if (zoption = http_curl_getopt(options, "onprogress", 0)) {
 358                 HTTP_CURL_OPT(PROGRESSFUNCTION, http_curl_progress_callback);
 359                 HTTP_CURL_OPT(PROGRESSDATA,  http_curl_callback_data(zoption));
 360         } else {
 361                 HTTP_CURL_OPT(NOPROGRESS, 1);
 362         }
 363
 364         /* debug callback */
 365         if (zoption = http_curl_getopt(options, "ondebug", 0)) {
 366                 HTTP_CURL_OPT(VERBOSE, 1);
 367                 HTTP_CURL_OPT(DEBUGFUNCTION, http_curl_debug_callback);
 368                 HTTP_CURL_OPT(DEBUGDATA, http_curl_callback_data(zoption));
 369         } else {
 370                 HTTP_CURL_OPT(VERBOSE, 0);
 371         }
 372
 373         /* proxy */
 374         if (zoption = http_curl_getopt(options, "proxyhost", IS_STRING)) {
 375                 HTTP_CURL_OPT(PROXY, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 376                 /* port */
 377                 if (zoption = http_curl_getopt(options, "proxyport", IS_LONG)) {
 378                         HTTP_CURL_OPT(PROXYPORT, Z_LVAL_P(zoption));
 379                 }
 380                 /* user:pass */
 381                 if (zoption = http_curl_getopt(options, "proxyauth", IS_STRING)) {
 382                         HTTP_CURL_OPT(PROXYUSERPWD, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 383                 }
 384 #if LIBCURL_VERSION_NUM >= 0x070a07
 385                 /* auth method */
 386                 if (zoption = http_curl_getopt(options, "proxyauthtype", IS_LONG)) {
 387                         HTTP_CURL_OPT(PROXYAUTH, Z_LVAL_P(zoption));
 388                 }
 389 #endif
 390         }
 391
 392         /* outgoing interface */
 393         if (zoption = http_curl_getopt(options, "interface", IS_STRING)) {
 394                 HTTP_CURL_OPT(INTERFACE, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 395         }
 396
 397         /* another port */
 398         if (zoption = http_curl_getopt(options, "port", IS_LONG)) {
 399                 HTTP_CURL_OPT(PORT, Z_LVAL_P(zoption));
 400         }
 401
 402         /* auth */
 403         if (zoption = http_curl_getopt(options, "httpauth", IS_STRING)) {
 404                 HTTP_CURL_OPT(USERPWD, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 405         }
 406 #if LIBCURL_VERSION_NUM >= 0x070a06
 407         if (zoption = http_curl_getopt(options, "httpauthtype", IS_LONG)) {
 408                 HTTP_CURL_OPT(HTTPAUTH, Z_LVAL_P(zoption));
 409         }
 410 #endif
 411
 412         /* compress, empty string enables deflate and gzip */
 413         if (zoption = http_curl_getopt(options, "compress", IS_BOOL)) {
 414                 if (Z_LVAL_P(zoption)) {
 415                         HTTP_CURL_OPT(ENCODING, "");
 416                 }
 417         }
 418
 419         /* redirects, defaults to 0 */
 420         if (zoption = http_curl_getopt(options, "redirect", IS_LONG)) {
 421                 HTTP_CURL_OPT(FOLLOWLOCATION, Z_LVAL_P(zoption) ? 1 : 0);
 422                 HTTP_CURL_OPT(MAXREDIRS, Z_LVAL_P(zoption));
 423                 if (zoption = http_curl_getopt(options, "unrestrictedauth", IS_BOOL)) {
 424                         HTTP_CURL_OPT(UNRESTRICTED_AUTH, Z_LVAL_P(zoption));
 425                 }
 426         } else {
 427                 HTTP_CURL_OPT(FOLLOWLOCATION, 0);
 428         }
 429
 430         /* referer */
 431         if (zoption = http_curl_getopt(options, "referer", IS_STRING)) {
 432                 HTTP_CURL_OPT(REFERER, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 433         }
 434
 435         /* useragent, default "PECL::HTTP/version (PHP/version)" */
 436         if (zoption = http_curl_getopt(options, "useragent", IS_STRING)) {
 437                 HTTP_CURL_OPT(USERAGENT, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 438         } else {
 439                 HTTP_CURL_OPT(USERAGENT, "PECL::HTTP/" HTTP_PEXT_VERSION " (PHP/" PHP_VERSION ")");
 440         }
 441
 442         /* additional headers, array('name' => 'value') */
 443         if (zoption = http_curl_getopt(options, "headers", IS_ARRAY)) {
 444                 char *header_key;
 445                 ulong header_idx;
 446                 struct curl_slist *headers = NULL;
 447
 448                 FOREACH_KEY(zoption, header_key, header_idx) {
 449                         if (header_key) {
 450                                 zval **header_val;
 451                                 if (SUCCESS == zend_hash_get_current_data(Z_ARRVAL_P(zoption), (void **) &header_val)) {
 452                                         char header[1024] = {0};
 453                                         snprintf(header, 1023, "%s: %s", header_key, Z_STRVAL_PP(header_val));
 454                                         headers = curl_slist_append(headers, http_request_data_copy(COPY_STRING, header));
 455                                 }
 456
 457                                 /* reset */
 458                                 header_key = NULL;
 459                         }
 460                 }
 461
 462                 if (headers) {
 463                         HTTP_CURL_OPT(HTTPHEADER, http_request_data_copy(COPY_SLIST, headers));
 464                 }
 465         } else {
 466                 HTTP_CURL_OPT(HTTPHEADER, NULL);
 467         }
 468
 469         /* cookies, array('name' => 'value') */
 470         if (zoption = http_curl_getopt(options, "cookies", IS_ARRAY)) {
 471                 char *cookie_key = NULL;
 472                 ulong cookie_idx = 0;
 473                 phpstr *qstr = phpstr_new();
 474
 475                 FOREACH_KEY(zoption, cookie_key, cookie_idx) {
 476                         if (cookie_key) {
 477                                 zval **cookie_val;
 478                                 if (SUCCESS == zend_hash_get_current_data(Z_ARRVAL_P(zoption), (void **) &cookie_val)) {
 479                                         phpstr_appendf(qstr, "%s=%s; ", cookie_key, Z_STRVAL_PP(cookie_val));
 480                                 }
 481
 482                                 /* reset */
 483                                 cookie_key = NULL;
 484                         }
 485                 }
 486
 487                 if (qstr->used) {
 488                         phpstr_fix(qstr);
 489                         HTTP_CURL_OPT(COOKIE, http_request_data_copy(COPY_STRING, qstr->data));
 490                 }
 491                 phpstr_free(qstr);
 492         }
 493
 494         /* cookiestore */
 495         if (zoption = http_curl_getopt(options, "cookiestore", IS_STRING)) {
 496                 HTTP_CURL_OPT(COOKIEFILE, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 497                 HTTP_CURL_OPT(COOKIEJAR, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 498         }
 499
 500         /* resume */
 501         if (zoption = http_curl_getopt(options, "resume", IS_LONG)) {
 502                 range_req = 1;
 503                 HTTP_CURL_OPT(RESUME_FROM, Z_LVAL_P(zoption));
 504         }
 505
 506         /* maxfilesize */
 507         if (zoption = http_curl_getopt(options, "maxfilesize", IS_LONG)) {
 508                 HTTP_CURL_OPT(MAXFILESIZE, Z_LVAL_P(zoption));
 509         }
 510
 511         /* lastmodified */
 512         if (zoption = http_curl_getopt(options, "lastmodified", IS_LONG)) {
 513                 HTTP_CURL_OPT(TIMECONDITION, range_req ? CURL_TIMECOND_IFUNMODSINCE : CURL_TIMECOND_IFMODSINCE);
 514                 HTTP_CURL_OPT(TIMEVALUE, Z_LVAL_P(zoption));
 515         }
 516
 517         /* timeout */
 518         if (zoption = http_curl_getopt(options, "timeout", IS_LONG)) {
 519                 HTTP_CURL_OPT(TIMEOUT, Z_LVAL_P(zoption));
 520         }
 521
 522         /* connecttimeout, defaults to 1 */
 523         if (zoption = http_curl_getopt(options, "connecttimeout", IS_LONG)) {
 524                 HTTP_CURL_OPT(CONNECTTIMEOUT, Z_LVAL_P(zoption));
 525         } else {
 526                 HTTP_CURL_OPT(CONNECTTIMEOUT, 1);
 527         }
 528
 529         /* ssl */
 530         if (zoption = http_curl_getopt(options, "ssl", IS_ARRAY)) {
 531                 ulong idx;
 532                 char *key = NULL;
 533                 zval **param;
 534
 535                 FOREACH_KEYVAL(zoption, key, idx, param) {
 536                         if (key) {
 537                                 HTTP_CURL_OPT_SSL_STRING(CERT);
 538 #if LIBCURL_VERSION_NUM >= 0x070903
 539                                 HTTP_CURL_OPT_SSL_STRING(CERTTYPE);
 540 #endif
 541                                 HTTP_CURL_OPT_SSL_STRING(CERTPASSWD);
 542
 543                                 HTTP_CURL_OPT_SSL_STRING(KEY);
 544                                 HTTP_CURL_OPT_SSL_STRING(KEYTYPE);
 545                                 HTTP_CURL_OPT_SSL_STRING(KEYPASSWD);
 546
 547                                 HTTP_CURL_OPT_SSL_STRING(ENGINE);
 548                                 HTTP_CURL_OPT_SSL_LONG(VERSION);
 549
 550                                 HTTP_CURL_OPT_SSL_LONG_(VERIFYPEER);
 551                                 HTTP_CURL_OPT_SSL_LONG_(VERIFYHOST);
 552                                 HTTP_CURL_OPT_SSL_STRING_(CIPHER_LIST);
 553
 554
 555                                 HTTP_CURL_OPT_STRING(CAINFO);
 556 #if LIBCURL_VERSION_NUM >= 0x070908
 557                                 HTTP_CURL_OPT_STRING(CAPATH);
 558 #endif
 559                                 HTTP_CURL_OPT_STRING(RANDOM_FILE);
 560                                 HTTP_CURL_OPT_STRING(EGDSOCKET);
 561
 562                                 /* reset key */
 563                                 key = NULL;
 564                         }
 565                 }
 566         } else {
 567                 /* disable SSL verification by default */
 568                 HTTP_CURL_OPT(SSL_VERIFYPEER, 0);
 569                 HTTP_CURL_OPT(SSL_VERIFYHOST, 0);
 570         }
 571
 572         /* request method */
 573         switch (meth)
 574         {
 575                 case HTTP_GET:
 576                         curl_easy_setopt(ch, CURLOPT_HTTPGET, 1);
 577                 break;
 578
 579                 case HTTP_HEAD:
 580                         curl_easy_setopt(ch, CURLOPT_NOBODY, 1);
 581                 break;
 582
 583                 case HTTP_POST:
 584                         curl_easy_setopt(ch, CURLOPT_POST, 1);
 585                 break;
 586
 587                 case HTTP_PUT:
 588                         curl_easy_setopt(ch, CURLOPT_UPLOAD, 1);
 589                 break;
 590
 591                 default:
 592                         if (http_request_method_exists(0, meth, NULL)) {
 593                                 curl_easy_setopt(ch, CURLOPT_CUSTOMREQUEST, http_request_method_name(meth));
 594                         } else {
 595                                 http_error_ex(E_WARNING, HTTP_E_CURL, "Unsupported request method: %d", meth);
 596                                 return FAILURE;
 597                         }
 598                 break;
 599         }
 600
 601         /* attach request body */
 602         if (body && (meth != HTTP_GET) && (meth != HTTP_HEAD)) {
 603                 switch (body->type)
 604                 {
 605                         case HTTP_REQUEST_BODY_CSTRING:
 606                                 curl_easy_setopt(ch, CURLOPT_POSTFIELDS, body->data);
 607                                 curl_easy_setopt(ch, CURLOPT_POSTFIELDSIZE, body->size);
 608                         break;
 609
 610                         case HTTP_REQUEST_BODY_CURLPOST:
 611                                 curl_easy_setopt(ch, CURLOPT_HTTPPOST, (struct curl_httppost *) body->data);
 612                         break;
 613
 614                         case HTTP_REQUEST_BODY_UPLOADFILE:
 615                                 curl_easy_setopt(ch, CURLOPT_READDATA, http_curl_callback_data(body));
 616                                 curl_easy_setopt(ch, CURLOPT_INFILESIZE, body->size);
 617                         break;
 618
 619                         default:
 620                                 http_error_ex(E_WARNING, HTTP_E_CURL, "Unknown request body type: %d", body->type);
 621                                 return FAILURE;
 622                         break;
 623                 }
 624         }
 625
 626         return SUCCESS;
 627 }
 628 /* }}} */
 629
 630 /* {{{ STATUS http_request_exec(CURL *, HashTable *) */
 631 PHP_HTTP_API STATUS _http_request_exec(CURL *ch, HashTable *info TSRMLS_DC)
 632 {
 633         CURLcode result;
 634
 635         /* perform request */
 636         if (CURLE_OK != (result = curl_easy_perform(ch))) {
 637                 http_error_ex(E_WARNING, HTTP_E_CURL, "Could not perform request: %s", curl_easy_strerror(result));
 638                 return FAILURE;
 639         } else {
 640                 /* get curl info */
 641                 if (info) {
 642                         http_request_info(ch, info);
 643                 }
 644                 return SUCCESS;
 645         }
 646 }
 647 /* }}} */
 648
 649 /* {{{ void http_request_info(CURL *, HashTable *) */
 650 PHP_HTTP_API void _http_request_info(CURL *ch, HashTable *info TSRMLS_DC)
 651 {
 652         zval array;
 653         Z_ARRVAL(array) = info;
 654
 655         HTTP_CURL_INFO(EFFECTIVE_URL);
 656 #if LIBCURL_VERSION_NUM >= 0x070a07
 657         HTTP_CURL_INFO(RESPONSE_CODE);
 658 #else
 659         HTTP_CURL_INFO_EX(HTTP_CODE, RESPONSE_CODE);
 660 #endif
 661         HTTP_CURL_INFO(HTTP_CONNECTCODE);
 662 #if LIBCURL_VERSION_NUM >= 0x070500
 663         HTTP_CURL_INFO(FILETIME);
 664 #endif
 665         HTTP_CURL_INFO(TOTAL_TIME);
 666         HTTP_CURL_INFO(NAMELOOKUP_TIME);
 667         HTTP_CURL_INFO(CONNECT_TIME);
 668         HTTP_CURL_INFO(PRETRANSFER_TIME);
 669         HTTP_CURL_INFO(STARTTRANSFER_TIME);
 670 #if LIBCURL_VERSION_NUM >= 0x070907
 671         HTTP_CURL_INFO(REDIRECT_TIME);
 672         HTTP_CURL_INFO(REDIRECT_COUNT);
 673 #endif
 674         HTTP_CURL_INFO(SIZE_UPLOAD);
 675         HTTP_CURL_INFO(SIZE_DOWNLOAD);
 676         HTTP_CURL_INFO(SPEED_DOWNLOAD);
 677         HTTP_CURL_INFO(SPEED_UPLOAD);
 678         HTTP_CURL_INFO(HEADER_SIZE);
 679         HTTP_CURL_INFO(REQUEST_SIZE);
 680         HTTP_CURL_INFO(SSL_VERIFYRESULT);
 681 #if LIBCURL_VERSION_NUM >= 0x070c03
 682         /*HTTP_CURL_INFO(SSL_ENGINES); todo: CURLINFO_SLIST */
 683 #endif
 684         HTTP_CURL_INFO(CONTENT_LENGTH_DOWNLOAD);
 685         HTTP_CURL_INFO(CONTENT_LENGTH_UPLOAD);
 686         HTTP_CURL_INFO(CONTENT_TYPE);
 687 #if LIBCURL_VERSION_NUM >= 0x070a03
 688         /*HTTP_CURL_INFO(PRIVATE);*/
 689 #endif
 690 #if LIBCURL_VERSION_NUM >= 0x070a08
 691         HTTP_CURL_INFO(HTTPAUTH_AVAIL);
 692         HTTP_CURL_INFO(PROXYAUTH_AVAIL);
 693 #endif
 694 #if LIBCURL_VERSION_NUM >= 0x070c02
 695         /*HTTP_CURL_INFO(OS_ERRNO);*/
 696 #endif
 697 #if LIBCURL_VERSION_NUM >= 0x070c03
 698         HTTP_CURL_INFO(NUM_CONNECTS);
 699 #endif
 700 }
 701 /* }}} */
 702
 703 /* {{{ STATUS http_request_ex(CURL *, http_request_method, char *, http_request_body, HashTable, HashTable, phpstr *) */
 704 PHP_HTTP_API STATUS _http_request_ex(CURL *ch, http_request_method meth, char *url, http_request_body *body, HashTable *options, HashTable *info, phpstr *response TSRMLS_DC)
 705 {
 706         STATUS status;
 707         zend_bool clean_curl;
 708
 709         if ((clean_curl = (!ch))) {
 710                 if (!(ch = curl_easy_init())) {
 711                         http_error(E_WARNING, HTTP_E_CURL, "Could not initialize curl.");
 712                         return FAILURE;
 713                 }
 714         }
 715
 716         status =        ((SUCCESS == http_request_init(ch, meth, url, body, options, response)) &&
 717                                 (SUCCESS == http_request_exec(ch, info))) ? SUCCESS : FAILURE;
 718
 719         if (clean_curl) {
 720                 curl_easy_cleanup(ch);
 721         }
 722         return status;
 723 }
 724 /* }}} */
 725
 726 /* {{{ char *http_request_method_name(http_request_method) */
 727 PHP_HTTP_API const char *_http_request_method_name(http_request_method m TSRMLS_DC)
 728 {
 729         zval **meth;
 730
 731         if (HTTP_STD_REQUEST_METHOD(m)) {
 732                 return http_request_methods[m];
 733         }
 734
 735         if (SUCCESS == zend_hash_index_find(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(m), (void **) &meth)) {
 736                 return Z_STRVAL_PP(meth);
 737         }
 738
 739         return http_request_methods[0];
 740 }
 741 /* }}} */
 742
 743 /* {{{ unsigned long http_request_method_exists(zend_bool, unsigned long, char *) */
 744 PHP_HTTP_API unsigned long _http_request_method_exists(zend_bool by_name, unsigned long id, const char *name TSRMLS_DC)
 745 {
 746         if (by_name) {
 747                 unsigned i;
 748
 749                 for (i = HTTP_NO_REQUEST_METHOD + 1; i < HTTP_MAX_REQUEST_METHOD; ++i) {
 750                         if (!strcmp(name, http_request_methods[i])) {
 751                                 return i;
 752                         }
 753                 }
 754                 {
 755                         zval **data;
 756                         char *key;
 757                         ulong idx;
 758
 759                         FOREACH_HASH_KEYVAL(&HTTP_G(request).methods.custom, key, idx, data) {
 760                                 if (!strcmp(name, Z_STRVAL_PP(data))) {
 761                                         return idx + HTTP_MAX_REQUEST_METHOD;
 762                                 }
 763                         }
 764                 }
 765                 return 0;
 766         } else {
 767                 return HTTP_STD_REQUEST_METHOD(id) || zend_hash_index_exists(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(id)) ? id : 0;
 768         }
 769 }
 770 /* }}} */
 771
 772 /* {{{ unsigned long http_request_method_register(char *) */
 773 PHP_HTTP_API unsigned long _http_request_method_register(const char *method TSRMLS_DC)
 774 {
 775         zval array;
 776         char *http_method;
 777         unsigned long meth_num = HTTP_G(request).methods.custom.nNextFreeElement + HTTP_MAX_REQUEST_METHOD;
 778
 779         Z_ARRVAL(array) = &HTTP_G(request).methods.custom;
 780         add_next_index_string(&array, estrdup(method), 0);
 781
 782         spprintf(&http_method, 0, "HTTP_%s", method);
 783         zend_register_long_constant(http_method, strlen(http_method) + 1, meth_num, CONST_CS, http_module_number TSRMLS_CC);
 784         efree(http_method);
 785
 786         return meth_num;
 787 }
 788 /* }}} */
 789
 790 /* {{{ STATUS http_request_method_unregister(usngigned long) */
 791 PHP_HTTP_API STATUS _http_request_method_unregister(unsigned long method TSRMLS_DC)
 792 {
 793         zval **zmethod;
 794         char *http_method;
 795
 796         if (SUCCESS != zend_hash_index_find(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(method), (void **) &zmethod)) {
 797                 http_error_ex(E_NOTICE, HTTP_E_PARAM, "Request method with id %lu does not exist", method);
 798                 return FAILURE;
 799         }
 800
 801         spprintf(&http_method, 0, "HTTP_%s", Z_STRVAL_PP(zmethod));
 802
 803         if (    (SUCCESS != zend_hash_index_del(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(method)))
 804                 ||      (SUCCESS != zend_hash_del(EG(zend_constants), http_method, strlen(http_method) + 1))) {
 805                 http_error_ex(E_NOTICE, 0, "Could not unregister request method: %s", http_method);
 806                 efree(http_method);
 807                 return FAILURE;
 808         }
 809
 810         efree(http_method);
 811         return SUCCESS;
 812 }
 813 /* }}} */
 814
 815
 816 /* {{{ char *http_request_methods[] */
 817 static const char *const http_request_methods[] = {
 818         "UNKOWN",
 819         /* HTTP/1.1 */
 820         "GET",
 821         "HEAD",
 822         "POST",
 823         "PUT",
 824         "DELETE",
 825         "OPTIONS",
 826         "TRACE",
 827         "CONNECT",
 828         /* WebDAV - RFC 2518 */
 829         "PROPFIND",
 830         "PROPPATCH",
 831         "MKCOL",
 832         "COPY",
 833         "MOVE",
 834         "LOCK",
 835         "UNLOCK",
 836         /* WebDAV Versioning - RFC 3253 */
 837         "VERSION-CONTROL",
 838         "REPORT",
 839         "CHECKOUT",
 840         "CHECKIN",
 841         "UNCHECKOUT",
 842         "MKWORKSPACE",
 843         "UPDATE",
 844         "LABEL",
 845         "MERGE",
 846         "BASELINE-CONTROL",
 847         "MKACTIVITY",
 848         /* WebDAV Access Control - RFC 3744 */
 849         "ACL",
 850         NULL
 851 };
 852 /* }}} */
 853
 854 /* {{{ static size_t http_curl_write_callback(char *, size_t, size_t, void *) */
 855 static size_t http_curl_write_callback(char *buf, size_t len, size_t n, void *s)
 856 {
 857         HTTP_CURL_CALLBACK_DATA(s, phpstr *, str);
 858         return str ? phpstr_append(PHPSTR(str), buf, len * n) : len * n;
 859 }
 860 /* }}} */
 861
 862 /* {{{ static size_t http_curl_read_callback(void *, size_t, size_t, void *) */
 863 static size_t http_curl_read_callback(void *data, size_t len, size_t n, void *s)
 864 {
 865         HTTP_CURL_CALLBACK_DATA(s, http_request_body *, body);
 866
 867         if (body->type != HTTP_REQUEST_BODY_UPLOADFILE) {
 868                 return 0;
 869         }
 870         return php_stream_read((php_stream *) body->data, data, len * n);
 871 }
 872 /* }}} */
 873
 874 /* {{{ http_curl_callback_ctx http_curl_callback_data(void *) */
 875 static http_curl_callback_ctx *_http_curl_callback_data(void *data TSRMLS_DC)
 876 {
 877         http_curl_callback_ctx *ctx = emalloc(sizeof(http_curl_callback_ctx));
 878         TSRMLS_SET_CTX(ctx->tsrm_ctx);
 879         ctx->data = data;
 880         return http_request_data_copy(COPY_CONTEXT, ctx);
 881 }
 882 /* }}} */
 883
 884 /* {{{ static int http_curl_progress_callback(void *, double, double, double, double) */
 885 static int http_curl_progress_callback(void *data, double dltotal, double dlnow, double ultotal, double ulnow)
 886 {
 887         zval *params_pass[4], params_local[4], retval;
 888         HTTP_CURL_CALLBACK_DATA(data, zval *, func);
 889
 890         params_pass[0] = &params_local[0];
 891         params_pass[1] = &params_local[1];
 892         params_pass[2] = &params_local[2];
 893         params_pass[3] = &params_local[3];
 894
 895         ZVAL_DOUBLE(params_pass[0], dltotal);
 896         ZVAL_DOUBLE(params_pass[1], dlnow);
 897         ZVAL_DOUBLE(params_pass[2], ultotal);
 898         ZVAL_DOUBLE(params_pass[3], ulnow);
 899
 900         return call_user_function(EG(function_table), NULL, func, &retval, 4, params_pass TSRMLS_CC);
 901 }
 902 /* }}} */
 903
 904 static int http_curl_debug_callback(CURL *ch, curl_infotype type, char *string, size_t length, void *data)
 905 {
 906         zval *params_pass[2], params_local[2], retval;
 907         HTTP_CURL_CALLBACK_DATA(data, zval *, func);
 908
 909         params_pass[0] = &params_local[0];
 910         params_pass[1] = &params_local[1];
 911
 912         ZVAL_LONG(params_pass[0], type);
 913         ZVAL_STRINGL(params_pass[1], string, length, 1);
 914
 915         call_user_function(EG(function_table), NULL, func, &retval, 2, params_pass TSRMLS_CC);
 916
 917         return 0;
 918 }
 919 /* {{{ static inline zval *http_curl_getopt(HashTable *, char *, size_t, int) */
 920 static inline zval *_http_curl_getopt_ex(HashTable *options, char *key, size_t keylen, int type TSRMLS_DC)
 921 {
 922         zval **zoption;
 923
 924         if (!options || (SUCCESS != zend_hash_find(options, key, keylen, (void **) &zoption))) {
 925                 return NULL;
 926         }
 927
 928         if (Z_TYPE_PP(zoption) != type) {
 929                 switch (type)
 930                 {
 931                         case IS_BOOL:   convert_to_boolean_ex(zoption); break;
 932                         case IS_LONG:   convert_to_long_ex(zoption);    break;
 933                         case IS_DOUBLE: convert_to_double_ex(zoption);  break;
 934                         case IS_STRING: convert_to_string_ex(zoption);  break;
 935                         case IS_ARRAY:  convert_to_array_ex(zoption);   break;
 936                         case IS_OBJECT: convert_to_object_ex(zoption);  break;
 937                         default:
 938                         break;
 939                 }
 940         }
 941
 942         return *zoption;
 943 }
 944 /* }}} */
 945
 946 /*
 947  * Local variables:
 948  * tab-width: 4
 949  * c-basic-offset: 4
 950  * End:
 951  * vim600: noet sw=4 ts=4 fdm=marker
 952  * vim<600: noet sw=4 ts=4
 953  */
 954