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 +--------------------------------------------------------------------+
13 #include "php_http_api.h"
15 #include <ext/spl/spl_observer.h>
18 * array of name => php_http_client_factory_driver_t*
20 static HashTable php_http_client_factory_drivers
;
22 PHP_HTTP_API STATUS
php_http_client_factory_add_driver(const char *name_str
, size_t name_len
, php_http_client_factory_driver_t
*driver
)
24 return zend_hash_add(&php_http_client_factory_drivers
, name_str
, name_len
+ 1, (void *) driver
, sizeof(php_http_client_factory_driver_t
), NULL
);
27 PHP_HTTP_API STATUS
php_http_client_factory_get_driver(const char *name_str
, size_t name_len
, php_http_client_factory_driver_t
*driver
)
29 php_http_client_factory_driver_t
*tmp
;
31 if (SUCCESS
== zend_hash_find(&php_http_client_factory_drivers
, name_str
, name_len
+ 1, (void *) &tmp
)) {
38 static zend_class_entry
*php_http_client_factory_find_class_entry(zval
*this_ptr
, const char *for_str
, size_t for_len TSRMLS_DC
)
40 /* stupid non-const api */
41 char *sc
= estrndup(for_str
, for_len
);
42 zval
*cn
= zend_read_property(Z_OBJCE_P(getThis()), getThis(), sc
, for_len
, 0 TSRMLS_CC
);
45 if (Z_TYPE_P(cn
) == IS_STRING
&& Z_STRLEN_P(cn
)) {
46 return zend_fetch_class(Z_STRVAL_P(cn
), Z_STRLEN_P(cn
), 0 TSRMLS_CC
);
52 #define PHP_HTTP_BEGIN_ARGS(method, req_args) PHP_HTTP_BEGIN_ARGS_EX(HttpClientFactory, method, 0, req_args)
53 #define PHP_HTTP_EMPTY_ARGS(method) PHP_HTTP_EMPTY_ARGS_EX(HttpClientFactory, method, 0)
54 #define PHP_HTTP_REQUEST_FACTORY_ME(method, visibility) PHP_ME(HttpClientFactory, method, PHP_HTTP_ARGS(HttpClientFactory, method), visibility)
55 #define PHP_HTTP_REQUEST_FACTORY_ALIAS(method, func) PHP_HTTP_STATIC_ME_ALIAS(method, func, PHP_HTTP_ARGS(HttpClientFactory, method))
56 #define PHP_HTTP_REQUEST_FACTORY_MALIAS(me, al, vis) ZEND_FENTRY(me, ZEND_MN(HttpClientFactory_##al), PHP_HTTP_ARGS(HttpClientFactory, al), vis)
58 PHP_HTTP_BEGIN_ARGS(__construct
, 0)
59 PHP_HTTP_ARG_VAL(options
, 0)
61 PHP_HTTP_BEGIN_ARGS(createClient
, 0)
62 PHP_HTTP_ARG_ARR(options
, 1, 0)
64 PHP_HTTP_BEGIN_ARGS(createPool
, 0)
65 PHP_HTTP_ARG_OBJ(http
\\Client
, client1
, 1)
66 PHP_HTTP_ARG_OBJ(http
\\Client
, client2
, 1)
67 PHP_HTTP_ARG_OBJ(http
\\Client
, clientN
, 1)
69 PHP_HTTP_BEGIN_ARGS(createDataShare
, 0)
70 PHP_HTTP_ARG_OBJ(http
\\Client
, client1
, 1)
71 PHP_HTTP_ARG_OBJ(http
\\Client
, client2
, 1)
72 PHP_HTTP_ARG_OBJ(http
\\Client
, clientN
, 1)
74 PHP_HTTP_EMPTY_ARGS(getDriver
);
75 PHP_HTTP_EMPTY_ARGS(getAvailableDrivers
);
77 static zend_class_entry
*php_http_client_factory_class_entry
;
79 zend_class_entry
*php_http_client_factory_get_class_entry(void)
81 return php_http_client_factory_class_entry
;
84 static zend_function_entry php_http_client_factory_method_entry
[] = {
85 PHP_HTTP_REQUEST_FACTORY_ME(__construct
, ZEND_ACC_PUBLIC
|ZEND_ACC_CTOR
)
86 PHP_HTTP_REQUEST_FACTORY_ME(createClient
, ZEND_ACC_PUBLIC
)
87 PHP_HTTP_REQUEST_FACTORY_ME(createPool
, ZEND_ACC_PUBLIC
)
88 PHP_HTTP_REQUEST_FACTORY_ME(createDataShare
, 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(HttpClientFactory
, __construct
)
97 with_error_handling(EH_THROW
, php_http_exception_get_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_client_factory_class_entry
, getThis(), key
.str
, key
.len
- 1, newval TSRMLS_CC
);
110 zval_ptr_dtor(&newval
);
115 } end_error_handling();
118 PHP_METHOD(HttpClientFactory
, createClient
)
120 zval
*options
= NULL
;
122 with_error_handling(EH_THROW
, php_http_exception_get_class_entry()) {
123 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "|a!", &options
)) {
124 with_error_handling(EH_THROW
, php_http_exception_get_class_entry()) {
126 zend_object_value ov
;
127 zend_class_entry
*class_entry
= NULL
;
128 php_http_client_t
*req
= NULL
;
129 php_http_client_factory_driver_t driver
;
131 zdriver
= zend_read_property(php_http_client_factory_class_entry
, getThis(), ZEND_STRL("driver"), 0 TSRMLS_CC
);
133 if ((IS_STRING
== Z_TYPE_P(zdriver
)) && (SUCCESS
== php_http_client_factory_get_driver(Z_STRVAL_P(zdriver
), Z_STRLEN_P(zdriver
), &driver
)) && driver
.client_ops
) {
134 zval
*phi
= php_http_zsep(1, IS_STRING
, zend_read_property(php_http_client_factory_class_entry
, getThis(), ZEND_STRL("persistentHandleId"), 0 TSRMLS_CC
));
135 php_http_resource_factory_t
*rf
= NULL
;
137 if (Z_STRLEN_P(phi
)) {
140 php_http_persistent_handle_factory_t
*pf
;
142 name_len
= spprintf(&name_str
, 0, "http_client.%s", Z_STRVAL_P(zdriver
));
144 if ((pf
= php_http_persistent_handle_concede(NULL
, name_str
, name_len
, Z_STRVAL_P(phi
), Z_STRLEN_P(phi
) TSRMLS_CC
))) {
145 rf
= php_http_resource_factory_init(NULL
, php_http_persistent_handle_resource_factory_ops(), pf
, (void (*)(void *)) php_http_persistent_handle_abandon
);
151 req
= php_http_client_init(NULL
, driver
.client_ops
, rf
, NULL TSRMLS_CC
);
153 if (!(class_entry
= php_http_client_factory_find_class_entry(getThis(), ZEND_STRL("clientClass") TSRMLS_CC
))) {
154 class_entry
= driver
.client_ops
->class_entry();
157 if (SUCCESS
== php_http_new(&ov
, class_entry
, driver
.client_ops
->create_object
, driver
.client_ops
->class_entry(), req
, NULL TSRMLS_CC
)) {
158 ZVAL_OBJVAL(return_value
, ov
, 0);
159 zend_call_method(&return_value
, Z_OBJCE_P(return_value
), NULL
, ZEND_STRL("__construct"), NULL
, !!options
, options
, NULL TSRMLS_CC
);
161 php_http_client_free(&req
);
167 php_http_error(HE_WARNING
, PHP_HTTP_E_REQUEST_FACTORY
, "clients are not supported by this driver");
169 } end_error_handling();
171 } end_error_handling();
174 PHP_METHOD(HttpClientFactory
, createPool
)
179 with_error_handling(EH_THROW
, php_http_exception_get_class_entry()) {
180 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "*", &argv
, &argc
)) {
181 with_error_handling(EH_THROW
, php_http_exception_get_class_entry()) {
184 zend_object_value ov
;
185 zend_class_entry
*class_entry
= NULL
;
186 php_http_client_pool_t
*pool
= NULL
;
187 php_http_client_factory_driver_t driver
;
189 zdriver
= zend_read_property(php_http_client_factory_class_entry
, getThis(), ZEND_STRL("driver"), 0 TSRMLS_CC
);
190 if ((IS_STRING
== Z_TYPE_P(zdriver
)) && (SUCCESS
== php_http_client_factory_get_driver(Z_STRVAL_P(zdriver
), Z_STRLEN_P(zdriver
), &driver
)) && driver
.client_pool_ops
) {
191 zval
*phi
= php_http_zsep(1, IS_STRING
, zend_read_property(php_http_client_factory_class_entry
, getThis(), ZEND_STRL("persistentHandleId"), 0 TSRMLS_CC
));
192 php_http_resource_factory_t
*rf
= NULL
;
194 if (Z_STRLEN_P(phi
)) {
197 php_http_persistent_handle_factory_t
*pf
;
199 name_len
= spprintf(&name_str
, 0, "http_client_pool.%s", Z_STRVAL_P(zdriver
));
201 if ((pf
= php_http_persistent_handle_concede(NULL
, name_str
, name_len
, Z_STRVAL_P(phi
), Z_STRLEN_P(phi
) TSRMLS_CC
))) {
202 rf
= php_http_resource_factory_init(NULL
, php_http_persistent_handle_resource_factory_ops(), pf
, (void (*)(void *)) php_http_persistent_handle_abandon
);
208 pool
= php_http_client_pool_init(NULL
, driver
.client_pool_ops
, rf
, NULL TSRMLS_CC
);
210 if (!(class_entry
= php_http_client_factory_find_class_entry(getThis(), ZEND_STRL("clientPoolClass") TSRMLS_CC
))) {
211 class_entry
= driver
.client_pool_ops
->class_entry();
214 if (SUCCESS
== php_http_new(&ov
, class_entry
, driver
.client_pool_ops
->create_object
, driver
.client_pool_ops
->class_entry(), pool
, NULL TSRMLS_CC
)) {
215 ZVAL_OBJVAL(return_value
, ov
, 0);
216 for (i
= 0; i
< argc
; ++i
) {
217 if (Z_TYPE_PP(argv
[i
]) == IS_OBJECT
&& instanceof_function(Z_OBJCE_PP(argv
[i
]), php_http_client_get_class_entry() TSRMLS_CC
)) {
218 php_http_client_pool_attach(pool
, *(argv
[i
]));
222 php_http_client_pool_free(&pool
);
228 php_http_error(HE_WARNING
, PHP_HTTP_E_REQUEST_FACTORY
, "pools are not supported by this driver");
230 } end_error_handling();
232 } end_error_handling();
235 PHP_METHOD(HttpClientFactory
, createDataShare
)
240 with_error_handling(EH_THROW
, php_http_exception_get_class_entry()) {
241 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "*", &argv
, &argc
)) {
242 with_error_handling(EH_THROW
, php_http_exception_get_class_entry()) {
245 zend_object_value ov
;
246 zend_class_entry
*class_entry
;
247 php_http_client_datashare_t
*share
= NULL
;
248 php_http_client_factory_driver_t driver
;
250 zdriver
= zend_read_property(php_http_client_factory_class_entry
, getThis(), ZEND_STRL("driver"), 0 TSRMLS_CC
);
251 if ((IS_STRING
== Z_TYPE_P(zdriver
)) && (SUCCESS
== php_http_client_factory_get_driver(Z_STRVAL_P(zdriver
), Z_STRLEN_P(zdriver
), &driver
)) && driver
.client_datashare_ops
) {
252 zval
*phi
= php_http_zsep(1, IS_STRING
, zend_read_property(php_http_client_factory_class_entry
, getThis(), ZEND_STRL("persistentHandleId"), 0 TSRMLS_CC
));
253 php_http_resource_factory_t
*rf
= NULL
;
255 if (Z_STRLEN_P(phi
)) {
258 php_http_persistent_handle_factory_t
*pf
;
260 name_len
= spprintf(&name_str
, 0, "http_client_datashare.%s", Z_STRVAL_P(zdriver
));
262 if ((pf
= php_http_persistent_handle_concede(NULL
, name_str
, name_len
, Z_STRVAL_P(phi
), Z_STRLEN_P(phi
) TSRMLS_CC
))) {
263 rf
= php_http_resource_factory_init(NULL
, php_http_persistent_handle_resource_factory_ops(), pf
, (void (*)(void *)) php_http_persistent_handle_abandon
);
269 share
= php_http_client_datashare_init(NULL
, driver
.client_datashare_ops
, rf
, NULL TSRMLS_CC
);
271 if (!(class_entry
= php_http_client_factory_find_class_entry(getThis(), ZEND_STRL("clientDataShareClass") TSRMLS_CC
))) {
272 class_entry
= driver
.client_datashare_ops
->class_entry();
275 if (SUCCESS
== php_http_new(&ov
, class_entry
, driver
.client_datashare_ops
->create_object
, driver
.client_datashare_ops
->class_entry(), share
, NULL TSRMLS_CC
)) {
276 ZVAL_OBJVAL(return_value
, ov
, 0);
277 for (i
= 0; i
< argc
; ++i
) {
278 if (Z_TYPE_PP(argv
[i
]) == IS_OBJECT
&& instanceof_function(Z_OBJCE_PP(argv
[i
]), php_http_client_get_class_entry() TSRMLS_CC
)) {
279 php_http_client_datashare_attach(share
, *(argv
[i
]));
283 php_http_client_datashare_free(&share
);
289 php_http_error(HE_WARNING
, PHP_HTTP_E_REQUEST_FACTORY
, "datashares are not supported by this driver");
291 } end_error_handling();
293 } end_error_handling();
296 PHP_METHOD(HttpClientFactory
, getDriver
)
298 if (SUCCESS
== zend_parse_parameters_none()) {
299 RETURN_PROP(php_http_client_factory_class_entry
, "driver");
304 PHP_METHOD(HttpClientFactory
, getAvailableDrivers
)
306 if (SUCCESS
== zend_parse_parameters_none()) {
308 php_http_array_hashkey_t key
= php_http_array_hashkey_init(0);
310 array_init(return_value
);
311 FOREACH_HASH_KEY(pos
, &php_http_client_factory_drivers
, key
) {
312 add_next_index_stringl(return_value
, key
.str
, key
.len
- 1, 1);
319 PHP_MINIT_FUNCTION(http_client_factory
)
321 zend_hash_init(&php_http_client_factory_drivers
, 0, NULL
, NULL
, 1);
323 PHP_HTTP_REGISTER_CLASS(http
\\Client
, Factory
, http_client_factory
, php_http_object_get_class_entry(), 0);
324 php_http_client_factory_class_entry
->create_object
= php_http_client_factory_new
;
326 zend_declare_property_stringl(php_http_client_factory_class_entry
, ZEND_STRL("driver"), ZEND_STRL("curl"), ZEND_ACC_PROTECTED TSRMLS_CC
);
327 zend_declare_property_null(php_http_client_factory_class_entry
, ZEND_STRL("persistentHandleId"), ZEND_ACC_PROTECTED TSRMLS_CC
);
328 zend_declare_property_null(php_http_client_factory_class_entry
, ZEND_STRL("clientClass"), ZEND_ACC_PROTECTED TSRMLS_CC
);
329 zend_declare_property_null(php_http_client_factory_class_entry
, ZEND_STRL("clientPoolClass"), ZEND_ACC_PROTECTED TSRMLS_CC
);
330 zend_declare_property_null(php_http_client_factory_class_entry
, ZEND_STRL("clientDataShareClass"), ZEND_ACC_PROTECTED TSRMLS_CC
);
335 PHP_MSHUTDOWN_FUNCTION(http_client_factory
)
337 zend_hash_destroy(&php_http_client_factory_drivers
);
348 * vim600: noet sw=4 ts=4 fdm=marker
349 * vim<600: noet sw=4 ts=4