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

   1 /*
   2    +----------------------------------------------------------------------+
   3    | PECL :: http                                                         |
   4    +----------------------------------------------------------------------+
   5    | This source file is subject to version 3.0 of the PHP license, that  |
   6    | is bundled with this package in the file LICENSE, and is available   |
   7    | through the world-wide-web at http://www.php.net/license/3_0.txt.    |
   8    | If you did not receive a copy of the PHP license and are unable to   |
   9    | obtain it through the world-wide-web, please send a note to          |
  10    | license@php.net so we can mail you a copy immediately.               |
  11    +----------------------------------------------------------------------+
  12    | Copyright (c) 2004-2005 Michael Wallner <mike@php.net>               |
  13    +----------------------------------------------------------------------+
  14 */
  15
  16 /* $Id$ */
  17
  18
  19 #ifdef HAVE_CONFIG_H
  20 #       include "config.h"
  21 #endif
  22
  23 #include "php.h"
  24
  25 #include "php_http.h"
  26 #include "php_http_std_defs.h"
  27 #include "php_http_message_object.h"
  28
  29 #ifdef ZEND_ENGINE_2
  30
  31 #define http_message_object_declare_default_properties() _http_message_object_declare_default_properties(TSRMLS_C)
  32 static inline void _http_message_object_declare_default_properties(TSRMLS_D);
  33 #define http_message_object_read_prop _http_message_object_read_prop
  34 static zval *_http_message_object_read_prop(zval *object, zval *member, int type TSRMLS_DC);
  35 #define http_message_object_write_prop _http_message_object_write_prop
  36 static void _http_message_object_write_prop(zval *object, zval *member, zval *value TSRMLS_DC);
  37 #define http_message_object_get_props _http_message_object_get_props
  38 static HashTable *_http_message_object_get_props(zval *object TSRMLS_DC);
  39
  40 zend_class_entry *http_message_object_ce;
  41 zend_function_entry http_message_object_fe[] = {
  42         PHP_ME(HttpMessage, __construct, NULL, ZEND_ACC_PUBLIC|ZEND_ACC_CTOR)
  43         PHP_ME(HttpMessage, setRaw, NULL, ZEND_ACC_PUBLIC)
  44         PHP_ME(HttpMessage, getBody, NULL, ZEND_ACC_PUBLIC)
  45         PHP_ME(HttpMessage, getHeaders, NULL, ZEND_ACC_PUBLIC)
  46         {NULL, NULL, NULL}
  47 };
  48 static zend_object_handlers http_message_object_handlers;
  49
  50 void _http_message_object_init(INIT_FUNC_ARGS)
  51 {
  52         HTTP_REGISTER_CLASS_EX(HttpMessage, http_message_object, NULL, 0);
  53
  54         http_message_object_handlers.read_property = http_message_object_read_prop;
  55         http_message_object_handlers.write_property = http_message_object_write_prop;
  56         http_message_object_handlers.get_properties = http_message_object_get_props;
  57 }
  58
  59 zend_object_value _http_message_object_new(zend_class_entry *ce TSRMLS_DC)
  60 {
  61         zend_object_value ov;
  62         http_message_object *o;
  63
  64         o = ecalloc(1, sizeof(http_message_object));
  65         o->zo.ce = ce;
  66         o->message = http_message_new();
  67
  68         ALLOC_HASHTABLE(OBJ_PROP(o));
  69         zend_hash_init(OBJ_PROP(o), 0, NULL, ZVAL_PTR_DTOR, 0);
  70
  71         ov.handle = zend_objects_store_put(o, (zend_objects_store_dtor_t) zend_objects_destroy_object, http_message_object_free, NULL TSRMLS_CC);
  72         ov.handlers = &http_message_object_handlers;
  73
  74         return ov;
  75 }
  76
  77 static inline void _http_message_object_declare_default_properties(TSRMLS_D)
  78 {
  79         zend_class_entry *ce = http_message_object_ce;
  80
  81         DCL_PROP(PROTECTED, long, type, HTTP_MSG_NONE);
  82
  83         DCL_PROP(PROTECTED, string, raw, "");
  84         DCL_PROP(PROTECTED, string, body, "");
  85
  86         DCL_PROP(PROTECTED, string, requestMethod, "");
  87         DCL_PROP(PROTECTED, string, requestUri, "");
  88         DCL_PROP(PROTECTED, long, responseStatus, 0);
  89
  90         DCL_PROP_N(PROTECTED, httpVersion);
  91         DCL_PROP_N(PROTECTED, headers);
  92         DCL_PROP_N(PROTECTED, nestedMessage);
  93 }
  94
  95 static void _http_message_object_free(zend_object *object TSRMLS_DC)
  96 {
  97         http_message_object *o = (http_message_object *) object;
  98
  99         if (OBJ_PROP(o)) {
 100                 zend_hash_destroy(OBJ_PROP(o));
 101                 FREE_HASHTABLE(OBJ_PROP(o));
 102         }
 103         if (o->message) {
 104                 http_message_free(o->message);
 105         }
 106         zval_dtor(&o->_tmp_property);
 107         efree(o);
 108 }
 109
 110 static zval *_http_message_object_read_prop(zval *object, zval *member, int type TSRMLS_DC)
 111 {
 112         getObjectEx(http_message_object, obj, object);
 113         http_message *msg = obj->message;
 114         zval *return_value = &obj->_tmp_property;
 115
 116         if (!EG(scope) || !instanceof_function(EG(scope), obj->zo.ce TSRMLS_CC)) {
 117                 zend_error(E_WARNING, "Cannot access protected property %s::$%s", obj->zo.ce->name, Z_STRVAL_P(member));
 118                 return EG(uninitialized_zval_ptr);
 119         }
 120
 121     zval_dtor(return_value);
 122
 123 #if 0
 124         fprintf(stderr, "Reading property: %s(%d==%d) (%lu)\n", Z_STRVAL_P(member), Z_STRLEN_P(member), strlen(Z_STRVAL_P(member)),
 125                 zend_get_hash_value(Z_STRVAL_P(member), strlen(Z_STRVAL_P(member)) + 1)
 126         );
 127 #endif
 128
 129         switch (zend_get_hash_value(Z_STRVAL_P(member), strlen(Z_STRVAL_P(member)) + 1))
 130         {
 131                 case HTTP_MSG_PROPHASH_TYPE:
 132                         RETVAL_LONG(msg->type);
 133                 break;
 134
 135                 case HTTP_MSG_PROPHASH_HTTP_VERSION:
 136                         switch (msg->type)
 137                         {
 138                                 case HTTP_MSG_NONE:
 139                                         RETVAL_NULL();
 140                                 break;
 141
 142                                 case HTTP_MSG_REQUEST:
 143                                         RETVAL_DOUBLE(msg->info.request.http_version);
 144                                 break;
 145
 146                                 case HTTP_MSG_RESPONSE:
 147                                         RETVAL_DOUBLE(msg->info.response.http_version);
 148                                 break;
 149                         }
 150                 break;
 151
 152                 case HTTP_MSG_PROPHASH_RAW:
 153                         if (msg->raw) {
 154                                 if (msg->len) {
 155                                         RETVAL_STRINGL(msg->raw, msg->len, 1);
 156                                 } else {
 157                                         RETVAL_STRINGL(empty_string, 0, 1);
 158                                 }
 159                         } else {
 160                                 RETVAL_NULL();
 161                         }
 162                 break;
 163
 164                 case HTTP_MSG_PROPHASH_BODY:
 165                         phpstr_fix(PHPSTR(msg));
 166                         RETVAL_PHPSTR(PHPSTR(msg), 0, 1);
 167                 break;
 168
 169                 case HTTP_MSG_PROPHASH_HEADERS:
 170                         array_init(return_value);
 171                         zend_hash_copy(Z_ARRVAL_P(return_value), &msg->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
 172                 break;
 173
 174                 case HTTP_MSG_PROPHASH_NESTED_MESSAGE:
 175                         RETVAL_NULL();
 176                 break;
 177
 178                 case HTTP_MSG_PROPHASH_REQUEST_METHOD:
 179                         if (msg->type == HTTP_MSG_REQUEST && msg->info.request.method) {
 180                                 RETVAL_STRING(msg->info.request.method, 1);
 181                         } else {
 182                                 RETVAL_NULL();
 183                         }
 184                 break;
 185
 186                 case HTTP_MSG_PROPHASH_REQUEST_URI:
 187                         if (msg->type == HTTP_MSG_REQUEST && msg->info.request.URI) {
 188                                 RETVAL_STRING(msg->info.request.URI, 1);
 189                         } else {
 190                                 RETVAL_NULL();
 191                         }
 192                 break;
 193
 194                 case HTTP_MSG_PROPHASH_RESPONSE_STATUS:
 195                         if (msg->type == HTTP_MSG_RESPONSE) {
 196                                 RETVAL_LONG(msg->info.response.status);
 197                         } else {
 198                                 RETVAL_NULL();
 199                         }
 200                 break;
 201
 202                 default:
 203                         RETVAL_NULL();
 204                 break;
 205         }
 206
 207         return return_value;
 208 }
 209
 210 static void _http_message_object_write_prop(zval *object, zval *member, zval *value TSRMLS_DC)
 211 {
 212         getObjectEx(http_message_object, obj, object);
 213         http_message *msg = obj->message;
 214
 215         if (!EG(scope) || !instanceof_function(EG(scope), obj->zo.ce TSRMLS_CC)) {
 216                 zend_error(E_WARNING, "Cannot access protected property %s::$%s", obj->zo.ce->name, Z_STRVAL_P(member));
 217         }
 218
 219 #if 0
 220         fprintf(stderr, "Writing property: %s(%d==%d) (%lu)\n", Z_STRVAL_P(member), Z_STRLEN_P(member), strlen(Z_STRVAL_P(member)),
 221                 zend_get_hash_value(Z_STRVAL_P(member), strlen(Z_STRVAL_P(member)) + 1)
 222         );
 223 #endif
 224
 225         switch (zend_get_hash_value(Z_STRVAL_P(member), strlen(Z_STRVAL_P(member)) + 1))
 226         {
 227                 case HTTP_MSG_PROPHASH_TYPE:
 228                         msg->type = Z_LVAL_P(value);
 229                 break;
 230
 231                 case HTTP_MSG_PROPHASH_HTTP_VERSION:
 232                         switch (msg->type)
 233                         {
 234                                 case HTTP_MSG_REQUEST:
 235                                         msg->info.request.http_version = (float) Z_DVAL_P(value);
 236                                 break;
 237
 238                                 case HTTP_MSG_RESPONSE:
 239                                         msg->info.response.http_version = (float) Z_DVAL_P(value);
 240                                 break;
 241                         }
 242                 break;
 243
 244                 case HTTP_MSG_PROPHASH_RAW:
 245                         http_message_dtor(msg);
 246                         http_message_parse_ex(msg, Z_STRVAL_P(value), Z_STRLEN_P(value), 1);
 247                 break;
 248
 249                 case HTTP_MSG_PROPHASH_BODY:
 250                         phpstr_dtor(PHPSTR(msg));
 251                         phpstr_from_string_ex(PHPSTR(msg), Z_STRVAL_P(value), Z_STRLEN_P(value));
 252                 break;
 253
 254                 case HTTP_MSG_PROPHASH_HEADERS:
 255                         zend_hash_clean(&msg->hdrs);
 256                         zend_hash_copy(&msg->hdrs, Z_ARRVAL_P(value), (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
 257                 break;
 258
 259                 case HTTP_MSG_PROPHASH_NESTED_MESSAGE:
 260                 break;
 261
 262                 case HTTP_MSG_PROPHASH_REQUEST_METHOD:
 263                         if (msg->type == HTTP_MSG_REQUEST) {
 264                                 if (msg->info.request.method) {
 265                                         efree(msg->info.request.method);
 266                                 }
 267                                 msg->info.request.method = estrndup(Z_STRVAL_P(value), Z_STRLEN_P(value));
 268                         }
 269                 break;
 270
 271                 case HTTP_MSG_PROPHASH_REQUEST_URI:
 272                         if (msg->type == HTTP_MSG_REQUEST) {
 273                                 if (msg->info.request.URI) {
 274                                         efree(msg->info.request.URI);
 275                                 }
 276                                 msg->info.request.URI = estrndup(Z_STRVAL_P(value), Z_STRLEN_P(value));
 277                         }
 278                 break;
 279
 280                 case HTTP_MSG_PROPHASH_RESPONSE_STATUS:
 281                         if (msg->type == HTTP_MSG_RESPONSE) {
 282                                 msg->info.response.status = Z_LVAL_P(value);
 283                         }
 284                 break;
 285         }
 286 }
 287
 288 static HashTable *_http_message_object_get_props(zval *object TSRMLS_DC)
 289 {
 290         zval *headers;
 291         getObjectEx(http_message_object, obj, object);
 292         http_message *msg = obj->message;
 293
 294 #define ASSOC_PROP(obj, ptype, name, val) \
 295         { \
 296                 zval array; \
 297                 char *m_prop_name; \
 298                 int m_prop_len; \
 299                 Z_ARRVAL(array) = OBJ_PROP(obj); \
 300                 zend_mangle_property_name(&m_prop_name, &m_prop_len, "*", 1, name, lenof(name), 1); \
 301                 add_assoc_ ##ptype## _ex(&array, m_prop_name, sizeof(name)+4, val); \
 302         }
 303 #define ASSOC_STRING(obj, name, val) ASSOC_STRINGL(obj, name, val, strlen(val))
 304 #define ASSOC_STRINGL(obj, name, val, len) \
 305         { \
 306                 zval array; \
 307                 char *m_prop_name; \
 308                 int m_prop_len; \
 309                 Z_ARRVAL(array) = OBJ_PROP(obj); \
 310                 zend_mangle_property_name(&m_prop_name, &m_prop_len, "*", 1, name, lenof(name), 1); \
 311                 add_assoc_stringl_ex(&array, m_prop_name, sizeof(name)+4, val, len, val != empty_string); \
 312         }
 313
 314         zend_hash_clean(OBJ_PROP(obj));
 315
 316         ASSOC_PROP(obj, long, "type", msg->type);
 317         ASSOC_STRINGL(obj, "raw", msg->raw, msg->len)
 318         ASSOC_STRINGL(obj, "body", PHPSTR_VAL(msg), PHPSTR_LEN(msg));
 319
 320         MAKE_STD_ZVAL(headers);
 321         array_init(headers);
 322
 323         zend_hash_copy(Z_ARRVAL_P(headers), &msg->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
 324         ASSOC_PROP(obj, zval, "headers", headers);
 325
 326         switch (msg->type)
 327         {
 328                 case HTTP_MSG_REQUEST:
 329                         ASSOC_PROP(obj, double, "httpVersion", msg->info.request.http_version);
 330                         ASSOC_PROP(obj, long, "responseStatus", 0);
 331                         ASSOC_STRING(obj, "requestMethod", msg->info.request.method);
 332                         ASSOC_STRING(obj, "requestUri", msg->info.request.URI);
 333                 break;
 334
 335                 case HTTP_MSG_RESPONSE:
 336                         ASSOC_PROP(obj, double, "httpVersion", msg->info.response.http_version);
 337                         ASSOC_PROP(obj, long, "responseStatus", msg->info.response.status);
 338                         ASSOC_STRING(obj, "requestMethod", empty_string);
 339                         ASSOC_STRING(obj, "requestUri", empty_string);
 340                 break;
 341
 342                 case HTTP_MSG_NONE:
 343                 default:
 344                         ASSOC_PROP(obj, double, "httpVersion", 0.0);
 345                         ASSOC_PROP(obj, long, "responseStatus", 0);
 346                         ASSOC_STRING(obj, "requestMethod", empty_string);
 347                         ASSOC_STRING(obj, "requestUri", empty_string);
 348                 break;
 349         }
 350
 351         return OBJ_PROP(obj);
 352 }
 353
 354 #endif /* ZEND_ENGINE_2 */
 355
 356 /*
 357  * Local variables:
 358  * tab-width: 4
 359  * c-basic-offset: 4
 360  * End:
 361  * vim600: noet sw=4 ts=4 fdm=marker
 362  * vim<600: noet sw=4 ts=4
 363  */
 364