git.m6w6.name Git - m6w6/ext-http/blob - php_http_message.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-2014, Michael Wallner <mike@php.net>            |
  10     +--------------------------------------------------------------------+
  11 */
  12
  13 #include "php_http_api.h"
  14
  15 static void message_headers(php_http_message_t *msg, php_http_buffer_t *str);
  16
  17 zend_bool php_http_message_info_callback(php_http_message_t **message, HashTable **headers, php_http_info_t *info TSRMLS_DC)
  18 {
  19         php_http_message_t *old = *message;
  20
  21         /* advance message */
  22         if (!old || old->type || zend_hash_num_elements(&old->hdrs)) {
  23                 (*message) = php_http_message_init(NULL, 0, NULL TSRMLS_CC);
  24                 (*message)->parent = old;
  25                 if (headers) {
  26                         (*headers) = &((*message)->hdrs);
  27                 }
  28         }
  29
  30         if (info) {
  31                 php_http_message_set_info(*message, info);
  32         }
  33
  34         return old != *message;
  35 }
  36
  37 php_http_message_t *php_http_message_init(php_http_message_t *message, php_http_message_type_t type, php_http_message_body_t *body TSRMLS_DC)
  38 {
  39         if (!message) {
  40                 message = emalloc(sizeof(*message));
  41         }
  42         memset(message, 0, sizeof(*message));
  43         TSRMLS_SET_CTX(message->ts);
  44
  45         php_http_message_set_type(message, type);
  46         message->http.version.major = 1;
  47         message->http.version.minor = 1;
  48         zend_hash_init(&message->hdrs, 0, NULL, ZVAL_PTR_DTOR, 0);
  49         message->body = body ? body : php_http_message_body_init(NULL, NULL TSRMLS_CC);
  50
  51         return message;
  52 }
  53
  54 php_http_message_t *php_http_message_init_env(php_http_message_t *message, php_http_message_type_t type TSRMLS_DC)
  55 {
  56         int free_msg = !message;
  57         zval *sval, tval;
  58         php_http_message_body_t *mbody;
  59
  60         switch (type) {
  61                 case PHP_HTTP_REQUEST:
  62                         mbody = php_http_env_get_request_body(TSRMLS_C);
  63                         php_http_message_body_addref(mbody);
  64                         message = php_http_message_init(message, type, mbody TSRMLS_CC);
  65                         if ((sval = php_http_env_get_server_var(ZEND_STRL("SERVER_PROTOCOL"), 1 TSRMLS_CC)) && !strncmp(Z_STRVAL_P(sval), "HTTP/", lenof("HTTP/"))) {
  66                                 php_http_version_parse(&message->http.version, Z_STRVAL_P(sval) TSRMLS_CC);
  67                         }
  68                         if ((sval = php_http_env_get_server_var(ZEND_STRL("REQUEST_METHOD"), 1 TSRMLS_CC))) {
  69                                 message->http.info.request.method = estrdup(Z_STRVAL_P(sval));
  70                         }
  71                         if ((sval = php_http_env_get_server_var(ZEND_STRL("REQUEST_URI"), 1 TSRMLS_CC))) {
  72                                 message->http.info.request.url = estrdup(Z_STRVAL_P(sval));
  73                         }
  74
  75                         php_http_env_get_request_headers(&message->hdrs TSRMLS_CC);
  76                         break;
  77
  78                 case PHP_HTTP_RESPONSE:
  79                         message = php_http_message_init(NULL, type, NULL TSRMLS_CC);
  80                         if (!SG(sapi_headers).http_status_line || !php_http_info_parse((php_http_info_t *) &message->http, SG(sapi_headers).http_status_line TSRMLS_CC)) {
  81                                 if (!(message->http.info.response.code = SG(sapi_headers).http_response_code)) {
  82                                         message->http.info.response.code = 200;
  83                                 }
  84                                 message->http.info.response.status = estrdup(php_http_env_get_response_status_for_code(message->http.info.response.code));
  85                         }
  86
  87                         php_http_env_get_response_headers(&message->hdrs TSRMLS_CC);
  88 #if PHP_VERSION_ID >= 50400
  89                         if (php_output_get_level(TSRMLS_C)) {
  90                                 if (php_output_get_status(TSRMLS_C) & PHP_OUTPUT_SENT) {
  91                                         php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not fetch response body, output has already been sent at %s:%d", php_output_get_start_filename(TSRMLS_C), php_output_get_start_lineno(TSRMLS_C));
  92                                         goto error;
  93                                 } else if (SUCCESS != php_output_get_contents(&tval TSRMLS_CC)) {
  94                                         php_error_docref(NULL TSRMLS_CC, E_WARNING, "Could not fetch response body");
  95                                         goto error;
  96                                 } else {
  97                                         php_http_message_body_append(message->body, Z_STRVAL(tval), Z_STRLEN(tval));
  98                                         zval_dtor(&tval);
  99                                 }
 100                         }
 101 #endif
 102                         break;
 103
 104                 default:
 105                 error:
 106                         if (free_msg) {
 107                                 if (message) {
 108                                         php_http_message_free(&message);
 109                                 }
 110                         } else {
 111                                 message = NULL;
 112                         }
 113                         break;
 114         }
 115
 116         return message;
 117 }
 118
 119 php_http_message_t *php_http_message_parse(php_http_message_t *msg, const char *str, size_t len, zend_bool greedy TSRMLS_DC)
 120 {
 121         php_http_message_parser_t p;
 122         php_http_buffer_t buf;
 123         unsigned flags = PHP_HTTP_MESSAGE_PARSER_CLEANUP;
 124         int free_msg;
 125
 126         php_http_buffer_from_string_ex(&buf, str, len);
 127         php_http_message_parser_init(&p TSRMLS_CC);
 128
 129         if ((free_msg = !msg)) {
 130                 msg = php_http_message_init(NULL, 0, NULL TSRMLS_CC);
 131         }
 132
 133         if (greedy) {
 134                 flags |= PHP_HTTP_MESSAGE_PARSER_GREEDY;
 135         }
 136         if (PHP_HTTP_MESSAGE_PARSER_STATE_FAILURE == php_http_message_parser_parse(&p, &buf, flags, &msg)) {
 137                 if (free_msg) {
 138                         php_http_message_free(&msg);
 139                 }
 140                 msg = NULL;
 141         }
 142
 143         php_http_message_parser_dtor(&p);
 144         php_http_buffer_dtor(&buf);
 145
 146         return msg;
 147 }
 148
 149 zval *php_http_message_header(php_http_message_t *msg, const char *key_str, size_t key_len, int join)
 150 {
 151         zval *ret = NULL, **header;
 152         char *key = php_http_pretty_key(estrndup(key_str, key_len), key_len, 1, 1);
 153
 154         if (SUCCESS == zend_symtable_find(&msg->hdrs, key, key_len + 1, (void *) &header)) {
 155                 if (join && Z_TYPE_PP(header) == IS_ARRAY) {
 156                         TSRMLS_FETCH_FROM_CTX(msg->ts);
 157
 158                         ret = php_http_header_value_to_string(*header TSRMLS_CC);
 159                 } else {
 160                         Z_ADDREF_PP(header);
 161                         ret = *header;
 162                 }
 163         }
 164
 165         efree(key);
 166
 167         return ret;
 168 }
 169
 170 zend_bool php_http_message_is_multipart(php_http_message_t *msg, char **boundary)
 171 {
 172         zval *ct = php_http_message_header(msg, ZEND_STRL("Content-Type"), 1);
 173         zend_bool is_multipart = 0;
 174         TSRMLS_FETCH_FROM_CTX(msg->ts);
 175
 176         if (ct) {
 177                 php_http_params_opts_t popts;
 178                 HashTable params;
 179
 180                 ZEND_INIT_SYMTABLE(&params);
 181                 php_http_params_opts_default_get(&popts);
 182                 popts.input.str = Z_STRVAL_P(ct);
 183                 popts.input.len = Z_STRLEN_P(ct);
 184
 185                 if (php_http_params_parse(&params, &popts TSRMLS_CC)) {
 186                         zval **cur, **arg;
 187                         char *ct_str;
 188
 189                         zend_hash_internal_pointer_reset(&params);
 190
 191                         if (SUCCESS == zend_hash_get_current_data(&params, (void *) &cur)
 192                         &&      Z_TYPE_PP(cur) == IS_ARRAY
 193                         &&      HASH_KEY_IS_STRING == zend_hash_get_current_key(&params, &ct_str, NULL, 0)
 194                         ) {
 195                                 if (php_http_match(ct_str, "multipart", PHP_HTTP_MATCH_WORD)) {
 196                                         is_multipart = 1;
 197
 198                                         /* get boundary */
 199                                         if (boundary
 200                                         &&      SUCCESS == zend_hash_find(Z_ARRVAL_PP(cur), ZEND_STRS("arguments"), (void *) &arg)
 201                                         &&      Z_TYPE_PP(arg) == IS_ARRAY
 202                                         ) {
 203                                                 zval **val;
 204                                                 HashPosition pos;
 205                                                 php_http_array_hashkey_t key = php_http_array_hashkey_init(0);
 206
 207                                                 FOREACH_KEYVAL(pos, *arg, key, val) {
 208                                                         if (key.type == HASH_KEY_IS_STRING && !strcasecmp(key.str, "boundary")) {
 209                                                                 zval *bnd = php_http_ztyp(IS_STRING, *val);
 210
 211                                                                 if (Z_STRLEN_P(bnd)) {
 212                                                                         *boundary = estrndup(Z_STRVAL_P(bnd), Z_STRLEN_P(bnd));
 213                                                                 }
 214                                                                 zval_ptr_dtor(&bnd);
 215                                                         }
 216                                                 }
 217                                         }
 218                                 }
 219                         }
 220                 }
 221                 zend_hash_destroy(&params);
 222                 zval_ptr_dtor(&ct);
 223         }
 224
 225         return is_multipart;
 226 }
 227
 228 /* */
 229 void php_http_message_set_type(php_http_message_t *message, php_http_message_type_t type)
 230 {
 231         /* just act if different */
 232         if (type != message->type) {
 233
 234                 /* free request info */
 235                 switch (message->type) {
 236                         case PHP_HTTP_REQUEST:
 237                                 STR_FREE(message->http.info.request.method);
 238                                 STR_FREE(message->http.info.request.url);
 239                                 break;
 240
 241                         case PHP_HTTP_RESPONSE:
 242                                 STR_FREE(message->http.info.response.status);
 243                                 break;
 244
 245                         default:
 246                                 break;
 247                 }
 248
 249                 message->type = type;
 250                 memset(&message->http, 0, sizeof(message->http));
 251         }
 252 }
 253
 254 void php_http_message_set_info(php_http_message_t *message, php_http_info_t *info)
 255 {
 256         php_http_message_set_type(message, info->type);
 257         message->http.version = info->http.version;
 258         switch (message->type) {
 259                 case PHP_HTTP_REQUEST:
 260                         STR_SET(PHP_HTTP_INFO(message).request.url, PHP_HTTP_INFO(info).request.url ? estrdup(PHP_HTTP_INFO(info).request.url) : NULL);
 261                         STR_SET(PHP_HTTP_INFO(message).request.method, PHP_HTTP_INFO(info).request.method ? estrdup(PHP_HTTP_INFO(info).request.method) : NULL);
 262                         break;
 263
 264                 case PHP_HTTP_RESPONSE:
 265                         PHP_HTTP_INFO(message).response.code = PHP_HTTP_INFO(info).response.code;
 266                         STR_SET(PHP_HTTP_INFO(message).response.status, PHP_HTTP_INFO(info).response.status ? estrdup(PHP_HTTP_INFO(info).response.status) : NULL);
 267                         break;
 268
 269                 default:
 270                         break;
 271         }
 272 }
 273
 274 void php_http_message_update_headers(php_http_message_t *msg)
 275 {
 276         zval *h;
 277         size_t size;
 278
 279         if (php_http_message_body_stream(msg->body)->readfilters.head) {
 280                 /* if a read stream filter is attached to the body the caller must also care for the headers */
 281         } else if ((size = php_http_message_body_size(msg->body))) {
 282                 MAKE_STD_ZVAL(h);
 283                 ZVAL_LONG(h, size);
 284                 zend_hash_update(&msg->hdrs, "Content-Length", sizeof("Content-Length"), &h, sizeof(zval *), NULL);
 285
 286                 if (msg->body->boundary) {
 287                         char *str;
 288                         size_t len;
 289
 290                         if (!(h = php_http_message_header(msg, ZEND_STRL("Content-Type"), 1))) {
 291                                 len = spprintf(&str, 0, "multipart/form-data; boundary=\"%s\"", msg->body->boundary);
 292                                 MAKE_STD_ZVAL(h);
 293                                 ZVAL_STRINGL(h, str, len, 0);
 294                                 zend_hash_update(&msg->hdrs, "Content-Type", sizeof("Content-Type"), &h, sizeof(zval *), NULL);
 295                         } else if (!php_http_match(Z_STRVAL_P(h), "boundary=", PHP_HTTP_MATCH_WORD)) {
 296                                 zval_dtor(h);
 297                                 Z_STRLEN_P(h) = spprintf(&Z_STRVAL_P(h), 0, "%s; boundary=\"%s\"", Z_STRVAL_P(h), msg->body->boundary);
 298                                 zend_hash_update(&msg->hdrs, "Content-Type", sizeof("Content-Type"), &h, sizeof(zval *), NULL);
 299                         } else {
 300                                 zval_ptr_dtor(&h);
 301                         }
 302                 }
 303         } else if ((h = php_http_message_header(msg, ZEND_STRL("Content-Length"), 1))) {
 304                 zval *h_cpy = php_http_ztyp(IS_LONG, h);
 305
 306                 zval_ptr_dtor(&h);
 307                 if (Z_LVAL_P(h_cpy)) {
 308                         zend_hash_del(&msg->hdrs, "Content-Length", sizeof("Content-Length"));
 309                 }
 310                 zval_ptr_dtor(&h_cpy);
 311         }
 312 }
 313
 314 static void message_headers(php_http_message_t *msg, php_http_buffer_t *str)
 315 {
 316         TSRMLS_FETCH_FROM_CTX(msg->ts);
 317
 318         switch (msg->type) {
 319                 case PHP_HTTP_REQUEST:
 320                         php_http_buffer_appendf(str, PHP_HTTP_INFO_REQUEST_FMT_ARGS(&msg->http, PHP_HTTP_CRLF));
 321                         break;
 322
 323                 case PHP_HTTP_RESPONSE:
 324                         php_http_buffer_appendf(str, PHP_HTTP_INFO_RESPONSE_FMT_ARGS(&msg->http, PHP_HTTP_CRLF));
 325                         break;
 326
 327                 default:
 328                         break;
 329         }
 330
 331         php_http_message_update_headers(msg);
 332         php_http_header_to_string(str, &msg->hdrs TSRMLS_CC);
 333 }
 334
 335 void php_http_message_to_callback(php_http_message_t *msg, php_http_pass_callback_t cb, void *cb_arg)
 336 {
 337         php_http_buffer_t str;
 338
 339         php_http_buffer_init_ex(&str, 0x1000, 0);
 340         message_headers(msg, &str);
 341         cb(cb_arg, str.data, str.used);
 342         php_http_buffer_dtor(&str);
 343
 344         if (php_http_message_body_size(msg->body)) {
 345                 cb(cb_arg, ZEND_STRL(PHP_HTTP_CRLF));
 346                 php_http_message_body_to_callback(msg->body, cb, cb_arg, 0, 0);
 347         }
 348 }
 349
 350 void php_http_message_to_string(php_http_message_t *msg, char **string, size_t *length)
 351 {
 352         php_http_buffer_t str;
 353         char *data;
 354
 355         php_http_buffer_init_ex(&str, 0x1000, 0);
 356         message_headers(msg, &str);
 357         if (php_http_message_body_size(msg->body)) {
 358                 php_http_buffer_appends(&str, PHP_HTTP_CRLF);
 359                 php_http_message_body_to_callback(msg->body, (php_http_pass_callback_t) php_http_buffer_append, &str, 0, 0);
 360         }
 361
 362         data = php_http_buffer_data(&str, string, length);
 363         if (!string) {
 364                 efree(data);
 365         }
 366
 367         php_http_buffer_dtor(&str);
 368 }
 369
 370 void php_http_message_serialize(php_http_message_t *message, char **string, size_t *length)
 371 {
 372         char *buf;
 373         php_http_buffer_t str;
 374         php_http_message_t *msg;
 375
 376         php_http_buffer_init(&str);
 377
 378         msg = message = php_http_message_reverse(message);
 379         do {
 380                 php_http_message_to_callback(message, (php_http_pass_callback_t) php_http_buffer_append, &str);
 381                 php_http_buffer_appends(&str, PHP_HTTP_CRLF);
 382         } while ((message = message->parent));
 383         php_http_message_reverse(msg);
 384
 385         buf = php_http_buffer_data(&str, string, length);
 386         if (!string) {
 387                 efree(buf);
 388         }
 389
 390         php_http_buffer_dtor(&str);
 391 }
 392
 393 php_http_message_t *php_http_message_reverse(php_http_message_t *msg)
 394 {
 395         int i, c = 0;
 396
 397         php_http_message_count(c, msg);
 398
 399         if (c > 1) {
 400                 php_http_message_t *tmp = msg, **arr;
 401
 402                 arr = ecalloc(c, sizeof(**arr));
 403                 for (i = 0; i < c; ++i) {
 404                         arr[i] = tmp;
 405                         tmp = tmp->parent;
 406                 }
 407                 arr[0]->parent = NULL;
 408                 for (i = 0; i < c-1; ++i) {
 409                         arr[i+1]->parent = arr[i];
 410                 }
 411
 412                 msg = arr[c-1];
 413                 efree(arr);
 414         }
 415
 416         return msg;
 417 }
 418
 419 php_http_message_t *php_http_message_zip(php_http_message_t *one, php_http_message_t *two)
 420 {
 421         php_http_message_t *dst = php_http_message_copy(one, NULL), *src = php_http_message_copy(two, NULL), *tmp_dst, *tmp_src, *ret = dst;
 422
 423         while(dst && src) {
 424                 tmp_dst = dst->parent;
 425                 tmp_src = src->parent;
 426                 dst->parent = src;
 427                 if (tmp_dst) {
 428                         src->parent = tmp_dst;
 429                 }
 430                 src = tmp_src;
 431                 dst = tmp_dst;
 432         }
 433
 434         return ret;
 435 }
 436
 437 php_http_message_t *php_http_message_copy_ex(php_http_message_t *from, php_http_message_t *to, zend_bool parents)
 438 {
 439         php_http_message_t *temp, *copy = NULL;
 440         php_http_info_t info;
 441         TSRMLS_FETCH_FROM_CTX(from->ts);
 442
 443         if (from) {
 444                 info.type = from->type;
 445                 info.http = from->http;
 446
 447                 copy = temp = php_http_message_init(to, 0, php_http_message_body_copy(from->body, NULL) TSRMLS_CC);
 448                 php_http_message_set_info(temp, &info);
 449                 zend_hash_copy(&temp->hdrs, &from->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
 450
 451                 if (parents) while (from->parent) {
 452                         info.type = from->parent->type;
 453                         info.http = from->parent->http;
 454
 455                         temp->parent = php_http_message_init(NULL, 0, php_http_message_body_copy(from->parent->body, NULL) TSRMLS_CC);
 456                         php_http_message_set_info(temp->parent, &info);
 457                         zend_hash_copy(&temp->parent->hdrs, &from->parent->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
 458
 459                         temp = temp->parent;
 460                         from = from->parent;
 461                 }
 462         }
 463
 464         return copy;
 465 }
 466
 467 php_http_message_t *php_http_message_copy(php_http_message_t *from, php_http_message_t *to)
 468 {
 469         return php_http_message_copy_ex(from, to, 1);
 470 }
 471
 472 void php_http_message_dtor(php_http_message_t *message)
 473 {
 474         if (message) {
 475                 zend_hash_destroy(&message->hdrs);
 476                 php_http_message_body_free(&message->body);
 477
 478                 switch (message->type) {
 479                         case PHP_HTTP_REQUEST:
 480                                 STR_SET(message->http.info.request.method, NULL);
 481                                 STR_SET(message->http.info.request.url, NULL);
 482                                 break;
 483
 484                         case PHP_HTTP_RESPONSE:
 485                                 STR_SET(message->http.info.response.status, NULL);
 486                                 break;
 487
 488                         default:
 489                                 break;
 490                 }
 491         }
 492 }
 493
 494 void php_http_message_free(php_http_message_t **message)
 495 {
 496         if (*message) {
 497                 if ((*message)->parent) {
 498                         php_http_message_free(&(*message)->parent);
 499                 }
 500                 php_http_message_dtor(*message);
 501                 efree(*message);
 502                 *message = NULL;
 503         }
 504 }
 505
 506 static zval *php_http_message_object_read_prop(zval *object, zval *member, int type PHP_HTTP_ZEND_LITERAL_DC TSRMLS_DC);
 507 static void php_http_message_object_write_prop(zval *object, zval *member, zval *value PHP_HTTP_ZEND_LITERAL_DC TSRMLS_DC);
 508 static HashTable *php_http_message_object_get_props(zval *object TSRMLS_DC);
 509
 510 static zend_object_handlers php_http_message_object_handlers;
 511 static HashTable php_http_message_object_prophandlers;
 512
 513 typedef void (*php_http_message_object_prophandler_func_t)(php_http_message_object_t *o, zval *v TSRMLS_DC);
 514
 515 typedef struct php_http_message_object_prophandler {
 516         php_http_message_object_prophandler_func_t read;
 517         php_http_message_object_prophandler_func_t write;
 518 } php_http_message_object_prophandler_t;
 519
 520 static STATUS php_http_message_object_add_prophandler(const char *prop_str, size_t prop_len, php_http_message_object_prophandler_func_t read, php_http_message_object_prophandler_func_t write) {
 521         php_http_message_object_prophandler_t h = { read, write };
 522         return zend_hash_add(&php_http_message_object_prophandlers, prop_str, prop_len + 1, (void *) &h, sizeof(h), NULL);
 523 }
 524 static STATUS php_http_message_object_get_prophandler(const char *prop_str, size_t prop_len, php_http_message_object_prophandler_t **handler) {
 525         return zend_hash_find(&php_http_message_object_prophandlers, prop_str, prop_len + 1, (void *) handler);
 526 }
 527 static void php_http_message_object_prophandler_get_type(php_http_message_object_t *obj, zval *return_value TSRMLS_DC) {
 528         RETVAL_LONG(obj->message->type);
 529 }
 530 static void php_http_message_object_prophandler_set_type(php_http_message_object_t *obj, zval *value TSRMLS_DC) {
 531         zval *cpy = php_http_ztyp(IS_LONG, value);
 532         php_http_message_set_type(obj->message, Z_LVAL_P(cpy));
 533         zval_ptr_dtor(&cpy);
 534 }
 535 static void php_http_message_object_prophandler_get_request_method(php_http_message_object_t *obj, zval *return_value TSRMLS_DC) {
 536         if (PHP_HTTP_MESSAGE_TYPE(REQUEST, obj->message) && obj->message->http.info.request.method) {
 537                 RETVAL_STRING(obj->message->http.info.request.method, 1);
 538         } else {
 539                 RETVAL_NULL();
 540         }
 541 }
 542 static void php_http_message_object_prophandler_set_request_method(php_http_message_object_t *obj, zval *value TSRMLS_DC) {
 543         if (PHP_HTTP_MESSAGE_TYPE(REQUEST, obj->message)) {
 544                 zval *cpy = php_http_ztyp(IS_STRING, value);
 545                 STR_SET(obj->message->http.info.request.method, estrndup(Z_STRVAL_P(cpy), Z_STRLEN_P(cpy)));
 546                 zval_ptr_dtor(&cpy);
 547         }
 548 }
 549 static void php_http_message_object_prophandler_get_request_url(php_http_message_object_t *obj, zval *return_value TSRMLS_DC) {
 550         if (PHP_HTTP_MESSAGE_TYPE(REQUEST, obj->message) && obj->message->http.info.request.url) {
 551                 RETVAL_STRING(obj->message->http.info.request.url, 1);
 552         } else {
 553                 RETVAL_NULL();
 554         }
 555 }
 556 static void php_http_message_object_prophandler_set_request_url(php_http_message_object_t *obj, zval *value TSRMLS_DC) {
 557         if (PHP_HTTP_MESSAGE_TYPE(REQUEST, obj->message)) {
 558                 zval *cpy = php_http_ztyp(IS_STRING, value);
 559                 STR_SET(obj->message->http.info.request.url, estrndup(Z_STRVAL_P(cpy), Z_STRLEN_P(cpy)));
 560                 zval_ptr_dtor(&cpy);
 561         }
 562 }
 563 static void php_http_message_object_prophandler_get_response_status(php_http_message_object_t *obj, zval *return_value TSRMLS_DC) {
 564         if (PHP_HTTP_MESSAGE_TYPE(RESPONSE, obj->message) && obj->message->http.info.response.status) {
 565                 RETVAL_STRING(obj->message->http.info.response.status, 1);
 566         } else {
 567                 RETVAL_NULL();
 568         }
 569 }
 570 static void php_http_message_object_prophandler_set_response_status(php_http_message_object_t *obj, zval *value TSRMLS_DC) {
 571         if (PHP_HTTP_MESSAGE_TYPE(RESPONSE, obj->message)) {
 572                 zval *cpy = php_http_ztyp(IS_STRING, value);
 573                 STR_SET(obj->message->http.info.response.status, estrndup(Z_STRVAL_P(cpy), Z_STRLEN_P(cpy)));
 574                 zval_ptr_dtor(&cpy);
 575         }
 576 }
 577 static void php_http_message_object_prophandler_get_response_code(php_http_message_object_t *obj, zval *return_value TSRMLS_DC) {
 578         if (PHP_HTTP_MESSAGE_TYPE(RESPONSE, obj->message)) {
 579                 RETVAL_LONG(obj->message->http.info.response.code);
 580         } else {
 581                 RETVAL_NULL();
 582         }
 583 }
 584 static void php_http_message_object_prophandler_set_response_code(php_http_message_object_t *obj, zval *value TSRMLS_DC) {
 585         if (PHP_HTTP_MESSAGE_TYPE(RESPONSE, obj->message)) {
 586                 zval *cpy = php_http_ztyp(IS_LONG, value);
 587                 obj->message->http.info.response.code = Z_LVAL_P(cpy);
 588                 STR_SET(obj->message->http.info.response.status, estrdup(php_http_env_get_response_status_for_code(obj->message->http.info.response.code)));
 589                 zval_ptr_dtor(&cpy);
 590         }
 591 }
 592 static void php_http_message_object_prophandler_get_http_version(php_http_message_object_t *obj, zval *return_value TSRMLS_DC) {
 593         char *version_str;
 594         size_t version_len;
 595
 596         php_http_version_to_string(&obj->message->http.version, &version_str, &version_len, NULL, NULL TSRMLS_CC);
 597         RETVAL_STRINGL(version_str, version_len, 0);
 598 }
 599 static void php_http_message_object_prophandler_set_http_version(php_http_message_object_t *obj, zval *value TSRMLS_DC) {
 600         zval *cpy = php_http_ztyp(IS_STRING, value);
 601         php_http_version_parse(&obj->message->http.version, Z_STRVAL_P(cpy) TSRMLS_CC);
 602         zval_ptr_dtor(&cpy);
 603 }
 604 static void php_http_message_object_prophandler_get_headers(php_http_message_object_t *obj, zval *return_value TSRMLS_DC) {
 605         array_init(return_value);
 606         zend_hash_copy(Z_ARRVAL_P(return_value), &obj->message->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
 607 }
 608 static void php_http_message_object_prophandler_set_headers(php_http_message_object_t *obj, zval *value TSRMLS_DC) {
 609         zval *cpy = php_http_ztyp(IS_ARRAY, value);
 610
 611         zend_hash_clean(&obj->message->hdrs);
 612         zend_hash_copy(&obj->message->hdrs, Z_ARRVAL_P(cpy), (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
 613         zval_ptr_dtor(&cpy);
 614 }
 615 static void php_http_message_object_prophandler_get_body(php_http_message_object_t *obj, zval *return_value TSRMLS_DC) {
 616         if (obj->body) {
 617                 RETVAL_OBJVAL(obj->body->zv, 1);
 618         } else {
 619                 RETVAL_NULL();
 620         }
 621 }
 622 static void php_http_message_object_prophandler_set_body(php_http_message_object_t *obj, zval *value TSRMLS_DC) {
 623         php_http_message_object_set_body(obj, value TSRMLS_CC);
 624 }
 625 static void php_http_message_object_prophandler_get_parent_message(php_http_message_object_t *obj, zval *return_value TSRMLS_DC) {
 626         if (obj->message->parent) {
 627                 RETVAL_OBJVAL(obj->parent->zv, 1);
 628         } else {
 629                 RETVAL_NULL();
 630         }
 631 }
 632 static void php_http_message_object_prophandler_set_parent_message(php_http_message_object_t *obj, zval *value TSRMLS_DC) {
 633         if (Z_TYPE_P(value) == IS_OBJECT && instanceof_function(Z_OBJCE_P(value), php_http_message_class_entry TSRMLS_CC)) {
 634                 php_http_message_object_t *parent_obj = zend_object_store_get_object(value TSRMLS_CC);
 635
 636                 if (obj->message->parent) {
 637                         zend_objects_store_del_ref_by_handle(obj->parent->zv.handle TSRMLS_CC);
 638                 }
 639                 Z_OBJ_ADDREF_P(value);
 640                 obj->parent = parent_obj;
 641                 obj->message->parent = parent_obj->message;
 642         }
 643 }
 644
 645 #define PHP_HTTP_MESSAGE_OBJECT_INIT(obj) \
 646         do { \
 647                 if (!obj->message) { \
 648                         obj->message = php_http_message_init(NULL, 0, NULL TSRMLS_CC); \
 649                 } \
 650         } while(0)
 651
 652
 653 void php_http_message_object_reverse(zval *this_ptr, zval *return_value TSRMLS_DC)
 654 {
 655         int i = 0;
 656         php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
 657
 658         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
 659
 660         /* count */
 661         php_http_message_count(i, obj->message);
 662
 663         if (i > 1) {
 664                 php_http_message_object_t **objects;
 665                 int last;
 666
 667                 objects = ecalloc(i, sizeof(**objects));
 668
 669                 /* we are the first message */
 670                 objects[0] = obj;
 671
 672                 /* fetch parents */
 673                 for (i = 1; obj->parent; ++i) {
 674                          objects[i] = obj = obj->parent;
 675                 }
 676
 677                 /* reorder parents */
 678                 for (last = --i; i; --i) {
 679                         objects[i]->message->parent = objects[i-1]->message;
 680                         objects[i]->parent = objects[i-1];
 681                 }
 682
 683                 objects[0]->message->parent = NULL;
 684                 objects[0]->parent = NULL;
 685
 686                 /* add ref, because we previously have not been a parent message */
 687                 Z_OBJ_ADDREF_P(getThis());
 688                 RETVAL_OBJVAL(objects[last]->zv, 0);
 689
 690                 efree(objects);
 691         } else {
 692                 RETURN_ZVAL(getThis(), 1, 0);
 693         }
 694 }
 695
 696 void php_http_message_object_prepend(zval *this_ptr, zval *prepend, zend_bool top TSRMLS_DC)
 697 {
 698         zval m;
 699         php_http_message_t *save_parent_msg = NULL;
 700         php_http_message_object_t *save_parent_obj = NULL, *obj = zend_object_store_get_object(this_ptr TSRMLS_CC);
 701         php_http_message_object_t *prepend_obj = zend_object_store_get_object(prepend TSRMLS_CC);
 702
 703         INIT_PZVAL(&m);
 704         m.type = IS_OBJECT;
 705
 706         if (!top) {
 707                 save_parent_obj = obj->parent;
 708                 save_parent_msg = obj->message->parent;
 709         } else {
 710                 /* iterate to the most parent object */
 711                 while (obj->parent) {
 712                         obj = obj->parent;
 713                 }
 714         }
 715
 716         /* prepend */
 717         obj->parent = prepend_obj;
 718         obj->message->parent = prepend_obj->message;
 719
 720         /* add ref */
 721         zend_objects_store_add_ref(prepend TSRMLS_CC);
 722
 723         if (!top) {
 724                 prepend_obj->parent = save_parent_obj;
 725                 prepend_obj->message->parent = save_parent_msg;
 726         }
 727 }
 728
 729 STATUS php_http_message_object_set_body(php_http_message_object_t *msg_obj, zval *zbody TSRMLS_DC)
 730 {
 731         zval *tmp = NULL;
 732         php_stream *s;
 733         zend_object_value ov;
 734         php_http_message_body_t *body;
 735         php_http_message_body_object_t *body_obj;
 736
 737         switch (Z_TYPE_P(zbody)) {
 738                 case IS_RESOURCE:
 739                         php_stream_from_zval_no_verify(s, &zbody);
 740                         if (!s) {
 741                                 php_http_throw(unexpected_val, "The stream is not a valid resource", NULL);
 742                                 return FAILURE;
 743                         }
 744
 745                         is_resource:
 746
 747                         body = php_http_message_body_init(NULL, s TSRMLS_CC);
 748                         if (SUCCESS != php_http_new(&ov, php_http_message_body_class_entry, (php_http_new_t) php_http_message_body_object_new_ex, NULL, body, NULL TSRMLS_CC)) {
 749                                 php_http_message_body_free(&body);
 750                                 return FAILURE;
 751                         }
 752                         MAKE_STD_ZVAL(tmp);
 753                         ZVAL_OBJVAL(tmp, ov, 0);
 754                         zbody = tmp;
 755                         break;
 756
 757                 case IS_OBJECT:
 758                         if (instanceof_function(Z_OBJCE_P(zbody), php_http_message_body_class_entry TSRMLS_CC)) {
 759                                 Z_OBJ_ADDREF_P(zbody);
 760                                 break;
 761                         }
 762                         /* no break */
 763
 764                 default:
 765                         tmp = php_http_ztyp(IS_STRING, zbody);
 766                         s = php_stream_temp_new();
 767                         php_stream_write(s, Z_STRVAL_P(tmp), Z_STRLEN_P(tmp));
 768                         zval_ptr_dtor(&tmp);
 769                         tmp = NULL;
 770                         goto is_resource;
 771
 772         }
 773
 774         body_obj = zend_object_store_get_object(zbody TSRMLS_CC);
 775         if (!body_obj->body) {
 776                 body_obj->body = php_http_message_body_init(NULL, NULL TSRMLS_CC);
 777         }
 778         if (msg_obj->body) {
 779                 zend_objects_store_del_ref_by_handle(msg_obj->body->zv.handle TSRMLS_CC);
 780         }
 781         if (msg_obj->message) {
 782                 php_http_message_body_free(&msg_obj->message->body);
 783                 msg_obj->message->body = php_http_message_body_init(&body_obj->body, NULL TSRMLS_CC);
 784         } else {
 785                 msg_obj->message = php_http_message_init(NULL, 0, php_http_message_body_init(&body_obj->body, NULL TSRMLS_CC) TSRMLS_CC);
 786         }
 787         msg_obj->body = body_obj;
 788
 789         if (tmp) {
 790                 FREE_ZVAL(tmp);
 791         }
 792         return SUCCESS;
 793 }
 794
 795 STATUS php_http_message_object_init_body_object(php_http_message_object_t *obj)
 796 {
 797         TSRMLS_FETCH_FROM_CTX(obj->message->ts);
 798
 799         php_http_message_body_addref(obj->message->body);
 800         return php_http_new(NULL, php_http_message_body_class_entry, (php_http_new_t) php_http_message_body_object_new_ex, NULL, obj->message->body, (void *) &obj->body TSRMLS_CC);
 801 }
 802
 803 zend_object_value php_http_message_object_new(zend_class_entry *ce TSRMLS_DC)
 804 {
 805         return php_http_message_object_new_ex(ce, NULL, NULL TSRMLS_CC);
 806 }
 807
 808 zend_object_value php_http_message_object_new_ex(zend_class_entry *ce, php_http_message_t *msg, php_http_message_object_t **ptr TSRMLS_DC)
 809 {
 810         php_http_message_object_t *o;
 811
 812         o = ecalloc(1, sizeof(php_http_message_object_t));
 813         zend_object_std_init((zend_object *) o, ce TSRMLS_CC);
 814         object_properties_init((zend_object *) o, ce);
 815
 816         if (ptr) {
 817                 *ptr = o;
 818         }
 819
 820         if (msg) {
 821                 o->message = msg;
 822                 if (msg->parent) {
 823                         php_http_message_object_new_ex(ce, msg->parent, &o->parent TSRMLS_CC);
 824                 }
 825                 php_http_message_body_object_new_ex(php_http_message_body_class_entry, php_http_message_body_init(&msg->body, NULL TSRMLS_CC), &o->body TSRMLS_CC);
 826         }
 827
 828         o->zv.handle = zend_objects_store_put((zend_object *) o, NULL, php_http_message_object_free, NULL TSRMLS_CC);
 829         o->zv.handlers = &php_http_message_object_handlers;
 830
 831         return o->zv;
 832 }
 833
 834 zend_object_value php_http_message_object_clone(zval *this_ptr TSRMLS_DC)
 835 {
 836         zend_object_value new_ov;
 837         php_http_message_object_t *new_obj = NULL;
 838         php_http_message_object_t *old_obj = zend_object_store_get_object(this_ptr TSRMLS_CC);
 839
 840         new_ov = php_http_message_object_new_ex(old_obj->zo.ce, php_http_message_copy(old_obj->message, NULL), &new_obj TSRMLS_CC);
 841         zend_objects_clone_members(&new_obj->zo, new_ov, &old_obj->zo, Z_OBJ_HANDLE_P(this_ptr) TSRMLS_CC);
 842
 843         return new_ov;
 844 }
 845
 846 void php_http_message_object_free(void *object TSRMLS_DC)
 847 {
 848         php_http_message_object_t *o = (php_http_message_object_t *) object;
 849
 850         if (o->iterator) {
 851                 zval_ptr_dtor(&o->iterator);
 852                 o->iterator = NULL;
 853         }
 854         if (o->message) {
 855                 /* do NOT free recursivly */
 856                 php_http_message_dtor(o->message);
 857                 efree(o->message);
 858                 o->message = NULL;
 859         }
 860         if (o->parent) {
 861                 zend_objects_store_del_ref_by_handle(o->parent->zv.handle TSRMLS_CC);
 862                 o->parent = NULL;
 863         }
 864         if (o->body) {
 865                 zend_objects_store_del_ref_by_handle(o->body->zv.handle TSRMLS_CC);
 866                 o->body = NULL;
 867         }
 868         zend_object_std_dtor((zend_object *) o TSRMLS_CC);
 869         efree(o);
 870 }
 871
 872 static zval *php_http_message_object_read_prop(zval *object, zval *member, int type PHP_HTTP_ZEND_LITERAL_DC TSRMLS_DC)
 873 {
 874         php_http_message_object_t *obj = zend_object_store_get_object(object TSRMLS_CC);
 875         php_http_message_object_prophandler_t *handler;
 876         zval *return_value, *copy = php_http_ztyp(IS_STRING, member);
 877
 878         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
 879
 880         if (SUCCESS == php_http_message_object_get_prophandler(Z_STRVAL_P(copy), Z_STRLEN_P(copy), &handler)) {
 881                 ALLOC_ZVAL(return_value);
 882                 Z_SET_REFCOUNT_P(return_value, 0);
 883                 Z_UNSET_ISREF_P(return_value);
 884
 885                 if (type == BP_VAR_R) {
 886                         handler->read(obj, return_value TSRMLS_CC);
 887                 } else {
 888                         php_property_proxy_t *proxy = php_property_proxy_init(object, Z_STRVAL_P(copy), Z_STRLEN_P(copy) TSRMLS_CC);
 889                         RETVAL_OBJVAL(php_property_proxy_object_new_ex(php_property_proxy_get_class_entry(), proxy, NULL TSRMLS_CC), 0);
 890                 }
 891         } else {
 892                 return_value = zend_get_std_object_handlers()->read_property(object, member, type PHP_HTTP_ZEND_LITERAL_CC TSRMLS_CC);
 893         }
 894
 895         zval_ptr_dtor(&copy);
 896
 897         return return_value;
 898 }
 899
 900 static void php_http_message_object_write_prop(zval *object, zval *member, zval *value PHP_HTTP_ZEND_LITERAL_DC TSRMLS_DC)
 901 {
 902         php_http_message_object_t *obj = zend_object_store_get_object(object TSRMLS_CC);
 903         php_http_message_object_prophandler_t *handler;
 904         zval *copy = php_http_ztyp(IS_STRING, member);
 905
 906         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
 907
 908         if (SUCCESS == php_http_message_object_get_prophandler(Z_STRVAL_P(copy), Z_STRLEN_P(copy), &handler)) {
 909                 handler->write(obj, value TSRMLS_CC);
 910         } else {
 911                 zend_get_std_object_handlers()->write_property(object, member, value PHP_HTTP_ZEND_LITERAL_CC TSRMLS_CC);
 912         }
 913
 914         zval_ptr_dtor(&copy);
 915 }
 916
 917 static HashTable *php_http_message_object_get_props(zval *object TSRMLS_DC)
 918 {
 919         zval *headers;
 920         php_http_message_object_t *obj = zend_object_store_get_object(object TSRMLS_CC);
 921         php_http_message_t *msg = obj->message;
 922         HashTable *props = zend_get_std_object_handlers()->get_properties(object TSRMLS_CC);
 923         zval array, *parent, *body;
 924         char *version;
 925
 926         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
 927
 928         INIT_PZVAL_ARRAY(&array, props);
 929
 930 #define ASSOC_PROP(ptype, n, val) \
 931         do { \
 932                 zend_property_info *pi; \
 933                 if (SUCCESS == zend_hash_find(&obj->zo.ce->properties_info, n, sizeof(n), (void *) &pi)) { \
 934                         add_assoc_ ##ptype## _ex(&array, pi->name, pi->name_length + 1, val); \
 935                 } \
 936         } while(0) \
 937
 938 #define ASSOC_STRING(name, val) ASSOC_STRINGL(name, val, strlen(val))
 939 #define ASSOC_STRINGL(name, val, len) ASSOC_STRINGL_EX(name, val, len, 1)
 940 #define ASSOC_STRINGL_EX(n, val, len, cpy) \
 941         do { \
 942                 zend_property_info *pi; \
 943                 if (SUCCESS == zend_hash_find(&obj->zo.ce->properties_info, n, sizeof(n), (void *) &pi)) { \
 944                         add_assoc_stringl_ex(&array, pi->name, pi->name_length + 1, val, len, cpy); \
 945                 } \
 946         } while(0)
 947
 948         ASSOC_PROP(long, "type", msg->type);
 949         ASSOC_STRINGL_EX("httpVersion", version, spprintf(&version, 0, "%u.%u", msg->http.version.major, msg->http.version.minor), 0);
 950
 951         switch (msg->type) {
 952                 case PHP_HTTP_REQUEST:
 953                         ASSOC_PROP(long, "responseCode", 0);
 954                         ASSOC_STRINGL("responseStatus", "", 0);
 955                         ASSOC_STRING("requestMethod", STR_PTR(msg->http.info.request.method));
 956                         ASSOC_STRING("requestUrl", STR_PTR(msg->http.info.request.url));
 957                         break;
 958
 959                 case PHP_HTTP_RESPONSE:
 960                         ASSOC_PROP(long, "responseCode", msg->http.info.response.code);
 961                         ASSOC_STRING("responseStatus", STR_PTR(msg->http.info.response.status));
 962                         ASSOC_STRINGL("requestMethod", "", 0);
 963                         ASSOC_STRINGL("requestUrl", "", 0);
 964                         break;
 965
 966                 case PHP_HTTP_NONE:
 967                 default:
 968                         ASSOC_PROP(long, "responseCode", 0);
 969                         ASSOC_STRINGL("responseStatus", "", 0);
 970                         ASSOC_STRINGL("requestMethod", "", 0);
 971                         ASSOC_STRINGL("requestUrl", "", 0);
 972                         break;
 973         }
 974
 975         MAKE_STD_ZVAL(headers);
 976         array_init(headers);
 977         zend_hash_copy(Z_ARRVAL_P(headers), &msg->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
 978         ASSOC_PROP(zval, "headers", headers);
 979
 980         MAKE_STD_ZVAL(body);
 981         if (!obj->body) {
 982                 php_http_new(NULL, php_http_message_body_class_entry, (php_http_new_t) php_http_message_body_object_new_ex, NULL, (void *) php_http_message_body_init(&obj->message->body, NULL TSRMLS_CC), (void *) &obj->body TSRMLS_CC);
 983         }
 984         ZVAL_OBJVAL(body, obj->body->zv, 1);
 985         ASSOC_PROP(zval, "body", body);
 986
 987         MAKE_STD_ZVAL(parent);
 988         if (msg->parent) {
 989                 ZVAL_OBJVAL(parent, obj->parent->zv, 1);
 990         } else {
 991                 ZVAL_NULL(parent);
 992         }
 993         ASSOC_PROP(zval, "parentMessage", parent);
 994
 995         return props;
 996 }
 997
 998 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage___construct, 0, 0, 0)
 999         ZEND_ARG_INFO(0, message)
1000         ZEND_ARG_INFO(0, greedy)
1001 ZEND_END_ARG_INFO();
1002 static PHP_METHOD(HttpMessage, __construct)
1003 {
1004         zend_bool greedy = 1;
1005         zval *zmessage = NULL;
1006         php_http_message_t *msg = NULL;
1007         php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1008         zend_error_handling zeh;
1009
1010         php_http_expect(SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|z!b", &zmessage, &greedy), invalid_arg, return);
1011
1012         zend_replace_error_handling(EH_THROW, php_http_exception_bad_message_class_entry, &zeh TSRMLS_CC);
1013         if (zmessage && Z_TYPE_P(zmessage) == IS_RESOURCE) {
1014                 php_stream *s;
1015                 php_http_message_parser_t p;
1016                 zend_error_handling zeh;
1017
1018                 zend_replace_error_handling(EH_THROW, php_http_exception_unexpected_val_class_entry, &zeh TSRMLS_CC);
1019                 php_stream_from_zval(s, &zmessage);
1020                 zend_restore_error_handling(&zeh TSRMLS_CC);
1021
1022                 if (s && php_http_message_parser_init(&p TSRMLS_CC)) {
1023                         unsigned flags = (greedy ? PHP_HTTP_MESSAGE_PARSER_GREEDY : 0);
1024
1025                         if (PHP_HTTP_MESSAGE_PARSER_STATE_FAILURE == php_http_message_parser_parse_stream(&p, s, flags, &msg)) {
1026                                 if (!EG(exception)) {
1027                                         php_http_throw(bad_message, "Could not parse message from stream", NULL);
1028                                 }
1029                         }
1030
1031                         php_http_message_parser_dtor(&p);
1032                 }
1033
1034                 if (!msg && !EG(exception)) {
1035                         php_http_throw(bad_message, "Empty message received from stream", NULL);
1036                 }
1037         } else if (zmessage) {
1038                 zmessage = php_http_ztyp(IS_STRING, zmessage);
1039                 msg = php_http_message_parse(NULL, Z_STRVAL_P(zmessage), Z_STRLEN_P(zmessage), greedy TSRMLS_CC);
1040
1041                 if (!msg && !EG(exception)) {
1042                         php_http_throw(bad_message, "Could not parse message: %.*s", MIN(25, Z_STRLEN_P(zmessage)), Z_STRVAL_P(zmessage));
1043                 }
1044                 zval_ptr_dtor(&zmessage);
1045         }
1046
1047         if (msg) {
1048                 php_http_message_dtor(obj->message);
1049                 obj->message = msg;
1050                 if (obj->message->parent) {
1051                         php_http_message_object_new_ex(Z_OBJCE_P(getThis()), obj->message->parent, &obj->parent TSRMLS_CC);
1052                 }
1053         }
1054         zend_restore_error_handling(&zeh TSRMLS_CC);
1055         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1056 }
1057
1058 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getBody, 0, 0, 0)
1059 ZEND_END_ARG_INFO();
1060 static PHP_METHOD(HttpMessage, getBody)
1061 {
1062         php_http_message_object_t *obj;
1063
1064         php_http_expect(SUCCESS == zend_parse_parameters_none(), invalid_arg, return);
1065
1066         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1067
1068         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1069
1070         if (!obj->body) {
1071                 php_http_message_object_init_body_object(obj);
1072
1073         }
1074         if (obj->body) {
1075                 RETVAL_OBJVAL(obj->body->zv, 1);
1076         }
1077 }
1078
1079 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setBody, 0, 0, 1)
1080         ZEND_ARG_OBJ_INFO(0, body, http\\Message\\Body, 0)
1081 ZEND_END_ARG_INFO();
1082 static PHP_METHOD(HttpMessage, setBody)
1083 {
1084         zval *zbody;
1085
1086         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "O", &zbody, php_http_message_body_class_entry)) {
1087                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1088
1089                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1090                 php_http_message_object_prophandler_set_body(obj, zbody TSRMLS_CC);
1091         }
1092         RETVAL_ZVAL(getThis(), 1, 0);
1093 }
1094
1095 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_addBody, 0, 0, 1)
1096         ZEND_ARG_OBJ_INFO(0, body, http\\Message\\Body, 0)
1097 ZEND_END_ARG_INFO();
1098 static PHP_METHOD(HttpMessage, addBody)
1099 {
1100         zval *new_body;
1101
1102         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "O", &new_body, php_http_message_body_class_entry)) {
1103                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1104                 php_http_message_body_object_t *new_obj = zend_object_store_get_object(new_body TSRMLS_CC);
1105
1106                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1107                 php_http_message_body_to_callback(new_obj->body, (php_http_pass_callback_t) php_http_message_body_append, obj->message->body, 0, 0);
1108         }
1109         RETVAL_ZVAL(getThis(), 1, 0);
1110 }
1111
1112 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getHeader, 0, 0, 1)
1113         ZEND_ARG_INFO(0, header)
1114         ZEND_ARG_INFO(0, into_class)
1115 ZEND_END_ARG_INFO();
1116 static PHP_METHOD(HttpMessage, getHeader)
1117 {
1118         char *header_str;
1119         int header_len;
1120         zend_class_entry *header_ce = NULL;
1121
1122         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|C!", &header_str, &header_len, &header_ce)) {
1123                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1124                 zval *header;
1125
1126                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1127
1128                 if ((header = php_http_message_header(obj->message, header_str, header_len, 0))) {
1129                         if (!header_ce) {
1130                                 RETURN_ZVAL(header, 1, 1);
1131                         } else if (instanceof_function(header_ce, php_http_header_class_entry TSRMLS_CC)) {
1132                                 zval *header_name, **argv[2];
1133
1134                                 MAKE_STD_ZVAL(header_name);
1135                                 ZVAL_STRINGL(header_name, header_str, header_len, 1);
1136                                 Z_ADDREF_P(header);
1137
1138                                 argv[0] = &header_name;
1139                                 argv[1] = &header;
1140
1141                                 object_init_ex(return_value, header_ce);
1142                                 php_http_method_call(return_value, ZEND_STRL("__construct"), 2, argv, NULL TSRMLS_CC);
1143
1144                                 zval_ptr_dtor(&header_name);
1145                                 zval_ptr_dtor(&header);
1146
1147                                 return;
1148                         } else {
1149                                 php_error_docref(NULL TSRMLS_CC, E_WARNING, "Class '%s' is not as descendant of http\\Header", header_ce->name);
1150                         }
1151                 }
1152         }
1153         RETURN_FALSE;
1154 }
1155
1156 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getHeaders, 0, 0, 0)
1157 ZEND_END_ARG_INFO();
1158 static PHP_METHOD(HttpMessage, getHeaders)
1159 {
1160         if (SUCCESS == zend_parse_parameters_none()) {
1161                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1162
1163                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1164
1165                 array_init(return_value);
1166                 array_copy(&obj->message->hdrs, Z_ARRVAL_P(return_value));
1167         }
1168 }
1169
1170 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setHeader, 0, 0, 1)
1171         ZEND_ARG_INFO(0, header)
1172         ZEND_ARG_INFO(0, value)
1173 ZEND_END_ARG_INFO();
1174 static PHP_METHOD(HttpMessage, setHeader)
1175 {
1176         zval *zvalue = NULL;
1177         char *name_str;
1178         int name_len;
1179
1180         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|z!", &name_str, &name_len, &zvalue)) {
1181                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1182                 char *name = php_http_pretty_key(estrndup(name_str, name_len), name_len, 1, 1);
1183
1184                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1185
1186                 if (!zvalue) {
1187                         zend_symtable_del(&obj->message->hdrs, name, name_len + 1);
1188                 } else {
1189                         Z_ADDREF_P(zvalue);
1190                         zend_symtable_update(&obj->message->hdrs, name, name_len + 1, &zvalue, sizeof(void *), NULL);
1191                 }
1192                 efree(name);
1193         }
1194         RETVAL_ZVAL(getThis(), 1, 0);
1195 }
1196
1197 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setHeaders, 0, 0, 1)
1198         ZEND_ARG_ARRAY_INFO(0, headers, 1)
1199 ZEND_END_ARG_INFO();
1200 static PHP_METHOD(HttpMessage, setHeaders)
1201 {
1202         zval *new_headers = NULL;
1203
1204         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a/!", &new_headers)) {
1205                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1206
1207                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1208
1209                 zend_hash_clean(&obj->message->hdrs);
1210                 if (new_headers) {
1211                         array_join(Z_ARRVAL_P(new_headers), &obj->message->hdrs, 0, ARRAY_JOIN_PRETTIFY|ARRAY_JOIN_STRONLY);
1212                 }
1213         }
1214         RETVAL_ZVAL(getThis(), 1, 0);
1215 }
1216
1217 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_addHeader, 0, 0, 2)
1218         ZEND_ARG_INFO(0, header)
1219         ZEND_ARG_INFO(0, value)
1220 ZEND_END_ARG_INFO();
1221 static PHP_METHOD(HttpMessage, addHeader)
1222 {
1223         zval *zvalue;
1224         char *name_str;
1225         int name_len;
1226
1227         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "sz", &name_str, &name_len, &zvalue)) {
1228                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1229                 char *name = php_http_pretty_key(estrndup(name_str, name_len), name_len, 1, 1);
1230                 zval *header;
1231
1232                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1233
1234                 Z_ADDREF_P(zvalue);
1235                 if ((header = php_http_message_header(obj->message, name, name_len, 0))) {
1236                         convert_to_array(header);
1237                         zend_hash_next_index_insert(Z_ARRVAL_P(header), &zvalue, sizeof(void *), NULL);
1238                         zval_ptr_dtor(&header);
1239                 } else {
1240                         zend_symtable_update(&obj->message->hdrs, name, name_len + 1, &zvalue, sizeof(void *), NULL);
1241                 }
1242                 efree(name);
1243         }
1244         RETVAL_ZVAL(getThis(), 1, 0);
1245 }
1246
1247 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_addHeaders, 0, 0, 1)
1248         ZEND_ARG_ARRAY_INFO(0, headers, 0)
1249         ZEND_ARG_INFO(0, append)
1250 ZEND_END_ARG_INFO();
1251 static PHP_METHOD(HttpMessage, addHeaders)
1252 {
1253         zval *new_headers;
1254         zend_bool append = 0;
1255
1256         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "a|b", &new_headers, &append)) {
1257                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1258
1259                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1260
1261                 array_join(Z_ARRVAL_P(new_headers), &obj->message->hdrs, append, ARRAY_JOIN_STRONLY|ARRAY_JOIN_PRETTIFY);
1262         }
1263         RETVAL_ZVAL(getThis(), 1, 0);
1264 }
1265
1266 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getType, 0, 0, 0)
1267 ZEND_END_ARG_INFO();
1268 static PHP_METHOD(HttpMessage, getType)
1269 {
1270         if (SUCCESS == zend_parse_parameters_none()) {
1271                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1272
1273                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1274
1275                 RETURN_LONG(obj->message->type);
1276         }
1277 }
1278
1279 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setType, 0, 0, 1)
1280         ZEND_ARG_INFO(0, type)
1281 ZEND_END_ARG_INFO();
1282 static PHP_METHOD(HttpMessage, setType)
1283 {
1284         long type;
1285
1286         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &type)) {
1287                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1288
1289                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1290
1291                 php_http_message_set_type(obj->message, type);
1292         }
1293         RETVAL_ZVAL(getThis(), 1, 0);
1294 }
1295
1296 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getInfo, 0, 0, 0)
1297 ZEND_END_ARG_INFO();
1298 static PHP_METHOD(HttpMessage, getInfo)
1299 {
1300         if (SUCCESS == zend_parse_parameters_none()) {
1301                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1302
1303                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1304
1305                 switch (obj->message->type) {
1306                         case PHP_HTTP_REQUEST:
1307                                 Z_STRLEN_P(return_value) = spprintf(&Z_STRVAL_P(return_value), 0, PHP_HTTP_INFO_REQUEST_FMT_ARGS(&obj->message->http, ""));
1308                                 break;
1309                         case PHP_HTTP_RESPONSE:
1310                                 Z_STRLEN_P(return_value) = spprintf(&Z_STRVAL_P(return_value), 0, PHP_HTTP_INFO_RESPONSE_FMT_ARGS(&obj->message->http, ""));
1311                                 break;
1312                         default:
1313                                 RETURN_NULL();
1314                                 break;
1315                 }
1316                 Z_TYPE_P(return_value) = IS_STRING;
1317                 return;
1318         }
1319 }
1320
1321 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setInfo, 0, 0, 1)
1322         ZEND_ARG_INFO(0, http_info)
1323 ZEND_END_ARG_INFO();
1324 static PHP_METHOD(HttpMessage, setInfo)
1325 {
1326         char *str;
1327         int len;
1328         php_http_message_object_t *obj;
1329         php_http_info_t inf;
1330
1331         php_http_expect(SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &str, &len), invalid_arg, return);
1332
1333         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1334         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1335
1336         if (!php_http_info_parse(&inf, str TSRMLS_CC)) {
1337                 php_http_throw(bad_header, "Could not parse message info '%s'", str);
1338                 return;
1339         }
1340
1341         php_http_message_set_info(obj->message, &inf);
1342         php_http_info_dtor(&inf);
1343
1344         RETVAL_ZVAL(getThis(), 1, 0);
1345 }
1346
1347 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getHttpVersion, 0, 0, 0)
1348 ZEND_END_ARG_INFO();
1349 static PHP_METHOD(HttpMessage, getHttpVersion)
1350 {
1351         if (SUCCESS == zend_parse_parameters_none()) {
1352                 char *str;
1353                 size_t len;
1354                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1355
1356                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1357
1358                 php_http_version_to_string(&obj->message->http.version, &str, &len, NULL, NULL TSRMLS_CC);
1359                 RETURN_STRINGL(str, len, 0);
1360         }
1361 }
1362
1363 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setHttpVersion, 0, 0, 1)
1364         ZEND_ARG_INFO(0, http_version)
1365 ZEND_END_ARG_INFO();
1366 static PHP_METHOD(HttpMessage, setHttpVersion)
1367 {
1368         char *v_str;
1369         int v_len;
1370         php_http_version_t version;
1371         php_http_message_object_t *obj;
1372
1373         php_http_expect(SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &v_str, &v_len), invalid_arg, return);
1374
1375         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1376         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1377
1378         php_http_expect(php_http_version_parse(&version, v_str TSRMLS_CC), unexpected_val, return);
1379
1380         obj->message->http.version = version;
1381
1382         RETVAL_ZVAL(getThis(), 1, 0);
1383 }
1384
1385 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getResponseCode, 0, 0, 0)
1386 ZEND_END_ARG_INFO();
1387 static PHP_METHOD(HttpMessage, getResponseCode)
1388 {
1389         if (SUCCESS == zend_parse_parameters_none()) {
1390                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1391
1392                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1393
1394                 if (obj->message->type != PHP_HTTP_RESPONSE) {
1395                         php_error_docref(NULL TSRMLS_CC, E_WARNING, "http\\Message is not if type response");
1396                         RETURN_FALSE;
1397                 }
1398
1399                 RETURN_LONG(obj->message->http.info.response.code);
1400         }
1401 }
1402
1403 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setResponseCode, 0, 0, 1)
1404         ZEND_ARG_INFO(0, response_code)
1405         ZEND_ARG_INFO(0, strict)
1406 ZEND_END_ARG_INFO();
1407 static PHP_METHOD(HttpMessage, setResponseCode)
1408 {
1409         long code;
1410         zend_bool strict = 1;
1411         php_http_message_object_t *obj;
1412
1413         php_http_expect(SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l|b", &code, &strict), invalid_arg, return);
1414
1415         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1416
1417         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1418
1419         if (obj->message->type != PHP_HTTP_RESPONSE) {
1420                 php_http_throw(bad_method_call, "http\\Message is not of type response", NULL);
1421                 return;
1422         }
1423
1424         if (strict && (code < 100 || code > 599)) {
1425                 php_http_throw(invalid_arg, "Invalid response code (100-599): %ld", code);
1426                 return;
1427         }
1428
1429         obj->message->http.info.response.code = code;
1430         STR_SET(obj->message->http.info.response.status, estrdup(php_http_env_get_response_status_for_code(code)));
1431
1432         RETVAL_ZVAL(getThis(), 1, 0);
1433 }
1434
1435 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getResponseStatus, 0, 0, 0)
1436 ZEND_END_ARG_INFO();
1437 static PHP_METHOD(HttpMessage, getResponseStatus)
1438 {
1439         if (SUCCESS == zend_parse_parameters_none()) {
1440                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1441
1442                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1443
1444                 if (obj->message->type != PHP_HTTP_RESPONSE) {
1445                         php_error_docref(NULL TSRMLS_CC, E_WARNING, "http\\Message is not of type response");
1446                 }
1447
1448                 if (obj->message->http.info.response.status) {
1449                         RETURN_STRING(obj->message->http.info.response.status, 1);
1450                 } else {
1451                         RETURN_EMPTY_STRING();
1452                 }
1453         }
1454 }
1455
1456 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setResponseStatus, 0, 0, 1)
1457         ZEND_ARG_INFO(0, response_status)
1458 ZEND_END_ARG_INFO();
1459 static PHP_METHOD(HttpMessage, setResponseStatus)
1460 {
1461         char *status;
1462         int status_len;
1463         php_http_message_object_t *obj;
1464
1465         php_http_expect(SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &status, &status_len), invalid_arg, return);
1466
1467         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1468
1469         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1470
1471         if (obj->message->type != PHP_HTTP_RESPONSE) {
1472                 php_http_throw(bad_method_call, "http\\Message is not of type response", NULL);
1473         }
1474
1475         STR_SET(obj->message->http.info.response.status, estrndup(status, status_len));
1476         RETVAL_ZVAL(getThis(), 1, 0);
1477 }
1478
1479 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getRequestMethod, 0, 0, 0)
1480 ZEND_END_ARG_INFO();
1481 static PHP_METHOD(HttpMessage, getRequestMethod)
1482 {
1483         if (SUCCESS == zend_parse_parameters_none()) {
1484                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1485
1486                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1487
1488                 if (obj->message->type != PHP_HTTP_REQUEST) {
1489                         php_error_docref(NULL TSRMLS_CC, E_WARNING, "http\\Message is not of type request");
1490                         RETURN_FALSE;
1491                 }
1492
1493                 if (obj->message->http.info.request.method) {
1494                         RETURN_STRING(obj->message->http.info.request.method, 1);
1495                 } else {
1496                         RETURN_EMPTY_STRING();
1497                 }
1498         }
1499 }
1500
1501 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setRequestMethod, 0, 0, 1)
1502         ZEND_ARG_INFO(0, request_method)
1503 ZEND_END_ARG_INFO();
1504 static PHP_METHOD(HttpMessage, setRequestMethod)
1505 {
1506         char *method;
1507         int method_len;
1508         php_http_message_object_t *obj;
1509
1510         php_http_expect(SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &method, &method_len), invalid_arg, return);
1511
1512         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1513
1514         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1515
1516         if (obj->message->type != PHP_HTTP_REQUEST) {
1517                 php_http_throw(bad_method_call, "http\\Message is not of type request", NULL);
1518                 return;
1519         }
1520
1521         if (method_len < 1) {
1522                 php_http_throw(invalid_arg, "Cannot set http\\Message's request method to an empty string", NULL);
1523                 return;
1524         }
1525
1526         STR_SET(obj->message->http.info.request.method, estrndup(method, method_len));
1527         RETVAL_ZVAL(getThis(), 1, 0);
1528 }
1529
1530 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getRequestUrl, 0, 0, 0)
1531 ZEND_END_ARG_INFO();
1532 static PHP_METHOD(HttpMessage, getRequestUrl)
1533 {
1534         if (SUCCESS == zend_parse_parameters_none()) {
1535                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1536
1537                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1538
1539                 if (obj->message->type != PHP_HTTP_REQUEST) {
1540                         php_error_docref(NULL TSRMLS_CC, E_WARNING, "http\\Message is not of type request");
1541                         RETURN_FALSE;
1542                 }
1543
1544                 if (obj->message->http.info.request.url) {
1545                         RETURN_STRING(obj->message->http.info.request.url, 1);
1546                 } else {
1547                         RETURN_EMPTY_STRING();
1548                 }
1549         }
1550 }
1551
1552 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_setRequestUrl, 0, 0, 1)
1553         ZEND_ARG_INFO(0, url)
1554 ZEND_END_ARG_INFO();
1555 static PHP_METHOD(HttpMessage, setRequestUrl)
1556 {
1557         char *url_str;
1558         int url_len;
1559         php_http_message_object_t *obj;
1560
1561         php_http_expect(SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &url_str, &url_len), invalid_arg, return);
1562
1563         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1564
1565         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1566
1567         if (obj->message->type != PHP_HTTP_REQUEST) {
1568                 php_http_throw(bad_method_call, "http\\Message is not of type request", NULL);
1569                 return;
1570         }
1571
1572         if (url_len < 1) {
1573                 php_http_throw(invalid_arg, "Cannot set http\\Message's request url to an empty string", NULL);
1574                 return;
1575         }
1576
1577         STR_SET(obj->message->http.info.request.url, estrndup(url_str, url_len));
1578         RETVAL_ZVAL(getThis(), 1, 0);
1579 }
1580
1581 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_getParentMessage, 0, 0, 0)
1582 ZEND_END_ARG_INFO();
1583 static PHP_METHOD(HttpMessage, getParentMessage)
1584 {
1585         php_http_message_object_t *obj;
1586
1587         php_http_expect(SUCCESS == zend_parse_parameters_none(), invalid_arg, return);
1588
1589         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1590
1591         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1592
1593         if (!obj->message->parent) {
1594                 php_http_throw(unexpected_val, "http\\Message has not parent message", NULL);
1595                 return;
1596         }
1597
1598         RETVAL_OBJVAL(obj->parent->zv, 1);
1599 }
1600
1601 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage___toString, 0, 0, 0)
1602 ZEND_END_ARG_INFO();
1603 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_toString, 0, 0, 0)
1604         ZEND_ARG_INFO(0, include_parent)
1605 ZEND_END_ARG_INFO();
1606 static PHP_METHOD(HttpMessage, toString)
1607 {
1608         zend_bool include_parent = 0;
1609
1610         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|b", &include_parent)) {
1611                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1612                 char *string;
1613                 size_t length;
1614
1615                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1616
1617                 if (include_parent) {
1618                         php_http_message_serialize(obj->message, &string, &length);
1619                 } else {
1620                         php_http_message_to_string(obj->message, &string, &length);
1621                 }
1622                 if (string) {
1623                         RETURN_STRINGL(string, length, 0);
1624                 }
1625         }
1626         RETURN_EMPTY_STRING();
1627 }
1628
1629 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_toStream, 0, 0, 1)
1630         ZEND_ARG_INFO(0, stream)
1631 ZEND_END_ARG_INFO();
1632 static PHP_METHOD(HttpMessage, toStream)
1633 {
1634         zval *zstream;
1635
1636         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &zstream)) {
1637                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1638                 php_stream *s;
1639
1640                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1641
1642                 php_stream_from_zval(s, &zstream);
1643                 php_http_message_to_callback(obj->message, (php_http_pass_callback_t) _php_stream_write, s);
1644         }
1645 }
1646
1647 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_toCallback, 0, 0, 1)
1648         ZEND_ARG_INFO(0, callback)
1649 ZEND_END_ARG_INFO();
1650 static PHP_METHOD(HttpMessage, toCallback)
1651 {
1652         php_http_pass_fcall_arg_t fcd;
1653
1654         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "f", &fcd.fci, &fcd.fcc)) {
1655                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1656
1657                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1658
1659                 fcd.fcz = getThis();
1660                 Z_ADDREF_P(fcd.fcz);
1661                 TSRMLS_SET_CTX(fcd.ts);
1662
1663                 php_http_message_to_callback(obj->message, php_http_pass_fcall_callback, &fcd);
1664                 zend_fcall_info_args_clear(&fcd.fci, 1);
1665
1666                 zval_ptr_dtor(&fcd.fcz);
1667                 RETURN_ZVAL(getThis(), 1, 0);
1668         }
1669 }
1670
1671 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_serialize, 0, 0, 0)
1672 ZEND_END_ARG_INFO();
1673 static PHP_METHOD(HttpMessage, serialize)
1674 {
1675         if (SUCCESS == zend_parse_parameters_none()) {
1676                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1677                 char *string;
1678                 size_t length;
1679
1680                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1681
1682                 php_http_message_serialize(obj->message, &string, &length);
1683                 RETURN_STRINGL(string, length, 0);
1684         }
1685         RETURN_EMPTY_STRING();
1686 }
1687
1688 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_unserialize, 0, 0, 1)
1689         ZEND_ARG_INFO(0, serialized)
1690 ZEND_END_ARG_INFO();
1691 static PHP_METHOD(HttpMessage, unserialize)
1692 {
1693         int length;
1694         char *serialized;
1695
1696         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &serialized, &length)) {
1697                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1698                 php_http_message_t *msg;
1699
1700                 if (obj->message) {
1701                         php_http_message_dtor(obj->message);
1702                         efree(obj->message);
1703                 }
1704                 if ((msg = php_http_message_parse(NULL, serialized, (size_t) length, 1 TSRMLS_CC))) {
1705                         obj->message = msg;
1706                 } else {
1707                         obj->message = php_http_message_init(NULL, 0, NULL TSRMLS_CC);
1708                         php_error_docref(NULL TSRMLS_CC, E_ERROR, "Could not unserialize http\\Message");
1709                 }
1710         }
1711 }
1712
1713 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_detach, 0, 0, 0)
1714 ZEND_END_ARG_INFO();
1715 static PHP_METHOD(HttpMessage, detach)
1716 {
1717         php_http_message_object_t *obj;
1718
1719         php_http_expect(SUCCESS == zend_parse_parameters_none(), invalid_arg, return);
1720
1721         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1722
1723         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1724
1725         RETVAL_OBJVAL(php_http_message_object_new_ex(obj->zo.ce, php_http_message_copy_ex(obj->message, NULL, 0), NULL TSRMLS_CC), 0);
1726 }
1727
1728 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_prepend, 0, 0, 1)
1729         ZEND_ARG_OBJ_INFO(0, message, http\\Message, 0)
1730         ZEND_ARG_INFO(0, top)
1731 ZEND_END_ARG_INFO();
1732 static PHP_METHOD(HttpMessage, prepend)
1733 {
1734         zval *prepend;
1735         zend_bool top = 1;
1736         php_http_message_t *msg[2];
1737         php_http_message_object_t *obj, *prepend_obj;
1738
1739         php_http_expect(SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "O|b", &prepend, php_http_message_class_entry, &top), invalid_arg, return);
1740
1741         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1742         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1743         prepend_obj = zend_object_store_get_object(prepend TSRMLS_CC);
1744         PHP_HTTP_MESSAGE_OBJECT_INIT(prepend_obj);
1745
1746         /* safety check */
1747         for (msg[0] = obj->message; msg[0]; msg[0] = msg[0]->parent) {
1748                 for (msg[1] = prepend_obj->message; msg[1]; msg[1] = msg[1]->parent) {
1749                         if (msg[0] == msg[1]) {
1750                                 php_http_throw(unexpected_val, "Cannot prepend a message located within the same message chain", NULL);
1751                                 return;
1752                         }
1753                 }
1754         }
1755
1756         php_http_message_object_prepend(getThis(), prepend, top TSRMLS_CC);
1757         RETURN_ZVAL(getThis(), 1, 0);
1758 }
1759
1760 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_reverse, 0, 0, 0)
1761 ZEND_END_ARG_INFO();
1762 static PHP_METHOD(HttpMessage, reverse)
1763 {
1764         php_http_expect(SUCCESS == zend_parse_parameters_none(), invalid_arg, return);
1765
1766         php_http_message_object_reverse(getThis(), return_value TSRMLS_CC);
1767 }
1768
1769 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_isMultipart, 0, 0, 0)
1770         ZEND_ARG_INFO(1, boundary)
1771 ZEND_END_ARG_INFO();
1772 static PHP_METHOD(HttpMessage, isMultipart)
1773 {
1774         zval *zboundary = NULL;
1775
1776         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|z", &zboundary)) {
1777                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1778                 char *boundary = NULL;
1779
1780                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1781
1782                 RETVAL_BOOL(php_http_message_is_multipart(obj->message, zboundary ? &boundary : NULL));
1783
1784                 if (zboundary && boundary) {
1785                         zval_dtor(zboundary);
1786                         ZVAL_STRING(zboundary, boundary, 0);
1787                 }
1788         }
1789 }
1790
1791 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_splitMultipartBody, 0, 0, 0)
1792 ZEND_END_ARG_INFO();
1793 static PHP_METHOD(HttpMessage, splitMultipartBody)
1794 {
1795         php_http_message_object_t *obj;
1796         php_http_message_t *msg;
1797         char *boundary = NULL;
1798
1799         php_http_expect(SUCCESS == zend_parse_parameters_none(), invalid_arg, return);
1800
1801         obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1802
1803         PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1804
1805         if (!php_http_message_is_multipart(obj->message, &boundary)) {
1806                 php_http_throw(bad_method_call, "http\\Message is not a multipart message", NULL);
1807                 return;
1808         }
1809
1810         php_http_expect(msg = php_http_message_body_split(obj->message->body, boundary), bad_message, return);
1811
1812         STR_FREE(boundary);
1813
1814         RETURN_OBJVAL(php_http_message_object_new_ex(php_http_message_class_entry, msg, NULL TSRMLS_CC), 0);
1815 }
1816
1817 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_count, 0, 0, 0)
1818 ZEND_END_ARG_INFO();
1819 static PHP_METHOD(HttpMessage, count)
1820 {
1821         long count_mode = -1;
1822
1823         if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|l", &count_mode)) {
1824                 long i = 0;
1825                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1826
1827                 PHP_HTTP_MESSAGE_OBJECT_INIT(obj);
1828
1829                 php_http_message_count(i, obj->message);
1830                 RETURN_LONG(i);
1831         }
1832 }
1833
1834 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_rewind, 0, 0, 0)
1835 ZEND_END_ARG_INFO();
1836 static PHP_METHOD(HttpMessage, rewind)
1837 {
1838         if (SUCCESS == zend_parse_parameters_none()) {
1839                 zval *zobj = getThis();
1840                 php_http_message_object_t *obj = zend_object_store_get_object(zobj TSRMLS_CC);
1841
1842                 if (obj->iterator) {
1843                         zval_ptr_dtor(&obj->iterator);
1844                 }
1845                 Z_ADDREF_P(zobj);
1846                 obj->iterator = zobj;
1847         }
1848 }
1849
1850 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_valid, 0, 0, 0)
1851 ZEND_END_ARG_INFO();
1852 static PHP_METHOD(HttpMessage, valid)
1853 {
1854         if (SUCCESS == zend_parse_parameters_none()) {
1855                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1856
1857                 RETURN_BOOL(obj->iterator != NULL);
1858         }
1859 }
1860
1861 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_next, 0, 0, 0)
1862 ZEND_END_ARG_INFO();
1863 static PHP_METHOD(HttpMessage, next)
1864 {
1865         if (SUCCESS == zend_parse_parameters_none()) {
1866                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1867
1868                 if (obj->iterator) {
1869                         php_http_message_object_t *itr = zend_object_store_get_object(obj->iterator TSRMLS_CC);
1870
1871                         if (itr && itr->parent) {
1872                                 zval *old = obj->iterator;
1873                                 MAKE_STD_ZVAL(obj->iterator);
1874                                 ZVAL_OBJVAL(obj->iterator, itr->parent->zv, 1);
1875                                 zval_ptr_dtor(&old);
1876                         } else {
1877                                 zval_ptr_dtor(&obj->iterator);
1878                                 obj->iterator = NULL;
1879                         }
1880                 }
1881         }
1882 }
1883
1884 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_key, 0, 0, 0)
1885 ZEND_END_ARG_INFO();
1886 static PHP_METHOD(HttpMessage, key)
1887 {
1888         if (SUCCESS == zend_parse_parameters_none()) {
1889                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1890
1891                 RETURN_LONG(obj->iterator ? obj->iterator->value.obj.handle:0);
1892         }
1893 }
1894
1895 ZEND_BEGIN_ARG_INFO_EX(ai_HttpMessage_current, 0, 0, 0)
1896 ZEND_END_ARG_INFO();
1897 static PHP_METHOD(HttpMessage, current)
1898 {
1899         if (SUCCESS == zend_parse_parameters_none()) {
1900                 php_http_message_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
1901
1902                 if (obj->iterator) {
1903                         RETURN_ZVAL(obj->iterator, 1, 0);
1904                 }
1905         }
1906 }
1907
1908 static zend_function_entry php_http_message_methods[] = {
1909         PHP_ME(HttpMessage, __construct,        ai_HttpMessage___construct,        ZEND_ACC_PUBLIC|ZEND_ACC_CTOR)
1910         PHP_ME(HttpMessage, getBody,            ai_HttpMessage_getBody,            ZEND_ACC_PUBLIC)
1911         PHP_ME(HttpMessage, setBody,            ai_HttpMessage_setBody,            ZEND_ACC_PUBLIC)
1912         PHP_ME(HttpMessage, addBody,            ai_HttpMessage_addBody,            ZEND_ACC_PUBLIC)
1913         PHP_ME(HttpMessage, getHeader,          ai_HttpMessage_getHeader,          ZEND_ACC_PUBLIC)
1914         PHP_ME(HttpMessage, setHeader,          ai_HttpMessage_setHeader,          ZEND_ACC_PUBLIC)
1915         PHP_ME(HttpMessage, addHeader,          ai_HttpMessage_addHeader,          ZEND_ACC_PUBLIC)
1916         PHP_ME(HttpMessage, getHeaders,         ai_HttpMessage_getHeaders,         ZEND_ACC_PUBLIC)
1917         PHP_ME(HttpMessage, setHeaders,         ai_HttpMessage_setHeaders,         ZEND_ACC_PUBLIC)
1918         PHP_ME(HttpMessage, addHeaders,         ai_HttpMessage_addHeaders,         ZEND_ACC_PUBLIC)
1919         PHP_ME(HttpMessage, getType,            ai_HttpMessage_getType,            ZEND_ACC_PUBLIC)
1920         PHP_ME(HttpMessage, setType,            ai_HttpMessage_setType,            ZEND_ACC_PUBLIC)
1921         PHP_ME(HttpMessage, getInfo,            ai_HttpMessage_getInfo,            ZEND_ACC_PUBLIC)
1922         PHP_ME(HttpMessage, setInfo,            ai_HttpMessage_setInfo,            ZEND_ACC_PUBLIC)
1923         PHP_ME(HttpMessage, getResponseCode,    ai_HttpMessage_getResponseCode,    ZEND_ACC_PUBLIC)
1924         PHP_ME(HttpMessage, setResponseCode,    ai_HttpMessage_setResponseCode,    ZEND_ACC_PUBLIC)
1925         PHP_ME(HttpMessage, getResponseStatus,  ai_HttpMessage_getResponseStatus,  ZEND_ACC_PUBLIC)
1926         PHP_ME(HttpMessage, setResponseStatus,  ai_HttpMessage_setResponseStatus,  ZEND_ACC_PUBLIC)
1927         PHP_ME(HttpMessage, getRequestMethod,   ai_HttpMessage_getRequestMethod,   ZEND_ACC_PUBLIC)
1928         PHP_ME(HttpMessage, setRequestMethod,   ai_HttpMessage_setRequestMethod,   ZEND_ACC_PUBLIC)
1929         PHP_ME(HttpMessage, getRequestUrl,      ai_HttpMessage_getRequestUrl,      ZEND_ACC_PUBLIC)
1930         PHP_ME(HttpMessage, setRequestUrl,      ai_HttpMessage_setRequestUrl,      ZEND_ACC_PUBLIC)
1931         PHP_ME(HttpMessage, getHttpVersion,     ai_HttpMessage_getHttpVersion,     ZEND_ACC_PUBLIC)
1932         PHP_ME(HttpMessage, setHttpVersion,     ai_HttpMessage_setHttpVersion,     ZEND_ACC_PUBLIC)
1933         PHP_ME(HttpMessage, getParentMessage,   ai_HttpMessage_getParentMessage,   ZEND_ACC_PUBLIC)
1934         PHP_ME(HttpMessage, toString,           ai_HttpMessage_toString,           ZEND_ACC_PUBLIC)
1935         PHP_ME(HttpMessage, toCallback,         ai_HttpMessage_toCallback,         ZEND_ACC_PUBLIC)
1936         PHP_ME(HttpMessage, toStream,           ai_HttpMessage_toStream,           ZEND_ACC_PUBLIC)
1937
1938         /* implements Countable */
1939         PHP_ME(HttpMessage, count,              ai_HttpMessage_count,              ZEND_ACC_PUBLIC)
1940
1941         /* implements Serializable */
1942         PHP_ME(HttpMessage, serialize,          ai_HttpMessage_serialize,          ZEND_ACC_PUBLIC)
1943         PHP_ME(HttpMessage, unserialize,        ai_HttpMessage_unserialize,        ZEND_ACC_PUBLIC)
1944
1945         /* implements Iterator */
1946         PHP_ME(HttpMessage, rewind,             ai_HttpMessage_rewind,             ZEND_ACC_PUBLIC)
1947         PHP_ME(HttpMessage, valid,              ai_HttpMessage_valid,              ZEND_ACC_PUBLIC)
1948         PHP_ME(HttpMessage, current,            ai_HttpMessage_current,            ZEND_ACC_PUBLIC)
1949         PHP_ME(HttpMessage, key,                ai_HttpMessage_key,                ZEND_ACC_PUBLIC)
1950         PHP_ME(HttpMessage, next,               ai_HttpMessage_next,               ZEND_ACC_PUBLIC)
1951
1952         ZEND_MALIAS(HttpMessage, __toString, toString, ai_HttpMessage___toString,  ZEND_ACC_PUBLIC)
1953
1954         PHP_ME(HttpMessage, detach,             ai_HttpMessage_detach,             ZEND_ACC_PUBLIC)
1955         PHP_ME(HttpMessage, prepend,            ai_HttpMessage_prepend,            ZEND_ACC_PUBLIC)
1956         PHP_ME(HttpMessage, reverse,            ai_HttpMessage_reverse,            ZEND_ACC_PUBLIC)
1957
1958         PHP_ME(HttpMessage, isMultipart,        ai_HttpMessage_isMultipart,        ZEND_ACC_PUBLIC)
1959         PHP_ME(HttpMessage, splitMultipartBody, ai_HttpMessage_splitMultipartBody, ZEND_ACC_PUBLIC)
1960
1961         EMPTY_FUNCTION_ENTRY
1962 };
1963
1964 zend_class_entry *php_http_message_class_entry;
1965
1966 PHP_MINIT_FUNCTION(http_message)
1967 {
1968         zend_class_entry ce = {0};
1969
1970         INIT_NS_CLASS_ENTRY(ce, "http", "Message", php_http_message_methods);
1971         php_http_message_class_entry = zend_register_internal_class(&ce TSRMLS_CC);
1972         php_http_message_class_entry->create_object = php_http_message_object_new;
1973         memcpy(&php_http_message_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
1974         php_http_message_object_handlers.clone_obj = php_http_message_object_clone;
1975         php_http_message_object_handlers.read_property = php_http_message_object_read_prop;
1976         php_http_message_object_handlers.write_property = php_http_message_object_write_prop;
1977         php_http_message_object_handlers.get_properties = php_http_message_object_get_props;
1978         php_http_message_object_handlers.get_property_ptr_ptr = NULL;
1979
1980         zend_class_implements(php_http_message_class_entry TSRMLS_CC, 3, spl_ce_Countable, zend_ce_serializable, zend_ce_iterator);
1981
1982         zend_hash_init(&php_http_message_object_prophandlers, 9, NULL, NULL, 1);
1983         zend_declare_property_long(php_http_message_class_entry, ZEND_STRL("type"), PHP_HTTP_NONE, ZEND_ACC_PROTECTED TSRMLS_CC);
1984         php_http_message_object_add_prophandler(ZEND_STRL("type"), php_http_message_object_prophandler_get_type, php_http_message_object_prophandler_set_type);
1985         zend_declare_property_null(php_http_message_class_entry, ZEND_STRL("body"), ZEND_ACC_PROTECTED TSRMLS_CC);
1986         php_http_message_object_add_prophandler(ZEND_STRL("body"), php_http_message_object_prophandler_get_body, php_http_message_object_prophandler_set_body);
1987         zend_declare_property_string(php_http_message_class_entry, ZEND_STRL("requestMethod"), "", ZEND_ACC_PROTECTED TSRMLS_CC);
1988         php_http_message_object_add_prophandler(ZEND_STRL("requestMethod"), php_http_message_object_prophandler_get_request_method, php_http_message_object_prophandler_set_request_method);
1989         zend_declare_property_string(php_http_message_class_entry, ZEND_STRL("requestUrl"), "", ZEND_ACC_PROTECTED TSRMLS_CC);
1990         php_http_message_object_add_prophandler(ZEND_STRL("requestUrl"), php_http_message_object_prophandler_get_request_url, php_http_message_object_prophandler_set_request_url);
1991         zend_declare_property_string(php_http_message_class_entry, ZEND_STRL("responseStatus"), "", ZEND_ACC_PROTECTED TSRMLS_CC);
1992         php_http_message_object_add_prophandler(ZEND_STRL("responseStatus"), php_http_message_object_prophandler_get_response_status, php_http_message_object_prophandler_set_response_status);
1993         zend_declare_property_long(php_http_message_class_entry, ZEND_STRL("responseCode"), 0, ZEND_ACC_PROTECTED TSRMLS_CC);
1994         php_http_message_object_add_prophandler(ZEND_STRL("responseCode"), php_http_message_object_prophandler_get_response_code, php_http_message_object_prophandler_set_response_code);
1995         zend_declare_property_null(php_http_message_class_entry, ZEND_STRL("httpVersion"), ZEND_ACC_PROTECTED TSRMLS_CC);
1996         php_http_message_object_add_prophandler(ZEND_STRL("httpVersion"), php_http_message_object_prophandler_get_http_version, php_http_message_object_prophandler_set_http_version);
1997         zend_declare_property_null(php_http_message_class_entry, ZEND_STRL("headers"), ZEND_ACC_PROTECTED TSRMLS_CC);
1998         php_http_message_object_add_prophandler(ZEND_STRL("headers"), php_http_message_object_prophandler_get_headers, php_http_message_object_prophandler_set_headers);
1999         zend_declare_property_null(php_http_message_class_entry, ZEND_STRL("parentMessage"), ZEND_ACC_PROTECTED TSRMLS_CC);
2000         php_http_message_object_add_prophandler(ZEND_STRL("parentMessage"), php_http_message_object_prophandler_get_parent_message, php_http_message_object_prophandler_set_parent_message);
2001
2002         zend_declare_class_constant_long(php_http_message_class_entry, ZEND_STRL("TYPE_NONE"), PHP_HTTP_NONE TSRMLS_CC);
2003         zend_declare_class_constant_long(php_http_message_class_entry, ZEND_STRL("TYPE_REQUEST"), PHP_HTTP_REQUEST TSRMLS_CC);
2004         zend_declare_class_constant_long(php_http_message_class_entry, ZEND_STRL("TYPE_RESPONSE"), PHP_HTTP_RESPONSE TSRMLS_CC);
2005
2006         return SUCCESS;
2007 }
2008
2009 PHP_MSHUTDOWN_FUNCTION(http_message)
2010 {
2011         zend_hash_destroy(&php_http_message_object_prophandlers);
2012
2013         return SUCCESS;
2014 }
2015
2016 /*
2017  * Local variables:
2018  * tab-width: 4
2019  * c-basic-offset: 4
2020  * End:
2021  * vim600: noet sw=4 ts=4 fdm=marker
2022  * vim<600: noet sw=4 ts=4
2023  */
2024