X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-http;a=blobdiff_plain;f=http.c;h=21939a062282561497b890a8456f8e2d7bdc7b7f;hp=f29b09bfa28472558d6ec1723e6df9bf555e9158;hb=8d7fee64c740137b693630ad82374c11d1aaa76a;hpb=9949be4659856993b6f3668c87cdcf158f6c2ddf diff --git a/http.c b/http.c index f29b09b..21939a0 100644 --- a/http.c +++ b/http.c @@ -15,13 +15,15 @@ /* $Id$ */ +#define ZEND_INCLUDE_FULL_WINDOWS_HEADERS + #ifdef HAVE_CONFIG_H -#include "config.h" +# include "config.h" #endif #include "php.h" +#include "snprintf.h" #include "ext/standard/info.h" -#include "ext/standard/datetime.h" #include "ext/session/php_session.h" #include "ext/standard/php_string.h" #include "ext/standard/php_smart_str.h" @@ -29,16 +31,48 @@ #include "php_http.h" #include "php_http_api.h" -#if defined(HAVE_CURL) && HAVE_CURL -#include +#ifdef ZEND_ENGINE_2 +# include "ext/standard/php_http.h" #endif +#ifdef HTTP_HAVE_CURL + +# ifdef PHP_WIN32 +# include +# include +# endif + +# include + +/* {{{ ARG_INFO */ +# ifdef ZEND_BEGIN_ARG_INFO +ZEND_BEGIN_ARG_INFO(http_request_info_ref_3, 0) + ZEND_ARG_PASS_INFO(0) + ZEND_ARG_PASS_INFO(0) + ZEND_ARG_PASS_INFO(1) +ZEND_END_ARG_INFO(); + +ZEND_BEGIN_ARG_INFO(http_request_info_ref_4, 0) + ZEND_ARG_PASS_INFO(0) + ZEND_ARG_PASS_INFO(0) + ZEND_ARG_PASS_INFO(0) + ZEND_ARG_PASS_INFO(1) +ZEND_END_ARG_INFO(); +# else +static unsigned char http_request_info_ref_3[] = {3, BYREF_NONE, BYREF_NONE, BYREF_FORCE}; +static unsigned char http_request_info_ref_4[] = {4, BYREF_NONE, BYREF_NONE, BYREF_NONE, BYREF_FORCE}; +# endif +/* }}} ARG_INFO */ + +#endif /* HTTP_HAVE_CURL */ + ZEND_DECLARE_MODULE_GLOBALS(http) #ifdef COMPILE_DL_HTTP ZEND_GET_MODULE(http) #endif + /* {{{ http_functions[] */ function_entry http_functions[] = { PHP_FE(http_date, NULL) @@ -52,7 +86,6 @@ function_entry http_functions[] = { PHP_FE(http_match_etag, NULL) PHP_FE(http_cache_last_modified, NULL) PHP_FE(http_cache_etag, NULL) - PHP_FE(http_accept_ranges, NULL) PHP_FE(http_content_type, NULL) PHP_FE(http_content_disposition, NULL) PHP_FE(http_send_data, NULL) @@ -60,14 +93,19 @@ function_entry http_functions[] = { PHP_FE(http_send_stream, NULL) PHP_FE(http_chunked_decode, NULL) PHP_FE(http_split_response, NULL) -#if defined(HAVE_CURL) && HAVE_CURL - PHP_FE(http_get, NULL) - PHP_FE(http_head, NULL) - PHP_FE(http_post_data, NULL) - PHP_FE(http_post_array, NULL) + PHP_FE(http_parse_headers, NULL) + PHP_FE(http_get_request_headers, NULL) +#ifdef HTTP_HAVE_CURL + PHP_FE(http_get, http_request_info_ref_3) + PHP_FE(http_head, http_request_info_ref_3) + PHP_FE(http_post_data, http_request_info_ref_4) + PHP_FE(http_post_array, http_request_info_ref_4) #endif PHP_FE(http_auth_basic, NULL) PHP_FE(http_auth_basic_cb, NULL) +#ifndef ZEND_ENGINE_2 + PHP_FE(http_build_query, NULL) +#endif {NULL, NULL, NULL} }; /* }}} */ @@ -92,6 +130,7 @@ zend_module_entry http_module_entry = { /* }}} */ #define RETURN_SUCCESS(v) RETURN_BOOL(SUCCESS == (v)) +#define HASH_ORNULL(z) ((z) ? Z_ARRVAL_P(z) : NULL) /* {{{ proto string http_date([int timestamp]) * @@ -241,10 +280,6 @@ PHP_FUNCTION(http_negotiate_charset) /* {{{ proto bool http_send_status(int status) * * Send HTTP status code. - * This function sends the desired HTTP status code along with its corresponding - * status message, e.g. calling http_send_status(304) will issue a - * "Status: 304 Not Modified" with CGI-SAPIs and "HTTP/1.1 304 Not Modified" - * when PHP is run as web server module. * */ PHP_FUNCTION(http_send_status) @@ -267,7 +302,7 @@ PHP_FUNCTION(http_send_status) * * This converts the given timestamp to a valid HTTP date and * sends it as "Last-Modified" HTTP header. If timestamp is - * omitted, current time is taken. + * omitted, current time is sent. * */ PHP_FUNCTION(http_send_last_modified) @@ -288,7 +323,7 @@ PHP_FUNCTION(http_send_last_modified) /* {{{ proto bool http_match_modified([int timestamp]) * - * Matches the given timestamp against the clients "If-Modified-Since" and + * Matches the given timestamp against the clients "If-Modified-Since" resp. * "If-Unmodified-Since" HTTP headers. * */ @@ -312,7 +347,7 @@ PHP_FUNCTION(http_match_modified) /* {{{ proto bool http_match_etag(string etag) * * This matches the given ETag against the clients - * "If-Match" and "If-None-Match" HTTP headers. + * "If-Match" resp. "If-None-Match" HTTP headers. * */ PHP_FUNCTION(http_match_etag) @@ -333,7 +368,7 @@ PHP_FUNCTION(http_match_etag) * If timestamp_or_exires is greater than 0, it is handled as timestamp * and will be sent as date of last modification. If it is 0 or omitted, * the current time will be sent as Last-Modified date. If it's negative, - * it is handled as expiration tim in seconds, which means that if the + * it is handled as expiration time in seconds, which means that if the * requested last modification date is not between the calculated timespan, * the Last-Modified header is updated and the actual body will be sent. * @@ -351,12 +386,12 @@ PHP_FUNCTION(http_cache_last_modified) /* 0 or omitted */ if (!last_modified) { - /* does the client have? */ + /* does the client have? (att: caching "forever") */ if (zlm = http_get_server_var("HTTP_IF_MODIFIED_SINCE")) { last_modified = send_modified = http_parse_date(Z_STRVAL_P(zlm)); - /* use current time */ + /* send current time */ } else { - last_modified = send_modified = t; + send_modified = t; } /* negative value is supposed to be expiration time */ } else if (last_modified < 0) { @@ -401,8 +436,7 @@ PHP_FUNCTION(http_cache_etag) RETURN_FALSE; } - /* send remaining data to nirvana */ - http_send_header("Connection: close"); + php_end_ob_buffers(0 TSRMLS_CC); http_send_header("Cache-Control: private, must-revalidate, max-age=0"); /* if no etag is given and we didn't already @@ -438,6 +472,8 @@ PHP_FUNCTION(http_cache_etag) * ("301 Moved Permanently") or a temporary ("302 Found") redirection * status code. * + * To be RFC compliant, "Redirecting to URI." will be displayed, + * if the client doesn't redirect immediatly. */ PHP_FUNCTION(http_redirect) { @@ -445,9 +481,9 @@ PHP_FUNCTION(http_redirect) zend_bool session = 0, permanent = 0; zval *params = NULL; smart_str qstr = {0}; - char *url, *URI, LOC[HTTP_URI_MAXLEN + 9]; + char *url, *URI, LOC[HTTP_URI_MAXLEN + 9], RED[HTTP_URI_MAXLEN * 2 + 34]; - if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|sa!bb", &url, &url_len, ¶ms, &session, &permanent) != SUCCESS) { + if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|sa!/bb", &url, &url_len, ¶ms, &session, &permanent) != SUCCESS) { RETURN_FALSE; } @@ -477,13 +513,19 @@ PHP_FUNCTION(http_redirect) URI = http_absolute_uri(url, NULL); if (qstr.c) { snprintf(LOC, HTTP_URI_MAXLEN + strlen("Location: "), "Location: %s?%s", URI, qstr.c); + sprintf(RED, "Redirecting to %s?%s.\n", URI, qstr.c, URI, qstr.c); efree(qstr.c); } else { snprintf(LOC, HTTP_URI_MAXLEN + strlen("Location: "), "Location: %s", URI); + sprintf(RED, "Redirecting to %s.\n", URI, URI); } efree(URI); - RETVAL_BOOL((SUCCESS == http_send_header(LOC)) && (SUCCESS == http_send_status((permanent ? 301 : 302)))); + if ((SUCCESS == http_send_header(LOC)) && (SUCCESS == http_send_status((permanent ? 301 : 302)))) { + php_body_write(RED, strlen(RED) TSRMLS_CC); + RETURN_TRUE; + } + RETURN_FALSE; } /* }}} */ @@ -501,7 +543,7 @@ PHP_FUNCTION(http_send_data) } convert_to_string_ex(&zdata); - + http_send_header("Accept-Ranges: bytes"); RETURN_SUCCESS(http_send_data(zdata)); } /* }}} */ @@ -520,7 +562,7 @@ PHP_FUNCTION(http_send_file) } convert_to_string_ex(&zfile); - + http_send_header("Accept-Ranges: bytes"); RETURN_SUCCESS(http_send_file(zfile)); } /* }}} */ @@ -540,36 +582,11 @@ PHP_FUNCTION(http_send_stream) } php_stream_from_zval(file, &zstream); - + http_send_header("Accept-Ranges: bytes"); RETURN_SUCCESS(http_send_stream(file)); } /* }}} */ -/* {{{ proto bool http_accept_ranges(void) - * - * Issues a "Accept-Ranges: bytes" header. - * - * Example: - *
- * 
- * 
- * - */ -PHP_FUNCTION(http_accept_ranges) -{ - if (ZEND_NUM_ARGS()) { - WRONG_PARAM_COUNT; - } - RETURN_SUCCESS(http_send_header("Accept-Ranges: bytes")); -} -/* }}} */ - /* {{{ proto bool http_content_type([string content_type = 'application/x-octetstream']) * * Sets the content type. @@ -660,6 +677,7 @@ PHP_FUNCTION(http_chunked_decode) * content body. The returned array may look simliar to the following example: * *
+ *  array(
  *         'Status' => '200 Ok',
@@ -668,6 +686,7 @@ PHP_FUNCTION(http_chunked_decode)
  *     ),
  *     1 => "Hello World!"
  * );
+ * ?>
  * 
*/ PHP_FUNCTION(http_split_response) @@ -684,7 +703,10 @@ PHP_FUNCTION(http_split_response) MAKE_STD_ZVAL(zheaders); array_init(zheaders); - http_split_response(zresponse, zheaders, zbody); + if (SUCCESS != http_split_response(zresponse, zheaders, zbody)) { + php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not parse HTTP response"); + RETURN_FALSE; + } array_init(return_value); add_index_zval(return_value, 0, zheaders); @@ -692,19 +714,58 @@ PHP_FUNCTION(http_split_response) } /* }}} */ +/* {{{ proto array http_parse_headers(string header) + * + */ +PHP_FUNCTION(http_parse_headers) +{ + char *header, *rnrn; + int header_len; + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &header, &header_len)) { + RETURN_FALSE; + } + + array_init(return_value); + + if (rnrn = strstr(header, HTTP_CRLF HTTP_CRLF)) { + header_len = rnrn - header + 2; + } + if (SUCCESS != http_parse_headers(header, header_len, return_value)) { + php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not parse HTTP header"); + zval_dtor(return_value); + RETURN_FALSE; + } +} +/* }}}*/ + +/* {{{ proto array http_get_request_headers(void) + * + */ +PHP_FUNCTION(http_get_request_headers) +{ + if (ZEND_NUM_ARGS()) { + WRONG_PARAM_COUNT; + } + + array_init(return_value); + http_get_request_headers(return_value); +} +/* }}} */ + /* {{{ HAVE_CURL */ -#if defined(HAVE_CURL) && HAVE_CURL +#ifdef HTTP_HAVE_CURL -/* {{{ proto string http_get(string url[, array options]) +/* {{{ proto string http_get(string url[, array options[, array &info]]) * * Performs an HTTP GET request on the supplied url. * * The second parameter is expected to be an associative * array where the following keys will be recognized: *
- *  - redirect:      	int, whether and how many redirects to follow
+ *  - redirect:         int, whether and how many redirects to follow
  *  - unrestrictedauth: bool, whether to continue sending credentials on
- * 	                    redirects to a different host
+ *                      redirects to a different host
  *  - proxyhost:        string, proxy host in "host[:port]" format
  *  - proxyport:        int, use another proxy port as specified in proxyhost
  *  - proxyauth:        string, proxy credentials in "user:pass" format
@@ -712,26 +773,68 @@ PHP_FUNCTION(http_split_response)
  *  - httpauth:         string, http credentials in "user:pass" format
  *  - httpauthtype:     int, HTTP_AUTH_BASIC, DIGEST and/or NTLM
  *  - compress:         bool, whether to allow gzip/deflate content encoding
+ *                      (defaults to true)
  *  - port:             int, use another port as specified in the url
  *  - referer:          string, the referer to sends
  *  - useragent:        string, the user agent to send
- *  - headers:          array, list of custom headers in "header: value" format
- *  - cookies:          array, list of cookies in "name=value" format
+ *                      (defaults to PECL::HTTP/version (PHP/version)))
+ *  - headers:          array, list of custom headers as associative array
+ *                      like array("header" => "value")
+ *  - cookies:          array, list of cookies as associative array
+ *                      like array("cookie" => "value")
  *  - cookiestore:      string, path to a file where cookies are/will be stored
  * 
+ * + * The optional third parameter will be filled with some additional information + * in form af an associative array, if supplied, like the following example: + *
+ *  'http://localhost',
+ *     'response_code' => 403,
+ *     'total_time' => 0.017,
+ *     'namelookup_time' => 0.013,
+ *     'connect_time' => 0.014,
+ *     'pretransfer_time' => 0.014,
+ *     'size_upload' => 0,
+ *     'size_download' => 202,
+ *     'speed_download' => 11882,
+ *     'speed_upload' => 0,
+ *     'header_size' => 145,
+ *     'request_size' => 62,
+ *     'ssl_verifyresult' => 0,
+ *     'filetime' => -1,
+ *     'content_length_download' => 202,
+ *     'content_length_upload' => 0,
+ *     'starttransfer_time' => 0.017,
+ *     'content_type' => 'text/html; charset=iso-8859-1',
+ *     'redirect_time' => 0,
+ *     'redirect_count' => 0,
+ *     'private' => '',
+ *     'http_connectcode' => 0,
+ *     'httpauth_avail' => 0,
+ *     'proxyauth_avail' => 0,
+ * )
+ * ?>
+ * 
*/ PHP_FUNCTION(http_get) { char *URL, *data = NULL; size_t data_len = 0; int URL_len; - zval *options = NULL; + zval *options = NULL, *info = NULL; - if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|a", &URL, &URL_len, &options) != SUCCESS) { + if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|a/!z", &URL, &URL_len, &options, &info) != SUCCESS) { RETURN_FALSE; } - if (SUCCESS == http_get(URL, options ? Z_ARRVAL_P(options) : NULL, &data, &data_len)) { + if (info) { + zval_dtor(info); + array_init(info); + } + + if (SUCCESS == http_get(URL, HASH_ORNULL(options), HASH_ORNULL(info), &data, &data_len)) { RETURN_STRINGL(data, data_len, 0); } else { RETURN_FALSE; @@ -739,7 +842,7 @@ PHP_FUNCTION(http_get) } /* }}} */ -/* {{{ proto string http_head(string url[, array options]) +/* {{{ proto string http_head(string url[, array options[, array &info]]) * * Performs an HTTP HEAD request on the suppied url. * Returns the HTTP response as string. @@ -750,13 +853,18 @@ PHP_FUNCTION(http_head) char *URL, *data = NULL; size_t data_len = 0; int URL_len; - zval *options = NULL; + zval *options = NULL, *info = NULL; - if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|a", &URL, &URL_len, &options) != SUCCESS) { + if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|a/!z", &URL, &URL_len, &options, &info) != SUCCESS) { RETURN_FALSE; } - if (SUCCESS == http_head(URL, options ? Z_ARRVAL_P(options) : NULL, &data, &data_len)) { + if (info) { + zval_dtor(info); + array_init(info); + } + + if (SUCCESS == http_head(URL, HASH_ORNULL(options), HASH_ORNULL(info), &data, &data_len)) { RETURN_STRINGL(data, data_len, 0); } else { RETURN_FALSE; @@ -764,7 +872,7 @@ PHP_FUNCTION(http_head) } /* }}} */ -/* {{{ proto string http_post_data(string url, string data[, array options]) +/* {{{ proto string http_post_data(string url, string data[, array options[, &info]]) * * Performs an HTTP POST request, posting data. * Returns the HTTP response as string. @@ -775,13 +883,18 @@ PHP_FUNCTION(http_post_data) char *URL, *postdata, *data = NULL; size_t data_len = 0; int postdata_len, URL_len; - zval *options = NULL; + zval *options = NULL, *info = NULL; - if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss|a", &URL, &URL_len, &postdata, &postdata_len, &options) != SUCCESS) { + if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss|a/!z", &URL, &URL_len, &postdata, &postdata_len, &options, &info) != SUCCESS) { RETURN_FALSE; } - if (SUCCESS == http_post_data(URL, postdata, (size_t) postdata_len, options ? Z_ARRVAL_P(options) : NULL, &data, &data_len)) { + if (info) { + zval_dtor(info); + array_init(info); + } + + if (SUCCESS == http_post_data(URL, postdata, (size_t) postdata_len, HASH_ORNULL(options), HASH_ORNULL(info), &data, &data_len)) { RETURN_STRINGL(data, data_len, 0); } else { RETURN_FALSE; @@ -789,7 +902,7 @@ PHP_FUNCTION(http_post_data) } /* }}} */ -/* {{{ proto string http_post_data(string url, array data[, array options]) +/* {{{ proto string http_post_array(string url, array data[, array options[, array &info]]) * * Performs an HTTP POST request, posting www-form-urlencoded array data. * Returns the HTTP response as string. @@ -800,13 +913,18 @@ PHP_FUNCTION(http_post_array) char *URL, *data = NULL; size_t data_len = 0; int URL_len; - zval *options = NULL, *postdata; + zval *options = NULL, *info = NULL, *postdata; - if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "sa|a", &URL, &URL_len, &postdata, &options) != SUCCESS) { + if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "sa|a/!z", &URL, &URL_len, &postdata, &options, &info) != SUCCESS) { RETURN_FALSE; } - if (SUCCESS == http_post_array(URL, Z_ARRVAL_P(postdata), options ? Z_ARRVAL_P(options) : NULL, &data, &data_len)) { + if (info) { + zval_dtor(info); + array_init(info); + } + + if (SUCCESS == http_post_array(URL, Z_ARRVAL_P(postdata), HASH_ORNULL(options), HASH_ORNULL(info), &data, &data_len)) { RETURN_STRINGL(data, data_len, 0); } else { RETURN_FALSE; @@ -934,7 +1052,9 @@ static void php_http_init_globals(zend_http_globals *http_globals) { http_globals->etag_started = 0; http_globals->ctype = NULL; -#if defined(HAVE_CURL) && HAVE_CURL + http_globals->etag = NULL; + http_globals->lmod = 0; +#ifdef HTTP_HAVE_CURL http_globals->curlbuf.body.data = NULL; http_globals->curlbuf.body.used = 0; http_globals->curlbuf.body.free = 0; @@ -949,7 +1069,7 @@ static void php_http_init_globals(zend_http_globals *http_globals) PHP_MINIT_FUNCTION(http) { ZEND_INIT_MODULE_GLOBALS(http, php_http_init_globals, NULL); -#if defined(HAVE_CURL) && HAVE_CURL +#ifdef HTTP_HAVE_CURL REGISTER_LONG_CONSTANT("HTTP_AUTH_BASIC", CURLAUTH_BASIC, CONST_CS | CONST_PERSISTENT); REGISTER_LONG_CONSTANT("HTTP_AUTH_DIGEST", CURLAUTH_DIGEST, CONST_CS | CONST_PERSISTENT); REGISTER_LONG_CONSTANT("HTTP_AUTH_NTLM", CURLAUTH_NTLM, CONST_CS | CONST_PERSISTENT); @@ -964,7 +1084,10 @@ PHP_RSHUTDOWN_FUNCTION(http) if (HTTP_G(ctype)) { efree(HTTP_G(ctype)); } -#if defined(HAVE_CURL) && HAVE_CURL + if (HTTP_G(etag)) { + efree(HTTP_G(etag)); + } +#ifdef HTTP_HAVE_CURL if (HTTP_G(curlbuf).body.data) { efree(HTTP_G(curlbuf).body.data); } @@ -983,7 +1106,7 @@ PHP_MINFO_FUNCTION(http) php_info_print_table_header(2, "Extended HTTP support", "enabled"); php_info_print_table_row(2, "Version:", PHP_EXT_HTTP_VERSION); php_info_print_table_row(2, "cURL convenience functions:", -#if defined(HAVE_CURL) && HAVE_CURL +#ifdef HTTP_HAVE_CURL "enabled" #else "disabled" @@ -1001,3 +1124,4 @@ PHP_MINFO_FUNCTION(http) * vim600: noet sw=4 ts=4 fdm=marker * vim<600: noet sw=4 ts=4 */ +