projects / m6w6 / ext-http / blob
? search:
summary | shortlog | log | commit | commitdiff | tree | github
history | raw | HEAD
- serialize HttpMessage in the same order as deserialized
[m6w6/ext-http] / 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, getBody, NULL, ZEND_ACC_PUBLIC)
44 PHP_ME(HttpMessage, getHeaders, NULL, ZEND_ACC_PUBLIC)
45 PHP_ME(HttpMessage, setHeaders, NULL, ZEND_ACC_PUBLIC)
46 PHP_ME(HttpMessage, addHeaders, NULL, ZEND_ACC_PUBLIC)
47 PHP_ME(HttpMessage, getType, NULL, ZEND_ACC_PUBLIC)
48 PHP_ME(HttpMessage, setType, NULL, ZEND_ACC_PUBLIC)
49 PHP_ME(HttpMessage, getResponseCode, NULL, ZEND_ACC_PUBLIC)
50 PHP_ME(HttpMessage, setResponseCode, NULL, ZEND_ACC_PUBLIC)
51 PHP_ME(HttpMessage, getRequestMethod, NULL, ZEND_ACC_PUBLIC)
52 PHP_ME(HttpMessage, setRequestMethod, NULL, ZEND_ACC_PUBLIC)
53 PHP_ME(HttpMessage, getRequestUri, NULL, ZEND_ACC_PUBLIC)
54 PHP_ME(HttpMessage, setRequestUri, NULL, ZEND_ACC_PUBLIC)
55 PHP_ME(HttpMessage, getHttpVersion, NULL, ZEND_ACC_PUBLIC)
56 PHP_ME(HttpMessage, setHttpVersion, NULL, ZEND_ACC_PUBLIC)
57 PHP_ME(HttpMessage, getParentMessage, NULL, ZEND_ACC_PUBLIC)
58 PHP_ME(HttpMessage, send, NULL, ZEND_ACC_PUBLIC)
59 PHP_ME(HttpMessage, toString, NULL, ZEND_ACC_PUBLIC)
60
61 ZEND_MALIAS(HttpMessage, __toString, toString, NULL, ZEND_ACC_PUBLIC)
62
63 PHP_ME(HttpMessage, fromString, NULL, ZEND_ACC_PUBLIC|ZEND_ACC_STATIC)
64 {NULL, NULL, NULL}
65 };
66 static zend_object_handlers http_message_object_handlers;
67
68 void _http_message_object_init(INIT_FUNC_ARGS)
69 {
70 HTTP_REGISTER_CLASS_EX(HttpMessage, http_message_object, NULL, 0);
71
72 HTTP_LONG_CONSTANT("HTTP_MSG_NONE", HTTP_MSG_NONE);
73 HTTP_LONG_CONSTANT("HTTP_MSG_REQUEST", HTTP_MSG_REQUEST);
74 HTTP_LONG_CONSTANT("HTTP_MSG_RESPONSE", HTTP_MSG_RESPONSE);
75
76 http_message_object_handlers.read_property = http_message_object_read_prop;
77 http_message_object_handlers.write_property = http_message_object_write_prop;
78 http_message_object_handlers.get_properties = http_message_object_get_props;
79 }
80
81 zend_object_value _http_message_object_new(zend_class_entry *ce TSRMLS_DC)
82 {
83 return http_message_object_new_ex(ce, NULL);
84 }
85
86 zend_object_value _http_message_object_new_ex(zend_class_entry *ce, http_message *msg TSRMLS_DC)
87 {
88 zend_object_value ov;
89 http_message_object *o;
90
91 o = ecalloc(1, sizeof(http_message_object));
92 o->zo.ce = ce;
93 o->message = NULL;
94 o->parent.handle = 0;
95 o->parent.handlers = NULL;
96
97 if (msg) {
98 o->message = msg;
99 if (msg->parent) {
100 o->parent = http_message_object_from_msg(msg->parent);
101 }
102 }
103
104 ALLOC_HASHTABLE(OBJ_PROP(o));
105 zend_hash_init(OBJ_PROP(o), 0, NULL, ZVAL_PTR_DTOR, 0);
106
107 ov.handle = zend_objects_store_put(o, (zend_objects_store_dtor_t) zend_objects_destroy_object, http_message_object_free, NULL TSRMLS_CC);
108 ov.handlers = &http_message_object_handlers;
109
110 return ov;
111 }
112
113 static inline void _http_message_object_declare_default_properties(TSRMLS_D)
114 {
115 zend_class_entry *ce = http_message_object_ce;
116
117 DCL_PROP(PROTECTED, long, type, HTTP_MSG_NONE);
118 DCL_PROP(PROTECTED, string, body, "");
119 DCL_PROP(PROTECTED, string, requestMethod, "");
120 DCL_PROP(PROTECTED, string, requestUri, "");
121 DCL_PROP(PROTECTED, long, responseCode, 0);
122 DCL_PROP_N(PROTECTED, httpVersion);
123 DCL_PROP_N(PROTECTED, headers);
124 DCL_PROP_N(PROTECTED, parentMessage);
125 }
126
127 static void _http_message_object_free(zend_object *object TSRMLS_DC)
128 {
129 http_message_object *o = (http_message_object *) object;
130
131 if (OBJ_PROP(o)) {
132 zend_hash_destroy(OBJ_PROP(o));
133 FREE_HASHTABLE(OBJ_PROP(o));
134 }
135 if (o->message) {
136 http_message_dtor(o->message);
137 efree(o->message);
138 }
139 efree(o);
140 }
141
142 static zval *_http_message_object_read_prop(zval *object, zval *member, int type TSRMLS_DC)
143 {
144 getObjectEx(http_message_object, obj, object);
145 http_message *msg = obj->message;
146 zval *return_value;
147
148 /* tmp var */
149 ALLOC_ZVAL(return_value);
150 return_value->refcount = 0;
151
152 if (!EG(scope) || !instanceof_function(EG(scope), obj->zo.ce TSRMLS_CC)) {
153 zend_error(E_WARNING, "Cannot access protected property %s::$%s", obj->zo.ce->name, Z_STRVAL_P(member));
154 return EG(uninitialized_zval_ptr);
155 }
156
157 #if 1
158 fprintf(stderr, "Reading property: %s(%d==%d)\n", Z_STRVAL_P(member), Z_STRLEN_P(member), strlen(Z_STRVAL_P(member)));
159 #endif
160
161 switch (zend_get_hash_value(Z_STRVAL_P(member), Z_STRLEN_P(member) + 1))
162 {
163 case HTTP_MSG_PROPHASH_TYPE:
164 RETVAL_LONG(msg->type);
165 break;
166
167 case HTTP_MSG_PROPHASH_HTTP_VERSION:
168 switch (msg->type)
169 {
170 case HTTP_MSG_REQUEST:
171 RETVAL_DOUBLE(msg->info.request.http_version);
172 break;
173
174 case HTTP_MSG_RESPONSE:
175 RETVAL_DOUBLE(msg->info.response.http_version);
176 break;
177
178 case HTTP_MSG_NONE:
179 default:
180 RETVAL_NULL();
181 break;
182 }
183 break;
184
185 case HTTP_MSG_PROPHASH_BODY:
186 phpstr_fix(PHPSTR(msg));
187 RETVAL_PHPSTR(PHPSTR(msg), 0, 1);
188 break;
189
190 case HTTP_MSG_PROPHASH_HEADERS:
191 array_init(return_value);
192 zend_hash_copy(Z_ARRVAL_P(return_value), &msg->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
193 break;
194
195 case HTTP_MSG_PROPHASH_PARENT_MESSAGE:
196 if (msg->parent) {
197 RETVAL_OBJVAL(obj->parent);
198 Z_TYPE_P(return_value) = IS_OBJECT;
199 return_value->value.obj = obj->parent;
200 zend_objects_store_add_ref(return_value TSRMLS_CC);
201 } else {
202 RETVAL_NULL();
203 }
204 break;
205
206 case HTTP_MSG_PROPHASH_REQUEST_METHOD:
207 if (HTTP_MSG_TYPE(REQUEST, msg) && msg->info.request.method) {
208 RETVAL_STRING(msg->info.request.method, 1);
209 } else {
210 RETVAL_NULL();
211 }
212 break;
213
214 case HTTP_MSG_PROPHASH_REQUEST_URI:
215 if (HTTP_MSG_TYPE(REQUEST, msg) && msg->info.request.URI) {
216 RETVAL_STRING(msg->info.request.URI, 1);
217 } else {
218 RETVAL_NULL();
219 }
220 break;
221
222 case HTTP_MSG_PROPHASH_RESPONSE_CODE:
223 if (HTTP_MSG_TYPE(RESPONSE, msg)) {
224 RETVAL_LONG(msg->info.response.code);
225 } else {
226 RETVAL_NULL();
227 }
228 break;
229
230 default:
231 RETVAL_NULL();
232 break;
233 }
234
235 return return_value;
236 }
237
238 static void _http_message_object_write_prop(zval *object, zval *member, zval *value TSRMLS_DC)
239 {
240 getObjectEx(http_message_object, obj, object);
241 http_message *msg = obj->message;
242
243 if (!EG(scope) || !instanceof_function(EG(scope), obj->zo.ce TSRMLS_CC)) {
244 zend_error(E_WARNING, "Cannot access protected property %s::$%s", obj->zo.ce->name, Z_STRVAL_P(member));
245 }
246
247 #if 1
248 fprintf(stderr, "Writing property: %s(%d==%d)\n", Z_STRVAL_P(member), Z_STRLEN_P(member), strlen(Z_STRVAL_P(member)));
249 #endif
250
251 switch (zend_get_hash_value(Z_STRVAL_P(member), Z_STRLEN_P(member) + 1))
252 {
253 case HTTP_MSG_PROPHASH_TYPE:
254 convert_to_long_ex(&value);
255 if (Z_LVAL_P(value) != msg->type) {
256 if (HTTP_MSG_TYPE(REQUEST, msg)) {
257 if (msg->info.request.method) {
258 efree(msg->info.request.method);
259 }
260 if (msg->info.request.URI) {
261 efree(msg->info.request.URI);
262 }
263 }
264 msg->type = Z_LVAL_P(value);
265 if (HTTP_MSG_TYPE(REQUEST, msg)) {
266 msg->info.request.method = NULL;
267 msg->info.request.URI = NULL;
268 }
269 }
270
271 break;
272
273 case HTTP_MSG_PROPHASH_HTTP_VERSION:
274 convert_to_long_ex(&value);
275 switch (msg->type)
276 {
277 case HTTP_MSG_REQUEST:
278 msg->info.request.http_version = (float) Z_DVAL_P(value);
279 break;
280
281 case HTTP_MSG_RESPONSE:
282 msg->info.response.http_version = (float) Z_DVAL_P(value);
283 break;
284 }
285 break;
286
287 case HTTP_MSG_PROPHASH_BODY:
288 convert_to_string_ex(&value);
289 phpstr_dtor(PHPSTR(msg));
290 phpstr_from_string_ex(PHPSTR(msg), Z_STRVAL_P(value), Z_STRLEN_P(value));
291 break;
292
293 case HTTP_MSG_PROPHASH_HEADERS:
294 convert_to_array_ex(&value);
295 zend_hash_clean(&msg->hdrs);
296 zend_hash_copy(&msg->hdrs, Z_ARRVAL_P(value), (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
297 break;
298
299 case HTTP_MSG_PROPHASH_PARENT_MESSAGE:
300 if (msg->parent) {
301 zval tmp;
302 tmp.value.obj = obj->parent;
303 zend_objects_store_del_ref(&tmp TSRMLS_CC);
304 }
305 zend_objects_store_add_ref(value TSRMLS_CC);
306 obj->parent = value->value.obj;
307 break;
308
309 case HTTP_MSG_PROPHASH_REQUEST_METHOD:
310 convert_to_string_ex(&value);
311 if (HTTP_MSG_TYPE(REQUEST, msg)) {
312 if (msg->info.request.method) {
313 efree(msg->info.request.method);
314 }
315 msg->info.request.method = estrndup(Z_STRVAL_P(value), Z_STRLEN_P(value));
316 }
317 break;
318
319 case HTTP_MSG_PROPHASH_REQUEST_URI:
320 convert_to_string_ex(&value);
321 if (HTTP_MSG_TYPE(REQUEST, msg)) {
322 if (msg->info.request.URI) {
323 efree(msg->info.request.URI);
324 }
325 msg->info.request.URI = estrndup(Z_STRVAL_P(value), Z_STRLEN_P(value));
326 }
327 break;
328
329 case HTTP_MSG_PROPHASH_RESPONSE_CODE:
330 convert_to_long_ex(&value);
331 if (HTTP_MSG_TYPE(RESPONSE, msg)) {
332 msg->info.response.code = Z_LVAL_P(value);
333 }
334 break;
335 }
336 }
337
338 static HashTable *_http_message_object_get_props(zval *object TSRMLS_DC)
339 {
340 zval *headers;
341 getObjectEx(http_message_object, obj, object);
342 http_message *msg = obj->message;
343
344 #define ASSOC_PROP(obj, ptype, name, val) \
345 { \
346 zval array; \
347 char *m_prop_name; \
348 int m_prop_len; \
349 Z_ARRVAL(array) = OBJ_PROP(obj); \
350 zend_mangle_property_name(&m_prop_name, &m_prop_len, "*", 1, name, lenof(name), 1); \
351 add_assoc_ ##ptype## _ex(&array, m_prop_name, sizeof(name)+4, val); \
352 }
353 #define ASSOC_STRING(obj, name, val) ASSOC_STRINGL(obj, name, val, strlen(val))
354 #define ASSOC_STRINGL(obj, name, val, len) \
355 { \
356 zval array; \
357 char *m_prop_name; \
358 int m_prop_len; \
359 Z_ARRVAL(array) = OBJ_PROP(obj); \
360 zend_mangle_property_name(&m_prop_name, &m_prop_len, "*", 1, name, lenof(name), 1); \
361 add_assoc_stringl_ex(&array, m_prop_name, sizeof(name)+4, val, len, 1); \
362 }
363
364 zend_hash_clean(OBJ_PROP(obj));
365
366 ASSOC_PROP(obj, long, "type", msg->type);
367 ASSOC_STRINGL(obj, "body", PHPSTR_VAL(msg), PHPSTR_LEN(msg));
368
369 MAKE_STD_ZVAL(headers);
370 array_init(headers);
371
372 zend_hash_copy(Z_ARRVAL_P(headers), &msg->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
373 ASSOC_PROP(obj, zval, "headers", headers);
374
375 switch (msg->type)
376 {
377 case HTTP_MSG_REQUEST:
378 ASSOC_PROP(obj, double, "httpVersion", msg->info.request.http_version);
379 ASSOC_PROP(obj, long, "responseCode", 0);
380 ASSOC_STRING(obj, "requestMethod", msg->info.request.method);
381 ASSOC_STRING(obj, "requestUri", msg->info.request.URI);
382 break;
383
384 case HTTP_MSG_RESPONSE:
385 ASSOC_PROP(obj, double, "httpVersion", msg->info.response.http_version);
386 ASSOC_PROP(obj, long, "responseCode", msg->info.response.code);
387 ASSOC_STRING(obj, "requestMethod", "");
388 ASSOC_STRING(obj, "requestUri", "");
389 break;
390
391 case HTTP_MSG_NONE:
392 default:
393 ASSOC_PROP(obj, double, "httpVersion", 0.0);
394 ASSOC_PROP(obj, long, "responseCode", 0);
395 ASSOC_STRING(obj, "requestMethod", "");
396 ASSOC_STRING(obj, "requestUri", "");
397 break;
398 }
399
400 return OBJ_PROP(obj);
401 }
402
403 #endif /* ZEND_ENGINE_2 */
404
405 /*
406 * Local variables:
407 * tab-width: 4
408 * c-basic-offset: 4
409 * End:
410 * vim600: noet sw=4 ts=4 fdm=marker
411 * vim<600: noet sw=4 ts=4
412 */
413
Extended HTTP Support