X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-http;a=blobdiff_plain;f=http_methods.c;h=715d904ae495daebdc3e0c66406f142526e8776d;hp=3701e1a953f94bdc08bc53ac0bf8e60ec98711db;hb=2214902cf967c3aaf8e8493295f1ac43831ed015;hpb=e0dea94e283b3429780057c2f052b1a6b43515ef diff --git a/http_methods.c b/http_methods.c index 3701e1a..715d904 100644 --- a/http_methods.c +++ b/http_methods.c @@ -1,1121 +1,3984 @@ /* + +----------------------------------------------------------------------+ + | PECL :: http | + +----------------------------------------------------------------------+ + | This source file is subject to version 3.0 of the PHP license, that | + | is bundled with this package in the file LICENSE, and is available | + | through the world-wide-web at http://www.php.net/license/3_0.txt. | + | If you did not receive a copy of the PHP license and are unable to | + | obtain it through the world-wide-web, please send a note to | + | license@php.net so we can mail you a copy immediately. | + +----------------------------------------------------------------------+ + | Copyright (c) 2004-2005 Michael Wallner | + +----------------------------------------------------------------------+ + */ + + /* $Id$ */ -#define _WINSOCKAPI_ -#define ZEND_INCLUDE_FULL_WINDOWS_HEADERS + #ifdef HAVE_CONFIG_H + # include "config.h" + #endif + + #include "php.h" + #include "php_http.h" -#include "php_http_api.h" -#include "php_http_curl_api.h" + #include "php_http_std_defs.h" -#include "ext/standard/php_smart_str.h" +#include "php_http_api.h" + +#include "php_http_cache_api.h" + +#include "php_http_request_api.h" + +#include "php_http_date_api.h" + +#include "php_http_headers_api.h" + +#include "php_http_message_api.h" + +#include "php_http_send_api.h" + +#include "php_http_url_api.h" + + + +#include "php_http_message_object.h" + +#include "php_http_response_object.h" + +#include "php_http_request_object.h" + +#include "php_http_exception_object.h" + + #ifdef ZEND_ENGINE_2 -/* {{{ HTTPi_Response */ -/* {{{ proto void HTTPi_Response::__construct(bool cache, bool gzip) + +/* {{{ HttpResponse */ + + + +/* {{{ proto void HttpResponse::__construct(bool cache, bool gzip) + + * + + * Instantiates a new HttpResponse object, which can be used to send + + * any data/resource/file to an HTTP client with caching and multiple + + * ranges/resuming support. + * + + * NOTE: GZIPping is not implemented yet. + */ -PHP_METHOD(HTTPi_Response, __construct) + +PHP_METHOD(HttpResponse, __construct) + { + zend_bool do_cache = 0, do_gzip = 0; - getObject(httpi_response_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|bb", &do_cache, &do_gzip)) { - // throw exception - return; + getObject(http_response_object, obj); + + + + SET_EH_THROW_HTTP(); + + if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|bb", &do_cache, &do_gzip)) { + + UPD_PROP(obj, long, cache, do_cache); + + UPD_PROP(obj, long, gzip, do_gzip); + } - UPD_PROP(obj, long, cache, do_cache); - UPD_PROP(obj, long, gzip, do_gzip); + SET_EH_NORMAL(); + } + /* }}} */ -/* {{{ proto bool HTTPi_Response::setCache(bool cache) + + +/* {{{ proto bool HttpResponse::setCache(bool cache) + + * + + * Whether it sould be attempted to cache the entitity. + + * This will result in necessary caching headers and checks of clients + + * "If-Modified-Since" and "If-None-Match" headers. If one of those headers + + * matches a "304 Not Modified" status code will be issued. + * + + * NOTE: If you're using sessions, be shure that you set session.cache_limiter + + * to something more appropriate than "no-cache"! + */ -PHP_METHOD(HTTPi_Response, setCache) + +PHP_METHOD(HttpResponse, setCache) + { + zend_bool do_cache = 0; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "b", &do_cache)) { + RETURN_FALSE; + } + + UPD_PROP(obj, long, cache, do_cache); + RETURN_TRUE; + } + /* }}} */ -/* {{{ proto bool HTTPi_Response::getCache() + + +/* {{{ proto bool HttpResponse::getCache() + * + + * Get current caching setting. + */ -PHP_METHOD(HTTPi_Response, getCache) + +PHP_METHOD(HttpResponse, getCache) + { + zval *do_cache = NULL; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + NO_ARGS; + + do_cache = GET_PROP(obj, cache); + RETURN_BOOL(Z_LVAL_P(do_cache)); + } + /* }}}*/ -/* {{{ proto bool HTTPi_Response::setGzip(bool gzip) + + +/* {{{ proto bool HttpResponse::setGzip(bool gzip) + * + + * Enable on-thy-fly gzipping of the sent entity. NOT IMPLEMENTED YET. + */ -PHP_METHOD(HTTPi_Response, setGzip) + +PHP_METHOD(HttpResponse, setGzip) + { + zend_bool do_gzip = 0; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "b", &do_gzip)) { + RETURN_FALSE; + } + + UPD_PROP(obj, long, gzip, do_gzip); + RETURN_TRUE; + } + /* }}} */ -/* {{{ proto bool HTTPi_Response::getGzip() + + +/* {{{ proto bool HttpResponse::getGzip() + * + + * Get current gzipping setting. + */ -PHP_METHOD(HTTPi_Response, getGzip) + +PHP_METHOD(HttpResponse, getGzip) + { + zval *do_gzip = NULL; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + NO_ARGS; + + do_gzip = GET_PROP(obj, gzip); + RETURN_BOOL(Z_LVAL_P(do_gzip)); + } + /* }}} */ -/* {{{ proto bool HTTPi_Response::setCacheControl(string control[, bool raw = false]) + + +/* {{{ proto bool HttpResponse::setCacheControl(string control[, bool raw = false]) + * + + * Set a custom cache-control header, usually being "private" or "public"; if + + * $raw is set to true the header will be sent as-is. + */ -PHP_METHOD(HTTPi_Response, setCacheControl) + +PHP_METHOD(HttpResponse, setCacheControl) + { + char *ccontrol; + int cc_len; + zend_bool raw = 0; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|b", &ccontrol, &cc_len, &raw)) { + RETURN_FALSE; + } + + if ((!raw) && (strcmp(ccontrol, "public") && strcmp(ccontrol, "private") && strcmp(ccontrol, "no-cache"))) { - php_error_docref(NULL TSRMLS_CC, E_WARNING, "Cache-Control '%s' doesn't match public, private or no-cache", ccontrol); + + http_error_ex(E_WARNING, HTTP_E_PARAM, "Cache-Control '%s' doesn't match public, private or no-cache", ccontrol); + RETURN_FALSE; + } + + UPD_PROP(obj, long, raw_cache_header, raw); + UPD_PROP(obj, string, cacheControl, ccontrol); + RETURN_TRUE; + } + /* }}} */ -/* {{{ proto string HTTPi_Response::getCacheControl() + + +/* {{{ proto string HttpResponse::getCacheControl() + * + + * Get current Cache-Control header setting. + */ -PHP_METHOD(HTTPi_Response, getCacheControl) + +PHP_METHOD(HttpResponse, getCacheControl) + { + zval *ccontrol; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + NO_ARGS; + + ccontrol = GET_PROP(obj, cacheControl); + RETURN_STRINGL(Z_STRVAL_P(ccontrol), Z_STRLEN_P(ccontrol), 1); + } + /* }}} */ -/* {{{ proto bool HTTPi::setContentType(string content_type) + + +/* {{{ proto bool HttpResponse::setContentType(string content_type) + * + + * Set the content-type of the sent entity. + */ -PHP_METHOD(HTTPi_Response, setContentType) + +PHP_METHOD(HttpResponse, setContentType) + { + char *ctype; + int ctype_len; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &ctype, &ctype_len)) { + RETURN_FALSE; + } + + if (!strchr(ctype, '/')) { - php_error_docref(NULL TSRMLS_CC, E_WARNING, - "Content type '%s' doesn't seem to contain a primary and a secondary part", ctype); + + http_error_ex(E_WARNING, HTTP_E_PARAM, "Content type '%s' doesn't seem to contain a primary and a secondary part", ctype); + RETURN_FALSE; + } + + UPD_PROP(obj, string, contentType, ctype); + + RETURN_TRUE; + } + /* }}} */ -/* {{{ proto string HTTPi_Response::getContentType() + + +/* {{{ proto string HttpResponse::getContentType() + * + + * Get current Content-Type header setting. + */ -PHP_METHOD(HTTPi_Response, getContentType) + +PHP_METHOD(HttpResponse, getContentType) + { + zval *ctype; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + NO_ARGS; + + ctype = GET_PROP(obj, contentType); + RETURN_STRINGL(Z_STRVAL_P(ctype), Z_STRLEN_P(ctype), 1); + } + /* }}} */ -/* {{{ proto bool HTTPi_Response::setContentDisposition(string filename[, bool inline = false]) + + +/* {{{ proto bool HttpResponse::setContentDisposition(string filename[, bool inline = false]) + * + + * Set the Content-Disposition of the sent entity. This setting aims to suggest + + * the receiveing user agent how to handle the sent entity; usually the client + + * will show the user a "Save As..." popup. + */ -PHP_METHOD(HTTPi_Response, setContentDisposition) + +PHP_METHOD(HttpResponse, setContentDisposition) + { + char *file; + int file_len; + zend_bool is_inline = 0; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|b", &file, &file_len, &is_inline)) { + RETURN_FALSE; + } + + UPD_PROP(obj, string, dispoFile, file); + UPD_PROP(obj, long, dispoInline, is_inline); + RETURN_TRUE; + } + /* }}} */ -/* {{{ proto array HTTPi_Response::getContentDisposition() - * - */ -PHP_METHOD(HTTPi_Response, getContentDisposition) -{ - zval *file; - zval *is_inline; - getObject(httpi_response_object, obj); - if (ZEND_NUM_ARGS()) { - WRONG_PARAM_COUNT; - } + +/* {{{ proto array HttpResponse::getContentDisposition() + + * + + * Get current Content-Disposition setting. + + * Will return an associative array like: + + * 
+
+ * array(
+
+ *     'filename' => 'foo.bar',
+
+ *     'inline'   => false
+
+ * )
+
+ *
+ + */ + +PHP_METHOD(HttpResponse, getContentDisposition) + +{ + + zval *file; + + zval *is_inline; + + getObject(http_response_object, obj); + + + + if (ZEND_NUM_ARGS()) { + + WRONG_PARAM_COUNT; + + } + + file = GET_PROP(obj, dispoFile); + is_inline = GET_PROP(obj, dispoInline); + + array_init(return_value); + add_assoc_stringl(return_value, "filename", Z_STRVAL_P(file), Z_STRLEN_P(file), 1); + add_assoc_bool(return_value, "inline", Z_LVAL_P(is_inline)); + } + /* }}} */ -/* {{{ proto bool HTTPi_Response::setETag(string etag) + + +/* {{{ proto bool HttpResponse::setETag(string etag) + * + + * Set a custom ETag. Use this only if you know what you're doing. + */ -PHP_METHOD(HTTPi_Response, setETag) + +PHP_METHOD(HttpResponse, setETag) + { + char *etag; + int etag_len; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &etag, &etag_len)) { + RETURN_FALSE; + } + + UPD_PROP(obj, string, eTag, etag); + RETURN_TRUE; + } + /* }}} */ -/* {{{ proto string HTTPi_Response::getETag() + + +/* {{{ proto string HttpResponse::getETag() + * + + * Get the previously set custom ETag. + */ -PHP_METHOD(HTTPi_Response, getETag) + +PHP_METHOD(HttpResponse, getETag) + { + zval *etag; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + NO_ARGS; + + etag = GET_PROP(obj, eTag); + RETURN_STRINGL(Z_STRVAL_P(etag), Z_STRLEN_P(etag), 1); + } + /* }}} */ -/* {{{ proto bool HTTPi_Response::setData(string data) + + +/* {{{ proto bool HttpResponse::setData(string data) + * + + * Set the data to be sent. + */ -PHP_METHOD(HTTPi_Response, setData) + +PHP_METHOD(HttpResponse, setData) + { + zval *the_data; - getObject(httpi_response_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z", &the_data)) { + getObject(http_response_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z/", &the_data)) { + RETURN_FALSE; + } + + convert_to_string_ex(&the_data); + SET_PROP(obj, data, the_data); - UPD_PROP(obj, long, lastModified, http_lmod(the_data, SEND_DATA)); + + UPD_PROP(obj, long, lastModified, http_last_modified(the_data, SEND_DATA)); + UPD_PROP(obj, long, send_mode, SEND_DATA); + RETURN_TRUE; + } + /* }}} */ -/* {{{ proto string HTTPi_Response::getData() + + +/* {{{ proto string HttpResponse::getData() + * + + * Get the previously set data to be sent. + */ -PHP_METHOD(HTTPi_Response, getData) + +PHP_METHOD(HttpResponse, getData) + { + zval *the_data; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + NO_ARGS; + + the_data = GET_PROP(obj, data); + RETURN_STRINGL(Z_STRVAL_P(the_data), Z_STRLEN_P(the_data), 1); + } + /* }}} */ -/* {{{ proto bool HTTPi_Response::setStream(resource stream) + + +/* {{{ proto bool HttpResponse::setStream(resource stream) + * + + * Set the resource to be sent. + */ -PHP_METHOD(HTTPi_Response, setStream) + +PHP_METHOD(HttpResponse, setStream) + { + zval *the_stream; + php_stream *the_real_stream; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &the_stream)) { + RETURN_FALSE; + } + + php_stream_from_zval(the_real_stream, &the_stream); + + SET_PROP(obj, stream, the_stream); - UPD_PROP(obj, long, lastModified, http_lmod(the_real_stream, SEND_RSRC)); + + UPD_PROP(obj, long, lastModified, http_last_modified(the_real_stream, SEND_RSRC)); + UPD_PROP(obj, long, send_mode, SEND_RSRC); + RETURN_TRUE; + } + /* }}} */ -/* {{{ proto resource HTTPi_Response::getStream() + + +/* {{{ proto resource HttpResponse::getStream() + * + + * Get the previously set resource to be sent. + */ -PHP_METHOD(HTTPi_Response, getStream) + +PHP_METHOD(HttpResponse, getStream) + { + zval *the_stream; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + NO_ARGS; + + the_stream = GET_PROP(obj, stream); + RETURN_RESOURCE(Z_LVAL_P(the_stream)); + } + /* }}} */ -/* {{{ proto bool HTTPi_Response::setFile(string file) + + +/* {{{ proto bool HttpResponse::setFile(string file) + * + + * Set the file to be sent. + */ -PHP_METHOD(HTTPi_Response, setFile) + +PHP_METHOD(HttpResponse, setFile) + { + zval *the_file; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z", &the_file)) { + RETURN_FALSE; + } + + convert_to_string_ex(&the_file); + + UPD_PROP(obj, string, file, Z_STRVAL_P(the_file)); - UPD_PROP(obj, long, lastModified, http_lmod(the_file, -1)); + + UPD_PROP(obj, long, lastModified, http_last_modified(the_file, -1)); + UPD_PROP(obj, long, send_mode, -1); + RETURN_TRUE; + } + /* }}} */ -/* {{{ proto string HTTPi_Response::getFile() + + +/* {{{ proto string HttpResponse::getFile() + * + + * Get the previously set file to be sent. + */ -PHP_METHOD(HTTPi_Response, getFile) + +PHP_METHOD(HttpResponse, getFile) + { + zval *the_file; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + NO_ARGS; + + the_file = GET_PROP(obj, file); + RETURN_STRINGL(Z_STRVAL_P(the_file), Z_STRLEN_P(the_file), 1); + } + /* }}} */ -PHP_METHOD(HTTPi_Response, send) + + +/* {{{ proto bool HttpResponse::send() + + * + + * Finally send the entity. + + * + + * Example: + + * 
+
+ * setFile('../hidden/contract.pdf');
+
+ * $r->setContentType('application/pdf');
+
+ * $r->send();
+
+ * ?>
+
+ *
+ + * + + */ + +PHP_METHOD(HttpResponse, send) + { + zval *do_cache, *do_gzip; - getObject(httpi_response_object, obj); + + getObject(http_response_object, obj); + + + + NO_ARGS; + + do_cache = GET_PROP(obj, cache); + do_gzip = GET_PROP(obj, gzip); + + + /* gzip */ + + if (Z_LVAL_P(do_gzip)) { + + php_start_ob_buffer_named("ob_gzhandler", 0, 1 TSRMLS_CC); + + } + + + /* caching */ + if (Z_LVAL_P(do_cache)) { + zval *cctrl, *etag, *lmod, *ccraw; + + etag = GET_PROP(obj, eTag); + lmod = GET_PROP(obj, lastModified); + cctrl = GET_PROP(obj, cacheControl); + ccraw = GET_PROP(obj, raw_cache_header); + + if (Z_LVAL_P(ccraw)) { + http_cache_etag(Z_STRVAL_P(etag), Z_STRLEN_P(etag), Z_STRVAL_P(cctrl), Z_STRLEN_P(cctrl)); + http_cache_last_modified(Z_LVAL_P(lmod), Z_LVAL_P(lmod) ? Z_LVAL_P(lmod) : time(NULL), Z_STRVAL_P(cctrl), Z_STRLEN_P(cctrl)); + } else { + char cc_header[42] = {0}; + sprintf(cc_header, "%s, must-revalidate, max-age=0", Z_STRVAL_P(cctrl)); + http_cache_etag(Z_STRVAL_P(etag), Z_STRLEN_P(etag), cc_header, strlen(cc_header)); + http_cache_last_modified(Z_LVAL_P(lmod), Z_LVAL_P(lmod) ? Z_LVAL_P(lmod) : time(NULL), cc_header, strlen(cc_header)); + } - } - /* gzip */ - if (Z_LVAL_P(do_gzip)) { - /* ... */ } + + /* content type */ + { + zval *ctype = GET_PROP(obj, contentType); + if (Z_STRLEN_P(ctype)) { + http_send_content_type(Z_STRVAL_P(ctype), Z_STRLEN_P(ctype)); + } else { + http_send_content_type("application/x-octetstream", sizeof("application/x-octetstream") - 1); + } + } + + /* content disposition */ + { + zval *dispo_file = GET_PROP(obj, dispoFile); + if (Z_STRLEN_P(dispo_file)) { + zval *dispo_inline = GET_PROP(obj, dispoInline); - http_send_content_disposition(Z_STRVAL_P(dispo_file), Z_STRLEN_P(dispo_file), Z_LVAL_P(dispo_inline)); + + http_send_content_disposition(Z_STRVAL_P(dispo_file), Z_STRLEN_P(dispo_file), (zend_bool) Z_LVAL_P(dispo_inline)); + } + } + + /* send */ + { + zval *send_mode = GET_PROP(obj, send_mode); + switch (Z_LVAL_P(send_mode)) + { + case SEND_DATA: + { - RETURN_SUCCESS(http_send_data(GET_PROP(obj, data))); + + zval *zdata = GET_PROP(obj, data); + + RETURN_SUCCESS(http_send_data(Z_STRVAL_P(zdata), Z_STRLEN_P(zdata))); + } + + case SEND_RSRC: + { + php_stream *the_real_stream; + zval *the_stream = GET_PROP(obj, stream); + php_stream_from_zval(the_real_stream, &the_stream); + RETURN_SUCCESS(http_send_stream(the_real_stream)); + } + + default: + { - RETURN_SUCCESS(http_send_file(GET_PROP(obj, file))); + + zval *zfile = GET_PROP(obj, file); + + RETURN_SUCCESS(http_send_file(Z_STRVAL_P(zfile))); + } + } + } + } + /* }}} */ + /* }}} */ -#ifdef HTTP_HAVE_CURL -/* {{{ HTTPi_Request */ -/* {{{ proto void HTTPi_Request::__construct([string url[, long request_method = HTTP_GET]]) + +/* {{{ HttpMessage */ + + + +/* {{{ proto static HttpMessage HttpMessage::fromString(string raw_message) + * + + * Create an HttpMessage object from a string. + */ -PHP_METHOD(HTTPi_Request, __construct) + +PHP_METHOD(HttpMessage, fromString) + { - char *URL = NULL; - int URL_len; - long meth = -1; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|sl", &URL, &URL_len, &meth)) { - return; - } + char *string = NULL; - INIT_PARR(obj, options); - INIT_PARR(obj, responseInfo); - INIT_PARR(obj, responseData); - INIT_PARR(obj, postData); - INIT_PARR(obj, postFiles); + int length = 0; + + http_message *msg = NULL; + + http_message_object obj; + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &string, &length)) { + + RETURN_NULL(); - if (URL) { - UPD_PROP(obj, string, url, URL); } - if (meth > -1) { - UPD_PROP(obj, long, method, meth); + + + + if (!(msg = http_message_parse(string, length))) { + + RETURN_NULL(); + } -} -/* }}} */ -/* {{{ proto void HTTPi_Request::__destruct() - * - */ -PHP_METHOD(HTTPi_Request, __destruct) -{ - getObject(httpi_request_object, obj); - NO_ARGS; - FREE_PARR(obj, options); - FREE_PARR(obj, responseInfo); - FREE_PARR(obj, responseData); - FREE_PARR(obj, postData); - FREE_PARR(obj, postFiles); + Z_TYPE_P(return_value) = IS_OBJECT; + + return_value->value.obj = http_message_object_from_msg(msg); + } + /* }}} */ -/* {{{ proto bool HTTPi_Request::setOptions(array options) + + +/* {{{ proto void HttpMessage::__construct([string message]) + * + + * Instantiate a new HttpMessage object. + */ -PHP_METHOD(HTTPi_Request, setOptions) + +PHP_METHOD(HttpMessage, __construct) + { - char *key = NULL; - long idx = 0; - zval *opts, *old_opts, **opt; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a/", &opts)) { - RETURN_FALSE; - } + char *message = NULL; - old_opts = GET_PROP(obj, options); + int length = 0; + + getObject(http_message_object, obj); + + + + SET_EH_THROW_HTTP(); + + if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s", &message, &length) && message && length) { + + if (obj->message = http_message_parse(message, length)) { + + if (obj->message->parent) { + + obj->parent = http_message_object_from_msg(obj->message->parent); - /* headers and cookies need extra attention -- thus cannot use array_merge() directly */ - FOREACH_KEYVAL(opts, key, idx, opt) { - if (key) { - if (!strcmp(key, "headers")) { - zval **headers; - if (SUCCESS == zend_hash_find(Z_ARRVAL_P(old_opts), "headers", sizeof("headers"), (void **) &headers)) { - array_merge(*opt, *headers); - continue; - } - } else if (!strcmp(key, "cookies")) { - zval **cookies; - if (SUCCESS == zend_hash_find(Z_ARRVAL_P(old_opts), "cookies", sizeof("cookies"), (void **) &cookies)) { - array_merge(*opt, *cookies); - continue; - } } - zval_add_ref(opt); - add_assoc_zval(old_opts, key, *opt); - /* reset */ - key = NULL; } + + } else if (!obj->message) { + + obj->message = http_message_new(); + } - RETURN_TRUE; + SET_EH_NORMAL(); + } + /* }}} */ -/* {{{ proto array HTTPi_Request::getOptions() - * - */ -PHP_METHOD(HTTPi_Request, getOptions) -{ - zval *opts; - getObject(httpi_request_object, obj); - NO_ARGS; - opts = GET_PROP(obj, options); - array_init(return_value); - array_copy(opts, return_value); -} -/* }}} */ +/* {{{ proto string HttpMessage::getBody() -/* {{{ proto bool HTTPi_Request::setURL(string url) * + + * Get the body of the parsed Message. + */ -PHP_METHOD(HTTPi_Request, setURL) + +PHP_METHOD(HttpMessage, getBody) + { - char *URL = NULL; - int URL_len; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &URL, &URL_len)) { - RETURN_FALSE; - } + zval *body; + + getObject(http_message_object, obj); - UPD_PROP(obj, string, url, URL); - RETURN_TRUE; -} -/* }}} */ -/* {{{ proto string HTTPi_Request::getUrl() - * - */ -PHP_METHOD(HTTPi_Request, getURL) -{ - zval *URL; - getObject(httpi_request_object, obj); NO_ARGS; - URL = GET_PROP(obj, url); - RETURN_STRINGL(Z_STRVAL_P(URL), Z_STRLEN_P(URL), 1); -} -/* }}} */ -/* {{{ proto bool HTTPi_Request::setMethod(long request_method) - * - */ -PHP_METHOD(HTTPi_Request, setMethod) -{ - long meth; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &meth)) { - RETURN_FALSE; - } + RETURN_PHPSTR(&obj->message->body, PHPSTR_FREE_NOT, 1); - UPD_PROP(obj, long, method, meth); - RETURN_TRUE; } + /* }}} */ -/* {{{ proto long HTTPi_Request::getMethod() - * - */ -PHP_METHOD(HTTPi_Request, getMethod) -{ - zval *meth; - getObject(httpi_request_object, obj); - NO_ARGS; - meth = GET_PROP(obj, method); - RETURN_LONG(Z_LVAL_P(meth)); -} -/* }}} */ +/* {{{ proto array HttpMessage::getHeaders() -/* {{{ proto bool HTTPi_Request::setContentType(string content_type) * + + * Get Message Headers. + */ -PHP_METHOD(HTTPi_Request, setContentType) + +PHP_METHOD(HttpMessage, getHeaders) + { - char *ctype; - int ct_len; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &ctype, &ct_len)) { - RETURN_FALSE; - } + zval headers; - if (!strchr(ctype, '/')) { - php_error_docref(NULL TSRMLS_CC, E_WARNING, - "Content-Type '%s' doesn't seem to contain a primary and a secondary part", - ctype); - RETURN_FALSE; - } + getObject(http_message_object, obj); - UPD_PROP(obj, string, contentType, ctype); - RETURN_TRUE; -} -/* }}} */ -/* {{{ proto string HTTPi_Request::getContentType() - * - */ -PHP_METHOD(HTTPi_Request, getContentType) -{ - zval *ctype; - getObject(httpi_request_object, obj); NO_ARGS; - ctype = GET_PROP(obj, contentType); - RETURN_STRINGL(Z_STRVAL_P(ctype), Z_STRLEN_P(ctype), 1); -} -/* }}} */ -/* {{{ proto bool HTTPi_Request::setQueryData(mixed query_data) - * - */ -PHP_METHOD(HTTPi_Request, setQueryData) -{ - zval *qdata; - char *query_data = NULL; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z", &qdata)) { - RETURN_FALSE; - } + Z_ARRVAL(headers) = &obj->message->hdrs; - if ((Z_TYPE_P(qdata) == IS_ARRAY) || (Z_TYPE_P(qdata) == IS_OBJECT)) { - if (SUCCESS != http_urlencode_hash(HASH_OF(qdata), &query_data)) { - RETURN_FALSE; - } - UPD_PROP(obj, string, queryData, query_data); - efree(query_data); - RETURN_TRUE; - } + array_init(return_value); + + array_copy(&headers, return_value); - convert_to_string(qdata); - UPD_PROP(obj, string, queryData, Z_STRVAL_P(qdata)); - RETURN_TRUE; } + /* }}} */ -/* {{{ proto string HTTPi_Request::getQueryData() - * - */ -PHP_METHOD(HTTPi_Request, getQueryData) -{ - zval *qdata; - getObject(httpi_request_object, obj); - NO_ARGS; - qdata = GET_PROP(obj, queryData); - RETURN_STRINGL(Z_STRVAL_P(qdata), Z_STRLEN_P(qdata), 1); -} -/* }}} */ +/* {{{ proto void HttpMessage::setHeaders(array headers) -/* {{{ proto bool HTTPi_Request::addQueryData(array query_params) * + + * Sets new headers. + */ -PHP_METHOD(HTTPi_Request, addQueryData) + +PHP_METHOD(HttpMessage, setHeaders) + { - zval *qdata, *old_qdata; - char *query_data = NULL; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a", &qdata)) { - RETURN_FALSE; - } + zval *new_headers, old_headers; - old_qdata = GET_PROP(obj, queryData); + getObject(http_message_object, obj); - if (SUCCESS != http_urlencode_hash_ex(HASH_OF(qdata), 1, Z_STRVAL_P(old_qdata), Z_STRLEN_P(old_qdata), &query_data, NULL)) { - RETURN_FALSE; - } - UPD_PROP(obj, string, queryData, query_data); - efree(query_data); - RETURN_TRUE; -} -/* }}} */ + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a/", &new_headers)) { + + return; + + } + + + + zend_hash_clean(&obj->message->hdrs); + + Z_ARRVAL(old_headers) = &obj->message->hdrs; + + array_copy(new_headers, &old_headers); + +} + +/* }}} */ + + + +/* {{{ proto void HttpMessage::addHeaders(array headers[, bool append = false]) + + * + + * Add headers. If append is true, headers with the same name will be separated, else overwritten. + + */ + +PHP_METHOD(HttpMessage, addHeaders) + +{ + + zval old_headers, *new_headers; + + zend_bool append = 0; + + getObject(http_message_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a|b", &new_headers, &append)) { + + return; + + } + + + + Z_ARRVAL(old_headers) = &obj->message->hdrs; + + if (append) { + + array_append(new_headers, &old_headers); + + } else { + + array_merge(new_headers, &old_headers); + + } + +} + +/* }}} */ + + + +/* {{{ proto long HttpMessage::getType() + + * + + * Get Message Type. (HTTP_MSG_NONE|HTTP_MSG_REQUEST|HTTP_MSG_RESPONSE) + + */ + +PHP_METHOD(HttpMessage, getType) -/* {{{ proto void HTTPi_Request::unsetQueryData() - * - */ -PHP_METHOD(HTTPi_Request, unsetQueryData) { - getObject(httpi_request_object, obj); + + getObject(http_message_object, obj); + + NO_ARGS; - UPD_PROP(obj, string, queryData, ""); + + + RETURN_LONG(obj->message->type); + } + /* }}} */ -/* {{{ proto bool HTTPi_Request::addPostData(array post_data) + + +/* {{{ proto void HttpMessage::setType(long type) + * + + * Set Message Type. (HTTP_MSG_NONE|HTTP_MSG_REQUEST|HTTP_MSG_RESPONSE) + */ -PHP_METHOD(HTTPi_Request, addPostData) + +PHP_METHOD(HttpMessage, setType) + { - zval *post, *post_data; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a", &post_data)) { + long type; + + getObject(http_message_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &type)) { + + return; + + } + + http_message_set_type(obj->message, type); + +} + +/* }}} */ + + + +/* {{{ proto long HttpMessage::getResponseCode() + + * + + * Get the Response Code of the Message. + + */ + +PHP_METHOD(HttpMessage, getResponseCode) + +{ + + getObject(http_message_object, obj); + + + + NO_ARGS; + + + + if (!HTTP_MSG_TYPE(RESPONSE, obj->message)) { + + http_error(E_NOTICE, HTTP_E_MSG, "HttpMessage is not of type HTTP_MSG_RESPONSE"); + + RETURN_NULL(); + + } + + + + RETURN_LONG(obj->message->info.response.code); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpMessage::setResponseCode(long code) + + * + + * Set the response code of an HTTP Response Message. + + * Returns false if the Message is not of type HTTP_MSG_RESPONSE, + + * or if the response code is out of range (100-510). + + */ + +PHP_METHOD(HttpMessage, setResponseCode) + +{ + + long code; + + getObject(http_message_object, obj); + + + + if (obj->message->type != HTTP_MSG_RESPONSE) { + + http_error(E_WARNING, HTTP_E_MSG, "HttpMessage is not of type HTTP_MSG_RESPONSE"); + RETURN_FALSE; + } - post = GET_PROP(obj, postData); - array_merge(post_data, post); + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &code)) { + + RETURN_FALSE; + + } + + if (code < 100 || code > 510) { + + http_error_ex(E_WARNING, HTTP_E_PARAM, "Invalid response code (100-510): %ld", code); + + RETURN_FALSE; + + } + + + + obj->message->info.response.code = code; RETURN_TRUE; + } + /* }}} */ -/* {{{ proto bool HTTPi_Request::setPostData(array post_data) + + +/* {{{ proto string HttpMessage::getRequestMethod() + * + + * Get the Request Method of the Message. + + * Returns false if the Message is not of type HTTP_MSG_REQUEST. + */ -PHP_METHOD(HTTPi_Request, setPostData) + +PHP_METHOD(HttpMessage, getRequestMethod) + { - zval *post, *post_data; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a", &post_data)) { + getObject(http_message_object, obj); + + + + NO_ARGS; + + + + if (obj->message->type != HTTP_MSG_REQUEST) { + + http_error(E_NOTICE, HTTP_E_MSG, "HttpMessage is not of type HTTP_MSG_REQUEST"); + + RETURN_NULL(); + + } + + + + RETURN_STRING(obj->message->info.request.method, 1); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpMessage::setRequestMethod(string method) + + * + + * Set the Request Method of the HTTP Message. + + * Returns false if the Message is not of type HTTP_MSG_REQUEST. + + */ + +PHP_METHOD(HttpMessage, setRequestMethod) + +{ + + char *method; + + int method_len; + + getObject(http_message_object, obj); + + + + if (obj->message->type != HTTP_MSG_REQUEST) { + + http_error(E_WARNING, HTTP_E_MSG, "HttpMessage is not of type HTTP_MSG_REQUEST"); + RETURN_FALSE; + } - post = GET_PROP(obj, postData); - zend_hash_clean(Z_ARRVAL_P(post)); - array_copy(post_data, post); - RETURN_TRUE; + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &method, &method_len)) { + + RETURN_FALSE; + + } + + if (method_len < 1) { + + http_error(E_WARNING, HTTP_E_PARAM, "Cannot set HttpMessage::requestMethod to an empty string"); + + RETURN_FALSE; + + } + + if (SUCCESS != http_check_method(method)) { + + http_error_ex(E_WARNING, HTTP_E_PARAM, "Unkown request method: %s", method); + + RETURN_FALSE; + + } + + + + if (obj->message->info.request.method) { + + efree(obj->message->info.request.method); + + } + + obj->message->info.request.method = estrndup(method, method_len); + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto string HttpMessage::getRequestUri() + + * + + * Get the Request URI of the Message. + + */ + +PHP_METHOD(HttpMessage, getRequestUri) + +{ + + zval *uri; + + getObject(http_message_object, obj); + + + + NO_ARGS; + + + + if (obj->message->type != HTTP_MSG_REQUEST) { + + http_error(E_WARNING, HTTP_E_MSG, "HttpMessage is not of type HTTP_MSG_REQUEST"); + + RETURN_NULL(); + + } + + + + RETURN_STRING(obj->message->info.request.URI, 1); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpMessage::setRequestUri(string URI) + + * + + * Set the Request URI of the HTTP Message. + + * Returns false if the Message is not of type HTTP_MSG_REQUEST, + + * or if paramtere URI was empty. + + */ + +PHP_METHOD(HttpMessage, setRequestUri) + +{ + + char *URI; + + int URIlen; + + getObject(http_message_object, obj); + + + + if (obj->message->type != HTTP_MSG_REQUEST) { + + http_error(E_WARNING, HTTP_E_MSG, "HttpMessage is not of type HTTP_MSG_REQUEST"); + + RETURN_FALSE; + + } + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &URI, &URIlen)) { + + RETURN_FALSE; + + } + + if (URIlen < 1) { + + http_error(E_WARNING, HTTP_E_PARAM, "Cannot set HttpMessage::requestUri to an empty string"); + + RETURN_FALSE; + + } + + + + if (obj->message->info.request.URI) { + + efree(obj->message->info.request.URI); + + } + + obj->message->info.request.URI = estrndup(URI, URIlen); + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto string HttpMessage::getHttpVersion() + + * + + * Get the HTTP Protocol Version of the Message. + + */ + +PHP_METHOD(HttpMessage, getHttpVersion) + +{ + + char ver[4] = {0}; + + float version; + + getObject(http_message_object, obj); + + + + NO_ARGS; + + + + switch (obj->message->type) + + { + + case HTTP_MSG_RESPONSE: + + version = obj->message->info.response.http_version; + + break; + + + + case HTTP_MSG_REQUEST: + + version = obj->message->info.request.http_version; + + break; + + + + case HTTP_MSG_NONE: + + default: + + RETURN_NULL(); + + } + + sprintf(ver, "%1.1f", version); + + RETURN_STRINGL(ver, 3, 1); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpMessage::setHttpVersion(string version) + + * + + * Set the HTTP Protocol version of the Message. + + * Returns false if version is invalid (1.0 and 1.1). + + */ + +PHP_METHOD(HttpMessage, setHttpVersion) + +{ + + char v[4]; + + zval *zv, *version; + + getObject(http_message_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z/", &zv)) { + + return; + + } + + + + if (obj->message->type == HTTP_MSG_NONE) { + + http_error(E_WARNING, HTTP_E_MSG, "Message is neither of type HTTP_MSG_RESPONSE nor HTTP_MSG_REQUEST"); + + RETURN_FALSE; + + } + + + + convert_to_double_ex(&zv); + + sprintf(v, "%1.1f", Z_DVAL_P(zv)); + + if (strcmp(v, "1.0") && strcmp(v, "1.1")) { + + http_error_ex(E_WARNING, HTTP_E_PARAM, "Invalid HTTP protocol version (1.0 or 1.1): %s", v); + + RETURN_FALSE; + + } + + + + if (obj->message->type == HTTP_MSG_RESPONSE) { + + obj->message->info.response.http_version = (float) Z_DVAL_P(zv); + + } else { + + obj->message->info.request.http_version = (float) Z_DVAL_P(zv); + + } + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto HttpMessage HttpMessage::getParentMessage() + + * + + * Get parent Message. + + */ + +PHP_METHOD(HttpMessage, getParentMessage) + +{ + + getObject(http_message_object, obj); + + + + NO_ARGS; + + + + if (obj->message->parent) { + + RETVAL_OBJVAL(obj->parent); + + } else { + + RETVAL_NULL(); + + } + +} + +/* }}} */ + + + +/* {{{ proto bool HttpMessage::send() + + * + + * Send the Message according to its type as Response or Request. + + */ + +PHP_METHOD(HttpMessage, send) + +{ + + getObject(http_message_object, obj); + + + + NO_ARGS; + + + + RETURN_SUCCESS(http_message_send(obj->message)); + +} + +/* }}} */ + + + +/* {{{ proto string HttpMessage::toString([bool include_parent = true]) + + * + + * Get the string representation of the Message. + + */ + +PHP_METHOD(HttpMessage, toString) + +{ + + char *string; + + size_t length; + + zend_bool include_parent = 1; + + getObject(http_message_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|b", &include_parent)) { + + RETURN_FALSE; + + } + + + + if (include_parent) { + + http_message_serialize(obj->message, &string, &length); + + } else { + + http_message_tostring(obj->message, &string, &length); + + } + + RETURN_STRINGL(string, length, 0); + +} + +/* }}} */ + + + +/* }}} */ + + + +#ifdef HTTP_HAVE_CURL + +/* {{{ HttpRequest */ + + + +/* {{{ proto void HttpRequest::__construct([string url[, long request_method = HTTP_GET]]) + + * + + * Instantiate a new HttpRequest object which can be used to issue HEAD, GET + + * and POST (including posting files) HTTP requests. + + */ + +PHP_METHOD(HttpRequest, __construct) + +{ + + char *URL = NULL; + + int URL_len; + + long meth = -1; + + getObject(http_request_object, obj); + + + + SET_EH_THROW_HTTP(); + + if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|sl", &URL, &URL_len, &meth)) { + + INIT_PARR(obj, options); + + INIT_PARR(obj, responseInfo); + + INIT_PARR(obj, responseData); + + INIT_PARR(obj, postData); + + INIT_PARR(obj, postFiles); + + + + if (URL) { + + UPD_PROP(obj, string, url, URL); + + } + + if (meth > -1) { + + UPD_PROP(obj, long, method, meth); + + } + + } + + SET_EH_NORMAL(); + +} + +/* }}} */ + + + +/* {{{ proto void HttpRequest::__destruct() + + * + + * Destroys the HttpRequest object. + + */ + +PHP_METHOD(HttpRequest, __destruct) + +{ + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + FREE_PARR(obj, options); + + FREE_PARR(obj, responseInfo); + + FREE_PARR(obj, responseData); + + FREE_PARR(obj, postData); + + FREE_PARR(obj, postFiles); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::setOptions(array options) + + * + + * Set the request options to use. See http_get() for a full list of available options. + + */ + +PHP_METHOD(HttpRequest, setOptions) + +{ + + char *key = NULL; + + long idx = 0; + + zval *opts, *old_opts, **opt; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a/", &opts)) { + + RETURN_FALSE; + + } + + + + old_opts = GET_PROP(obj, options); + + + + /* headers and cookies need extra attention -- thus cannot use array_merge() directly */ + + FOREACH_KEYVAL(opts, key, idx, opt) { + + if (key) { + + if (!strcmp(key, "headers")) { + + zval **headers; + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(old_opts), "headers", sizeof("headers"), (void **) &headers)) { + + array_merge(*opt, *headers); + + continue; + + } + + } else if (!strcmp(key, "cookies")) { + + zval **cookies; + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(old_opts), "cookies", sizeof("cookies"), (void **) &cookies)) { + + array_merge(*opt, *cookies); + + continue; + + } + + } + + zval_add_ref(opt); + + add_assoc_zval(old_opts, key, *opt); + + + + /* reset */ + + key = NULL; + + } + + } + + + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto array HttpRequest::getOptions() + + * + + * Get current set options. + + */ + +PHP_METHOD(HttpRequest, getOptions) + +{ + + zval *opts; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + opts = GET_PROP(obj, options); + + array_init(return_value); + + array_copy(opts, return_value); + +} + +/* }}} */ + + + +/* {{{ proto void HttpRequest::unsetOptions() + + * + + * Unset all options/headers/cookies. + + */ + +PHP_METHOD(HttpRequest, unsetOptions) + +{ + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + FREE_PARR(obj, options); + + INIT_PARR(obj, options); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::setSslOptions(array options) + + * + + * Set additional SSL options. + + */ + +PHP_METHOD(HttpRequest, setSslOptions) + +{ + + zval *opts, *old_opts, **ssl_options; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a/", &opts)) { + + RETURN_FALSE; + + } + + + + old_opts = GET_PROP(obj, options); + + + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(old_opts), "ssl", sizeof("ssl"), (void **) &ssl_options)) { + + array_merge(opts, *ssl_options); + + } else { + + zval_add_ref(&opts); + + add_assoc_zval(old_opts, "ssl", opts); + + } + + + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto array HttpRequest::getSslOtpions() + + * + + * Get previously set SSL options. + + */ + +PHP_METHOD(HttpRequest, getSslOptions) + +{ + + zval *opts, **ssl_options; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + opts = GET_PROP(obj, options); + + + + array_init(return_value); + + + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(opts), "ssl", sizeof("ssl"), (void **) &ssl_options)) { + + array_copy(*ssl_options, return_value); + + } + +} + +/* }}} */ + + + +/* {{{ proto void HttpRequest::unsetSslOptions() + + * + + * Unset previously set SSL options. + + */ + +PHP_METHOD(HttpRequest, unsetSslOptions) + +{ + + zval *opts; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + opts = GET_PROP(obj, options); + + zend_hash_del(Z_ARRVAL_P(opts), "ssl", sizeof("ssl")); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::addHeaders(array headers) + + * + + * Add request header name/value pairs. + + */ + +PHP_METHOD(HttpRequest, addHeaders) + +{ + + zval *opts, **headers, *new_headers; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a/", &new_headers)) { + + RETURN_FALSE; + + } + + + + opts = GET_PROP(obj, options); + + + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(opts), "headers", sizeof("headers"), (void **) &headers)) { + + array_merge(new_headers, *headers); + + } else { + + zval_add_ref(&new_headers); + + add_assoc_zval(opts, "headers", new_headers); + + } + + + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto array HttpRequest::getHeaders() + + * + + * Get previously set request headers. + + */ + +PHP_METHOD(HttpRequest, getHeaders) + +{ + + zval *opts, **headers; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + opts = GET_PROP(obj, options); + + + + array_init(return_value); + + + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(opts), "headers", sizeof("headers"), (void **) &headers)) { + + array_copy(*headers, return_value); + + } + +} + +/* }}} */ + + + +/* {{{ proto void HttpRequest::unsetHeaders() + + * + + * Unset previously set request headers. + + */ + +PHP_METHOD(HttpRequest, unsetHeaders) + +{ + + zval *opts; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + opts = GET_PROP(obj, options); + + zend_hash_del(Z_ARRVAL_P(opts), "headers", sizeof("headers")); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::addCookies(array cookies) + + * + + * Add cookies. + + */ + +PHP_METHOD(HttpRequest, addCookies) + +{ + + zval *opts, **cookies, *new_cookies; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a/", &new_cookies)) { + + RETURN_FALSE; + + } + + + + opts = GET_PROP(obj, options); + + + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(opts), "cookies", sizeof("cookies"), (void **) &cookies)) { + + array_merge(new_cookies, *cookies); + + } else { + + zval_add_ref(&new_cookies); + + add_assoc_zval(opts, "cookies", new_cookies); + + } + + + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto array HttpRequest::getCookies() + + * + + * Get previously set cookies. + + */ + +PHP_METHOD(HttpRequest, getCookies) + +{ + + zval *opts, **cookies; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + opts = GET_PROP(obj, options); + + + + array_init(return_value); + + + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(opts), "cookies", sizeof("cookies"), (void **) &cookies)) { + + array_copy(*cookies, return_value); + + } + +} + +/* }}} */ + + + +/* {{{ proto void HttpRequest::unsetCookies() + + * + + */ + +PHP_METHOD(HttpRequest, unsetCookies) + +{ + + zval *opts; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + opts = GET_PROP(obj, options); + + zend_hash_del(Z_ARRVAL_P(opts), "cookies", sizeof("cookies")); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::setURL(string url) + + * + + * Set the request URL. + + */ + +PHP_METHOD(HttpRequest, setURL) + +{ + + char *URL = NULL; + + int URL_len; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &URL, &URL_len)) { + + RETURN_FALSE; + + } + + + + UPD_PROP(obj, string, url, URL); + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto string HttpRequest::getUrl() + + * + + * Get the previously set request URL. + + */ + +PHP_METHOD(HttpRequest, getURL) + +{ + + zval *URL; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + URL = GET_PROP(obj, url); + + RETURN_STRINGL(Z_STRVAL_P(URL), Z_STRLEN_P(URL), 1); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::setMethod(long request_method) + + * + + * Set the request methods; one of the HTTP_HEAD, HTTP_GET or + + * HTTP_POST constants. + + */ + +PHP_METHOD(HttpRequest, setMethod) + +{ + + long meth; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &meth)) { + + RETURN_FALSE; + + } + + + + UPD_PROP(obj, long, method, meth); + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto long HttpRequest::getMethod() + + * + + * Get the previously set request method. + + */ + +PHP_METHOD(HttpRequest, getMethod) + +{ + + zval *meth; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + meth = GET_PROP(obj, method); + + RETURN_LONG(Z_LVAL_P(meth)); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::setContentType(string content_type) + + * + + * Set the content type the post request should have. + + * Use this only if you know what you're doing. + + */ + +PHP_METHOD(HttpRequest, setContentType) + +{ + + char *ctype; + + int ct_len; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &ctype, &ct_len)) { + + RETURN_FALSE; + + } + + + + if (!strchr(ctype, '/')) { + + http_error_ex(E_WARNING, HTTP_E_PARAM, "Content-Type '%s' doesn't seem to contain a primary and a secondary part", ctype); + + RETURN_FALSE; + + } + + + + UPD_PROP(obj, string, contentType, ctype); + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto string HttpRequest::getContentType() + + * + + * Get the previously content type. + + */ + +PHP_METHOD(HttpRequest, getContentType) + +{ + + zval *ctype; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + ctype = GET_PROP(obj, contentType); + + RETURN_STRINGL(Z_STRVAL_P(ctype), Z_STRLEN_P(ctype), 1); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::setQueryData(mixed query_data) + + * + + * Set the URL query parameters to use. + + * Overwrites previously set query parameters. + + * Affects any request types. + + */ + +PHP_METHOD(HttpRequest, setQueryData) + +{ + + zval *qdata; + + char *query_data = NULL; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z", &qdata)) { + + RETURN_FALSE; + + } + + + + if ((Z_TYPE_P(qdata) == IS_ARRAY) || (Z_TYPE_P(qdata) == IS_OBJECT)) { + + if (SUCCESS != http_urlencode_hash(HASH_OF(qdata), &query_data)) { + + RETURN_FALSE; + + } + + UPD_PROP(obj, string, queryData, query_data); + + efree(query_data); + + RETURN_TRUE; + + } + + + + convert_to_string(qdata); + + UPD_PROP(obj, string, queryData, Z_STRVAL_P(qdata)); + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto string HttpRequest::getQueryData() + + * + + * Get the current query data in form of an urlencoded query string. + + */ + +PHP_METHOD(HttpRequest, getQueryData) + +{ + + zval *qdata; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + qdata = GET_PROP(obj, queryData); + + RETURN_STRINGL(Z_STRVAL_P(qdata), Z_STRLEN_P(qdata), 1); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::addQueryData(array query_params) + + * + + * Add parameters to the query parameter list. + + * Affects any request type. + + */ + +PHP_METHOD(HttpRequest, addQueryData) + +{ + + zval *qdata, *old_qdata; + + char *query_data = NULL; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a", &qdata)) { + + RETURN_FALSE; + + } + + + + old_qdata = GET_PROP(obj, queryData); + + + + if (SUCCESS != http_urlencode_hash_ex(HASH_OF(qdata), 1, Z_STRVAL_P(old_qdata), Z_STRLEN_P(old_qdata), &query_data, NULL)) { + + RETURN_FALSE; + + } + + + + UPD_PROP(obj, string, queryData, query_data); + + efree(query_data); + + + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto void HttpRequest::unsetQueryData() + + * + + * Clean the query parameters. + + * Affects any request type. + + */ + +PHP_METHOD(HttpRequest, unsetQueryData) + +{ + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + UPD_PROP(obj, string, queryData, ""); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::addPostData(array post_data) + + * + + * Adds POST data entries. + + * Affects only POST requests. + + */ + +PHP_METHOD(HttpRequest, addPostData) + +{ + + zval *post, *post_data; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a", &post_data)) { + + RETURN_FALSE; + + } + + + + post = GET_PROP(obj, postData); + + array_merge(post_data, post); + + + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::setPostData(array post_data) + + * + + * Set the POST data entries. + + * Overwrites previously set POST data. + + * Affects only POST requests. + + */ + +PHP_METHOD(HttpRequest, setPostData) + +{ + + zval *post, *post_data; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a", &post_data)) { + + RETURN_FALSE; + + } + + + + post = GET_PROP(obj, postData); + + zend_hash_clean(Z_ARRVAL_P(post)); + + array_copy(post_data, post); + + + + RETURN_TRUE; + +} + +/* }}}*/ + + + +/* {{{ proto array HttpRequest::getPostData() + + * + + * Get previously set POST data. + + */ + +PHP_METHOD(HttpRequest, getPostData) + +{ + + zval *post_data; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + post_data = GET_PROP(obj, postData); + + array_init(return_value); + + array_copy(post_data, return_value); + +} + +/* }}} */ + + + +/* {{{ proto void HttpRequest::unsetPostData() + + * + + * Clean POST data entires. + + * Affects only POST requests. + + */ + +PHP_METHOD(HttpRequest, unsetPostData) + +{ + + zval *post_data; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + post_data = GET_PROP(obj, postData); + + zend_hash_clean(Z_ARRVAL_P(post_data)); + +} + +/* }}} */ + + + +/* {{{ proto bool HttpRequest::addPostFile(string name, string file[, string content_type = "application/x-octetstream"]) + + * + + * Add a file to the POST request. + + * Affects only POST requests. + + */ + +PHP_METHOD(HttpRequest, addPostFile) + +{ + + zval *files, *entry; + + char *name, *file, *type = NULL; + + int name_len, file_len, type_len = 0; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss|s", &name, &name_len, &file, &file_len, &type, &type_len)) { + + RETURN_FALSE; + + } + + + + if (type_len) { + + if (!strchr(type, '/')) { + + http_error_ex(E_WARNING, HTTP_E_PARAM, "Content-Type '%s' doesn't seem to contain a primary and a secondary part", type); + + RETURN_FALSE; + + } + + } else { + + type = "application/x-octetstream"; + + type_len = sizeof("application/x-octetstream") - 1; + + } + + + + MAKE_STD_ZVAL(entry); + + array_init(entry); + + + + add_assoc_stringl(entry, "name", name, name_len, 1); + + add_assoc_stringl(entry, "type", type, type_len, 1); + + add_assoc_stringl(entry, "file", file, file_len, 1); + + + + files = GET_PROP(obj, postFiles); + + add_next_index_zval(files, entry); + + + + RETURN_TRUE; + +} + +/* }}} */ + + + +/* {{{ proto array HttpRequest::getPostFiles() + + * + + * Get all previously added POST files. + + */ + +PHP_METHOD(HttpRequest, getPostFiles) + +{ + + zval *files; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + files = GET_PROP(obj, postFiles); + + + + array_init(return_value); + + array_copy(files, return_value); + +} + +/* }}} */ + + + +/* {{{ proto void HttpRequest::unsetPostFiles() + + * + + * Unset the POST files list. + + * Affects only POST requests. + + */ + +PHP_METHOD(HttpRequest, unsetPostFiles) + +{ + + zval *files; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + files = GET_PROP(obj, postFiles); + + zend_hash_clean(Z_ARRVAL_P(files)); + +} + +/* }}} */ + + + +/* {{{ proto array HttpRequest::getResponseData() + + * + + * Get all response data after the request has been sent. + + */ + +PHP_METHOD(HttpRequest, getResponseData) + +{ + + zval *data; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + data = GET_PROP(obj, responseData); + + array_init(return_value); + + array_copy(data, return_value); + +} + +/* }}} */ + + + +/* {{{ proto mixed HttpRequest::getResponseHeader([string name]) + + * + + * Get response header(s) after the request has been sent. + + */ + +PHP_METHOD(HttpRequest, getResponseHeader) + +{ + + zval *data, **headers, **header; + + char *header_name = NULL; + + int header_len = 0; + + getObject(http_response_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s", &header_name, &header_len)) { + + RETURN_FALSE; + + } + + + + data = GET_PROP(obj, responseData); + + if (SUCCESS != zend_hash_find(Z_ARRVAL_P(data), "headers", sizeof("headers"), (void **) &headers)) { + + RETURN_FALSE; + + } + + + + if (!header_len || !header_name) { + + array_init(return_value); + + array_copy(*headers, return_value); + + } else if (SUCCESS == zend_hash_find(Z_ARRVAL_PP(headers), pretty_key(header_name, header_len, 1, 1), header_len + 1, (void **) &header)) { + + RETURN_STRINGL(Z_STRVAL_PP(header), Z_STRLEN_PP(header), 1); + + } else { + + RETURN_FALSE; + + } + +} + +/* }}} */ + + + +/* {{{ proto array HttpRequest::getResponseCookie([string name]) + + * + + * Get response cookie(s) after the request has been sent. + + */ + +PHP_METHOD(HttpRequest, getResponseCookie) + +{ + + zval *data, **headers; + + char *cookie_name = NULL; + + int cookie_len = 0; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s", &cookie_name, &cookie_len)) { + + RETURN_FALSE; + + } + + + + array_init(return_value); + + + + data = GET_PROP(obj, responseData); + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(data), "headers", sizeof("headers"), (void **) &headers)) { + + ulong idx = 0; + + char *key = NULL; + + zval **header = NULL; + + + + FOREACH_HASH_KEYVAL(Z_ARRVAL_PP(headers), key, idx, header) { + + if (key && !strcasecmp(key, "Set-Cookie")) { + + /* several cookies? */ + + if (Z_TYPE_PP(header) == IS_ARRAY) { + + zval **cookie; + + + + FOREACH_HASH_VAL(Z_ARRVAL_PP(header), cookie) { + + zval *cookie_hash; + + MAKE_STD_ZVAL(cookie_hash); + + array_init(cookie_hash); + + + + if (SUCCESS == http_parse_cookie(Z_STRVAL_PP(cookie), Z_ARRVAL_P(cookie_hash))) { + + if (!cookie_len) { + + add_next_index_zval(return_value, cookie_hash); + + } else { + + zval **name; + + + + if ( (SUCCESS == zend_hash_find(Z_ARRVAL_P(cookie_hash), "name", sizeof("name"), (void **) &name)) && + + (!strcmp(Z_STRVAL_PP(name), cookie_name))) { + + add_next_index_zval(return_value, cookie_hash); + + return; /* <<< FOUND >>> */ + + } else { + + zval_dtor(cookie_hash); + + efree(cookie_hash); + + } + + } + + } else { + + zval_dtor(cookie_hash); + + efree(cookie_hash); + + } + + } + + } else { + + zval *cookie_hash; + + MAKE_STD_ZVAL(cookie_hash); + + array_init(cookie_hash); + + + + if (SUCCESS == http_parse_cookie(Z_STRVAL_PP(header), Z_ARRVAL_P(cookie_hash))) { + + if (!cookie_len) { + + add_next_index_zval(return_value, cookie_hash); + + } else { + + zval **name; + + + + if ( (SUCCESS == zend_hash_find(Z_ARRVAL_P(cookie_hash), "name", sizeof("name"), (void **) &name)) && + + (!strcmp(Z_STRVAL_PP(name), cookie_name))) { + + add_next_index_zval(return_value, cookie_hash); + + } else { + + zval_dtor(cookie_hash); + + efree(cookie_hash); + + } + + } + + } else { + + zval_dtor(cookie_hash); + + efree(cookie_hash); + + } + + } + + break; + + } + + /* reset key */ + + key = NULL; + + } + + } + +} + +/* }}} */ + + + +/* {{{ proto string HttpRequest::getResponseBody() + + * + + * Get the response body after the request has been sent. + + */ + +PHP_METHOD(HttpRequest, getResponseBody) + +{ + + zval *data, **body; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + data = GET_PROP(obj, responseData); + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(data), "body", sizeof("body"), (void **) &body)) { + + RETURN_STRINGL(Z_STRVAL_PP(body), Z_STRLEN_PP(body), 1); + + } else { + + RETURN_FALSE; + + } + +} + +/* }}} */ + + + +/* {{{ proto int HttpRequest::getResponseCode() + + * + + * Get the response code after the request has been sent. + + */ + +PHP_METHOD(HttpRequest, getResponseCode) + +{ + + zval *code; + + getObject(http_request_object, obj); + + + + NO_ARGS; + + + + code = GET_PROP(obj, responseCode); + + RETURN_LONG(Z_LVAL_P(code)); + +} + +/* }}} */ + + + +/* {{{ proto array HttpRequest::getResponseInfo([string name]) + + * + + * Get response info after the request has been sent. + + * See http_get() for a full list of returned info. + + */ + +PHP_METHOD(HttpRequest, getResponseInfo) + +{ + + zval *info, **infop; + + char *info_name = NULL; + + int info_len = 0; + + getObject(http_request_object, obj); + + + + if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s", &info_name, &info_len)) { + + RETURN_FALSE; + + } + + + + info = GET_PROP(obj, responseInfo); + + + + if (info_len && info_name) { + + if (SUCCESS == zend_hash_find(Z_ARRVAL_P(info), pretty_key(info_name, info_len, 0, 0), info_len + 1, (void **) &infop)) { + + RETURN_ZVAL(*infop, 1, ZVAL_PTR_DTOR); + + } else { + + http_error_ex(E_NOTICE, HTTP_E_PARAM, "Could not find response info named %s", info_name); + + RETURN_FALSE; + + } + + } else { + + array_init(return_value); + + array_copy(info, return_value); + + } + } + /* }}}*/ -/* {{{ proto array HTTPi_Request::getPostData() - * - */ -PHP_METHOD(HTTPi_Request, getPostData) -{ - zval *post_data; - getObject(httpi_request_object, obj); - NO_ARGS; - post_data = GET_PROP(obj, postData); - array_init(return_value); - array_copy(post_data, return_value); -} -/* }}} */ +/* {{{ proto HttpMessage HttpRequest::getResponseMessage() -/* {{{ proto void HTTPi_Request::unsetPostData() * + + * Get the full response as HttpMessage object. + */ -PHP_METHOD(HTTPi_Request, unsetPostData) + +PHP_METHOD(HttpRequest, getResponseMessage) + { - zval *post_data; - getObject(httpi_request_object, obj); + + zval *message; + + getObject(http_request_object, obj); + + NO_ARGS; - post_data = GET_PROP(obj, postData); - zend_hash_clean(Z_ARRVAL_P(post_data)); -} -/* }}} */ -/* {{{ proto bool HTTPi_Request::addPostFile(string name, string file[, string content_type = "application/x-octetstream"]) - * - */ -PHP_METHOD(HTTPi_Request, addPostFile) -{ - zval *files, *entry; - char *name, *file, *type = NULL; - int name_len, file_len, type_len = 0; - getObject(httpi_request_object, obj); - if (SUCCESS != zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss|s", &name, &name_len, &file, &file_len, &type, &type_len)) { - RETURN_FALSE; - } + message = GET_PROP(obj, responseMessage); - if (type_len) { - if (!strchr(type, '/')) { - php_error_docref(NULL TSRMLS_CC, E_WARNING, "Content-Type '%s' doesn't seem to contain a primary and a secondary part", type); - RETURN_FALSE; - } - } else { - type = "application/x-octetstream"; - type_len = sizeof("application/x-octetstream") - 1; - } + Z_TYPE_P(return_value) = IS_OBJECT; - MAKE_STD_ZVAL(entry); - array_init(entry); + return_value->is_ref = 1; - add_assoc_stringl(entry, "name", name, name_len, 1); - add_assoc_stringl(entry, "type", type, type_len, 1); - add_assoc_stringl(entry, "file", file, file_len, 1); + return_value->value.obj = message->value.obj; - files = GET_PROP(obj, postFiles); - add_next_index_zval(files, entry); + zval_add_ref(&return_value); - RETURN_TRUE; } -/* }}} */ -/* {{{ proto array HTTPi_Request::getPostFiles() - * - */ -PHP_METHOD(HTTPi_Request, getPostFiles) -{ - zval *files; - getObject(httpi_request_object, obj); - NO_ARGS; - files = GET_PROP(obj, postFiles); +/* {{{ proto bool HttpRequest::send() - array_init(return_value); - array_copy(files, return_value); -} -/* }}} */ + * + + * Send the HTTP request. -/* {{{ proto void HTTPi_Request::unsetPostFiles() * - */ -PHP_METHOD(HTTPi_Request, unsetPostFiles) -{ - zval *files; - getObject(httpi_request_object, obj); - NO_ARGS; + * GET example: - files = GET_PROP(obj, postFiles); - zend_hash_clean(Z_ARRVAL_P(files)); -} -/* }}} */ + * 
 
-/* {{{ proto array HTTPi_Request::getResponseData()
- *
- */
-PHP_METHOD(HTTPi_Request, getResponseData)
-{
-	zval *data;
-	getObject(httpi_request_object, obj);
+ * setOptions(array('lastmodified' => filemtime('local.rss')));
 
-/* {{{ proto array HTTPi_Request::getResponseHeaders()
- *
- */
-PHP_METHOD(HTTPi_Request, getResponseHeaders)
-{
-	zval *data, **headers;
-	getObject(httpi_request_object, obj);
+ * $r->addQueryData(array('category' => 3));
 
-	NO_ARGS;
+ * try {
 
-	array_init(return_value);
-	data = GET_PROP(obj, responseData);
-	if (SUCCESS == zend_hash_find(Z_ARRVAL_P(data), "headers", sizeof("headers"), (void **) &headers)) {
-		array_copy(*headers, return_value);
-	}
-}
-/* }}} */
+ *     $r->send();
 
-/* {{{ proto string HTTPi_Request::getResponseBody()
- *
- */
-PHP_METHOD(HTTPi_Request, getResponseBody)
-{
-	zval *data, **body;
-	getObject(httpi_request_object, obj);
+ *     if ($r->getResponseCode() == 200) {
 
-	NO_ARGS;
+ *         file_put_contents('local.rss', $r->getResponseBody());
 
-	data = GET_PROP(obj, responseData);
-	if (SUCCESS == zend_hash_find(Z_ARRVAL_P(data), "body", sizeof("body"), (void **) &body)) {
-		RETURN_STRINGL(Z_STRVAL_PP(body), Z_STRLEN_PP(body), 1);
-	} else {
-		Z_TYPE_P(return_value) = IS_NULL;
-	}
-}
-/* }}} */
+ *    }
 
-/* {{{ proto array HTTPi_Request::getResponseInfo()
- *
- */
-PHP_METHOD(HTTPi_Request, getResponseInfo)
-{
-	zval *info;
-	getObject(httpi_request_object, obj);
+ * } catch (HttpException $ex) {
 
-	NO_ARGS;
+ *     echo $ex;
 
-	info = GET_PROP(obj, responseInfo);
-	array_init(return_value);
-	array_copy(info, return_value);
-}
-/* }}}*/
+ * }
+
+ * ?>
+
+ *
-/* {{{ proto bool HTTPi_Request::send() * + + * POST example: + + * 
+
+ * setOptions(array('cookies' => array('lang' => 'de')));
+
+ * $r->addPostData(array('user' => 'mike', 'pass' => 's3c|r3t'));
+
+ * $r->addPostFile('image', 'profile.jpg', 'image/jpeg');
+
+ * if ($r->send()) {
+
+ *     echo $r->getResponseBody();
+
+ * }
+
+ * ?>
+
+ *
+ */ -PHP_METHOD(HTTPi_Request, send) + +PHP_METHOD(HttpRequest, send) + { + STATUS status = FAILURE; + zval *meth, *URL, *qdata, *opts, *info, *resp; - char *response_data, *request_uri; - size_t response_len; - getObject(httpi_request_object, obj); + + char *request_uri; + + getObject(http_request_object, obj); + + NO_ARGS; + + + SET_EH_THROW_HTTP(); + + + if ((!obj->ch) && (!(obj->ch = curl_easy_init()))) { - php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not initilaize cURL"); + + http_error(E_WARNING, HTTP_E_CURL, "Could not initilaize curl"); + RETURN_FALSE; + } + + meth = GET_PROP(obj, method); + URL = GET_PROP(obj, url); + qdata = GET_PROP(obj, queryData); + opts = GET_PROP(obj, options); + info = GET_PROP(obj, responseInfo); + resp = GET_PROP(obj, responseData); - // HTTP_URI_MAXLEN+1 big char * - request_uri = http_absolute_uri(Z_STRVAL_P(URL), NULL); + + + // HTTP_URI_MAXLEN+1 long char * + + request_uri = http_absolute_uri_ex(Z_STRVAL_P(URL), Z_STRLEN_P(URL), NULL, 0, NULL, 0, 0); + + if (Z_STRLEN_P(qdata) && (strlen(request_uri) < HTTP_URI_MAXLEN)) { + if (!strchr(request_uri, '?')) { + strcat(request_uri, "?"); + } else { + strcat(request_uri, "&"); + } + strncat(request_uri, Z_STRVAL_P(qdata), HTTP_URI_MAXLEN - strlen(request_uri)); + } + + switch (Z_LVAL_P(meth)) + { + case HTTP_GET: - status = http_get_ex(obj->ch, request_uri, Z_ARRVAL_P(opts), Z_ARRVAL_P(info), &response_data, &response_len); - break; case HTTP_HEAD: - status = http_head_ex(obj->ch, request_uri, Z_ARRVAL_P(opts), Z_ARRVAL_P(info), &response_data, &response_len); + + status = http_request_ex(obj->ch, Z_LVAL_P(meth), request_uri, NULL, Z_ARRVAL_P(opts), Z_ARRVAL_P(info), &obj->response); + + break; + + + + case HTTP_PUT: + break; + + case HTTP_POST: - { - zval *post_files, *post_data; - post_files = GET_PROP(obj, postFiles); - post_data = GET_PROP(obj, postData); + default: - if (!zend_hash_num_elements(Z_ARRVAL_P(post_files))) { + { - /* urlencoded post */ - status = http_post_array_ex(obj->ch, request_uri, Z_ARRVAL_P(post_data), Z_ARRVAL_P(opts), Z_ARRVAL_P(info), &response_data, &response_len); + http_request_body body; - } else { + zval *fields = GET_PROP(obj, postData), *files = GET_PROP(obj, postFiles); - /* - * multipart post - */ - char *key = NULL; - long idx; - zval **data; - struct curl_httppost *http_post_data[2] = {NULL, NULL}; - - /* normal data */ - FOREACH_KEYVAL(post_data, key, idx, data) { - if (key) { - convert_to_string_ex(data); - curl_formadd(&http_post_data[0], &http_post_data[1], - CURLFORM_COPYNAME, key, - CURLFORM_COPYCONTENTS, Z_STRVAL_PP(data), - CURLFORM_CONTENTSLENGTH, Z_STRLEN_PP(data), - CURLFORM_END - ); - - /* reset */ - key = NULL; - } - } - /* file data */ - FOREACH_VAL(post_files, data) { - zval **file, **type, **name; - if ( SUCCESS == zend_hash_find(Z_ARRVAL_PP(data), "name", sizeof("name"), (void **) &name) && - SUCCESS == zend_hash_find(Z_ARRVAL_PP(data), "type", sizeof("type"), (void **) &type) && - SUCCESS == zend_hash_find(Z_ARRVAL_PP(data), "file", sizeof("file"), (void **) &file)) { + if (SUCCESS == (status = http_request_body_fill(&body, Z_ARRVAL_P(fields), Z_ARRVAL_P(files)))) { - curl_formadd(&http_post_data[0], &http_post_data[1], - CURLFORM_COPYNAME, Z_STRVAL_PP(name), - CURLFORM_FILE, Z_STRVAL_PP(file), - CURLFORM_CONTENTTYPE, Z_STRVAL_PP(type), - CURLFORM_END - ); - } - } + status = http_request_ex(obj->ch, Z_LVAL_P(meth), request_uri, &body, Z_ARRVAL_P(opts), Z_ARRVAL_P(info), &obj->response); + + http_request_body_dtor(&body); - status = http_post_curldata_ex(obj->ch, request_uri, http_post_data[0], Z_ARRVAL_P(opts), Z_ARRVAL_P(info), &response_data, &response_len); - curl_formfree(http_post_data[0]); - } } - break; - default: + } + break; + } + + efree(request_uri); + + /* final data handling */ - if (status != SUCCESS) { - RETURN_FALSE; - } else { - zval *zheaders, *zbody; - MAKE_STD_ZVAL(zbody); - MAKE_STD_ZVAL(zheaders) - array_init(zheaders); + if (status == SUCCESS) { - if (SUCCESS != http_split_response_ex(response_data, response_len, zheaders, zbody)) { - zval_dtor(zheaders); - efree(zheaders), - efree(zbody); - efree(response_data); - RETURN_FALSE; - } + http_message *msg; - add_assoc_zval(resp, "headers", zheaders); - add_assoc_zval(resp, "body", zbody); - efree(response_data); - RETURN_TRUE; + if (msg = http_message_parse(PHPSTR_VAL(&obj->response), PHPSTR_LEN(&obj->response))) { + + zval *headers, *message; + + char *body; + + size_t body_len; + + + + UPD_PROP(obj, long, responseCode, msg->info.response.code); + + + + MAKE_STD_ZVAL(headers) + + array_init(headers); + + + + zend_hash_copy(Z_ARRVAL_P(headers), &msg->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *)); + + phpstr_data(PHPSTR(msg), &body, &body_len); + + + + add_assoc_zval(resp, "headers", headers); + + add_assoc_stringl(resp, "body", body, body_len, 0); + + + + message = GET_PROP(obj, responseMessage); + + zval_dtor(message); + + Z_TYPE_P(message) = IS_OBJECT; + + message->value.obj = http_message_object_from_msg(msg); + + SET_PROP(obj, responseMessage, message); + + } else { + + status = FAILURE; + + } + } - /* */ + + + + SET_EH_NORMAL(); + + RETURN_SUCCESS(status); + } + /* }}} */ + /* }}} */ + #endif /* HTTP_HAVE_CURL */ + + #endif /* ZEND_ENGINE_2 */ + + /* + * 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 - */ \ No newline at end of file + + */ +