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((const char*) 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, const 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, (void *) url));
 334         }
 335
 336         if (response) {
 337                 HTTP_CURL_OPT(WRITEDATA, http_curl_callback_data(response));
 338                 HTTP_CURL_OPT(WRITEHEADER, http_curl_callback_data(response));
 339         }
 340
 341         HTTP_CURL_OPT(HEADER, 0);
 342         HTTP_CURL_OPT(FILETIME, 1);
 343         HTTP_CURL_OPT(AUTOREFERER, 1);
 344         HTTP_CURL_OPT(READFUNCTION, http_curl_read_callback);
 345         HTTP_CURL_OPT(WRITEFUNCTION, http_curl_write_callback);
 346         HTTP_CURL_OPT(HEADERFUNCTION, http_curl_write_callback);
 347
 348 #if defined(ZTS) && (LIBCURL_VERSION_NUM >= 0x070a00)
 349         HTTP_CURL_OPT(NOSIGNAL, 1);
 350 #endif
 351 #if LIBCURL_VERSION_NUM < 0x070c00
 352         HTTP_CURL_OPT(ERRORBUFFER, HTTP_G(request).error);
 353 #endif
 354
 355         /* progress callback */
 356         if (zoption = http_curl_getopt(options, "onprogress", 0)) {
 357                 HTTP_CURL_OPT(PROGRESSFUNCTION, http_curl_progress_callback);
 358                 HTTP_CURL_OPT(PROGRESSDATA,  http_curl_callback_data(zoption));
 359         } else {
 360                 HTTP_CURL_OPT(NOPROGRESS, 1);
 361         }
 362
 363         /* debug callback */
 364         if (zoption = http_curl_getopt(options, "ondebug", 0)) {
 365                 HTTP_CURL_OPT(VERBOSE, 1);
 366                 HTTP_CURL_OPT(DEBUGFUNCTION, http_curl_debug_callback);
 367                 HTTP_CURL_OPT(DEBUGDATA, http_curl_callback_data(zoption));
 368         } else {
 369                 HTTP_CURL_OPT(VERBOSE, 0);
 370         }
 371
 372         /* proxy */
 373         if (zoption = http_curl_getopt(options, "proxyhost", IS_STRING)) {
 374                 HTTP_CURL_OPT(PROXY, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 375                 /* port */
 376                 if (zoption = http_curl_getopt(options, "proxyport", IS_LONG)) {
 377                         HTTP_CURL_OPT(PROXYPORT, Z_LVAL_P(zoption));
 378                 }
 379                 /* user:pass */
 380                 if (zoption = http_curl_getopt(options, "proxyauth", IS_STRING)) {
 381                         HTTP_CURL_OPT(PROXYUSERPWD, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 382                 }
 383 #if LIBCURL_VERSION_NUM >= 0x070a07
 384                 /* auth method */
 385                 if (zoption = http_curl_getopt(options, "proxyauthtype", IS_LONG)) {
 386                         HTTP_CURL_OPT(PROXYAUTH, Z_LVAL_P(zoption));
 387                 }
 388 #endif
 389         }
 390
 391         /* outgoing interface */
 392         if (zoption = http_curl_getopt(options, "interface", IS_STRING)) {
 393                 HTTP_CURL_OPT(INTERFACE, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 394         }
 395
 396         /* another port */
 397         if (zoption = http_curl_getopt(options, "port", IS_LONG)) {
 398                 HTTP_CURL_OPT(PORT, Z_LVAL_P(zoption));
 399         }
 400
 401         /* auth */
 402         if (zoption = http_curl_getopt(options, "httpauth", IS_STRING)) {
 403                 HTTP_CURL_OPT(USERPWD, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 404         }
 405 #if LIBCURL_VERSION_NUM >= 0x070a06
 406         if (zoption = http_curl_getopt(options, "httpauthtype", IS_LONG)) {
 407                 HTTP_CURL_OPT(HTTPAUTH, Z_LVAL_P(zoption));
 408         }
 409 #endif
 410
 411         /* compress, empty string enables deflate and gzip */
 412         if (zoption = http_curl_getopt(options, "compress", IS_BOOL)) {
 413                 if (Z_LVAL_P(zoption)) {
 414                         HTTP_CURL_OPT(ENCODING, http_request_data_copy(COPY_STRING, ""));
 415                 }
 416         }
 417
 418         /* redirects, defaults to 0 */
 419         if (zoption = http_curl_getopt(options, "redirect", IS_LONG)) {
 420                 HTTP_CURL_OPT(FOLLOWLOCATION, Z_LVAL_P(zoption) ? 1 : 0);
 421                 HTTP_CURL_OPT(MAXREDIRS, Z_LVAL_P(zoption));
 422                 if (zoption = http_curl_getopt(options, "unrestrictedauth", IS_BOOL)) {
 423                         HTTP_CURL_OPT(UNRESTRICTED_AUTH, Z_LVAL_P(zoption));
 424                 }
 425         } else {
 426                 HTTP_CURL_OPT(FOLLOWLOCATION, 0);
 427         }
 428
 429         /* referer */
 430         if (zoption = http_curl_getopt(options, "referer", IS_STRING)) {
 431                 HTTP_CURL_OPT(REFERER, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 432         }
 433
 434         /* useragent, default "PECL::HTTP/version (PHP/version)" */
 435         if (zoption = http_curl_getopt(options, "useragent", IS_STRING)) {
 436                 HTTP_CURL_OPT(USERAGENT, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 437         } else {
 438                 HTTP_CURL_OPT(USERAGENT, http_request_data_copy(COPY_STRING, "PECL::HTTP/" HTTP_PEXT_VERSION " (PHP/" PHP_VERSION ")"));
 439         }
 440
 441         /* additional headers, array('name' => 'value') */
 442         if (zoption = http_curl_getopt(options, "headers", IS_ARRAY)) {
 443                 char *header_key;
 444                 ulong header_idx;
 445                 struct curl_slist *headers = NULL;
 446
 447                 FOREACH_KEY(zoption, header_key, header_idx) {
 448                         if (header_key) {
 449                                 zval **header_val;
 450                                 if (SUCCESS == zend_hash_get_current_data(Z_ARRVAL_P(zoption), (void **) &header_val)) {
 451                                         char header[1024] = {0};
 452                                         snprintf(header, 1023, "%s: %s", header_key, Z_STRVAL_PP(header_val));
 453                                         headers = curl_slist_append(headers, http_request_data_copy(COPY_STRING, header));
 454                                 }
 455
 456                                 /* reset */
 457                                 header_key = NULL;
 458                         }
 459                 }
 460
 461                 if (headers) {
 462                         HTTP_CURL_OPT(HTTPHEADER, http_request_data_copy(COPY_SLIST, headers));
 463                 }
 464         } else {
 465                 HTTP_CURL_OPT(HTTPHEADER, NULL);
 466         }
 467
 468         /* cookies, array('name' => 'value') */
 469         if (zoption = http_curl_getopt(options, "cookies", IS_ARRAY)) {
 470                 char *cookie_key = NULL;
 471                 ulong cookie_idx = 0;
 472                 phpstr *qstr = phpstr_new();
 473
 474                 FOREACH_KEY(zoption, cookie_key, cookie_idx) {
 475                         if (cookie_key) {
 476                                 zval **cookie_val;
 477                                 if (SUCCESS == zend_hash_get_current_data(Z_ARRVAL_P(zoption), (void **) &cookie_val)) {
 478                                         phpstr_appendf(qstr, "%s=%s; ", cookie_key, Z_STRVAL_PP(cookie_val));
 479                                 }
 480
 481                                 /* reset */
 482                                 cookie_key = NULL;
 483                         }
 484                 }
 485
 486                 if (qstr->used) {
 487                         phpstr_fix(qstr);
 488                         HTTP_CURL_OPT(COOKIE, http_request_data_copy(COPY_STRING, qstr->data));
 489                 }
 490                 phpstr_free(qstr);
 491         }
 492
 493         /* cookiestore */
 494         if (zoption = http_curl_getopt(options, "cookiestore", IS_STRING)) {
 495                 HTTP_CURL_OPT(COOKIEFILE, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 496                 HTTP_CURL_OPT(COOKIEJAR, http_request_data_copy(COPY_STRING, Z_STRVAL_P(zoption)));
 497         }
 498
 499         /* resume */
 500         if (zoption = http_curl_getopt(options, "resume", IS_LONG)) {
 501                 range_req = 1;
 502                 HTTP_CURL_OPT(RESUME_FROM, Z_LVAL_P(zoption));
 503         }
 504
 505         /* maxfilesize */
 506         if (zoption = http_curl_getopt(options, "maxfilesize", IS_LONG)) {
 507                 HTTP_CURL_OPT(MAXFILESIZE, Z_LVAL_P(zoption));
 508         }
 509
 510         /* lastmodified */
 511         if (zoption = http_curl_getopt(options, "lastmodified", IS_LONG)) {
 512                 HTTP_CURL_OPT(TIMECONDITION, range_req ? CURL_TIMECOND_IFUNMODSINCE : CURL_TIMECOND_IFMODSINCE);
 513                 HTTP_CURL_OPT(TIMEVALUE, Z_LVAL_P(zoption));
 514         }
 515
 516         /* timeout */
 517         if (zoption = http_curl_getopt(options, "timeout", IS_LONG)) {
 518                 HTTP_CURL_OPT(TIMEOUT, Z_LVAL_P(zoption));
 519         }
 520
 521         /* connecttimeout, defaults to 1 */
 522         if (zoption = http_curl_getopt(options, "connecttimeout", IS_LONG)) {
 523                 HTTP_CURL_OPT(CONNECTTIMEOUT, Z_LVAL_P(zoption));
 524         } else {
 525                 HTTP_CURL_OPT(CONNECTTIMEOUT, 1);
 526         }
 527
 528         /* ssl */
 529         if (zoption = http_curl_getopt(options, "ssl", IS_ARRAY)) {
 530                 ulong idx;
 531                 char *key = NULL;
 532                 zval **param;
 533
 534                 FOREACH_KEYVAL(zoption, key, idx, param) {
 535                         if (key) {
 536                                 HTTP_CURL_OPT_SSL_STRING(CERT);
 537 #if LIBCURL_VERSION_NUM >= 0x070903
 538                                 HTTP_CURL_OPT_SSL_STRING(CERTTYPE);
 539 #endif
 540                                 HTTP_CURL_OPT_SSL_STRING(CERTPASSWD);
 541
 542                                 HTTP_CURL_OPT_SSL_STRING(KEY);
 543                                 HTTP_CURL_OPT_SSL_STRING(KEYTYPE);
 544                                 HTTP_CURL_OPT_SSL_STRING(KEYPASSWD);
 545
 546                                 HTTP_CURL_OPT_SSL_STRING(ENGINE);
 547                                 HTTP_CURL_OPT_SSL_LONG(VERSION);
 548
 549                                 HTTP_CURL_OPT_SSL_LONG_(VERIFYPEER);
 550                                 HTTP_CURL_OPT_SSL_LONG_(VERIFYHOST);
 551                                 HTTP_CURL_OPT_SSL_STRING_(CIPHER_LIST);
 552
 553
 554                                 HTTP_CURL_OPT_STRING(CAINFO);
 555 #if LIBCURL_VERSION_NUM >= 0x070908
 556                                 HTTP_CURL_OPT_STRING(CAPATH);
 557 #endif
 558                                 HTTP_CURL_OPT_STRING(RANDOM_FILE);
 559                                 HTTP_CURL_OPT_STRING(EGDSOCKET);
 560
 561                                 /* reset key */
 562                                 key = NULL;
 563                         }
 564                 }
 565         } else {
 566                 /* disable SSL verification by default */
 567                 HTTP_CURL_OPT(SSL_VERIFYPEER, 0);
 568                 HTTP_CURL_OPT(SSL_VERIFYHOST, 0);
 569         }
 570
 571         /* request method */
 572         switch (meth)
 573         {
 574                 case HTTP_GET:
 575                         curl_easy_setopt(ch, CURLOPT_HTTPGET, 1);
 576                 break;
 577
 578                 case HTTP_HEAD:
 579                         curl_easy_setopt(ch, CURLOPT_NOBODY, 1);
 580                 break;
 581
 582                 case HTTP_POST:
 583                         curl_easy_setopt(ch, CURLOPT_POST, 1);
 584                 break;
 585
 586                 case HTTP_PUT:
 587                         curl_easy_setopt(ch, CURLOPT_UPLOAD, 1);
 588                 break;
 589
 590                 default:
 591                         if (http_request_method_exists(0, meth, NULL)) {
 592                                 curl_easy_setopt(ch, CURLOPT_CUSTOMREQUEST, http_request_method_name(meth));
 593                         } else {
 594                                 http_error_ex(E_WARNING, HTTP_E_CURL, "Unsupported request method: %d", meth);
 595                                 return FAILURE;
 596                         }
 597                 break;
 598         }
 599
 600         /* attach request body */
 601         if (body && (meth != HTTP_GET) && (meth != HTTP_HEAD)) {
 602                 switch (body->type)
 603                 {
 604                         case HTTP_REQUEST_BODY_CSTRING:
 605                                 curl_easy_setopt(ch, CURLOPT_POSTFIELDS, body->data);
 606                                 curl_easy_setopt(ch, CURLOPT_POSTFIELDSIZE, body->size);
 607                         break;
 608
 609                         case HTTP_REQUEST_BODY_CURLPOST:
 610                                 curl_easy_setopt(ch, CURLOPT_HTTPPOST, (struct curl_httppost *) body->data);
 611                         break;
 612
 613                         case HTTP_REQUEST_BODY_UPLOADFILE:
 614                                 curl_easy_setopt(ch, CURLOPT_READDATA, http_curl_callback_data(body));
 615                                 curl_easy_setopt(ch, CURLOPT_INFILESIZE, body->size);
 616                         break;
 617
 618                         default:
 619                                 http_error_ex(E_WARNING, HTTP_E_CURL, "Unknown request body type: %d", body->type);
 620                                 return FAILURE;
 621                         break;
 622                 }
 623         }
 624
 625         return SUCCESS;
 626 }
 627 /* }}} */
 628
 629 /* {{{ STATUS http_request_exec(CURL *, HashTable *) */
 630 PHP_HTTP_API STATUS _http_request_exec(CURL *ch, HashTable *info TSRMLS_DC)
 631 {
 632         CURLcode result;
 633
 634         /* perform request */
 635         if (CURLE_OK != (result = curl_easy_perform(ch))) {
 636                 http_error_ex(E_WARNING, HTTP_E_CURL, "Could not perform request: %s", curl_easy_strerror(result));
 637                 return FAILURE;
 638         } else {
 639                 /* get curl info */
 640                 if (info) {
 641                         http_request_info(ch, info);
 642                 }
 643                 return SUCCESS;
 644         }
 645 }
 646 /* }}} */
 647
 648 /* {{{ void http_request_info(CURL *, HashTable *) */
 649 PHP_HTTP_API void _http_request_info(CURL *ch, HashTable *info TSRMLS_DC)
 650 {
 651         zval array;
 652         Z_ARRVAL(array) = info;
 653
 654         HTTP_CURL_INFO(EFFECTIVE_URL);
 655 #if LIBCURL_VERSION_NUM >= 0x070a07
 656         HTTP_CURL_INFO(RESPONSE_CODE);
 657 #else
 658         HTTP_CURL_INFO_EX(HTTP_CODE, RESPONSE_CODE);
 659 #endif
 660         HTTP_CURL_INFO(HTTP_CONNECTCODE);
 661 #if LIBCURL_VERSION_NUM >= 0x070500
 662         HTTP_CURL_INFO(FILETIME);
 663 #endif
 664         HTTP_CURL_INFO(TOTAL_TIME);
 665         HTTP_CURL_INFO(NAMELOOKUP_TIME);
 666         HTTP_CURL_INFO(CONNECT_TIME);
 667         HTTP_CURL_INFO(PRETRANSFER_TIME);
 668         HTTP_CURL_INFO(STARTTRANSFER_TIME);
 669 #if LIBCURL_VERSION_NUM >= 0x070907
 670         HTTP_CURL_INFO(REDIRECT_TIME);
 671         HTTP_CURL_INFO(REDIRECT_COUNT);
 672 #endif
 673         HTTP_CURL_INFO(SIZE_UPLOAD);
 674         HTTP_CURL_INFO(SIZE_DOWNLOAD);
 675         HTTP_CURL_INFO(SPEED_DOWNLOAD);
 676         HTTP_CURL_INFO(SPEED_UPLOAD);
 677         HTTP_CURL_INFO(HEADER_SIZE);
 678         HTTP_CURL_INFO(REQUEST_SIZE);
 679         HTTP_CURL_INFO(SSL_VERIFYRESULT);
 680 #if LIBCURL_VERSION_NUM >= 0x070c03
 681         /*HTTP_CURL_INFO(SSL_ENGINES); todo: CURLINFO_SLIST */
 682 #endif
 683         HTTP_CURL_INFO(CONTENT_LENGTH_DOWNLOAD);
 684         HTTP_CURL_INFO(CONTENT_LENGTH_UPLOAD);
 685         HTTP_CURL_INFO(CONTENT_TYPE);
 686 #if LIBCURL_VERSION_NUM >= 0x070a03
 687         /*HTTP_CURL_INFO(PRIVATE);*/
 688 #endif
 689 #if LIBCURL_VERSION_NUM >= 0x070a08
 690         HTTP_CURL_INFO(HTTPAUTH_AVAIL);
 691         HTTP_CURL_INFO(PROXYAUTH_AVAIL);
 692 #endif
 693 #if LIBCURL_VERSION_NUM >= 0x070c02
 694         /*HTTP_CURL_INFO(OS_ERRNO);*/
 695 #endif
 696 #if LIBCURL_VERSION_NUM >= 0x070c03
 697         HTTP_CURL_INFO(NUM_CONNECTS);
 698 #endif
 699 }
 700 /* }}} */
 701
 702 /* {{{ STATUS http_request_ex(CURL *, http_request_method, char *, http_request_body, HashTable, HashTable, phpstr *) */
 703 PHP_HTTP_API STATUS _http_request_ex(CURL *ch, http_request_method meth, const char *url, http_request_body *body, HashTable *options, HashTable *info, phpstr *response TSRMLS_DC)
 704 {
 705         STATUS status;
 706         zend_bool clean_curl;
 707
 708         if ((clean_curl = (!ch))) {
 709                 if (!(ch = curl_easy_init())) {
 710                         http_error(E_WARNING, HTTP_E_CURL, "Could not initialize curl.");
 711                         return FAILURE;
 712                 }
 713         }
 714
 715         status =        ((SUCCESS == http_request_init(ch, meth, url, body, options, response)) &&
 716                                 (SUCCESS == http_request_exec(ch, info))) ? SUCCESS : FAILURE;
 717
 718         if (clean_curl) {
 719                 curl_easy_cleanup(ch);
 720         }
 721         return status;
 722 }
 723 /* }}} */
 724
 725 /* {{{ char *http_request_method_name(http_request_method) */
 726 PHP_HTTP_API const char *_http_request_method_name(http_request_method m TSRMLS_DC)
 727 {
 728         zval **meth;
 729
 730         if (HTTP_STD_REQUEST_METHOD(m)) {
 731                 return http_request_methods[m];
 732         }
 733
 734         if (SUCCESS == zend_hash_index_find(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(m), (void **) &meth)) {
 735                 return Z_STRVAL_PP(meth);
 736         }
 737
 738         return http_request_methods[0];
 739 }
 740 /* }}} */
 741
 742 /* {{{ unsigned long http_request_method_exists(zend_bool, unsigned long, char *) */
 743 PHP_HTTP_API unsigned long _http_request_method_exists(zend_bool by_name, unsigned long id, const char *name TSRMLS_DC)
 744 {
 745         if (by_name) {
 746                 unsigned i;
 747
 748                 for (i = HTTP_NO_REQUEST_METHOD + 1; i < HTTP_MAX_REQUEST_METHOD; ++i) {
 749                         if (!strcmp(name, http_request_methods[i])) {
 750                                 return i;
 751                         }
 752                 }
 753                 {
 754                         zval **data;
 755                         char *key;
 756                         ulong idx;
 757
 758                         FOREACH_HASH_KEYVAL(&HTTP_G(request).methods.custom, key, idx, data) {
 759                                 if (!strcmp(name, Z_STRVAL_PP(data))) {
 760                                         return idx + HTTP_MAX_REQUEST_METHOD;
 761                                 }
 762                         }
 763                 }
 764                 return 0;
 765         } else {
 766                 return HTTP_STD_REQUEST_METHOD(id) || zend_hash_index_exists(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(id)) ? id : 0;
 767         }
 768 }
 769 /* }}} */
 770
 771 /* {{{ unsigned long http_request_method_register(char *) */
 772 PHP_HTTP_API unsigned long _http_request_method_register(const char *method TSRMLS_DC)
 773 {
 774         zval array;
 775         char *http_method;
 776         unsigned long meth_num = HTTP_G(request).methods.custom.nNextFreeElement + HTTP_MAX_REQUEST_METHOD;
 777
 778         Z_ARRVAL(array) = &HTTP_G(request).methods.custom;
 779         add_next_index_string(&array, estrdup(method), 0);
 780
 781         spprintf(&http_method, 0, "HTTP_%s", method);
 782         zend_register_long_constant(http_method, strlen(http_method) + 1, meth_num, CONST_CS, http_module_number TSRMLS_CC);
 783         efree(http_method);
 784
 785         return meth_num;
 786 }
 787 /* }}} */
 788
 789 /* {{{ STATUS http_request_method_unregister(usngigned long) */
 790 PHP_HTTP_API STATUS _http_request_method_unregister(unsigned long method TSRMLS_DC)
 791 {
 792         zval **zmethod;
 793         char *http_method;
 794
 795         if (SUCCESS != zend_hash_index_find(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(method), (void **) &zmethod)) {
 796                 http_error_ex(E_NOTICE, HTTP_E_PARAM, "Request method with id %lu does not exist", method);
 797                 return FAILURE;
 798         }
 799
 800         spprintf(&http_method, 0, "HTTP_%s", Z_STRVAL_PP(zmethod));
 801
 802         if (    (SUCCESS != zend_hash_index_del(&HTTP_G(request).methods.custom, HTTP_CUSTOM_REQUEST_METHOD(method)))
 803                 ||      (SUCCESS != zend_hash_del(EG(zend_constants), http_method, strlen(http_method) + 1))) {
 804                 http_error_ex(E_NOTICE, 0, "Could not unregister request method: %s", http_method);
 805                 efree(http_method);
 806                 return FAILURE;
 807         }
 808
 809         efree(http_method);
 810         return SUCCESS;
 811 }
 812 /* }}} */
 813
 814
 815 /* {{{ char *http_request_methods[] */
 816 static const char *const http_request_methods[] = {
 817         "UNKOWN",
 818         /* HTTP/1.1 */
 819         "GET",
 820         "HEAD",
 821         "POST",
 822         "PUT",
 823         "DELETE",
 824         "OPTIONS",
 825         "TRACE",
 826         "CONNECT",
 827         /* WebDAV - RFC 2518 */
 828         "PROPFIND",
 829         "PROPPATCH",
 830         "MKCOL",
 831         "COPY",
 832         "MOVE",
 833         "LOCK",
 834         "UNLOCK",
 835         /* WebDAV Versioning - RFC 3253 */
 836         "VERSION-CONTROL",
 837         "REPORT",
 838         "CHECKOUT",
 839         "CHECKIN",
 840         "UNCHECKOUT",
 841         "MKWORKSPACE",
 842         "UPDATE",
 843         "LABEL",
 844         "MERGE",
 845         "BASELINE-CONTROL",
 846         "MKACTIVITY",
 847         /* WebDAV Access Control - RFC 3744 */
 848         "ACL",
 849         NULL
 850 };
 851 /* }}} */
 852
 853 /* {{{ static size_t http_curl_write_callback(char *, size_t, size_t, void *) */
 854 static size_t http_curl_write_callback(char *buf, size_t len, size_t n, void *s)
 855 {
 856         HTTP_CURL_CALLBACK_DATA(s, phpstr *, str);
 857         return str ? phpstr_append(PHPSTR(str), buf, len * n) : len * n;
 858 }
 859 /* }}} */
 860
 861 /* {{{ static size_t http_curl_read_callback(void *, size_t, size_t, void *) */
 862 static size_t http_curl_read_callback(void *data, size_t len, size_t n, void *s)
 863 {
 864         static char *offset = NULL, *original = NULL;
 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