-/*
- +--------------------------------------------------------------------+
- | PECL :: http |
- +--------------------------------------------------------------------+
- | Redistribution and use in source and binary forms, with or without |
- | modification, are permitted provided that the conditions mentioned |
- | in the accompanying LICENSE file are met. |
- +--------------------------------------------------------------------+
- | Copyright (c) 2004-2014, Michael Wallner <mike@php.net> |
- +--------------------------------------------------------------------+
-*/
-
-#include "php_http_api.h"
-#include "php_http_client.h"
-
-#if PHP_HTTP_HAVE_CURL
-
-#if PHP_HTTP_HAVE_EVENT
-# if !PHP_HTTP_HAVE_EVENT2 && /* just be really sure */ !(LIBEVENT_VERSION_NUMBER >= 0x02000000)
-# include <event.h>
-# define event_base_new event_init
-# define event_assign(e, b, s, a, cb, d) do {\
- event_set(e, s, a, cb, d); \
- event_base_set(b, e); \
- } while(0)
-# else
-# if PHP_HTTP_HAVE_EVENT2
-# include <event2/event.h>
-# include <event2/event_struct.h>
-# else
-# error "libevent presence is unknown"
-# endif
-# endif
-# ifndef DBG_EVENTS
-# define DBG_EVENTS 0
-# endif
-#endif
-
-#ifdef PHP_HTTP_HAVE_OPENSSL
-# include <openssl/ssl.h>
-#endif
-#ifdef PHP_HTTP_HAVE_GNUTLS
-# include <gnutls.h>
-#endif
-
-typedef struct php_http_client_curl {
- CURLM *handle;
-
- int unfinished; /* int because of curl_multi_perform() */
-
-#if PHP_HTTP_HAVE_EVENT
- struct event_base *evbase;
- struct event *timeout;
- unsigned useevents:1;
-#endif
-} php_http_client_curl_t;
-
-typedef struct php_http_client_curl_handler {
- CURL *handle;
- php_resource_factory_t *rf;
- php_http_client_t *client;
- php_http_client_progress_state_t progress;
- php_http_client_enqueue_t queue;
-
- struct {
- php_http_buffer_t headers;
- php_http_message_body_t *body;
- } response;
-
- struct {
- HashTable cache;
-
- struct curl_slist *proxyheaders;
- struct curl_slist *headers;
- struct curl_slist *resolve;
- php_http_buffer_t cookies;
- php_http_buffer_t ranges;
-
- long redirects;
- unsigned range_request:1;
- unsigned encode_cookies:1;
-
- struct {
- uint count;
- double delay;
- } retry;
-
- } options;
-
-} php_http_client_curl_handler_t;
-
-typedef struct php_http_curle_storage {
- char *url;
- char *cookiestore;
- CURLcode errorcode;
- char errorbuffer[0x100];
-} php_http_curle_storage_t;
-
-static inline php_http_curle_storage_t *php_http_curle_get_storage(CURL *ch) {
- php_http_curle_storage_t *st = NULL;
-
- curl_easy_getinfo(ch, CURLINFO_PRIVATE, &st);
-
- if (!st) {
- st = pecalloc(1, sizeof(*st), 1);
- curl_easy_setopt(ch, CURLOPT_PRIVATE, st);
- curl_easy_setopt(ch, CURLOPT_ERRORBUFFER, st->errorbuffer);
- }
-
- return st;
-}
-
-static void *php_http_curle_ctor(void *opaque, void *init_arg TSRMLS_DC)
-{
- void *ch;
-
- if ((ch = curl_easy_init())) {
- php_http_curle_get_storage(ch);
- return ch;
- }
- return NULL;
-}
-
-static void *php_http_curle_copy(void *opaque, void *handle TSRMLS_DC)
-{
- void *ch;
-
- if ((ch = curl_easy_duphandle(handle))) {
- curl_easy_reset(ch);
- php_http_curle_get_storage(ch);
- return ch;
- }
- return NULL;
-}
-
-static void php_http_curle_dtor(void *opaque, void *handle TSRMLS_DC)
-{
- php_http_curle_storage_t *st = php_http_curle_get_storage(handle);
-
- curl_easy_cleanup(handle);
-
- if (st) {
- if (st->url) {
- pefree(st->url, 1);
- }
- if (st->cookiestore) {
- pefree(st->cookiestore, 1);
- }
- pefree(st, 1);
- }
-}
-
-static php_resource_factory_ops_t php_http_curle_resource_factory_ops = {
- php_http_curle_ctor,
- php_http_curle_copy,
- php_http_curle_dtor
-};
-
-static void *php_http_curlm_ctor(void *opaque, void *init_arg TSRMLS_DC)
-{
- return curl_multi_init();
-}
-
-static void php_http_curlm_dtor(void *opaque, void *handle TSRMLS_DC)
-{
- curl_multi_cleanup(handle);
-}
-
-static php_resource_factory_ops_t php_http_curlm_resource_factory_ops = {
- php_http_curlm_ctor,
- NULL,
- php_http_curlm_dtor
-};
-
-/* curl callbacks */
-
-static size_t php_http_curle_read_callback(void *data, size_t len, size_t n, void *ctx)
-{
- php_http_message_body_t *body = ctx;
-
- if (body && body->stream_id) {
- php_stream *s = php_http_message_body_stream(body);
-
- if (s) {
- TSRMLS_FETCH_FROM_CTX(body->ts);
- return php_stream_read(s, data, len * n);
- } else abort();
- }
- return 0;
-}
-
-#if PHP_HTTP_CURL_VERSION(7,32,0)
-static int php_http_curle_xferinfo_callback(void *ctx, curl_off_t dltotal, curl_off_t dlnow, curl_off_t ultotal, curl_off_t ulnow)
-#else
-static int php_http_curle_progress_callback(void *ctx, double dltotal, double dlnow, double ultotal, double ulnow)
-#endif
-{
- php_http_client_curl_handler_t *h = ctx;
- zend_bool update = 0;
-
- if (h->progress.dl.total != dltotal
- || h->progress.dl.now != dlnow
- || h->progress.ul.total != ultotal
- || h->progress.ul.now != ulnow
- ) {
- update = 1;
-
- h->progress.dl.total = dltotal;
- h->progress.dl.now = dlnow;
- h->progress.ul.total = ultotal;
- h->progress.ul.now = ulnow;
- }
-
- if (update && h->client->callback.progress.func) {
- h->client->callback.progress.func(h->client->callback.progress.arg, h->client, &h->queue, &h->progress);
- }
-
- return 0;
-}
-
-static int php_http_curle_seek_callback(void *userdata, curl_off_t offset, int origin)
-{
- php_http_message_body_t *body = userdata;
- TSRMLS_FETCH_FROM_CTX(body->ts);
-
- if (!body) {
- return 1;
- }
- if (0 == php_stream_seek(php_http_message_body_stream(body), offset, origin)) {
- return 0;
- }
- return 2;
-}
-
-static int php_http_curle_raw_callback(CURL *ch, curl_infotype type, char *data, size_t length, void *ctx)
-{
- php_http_client_curl_handler_t *h = ctx;
-
- /* catch progress */
- switch (type) {
- case CURLINFO_TEXT:
- if (data[0] == '-') {
- } else if (php_memnstr(data, ZEND_STRL("Adding handle:"), data + length)) {
- h->progress.info = "setup";
- } else if (php_memnstr(data, ZEND_STRL("addHandle"), data + length)) {
- h->progress.info = "setup";
- } else if (php_memnstr(data, ZEND_STRL("About to connect"), data + length)) {
- h->progress.info = "resolve";
- } else if (php_memnstr(data, ZEND_STRL("Trying"), data + length)) {
- h->progress.info = "connect";
- } else if (php_memnstr(data, ZEND_STRL("Found bundle for host"), data + length)) {
- h->progress.info = "connect";
- } else if (php_memnstr(data, ZEND_STRL("Connected"), data + length)) {
- h->progress.info = "connected";
- } else if (php_memnstr(data, ZEND_STRL("Re-using existing connection!"), data + length)) {
- h->progress.info = "connected";
- } else if (php_memnstr(data, ZEND_STRL("blacklisted"), data + length)) {
- h->progress.info = "blacklist check";
- } else if (php_memnstr(data, ZEND_STRL("SSL"), data + length)) {
- h->progress.info = "ssl negotiation";
- } else if (php_memnstr(data, ZEND_STRL("upload"), data + length)) {
- h->progress.info = "uploaded";
- } else if (php_memnstr(data, ZEND_STRL("left intact"), data + length)) {
- h->progress.info = "not disconnected";
- } else if (php_memnstr(data, ZEND_STRL("closed"), data + length)) {
- h->progress.info = "disconnected";
- } else if (php_memnstr(data, ZEND_STRL("Issue another request"), data + length)) {
- h->progress.info = "redirect";
- } else if (php_memnstr(data, ZEND_STRL("Operation timed out"), data + length)) {
- h->progress.info = "timeout";
- } else {
-#if 0
- h->progress.info = data;
- data[length - 1] = '\0';
-#endif
- }
- if (h->client->callback.progress.func) {
- h->client->callback.progress.func(h->client->callback.progress.arg, h->client, &h->queue, &h->progress);
- }
- break;
- case CURLINFO_HEADER_OUT:
- case CURLINFO_DATA_OUT:
- case CURLINFO_SSL_DATA_OUT:
- h->progress.info = "send";
- break;
- case CURLINFO_HEADER_IN:
- case CURLINFO_DATA_IN:
- case CURLINFO_SSL_DATA_IN:
- h->progress.info = "receive";
- break;
- default:
- break;
- }
-
-#if 0
- /* debug */
- _dpf(type, data, length);
-#endif
-
- return 0;
-}
-
-static int php_http_curle_header_callback(char *data, size_t n, size_t l, void *arg)
-{
- php_http_client_curl_handler_t *h = arg;
-
- return php_http_buffer_append(&h->response.headers, data, n * l);
-}
-
-static int php_http_curle_body_callback(char *data, size_t n, size_t l, void *arg)
-{
- php_http_client_curl_handler_t *h = arg;
-
- return php_http_message_body_append(h->response.body, data, n*l);
-}
-
-static ZEND_RESULT_CODE php_http_curle_get_info(CURL *ch, HashTable *info)
-{
- char *c;
- long l;
- double d;
- struct curl_slist *s, *p;
- zval *subarray, array;
- INIT_PZVAL_ARRAY(&array, info);
-
- /* BEGIN::CURLINFO */
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_EFFECTIVE_URL, &c)) {
- add_assoc_string_ex(&array, "effective_url", sizeof("effective_url"), c ? c : "", 1);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_RESPONSE_CODE, &l)) {
- add_assoc_long_ex(&array, "response_code", sizeof("response_code"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_TOTAL_TIME, &d)) {
- add_assoc_double_ex(&array, "total_time", sizeof("total_time"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_NAMELOOKUP_TIME, &d)) {
- add_assoc_double_ex(&array, "namelookup_time", sizeof("namelookup_time"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONNECT_TIME, &d)) {
- add_assoc_double_ex(&array, "connect_time", sizeof("connect_time"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_PRETRANSFER_TIME, &d)) {
- add_assoc_double_ex(&array, "pretransfer_time", sizeof("pretransfer_time"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SIZE_UPLOAD, &d)) {
- add_assoc_double_ex(&array, "size_upload", sizeof("size_upload"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SIZE_DOWNLOAD, &d)) {
- add_assoc_double_ex(&array, "size_download", sizeof("size_download"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SPEED_DOWNLOAD, &d)) {
- add_assoc_double_ex(&array, "speed_download", sizeof("speed_download"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SPEED_UPLOAD, &d)) {
- add_assoc_double_ex(&array, "speed_upload", sizeof("speed_upload"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_HEADER_SIZE, &l)) {
- add_assoc_long_ex(&array, "header_size", sizeof("header_size"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_REQUEST_SIZE, &l)) {
- add_assoc_long_ex(&array, "request_size", sizeof("request_size"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SSL_VERIFYRESULT, &l)) {
- add_assoc_long_ex(&array, "ssl_verifyresult", sizeof("ssl_verifyresult"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_FILETIME, &l)) {
- add_assoc_long_ex(&array, "filetime", sizeof("filetime"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONTENT_LENGTH_DOWNLOAD, &d)) {
- add_assoc_double_ex(&array, "content_length_download", sizeof("content_length_download"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONTENT_LENGTH_UPLOAD, &d)) {
- add_assoc_double_ex(&array, "content_length_upload", sizeof("content_length_upload"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_STARTTRANSFER_TIME, &d)) {
- add_assoc_double_ex(&array, "starttransfer_time", sizeof("starttransfer_time"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONTENT_TYPE, &c)) {
- add_assoc_string_ex(&array, "content_type", sizeof("content_type"), c ? c : "", 1);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_REDIRECT_TIME, &d)) {
- add_assoc_double_ex(&array, "redirect_time", sizeof("redirect_time"), d);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_REDIRECT_COUNT, &l)) {
- add_assoc_long_ex(&array, "redirect_count", sizeof("redirect_count"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_HTTP_CONNECTCODE, &l)) {
- add_assoc_long_ex(&array, "connect_code", sizeof("connect_code"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_HTTPAUTH_AVAIL, &l)) {
- add_assoc_long_ex(&array, "httpauth_avail", sizeof("httpauth_avail"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_PROXYAUTH_AVAIL, &l)) {
- add_assoc_long_ex(&array, "proxyauth_avail", sizeof("proxyauth_avail"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_OS_ERRNO, &l)) {
- add_assoc_long_ex(&array, "os_errno", sizeof("os_errno"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_NUM_CONNECTS, &l)) {
- add_assoc_long_ex(&array, "num_connects", sizeof("num_connects"), l);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_SSL_ENGINES, &s)) {
- MAKE_STD_ZVAL(subarray);
- array_init(subarray);
- for (p = s; p; p = p->next) {
- if (p->data) {
- add_next_index_string(subarray, p->data, 1);
- }
- }
- add_assoc_zval_ex(&array, "ssl_engines", sizeof("ssl_engines"), subarray);
- curl_slist_free_all(s);
- }
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_REDIRECT_URL, &c)) {
- add_assoc_string_ex(&array, "redirect_url", sizeof("redirect_url"), c ? c : "", 1);
- }
-#if PHP_HTTP_CURL_VERSION(7,19,0)
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_PRIMARY_IP, &c)) {
- add_assoc_string_ex(&array, "primary_ip", sizeof("primary_ip"), c ? c : "", 1);
- }
-#endif
-#if PHP_HTTP_CURL_VERSION(7,19,0)
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_APPCONNECT_TIME, &d)) {
- add_assoc_double_ex(&array, "appconnect_time", sizeof("appconnect_time"), d);
- }
-#endif
-#if PHP_HTTP_CURL_VERSION(7,19,4)
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CONDITION_UNMET, &l)) {
- add_assoc_long_ex(&array, "condition_unmet", sizeof("condition_unmet"), l);
- }
-#endif
-#if PHP_HTTP_CURL_VERSION(7,21,0)
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_PRIMARY_PORT, &l)) {
- add_assoc_long_ex(&array, "primary_port", sizeof("primary_port"), l);
- }
-#endif
-#if PHP_HTTP_CURL_VERSION(7,21,0)
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_LOCAL_IP, &c)) {
- add_assoc_string_ex(&array, "local_ip", sizeof("local_ip"), c ? c : "", 1);
- }
-#endif
-#if PHP_HTTP_CURL_VERSION(7,21,0)
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_LOCAL_PORT, &l)) {
- add_assoc_long_ex(&array, "local_port", sizeof("local_port"), l);
- }
-#endif
-
- /* END::CURLINFO */
-
-#if PHP_HTTP_CURL_VERSION(7,34,0)
- {
- zval *ti_array;
- struct curl_tlssessioninfo *ti;
-
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_TLS_SESSION, &ti)) {
- const char *backend;
-
- MAKE_STD_ZVAL(subarray);
- ZVAL_NULL(subarray);
- MAKE_STD_ZVAL(ti_array);
- array_init(ti_array);
-
- switch (ti->backend) {
- case CURLSSLBACKEND_NONE:
- backend = "none";
- break;
- case CURLSSLBACKEND_OPENSSL:
- backend = "openssl";
-#ifdef PHP_HTTP_HAVE_OPENSSL
- {
- SSL_CTX *ctx = ti->internals;
-
- array_init(subarray);
- add_assoc_long_ex(subarray, ZEND_STRS("number"), SSL_CTX_sess_number(ctx));
- add_assoc_long_ex(subarray, ZEND_STRS("connect"), SSL_CTX_sess_connect(ctx));
- add_assoc_long_ex(subarray, ZEND_STRS("connect_good"), SSL_CTX_sess_connect_good(ctx));
- add_assoc_long_ex(subarray, ZEND_STRS("connect_renegotiate"), SSL_CTX_sess_connect_renegotiate(ctx));
- add_assoc_long_ex(subarray, ZEND_STRS("hits"), SSL_CTX_sess_hits(ctx));
- add_assoc_long_ex(subarray, ZEND_STRS("cache_full"), SSL_CTX_sess_cache_full(ctx));
- }
-#endif
- break;
- case CURLSSLBACKEND_GNUTLS:
- backend = "gnutls";
-#ifdef PHP_HTTP_HAVE_GNUTLS
- {
- gnutls_session_t sess = ti->internals;
- char *desc;
-
- array_init(subarray);
- if ((desc = gnutls_session_get_desc(sess))) {
- add_assoc_string_ex(subarray, ZEND_STRS("desc"), desc, 1);
- gnutls_free(desc);
- }
- add_assoc_bool_ex(subarray, ZEND_STRS("resumed"), gnutls_session_is_resumed(sess));
- }
-#endif
- break;
- case CURLSSLBACKEND_NSS:
- backend = "nss";
- break;
-#if !PHP_HTTP_CURL_VERSION(7,39,0)
- case CURLSSLBACKEND_QSOSSL:
- backend = "qsossl";
- break;
-#else
- case CURLSSLBACKEND_GSKIT:
- backend = "gskit";
- break;
-#endif
- case CURLSSLBACKEND_POLARSSL:
- backend = "polarssl";
- break;
- case CURLSSLBACKEND_CYASSL:
- backend = "cyassl";
- break;
- case CURLSSLBACKEND_SCHANNEL:
- backend = "schannel";
- break;
- case CURLSSLBACKEND_DARWINSSL:
- backend = "darwinssl";
- break;
- default:
- backend = "unknown";
- }
- add_assoc_string_ex(ti_array, ZEND_STRS("backend"), estrdup(backend), 0);
- add_assoc_zval_ex(ti_array, ZEND_STRS("internals"), subarray);
- add_assoc_zval_ex(&array, "tls_session", sizeof("tls_session"), ti_array);
- }
- }
-#endif
-
-#if (PHP_HTTP_CURL_VERSION(7,19,1) && defined(PHP_HTTP_HAVE_OPENSSL)) || (PHP_HTTP_CURL_VERSION(7,34,0) && defined(PHP_HTTP_HAVE_NSS)) || (PHP_HTTP_CURL_VERSION(7,42,0) && defined(PHP_HTTP_HAVE_GNUTLS)) || (PHP_HTTP_CURL_VERSION(7,39,0) && defined(PHP_HTTP_HAVE_GSKIT))
- {
- int i;
- zval *ci_array;
- struct curl_certinfo *ci;
- char *colon, *keyname;
-
- if (CURLE_OK == curl_easy_getinfo(ch, CURLINFO_CERTINFO, &ci)) {
- MAKE_STD_ZVAL(ci_array);
- array_init(ci_array);
-
- for (i = 0; i < ci->num_of_certs; ++i) {
- s = ci->certinfo[i];
-
- MAKE_STD_ZVAL(subarray);
- array_init(subarray);
- for (p = s; p; p = p->next) {
- if (p->data) {
- if ((colon = strchr(p->data, ':'))) {
- keyname = estrndup(p->data, colon - p->data);
- add_assoc_string_ex(subarray, keyname, colon - p->data + 1, colon + 1, 1);
- efree(keyname);
- } else {
- add_next_index_string(subarray, p->data, 1);
- }
- }
- }
- add_next_index_zval(ci_array, subarray);
- }
- add_assoc_zval_ex(&array, "certinfo", sizeof("certinfo"), ci_array);
- }
- }
-#endif
- {
- php_http_curle_storage_t *st = php_http_curle_get_storage(ch);
-
- add_assoc_long_ex(&array, "curlcode", sizeof("curlcode"), st->errorcode);
- add_assoc_string_ex(&array, "error", sizeof("error"), st->errorbuffer, 1);
- }
-
- return SUCCESS;
-}
-
-static int compare_queue(php_http_client_enqueue_t *e, void *handle)
-{
- return handle == ((php_http_client_curl_handler_t *) e->opaque)->handle;
-}
-
-static php_http_message_t *php_http_curlm_responseparser(php_http_client_curl_handler_t *h TSRMLS_DC)
-{
- php_http_message_t *response;
- php_http_header_parser_t parser;
- zval *zh;
-
- response = php_http_message_init(NULL, 0, h->response.body TSRMLS_CC);
- php_http_header_parser_init(&parser TSRMLS_CC);
- while (h->response.headers.used) {
- php_http_header_parser_state_t st = php_http_header_parser_parse(&parser,
- &h->response.headers, PHP_HTTP_HEADER_PARSER_CLEANUP, &response->hdrs,
- (php_http_info_callback_t) php_http_message_info_callback, (void *) &response);
- if (PHP_HTTP_HEADER_PARSER_STATE_FAILURE == st) {
- break;
- }
- }
- php_http_header_parser_dtor(&parser);
-
- /* move body to right message */
- if (response->body != h->response.body) {
- php_http_message_t *ptr = response;
-
- while (ptr->parent) {
- ptr = ptr->parent;
- }
- php_http_message_body_free(&response->body);
- response->body = ptr->body;
- ptr->body = NULL;
- }
- php_http_message_body_addref(h->response.body);
-
- /* let's update the response headers */
- if ((zh = php_http_message_header(response, ZEND_STRL("Content-Length"), 1))) {
- zend_hash_update(&response->hdrs, "X-Original-Content-Length", sizeof("X-Original-Content-Length"), &zh, sizeof(zval *), NULL);
- }
- if ((zh = php_http_message_header(response, ZEND_STRL("Transfer-Encoding"), 0))) {
- zend_hash_update(&response->hdrs, "X-Original-Transfer-Encoding", sizeof("X-Original-Transfer-Encoding"), (void *) &zh, sizeof(zval *), NULL);
- zend_hash_del(&response->hdrs, "Transfer-Encoding", sizeof("Transfer-Encoding"));
- }
- if ((zh = php_http_message_header(response, ZEND_STRL("Content-Range"), 0))) {
- zend_hash_update(&response->hdrs, "X-Original-Content-Range", sizeof("X-Original-Content-Range"), &zh, sizeof(zval *), NULL);
- zend_hash_del(&response->hdrs, "Content-Range", sizeof("Content-Range"));
- }
- if ((zh = php_http_message_header(response, ZEND_STRL("Content-Encoding"), 0))) {
- zend_hash_update(&response->hdrs, "X-Original-Content-Encoding", sizeof("X-Original-Content-Encoding"), &zh, sizeof(zval *), NULL);
- zend_hash_del(&response->hdrs, "Content-Encoding", sizeof("Content-Encoding"));
- }
- php_http_message_update_headers(response);
-
- return response;
-}
-
-static void php_http_curlm_responsehandler(php_http_client_t *context)
-{
- int err_count = 0, remaining = 0;
- php_http_curle_storage_t *st, *err = NULL;
- php_http_client_enqueue_t *enqueue;
- php_http_client_curl_t *curl = context->ctx;
- TSRMLS_FETCH_FROM_CTX(context->ts);
-
- do {
- CURLMsg *msg = curl_multi_info_read(curl->handle, &remaining);
-
- if (msg && CURLMSG_DONE == msg->msg) {
- if (CURLE_OK != msg->data.result) {
- st = php_http_curle_get_storage(msg->easy_handle);
- st->errorcode = msg->data.result;
-
- /* defer the warnings/exceptions, so the callback is still called for this request */
- if (!err) {
- err = ecalloc(remaining + 1, sizeof(*err));
- }
- memcpy(&err[err_count], st, sizeof(*st));
- if (st->url) {
- err[err_count].url = estrdup(st->url);
- }
- err_count++;
- }
-
- if ((enqueue = php_http_client_enqueued(context, msg->easy_handle, compare_queue))) {
- php_http_client_curl_handler_t *handler = enqueue->opaque;
- php_http_message_t *response = php_http_curlm_responseparser(handler TSRMLS_CC);
-
- if (response) {
- context->callback.response.func(context->callback.response.arg, context, &handler->queue, &response);
- php_http_message_free(&response);
- }
- }
- }
- } while (remaining);
-
- if (err_count) {
- int i = 0;
-
- do {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s; %s (%s)", curl_easy_strerror(err[i].errorcode), err[i].errorbuffer, STR_PTR(err[i].url));
- if (err[i].url) {
- efree(err[i].url);
- }
- } while (++i < err_count);
-
- efree(err);
- }
-}
-
-#if PHP_HTTP_HAVE_EVENT
-
-typedef struct php_http_curlm_event {
- struct event evnt;
- php_http_client_t *context;
-} php_http_curlm_event_t;
-
-static inline int etoca(short action) {
- switch (action & (EV_READ|EV_WRITE)) {
- case EV_READ:
- return CURL_CSELECT_IN;
- break;
- case EV_WRITE:
- return CURL_CSELECT_OUT;
- break;
- case EV_READ|EV_WRITE:
- return CURL_CSELECT_IN|CURL_CSELECT_OUT;
- break;
- default:
- return 0;
- }
-}
-
-static void php_http_curlm_timeout_callback(int socket, short action, void *event_data)
-{
- php_http_client_t *context = event_data;
- php_http_client_curl_t *curl = context->ctx;
-
-#if DBG_EVENTS
- fprintf(stderr, "T");
-#endif
- if (curl->useevents) {
- CURLMcode rc;
- TSRMLS_FETCH_FROM_CTX(context->ts);
-
- /* ignore and use -1,0 on timeout */
- (void) socket;
- (void) action;
-
- while (CURLM_CALL_MULTI_PERFORM == (rc = curl_multi_socket_action(curl->handle, CURL_SOCKET_TIMEOUT, 0, &curl->unfinished)));
-
- if (CURLM_OK != rc) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", curl_multi_strerror(rc));
- }
-
- php_http_curlm_responsehandler(context);
- }
-}
-
-static void php_http_curlm_event_callback(int socket, short action, void *event_data)
-{
- php_http_client_t *context = event_data;
- php_http_client_curl_t *curl = context->ctx;
-
-#if DBG_EVENTS
- fprintf(stderr, "E");
-#endif
- if (curl->useevents) {
- CURLMcode rc = CURLM_OK;
- TSRMLS_FETCH_FROM_CTX(context->ts);
-
- while (CURLM_CALL_MULTI_PERFORM == (rc = curl_multi_socket_action(curl->handle, socket, etoca(action), &curl->unfinished)));
-
- if (CURLM_OK != rc) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", curl_multi_strerror(rc));
- }
-
- php_http_curlm_responsehandler(context);
-
- /* remove timeout if there are no transfers left */
- if (!curl->unfinished && event_initialized(curl->timeout) && event_pending(curl->timeout, EV_TIMEOUT, NULL)) {
- event_del(curl->timeout);
- }
- }
-}
-
-static int php_http_curlm_socket_callback(CURL *easy, curl_socket_t sock, int action, void *socket_data, void *assign_data)
-{
- php_http_client_t *context = socket_data;
- php_http_client_curl_t *curl = context->ctx;
-
-#if DBG_EVENTS
- fprintf(stderr, "S");
-#endif
- if (curl->useevents) {
- int events = EV_PERSIST;
- php_http_curlm_event_t *ev = assign_data;
- TSRMLS_FETCH_FROM_CTX(context->ts);
-
- if (!ev) {
- ev = ecalloc(1, sizeof(php_http_curlm_event_t));
- ev->context = context;
- curl_multi_assign(curl->handle, sock, ev);
- } else {
- event_del(&ev->evnt);
- }
-
- switch (action) {
- case CURL_POLL_IN:
- events |= EV_READ;
- break;
- case CURL_POLL_OUT:
- events |= EV_WRITE;
- break;
- case CURL_POLL_INOUT:
- events |= EV_READ|EV_WRITE;
- break;
-
- case CURL_POLL_REMOVE:
- efree(ev);
- /* no break */
- case CURL_POLL_NONE:
- return 0;
-
- default:
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unknown socket action %d", action);
- return -1;
- }
-
- event_assign(&ev->evnt, curl->evbase, sock, events, php_http_curlm_event_callback, context);
- event_add(&ev->evnt, NULL);
- }
-
- return 0;
-}
-
-static void php_http_curlm_timer_callback(CURLM *multi, long timeout_ms, void *timer_data)
-{
- php_http_client_t *context = timer_data;
- php_http_client_curl_t *curl = context->ctx;
-
-#if DBG_EVENTS
- fprintf(stderr, "\ntimer <- timeout_ms: %ld\n", timeout_ms);
-#endif
- if (curl->useevents) {
-
- if (timeout_ms < 0) {
- php_http_curlm_timeout_callback(CURL_SOCKET_TIMEOUT, /*EV_READ|EV_WRITE*/0, context);
- } else if (timeout_ms > 0 || !event_initialized(curl->timeout) || !event_pending(curl->timeout, EV_TIMEOUT, NULL)) {
- struct timeval timeout;
-
- if (!event_initialized(curl->timeout)) {
- event_assign(curl->timeout, curl->evbase, CURL_SOCKET_TIMEOUT, 0, php_http_curlm_timeout_callback, context);
- }
-
- timeout.tv_sec = timeout_ms / 1000;
- timeout.tv_usec = (timeout_ms % 1000) * 1000;
-
- event_add(curl->timeout, &timeout);
- }
- }
-}
-
-#endif /* HAVE_EVENT */
-
-/* curl options */
-
-static php_http_options_t php_http_curle_options, php_http_curlm_options;
-
-#define PHP_HTTP_CURLE_OPTION_CHECK_STRLEN 0x0001
-#define PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR 0x0002
-#define PHP_HTTP_CURLE_OPTION_TRANSFORM_MS 0x0004
-
-static ZEND_RESULT_CODE php_http_curle_option_set_ssl_verifyhost(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
-
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_SSL_VERIFYHOST, Z_BVAL_P(val) ? 2 : 0)) {
- return FAILURE;
- }
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_cookiestore(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
- php_http_curle_storage_t *storage = php_http_curle_get_storage(curl->handle);
-
- if (storage->cookiestore) {
- pefree(storage->cookiestore, 1);
- }
- if (val && Z_STRLEN_P(val)) {
- storage->cookiestore = pestrndup(Z_STRVAL_P(val), Z_STRLEN_P(val), 1);
- } else {
- storage->cookiestore = NULL;
- }
- if ( CURLE_OK != curl_easy_setopt(ch, CURLOPT_COOKIEFILE, storage->cookiestore)
- || CURLE_OK != curl_easy_setopt(ch, CURLOPT_COOKIEJAR, storage->cookiestore)
- ) {
- return FAILURE;
- }
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_cookies(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
- TSRMLS_FETCH_FROM_CTX(curl->client->ts);
-
- if (val && Z_TYPE_P(val) != IS_NULL) {
- if (curl->options.encode_cookies) {
- if (SUCCESS == php_http_url_encode_hash_ex(HASH_OF(val), &curl->options.cookies, ZEND_STRL(";"), ZEND_STRL("="), NULL, 0 TSRMLS_CC)) {
- php_http_buffer_fix(&curl->options.cookies);
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_COOKIE, curl->options.cookies.data)) {
- return FAILURE;
- }
- } else {
- return FAILURE;
- }
- } else {
- HashPosition pos;
- php_http_array_hashkey_t cookie_key = php_http_array_hashkey_init(0);
- zval **cookie_val;
-
- FOREACH_KEYVAL(pos, val, cookie_key, cookie_val) {
- zval *zv = php_http_ztyp(IS_STRING, *cookie_val);
-
- php_http_array_hashkey_stringify(&cookie_key);
- php_http_buffer_appendf(&curl->options.cookies, "%s=%s; ", cookie_key.str, Z_STRVAL_P(zv));
- php_http_array_hashkey_stringfree(&cookie_key);
-
- zval_ptr_dtor(&zv);
- }
-
- php_http_buffer_fix(&curl->options.cookies);
- if (curl->options.cookies.used) {
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_COOKIE, curl->options.cookies.data)) {
- return FAILURE;
- }
- }
- }
- } else {
- php_http_buffer_reset(&curl->options.cookies);
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_COOKIE, NULL)) {
- return FAILURE;
- }
- }
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_encodecookies(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
-
- curl->options.encode_cookies = Z_BVAL_P(val);
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_lastmodified(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
- TSRMLS_FETCH_FROM_CTX(curl->client->ts);
-
- if (Z_LVAL_P(val)) {
- if (Z_LVAL_P(val) > 0) {
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMEVALUE, Z_LVAL_P(val))) {
- return FAILURE;
- }
- } else {
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMEVALUE, (long) sapi_get_request_time(TSRMLS_C) + Z_LVAL_P(val))) {
- return FAILURE;
- }
- }
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMECONDITION, (long) (curl->options.range_request ? CURL_TIMECOND_IFUNMODSINCE : CURL_TIMECOND_IFMODSINCE))) {
- return FAILURE;
- }
- } else {
- if ( CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMEVALUE, 0)
- || CURLE_OK != curl_easy_setopt(ch, CURLOPT_TIMECONDITION, 0)
- ) {
- return FAILURE;
- }
- }
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_compress(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
-
-#if !PHP_HTTP_CURL_VERSION(7,21,6)
-# define CURLOPT_ACCEPT_ENCODING CURLOPT_ENCODING
-#endif
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_ACCEPT_ENCODING, Z_BVAL_P(val) ? "" : NULL)) {
- return FAILURE;
- }
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_etag(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- php_http_buffer_t header;
-
- if (Z_STRLEN_P(val)) {
- zend_bool is_quoted = !((Z_STRVAL_P(val)[0] != '"') || (Z_STRVAL_P(val)[Z_STRLEN_P(val)-1] != '"'));
- php_http_buffer_init(&header);
- php_http_buffer_appendf(&header, is_quoted?"%s: %s":"%s: \"%s\"", curl->options.range_request?"If-Match":"If-None-Match", Z_STRVAL_P(val));
- php_http_buffer_fix(&header);
- curl->options.headers = curl_slist_append(curl->options.headers, header.data);
- php_http_buffer_dtor(&header);
- }
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_range(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
- TSRMLS_FETCH_FROM_CTX(curl->client->ts);
-
- php_http_buffer_reset(&curl->options.ranges);
-
- if (val && Z_TYPE_P(val) != IS_NULL) {
- HashPosition pos;
- zval **rr, **rb, **re;
-
- FOREACH_VAL(pos, val, rr) {
- if (Z_TYPE_PP(rr) == IS_ARRAY) {
- if (2 == php_http_array_list(Z_ARRVAL_PP(rr) TSRMLS_CC, 2, &rb, &re)) {
- if ( ((Z_TYPE_PP(rb) == IS_LONG) || ((Z_TYPE_PP(rb) == IS_STRING) && is_numeric_string(Z_STRVAL_PP(rb), Z_STRLEN_PP(rb), NULL, NULL, 1))) &&
- ((Z_TYPE_PP(re) == IS_LONG) || ((Z_TYPE_PP(re) == IS_STRING) && is_numeric_string(Z_STRVAL_PP(re), Z_STRLEN_PP(re), NULL, NULL, 1)))) {
- zval *rbl = php_http_ztyp(IS_LONG, *rb);
- zval *rel = php_http_ztyp(IS_LONG, *re);
-
- if ((Z_LVAL_P(rbl) >= 0) && (Z_LVAL_P(rel) >= 0)) {
- php_http_buffer_appendf(&curl->options.ranges, "%ld-%ld,", Z_LVAL_P(rbl), Z_LVAL_P(rel));
- }
- zval_ptr_dtor(&rbl);
- zval_ptr_dtor(&rel);
- }
-
- }
- }
- }
-
- if (curl->options.ranges.used) {
- curl->options.range_request = 1;
- /* ditch last comma */
- curl->options.ranges.data[curl->options.ranges.used - 1] = '\0';
- }
- }
-
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_RANGE, curl->options.ranges.data)) {
- return FAILURE;
- }
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_resume(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
-
- if (Z_LVAL_P(val) > 0) {
- curl->options.range_request = 1;
- }
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_RESUME_FROM, Z_LVAL_P(val))) {
- return FAILURE;
- }
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_retrydelay(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
-
- curl->options.retry.delay = Z_DVAL_P(val);
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_retrycount(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
-
- curl->options.retry.count = Z_LVAL_P(val);
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_redirect(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
-
- if ( CURLE_OK != curl_easy_setopt(ch, CURLOPT_FOLLOWLOCATION, Z_LVAL_P(val) ? 1L : 0L)
- || CURLE_OK != curl_easy_setopt(ch, CURLOPT_MAXREDIRS, curl->options.redirects = Z_LVAL_P(val))
- ) {
- return FAILURE;
- }
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curle_option_set_portrange(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
- long localport = 0, localportrange = 0;
- TSRMLS_FETCH_FROM_CTX(curl->client->ts);
-
- if (val && Z_TYPE_P(val) != IS_NULL) {
- zval **z_port_start, *zps_copy = NULL, **z_port_end, *zpe_copy = NULL;
-
- switch (php_http_array_list(Z_ARRVAL_P(val) TSRMLS_CC, 2, &z_port_start, &z_port_end)) {
- case 2:
- zps_copy = php_http_ztyp(IS_LONG, *z_port_start);
- zpe_copy = php_http_ztyp(IS_LONG, *z_port_end);
- localportrange = labs(Z_LVAL_P(zps_copy)-Z_LVAL_P(zpe_copy))+1L;
- /* no break */
- case 1:
- if (!zps_copy) {
- zps_copy = php_http_ztyp(IS_LONG, *z_port_start);
- }
- localport = (zpe_copy && Z_LVAL_P(zpe_copy) > 0) ? MIN(Z_LVAL_P(zps_copy), Z_LVAL_P(zpe_copy)) : Z_LVAL_P(zps_copy);
- zval_ptr_dtor(&zps_copy);
- if (zpe_copy) {
- zval_ptr_dtor(&zpe_copy);
- }
- break;
- default:
- break;
- }
- }
- if ( CURLE_OK != curl_easy_setopt(ch, CURLOPT_LOCALPORT, localport)
- || CURLE_OK != curl_easy_setopt(ch, CURLOPT_LOCALPORTRANGE, localportrange)
- ) {
- return FAILURE;
- }
- return SUCCESS;
-}
-
-#if PHP_HTTP_CURL_VERSION(7,37,0)
-static ZEND_RESULT_CODE php_http_curle_option_set_proxyheader(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- TSRMLS_FETCH_FROM_CTX(curl->client->ts);
-
- if (val && Z_TYPE_P(val) != IS_NULL) {
- php_http_array_hashkey_t header_key = php_http_array_hashkey_init(0);
- zval **header_val, *header_cpy;
- HashPosition pos;
- php_http_buffer_t header;
-
- php_http_buffer_init(&header);
- FOREACH_KEYVAL(pos, val, header_key, header_val) {
- if (header_key.type == HASH_KEY_IS_STRING) {
- header_cpy = php_http_ztyp(IS_STRING, *header_val);
- php_http_buffer_appendf(&header, "%s: %s", header_key.str, Z_STRVAL_P(header_cpy));
- php_http_buffer_fix(&header);
- curl->options.proxyheaders = curl_slist_append(curl->options.proxyheaders, header.data);
- php_http_buffer_reset(&header);
-
- zval_ptr_dtor(&header_cpy);
- }
- }
- php_http_buffer_dtor(&header);
- }
- if (CURLE_OK != curl_easy_setopt(curl->handle, CURLOPT_PROXYHEADER, curl->options.proxyheaders)) {
- return FAILURE;
- }
- if (CURLE_OK != curl_easy_setopt(curl->handle, CURLOPT_HEADEROPT, CURLHEADER_SEPARATE)) {
- curl_easy_setopt(curl->handle, CURLOPT_PROXYHEADER, NULL);
- return FAILURE;
- }
- return SUCCESS;
-}
-#endif
-
-#if PHP_HTTP_CURL_VERSION(7,21,3)
-static ZEND_RESULT_CODE php_http_curle_option_set_resolve(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
- TSRMLS_FETCH_FROM_CTX(curl->client->ts);
-
- if (val && Z_TYPE_P(val) != IS_NULL) {
- php_http_array_hashkey_t key = php_http_array_hashkey_init(0);
- HashPosition pos;
- zval **data;
-
- FOREACH_KEYVAL(pos, val, key, data) {
- zval *cpy = php_http_ztyp(IS_STRING, *data);
- curl->options.resolve = curl_slist_append(curl->options.resolve, Z_STRVAL_P(cpy));
- zval_ptr_dtor(&cpy);
- }
-
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_RESOLVE, curl->options.resolve)) {
- return FAILURE;
- }
- } else {
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_RESOLVE, NULL)) {
- return FAILURE;
- }
- }
- return SUCCESS;
-}
-#endif
-
-#if PHP_HTTP_CURL_VERSION(7,21,4) && defined(PHP_HTTP_CURL_TLSAUTH_SRP)
-static ZEND_RESULT_CODE php_http_curle_option_set_ssl_tlsauthtype(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
-
- if (val && Z_LVAL_P(val)) {
- switch (Z_LVAL_P(val)) {
- case CURL_TLSAUTH_SRP:
- if (CURLE_OK == curl_easy_setopt(ch, CURLOPT_TLSAUTH_TYPE, PHP_HTTP_CURL_TLSAUTH_SRP)) {
- return SUCCESS;
- }
- /* no break */
- default:
- return FAILURE;
- }
- }
- if (CURLE_OK != curl_easy_setopt(ch, CURLOPT_TLSAUTH_TYPE, PHP_HTTP_CURL_TLSAUTH_DEF)) {
- return FAILURE;
- }
- return SUCCESS;
-}
-#endif
-
-static void php_http_curle_options_init(php_http_options_t *registry TSRMLS_DC)
-{
- php_http_option_t *opt;
-
- /* url options */
-#if PHP_HTTP_CURL_VERSION(7,42,0)
- php_http_option_register(registry, ZEND_STRL("path_as_is"), CURLOPT_PATH_AS_IS, IS_BOOL);
-#endif
-
- /* proxy */
- if ((opt = php_http_option_register(registry, ZEND_STRL("proxyhost"), CURLOPT_PROXY, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
- php_http_option_register(registry, ZEND_STRL("proxytype"), CURLOPT_PROXYTYPE, IS_LONG);
- php_http_option_register(registry, ZEND_STRL("proxyport"), CURLOPT_PROXYPORT, IS_LONG);
- if ((opt = php_http_option_register(registry, ZEND_STRL("proxyauth"), CURLOPT_PROXYUSERPWD, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("proxyauthtype"), CURLOPT_PROXYAUTH, IS_LONG))) {
- Z_LVAL(opt->defval) = CURLAUTH_ANYSAFE;
- }
- php_http_option_register(registry, ZEND_STRL("proxytunnel"), CURLOPT_HTTPPROXYTUNNEL, IS_BOOL);
-#if PHP_HTTP_CURL_VERSION(7,19,4)
- php_http_option_register(registry, ZEND_STRL("noproxy"), CURLOPT_NOPROXY, IS_STRING);
-#endif
-
-#if PHP_HTTP_CURL_VERSION(7,37,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("proxyheader"), CURLOPT_PROXYHEADER, IS_ARRAY))) {
- opt->setter = php_http_curle_option_set_proxyheader;
- }
-#endif
-#if PHP_HTTP_CURL_VERSION(7,43,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("proxy_service_name"), CURLOPT_PROXY_SERVICE_NAME, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
-#endif
-
-#if PHP_HTTP_CURL_VERSION(7,40,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("unix_socket_path"), CURLOPT_UNIX_SOCKET_PATH, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- }
-#endif
-
- /* dns */
- if ((opt = php_http_option_register(registry, ZEND_STRL("dns_cache_timeout"), CURLOPT_DNS_CACHE_TIMEOUT, IS_LONG))) {
- Z_LVAL(opt->defval) = 60;
- }
- php_http_option_register(registry, ZEND_STRL("ipresolve"), CURLOPT_IPRESOLVE, IS_LONG);
-#if PHP_HTTP_CURL_VERSION(7,21,3)
- if ((opt = php_http_option_register(registry, ZEND_STRL("resolve"), CURLOPT_RESOLVE, IS_ARRAY))) {
- opt->setter = php_http_curle_option_set_resolve;
- }
-#endif
-#if PHP_HTTP_HAVE_ARES
-# if PHP_HTTP_CURL_VERSION(7,24,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("dns_servers"), CURLOPT_DNS_SERVERS, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
-# endif
-# if PHP_HTTP_CURL_VERSION(7,33,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("dns_interface"), CURLOPT_DNS_INTERFACE, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("dns_local_ip4"), CURLOPT_DNS_LOCAL_IP4, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("dns_local_ip6"), CURLOPT_DNS_LOCAL_IP6, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
-# endif
-#endif
-
- /* limits */
- php_http_option_register(registry, ZEND_STRL("low_speed_limit"), CURLOPT_LOW_SPEED_LIMIT, IS_LONG);
- php_http_option_register(registry, ZEND_STRL("low_speed_time"), CURLOPT_LOW_SPEED_TIME, IS_LONG);
-
- /* LSF weirdance
- php_http_option_register(registry, ZEND_STRL("max_send_speed"), CURLOPT_MAX_SEND_SPEED_LARGE, IS_LONG);
- php_http_option_register(registry, ZEND_STRL("max_recv_speed"), CURLOPT_MAX_RECV_SPEED_LARGE, IS_LONG);
- */
-
- /* connection handling */
- /* crashes
- if ((opt = php_http_option_register(registry, ZEND_STRL("maxconnects"), CURLOPT_MAXCONNECTS, IS_LONG))) {
- Z_LVAL(opt->defval) = 5;
- }
- */
- php_http_option_register(registry, ZEND_STRL("fresh_connect"), CURLOPT_FRESH_CONNECT, IS_BOOL);
- php_http_option_register(registry, ZEND_STRL("forbid_reuse"), CURLOPT_FORBID_REUSE, IS_BOOL);
-
- /* outgoing interface */
- php_http_option_register(registry, ZEND_STRL("interface"), CURLOPT_INTERFACE, IS_STRING);
- if ((opt = php_http_option_register(registry, ZEND_STRL("portrange"), CURLOPT_LOCALPORT, IS_ARRAY))) {
- opt->setter = php_http_curle_option_set_portrange;
- }
-
- /* another endpoint port */
- php_http_option_register(registry, ZEND_STRL("port"), CURLOPT_PORT, IS_LONG);
-
- /* RFC4007 zone_id */
-#if PHP_HTTP_CURL_VERSION(7,19,0)
- php_http_option_register(registry, ZEND_STRL("address_scope"), CURLOPT_ADDRESS_SCOPE, IS_LONG);
-#endif
-
- /* auth */
- if ((opt = php_http_option_register(registry, ZEND_STRL("httpauth"), CURLOPT_USERPWD, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("httpauthtype"), CURLOPT_HTTPAUTH, IS_LONG))) {
- Z_LVAL(opt->defval) = CURLAUTH_ANYSAFE;
- }
-#if PHP_HTTP_CURL_VERSION(7,43,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("service_name"), CURLOPT_SERVICE_NAME, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
-#endif
-
- /* redirects */
- if ((opt = php_http_option_register(registry, ZEND_STRL("redirect"), CURLOPT_FOLLOWLOCATION, IS_LONG))) {
- opt->setter = php_http_curle_option_set_redirect;
- }
- php_http_option_register(registry, ZEND_STRL("unrestricted_auth"), CURLOPT_UNRESTRICTED_AUTH, IS_BOOL);
-#if PHP_HTTP_CURL_VERSION(7,19,1)
- php_http_option_register(registry, ZEND_STRL("postredir"), CURLOPT_POSTREDIR, IS_LONG);
-#endif
-
- /* retries */
- if ((opt = php_http_option_register(registry, ZEND_STRL("retrycount"), 0, IS_LONG))) {
- opt->setter = php_http_curle_option_set_retrycount;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("retrydelay"), 0, IS_DOUBLE))) {
- opt->setter = php_http_curle_option_set_retrydelay;
- }
-
- /* referer */
- if ((opt = php_http_option_register(registry, ZEND_STRL("referer"), CURLOPT_REFERER, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("autoreferer"), CURLOPT_AUTOREFERER, IS_BOOL))) {
- ZVAL_BOOL(&opt->defval, 1);
- }
-
- /* useragent */
- if ((opt = php_http_option_register(registry, ZEND_STRL("useragent"), CURLOPT_USERAGENT, IS_STRING))) {
- /* don't check strlen, to allow sending no useragent at all */
- ZVAL_STRING(&opt->defval,
- "PECL_HTTP/" PHP_PECL_HTTP_VERSION " "
- "PHP/" PHP_VERSION " "
- "libcurl/" LIBCURL_VERSION
- , 0);
- }
-
- /* resume */
- if ((opt = php_http_option_register(registry, ZEND_STRL("resume"), CURLOPT_RESUME_FROM, IS_LONG))) {
- opt->setter = php_http_curle_option_set_resume;
- }
- /* ranges */
- if ((opt = php_http_option_register(registry, ZEND_STRL("range"), CURLOPT_RANGE, IS_ARRAY))) {
- opt->setter = php_http_curle_option_set_range;
- }
-
- /* etag */
- if ((opt = php_http_option_register(registry, ZEND_STRL("etag"), 0, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->setter = php_http_curle_option_set_etag;
- }
-
- /* compression */
- if ((opt = php_http_option_register(registry, ZEND_STRL("compress"), 0, IS_BOOL))) {
- opt->setter = php_http_curle_option_set_compress;
- }
-
- /* lastmodified */
- if ((opt = php_http_option_register(registry, ZEND_STRL("lastmodified"), 0, IS_LONG))) {
- opt->setter = php_http_curle_option_set_lastmodified;
- }
-
- /* cookies */
- if ((opt = php_http_option_register(registry, ZEND_STRL("encodecookies"), 0, IS_BOOL))) {
- opt->setter = php_http_curle_option_set_encodecookies;
- ZVAL_BOOL(&opt->defval, 1);
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("cookies"), 0, IS_ARRAY))) {
- opt->setter = php_http_curle_option_set_cookies;
- }
-
- /* cookiesession, don't load session cookies from cookiestore */
- php_http_option_register(registry, ZEND_STRL("cookiesession"), CURLOPT_COOKIESESSION, IS_BOOL);
- /* cookiestore, read initial cookies from that file and store cookies back into that file */
- if ((opt = php_http_option_register(registry, ZEND_STRL("cookiestore"), 0, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- opt->setter = php_http_curle_option_set_cookiestore;
- }
-
- /* maxfilesize */
- php_http_option_register(registry, ZEND_STRL("maxfilesize"), CURLOPT_MAXFILESIZE, IS_LONG);
-
- /* http protocol version */
- php_http_option_register(registry, ZEND_STRL("protocol"), CURLOPT_HTTP_VERSION, IS_LONG);
-
- /* timeouts */
- if ((opt = php_http_option_register(registry, ZEND_STRL("timeout"), CURLOPT_TIMEOUT_MS, IS_DOUBLE))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_TRANSFORM_MS;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("connecttimeout"), CURLOPT_CONNECTTIMEOUT_MS, IS_DOUBLE))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_TRANSFORM_MS;
- Z_DVAL(opt->defval) = 3;
- }
-#if PHP_HTTP_CURL_VERSION(7,36,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("expect_100_timeout"), CURLOPT_EXPECT_100_TIMEOUT_MS, IS_DOUBLE))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_TRANSFORM_MS;
- Z_DVAL(opt->defval) = 1;
- }
-#endif
-
- /* tcp */
- php_http_option_register(registry, ZEND_STRL("tcp_nodelay"), CURLOPT_TCP_NODELAY, IS_BOOL);
-#if PHP_HTTP_CURL_VERSION(7,25,0)
- php_http_option_register(registry, ZEND_STRL("tcp_keepalive"), CURLOPT_TCP_KEEPALIVE, IS_BOOL);
- if ((opt = php_http_option_register(registry, ZEND_STRL("tcp_keepidle"), CURLOPT_TCP_KEEPIDLE, IS_LONG))) {
- Z_LVAL(opt->defval) = 60;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("tcp_keepintvl"), CURLOPT_TCP_KEEPINTVL, IS_LONG))) {
- Z_LVAL(opt->defval) = 60;
- }
-#endif
-
- /* ssl */
- if ((opt = php_http_option_register(registry, ZEND_STRL("ssl"), 0, IS_ARRAY))) {
- registry = &opt->suboptions;
-
- if ((opt = php_http_option_register(registry, ZEND_STRL("cert"), CURLOPT_SSLCERT, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("certtype"), CURLOPT_SSLCERTTYPE, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- ZVAL_STRING(&opt->defval, "PEM", 0);
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("key"), CURLOPT_SSLKEY, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("keytype"), CURLOPT_SSLKEYTYPE, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- ZVAL_STRING(&opt->defval, "PEM", 0);
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("keypasswd"), CURLOPT_SSLKEYPASSWD, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
- php_http_option_register(registry, ZEND_STRL("engine"), CURLOPT_SSLENGINE, IS_STRING);
- php_http_option_register(registry, ZEND_STRL("version"), CURLOPT_SSLVERSION, IS_LONG);
- if ((opt = php_http_option_register(registry, ZEND_STRL("verifypeer"), CURLOPT_SSL_VERIFYPEER, IS_BOOL))) {
- ZVAL_BOOL(&opt->defval, 1);
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("verifyhost"), CURLOPT_SSL_VERIFYHOST, IS_BOOL))) {
- ZVAL_BOOL(&opt->defval, 1);
- opt->setter = php_http_curle_option_set_ssl_verifyhost;
- }
-#if PHP_HTTP_CURL_VERSION(7,41,0)
- php_http_option_register(registry, ZEND_STRL("verifystatus"), CURLOPT_SSL_VERIFYSTATUS, IS_BOOL);
-#endif
- php_http_option_register(registry, ZEND_STRL("cipher_list"), CURLOPT_SSL_CIPHER_LIST, IS_STRING);
- if ((opt = php_http_option_register(registry, ZEND_STRL("cainfo"), CURLOPT_CAINFO, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
-#ifdef PHP_HTTP_CURL_CAINFO
- ZVAL_STRING(&opt->defval, PHP_HTTP_CURL_CAINFO, 0);
-#endif
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("capath"), CURLOPT_CAPATH, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("random_file"), CURLOPT_RANDOM_FILE, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("egdsocket"), CURLOPT_EGDSOCKET, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- }
-#if PHP_HTTP_CURL_VERSION(7,19,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("issuercert"), CURLOPT_ISSUERCERT, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- }
-# ifdef PHP_HTTP_HAVE_OPENSSL
- if ((opt = php_http_option_register(registry, ZEND_STRL("crlfile"), CURLOPT_CRLFILE, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- }
-# endif
-#endif
-#if (PHP_HTTP_CURL_VERSION(7,19,1) && defined(PHP_HTTP_HAVE_OPENSSL)) || (PHP_HTTP_CURL_VERSION(7,34,0) && defined(PHP_HTTP_HAVE_NSS)) || (PHP_HTTP_CURL_VERSION(7,42,0) && defined(PHP_HTTP_HAVE_GNUTLS)) || (PHP_HTTP_CURL_VERSION(7,39,0) && defined(PHP_HTTP_HAVE_GSKIT))
- php_http_option_register(registry, ZEND_STRL("certinfo"), CURLOPT_CERTINFO, IS_BOOL);
-#endif
-#if PHP_HTTP_CURL_VERSION(7,36,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("enable_npn"), CURLOPT_SSL_ENABLE_NPN, IS_BOOL))) {
- ZVAL_BOOL(&opt->defval, 1);
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("enable_alpn"), CURLOPT_SSL_ENABLE_ALPN, IS_BOOL))) {
- ZVAL_BOOL(&opt->defval, 1);
- }
-#endif
-#if PHP_HTTP_CURL_VERSION(7,39,0)
- /* FIXME: see http://curl.haxx.se/libcurl/c/CURLOPT_PINNEDPUBLICKEY.html#AVAILABILITY */
- if ((opt = php_http_option_register(registry, ZEND_STRL("pinned_publickey"), CURLOPT_PINNEDPUBLICKEY, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR;
- }
-#endif
-#if PHP_HTTP_CURL_VERSION(7,21,4) && defined(PHP_HTTP_CURL_TLSAUTH_SRP)
- if ((opt = php_http_option_register(registry, ZEND_STRL("tlsauthtype"), CURLOPT_TLSAUTH_TYPE, IS_LONG))) {
- opt->setter = php_http_curle_option_set_ssl_tlsauthtype;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("tlsauthuser"), CURLOPT_TLSAUTH_USERNAME, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
- if ((opt = php_http_option_register(registry, ZEND_STRL("tlsauthpass"), CURLOPT_TLSAUTH_PASSWORD, IS_STRING))) {
- opt->flags |= PHP_HTTP_CURLE_OPTION_CHECK_STRLEN;
- }
-#endif
-#if PHP_HTTP_CURL_VERSION(7,42,0) && (defined(PHP_HTTP_HAVE_NSS) || defined(PHP_HTTP_HAVE_DARWINSSL))
- php_http_option_register(registry, ZEND_STRL("falsestart"), CURLOPT_SSL_FALSESTART, IS_BOOL);
-#endif
- }
-}
-
-static zval *php_http_curle_get_option(php_http_option_t *opt, HashTable *options, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- zval *option;
-
- if ((option = php_http_option_get(opt, options, NULL))) {
- option = php_http_ztyp(opt->type, option);
- zend_hash_quick_update(&curl->options.cache, opt->name.s, opt->name.l, opt->name.h, &option, sizeof(zval *), NULL);
- }
- return option;
-}
-
-static ZEND_RESULT_CODE php_http_curle_set_option(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_curl_handler_t *curl = userdata;
- CURL *ch = curl->handle;
- zval tmp;
- CURLcode rc = CURLE_OK;
- ZEND_RESULT_CODE rv = SUCCESS;
- TSRMLS_FETCH_FROM_CTX(curl->client->ts);
-
- if (!val) {
- val = &opt->defval;
- }
-
- switch (opt->type) {
- case IS_BOOL:
- if (opt->setter) {
- rv = opt->setter(opt, val, curl);
- } else if (CURLE_OK != curl_easy_setopt(ch, opt->option, (long) Z_BVAL_P(val))) {
- rv = FAILURE;
- }
- break;
-
- case IS_LONG:
- if (opt->setter) {
- rv = opt->setter(opt, val, curl);
- } else if (CURLE_OK != curl_easy_setopt(ch, opt->option, Z_LVAL_P(val))) {
- rv = FAILURE;
- }
- break;
-
- case IS_STRING:
- if (opt->setter) {
- rv = opt->setter(opt, val, curl);
- } else if ((opt->flags & PHP_HTTP_CURLE_OPTION_CHECK_STRLEN) && !Z_STRLEN_P(val)) {
- if (CURLE_OK != (rc = curl_easy_setopt(ch, opt->option, NULL))) {
- rv = FAILURE;
- }
- } else if ((opt->flags & PHP_HTTP_CURLE_OPTION_CHECK_BASEDIR) && Z_STRVAL_P(val) && SUCCESS != php_check_open_basedir(Z_STRVAL_P(val) TSRMLS_CC)) {
- if (CURLE_OK != (rc = curl_easy_setopt(ch, opt->option, NULL))) {
- rv = FAILURE;
- }
- } else if (CURLE_OK != (rc = curl_easy_setopt(ch, opt->option, Z_STRVAL_P(val)))) {
- rv = FAILURE;
- }
- break;
-
- case IS_DOUBLE:
- if (opt->flags & PHP_HTTP_CURLE_OPTION_TRANSFORM_MS) {
- tmp = *val;
- Z_DVAL(tmp) *= 1000;
- val = &tmp;
- }
- if (opt->setter) {
- rv = opt->setter(opt, val, curl);
- } else if (CURLE_OK != curl_easy_setopt(ch, opt->option, (long) Z_DVAL_P(val))) {
- rv = FAILURE;
- }
- break;
-
- case IS_ARRAY:
- if (opt->setter) {
- rv = opt->setter(opt, val, curl);
- } else if (Z_TYPE_P(val) != IS_NULL) {
- rv = php_http_options_apply(&opt->suboptions, Z_ARRVAL_P(val), curl);
- }
- break;
-
- default:
- if (opt->setter) {
- rv = opt->setter(opt, val, curl);
- } else {
- rv = FAILURE;
- }
- break;
- }
- if (rv != SUCCESS) {
- php_error_docref(NULL TSRMLS_CC, E_NOTICE, "Could not set option %s (%s)", opt->name.s, curl_easy_strerror(rc));
- }
- return rv;
-}
-
-#if PHP_HTTP_CURL_VERSION(7,30,0)
-static ZEND_RESULT_CODE php_http_curlm_option_set_pipelining_bl(php_http_option_t *opt, zval *value, void *userdata)
-{
- php_http_client_t *client = userdata;
- php_http_client_curl_t *curl = client->ctx;
- CURLM *ch = curl->handle;
- HashTable tmp_ht;
- char **bl = NULL;
- TSRMLS_FETCH_FROM_CTX(client->ts);
-
- /* array of char *, ending with a NULL */
- if (value && Z_TYPE_P(value) != IS_NULL) {
- zval **entry;
- HashPosition pos;
- HashTable *ht = HASH_OF(value);
- int c = zend_hash_num_elements(ht);
- char **ptr = ecalloc(c + 1, sizeof(char *));
-
- bl = ptr;
-
- zend_hash_init(&tmp_ht, c, NULL, ZVAL_PTR_DTOR, 0);
- array_join(ht, &tmp_ht, 0, ARRAY_JOIN_STRINGIFY);
-
- FOREACH_HASH_VAL(pos, &tmp_ht, entry) {
- *ptr++ = Z_STRVAL_PP(entry);
- }
- }
-
- if (CURLM_OK != curl_multi_setopt(ch, opt->option, bl)) {
- if (bl) {
- efree(bl);
- zend_hash_destroy(&tmp_ht);
- }
- return FAILURE;
- }
-
- if (bl) {
- efree(bl);
- zend_hash_destroy(&tmp_ht);
- }
- return SUCCESS;
-}
-#endif
-
-#if PHP_HTTP_HAVE_EVENT
-static inline ZEND_RESULT_CODE php_http_curlm_use_eventloop(php_http_client_t *h, zend_bool enable)
-{
- php_http_client_curl_t *curl = h->ctx;
-
- if ((curl->useevents = enable)) {
- if (!curl->evbase) {
- curl->evbase = event_base_new();
- }
- if (!curl->timeout) {
- curl->timeout = ecalloc(1, sizeof(struct event));
- }
- curl_multi_setopt(curl->handle, CURLMOPT_SOCKETDATA, h);
- curl_multi_setopt(curl->handle, CURLMOPT_SOCKETFUNCTION, php_http_curlm_socket_callback);
- curl_multi_setopt(curl->handle, CURLMOPT_TIMERDATA, h);
- curl_multi_setopt(curl->handle, CURLMOPT_TIMERFUNCTION, php_http_curlm_timer_callback);
- } else {
- curl_multi_setopt(curl->handle, CURLMOPT_SOCKETDATA, NULL);
- curl_multi_setopt(curl->handle, CURLMOPT_SOCKETFUNCTION, NULL);
- curl_multi_setopt(curl->handle, CURLMOPT_TIMERDATA, NULL);
- curl_multi_setopt(curl->handle, CURLMOPT_TIMERFUNCTION, NULL);
- }
-
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_curlm_option_set_use_eventloop(php_http_option_t *opt, zval *value, void *userdata)
-{
- php_http_client_t *client = userdata;
-
- return php_http_curlm_use_eventloop(client, value && Z_BVAL_P(value));
-}
-#endif
-
-static void php_http_curlm_options_init(php_http_options_t *registry TSRMLS_DC)
-{
- php_http_option_t *opt;
-
- /* set size of connection cache */
- if ((opt = php_http_option_register(registry, ZEND_STRL("maxconnects"), CURLMOPT_MAXCONNECTS, IS_LONG))) {
- /* -1 == default, 0 == unlimited */
- ZVAL_LONG(&opt->defval, -1);
- }
- /* set max number of connections to a single host */
-#if PHP_HTTP_CURL_VERSION(7,30,0)
- php_http_option_register(registry, ZEND_STRL("max_host_connections"), CURLMOPT_MAX_HOST_CONNECTIONS, IS_LONG);
-#endif
- /* maximum number of requests in a pipeline */
-#if PHP_HTTP_CURL_VERSION(7,30,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("max_pipeline_length"), CURLMOPT_MAX_PIPELINE_LENGTH, IS_LONG))) {
- ZVAL_LONG(&opt->defval, 5);
- }
-#endif
- /* max simultaneously open connections */
-#if PHP_HTTP_CURL_VERSION(7,30,0)
- php_http_option_register(registry, ZEND_STRL("max_total_connections"), CURLMOPT_MAX_TOTAL_CONNECTIONS, IS_LONG);
-#endif
- /* enable/disable HTTP pipelining */
- php_http_option_register(registry, ZEND_STRL("pipelining"), CURLMOPT_PIPELINING, IS_BOOL);
- /* chunk length threshold for pipelining */
-#if PHP_HTTP_CURL_VERSION(7,30,0)
- php_http_option_register(registry, ZEND_STRL("chunk_length_penalty_size"), CURLMOPT_CHUNK_LENGTH_PENALTY_SIZE, IS_LONG);
-#endif
- /* size threshold for pipelining penalty */
-#if PHP_HTTP_CURL_VERSION(7,30,0)
- php_http_option_register(registry, ZEND_STRL("content_length_penalty_size"), CURLMOPT_CONTENT_LENGTH_PENALTY_SIZE, IS_LONG);
-#endif
- /* pipelining server blacklist */
-#if PHP_HTTP_CURL_VERSION(7,30,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("pipelining_server_bl"), CURLMOPT_PIPELINING_SERVER_BL, IS_ARRAY))) {
- opt->setter = php_http_curlm_option_set_pipelining_bl;
- }
-#endif
- /* pipelining host blacklist */
-#if PHP_HTTP_CURL_VERSION(7,30,0)
- if ((opt = php_http_option_register(registry, ZEND_STRL("pipelining_site_bl"), CURLMOPT_PIPELINING_SITE_BL, IS_ARRAY))) {
- opt->setter = php_http_curlm_option_set_pipelining_bl;
- }
-#endif
- /* events */
-#if PHP_HTTP_HAVE_EVENT
- if ((opt = php_http_option_register(registry, ZEND_STRL("use_eventloop"), 0, IS_BOOL))) {
- opt->setter = php_http_curlm_option_set_use_eventloop;
- }
-#endif
-}
-
-static ZEND_RESULT_CODE php_http_curlm_set_option(php_http_option_t *opt, zval *val, void *userdata)
-{
- php_http_client_t *client = userdata;
- php_http_client_curl_t *curl = client->ctx;
- CURLM *ch = curl->handle;
- zval *orig = val;
- CURLMcode rc = CURLM_UNKNOWN_OPTION;
- ZEND_RESULT_CODE rv = SUCCESS;
- TSRMLS_FETCH_FROM_CTX(client->ts);
-
- if (!val) {
- val = &opt->defval;
- } else if (opt->type && Z_TYPE_P(val) != opt->type && !(Z_TYPE_P(val) == IS_NULL && opt->type == IS_ARRAY)) {
- val = php_http_ztyp(opt->type, val);
- }
-
- if (opt->setter) {
- rv = opt->setter(opt, val, client);
- } else {
- switch (opt->type) {
- case IS_BOOL:
- if (CURLM_OK != (rc = curl_multi_setopt(ch, opt->option, (long) Z_BVAL_P(val)))) {
- rv = FAILURE;
- }
- break;
- case IS_LONG:
- if (CURLM_OK != (rc = curl_multi_setopt(ch, opt->option, Z_LVAL_P(val)))) {
- rv = FAILURE;
- }
- break;
- default:
- rv = FAILURE;
- break;
- }
- }
-
- if (val && val != orig && val != &opt->defval) {
- zval_ptr_dtor(&val);
- }
-
- if (rv != SUCCESS) {
- php_error_docref(NULL TSRMLS_CC, E_NOTICE, "Could not set option %s (%s)", opt->name.s, curl_easy_strerror(rc));
- }
- return rv;
-}
-
-/* client ops */
-
-static ZEND_RESULT_CODE php_http_client_curl_handler_reset(php_http_client_curl_handler_t *curl)
-{
- CURL *ch = curl->handle;
- php_http_curle_storage_t *st;
-
- if ((st = php_http_curle_get_storage(ch))) {
- if (st->url) {
- pefree(st->url, 1);
- st->url = NULL;
- }
- if (st->cookiestore) {
- pefree(st->cookiestore, 1);
- st->cookiestore = NULL;
- }
- st->errorbuffer[0] = '\0';
- }
-
- curl_easy_setopt(ch, CURLOPT_URL, NULL);
- curl_easy_setopt(ch, CURLOPT_CUSTOMREQUEST, NULL);
- curl_easy_setopt(ch, CURLOPT_HTTPGET, 1L);
- curl_easy_setopt(ch, CURLOPT_NOBODY, 0L);
- /* libcurl < 7.19.6 does not clear auth info with USERPWD set to NULL */
-#if PHP_HTTP_CURL_VERSION(7,19,1)
- curl_easy_setopt(ch, CURLOPT_PROXYUSERNAME, NULL);
- curl_easy_setopt(ch, CURLOPT_PROXYPASSWORD, NULL);
- curl_easy_setopt(ch, CURLOPT_USERNAME, NULL);
- curl_easy_setopt(ch, CURLOPT_PASSWORD, NULL);
-#endif
-
-#if PHP_HTTP_CURL_VERSION(7,21,3)
- if (curl->options.resolve) {
- curl_slist_free_all(curl->options.resolve);
- curl->options.resolve = NULL;
- }
-#endif
- curl->options.retry.count = 0;
- curl->options.retry.delay = 0;
- curl->options.redirects = 0;
- curl->options.encode_cookies = 1;
-
- if (curl->options.headers) {
- curl_slist_free_all(curl->options.headers);
- curl->options.headers = NULL;
- }
- if (curl->options.proxyheaders) {
- curl_slist_free_all(curl->options.proxyheaders);
- curl->options.proxyheaders = NULL;
- }
-
- php_http_buffer_reset(&curl->options.cookies);
- php_http_buffer_reset(&curl->options.ranges);
-
- return SUCCESS;
-}
-
-static php_http_client_curl_handler_t *php_http_client_curl_handler_init(php_http_client_t *h, php_resource_factory_t *rf)
-{
- void *handle;
- php_http_client_curl_handler_t *handler;
- TSRMLS_FETCH_FROM_CTX(h->ts);
-
- if (!(handle = php_resource_factory_handle_ctor(rf, NULL TSRMLS_CC))) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Failed to initialize curl handle");
- return NULL;
- }
-
- handler = ecalloc(1, sizeof(*handler));
- handler->rf = rf;
- handler->client = h;
- handler->handle = handle;
- handler->response.body = php_http_message_body_init(NULL, NULL TSRMLS_CC);
- php_http_buffer_init(&handler->response.headers);
- php_http_buffer_init(&handler->options.cookies);
- php_http_buffer_init(&handler->options.ranges);
- zend_hash_init(&handler->options.cache, 0, NULL, ZVAL_PTR_DTOR, 0);
-
-#if defined(ZTS)
- curl_easy_setopt(handle, CURLOPT_NOSIGNAL, 1L);
-#endif
- curl_easy_setopt(handle, CURLOPT_HEADER, 0L);
- curl_easy_setopt(handle, CURLOPT_FILETIME, 1L);
- curl_easy_setopt(handle, CURLOPT_AUTOREFERER, 1L);
- curl_easy_setopt(handle, CURLOPT_VERBOSE, 1L);
- curl_easy_setopt(handle, CURLOPT_NOPROGRESS, 0L);
- curl_easy_setopt(handle, CURLOPT_HEADERFUNCTION, php_http_curle_header_callback);
- curl_easy_setopt(handle, CURLOPT_WRITEFUNCTION, php_http_curle_body_callback);
- curl_easy_setopt(handle, CURLOPT_DEBUGFUNCTION, php_http_curle_raw_callback);
- curl_easy_setopt(handle, CURLOPT_READFUNCTION, php_http_curle_read_callback);
- curl_easy_setopt(handle, CURLOPT_SEEKFUNCTION, php_http_curle_seek_callback);
-#if PHP_HTTP_CURL_VERSION(7,32,0)
- curl_easy_setopt(handle, CURLOPT_XFERINFOFUNCTION, php_http_curle_xferinfo_callback);
- curl_easy_setopt(handle, CURLOPT_XFERINFODATA, handler);
-#else
- curl_easy_setopt(handle, CURLOPT_PROGRESSFUNCTION, php_http_curle_progress_callback);
- curl_easy_setopt(handle, CURLOPT_PROGRESSDATA, handler);
-#endif
- curl_easy_setopt(handle, CURLOPT_DEBUGDATA, handler);
- curl_easy_setopt(handle, CURLOPT_WRITEDATA, handler);
- curl_easy_setopt(handle, CURLOPT_HEADERDATA, handler);
-
- php_http_client_curl_handler_reset(handler);
-
- return handler;
-}
-
-
-static ZEND_RESULT_CODE php_http_client_curl_handler_prepare(php_http_client_curl_handler_t *curl, php_http_client_enqueue_t *enqueue)
-{
- size_t body_size;
- php_http_message_t *msg = enqueue->request;
- php_http_curle_storage_t *storage = php_http_curle_get_storage(curl->handle);
- TSRMLS_FETCH_FROM_CTX(curl->client->ts);
-
- /* request url */
- if (!PHP_HTTP_INFO(msg).request.url) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Cannot request empty URL");
- return FAILURE;
- }
- storage->errorbuffer[0] = '\0';
- if (storage->url) {
- pefree(storage->url, 1);
- }
- php_http_url_to_string(PHP_HTTP_INFO(msg).request.url, &storage->url, NULL, 1);
- curl_easy_setopt(curl->handle, CURLOPT_URL, storage->url);
-
- /* apply options */
- php_http_options_apply(&php_http_curle_options, enqueue->options, curl);
-
- /* request headers */
- php_http_message_update_headers(msg);
- if (zend_hash_num_elements(&msg->hdrs)) {
- php_http_array_hashkey_t header_key = php_http_array_hashkey_init(0);
- zval **header_val, *header_cpy;
- HashPosition pos;
- php_http_buffer_t header;
-#if !PHP_HTTP_CURL_VERSION(7,23,0)
- zval **ct = NULL;
-
- zend_hash_find(&msg->hdrs, ZEND_STRS("Content-Length"), (void *) &ct);
-#endif
-
- php_http_buffer_init(&header);
- FOREACH_HASH_KEYVAL(pos, &msg->hdrs, header_key, header_val) {
- if (header_key.type == HASH_KEY_IS_STRING) {
-#if !PHP_HTTP_CURL_VERSION(7,23,0)
- /* avoid duplicate content-length header */
- if (ct && *ct == *header_val) {
- continue;
- }
-#endif
- header_cpy = php_http_ztyp(IS_STRING, *header_val);
- php_http_buffer_appendf(&header, "%s: %s", header_key.str, Z_STRVAL_P(header_cpy));
- php_http_buffer_fix(&header);
- curl->options.headers = curl_slist_append(curl->options.headers, header.data);
- php_http_buffer_reset(&header);
-
- zval_ptr_dtor(&header_cpy);
- }
- }
- php_http_buffer_dtor(&header);
- }
- curl_easy_setopt(curl->handle, CURLOPT_HTTPHEADER, curl->options.headers);
-
- /* attach request body */
- if ((body_size = php_http_message_body_size(msg->body))) {
- /* RFC2616, section 4.3 (para. 4) states that »a message-body MUST NOT be included in a request if the
- * specification of the request method (section 5.1.1) does not allow sending an entity-body in request.«
- * Following the clause in section 5.1.1 (para. 2) that request methods »MUST be implemented with the
- * same semantics as those specified in section 9« reveal that not any single defined HTTP/1.1 method
- * does not allow a request body.
- */
- php_stream_rewind(php_http_message_body_stream(msg->body));
- curl_easy_setopt(curl->handle, CURLOPT_SEEKDATA, msg->body);
- curl_easy_setopt(curl->handle, CURLOPT_READDATA, msg->body);
- curl_easy_setopt(curl->handle, CURLOPT_INFILESIZE, body_size);
- curl_easy_setopt(curl->handle, CURLOPT_POSTFIELDSIZE, body_size);
- curl_easy_setopt(curl->handle, CURLOPT_POST, 1L);
- } else {
- curl_easy_setopt(curl->handle, CURLOPT_SEEKDATA, NULL);
- curl_easy_setopt(curl->handle, CURLOPT_READDATA, NULL);
- curl_easy_setopt(curl->handle, CURLOPT_INFILESIZE, 0L);
- curl_easy_setopt(curl->handle, CURLOPT_POSTFIELDSIZE, 0L);
- }
-
- /*
- * Always use CUSTOMREQUEST, else curl won't send any request body for GET etc.
- * See e.g. bug #69313.
- *
- * Here's what curl does:
- * - CURLOPT_HTTPGET: ignore request body
- * - CURLOPT_UPLOAD: set "Expect: 100-continue" header
- * - CURLOPT_POST: set "Content-Type: application/x-www-form-urlencoded" header
- * Now select the least bad.
- *
- * See also https://tools.ietf.org/html/rfc7231#section-5.1.1
- */
- if (PHP_HTTP_INFO(msg).request.method) {
- switch(php_http_select_str(PHP_HTTP_INFO(msg).request.method, 2, "HEAD", "PUT")) {
- case 0:
- curl_easy_setopt(curl->handle, CURLOPT_NOBODY, 1L);
- break;
- case 1:
- curl_easy_setopt(curl->handle, CURLOPT_UPLOAD, 1L);
- break;
- default:
- curl_easy_setopt(curl->handle, CURLOPT_CUSTOMREQUEST, PHP_HTTP_INFO(msg).request.method);
- }
- } else {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Cannot use empty request method");
- return FAILURE;
- }
-
- return SUCCESS;
-}
-
-static void php_http_client_curl_handler_clear(php_http_client_curl_handler_t *handler)
-{
- curl_easy_setopt(handler->handle, CURLOPT_NOPROGRESS, 1L);
-#if PHP_HTTP_CURL_VERSION(7,32,0)
- curl_easy_setopt(handler->handle, CURLOPT_XFERINFOFUNCTION, NULL);
-#else
- curl_easy_setopt(handler->handle, CURLOPT_PROGRESSFUNCTION, NULL);
-#endif
- curl_easy_setopt(handler->handle, CURLOPT_VERBOSE, 0L);
- curl_easy_setopt(handler->handle, CURLOPT_DEBUGFUNCTION, NULL);
-}
-
-static void php_http_client_curl_handler_dtor(php_http_client_curl_handler_t *handler)
-{
- TSRMLS_FETCH_FROM_CTX(handler->client->ts);
-
- php_http_client_curl_handler_clear(handler);
-
- php_resource_factory_handle_dtor(handler->rf, handler->handle TSRMLS_CC);
- php_resource_factory_free(&handler->rf);
-
- php_http_message_body_free(&handler->response.body);
- php_http_buffer_dtor(&handler->response.headers);
- php_http_buffer_dtor(&handler->options.ranges);
- php_http_buffer_dtor(&handler->options.cookies);
- zend_hash_destroy(&handler->options.cache);
-
- if (handler->options.headers) {
- curl_slist_free_all(handler->options.headers);
- handler->options.headers = NULL;
- }
-
- efree(handler);
-}
-
-static php_http_client_t *php_http_client_curl_init(php_http_client_t *h, void *handle)
-{
- php_http_client_curl_t *curl;
- TSRMLS_FETCH_FROM_CTX(h->ts);
-
- if (!handle && !(handle = php_resource_factory_handle_ctor(h->rf, NULL TSRMLS_CC))) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Failed to initialize curl handle");
- return NULL;
- }
-
- curl = ecalloc(1, sizeof(*curl));
- curl->handle = handle;
- curl->unfinished = 0;
- h->ctx = curl;
-
- return h;
-}
-
-static void php_http_client_curl_dtor(php_http_client_t *h)
-{
- php_http_client_curl_t *curl = h->ctx;
- TSRMLS_FETCH_FROM_CTX(h->ts);
-
-#if PHP_HTTP_HAVE_EVENT
- if (curl->timeout) {
- if (event_initialized(curl->timeout) && event_pending(curl->timeout, EV_TIMEOUT, NULL)) {
- event_del(curl->timeout);
- }
- efree(curl->timeout);
- curl->timeout = NULL;
- }
- if (curl->evbase) {
- event_base_free(curl->evbase);
- curl->evbase = NULL;
- }
-#endif
- curl->unfinished = 0;
-
- php_resource_factory_handle_dtor(h->rf, curl->handle TSRMLS_CC);
-
- efree(curl);
- h->ctx = NULL;
-}
-
-static void queue_dtor(php_http_client_enqueue_t *e)
-{
- php_http_client_curl_handler_t *handler = e->opaque;
-
- if (handler->queue.dtor) {
- e->opaque = handler->queue.opaque;
- handler->queue.dtor(e);
- }
- php_http_client_curl_handler_dtor(handler);
-}
-
-static php_resource_factory_t *create_rf(php_http_client_t *h, php_http_client_enqueue_t *enqueue TSRMLS_DC)
-{
- php_persistent_handle_factory_t *pf = NULL;
- php_resource_factory_t *rf = NULL;
- php_http_url_t *url = enqueue->request->http.info.request.url;
-
- if (!url || (!url->host && !url->path)) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Cannot request empty URL");
- return NULL;
- }
-
- /* only if the client itself is setup for persistence */
- if (php_resource_factory_is_persistent(h->rf)) {
- char *id_str = NULL;
- size_t id_len;
- int port = url->port ? url->port : 80;
- zval **zport;
-
- if (SUCCESS == zend_hash_find(enqueue->options, ZEND_STRS("port"), (void *) &zport)) {
- zval *zcpy = php_http_ztyp(IS_LONG, *zport);
-
- if (Z_LVAL_P(zcpy)) {
- port = Z_LVAL_P(zcpy);
- }
- zval_ptr_dtor(&zcpy);
- }
-
- id_len = spprintf(&id_str, 0, "%s:%d", STR_PTR(url->host), port);
- pf = php_persistent_handle_concede(NULL, ZEND_STRL("http\\Client\\Curl\\Request"), id_str, id_len, NULL, NULL TSRMLS_CC);
- efree(id_str);
- }
-
- if (pf) {
- rf = php_persistent_handle_resource_factory_init(NULL, pf);
- } else {
- rf = php_resource_factory_init(NULL, &php_http_curle_resource_factory_ops, NULL, NULL);
- }
-
- return rf;
-}
-
-static ZEND_RESULT_CODE php_http_client_curl_enqueue(php_http_client_t *h, php_http_client_enqueue_t *enqueue)
-{
- CURLMcode rs;
- php_http_client_curl_t *curl = h->ctx;
- php_http_client_curl_handler_t *handler;
- php_http_client_progress_state_t *progress;
- php_resource_factory_t *rf;
- TSRMLS_FETCH_FROM_CTX(h->ts);
-
- rf = create_rf(h, enqueue TSRMLS_CC);
- if (!rf) {
- return FAILURE;
- }
-
- handler = php_http_client_curl_handler_init(h, rf);
- if (!handler) {
- return FAILURE;
- }
-
- if (SUCCESS != php_http_client_curl_handler_prepare(handler, enqueue)) {
- php_http_client_curl_handler_dtor(handler);
- return FAILURE;
- }
-
- handler->queue = *enqueue;
- enqueue->opaque = handler;
- enqueue->dtor = queue_dtor;
-
- if (CURLM_OK == (rs = curl_multi_add_handle(curl->handle, handler->handle))) {
- zend_llist_add_element(&h->requests, enqueue);
- ++curl->unfinished;
-
- if (h->callback.progress.func && SUCCESS == php_http_client_getopt(h, PHP_HTTP_CLIENT_OPT_PROGRESS_INFO, enqueue->request, &progress)) {
- progress->info = "start";
- h->callback.progress.func(h->callback.progress.arg, h, &handler->queue, progress);
- progress->started = 1;
- }
-
- return SUCCESS;
- } else {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not enqueue request: %s", curl_multi_strerror(rs));
- return FAILURE;
- }
-}
-
-static ZEND_RESULT_CODE php_http_client_curl_dequeue(php_http_client_t *h, php_http_client_enqueue_t *enqueue)
-{
- CURLMcode rs;
- php_http_client_curl_t *curl = h->ctx;
- php_http_client_curl_handler_t *handler = enqueue->opaque;
- TSRMLS_FETCH_FROM_CTX(h->ts);
-
- php_http_client_curl_handler_clear(handler);
- if (CURLM_OK == (rs = curl_multi_remove_handle(curl->handle, handler->handle))) {
- zend_llist_del_element(&h->requests, handler->handle, (int (*)(void *, void *)) compare_queue);
- return SUCCESS;
- } else {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not dequeue request: %s", curl_multi_strerror(rs));
- }
-
- return FAILURE;
-}
-
-static void php_http_client_curl_reset(php_http_client_t *h)
-{
- zend_llist_element *next_el, *this_el;
-
- for (this_el = h->requests.head; this_el; this_el = next_el) {
- next_el = this_el->next;
- php_http_client_curl_dequeue(h, (void *) this_el->data);
- }
-}
-
-static inline void php_http_client_curl_get_timeout(php_http_client_curl_t *curl, long max_tout, struct timeval *timeout)
-{
- if ((CURLM_OK == curl_multi_timeout(curl->handle, &max_tout)) && (max_tout > 0)) {
- timeout->tv_sec = max_tout / 1000;
- timeout->tv_usec = (max_tout % 1000) * 1000;
- } else {
- timeout->tv_sec = 0;
- timeout->tv_usec = 1000;
- }
-}
-
-#ifdef PHP_WIN32
-# define SELECT_ERROR SOCKET_ERROR
-#else
-# define SELECT_ERROR -1
-#endif
-
-static ZEND_RESULT_CODE php_http_client_curl_wait(php_http_client_t *h, struct timeval *custom_timeout)
-{
- int MAX;
- fd_set R, W, E;
- struct timeval timeout;
- php_http_client_curl_t *curl = h->ctx;
-
-#if PHP_HTTP_HAVE_EVENT
- if (curl->useevents) {
- if (!event_initialized(curl->timeout)) {
- event_assign(curl->timeout, curl->evbase, CURL_SOCKET_TIMEOUT, 0, php_http_curlm_timeout_callback, h);
- } else if (custom_timeout && timerisset(custom_timeout)) {
- event_add(curl->timeout, custom_timeout);
- } else if (!event_pending(curl->timeout, EV_TIMEOUT, NULL)) {
- php_http_client_curl_get_timeout(curl, 1000, &timeout);
- event_add(curl->timeout, &timeout);
- }
-
- event_base_loop(curl->evbase, EVLOOP_ONCE);
-
- return SUCCESS;
- }
-#endif
-
- FD_ZERO(&R);
- FD_ZERO(&W);
- FD_ZERO(&E);
-
- if (CURLM_OK == curl_multi_fdset(curl->handle, &R, &W, &E, &MAX)) {
- if (custom_timeout && timerisset(custom_timeout)) {
- timeout = *custom_timeout;
- } else {
- php_http_client_curl_get_timeout(curl, 1000, &timeout);
- }
-
- if (MAX == -1) {
- php_http_sleep((double) timeout.tv_sec + (double) (timeout.tv_usec / PHP_HTTP_MCROSEC));
- return SUCCESS;
- } else if (SELECT_ERROR != select(MAX + 1, &R, &W, &E, &timeout)) {
- return SUCCESS;
- }
- }
- return FAILURE;
-}
-
-static int php_http_client_curl_once(php_http_client_t *h)
-{
- php_http_client_curl_t *curl = h->ctx;
-
-#if PHP_HTTP_HAVE_EVENT
- if (curl->useevents) {
- event_base_loop(curl->evbase, EVLOOP_NONBLOCK);
- } else
-#endif
- while (CURLM_CALL_MULTI_PERFORM == curl_multi_perform(curl->handle, &curl->unfinished));
-
- php_http_curlm_responsehandler(h);
-
- return curl->unfinished;
-
-}
-
-static ZEND_RESULT_CODE php_http_client_curl_exec(php_http_client_t *h)
-{
-#if PHP_HTTP_HAVE_EVENT
- php_http_client_curl_t *curl = h->ctx;
-#endif
- TSRMLS_FETCH_FROM_CTX(h->ts);
-
-#if PHP_HTTP_HAVE_EVENT
- if (curl->useevents) {
- php_http_curlm_timeout_callback(CURL_SOCKET_TIMEOUT, /*EV_READ|EV_WRITE*/0, h);
- do {
- int ev_rc = event_base_dispatch(curl->evbase);
-
-#if DBG_EVENTS
- fprintf(stderr, "%c", "X.0"[ev_rc+1]);
-#endif
-
- if (ev_rc < 0) {
- php_error_docref(NULL TSRMLS_CC, E_ERROR, "Error in event_base_dispatch()");
- return FAILURE;
- }
- } while (curl->unfinished && !EG(exception));
- } else
-#endif
- {
- while (php_http_client_curl_once(h) && !EG(exception)) {
- if (SUCCESS != php_http_client_curl_wait(h, NULL)) {
-#ifdef PHP_WIN32
- /* see http://msdn.microsoft.com/library/en-us/winsock/winsock/windows_sockets_error_codes_2.asp */
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "WinSock error: %d", WSAGetLastError());
-#else
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", strerror(errno));
-#endif
- return FAILURE;
- }
- }
- }
-
- return SUCCESS;
-}
-
-static ZEND_RESULT_CODE php_http_client_curl_setopt(php_http_client_t *h, php_http_client_setopt_opt_t opt, void *arg)
-{
- php_http_client_curl_t *curl = h->ctx;
-
- switch (opt) {
- case PHP_HTTP_CLIENT_OPT_CONFIGURATION:
- return php_http_options_apply(&php_http_curlm_options, (HashTable *) arg, h);
- break;
-
- case PHP_HTTP_CLIENT_OPT_ENABLE_PIPELINING:
- if (CURLM_OK != curl_multi_setopt(curl->handle, CURLMOPT_PIPELINING, (long) *((zend_bool *) arg))) {
- return FAILURE;
- }
- break;
-
- case PHP_HTTP_CLIENT_OPT_USE_EVENTS:
-#if PHP_HTTP_HAVE_EVENT
- return php_http_curlm_use_eventloop(h, *(zend_bool *) arg);
- break;
-#endif
-
- default:
- return FAILURE;
- }
- return SUCCESS;
-}
-
-static int apply_available_options(void *pDest TSRMLS_DC, int num_args, va_list args, zend_hash_key *hash_key)
-{
- php_http_option_t *opt = pDest;
- HashTable *ht;
- zval *entry;
- int c;
-
- ht = va_arg(args, HashTable*);
-
- MAKE_STD_ZVAL(entry);
-
- if ((c = zend_hash_num_elements(&opt->suboptions.options))) {
- array_init_size(entry, c);
- zend_hash_apply_with_arguments(&opt->suboptions.options TSRMLS_CC, apply_available_options, 1, Z_ARRVAL_P(entry));
- } else {
- /* catch deliberate NULL options */
- if (Z_TYPE(opt->defval) == IS_STRING && !Z_STRVAL(opt->defval)) {
- ZVAL_NULL(entry);
- } else {
- ZVAL_COPY_VALUE(entry, &opt->defval);
- zval_copy_ctor(entry);
- }
- }
-
- if (hash_key->nKeyLength) {
- zend_hash_quick_update(ht, hash_key->arKey, hash_key->nKeyLength, hash_key->h, (void *) &entry, sizeof(zval *), NULL);
- } else {
- zend_hash_index_update(ht, hash_key->h, (void *) &entry, sizeof(zval *), NULL);
- }
-
- return ZEND_HASH_APPLY_KEEP;
-}
-
-static ZEND_RESULT_CODE php_http_client_curl_getopt(php_http_client_t *h, php_http_client_getopt_opt_t opt, void *arg, void **res)
-{
- php_http_client_enqueue_t *enqueue;
- TSRMLS_FETCH_FROM_CTX(h->ts);
-
- switch (opt) {
- case PHP_HTTP_CLIENT_OPT_PROGRESS_INFO:
- if ((enqueue = php_http_client_enqueued(h, arg, NULL))) {
- php_http_client_curl_handler_t *handler = enqueue->opaque;
-
- *((php_http_client_progress_state_t **) res) = &handler->progress;
- return SUCCESS;
- }
- break;
-
- case PHP_HTTP_CLIENT_OPT_TRANSFER_INFO:
- if ((enqueue = php_http_client_enqueued(h, arg, NULL))) {
- php_http_client_curl_handler_t *handler = enqueue->opaque;
-
- php_http_curle_get_info(handler->handle, *(HashTable **) res);
- return SUCCESS;
- }
- break;
-
- case PHP_HTTP_CLIENT_OPT_AVAILABLE_OPTIONS:
- zend_hash_apply_with_arguments(&php_http_curle_options.options TSRMLS_CC, apply_available_options, 1, *(HashTable **) res);
- break;
-
- case PHP_HTTP_CLIENT_OPT_AVAILABLE_CONFIGURATION:
- zend_hash_apply_with_arguments(&php_http_curlm_options.options TSRMLS_CC, apply_available_options, 1, *(HashTable **) res);
- break;
-
- default:
- break;
- }
-
- return FAILURE;
-}
-
-static php_http_client_ops_t php_http_client_curl_ops = {
- &php_http_curlm_resource_factory_ops,
- php_http_client_curl_init,
- NULL /* copy */,
- php_http_client_curl_dtor,
- php_http_client_curl_reset,
- php_http_client_curl_exec,
- php_http_client_curl_wait,
- php_http_client_curl_once,
- php_http_client_curl_enqueue,
- php_http_client_curl_dequeue,
- php_http_client_curl_setopt,
- php_http_client_curl_getopt
-};
-
-php_http_client_ops_t *php_http_client_curl_get_ops(void)
-{
- return &php_http_client_curl_ops;
-}
-
-PHP_MINIT_FUNCTION(http_client_curl)
-{
- php_http_options_t *options;
- php_http_client_driver_t driver = {
- ZEND_STRL("curl"),
- &php_http_client_curl_ops
- };
-
- if (SUCCESS != php_http_client_driver_add(&driver)) {
- return FAILURE;
- }
-
- if (SUCCESS != php_persistent_handle_provide(ZEND_STRL("http\\Client\\Curl"), &php_http_curlm_resource_factory_ops, NULL, NULL TSRMLS_CC)) {
- return FAILURE;
- }
- if (SUCCESS != php_persistent_handle_provide(ZEND_STRL("http\\Client\\Curl\\Request"), &php_http_curle_resource_factory_ops, NULL, NULL TSRMLS_CC)) {
- return FAILURE;
- }
-
- if ((options = php_http_options_init(&php_http_curle_options, 1))) {
- options->getter = php_http_curle_get_option;
- options->setter = php_http_curle_set_option;
-
- php_http_curle_options_init(options TSRMLS_CC);
- }
- if ((options = php_http_options_init(&php_http_curlm_options, 1))) {
- options->getter = php_http_option_get;
- options->setter = php_http_curlm_set_option;
-
- php_http_curlm_options_init(options TSRMLS_CC);
- }
-
- /*
- * HTTP Protocol Version Constants
- */
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "HTTP_VERSION_1_0", CURL_HTTP_VERSION_1_0, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "HTTP_VERSION_1_1", CURL_HTTP_VERSION_1_1, CONST_CS|CONST_PERSISTENT);
-#if PHP_HTTP_CURL_VERSION(7,33,0)
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "HTTP_VERSION_2_0", CURL_HTTP_VERSION_2_0, CONST_CS|CONST_PERSISTENT);
-#endif
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "HTTP_VERSION_ANY", CURL_HTTP_VERSION_NONE, CONST_CS|CONST_PERSISTENT);
-
- /*
- * SSL Version Constants
- */
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_TLSv1", CURL_SSLVERSION_TLSv1, CONST_CS|CONST_PERSISTENT);
-#if PHP_HTTP_CURL_VERSION(7,34,0)
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_TLSv1_0", CURL_SSLVERSION_TLSv1_0, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_TLSv1_1", CURL_SSLVERSION_TLSv1_1, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_TLSv1_2", CURL_SSLVERSION_TLSv1_2, CONST_CS|CONST_PERSISTENT);
-#endif
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_SSLv2", CURL_SSLVERSION_SSLv2, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_SSLv3", CURL_SSLVERSION_SSLv3, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "SSL_VERSION_ANY", CURL_SSLVERSION_DEFAULT, CONST_CS|CONST_PERSISTENT);
-#if PHP_HTTP_CURL_VERSION(7,21,4) && defined(PHP_HTTP_CURL_TLSAUTH_SRP)
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "TLSAUTH_SRP", CURL_TLSAUTH_SRP, CONST_CS|CONST_PERSISTENT);
-#endif
-
- /*
- * DNS IPvX resolving
- */
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "IPRESOLVE_V4", CURL_IPRESOLVE_V4, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "IPRESOLVE_V6", CURL_IPRESOLVE_V6, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "IPRESOLVE_ANY", CURL_IPRESOLVE_WHATEVER, CONST_CS|CONST_PERSISTENT);
-
- /*
- * Auth Constants
- */
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_BASIC", CURLAUTH_BASIC, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_DIGEST", CURLAUTH_DIGEST, CONST_CS|CONST_PERSISTENT);
-#if PHP_HTTP_CURL_VERSION(7,19,3)
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_DIGEST_IE", CURLAUTH_DIGEST_IE, CONST_CS|CONST_PERSISTENT);
-#endif
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_NTLM", CURLAUTH_NTLM, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_GSSNEG", CURLAUTH_GSSNEGOTIATE, CONST_CS|CONST_PERSISTENT);
-#if PHP_HTTP_CURL_VERSION(7,38,0)
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_SPNEGO", CURLAUTH_NEGOTIATE, CONST_CS|CONST_PERSISTENT);
-#endif
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "AUTH_ANY", CURLAUTH_ANY, CONST_CS|CONST_PERSISTENT);
-
- /*
- * Proxy Type Constants
- */
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_SOCKS4", CURLPROXY_SOCKS4, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_SOCKS4A", CURLPROXY_SOCKS5, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_SOCKS5_HOSTNAME", CURLPROXY_SOCKS5, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_SOCKS5", CURLPROXY_SOCKS5, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_HTTP", CURLPROXY_HTTP, CONST_CS|CONST_PERSISTENT);
-#if PHP_HTTP_CURL_VERSION(7,19,4)
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "PROXY_HTTP_1_0", CURLPROXY_HTTP_1_0, CONST_CS|CONST_PERSISTENT);
-#endif
-
- /*
- * Post Redirection Constants
- */
-#if PHP_HTTP_CURL_VERSION(7,19,1)
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "POSTREDIR_301", CURL_REDIR_POST_301, CONST_CS|CONST_PERSISTENT);
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "POSTREDIR_302", CURL_REDIR_POST_302, CONST_CS|CONST_PERSISTENT);
-#if PHP_HTTP_CURL_VERSION(7,26,0)
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "POSTREDIR_303", CURL_REDIR_POST_303, CONST_CS|CONST_PERSISTENT);
-#endif
- REGISTER_NS_LONG_CONSTANT("http\\Client\\Curl", "POSTREDIR_ALL", CURL_REDIR_POST_ALL, CONST_CS|CONST_PERSISTENT);
-#endif
-
- return SUCCESS;
-}
-
-PHP_MSHUTDOWN_FUNCTION(http_client_curl)
-{
- php_persistent_handle_cleanup(ZEND_STRL("http\\Client\\Curl"), NULL, 0 TSRMLS_CC);
- php_persistent_handle_cleanup(ZEND_STRL("http\\Client\\Curl\\Request"), NULL, 0 TSRMLS_CC);
-
- php_http_options_dtor(&php_http_curle_options);
- php_http_options_dtor(&php_http_curlm_options);
-
- return SUCCESS;
-}
-
-#endif /* PHP_HTTP_HAVE_CURL */
-
-/*
- * Local variables:
- * tab-width: 4
- * c-basic-offset: 4
- * End:
- * vim600: noet sw=4 ts=4 fdm=marker
- * vim<600: noet sw=4 ts=4
- */
projects / m6w6 / ext-http / commitdiff
