2 +--------------------------------------------------------------------+
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 +--------------------------------------------------------------------+
15 #include <ext/standard/php_string.h>
16 #include <ext/spl/spl_observer.h>
17 #include <Zend/zend_interfaces.h>
20 * array of name => php_http_request_factory_driver_t*
22 static HashTable php_http_request_factory_drivers
;
24 PHP_HTTP_API STATUS
php_http_request_factory_add_driver(const char *name_str
, size_t name_len
, php_http_request_factory_driver_t
*driver
)
26 return zend_hash_add(&php_http_request_factory_drivers
, name_str
, name_len
+ 1, (void *) driver
, sizeof(php_http_request_factory_driver_t
), NULL
);
29 PHP_HTTP_API STATUS
php_http_request_factory_get_driver(const char *name_str
, size_t name_len
, php_http_request_factory_driver_t
*driver
)
31 php_http_request_factory_driver_t
*tmp
;
33 if (SUCCESS
== zend_hash_find(&php_http_request_factory_drivers
, name_str
, name_len
+ 1, (void *) &tmp
)) {
40 static zend_class_entry
*php_http_request_factory_get_class_entry(zval
*this_ptr
, const char *for_str
, size_t for_len TSRMLS_DC
)
42 /* stupid non-const api */
43 char *sc
= estrndup(for_str
, for_len
);
44 zval
*cn
= zend_read_property(Z_OBJCE_P(getThis()), getThis(), sc
, for_len
, 0 TSRMLS_CC
);
47 if (Z_TYPE_P(cn
) == IS_STRING
&& Z_STRLEN_P(cn
)) {
48 return zend_fetch_class(Z_STRVAL_P(cn
), Z_STRLEN_P(cn
), 0 TSRMLS_CC
);
54 #define PHP_HTTP_BEGIN_ARGS(method, req_args) PHP_HTTP_BEGIN_ARGS_EX(HttpRequestFactory, method, 0, req_args)
55 #define PHP_HTTP_EMPTY_ARGS(method) PHP_HTTP_EMPTY_ARGS_EX(HttpRequestFactory, method, 0)
56 #define PHP_HTTP_REQUEST_FACTORY_ME(method, visibility) PHP_ME(HttpRequestFactory, method, PHP_HTTP_ARGS(HttpRequestFactory, method), visibility)
57 #define PHP_HTTP_REQUEST_FACTORY_ALIAS(method, func) PHP_HTTP_STATIC_ME_ALIAS(method, func, PHP_HTTP_ARGS(HttpRequestFactory, method))
58 #define PHP_HTTP_REQUEST_FACTORY_MALIAS(me, al, vis) ZEND_FENTRY(me, ZEND_MN(HttpRequestFactory_##al), PHP_HTTP_ARGS(HttpRequestFactory, al), vis)
60 PHP_HTTP_BEGIN_ARGS(__construct
, 1)
61 PHP_HTTP_ARG_VAL(options
, 0)
63 PHP_HTTP_BEGIN_ARGS(createRequest
, 0)
64 PHP_HTTP_ARG_VAL(url
, 0)
65 PHP_HTTP_ARG_VAL(method
, 0)
66 PHP_HTTP_ARG_VAL(options
, 0)
68 PHP_HTTP_BEGIN_ARGS(createPool
, 0)
69 PHP_HTTP_ARG_OBJ(http
\\Request
, request1
, 1)
70 PHP_HTTP_ARG_OBJ(http
\\Request
, request2
, 1)
71 PHP_HTTP_ARG_OBJ(http
\\Request
, requestN
, 1)
73 PHP_HTTP_BEGIN_ARGS(createDataShare
, 0)
74 PHP_HTTP_ARG_OBJ(http
\\Request
, request1
, 1)
75 PHP_HTTP_ARG_OBJ(http
\\Request
, request2
, 1)
76 PHP_HTTP_ARG_OBJ(http
\\Request
, requestN
, 1)
78 PHP_HTTP_EMPTY_ARGS(getGlobalDataShareInstance
);
79 PHP_HTTP_EMPTY_ARGS(getDriver
);
80 PHP_HTTP_EMPTY_ARGS(getAvailableDrivers
);
82 zend_class_entry
*php_http_request_factory_class_entry
;
83 zend_function_entry php_http_request_factory_method_entry
[] = {
84 PHP_HTTP_REQUEST_FACTORY_ME(__construct
, ZEND_ACC_PUBLIC
|ZEND_ACC_CTOR
)
85 PHP_HTTP_REQUEST_FACTORY_ME(createRequest
, ZEND_ACC_PUBLIC
)
86 PHP_HTTP_REQUEST_FACTORY_ME(createPool
, ZEND_ACC_PUBLIC
)
87 PHP_HTTP_REQUEST_FACTORY_ME(createDataShare
, ZEND_ACC_PUBLIC
)
88 PHP_HTTP_REQUEST_FACTORY_ME(getGlobalDataShareInstance
, ZEND_ACC_PUBLIC
)
89 PHP_HTTP_REQUEST_FACTORY_ME(getDriver
, ZEND_ACC_PUBLIC
)
90 PHP_HTTP_REQUEST_FACTORY_ME(getAvailableDrivers
, ZEND_ACC_PUBLIC
|ZEND_ACC_STATIC
)
95 PHP_METHOD(HttpRequestFactory
, __construct
)
97 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
98 HashTable
*options
= NULL
;
100 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "|h", &options
)) {
104 php_http_array_hashkey_t key
= php_http_array_hashkey_init(0);
106 FOREACH_HASH_KEYVAL(pos
, options
, key
, val
) {
107 if (key
.type
== HASH_KEY_IS_STRING
) {
108 zval
*newval
= php_http_zsep(1, Z_TYPE_PP(val
), *val
);
109 zend_update_property(php_http_request_factory_class_entry
, getThis(), key
.str
, key
.len
- 1, newval TSRMLS_CC
);
110 zval_ptr_dtor(&newval
);
115 } end_error_handling();
118 PHP_METHOD(HttpRequestFactory
, createRequest
)
120 char *url_str
= NULL
;
123 zval
*options
= NULL
;
125 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
126 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "|s!la!", &url_str
, &url_len
, &meth
, &options
)) {
127 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
129 zend_object_value ov
;
130 zend_class_entry
*class_entry
= NULL
;
131 php_http_request_t
*req
= NULL
;
132 php_http_request_factory_driver_t driver
;
134 class_entry
= php_http_request_factory_get_class_entry(getThis(), ZEND_STRL("requestClass") TSRMLS_CC
);
137 class_entry
= php_http_request_class_entry
;
140 zdriver
= zend_read_property(php_http_request_factory_class_entry
, getThis(), ZEND_STRL("driver"), 0 TSRMLS_CC
);
142 if ((IS_STRING
== Z_TYPE_P(zdriver
)) && (SUCCESS
== php_http_request_factory_get_driver(Z_STRVAL_P(zdriver
), Z_STRLEN_P(zdriver
), &driver
)) && driver
.request_ops
) {
143 zval
*phi
= php_http_zsep(1, IS_STRING
, zend_read_property(php_http_request_factory_class_entry
, getThis(), ZEND_STRL("persistentHandleId"), 0 TSRMLS_CC
));
144 php_http_resource_factory_t
*rf
= NULL
;
146 if (Z_STRLEN_P(phi
)) {
149 php_http_persistent_handle_factory_t
*pf
;
151 name_len
= spprintf(&name_str
, 0, "http_request.%s", Z_STRVAL_P(zdriver
));
153 if ((pf
= php_http_persistent_handle_concede(NULL
, name_str
, name_len
, Z_STRVAL_P(phi
), Z_STRLEN_P(phi
) TSRMLS_CC
))) {
154 php_http_resource_factory_ops_t ops
= {
155 (php_http_resource_factory_handle_ctor_t
) php_http_persistent_handle_acquire
,
156 (php_http_resource_factory_handle_copy_t
) php_http_persistent_handle_accrete
,
157 (php_http_resource_factory_handle_dtor_t
) php_http_persistent_handle_release
160 rf
= php_http_resource_factory_init(NULL
, &ops
, pf
, (void (*)(void *)) php_http_persistent_handle_abandon
);
166 req
= php_http_request_init(NULL
, driver
.request_ops
, rf
, NULL TSRMLS_CC
);
168 if (SUCCESS
== php_http_new(&ov
, class_entry
, (php_http_new_t
) php_http_request_object_new_ex
, php_http_request_class_entry
, req
, NULL TSRMLS_CC
)) {
169 ZVAL_OBJVAL(return_value
, ov
, 0);
172 object_init_ex(os
, spl_ce_SplObjectStorage
);
173 zend_update_property(php_http_request_class_entry
, return_value
, ZEND_STRL("observers"), os TSRMLS_CC
);
177 zend_update_property_stringl(php_http_request_class_entry
, return_value
, ZEND_STRL("url"), url_str
, url_len TSRMLS_CC
);
180 zend_update_property_long(php_http_request_class_entry
, return_value
, ZEND_STRL("method"), meth TSRMLS_CC
);
183 zend_call_method_with_1_params(&return_value
, Z_OBJCE_P(return_value
), NULL
, "setoptions", NULL
, options
);
186 php_http_request_free(&req
);
192 php_http_error(HE_WARNING
, PHP_HTTP_E_REQUEST_FACTORY
, "requests are not supported by this driver");
194 } end_error_handling();
196 } end_error_handling();
199 PHP_METHOD(HttpRequestFactory
, createPool
)
204 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
205 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "|*", &argv
, &argc
)) {
206 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
209 zend_object_value ov
;
210 zend_class_entry
*class_entry
= NULL
;
211 php_http_request_pool_t
*pool
= NULL
;
212 php_http_request_factory_driver_t driver
;
214 if (!(class_entry
= php_http_request_factory_get_class_entry(getThis(), ZEND_STRL("requestPoolClass") TSRMLS_CC
))) {
215 class_entry
= php_http_request_pool_class_entry
;
218 zdriver
= zend_read_property(php_http_request_factory_class_entry
, getThis(), ZEND_STRL("driver"), 0 TSRMLS_CC
);
219 if ((IS_STRING
== Z_TYPE_P(zdriver
)) && (SUCCESS
== php_http_request_factory_get_driver(Z_STRVAL_P(zdriver
), Z_STRLEN_P(zdriver
), &driver
)) && driver
.request_pool_ops
) {
220 zval
*phi
= php_http_zsep(1, IS_STRING
, zend_read_property(php_http_request_factory_class_entry
, getThis(), ZEND_STRL("persistentHandleId"), 0 TSRMLS_CC
));
221 php_http_resource_factory_t
*rf
= NULL
;
223 if (Z_STRLEN_P(phi
)) {
226 php_http_persistent_handle_factory_t
*pf
;
228 name_len
= spprintf(&name_str
, 0, "http_request_pool.%s", Z_STRVAL_P(zdriver
));
230 if ((pf
= php_http_persistent_handle_concede(NULL
, name_str
, name_len
, Z_STRVAL_P(phi
), Z_STRLEN_P(phi
) TSRMLS_CC
))) {
231 php_http_resource_factory_ops_t ops
= {
232 (php_http_resource_factory_handle_ctor_t
) php_http_persistent_handle_acquire
,
233 (php_http_resource_factory_handle_copy_t
) php_http_persistent_handle_accrete
,
234 (php_http_resource_factory_handle_dtor_t
) php_http_persistent_handle_release
237 rf
= php_http_resource_factory_init(NULL
, &ops
, pf
, (void (*)(void *)) php_http_persistent_handle_abandon
);
243 pool
= php_http_request_pool_init(NULL
, driver
.request_pool_ops
, rf
, NULL TSRMLS_CC
);
245 if (SUCCESS
== php_http_new(&ov
, class_entry
, (php_http_new_t
) php_http_request_pool_object_new_ex
, php_http_request_pool_class_entry
, pool
, NULL TSRMLS_CC
)) {
246 ZVAL_OBJVAL(return_value
, ov
, 0);
247 for (i
= 0; i
< argc
; ++i
) {
248 if (Z_TYPE_PP(argv
[i
]) == IS_OBJECT
&& instanceof_function(Z_OBJCE_PP(argv
[i
]), php_http_request_class_entry TSRMLS_CC
)) {
249 php_http_request_pool_attach(pool
, *(argv
[i
]));
253 php_http_request_pool_free(&pool
);
259 php_http_error(HE_WARNING
, PHP_HTTP_E_REQUEST_FACTORY
, "pools are not supported by this driver");
261 } end_error_handling();
263 } end_error_handling();
266 PHP_METHOD(HttpRequestFactory
, createDataShare
)
271 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
272 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "|*", &argv
, &argc
)) {
273 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
276 zend_object_value ov
;
277 zend_class_entry
*class_entry
;
278 php_http_request_datashare_t
*share
= NULL
;
279 php_http_request_factory_driver_t driver
;
281 if (!(class_entry
= php_http_request_factory_get_class_entry(getThis(), ZEND_STRL("requestDataShareClass") TSRMLS_CC
))) {
282 class_entry
= php_http_request_datashare_class_entry
;
285 zdriver
= zend_read_property(php_http_request_factory_class_entry
, getThis(), ZEND_STRL("driver"), 0 TSRMLS_CC
);
286 if ((IS_STRING
== Z_TYPE_P(zdriver
)) && (SUCCESS
== php_http_request_factory_get_driver(Z_STRVAL_P(zdriver
), Z_STRLEN_P(zdriver
), &driver
)) && driver
.request_datashare_ops
) {
287 zval
*phi
= php_http_zsep(1, IS_STRING
, zend_read_property(php_http_request_factory_class_entry
, getThis(), ZEND_STRL("persistentHandleId"), 0 TSRMLS_CC
));
288 php_http_resource_factory_t
*rf
= NULL
;
290 if (Z_STRLEN_P(phi
)) {
293 php_http_persistent_handle_factory_t
*pf
;
295 name_len
= spprintf(&name_str
, 0, "http_request_datashare.%s", Z_STRVAL_P(zdriver
));
297 if ((pf
= php_http_persistent_handle_concede(NULL
, name_str
, name_len
, Z_STRVAL_P(phi
), Z_STRLEN_P(phi
) TSRMLS_CC
))) {
298 php_http_resource_factory_ops_t ops
= {
299 (php_http_resource_factory_handle_ctor_t
) php_http_persistent_handle_acquire
,
300 (php_http_resource_factory_handle_copy_t
) php_http_persistent_handle_accrete
,
301 (php_http_resource_factory_handle_dtor_t
) php_http_persistent_handle_release
304 rf
= php_http_resource_factory_init(NULL
, &ops
, pf
, (void (*)(void *)) php_http_persistent_handle_abandon
);
310 share
= php_http_request_datashare_init(NULL
, driver
.request_datashare_ops
, rf
, NULL
, 0 TSRMLS_CC
);
312 if (SUCCESS
== php_http_new(&ov
, class_entry
, (php_http_new_t
) php_http_request_datashare_object_new_ex
, php_http_request_datashare_class_entry
, share
, NULL TSRMLS_CC
)) {
313 ZVAL_OBJVAL(return_value
, ov
, 0);
314 for (i
= 0; i
< argc
; ++i
) {
315 if (Z_TYPE_PP(argv
[i
]) == IS_OBJECT
&& instanceof_function(Z_OBJCE_PP(argv
[i
]), php_http_request_class_entry TSRMLS_CC
)) {
316 php_http_request_datashare_attach(share
, *(argv
[i
]));
320 php_http_request_datashare_free(&share
);
326 php_http_error(HE_WARNING
, PHP_HTTP_E_REQUEST_FACTORY
, "datashares are not supported by this driver");
328 } end_error_handling();
330 } end_error_handling();
333 PHP_METHOD(HttpRequestFactory
, getGlobalDataShareInstance
)
335 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
336 if (SUCCESS
== zend_parse_parameters_none()) {
337 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
338 zval
*instance
= *zend_std_get_static_property(php_http_request_datashare_class_entry
, ZEND_STRL("instance"), 0, NULL TSRMLS_CC
);
340 if (Z_TYPE_P(instance
) != IS_OBJECT
) {
342 zend_object_value ov
;
343 zend_class_entry
*class_entry
;
344 php_http_request_datashare_t
*share
;
346 if (!(class_entry
= php_http_request_factory_get_class_entry(getThis(), ZEND_STRL("requestDataShareClass") TSRMLS_CC
))) {
347 class_entry
= php_http_request_datashare_class_entry
;
350 if ((zdriver
= zend_read_property(php_http_request_factory_class_entry
, getThis(), ZEND_STRL("driver"), 0 TSRMLS_CC
))
351 && (IS_STRING
== Z_TYPE_P(zdriver
))
352 && (share
= php_http_request_datashare_global_get(Z_STRVAL_P(zdriver
), Z_STRLEN_P(zdriver
) TSRMLS_CC
))
353 && (SUCCESS
== php_http_new(&ov
, class_entry
, (php_http_new_t
) php_http_request_datashare_object_new_ex
, php_http_request_datashare_class_entry
, share
, NULL TSRMLS_CC
))
355 MAKE_STD_ZVAL(instance
);
356 ZVAL_OBJVAL(instance
, ov
, 0);
357 zend_update_static_property(php_http_request_datashare_class_entry
, ZEND_STRL("instance"), instance TSRMLS_CC
);
359 if (PHP_HTTP_G
->request_datashare
.cookie
) {
360 zend_update_property_bool(php_http_request_datashare_class_entry
, instance
, ZEND_STRL("cookie"), PHP_HTTP_G
->request_datashare
.cookie TSRMLS_CC
);
362 if (PHP_HTTP_G
->request_datashare
.dns
) {
363 zend_update_property_bool(php_http_request_datashare_class_entry
, instance
, ZEND_STRL("dns"), PHP_HTTP_G
->request_datashare
.dns TSRMLS_CC
);
368 RETVAL_ZVAL(instance
, 1, 0);
369 } end_error_handling();
371 } end_error_handling();
375 PHP_METHOD(HttpRequestFactory
, getDriver
)
377 if (SUCCESS
== zend_parse_parameters_none()) {
378 RETURN_PROP(php_http_request_factory_class_entry
, "driver");
383 PHP_METHOD(HttpRequestFactory
, getAvailableDrivers
)
385 if (SUCCESS
== zend_parse_parameters_none()) {
387 php_http_array_hashkey_t key
= php_http_array_hashkey_init(0);
389 array_init(return_value
);
390 FOREACH_HASH_KEY(pos
, &php_http_request_factory_drivers
, key
) {
391 add_next_index_stringl(return_value
, key
.str
, key
.len
- 1, 1);
398 PHP_MINIT_FUNCTION(http_request_factory
)
400 zend_hash_init(&php_http_request_factory_drivers
, 0, NULL
, NULL
, 1);
402 PHP_HTTP_REGISTER_CLASS(http
\\Request
, Factory
, http_request_factory
, php_http_object_class_entry
, 0);
403 php_http_request_factory_class_entry
->create_object
= php_http_request_factory_new
;
405 zend_declare_property_stringl(php_http_request_factory_class_entry
, ZEND_STRL("driver"), ZEND_STRL("curl"), ZEND_ACC_PROTECTED TSRMLS_CC
);
406 zend_declare_property_null(php_http_request_factory_class_entry
, ZEND_STRL("persistentHandleId"), ZEND_ACC_PROTECTED TSRMLS_CC
);
407 zend_declare_property_null(php_http_request_factory_class_entry
, ZEND_STRL("requestClass"), ZEND_ACC_PROTECTED TSRMLS_CC
);
408 zend_declare_property_null(php_http_request_factory_class_entry
, ZEND_STRL("requestPoolClass"), ZEND_ACC_PROTECTED TSRMLS_CC
);
409 zend_declare_property_null(php_http_request_factory_class_entry
, ZEND_STRL("requestDataShareClass"), ZEND_ACC_PROTECTED TSRMLS_CC
);
414 PHP_MSHUTDOWN_FUNCTION(http_request_factory
)
416 zend_hash_destroy(&php_http_request_factory_drivers
);
427 * vim600: noet sw=4 ts=4 fdm=marker
428 * vim<600: noet sw=4 ts=4