projects / m6w6 / ext-http / blob
? search:
summary | shortlog | log | commit | commitdiff | tree | github
history | raw | HEAD
fixup http\Message\Body::add() for files where data isset
[m6w6/ext-http] / php_http_message_body.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-2011, Michael Wallner <mike@php.net> |
10 +--------------------------------------------------------------------+
11 */
12
13 #include "php_http_api.h"
14
15 #include <ext/standard/php_lcg.h>
16
17 #define BOUNDARY_OPEN(body) \
18 do {\
19 size_t size = php_http_message_body_size(body); \
20 if (size) { \
21 php_stream_truncate_set_size(php_http_message_body_stream(body), size - lenof("--" PHP_HTTP_CRLF)); \
22 php_http_message_body_append(body, ZEND_STRL(PHP_HTTP_CRLF)); \
23 } else { \
24 php_http_message_body_appendf(body, "--%s" PHP_HTTP_CRLF, php_http_message_body_boundary(body)); \
25 } \
26 } while(0)
27 #define BOUNDARY_CLOSE(body) \
28 php_http_message_body_appendf(body, PHP_HTTP_CRLF "--%s--" PHP_HTTP_CRLF, php_http_message_body_boundary(body))
29
30 static STATUS add_recursive_fields(php_http_message_body_t *body, const char *name, zval *value);
31 static STATUS add_recursive_files(php_http_message_body_t *body, const char *name, zval *value);
32
33 PHP_HTTP_API php_http_message_body_t *php_http_message_body_init(php_http_message_body_t *body, php_stream *stream TSRMLS_DC)
34 {
35 if (!body) {
36 body = emalloc(sizeof(php_http_message_body_t));
37 }
38 memset(body, 0, sizeof(*body));
39
40 if (stream) {
41 php_stream_auto_cleanup(stream);
42 body->stream_id = php_stream_get_resource_id(stream);
43 zend_list_addref(body->stream_id);
44 } else {
45 stream = php_stream_temp_create(TEMP_STREAM_DEFAULT, 0xffff);
46 php_stream_auto_cleanup(stream);
47 body->stream_id = php_stream_get_resource_id(stream);
48 }
49 TSRMLS_SET_CTX(body->ts);
50
51 return body;
52 }
53
54 PHP_HTTP_API php_http_message_body_t *php_http_message_body_copy(php_http_message_body_t *from, php_http_message_body_t *to, zend_bool dup_internal_stream_and_contents)
55 {
56 if (!from) {
57 return NULL;
58 } else {
59 TSRMLS_FETCH_FROM_CTX(from->ts);
60
61 if (dup_internal_stream_and_contents) {
62 to = php_http_message_body_init(to, NULL TSRMLS_CC);
63 php_http_message_body_to_stream(from, php_http_message_body_stream(to), 0, 0);
64 } else {
65 to = php_http_message_body_init(to, php_http_message_body_stream(from) TSRMLS_CC);
66 }
67
68 if (from->boundary) {
69 to->boundary = estrdup(from->boundary);
70 }
71
72 return to;
73 }
74 }
75
76 PHP_HTTP_API void php_http_message_body_dtor(php_http_message_body_t *body)
77 {
78 TSRMLS_FETCH_FROM_CTX(body->ts);
79 /* NO FIXME: shows leakinfo in DEBUG mode */
80 zend_list_delete(body->stream_id);
81 STR_FREE(body->boundary);
82 }
83
84 PHP_HTTP_API void php_http_message_body_free(php_http_message_body_t **body)
85 {
86 if (*body) {
87 php_http_message_body_dtor(*body);
88 efree(*body);
89 *body = NULL;
90 }
91 }
92
93 PHP_HTTP_API const php_stream_statbuf *php_http_message_body_stat(php_http_message_body_t *body)
94 {
95 TSRMLS_FETCH_FROM_CTX(body->ts);
96 php_stream_stat(php_http_message_body_stream(body), &body->ssb);
97 return &body->ssb;
98 }
99
100 PHP_HTTP_API const char *php_http_message_body_boundary(php_http_message_body_t *body)
101 {
102 if (!body->boundary) {
103 union { double dbl; int num[2]; } data;
104 TSRMLS_FETCH_FROM_CTX(body->ts);
105
106 data.dbl = php_combined_lcg(TSRMLS_C);
107 spprintf(&body->boundary, 0, "%x.%x", data.num[0], data.num[1]);
108 }
109 return body->boundary;
110 }
111
112 PHP_HTTP_API char *php_http_message_body_etag(php_http_message_body_t *body)
113 {
114 TSRMLS_FETCH_FROM_CTX(body->ts);
115 const php_stream_statbuf *ssb = php_http_message_body_stat(body);
116
117 /* real file or temp buffer ? */
118 if (ssb && ssb->sb.st_mtime) {
119 char *etag;
120
121 spprintf(&etag, 0, "%lx-%lx-%lx", ssb->sb.st_ino, ssb->sb.st_mtime, ssb->sb.st_size);
122 return etag;
123 } else {
124 php_http_etag_t *etag = php_http_etag_init(PHP_HTTP_G->env.etag_mode TSRMLS_CC);
125
126 php_http_message_body_to_callback(body, (php_http_pass_callback_t) php_http_etag_update, etag, 0, 0);
127 return php_http_etag_finish(etag);
128 }
129 }
130
131 PHP_HTTP_API void php_http_message_body_to_string(php_http_message_body_t *body, char **buf, size_t *len, off_t offset, size_t forlen)
132 {
133 TSRMLS_FETCH_FROM_CTX(body->ts);
134 php_stream *s = php_http_message_body_stream(body);
135
136 php_stream_seek(s, offset, SEEK_SET);
137 if (!forlen) {
138 forlen = -1;
139 }
140 *len = php_stream_copy_to_mem(s, buf, forlen, 0);
141 }
142
143 PHP_HTTP_API void php_http_message_body_to_stream(php_http_message_body_t *body, php_stream *dst, off_t offset, size_t forlen)
144 {
145 TSRMLS_FETCH_FROM_CTX(body->ts);
146 php_stream *s = php_http_message_body_stream(body);
147
148 php_stream_seek(s, offset, SEEK_SET);
149 if (!forlen) {
150 forlen = -1;
151 }
152 php_stream_copy_to_stream_ex(s, dst, forlen, NULL);
153 }
154
155 PHP_HTTP_API void php_http_message_body_to_callback(php_http_message_body_t *body, php_http_pass_callback_t cb, void *cb_arg, off_t offset, size_t forlen)
156 {
157 TSRMLS_FETCH_FROM_CTX(body->ts);
158 php_stream *s = php_http_message_body_stream(body);
159 char *buf = emalloc(0x1000);
160
161 php_stream_seek(s, offset, SEEK_SET);
162
163 if (!forlen) {
164 forlen = -1;
165 }
166 while (!php_stream_eof(s)) {
167 size_t read = php_stream_read(s, buf, MIN(forlen, 0x1000));
168
169 if (read) {
170 cb(cb_arg, buf, read);
171 }
172
173 if (read < MIN(forlen, sizeof(buf))) {
174 break;
175 }
176
177 if (forlen && !(forlen -= read)) {
178 break;
179 }
180 }
181 efree(buf);
182 }
183
184 PHP_HTTP_API size_t php_http_message_body_append(php_http_message_body_t *body, const char *buf, size_t len)
185 {
186 php_stream *s;
187 TSRMLS_FETCH_FROM_CTX(body->ts);
188
189 s = php_http_message_body_stream(body);
190 php_stream_seek(s, 0, SEEK_END);
191 return php_stream_write(s, buf, len);
192 }
193
194 PHP_HTTP_API size_t php_http_message_body_appendf(php_http_message_body_t *body, const char *fmt, ...)
195 {
196 va_list argv;
197 char *print_str;
198 size_t print_len;
199
200 va_start(argv, fmt);
201 print_len = vspprintf(&print_str, 0, fmt, argv);
202 va_end(argv);
203
204 print_len = php_http_message_body_append(body, print_str, print_len);
205 efree(print_str);
206
207 return print_len;
208 }
209
210 PHP_HTTP_API STATUS php_http_message_body_add(php_http_message_body_t *body, HashTable *fields, HashTable *files)
211 {
212 zval tmp;
213
214 if (fields) {
215 INIT_PZVAL_ARRAY(&tmp, fields);
216 if (SUCCESS != add_recursive_fields(body, NULL, &tmp)) {
217 return FAILURE;
218 }
219 }
220 if (files) {
221 INIT_PZVAL_ARRAY(&tmp, files);
222 if (SUCCESS != add_recursive_files(body, NULL, &tmp)) {
223 return FAILURE;
224 }
225 }
226
227 return SUCCESS;
228 }
229
230
231 PHP_HTTP_API STATUS php_http_message_body_add_field(php_http_message_body_t *body, const char *name, const char *value_str, size_t value_len)
232 {
233 char *safe_name;
234 TSRMLS_FETCH_FROM_CTX(body->ts);
235
236 safe_name = php_addslashes(estrdup(name), strlen(name), NULL, 1 TSRMLS_CC);
237
238 BOUNDARY_OPEN(body);
239 php_http_message_body_appendf(
240 body,
241 "Content-Disposition: form-data; name=\"%s\"" PHP_HTTP_CRLF
242 "" PHP_HTTP_CRLF,
243 safe_name
244 );
245 php_http_message_body_append(body, value_str, value_len);
246 BOUNDARY_CLOSE(body);
247
248 efree(safe_name);
249 return SUCCESS;
250 }
251
252 PHP_HTTP_API STATUS php_http_message_body_add_file(php_http_message_body_t *body, const char *name, const char *ctype, const char *path, php_stream *in)
253 {
254 php_stream_statbuf ssb = {{0}};
255 php_stream_filter *tef = NULL;
256 char *safe_name, *path_dup = estrdup(path);
257 TSRMLS_FETCH_FROM_CTX(body->ts);
258
259 safe_name = php_addslashes(estrdup(name), strlen(name), NULL, 1 TSRMLS_CC);
260
261 BOUNDARY_OPEN(body);
262 php_http_message_body_appendf(
263 body,
264 "Content-Disposition: attachment; name=\"%s\"; filename=\"%s\"" PHP_HTTP_CRLF
265 "Content-Type: %s" PHP_HTTP_CRLF,
266 safe_name, basename(path_dup), ctype
267 );
268
269 if (SUCCESS == php_stream_stat(in, &ssb)) {
270 php_http_message_body_appendf(
271 body,
272 "Content-Length: %zu" PHP_HTTP_CRLF
273 "" PHP_HTTP_CRLF,
274 ssb.sb.st_size
275 );
276 } else {
277 php_http_message_body_append(
278 body,
279 ZEND_STRL(
280 "Transfer-Encoding: chunked" PHP_HTTP_CRLF
281 "" PHP_HTTP_CRLF
282 )
283 );
284
285 if ((tef = php_http_filter_factory.create_filter("http.chunked_encode", NULL, 0 TSRMLS_CC))) {
286 php_stream_filter_append(&in->readfilters, tef);
287 }
288 }
289
290 php_stream_copy_to_stream_ex(in, php_http_message_body_stream(body), PHP_STREAM_COPY_ALL, NULL);
291 BOUNDARY_CLOSE(body);
292
293 if (tef) {
294 php_stream_filter_remove(tef, 1 TSRMLS_CC);
295 }
296
297 efree(safe_name);
298 efree(path_dup);
299
300 return SUCCESS;
301 }
302
303 static inline char *format_key(uint type, char *str, ulong num, const char *prefix) {
304 char *new_key = NULL;
305
306 if (prefix && *prefix) {
307 if (type == HASH_KEY_IS_STRING) {
308 spprintf(&new_key, 0, "%s[%s]", prefix, str);
309 } else {
310 spprintf(&new_key, 0, "%s[%lu]", prefix, num);
311 }
312 } else if (type == HASH_KEY_IS_STRING) {
313 new_key = estrdup(str);
314 } else {
315 estrdup("");
316 }
317
318 return new_key;
319 }
320
321 static STATUS add_recursive_fields(php_http_message_body_t *body, const char *name, zval *value)
322 {
323 if (Z_TYPE_P(value) == IS_ARRAY || Z_TYPE_P(value) == IS_OBJECT) {
324 zval **val;
325 HashTable *ht;
326 HashPosition pos;
327 php_http_array_hashkey_t key = php_http_array_hashkey_init(0);
328 TSRMLS_FETCH_FROM_CTX(body->ts);
329
330 ht = HASH_OF(value);
331 if (!ht->nApplyCount) {
332 ++ht->nApplyCount;
333 FOREACH_KEYVAL(pos, value, key, val) {
334 char *str = format_key(key.type, key.str, key.num, name);
335 if (SUCCESS != add_recursive_fields(body, str, *val)) {
336 efree(str);
337 ht->nApplyCount--;
338 return FAILURE;
339 }
340 efree(str);
341 }
342 --ht->nApplyCount;
343 }
344 } else {
345 zval *cpy = php_http_ztyp(IS_STRING, value);
346 php_http_message_body_add_field(body, name, Z_STRVAL_P(cpy), Z_STRLEN_P(cpy));
347 zval_ptr_dtor(&cpy);
348 }
349
350 return SUCCESS;
351 }
352
353 static STATUS add_recursive_files(php_http_message_body_t *body, const char *name, zval *value)
354 {
355 zval **zdata = NULL, **zfile, **zname, **ztype;
356 HashTable *ht;
357 TSRMLS_FETCH_FROM_CTX(body->ts);
358
359 if (Z_TYPE_P(value) != IS_ARRAY && Z_TYPE_P(value) != IS_OBJECT) {
360 php_http_error(HE_WARNING, PHP_HTTP_E_MESSAGE_BODY, "Expected array or object (name, type, file) for message body file to add");
361 return FAILURE;
362 }
363
364 ht = HASH_OF(value);
365
366 if ((SUCCESS != zend_hash_find(ht, ZEND_STRS("name"), (void *) &zname))
367 || (SUCCESS != zend_hash_find(ht, ZEND_STRS("type"), (void *) &ztype))
368 || (SUCCESS != zend_hash_find(ht, ZEND_STRS("file"), (void *) &zfile))
369 ) {
370 zval **val;
371 HashPosition pos;
372 php_http_array_hashkey_t key = php_http_array_hashkey_init(0);
373
374 if (!ht->nApplyCount) {
375 ++ht->nApplyCount;
376 FOREACH_HASH_KEYVAL(pos, ht, key, val) {
377 if (Z_TYPE_PP(val) == IS_ARRAY || Z_TYPE_PP(val) == IS_OBJECT) {
378 char *str = format_key(key.type, key.str, key.num, name);
379
380 if (SUCCESS != add_recursive_files(body, str, *val)) {
381 efree(str);
382 --ht->nApplyCount;
383 return FAILURE;
384 }
385 efree(str);
386 }
387 }
388 --ht->nApplyCount;
389 }
390 return SUCCESS;
391 } else {
392 php_stream *stream;
393 zval *zfc = php_http_ztyp(IS_STRING, *zfile);
394
395 if (SUCCESS == zend_hash_find(ht, ZEND_STRS("data"), (void *) &zdata)) {
396 if (Z_TYPE_PP(zdata) == IS_RESOURCE) {
397 php_stream_from_zval_no_verify(stream, zdata);
398 } else {
399 zval *tmp = php_http_ztyp(IS_STRING, *zdata);
400
401 stream = php_stream_memory_open(TEMP_STREAM_READONLY, Z_STRVAL_P(tmp), Z_STRLEN_P(tmp));
402 zval_ptr_dtor(&tmp);
403 }
404 } else {
405 stream = php_stream_open_wrapper(Z_STRVAL_P(zfc), "r", REPORT_ERRORS|USE_PATH, NULL);
406 }
407
408 if (!stream) {
409 zval_ptr_dtor(&zfc);
410 return FAILURE;
411 } else {
412 zval *znc = php_http_ztyp(IS_STRING, *zname), *ztc = php_http_ztyp(IS_STRING, *ztype);
413 char *key = format_key(HASH_KEY_IS_STRING, Z_STRVAL_P(znc), 0, name);
414 STATUS ret = php_http_message_body_add_file(body, key, Z_STRVAL_P(ztc), Z_STRVAL_P(zfc), stream);
415
416 efree(key);
417 zval_ptr_dtor(&znc);
418 zval_ptr_dtor(&ztc);
419 zval_ptr_dtor(&zfc);
420 if (!zdata || Z_TYPE_PP(zdata) != IS_RESOURCE) {
421 php_stream_close(stream);
422 }
423 return ret;
424 }
425
426 }
427 }
428
429 /* PHP */
430
431 #define PHP_HTTP_BEGIN_ARGS(method, req_args) PHP_HTTP_BEGIN_ARGS_EX(HttpMessageBody, method, 0, req_args)
432 #define PHP_HTTP_EMPTY_ARGS(method) PHP_HTTP_EMPTY_ARGS_EX(HttpMessageBody, method, 0)
433 #define PHP_HTTP_MESSAGE_BODY_ME(method, visibility) PHP_ME(HttpMessageBody, method, PHP_HTTP_ARGS(HttpMessageBody, method), visibility)
434
435 PHP_HTTP_BEGIN_ARGS(__construct, 0)
436 PHP_HTTP_ARG_VAL(stream, 0)
437 PHP_HTTP_END_ARGS;
438
439 PHP_HTTP_EMPTY_ARGS(__toString);
440
441 PHP_HTTP_BEGIN_ARGS(toStream, 1)
442 PHP_HTTP_ARG_VAL(stream, 0)
443 PHP_HTTP_END_ARGS;
444
445 PHP_HTTP_BEGIN_ARGS(toCallback, 1)
446 PHP_HTTP_ARG_VAL(callback, 0)
447 PHP_HTTP_END_ARGS;
448
449 PHP_HTTP_BEGIN_ARGS(append, 1)
450 PHP_HTTP_ARG_VAL(string, 0)
451 PHP_HTTP_END_ARGS;
452
453 PHP_HTTP_BEGIN_ARGS(add, 0)
454 PHP_HTTP_ARG_ARR(fields, 1, 0)
455 PHP_HTTP_ARG_ARR(files, 1, 0)
456 PHP_HTTP_END_ARGS;
457
458 PHP_HTTP_EMPTY_ARGS(etag);
459
460 PHP_HTTP_BEGIN_ARGS(stat, 0)
461 PHP_HTTP_ARG_VAL(what, 0)
462 PHP_HTTP_END_ARGS;
463
464 zend_class_entry *php_http_message_body_class_entry;
465 zend_function_entry php_http_message_body_method_entry[] = {
466 PHP_HTTP_MESSAGE_BODY_ME(__construct, ZEND_ACC_PUBLIC|ZEND_ACC_CTOR)
467 PHP_HTTP_MESSAGE_BODY_ME(__toString, ZEND_ACC_PUBLIC)
468 PHP_MALIAS(HttpMessageBody, toString, __toString, args_for_HttpMessageBody___toString, ZEND_ACC_PUBLIC)
469 PHP_HTTP_MESSAGE_BODY_ME(toStream, ZEND_ACC_PUBLIC)
470 PHP_HTTP_MESSAGE_BODY_ME(toCallback, ZEND_ACC_PUBLIC)
471 PHP_HTTP_MESSAGE_BODY_ME(append, ZEND_ACC_PUBLIC)
472 PHP_HTTP_MESSAGE_BODY_ME(add, ZEND_ACC_PUBLIC)
473 PHP_HTTP_MESSAGE_BODY_ME(etag, ZEND_ACC_PUBLIC)
474 PHP_HTTP_MESSAGE_BODY_ME(stat, ZEND_ACC_PUBLIC)
475 EMPTY_FUNCTION_ENTRY
476 };
477 static zend_object_handlers php_http_message_body_object_handlers;
478
479 PHP_MINIT_FUNCTION(http_message_body)
480 {
481 PHP_HTTP_REGISTER_CLASS(http\\Message, Body, http_message_body, php_http_object_class_entry, 0);
482 php_http_message_body_class_entry->create_object = php_http_message_body_object_new;
483 memcpy(&php_http_message_body_object_handlers, zend_get_std_object_handlers(), sizeof(zend_object_handlers));
484 php_http_message_body_object_handlers.clone_obj = php_http_message_body_object_clone;
485
486 return SUCCESS;
487 }
488
489 zend_object_value php_http_message_body_object_new(zend_class_entry *ce TSRMLS_DC)
490 {
491 return php_http_message_body_object_new_ex(ce, NULL, NULL TSRMLS_CC);
492 }
493
494 zend_object_value php_http_message_body_object_new_ex(zend_class_entry *ce, php_http_message_body_t *body, php_http_message_body_object_t **ptr TSRMLS_DC)
495 {
496 zend_object_value ov;
497 php_http_message_body_object_t *o;
498
499 o = ecalloc(1, sizeof(php_http_message_body_object_t));
500 zend_object_std_init((zend_object *) o, php_http_message_body_class_entry TSRMLS_CC);
501 object_properties_init((zend_object *) o, ce);
502
503 if (ptr) {
504 *ptr = o;
505 }
506
507 if (body) {
508 o->body = body;
509 }
510
511 ov.handle = zend_objects_store_put((zend_object *) o, NULL, php_http_message_body_object_free, NULL TSRMLS_CC);
512 ov.handlers = &php_http_message_body_object_handlers;
513
514 return ov;
515 }
516
517 zend_object_value php_http_message_body_object_clone(zval *object TSRMLS_DC)
518 {
519 zend_object_value new_ov;
520 php_http_message_body_object_t *new_obj = NULL;
521 php_http_message_body_object_t *old_obj = zend_object_store_get_object(object TSRMLS_CC);
522
523 new_ov = php_http_message_body_object_new_ex(old_obj->zo.ce, php_http_message_body_copy(old_obj->body, NULL, 1), &new_obj TSRMLS_CC);
524 zend_objects_clone_members(&new_obj->zo, new_ov, &old_obj->zo, Z_OBJ_HANDLE_P(object) TSRMLS_CC);
525
526 return new_ov;
527 }
528
529 void php_http_message_body_object_free(void *object TSRMLS_DC)
530 {
531 php_http_message_body_object_t *obj = object;
532
533 php_http_message_body_free(&obj->body);
534
535 zend_object_std_dtor((zend_object *) obj TSRMLS_CC);
536 efree(obj);
537 }
538
539 PHP_METHOD(HttpMessageBody, __construct)
540 {
541 php_http_message_body_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
542 zval *zstream = NULL;
543 php_stream *stream;
544
545 with_error_handling(EH_THROW, php_http_exception_class_entry) {
546 if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r!", &zstream)) {
547 if (zstream) {
548 php_stream_from_zval(stream, &zstream);
549
550 if (stream) {
551 if (obj->body) {
552 php_http_message_body_dtor(obj->body);
553 }
554 obj->body = php_http_message_body_init(obj->body, stream TSRMLS_CC);
555 }
556 }
557 if (!obj->body) {
558 obj->body = php_http_message_body_init(NULL, NULL TSRMLS_CC);
559 }
560 }
561 } end_error_handling();
562 }
563
564 PHP_METHOD(HttpMessageBody, __toString)
565 {
566 if (SUCCESS == zend_parse_parameters_none()) {
567 php_http_message_body_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
568 char *str;
569 size_t len;
570
571 php_http_message_body_to_string(obj->body, &str, &len, 0, 0);
572 if (str) {
573 RETURN_STRINGL(str, len, 0);
574 }
575 }
576 RETURN_EMPTY_STRING();
577 }
578
579 PHP_METHOD(HttpMessageBody, toStream)
580 {
581 zval *zstream;
582 long offset = 0, forlen = 0;
583
584 if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|ll", &zstream, &offset, &forlen)) {
585 php_stream *stream;
586 php_http_message_body_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
587
588 php_stream_from_zval(stream, &zstream);
589 php_http_message_body_to_stream(obj->body, stream, offset, forlen);
590 RETURN_TRUE;
591 }
592 RETURN_FALSE;
593 }
594
595 struct fcd {
596 zval *fcz;
597 zend_fcall_info fci;
598 zend_fcall_info_cache fcc;
599 #ifdef ZTS
600 void ***ts;
601 #endif
602 };
603
604 static size_t pass(void *cb_arg, const char *str, size_t len)
605 {
606 struct fcd *fcd = cb_arg;
607 zval *zdata;
608 TSRMLS_FETCH_FROM_CTX(fcd->ts);
609
610 MAKE_STD_ZVAL(zdata);
611 ZVAL_STRINGL(zdata, str, len, 1);
612 if (SUCCESS == zend_fcall_info_argn(&fcd->fci TSRMLS_CC, 2, &fcd->fcz, &zdata)) {
613 zend_fcall_info_call(&fcd->fci, &fcd->fcc, NULL, NULL TSRMLS_CC);
614 zend_fcall_info_args_clear(&fcd->fci, 0);
615 }
616 zval_ptr_dtor(&zdata);
617 return len;
618 }
619
620 PHP_METHOD(HttpMessageBody, toCallback)
621 {
622 struct fcd fcd = {0};
623 long offset = 0, forlen = 0;
624
625 if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "f|ll", &fcd.fci, &fcd.fcc, &offset, &forlen)) {
626 php_http_message_body_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
627
628 fcd.fcz = getThis();
629 Z_ADDREF_P(fcd.fcz);
630 TSRMLS_SET_CTX(fcd.ts);
631
632 php_http_message_body_to_callback(obj->body, pass, &fcd, offset, forlen);
633 zend_fcall_info_args_clear(&fcd.fci, 1);
634
635 zval_ptr_dtor(&fcd.fcz);
636 RETURN_TRUE;
637 }
638 RETURN_FALSE;
639 }
640
641 PHP_METHOD(HttpMessageBody, append)
642 {
643 char *str;
644 int len;
645
646 if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &str, &len)) {
647 php_http_message_body_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
648
649 RETURN_LONG(php_http_message_body_append(obj->body, str, len));
650 }
651 RETURN_FALSE;
652 }
653
654 PHP_METHOD(HttpMessageBody, add)
655 {
656 HashTable *fields = NULL, *files = NULL;
657
658 if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|h!h!", &fields, &files)) {
659 php_http_message_body_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
660
661 RETURN_SUCCESS(php_http_message_body_add(obj->body, fields, files));
662 }
663 RETURN_FALSE;
664 }
665
666 PHP_METHOD(HttpMessageBody, etag)
667 {
668 if (SUCCESS == zend_parse_parameters_none()) {
669 php_http_message_body_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
670 char *etag = php_http_message_body_etag(obj->body);
671
672 if (etag) {
673 RETURN_STRING(etag, 0);
674 }
675 }
676 RETURN_FALSE;
677 }
678
679 PHP_METHOD(HttpMessageBody, stat)
680 {
681 char *field_str = NULL;
682 int field_len = 0;
683
684 if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s", &field_str, &field_len)) {
685 php_http_message_body_object_t *obj = zend_object_store_get_object(getThis() TSRMLS_CC);
686 const php_stream_statbuf *sb = php_http_message_body_stat(obj->body);
687
688 if (sb) {
689 if (field_str && field_len) {
690 switch (*field_str) {
691 case 's':
692 case 'S':
693 RETURN_LONG(sb->sb.st_size);
694 break;
695 case 'a':
696 case 'A':
697 RETURN_LONG(sb->sb.st_atime);
698 break;
699 case 'm':
700 case 'M':
701 RETURN_LONG(sb->sb.st_mtime);
702 break;
703 case 'c':
704 case 'C':
705 RETURN_LONG(sb->sb.st_ctime);
706 break;
707 default:
708 php_http_error(HE_WARNING, PHP_HTTP_E_MESSAGE_BODY, "unknown stat field: '%s' (should be one of [s]ize, [a]time, [m]time or [c]time)", field_str);
709 break;
710 }
711 } else {
712 array_init(return_value);
713 add_assoc_long_ex(return_value, ZEND_STRS("size"), sb->sb.st_size);
714 add_assoc_long_ex(return_value, ZEND_STRS("atime"), sb->sb.st_atime);
715 add_assoc_long_ex(return_value, ZEND_STRS("mtime"), sb->sb.st_mtime);
716 add_assoc_long_ex(return_value, ZEND_STRS("ctime"), sb->sb.st_ctime);
717 return;
718 }
719 }
720 }
721 RETURN_FALSE;
722 }
723
724 /*
725 * Local variables:
726 * tab-width: 4
727 * c-basic-offset: 4
728 * End:
729 * vim600: noet sw=4 ts=4 fdm=marker
730 * vim<600: noet sw=4 ts=4
731 */
Extended HTTP Support