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)) && Z_LVAL_P(zoption)) {
 414                 HTTP_CURL_OPT(ENCODING, "");
 415         } else {
 416                 HTTP_CURL_OPT(ENCODING, 0);
 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         } else {
 434                 HTTP_CURL_OPT(REFERER, NULL);
 435         }
 436
 437         /* useragent, default "PECL::HTTP/version (PHP/version)" */
 438         if (zoption = http_curl_getopt(options, "useragent", IS_STRING)) {
 439                 HTTP_CURL_OPT(USERAGENT, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 440         } else {
 441                 HTTP_CURL_OPT(USERAGENT, "PECL::HTTP/" HTTP_PEXT_VERSION " (PHP/" PHP_VERSION ")");
 442         }
 443
 444         /* additional headers, array('name' => 'value') */
 445         if (zoption = http_curl_getopt(options, "headers", IS_ARRAY)) {
 446                 char *header_key;
 447                 ulong header_idx;
 448                 struct curl_slist *headers = NULL;
 449
 450                 FOREACH_KEY(zoption, header_key, header_idx) {
 451                         if (header_key) {
 452                                 zval **header_val;
 453                                 if (SUCCESS == zend_hash_get_current_data(Z_ARRVAL_P(zoption), (void **) &header_val)) {
 454                                         char header[1024] = {0};
 455                                         snprintf(header, 1023, "%s: %s", header_key, Z_STRVAL_PP(header_val));
 456                                         headers = curl_slist_append(headers, http_request_data_copy(COPY_STRING, header));
 457                                 }
 458
 459                                 /* reset */
 460                                 header_key = NULL;
 461                         }
 462                 }
 463
 464                 if (headers) {
 465                         HTTP_CURL_OPT(HTTPHEADER, http_request_data_copy(COPY_SLIST, headers));
 466                 }
 467         } else {
 468                 HTTP_CURL_OPT(HTTPHEADER, NULL);
 469         }
 470
 471         /* cookies, array('name' => 'value') */
 472         if (zoption = http_curl_getopt(options, "cookies", IS_ARRAY)) {
 473                 char *cookie_key = NULL;
 474                 ulong cookie_idx = 0;
 475                 phpstr *qstr = phpstr_new();
 476
 477                 FOREACH_KEY(zoption, cookie_key, cookie_idx) {
 478                         if (cookie_key) {
 479                                 zval **cookie_val;
 480                                 if (SUCCESS == zend_hash_get_current_data(Z_ARRVAL_P(zoption), (void **) &cookie_val)) {
 481                                         phpstr_appendf(qstr, "%s=%s; ", cookie_key, Z_STRVAL_PP(cookie_val));
 482                                 }
 483
 484                                 /* reset */
 485                                 cookie_key = NULL;
 486                         }
 487                 }
 488
 489                 if (qstr->used) {
 490                         phpstr_fix(qstr);
 491                         HTTP_CURL_OPT(COOKIE, http_request_data_copy(COPY_STRING, qstr->data));
 492                 }
 493                 phpstr_free(qstr);
 494         } else {
 495                 HTTP_CURL_OPT(COOKIE, NULL);
 496         }
 497
 498         /* session cookies */
 499         if (zoption = http_curl_getopt(options, "cookiesession", IS_BOOL)) {
 500                 if (Z_LVAL_P(zoption)) {
 501                         /* accept cookies for this session */
 502                         HTTP_CURL_OPT(COOKIEFILE, "");
 503                 } else {
 504                         /* reset session cookies */
 505                         HTTP_CURL_OPT(COOKIESESSION, 1);
 506                 }
 507         } else {
 508                 HTTP_CURL_OPT(COOKIEFILE, NULL);
 509         }
 510
 511         /* cookiestore, read initial cookies from that file and store cookies back into that file */
 512         if ((zoption = http_curl_getopt(options, "cookiestore", IS_STRING)) && Z_STRLEN_P(zoption)) {
 513                 HTTP_CURL_OPT(COOKIEFILE, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 514                 HTTP_CURL_OPT(COOKIEJAR, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 515         } else {
 516                 HTTP_CURL_OPT(COOKIEFILE, NULL);
 517                 HTTP_CURL_OPT(COOKIEJAR, NULL);
 518         }
 519
 520         /* resume */
 521         if (zoption = http_curl_getopt(options, "resume", IS_LONG)) {
 522                 range_req = 1;
 523                 HTTP_CURL_OPT(RESUME_FROM, Z_LVAL_P(zoption));
 524         } else {
 525                 HTTP_CURL_OPT(RESUME_FROM, 0);
 526         }
 527
 528         /* maxfilesize */
 529         if (zoption = http_curl_getopt(options, "maxfilesize", IS_LONG)) {
 530                 HTTP_CURL_OPT(MAXFILESIZE, Z_LVAL_P(zoption));
 531         } else {
 532                 HTTP_CURL_OPT(MAXFILESIZE, 0);
 533         }
 534
 535         /* lastmodified */
 536         if (zoption = http_curl_getopt(options, "lastmodified", IS_LONG)) {
 537                 HTTP_CURL_OPT(TIMECONDITION, range_req ? CURL_TIMECOND_IFUNMODSINCE : CURL_TIMECOND_IFMODSINCE);
 538                 HTTP_CURL_OPT(TIMEVALUE, Z_LVAL_P(zoption));
 539         } else {
 540                 HTTP_CURL_OPT(TIMEVALUE, 0);
 541         }
 542
 543         /* timeout, defaults to 3 */
 544         if (zoption = http_curl_getopt(options, "timeout", IS_LONG)) {
 545                 HTTP_CURL_OPT(TIMEOUT, Z_LVAL_P(zoption));
 546         } else {
 547                 HTTP_CURL_OPT(TIMEOUT, 3);
 548         }
 549
 550         /* connecttimeout, defaults to 3 */
 551         if (zoption = http_curl_getopt(options, "connecttimeout", IS_LONG)) {
 552                 HTTP_CURL_OPT(CONNECTTIMEOUT, Z_LVAL_P(zoption));
 553         } else {
 554                 HTTP_CURL_OPT(CONNECTTIMEOUT, 3);
 555         }
 556
 557         /* ssl */
 558         if (zoption = http_curl_getopt(options, "ssl", IS_ARRAY)) {
 559                 ulong idx;
 560                 char *key = NULL;
 561                 zval **param;
 562
 563                 FOREACH_KEYVAL(zoption, key, idx, param) {
 564                         if (key) {
 565                                 HTTP_CURL_OPT_SSL_STRING(CERT);
 566 #if LIBCURL_VERSION_NUM >= 0x070903
 567                                 HTTP_CURL_OPT_SSL_STRING(CERTTYPE);
 568 #endif
 569                                 HTTP_CURL_OPT_SSL_STRING(CERTPASSWD);
 570
 571                                 HTTP_CURL_OPT_SSL_STRING(KEY);
 572                                 HTTP_CURL_OPT_SSL_STRING(KEYTYPE);
 573                                 HTTP_CURL_OPT_SSL_STRING(KEYPASSWD);
 574
 575                                 HTTP_CURL_OPT_SSL_STRING(ENGINE);
 576                                 HTTP_CURL_OPT_SSL_LONG(VERSION);
 577
 578                                 HTTP_CURL_OPT_SSL_LONG_(VERIFYPEER);
 579                                 HTTP_CURL_OPT_SSL_LONG_(VERIFYHOST);
 580                                 HTTP_CURL_OPT_SSL_STRING_(CIPHER_LIST);
 581
 582
 583                                 HTTP_CURL_OPT_STRING(CAINFO);
 584 #if LIBCURL_VERSION_NUM >= 0x070908
 585                                 HTTP_CURL_OPT_STRING(CAPATH);
 586 #endif
 587                                 HTTP_CURL_OPT_STRING(RANDOM_FILE);
 588                                 HTTP_CURL_OPT_STRING(EGDSOCKET);
 589
 590                                 /* reset key */
 591                                 key = NULL;
 592                         }
 593                 }
 594         } else {
 595                 /* disable SSL verification by default */
 596                 HTTP_CURL_OPT(SSL_VERIFYPEER, 0);
 597                 HTTP_CURL_OPT(SSL_VERIFYHOST, 0);
 598         }
 599
 600         /* request method */
 601         switch (meth)
 602         {
 603                 case HTTP_GET:
 604                         curl_easy_setopt(ch, CURLOPT_HTTPGET, 1);
 605                 break;
 606
 607                 case HTTP_HEAD:
 608                         curl_easy_setopt(ch, CURLOPT_NOBODY, 1);
 609                 break;
 610
 611                 case HTTP_POST:
 612                         curl_easy_setopt(ch, CURLOPT_POST, 1);
 613                 break;
 614
 615                 case HTTP_PUT:
 616                         curl_easy_setopt(ch, CURLOPT_UPLOAD, 1);
 617                 break;
 618
 619                 default:
 620                         if (http_request_method_exists(0, meth, NULL)) {
 621                                 curl_easy_setopt(ch, CURLOPT_CUSTOMREQUEST, http_request_method_name(meth));
 622                         } else {
 623                                 http_error_ex(E_WARNING, HTTP_E_CURL, "Unsupported request method: %d", meth);
 624                                 return FAILURE;
 625                         }
 626                 break;
 627         }
 628
 629         /* attach request body */
 630         if (body && (meth != HTTP_GET) && (meth != HTTP_HEAD)) {
 631                 switch (body->type)
 632                 {
 633                         case HTTP_REQUEST_BODY_CSTRING:
 634                                 curl_easy_setopt(ch, CURLOPT_POSTFIELDS, body->data);
 635                                 curl_easy_setopt(ch, CURLOPT_POSTFIELDSIZE, body->size);
 636                         break;
 637
 638                         case HTTP_REQUEST_BODY_CURLPOST:
 639                                 curl_easy_setopt(ch, CURLOPT_HTTPPOST, (struct curl_httppost *) body->data);
 640                         break;
 641
 642                         case HTTP_REQUEST_BODY_UPLOADFILE:
 643                                 curl_easy_setopt(ch, CURLOPT_READDATA, http_curl_callback_data(body));
 644                                 curl_easy_setopt(ch, CURLOPT_INFILESIZE, body->size);
 645                         break;
 646
 647                         default:
 648                                 http_error_ex(E_WARNING, HTTP_E_CURL, "Unknown request body type: %d", body->type);
 649                                 return FAILURE;
 650                         break;
 651                 }
 652         }
 653
 654         return SUCCESS;
 655 }
 656 /* }}} */
 657
 658 /* {{{ STATUS http_request_exec(CURL *, HashTable *) */
 659 PHP_HTTP_API STATUS _http_request_exec(CURL *ch, HashTable *info TSRMLS_DC)
 660 {
 661         CURLcode result;
 662
 663         /* perform request */
 664         if (CURLE_OK != (result = curl_easy_perform(ch))) {
 665                 http_error_ex(E_WARNING, HTTP_E_CURL, "Could not perform request: %s", curl_easy_strerror(result));
 666                 return FAILURE;
 667         } else {
 668                 /* get curl info */
 669                 if (info) {
 670                         http_request_info(ch, info);
 671                 }
 672                 return SUCCESS;
 673         }
 674 }
 675 /* }}} */
 676
 677 /* {{{ void http_request_info(CURL *, HashTable *) */
 678 PHP_HTTP_API void _http_request_info(CURL *ch, HashTable *info TSRMLS_DC)
 679 {
 680         zval array;
 681         Z_ARRVAL(array) = info;
 682
 683         HTTP_CURL_INFO(EFFECTIVE_URL);
 684 #if LIBCURL_VERSION_NUM >= 0x070a07
 685         HTTP_CURL_INFO(RESPONSE_CODE);
 686 #else
 687         HTTP_CURL_INFO_EX(HTTP_CODE, RESPONSE_CODE);
 688 #endif
 689         HTTP_CURL_INFO(HTTP_CONNECTCODE);
 690 #if LIBCURL_VERSION_NUM >= 0x070500
 691         HTTP_CURL_INFO(FILETIME);
 692 #endif
 693         HTTP_CURL_INFO(TOTAL_TIME);
 694         HTTP_CURL_INFO(NAMELOOKUP_TIME);
 695         HTTP_CURL_INFO(CONNECT_TIME);
 696         HTTP_CURL_INFO(PRETRANSFER_TIME);
 697         HTTP_CURL_INFO(STARTTRANSFER_TIME);
 698 #if LIBCURL_VERSION_NUM >= 0x070907
 699         HTTP_CURL_INFO(REDIRECT_TIME);
 700         HTTP_CURL_INFO(REDIRECT_COUNT);
 701 #endif
 702         HTTP_CURL_INFO(SIZE_UPLOAD);
 703         HTTP_CURL_INFO(SIZE_DOWNLOAD);
 704         HTTP_CURL_INFO(SPEED_DOWNLOAD);
 705         HTTP_CURL_INFO(SPEED_UPLOAD);
 706         HTTP_CURL_INFO(HEADER_SIZE);
 707         HTTP_CURL_INFO(REQUEST_SIZE);
 708         HTTP_CURL_INFO(SSL_VERIFYRESULT);
 709 #if LIBCURL_VERSION_NUM >= 0x070c03
 710         /*HTTP_CURL_INFO(SSL_ENGINES); todo: CURLINFO_SLIST */
 711 #endif
 712         HTTP_CURL_INFO(CONTENT_LENGTH_DOWNLOAD);
 713         HTTP_CURL_INFO(CONTENT_LENGTH_UPLOAD);
 714         HTTP_CURL_INFO(CONTENT_TYPE);
 715 #if LIBCURL_VERSION_NUM >= 0x070a03
 716         /*HTTP_CURL_INFO(PRIVATE);*/
 717 #endif
 718 #if LIBCURL_VERSION_NUM >= 0x070a08
 719         HTTP_CURL_INFO(HTTPAUTH_AVAIL);
 720         HTTP_CURL_INFO(PROXYAUTH_AVAIL);
 721 #endif
 722 #if LIBCURL_VERSION_NUM >= 0x070c02
 723         /*HTTP_CURL_INFO(OS_ERRNO);*/
 724 #endif
 725 #if LIBCURL_VERSION_NUM >= 0x070c03
 726         HTTP_CURL_INFO(NUM_CONNECTS);
 727 #endif
 728 }
 729 /* }}} */
 730
 731 /* {{{ STATUS http_request_ex(CURL *, http_request_method, char *, http_request_body, HashTable, HashTable, phpstr *) */
 732 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)
 733 {
 734         STATUS status;
 735         zend_bool clean_curl;
 736
 737         if ((clean_curl = (!ch))) {
 738                 if (!(ch = curl_easy_init())) {
 739                         http_error(E_WARNING, HTTP_E_CURL, "Could not initialize curl.");
 740                         return FAILURE;
 741                 }
 742         }
 743
 744         status =        ((SUCCESS == http_request_init(ch, meth, url, body, options, response)) &&
 745                                 (SUCCESS == http_request_exec(ch, info))) ? SUCCESS : FAILURE;
 746
 747         if (clean_curl) {
 748                 curl_easy_cleanup(ch);
 749         }
 750         return status;
 751 }
 752 /* }}} */
 753
 754 /* {{{ char *http_request_method_name(http_request_method) */
 755 PHP_HTTP_API const char *_http_request_method_name(http_request_method m TSRMLS_DC)
 756 {
 757         zval **meth;
 758
 759         if (HTTP_STD_REQUEST_METHOD(m)) {
 760                 return http_request_methods[m];
 761         }
 762
 763         if (SUCCESS == zend_hash_index_find(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(m), (void **) &meth)) {
 764                 return Z_STRVAL_PP(meth);
 765         }
 766
 767         return http_request_methods[0];
 768 }
 769 /* }}} */
 770
 771 /* {{{ unsigned long http_request_method_exists(zend_bool, unsigned long, char *) */
 772 PHP_HTTP_API unsigned long _http_request_method_exists(zend_bool by_name, unsigned long id, const char *name TSRMLS_DC)
 773 {
 774         if (by_name) {
 775                 unsigned i;
 776
 777                 for (i = HTTP_NO_REQUEST_METHOD + 1; i < HTTP_MAX_REQUEST_METHOD; ++i) {
 778                         if (!strcmp(name, http_request_methods[i])) {
 779                                 return i;
 780                         }
 781                 }
 782                 {
 783                         zval **data;
 784                         char *key;
 785                         ulong idx;
 786
 787                         FOREACH_HASH_KEYVAL(&HTTP_G(request).methods.custom, key, idx, data) {
 788                                 if (!strcmp(name, Z_STRVAL_PP(data))) {
 789                                         return idx + HTTP_MAX_REQUEST_METHOD;
 790                                 }
 791                         }
 792                 }
 793                 return 0;
 794         } else {
 795                 return HTTP_STD_REQUEST_METHOD(id) || zend_hash_index_exists(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(id)) ? id : 0;
 796         }
 797 }
 798 /* }}} */
 799
 800 /* {{{ unsigned long http_request_method_register(char *) */
 801 PHP_HTTP_API unsigned long _http_request_method_register(const char *method TSRMLS_DC)
 802 {
 803         zval array;
 804         char *http_method;
 805         unsigned long meth_num = HTTP_G(request).methods.custom.nNextFreeElement + HTTP_MAX_REQUEST_METHOD;
 806
 807         Z_ARRVAL(array) = &HTTP_G(request).methods.custom;
 808         add_next_index_string(&array, estrdup(method), 0);
 809
 810         spprintf(&http_method, 0, "HTTP_%s", method);
 811         zend_register_long_constant(http_method, strlen(http_method) + 1, meth_num, CONST_CS, http_module_number TSRMLS_CC);
 812         efree(http_method);
 813
 814         return meth_num;
 815 }
 816 /* }}} */
 817
 818 /* {{{ STATUS http_request_method_unregister(usngigned long) */
 819 PHP_HTTP_API STATUS _http_request_method_unregister(unsigned long method TSRMLS_DC)
 820 {
 821         zval **zmethod;
 822         char *http_method;
 823
 824         if (SUCCESS != zend_hash_index_find(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(method), (void **) &zmethod)) {
 825                 http_error_ex(E_NOTICE, HTTP_E_PARAM, "Request method with id %lu does not exist", method);
 826                 return FAILURE;
 827         }
 828
 829         spprintf(&http_method, 0, "HTTP_%s", Z_STRVAL_PP(zmethod));
 830
 831         if (    (SUCCESS != zend_hash_index_del(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(method)))
 832                 ||      (SUCCESS != zend_hash_del(EG(zend_constants), http_method, strlen(http_method) + 1))) {
 833                 http_error_ex(E_NOTICE, 0, "Could not unregister request method: %s", http_method);
 834                 efree(http_method);
 835                 return FAILURE;
 836         }
 837
 838         efree(http_method);
 839         return SUCCESS;
 840 }
 841 /* }}} */
 842
 843
 844 /* {{{ char *http_request_methods[] */
 845 static const char *const http_request_methods[] = {
 846         "UNKOWN",
 847         /* HTTP/1.1 */
 848         "GET",
 849         "HEAD",
 850         "POST",
 851         "PUT",
 852         "DELETE",
 853         "OPTIONS",
 854         "TRACE",
 855         "CONNECT",
 856         /* WebDAV - RFC 2518 */
 857         "PROPFIND",
 858         "PROPPATCH",
 859         "MKCOL",
 860         "COPY",
 861         "MOVE",
 862         "LOCK",
 863         "UNLOCK",
 864         /* WebDAV Versioning - RFC 3253 */
 865         "VERSION-CONTROL",
 866         "REPORT",
 867         "CHECKOUT",
 868         "CHECKIN",
 869         "UNCHECKOUT",
 870         "MKWORKSPACE",
 871         "UPDATE",
 872         "LABEL",
 873         "MERGE",
 874         "BASELINE-CONTROL",
 875         "MKACTIVITY",
 876         /* WebDAV Access Control - RFC 3744 */
 877         "ACL",
 878         NULL
 879 };
 880 /* }}} */
 881
 882 /* {{{ static size_t http_curl_write_callback(char *, size_t, size_t, void *) */
 883 static size_t http_curl_write_callback(char *buf, size_t len, size_t n, void *s)
 884 {
 885         HTTP_CURL_CALLBACK_DATA(s, phpstr *, str);
 886         return str ? phpstr_append(PHPSTR(str), buf, len * n) : len * n;
 887 }
 888 /* }}} */
 889
 890 /* {{{ static size_t http_curl_read_callback(void *, size_t, size_t, void *) */
 891 static size_t http_curl_read_callback(void *data, size_t len, size_t n, void *s)
 892 {
 893         HTTP_CURL_CALLBACK_DATA(s, http_request_body *, body);
 894
 895         if (body->type != HTTP_REQUEST_BODY_UPLOADFILE) {
 896                 return 0;
 897         }
 898         return php_stream_read((php_stream *) body->data, data, len * n);
 899 }
 900 /* }}} */
 901
 902 /* {{{ http_curl_callback_ctx http_curl_callback_data(void *) */
 903 static http_curl_callback_ctx *_http_curl_callback_data(void *data TSRMLS_DC)
 904 {
 905         http_curl_callback_ctx *ctx = emalloc(sizeof(http_curl_callback_ctx));
 906         TSRMLS_SET_CTX(ctx->tsrm_ctx);
 907         ctx->data = data;
 908         return http_request_data_copy(COPY_CONTEXT, ctx);
 909 }
 910 /* }}} */
 911
 912 /* {{{ static int http_curl_progress_callback(void *, double, double, double, double) */
 913 static int http_curl_progress_callback(void *data, double dltotal, double dlnow, double ultotal, double ulnow)
 914 {
 915         zval *params_pass[4], params_local[4], retval;
 916         HTTP_CURL_CALLBACK_DATA(data, zval *, func);
 917
 918         params_pass[0] = &params_local[0];
 919         params_pass[1] = &params_local[1];
 920         params_pass[2] = &params_local[2];
 921         params_pass[3] = &params_local[3];
 922
 923         ZVAL_DOUBLE(params_pass[0], dltotal);
 924         ZVAL_DOUBLE(params_pass[1], dlnow);
 925         ZVAL_DOUBLE(params_pass[2], ultotal);
 926         ZVAL_DOUBLE(params_pass[3], ulnow);
 927
 928         return call_user_function(EG(function_table), NULL, func, &retval, 4, params_pass TSRMLS_CC);
 929 }
 930 /* }}} */
 931
 932 static int http_curl_debug_callback(CURL *ch, curl_infotype type, char *string, size_t length, void *data)
 933 {
 934         zval *params_pass[2], params_local[2], retval;
 935         HTTP_CURL_CALLBACK_DATA(data, zval *, func);
 936
 937         params_pass[0] = &params_local[0];
 938         params_pass[1] = &params_local[1];
 939
 940         ZVAL_LONG(params_pass[0], type);
 941         ZVAL_STRINGL(params_pass[1], string, length, 1);
 942
 943         call_user_function(EG(function_table), NULL, func, &retval, 2, params_pass TSRMLS_CC);
 944
 945         return 0;
 946 }
 947 /* {{{ static inline zval *http_curl_getopt(HashTable *, char *, size_t, int) */
 948 static inline zval *_http_curl_getopt_ex(HashTable *options, char *key, size_t keylen, int type TSRMLS_DC)
 949 {
 950         zval **zoption;
 951
 952         if (!options || (SUCCESS != zend_hash_find(options, key, keylen, (void **) &zoption))) {
 953                 return NULL;
 954         }
 955
 956         if (Z_TYPE_PP(zoption) != type) {
 957                 switch (type)
 958                 {
 959                         case IS_BOOL:   convert_to_boolean_ex(zoption); break;
 960                         case IS_LONG:   convert_to_long_ex(zoption);    break;
 961                         case IS_DOUBLE: convert_to_double_ex(zoption);  break;
 962                         case IS_STRING: convert_to_string_ex(zoption);  break;
 963                         case IS_ARRAY:  convert_to_array_ex(zoption);   break;
 964                         case IS_OBJECT: convert_to_object_ex(zoption);  break;
 965                         default:
 966                         break;
 967                 }
 968         }
 969
 970         return *zoption;
 971 }
 972 /* }}} */
 973
 974 /*
 975  * Local variables:
 976  * tab-width: 4
 977  * c-basic-offset: 4
 978  * End:
 979  * vim600: noet sw=4 ts=4 fdm=marker
 980  * vim<600: noet sw=4 ts=4
 981  */
 982