git.m6w6.name Git - m6w6/ext-http/blob - php_http_client_request.c

   1 /*
   2     +--------------------------------------------------------------------+
   3     | PECL :: http                                                       |
   4     +--------------------------------------------------------------------+
   5     | Redistribution and use in source and binary forms, with or without |
   6     | modification, are permitted provided that the conditions mentioned |
   7     | in the accompanying LICENSE file are met.                          |
   8     +--------------------------------------------------------------------+
   9     | Copyright (c) 2004-2011, Michael Wallner <mike@php.net>            |
  10     +--------------------------------------------------------------------+
  11 */
  12
  13 #include "php_http_api.h"
  14
  15 void php_http_client_options_set_subr(zval *this_ptr, char *key, size_t len, zval *opts, int overwrite TSRMLS_DC);
  16 void php_http_client_options_set(zval *this_ptr, zval *opts TSRMLS_DC);
  17 void php_http_client_options_get_subr(zval *this_ptr, char *key, size_t len, zval *return_value TSRMLS_DC);
  18
  19 #define PHP_HTTP_BEGIN_ARGS(method, req_args)                   PHP_HTTP_BEGIN_ARGS_EX(HttpClientRequest, method, 0, req_args)
  20 #define PHP_HTTP_EMPTY_ARGS(method)                                             PHP_HTTP_EMPTY_ARGS_EX(HttpClientRequest, method, 0)
  21 #define PHP_HTTP_CLIENT_REQUEST_ME(method, visibility)  PHP_ME(HttpClientRequest, method, PHP_HTTP_ARGS(HttpClientRequest, method), visibility)
  22 #define PHP_HTTP_CLIENT_REQUEST_ALIAS(method, func)             PHP_HTTP_STATIC_ME_ALIAS(method, func, PHP_HTTP_ARGS(HttpClientRequest, method))
  23 #define PHP_HTTP_CLIENT_REQUEST_MALIAS(me, al, vis)             ZEND_FENTRY(me, ZEND_MN(HttpClientRequest_##al), PHP_HTTP_ARGS(HttpClientRequest, al), vis)
  24
  25 PHP_HTTP_BEGIN_ARGS(__construct, 0)
  26         PHP_HTTP_ARG_VAL(method, 0)
  27         PHP_HTTP_ARG_VAL(url, 0)
  28         PHP_HTTP_ARG_ARR(headers, 1, 0)
  29         PHP_HTTP_ARG_OBJ(http\\Message\\Body, body, 1)
  30 PHP_HTTP_END_ARGS;
  31
  32 PHP_HTTP_EMPTY_ARGS(getContentType);
  33 PHP_HTTP_BEGIN_ARGS(setContentType, 1)
  34         PHP_HTTP_ARG_VAL(content_type, 0)
  35 PHP_HTTP_END_ARGS;
  36
  37 PHP_HTTP_EMPTY_ARGS(getQuery);
  38 PHP_HTTP_BEGIN_ARGS(setQuery, 0)
  39         PHP_HTTP_ARG_VAL(query_data, 0)
  40 PHP_HTTP_END_ARGS;
  41
  42 PHP_HTTP_BEGIN_ARGS(addQuery, 1)
  43         PHP_HTTP_ARG_VAL(query_data, 0)
  44 PHP_HTTP_END_ARGS;
  45
  46 PHP_HTTP_EMPTY_ARGS(getOptions);
  47 PHP_HTTP_BEGIN_ARGS(setOptions, 0)
  48         PHP_HTTP_ARG_ARR(options, 1, 0)
  49 PHP_HTTP_END_ARGS;
  50
  51 PHP_HTTP_EMPTY_ARGS(getSslOptions);
  52 PHP_HTTP_BEGIN_ARGS(setSslOptions, 0)
  53         PHP_HTTP_ARG_ARR(ssl_options, 1, 0)
  54 PHP_HTTP_END_ARGS;
  55
  56 PHP_HTTP_BEGIN_ARGS(addSslOptions, 0)
  57         PHP_HTTP_ARG_ARR(ssl_options, 1, 0)
  58 PHP_HTTP_END_ARGS;
  59
  60
  61 static zend_class_entry *php_http_client_request_class_entry;
  62
  63 zend_class_entry * php_http_client_request_get_class_entry(void)
  64 {
  65         return php_http_client_request_class_entry;
  66 }
  67
  68 static zend_function_entry php_http_client_request_method_entry[] = {
  69         PHP_HTTP_CLIENT_REQUEST_ME(__construct, ZEND_ACC_PUBLIC|ZEND_ACC_CTOR)
  70         PHP_HTTP_CLIENT_REQUEST_ME(getQuery, ZEND_ACC_PUBLIC)
  71         PHP_HTTP_CLIENT_REQUEST_ME(setQuery, ZEND_ACC_PUBLIC)
  72         PHP_HTTP_CLIENT_REQUEST_ME(addQuery, ZEND_ACC_PUBLIC)
  73         PHP_HTTP_CLIENT_REQUEST_ME(getContentType, ZEND_ACC_PUBLIC)
  74         PHP_HTTP_CLIENT_REQUEST_ME(setContentType, ZEND_ACC_PUBLIC)
  75         PHP_HTTP_CLIENT_REQUEST_ME(setOptions, ZEND_ACC_PUBLIC)
  76         PHP_HTTP_CLIENT_REQUEST_ME(getOptions, ZEND_ACC_PUBLIC)
  77         PHP_HTTP_CLIENT_REQUEST_ME(setSslOptions, ZEND_ACC_PUBLIC)
  78         PHP_HTTP_CLIENT_REQUEST_ME(getSslOptions, ZEND_ACC_PUBLIC)
  79         PHP_HTTP_CLIENT_REQUEST_ME(addSslOptions, ZEND_ACC_PUBLIC)
  80         EMPTY_FUNCTION_ENTRY
  81 };
  82
  83
  84 PHP_METHOD(HttpClientRequest, __construct)
  85 {
  86         char *meth_str = NULL, *url_str = NULL;
  87         int meth_len = 0, url_len = 0;
  88         zval *zheaders = NULL, *zbody = NULL;
  89
  90         with_error_handling(EH_THROW, php_http_exception_get_class_entry()) {
  91                 if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s!s!a!O!", &meth_str, &meth_len, &url_str, &url_len, &zheaders, &zbody, php_http_message_body_get_class_entry())) {
  92                         php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
  93                         php_http_message_body_object_t *body_obj = NULL;
  94
  95                         if (zbody) {
  96                                 body_obj = zend_object_store_get_object(zbody TSRMLS_CC);
  97                                 Z_OBJ_ADDREF_P(zbody);
  98                                 obj->body = Z_OBJVAL_P(zbody);
  99                                 php_http_message_body_addref(body_obj->body);
 100                         }
 101
 102                         if (obj->message) {
 103                                 php_http_message_set_type(obj->message, PHP_HTTP_REQUEST);
 104                                 if (body_obj) {
 105                                         php_http_message_body_free(&obj->message->body);
 106                                         obj->message->body = body_obj->body;
 107                                 }
 108                         } else {
 109                                 obj->message = php_http_message_init(NULL, PHP_HTTP_REQUEST, body_obj ? body_obj->body : NULL TSRMLS_CC);
 110                         }
 111
 112                         if (meth_str && meth_len) {
 113                                 PHP_HTTP_INFO(obj->message).request.method = estrndup(meth_str, meth_len);
 114                         }
 115                         if (url_str && url_len) {
 116                                 PHP_HTTP_INFO(obj->message).request.url = estrndup(url_str, url_len);
 117                         }
 118                         if (zheaders) {
 119                                 array_copy(Z_ARRVAL_P(zheaders), &obj->message->hdrs);
 120                         }
 121                 }
 122         } end_error_handling();
 123 }
 124
 125
 126 PHP_METHOD(HttpClientRequest, setContentType)
 127 {
 128         char *ct_str;
 129         int ct_len;
 130
 131         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &ct_str, &ct_len)) {
 132                 int invalid = 0;
 133
 134                 if (ct_len) {
 135                         PHP_HTTP_CHECK_CONTENT_TYPE(ct_str, invalid = 1);
 136                 }
 137
 138                 if (!invalid) {
 139                         php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
 140                         zval *zct;
 141
 142                         MAKE_STD_ZVAL(zct);
 143                         ZVAL_STRINGL(zct, ct_str, ct_len, 1);
 144                         zend_hash_update(&obj->message->hdrs, "Content-Type", sizeof("Content-Type"), (void *) &zct, sizeof(void *), NULL);
 145                 }
 146         }
 147         RETVAL_ZVAL(getThis(), 1, 0);
 148 }
 149
 150 PHP_METHOD(HttpClientRequest, getContentType)
 151 {
 152         if (SUCCESS == zend_parse_parameters_none()) {
 153                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
 154                 zval *zct = php_http_message_header(obj->message, ZEND_STRL("Content-Type"), 1);
 155
 156                 RETURN_ZVAL(zct, 0, 1);
 157         }
 158         RETURN_FALSE;
 159 }
 160
 161 PHP_METHOD(HttpClientRequest, setQuery)
 162 {
 163         zval *qdata = NULL;
 164
 165         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z!", &qdata)) {
 166                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
 167                 php_url *old_url = NULL, new_url = {NULL};
 168                 char empty[] = "";
 169
 170                 if (qdata) {
 171                         zval arr, str;
 172
 173                         INIT_PZVAL(&arr);
 174                         array_init(&arr);
 175                         INIT_PZVAL(&str);
 176                         ZVAL_NULL(&str);
 177
 178                         php_http_querystring_update(&arr, qdata, &str TSRMLS_CC);
 179                         new_url.query = Z_STRVAL(str);
 180                         zval_dtor(&arr);
 181                 } else {
 182                         new_url.query = &empty[0];
 183                 }
 184
 185                 if (obj->message->http.info.request.url) {
 186                         old_url = php_url_parse(obj->message->http.info.request.url);
 187                         efree(obj->message->http.info.request.url);
 188                 }
 189
 190                 php_http_url(PHP_HTTP_URL_REPLACE, old_url, &new_url, NULL, &obj->message->http.info.request.url, NULL TSRMLS_CC);
 191
 192                 if (old_url) {
 193                         php_url_free(old_url);
 194                 }
 195                 if (new_url.query != &empty[0]) {
 196                         STR_FREE(new_url.query);
 197                 }
 198         }
 199         RETVAL_ZVAL(getThis(), 1, 0);
 200 }
 201
 202 PHP_METHOD(HttpClientRequest, getQuery)
 203 {
 204         if (SUCCESS == zend_parse_parameters_none()) {
 205                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
 206
 207                 if (obj->message->http.info.request.url) {
 208                         php_url *purl = php_url_parse(obj->message->http.info.request.url);
 209
 210                         if (purl) {
 211                                 if (purl->query) {
 212                                         RETVAL_STRING(purl->query, 0);
 213                                         purl->query = NULL;
 214                                 }
 215                                 php_url_free(purl);
 216                         }
 217                 }
 218         }
 219 }
 220
 221 PHP_METHOD(HttpClientRequest, addQuery)
 222 {
 223         zval *qdata;
 224
 225         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "z", &qdata)) {
 226                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
 227                 php_url *old_url = NULL, new_url = {NULL};
 228
 229                 zval arr, str;
 230
 231                 INIT_PZVAL(&arr);
 232                 array_init(&arr);
 233                 INIT_PZVAL(&str);
 234                 ZVAL_NULL(&str);
 235
 236                 php_http_querystring_update(&arr, qdata, &str TSRMLS_CC);
 237                 new_url.query = Z_STRVAL(str);
 238                 zval_dtor(&arr);
 239
 240                 if (obj->message->http.info.request.url) {
 241                         old_url = php_url_parse(obj->message->http.info.request.url);
 242                         efree(obj->message->http.info.request.url);
 243                 }
 244
 245                 php_http_url(PHP_HTTP_URL_JOIN_QUERY, old_url, &new_url, NULL, &obj->message->http.info.request.url, NULL TSRMLS_CC);
 246
 247                 if (old_url) {
 248                         php_url_free(old_url);
 249                 }
 250                 STR_FREE(new_url.query);
 251         }
 252         RETVAL_ZVAL(getThis(), 1, 0);
 253 }
 254
 255 PHP_METHOD(HttpClientRequest, setOptions)
 256 {
 257         zval *opts = NULL;
 258
 259         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|a!/", &opts)) {
 260                 php_http_client_options_set(getThis(), opts TSRMLS_CC);
 261
 262                 RETVAL_ZVAL(getThis(), 1, 0);
 263         }
 264 }
 265
 266 PHP_METHOD(HttpClientRequest, getOptions)
 267 {
 268         if (SUCCESS == zend_parse_parameters_none()) {
 269                 RETURN_PROP(php_http_client_request_class_entry, "options");
 270         }
 271         RETURN_FALSE;
 272 }
 273
 274 PHP_METHOD(HttpClientRequest, setSslOptions)
 275 {
 276         zval *opts = NULL;
 277
 278         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|a!/", &opts)) {
 279                 php_http_client_options_set_subr(getThis(), ZEND_STRS("ssl"), opts, 1 TSRMLS_CC);
 280
 281                 RETVAL_ZVAL(getThis(), 1, 0);
 282         }
 283 }
 284
 285 PHP_METHOD(HttpClientRequest, addSslOptions)
 286 {
 287         zval *opts = NULL;
 288
 289         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|a!/", &opts)) {
 290                 php_http_client_options_set_subr(getThis(), ZEND_STRS("ssl"), opts, 0 TSRMLS_CC);
 291
 292                 RETVAL_ZVAL(getThis(), 1, 0);
 293         }
 294 }
 295
 296 PHP_METHOD(HttpClientRequest, getSslOptions)
 297 {
 298         if (SUCCESS == zend_parse_parameters_none()) {
 299                 php_http_client_options_get_subr(getThis(), ZEND_STRS("ssl"), return_value TSRMLS_CC);
 300         }
 301 }
 302
 303 PHP_MINIT_FUNCTION(http_client_request)
 304 {
 305         PHP_HTTP_REGISTER_CLASS(http\\Client, Request, http_client_request, php_http_message_get_class_entry(), 0);
 306
 307         zend_declare_property_null(php_http_client_request_class_entry, ZEND_STRL("options"), ZEND_ACC_PROTECTED TSRMLS_CC);
 308
 309         return SUCCESS;
 310 }
 311
 312 /*
 313  * Local variables:
 314  * tab-width: 4
 315  * c-basic-offset: 4
 316  * End:
 317  * vim600: noet sw=4 ts=4 fdm=marker
 318  * vim<600: noet sw=4 ts=4
 319  */
 320