projects / m6w6 / ext-http / blob
? search:


2b8de8ba9b7448571fe9c31a78395c9b5308a762
[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 switch (zend_get_hash_value(Z_STRVAL_P(member), Z_STRLEN_P(member) + 1))
158 {
159 case HTTP_MSG_PROPHASH_TYPE:
160 RETVAL_LONG(msg->type);
161 break;
162
163 case HTTP_MSG_PROPHASH_HTTP_VERSION:
164 switch (msg->type)
165 {
166 case HTTP_MSG_REQUEST:
167 RETVAL_DOUBLE(msg->info.request.http_version);
168 break;
169
170 case HTTP_MSG_RESPONSE:
171 RETVAL_DOUBLE(msg->info.response.http_version);
172 break;
173
174 case HTTP_MSG_NONE:
175 default:
176 RETVAL_NULL();
177 break;
178 }
179 break;
180
181 case HTTP_MSG_PROPHASH_BODY:
182 phpstr_fix(PHPSTR(msg));
183 RETVAL_PHPSTR(PHPSTR(msg), 0, 1);
184 break;
185
186 case HTTP_MSG_PROPHASH_HEADERS:
187 array_init(return_value);
188 zend_hash_copy(Z_ARRVAL_P(return_value), &msg->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
189 break;
190
191 case HTTP_MSG_PROPHASH_PARENT_MESSAGE:
192 if (msg->parent) {
193 RETVAL_OBJVAL(obj->parent);
194 Z_TYPE_P(return_value) = IS_OBJECT;
195 return_value->value.obj = obj->parent;
196 zend_objects_store_add_ref(return_value TSRMLS_CC);
197 } else {
198 RETVAL_NULL();
199 }
200 break;
201
202 case HTTP_MSG_PROPHASH_REQUEST_METHOD:
203 if (HTTP_MSG_TYPE(REQUEST, msg) && msg->info.request.method) {
204 RETVAL_STRING(msg->info.request.method, 1);
205 } else {
206 RETVAL_NULL();
207 }
208 break;
209
210 case HTTP_MSG_PROPHASH_REQUEST_URI:
211 if (HTTP_MSG_TYPE(REQUEST, msg) && msg->info.request.URI) {
212 RETVAL_STRING(msg->info.request.URI, 1);
213 } else {
214 RETVAL_NULL();
215 }
216 break;
217
218 case HTTP_MSG_PROPHASH_RESPONSE_CODE:
219 if (HTTP_MSG_TYPE(RESPONSE, msg)) {
220 RETVAL_LONG(msg->info.response.code);
221 } else {
222 RETVAL_NULL();
223 }
224 break;
225
226 default:
227 RETVAL_NULL();
228 break;
229 }
230
231 return return_value;
232 }
233
234 static void _http_message_object_write_prop(zval *object, zval *member, zval *value TSRMLS_DC)
235 {
236 getObjectEx(http_message_object, obj, object);
237 http_message *msg = obj->message;
238
239 if (!EG(scope) || !instanceof_function(EG(scope), obj->zo.ce TSRMLS_CC)) {
240 zend_error(E_WARNING, "Cannot access protected property %s::$%s", obj->zo.ce->name, Z_STRVAL_P(member));
241 }
242
243 switch (zend_get_hash_value(Z_STRVAL_P(member), Z_STRLEN_P(member) + 1))
244 {
245 case HTTP_MSG_PROPHASH_TYPE:
246 convert_to_long_ex(&value);
247 if (Z_LVAL_P(value) != msg->type) {
248 if (HTTP_MSG_TYPE(REQUEST, msg)) {
249 if (msg->info.request.method) {
250 efree(msg->info.request.method);
251 }
252 if (msg->info.request.URI) {
253 efree(msg->info.request.URI);
254 }
255 }
256 msg->type = Z_LVAL_P(value);
257 if (HTTP_MSG_TYPE(REQUEST, msg)) {
258 msg->info.request.method = NULL;
259 msg->info.request.URI = NULL;
260 }
261 }
262
263 break;
264
265 case HTTP_MSG_PROPHASH_HTTP_VERSION:
266 convert_to_double_ex(&value);
267 switch (msg->type)
268 {
269 case HTTP_MSG_REQUEST:
270 msg->info.request.http_version = (float) Z_DVAL_P(value);
271 break;
272
273 case HTTP_MSG_RESPONSE:
274 msg->info.response.http_version = (float) Z_DVAL_P(value);
275 break;
276 }
277 break;
278
279 case HTTP_MSG_PROPHASH_BODY:
280 convert_to_string_ex(&value);
281 phpstr_dtor(PHPSTR(msg));
282 phpstr_from_string_ex(PHPSTR(msg), Z_STRVAL_P(value), Z_STRLEN_P(value));
283 break;
284
285 case HTTP_MSG_PROPHASH_HEADERS:
286 convert_to_array_ex(&value);
287 zend_hash_clean(&msg->hdrs);
288 zend_hash_copy(&msg->hdrs, Z_ARRVAL_P(value), (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
289 break;
290
291 case HTTP_MSG_PROPHASH_PARENT_MESSAGE:
292 if (msg->parent) {
293 zval tmp;
294 tmp.value.obj = obj->parent;
295 zend_objects_store_del_ref(&tmp TSRMLS_CC);
296 }
297 zend_objects_store_add_ref(value TSRMLS_CC);
298 obj->parent = value->value.obj;
299 break;
300
301 case HTTP_MSG_PROPHASH_REQUEST_METHOD:
302 convert_to_string_ex(&value);
303 if (HTTP_MSG_TYPE(REQUEST, msg)) {
304 if (msg->info.request.method) {
305 efree(msg->info.request.method);
306 }
307 msg->info.request.method = estrndup(Z_STRVAL_P(value), Z_STRLEN_P(value));
308 }
309 break;
310
311 case HTTP_MSG_PROPHASH_REQUEST_URI:
312 convert_to_string_ex(&value);
313 if (HTTP_MSG_TYPE(REQUEST, msg)) {
314 if (msg->info.request.URI) {
315 efree(msg->info.request.URI);
316 }
317 msg->info.request.URI = estrndup(Z_STRVAL_P(value), Z_STRLEN_P(value));
318 }
319 break;
320
321 case HTTP_MSG_PROPHASH_RESPONSE_CODE:
322 convert_to_long_ex(&value);
323 if (HTTP_MSG_TYPE(RESPONSE, msg)) {
324 msg->info.response.code = Z_LVAL_P(value);
325 }
326 break;
327 }
328 }
329
330 static HashTable *_http_message_object_get_props(zval *object TSRMLS_DC)
331 {
332 zval *headers;
333 getObjectEx(http_message_object, obj, object);
334 http_message *msg = obj->message;
335
336 #define ASSOC_PROP(obj, ptype, name, val) \
337 { \
338 zval array; \
339 char *m_prop_name; \
340 int m_prop_len; \
341 Z_ARRVAL(array) = OBJ_PROP(obj); \
342 zend_mangle_property_name(&m_prop_name, &m_prop_len, "*", 1, name, lenof(name), 1); \
343 add_assoc_ ##ptype## _ex(&array, m_prop_name, sizeof(name)+4, val); \
344 }
345 #define ASSOC_STRING(obj, name, val) ASSOC_STRINGL(obj, name, val, strlen(val))
346 #define ASSOC_STRINGL(obj, name, val, len) \
347 { \
348 zval array; \
349 char *m_prop_name; \
350 int m_prop_len; \
351 Z_ARRVAL(array) = OBJ_PROP(obj); \
352 zend_mangle_property_name(&m_prop_name, &m_prop_len, "*", 1, name, lenof(name), 1); \
353 add_assoc_stringl_ex(&array, m_prop_name, sizeof(name)+4, val, len, 1); \
354 }
355
356 zend_hash_clean(OBJ_PROP(obj));
357
358 ASSOC_PROP(obj, long, "type", msg->type);
359 ASSOC_STRINGL(obj, "body", PHPSTR_VAL(msg), PHPSTR_LEN(msg));
360
361 MAKE_STD_ZVAL(headers);
362 array_init(headers);
363
364 zend_hash_copy(Z_ARRVAL_P(headers), &msg->hdrs, (copy_ctor_func_t) zval_add_ref, NULL, sizeof(zval *));
365 ASSOC_PROP(obj, zval, "headers", headers);
366
367 switch (msg->type)
368 {
369 case HTTP_MSG_REQUEST:
370 ASSOC_PROP(obj, double, "httpVersion", msg->info.request.http_version);
371 ASSOC_PROP(obj, long, "responseCode", 0);
372 ASSOC_STRING(obj, "requestMethod", msg->info.request.method);
373 ASSOC_STRING(obj, "requestUri", msg->info.request.URI);
374 break;
375
376 case HTTP_MSG_RESPONSE:
377 ASSOC_PROP(obj, double, "httpVersion", msg->info.response.http_version);
378 ASSOC_PROP(obj, long, "responseCode", msg->info.response.code);
379 ASSOC_STRING(obj, "requestMethod", "");
380 ASSOC_STRING(obj, "requestUri", "");
381 break;
382
383 case HTTP_MSG_NONE:
384 default:
385 ASSOC_PROP(obj, double, "httpVersion", 0.0);
386 ASSOC_PROP(obj, long, "responseCode", 0);
387 ASSOC_STRING(obj, "requestMethod", "");
388 ASSOC_STRING(obj, "requestUri", "");
389 break;
390 }
391
392 return OBJ_PROP(obj);
393 }
394
395 #endif /* ZEND_ENGINE_2 */
396
397 /*
398 * Local variables:
399 * tab-width: 4
400 * c-basic-offset: 4
401 * End:
402 * vim600: noet sw=4 ts=4 fdm=marker
403 * vim<600: noet sw=4 ts=4
404 */
405
Extended HTTP Support