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