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