2 +----------------------------------------------------------------------+
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 +----------------------------------------------------------------------+
25 # include <winsock2.h>
27 # include <curl/curl.h>
32 #include "php_http_std_defs.h"
33 #include "php_http_request_object.h"
34 #include "php_http_request_api.h"
35 #include "php_http_request_pool_api.h"
36 #include "php_http_api.h"
37 #include "php_http_url_api.h"
38 #include "php_http_message_api.h"
39 #include "php_http_message_object.h"
44 #define http_request_object_declare_default_properties() _http_request_object_declare_default_properties(TSRMLS_C)
45 static inline void _http_request_object_declare_default_properties(TSRMLS_D
);
47 zend_class_entry
*http_request_object_ce
;
48 zend_function_entry http_request_object_fe
[] = {
49 PHP_ME(HttpRequest
, __construct
, NULL
, ZEND_ACC_PUBLIC
|ZEND_ACC_CTOR
)
50 PHP_ME(HttpRequest
, __destruct
, NULL
, ZEND_ACC_PUBLIC
|ZEND_ACC_DTOR
)
52 PHP_ME(HttpRequest
, setOptions
, NULL
, ZEND_ACC_PUBLIC
)
53 PHP_ME(HttpRequest
, getOptions
, NULL
, ZEND_ACC_PUBLIC
)
54 PHP_ME(HttpRequest
, unsetOptions
, NULL
, ZEND_ACC_PUBLIC
)
55 PHP_ME(HttpRequest
, setSslOptions
, NULL
, ZEND_ACC_PUBLIC
)
56 PHP_ME(HttpRequest
, getSslOptions
, NULL
, ZEND_ACC_PUBLIC
)
57 PHP_ME(HttpRequest
, unsetSslOptions
, NULL
, ZEND_ACC_PUBLIC
)
59 PHP_ME(HttpRequest
, addHeaders
, NULL
, ZEND_ACC_PUBLIC
)
60 PHP_ME(HttpRequest
, getHeaders
, NULL
, ZEND_ACC_PUBLIC
)
61 PHP_ME(HttpRequest
, unsetHeaders
, NULL
, ZEND_ACC_PUBLIC
)
62 PHP_ME(HttpRequest
, addCookies
, NULL
, ZEND_ACC_PUBLIC
)
63 PHP_ME(HttpRequest
, getCookies
, NULL
, ZEND_ACC_PUBLIC
)
64 PHP_ME(HttpRequest
, unsetCookies
, NULL
, ZEND_ACC_PUBLIC
)
66 PHP_ME(HttpRequest
, setMethod
, NULL
, ZEND_ACC_PUBLIC
)
67 PHP_ME(HttpRequest
, getMethod
, NULL
, ZEND_ACC_PUBLIC
)
69 PHP_ME(HttpRequest
, setURL
, NULL
, ZEND_ACC_PUBLIC
)
70 PHP_ME(HttpRequest
, getURL
, NULL
, ZEND_ACC_PUBLIC
)
72 PHP_ME(HttpRequest
, setContentType
, NULL
, ZEND_ACC_PUBLIC
)
73 PHP_ME(HttpRequest
, getContentType
, NULL
, ZEND_ACC_PUBLIC
)
75 PHP_ME(HttpRequest
, setQueryData
, NULL
, ZEND_ACC_PUBLIC
)
76 PHP_ME(HttpRequest
, getQueryData
, NULL
, ZEND_ACC_PUBLIC
)
77 PHP_ME(HttpRequest
, addQueryData
, NULL
, ZEND_ACC_PUBLIC
)
78 PHP_ME(HttpRequest
, unsetQueryData
, NULL
, ZEND_ACC_PUBLIC
)
80 PHP_ME(HttpRequest
, setPostFields
, NULL
, ZEND_ACC_PUBLIC
)
81 PHP_ME(HttpRequest
, getPostFields
, NULL
, ZEND_ACC_PUBLIC
)
82 PHP_ME(HttpRequest
, addPostFields
, NULL
, ZEND_ACC_PUBLIC
)
83 PHP_ME(HttpRequest
, unsetPostFields
, NULL
, ZEND_ACC_PUBLIC
)
85 PHP_ME(HttpRequest
, setPostFiles
, NULL
, ZEND_ACC_PUBLIC
)
86 PHP_ME(HttpRequest
, addPostFile
, NULL
, ZEND_ACC_PUBLIC
)
87 PHP_ME(HttpRequest
, getPostFiles
, NULL
, ZEND_ACC_PUBLIC
)
88 PHP_ME(HttpRequest
, unsetPostFiles
, NULL
, ZEND_ACC_PUBLIC
)
90 PHP_ME(HttpRequest
, setPutFile
, NULL
, ZEND_ACC_PUBLIC
)
91 PHP_ME(HttpRequest
, getPutFile
, NULL
, ZEND_ACC_PUBLIC
)
92 PHP_ME(HttpRequest
, unsetPutFile
, NULL
, ZEND_ACC_PUBLIC
)
94 PHP_ME(HttpRequest
, send
, NULL
, ZEND_ACC_PUBLIC
)
96 PHP_ME(HttpRequest
, getResponseData
, NULL
, ZEND_ACC_PUBLIC
)
97 PHP_ME(HttpRequest
, getResponseHeader
, NULL
, ZEND_ACC_PUBLIC
)
98 PHP_ME(HttpRequest
, getResponseCookie
, NULL
, ZEND_ACC_PUBLIC
)
99 PHP_ME(HttpRequest
, getResponseCode
, NULL
, ZEND_ACC_PUBLIC
)
100 PHP_ME(HttpRequest
, getResponseBody
, NULL
, ZEND_ACC_PUBLIC
)
101 PHP_ME(HttpRequest
, getResponseInfo
, NULL
, ZEND_ACC_PUBLIC
)
102 PHP_ME(HttpRequest
, getResponseMessage
, NULL
, ZEND_ACC_PUBLIC
)
106 static zend_object_handlers http_request_object_handlers
;
108 void _http_request_object_init(INIT_FUNC_ARGS
)
110 HTTP_REGISTER_CLASS_EX(HttpRequest
, http_request_object
, NULL
, 0);
113 HTTP_LONG_CONSTANT("HTTP_GET", HTTP_GET
);
114 HTTP_LONG_CONSTANT("HTTP_HEAD", HTTP_HEAD
);
115 HTTP_LONG_CONSTANT("HTTP_POST", HTTP_POST
);
116 HTTP_LONG_CONSTANT("HTTP_PUT", HTTP_PUT
);
117 HTTP_LONG_CONSTANT("HTTP_DELETE", HTTP_DELETE
);
118 HTTP_LONG_CONSTANT("HTTP_OPTIONS", HTTP_OPTIONS
);
119 HTTP_LONG_CONSTANT("HTTP_TRACE", HTTP_TRACE
);
120 HTTP_LONG_CONSTANT("HTTP_CONNECT", HTTP_CONNECT
);
121 /* WebDAV - RFC 2518 */
122 HTTP_LONG_CONSTANT("HTTP_PROPFIND", HTTP_PROPFIND
);
123 HTTP_LONG_CONSTANT("HTTP_PROPPATCH", HTTP_PROPPATCH
);
124 HTTP_LONG_CONSTANT("HTTP_MKCOL", HTTP_MKCOL
);
125 HTTP_LONG_CONSTANT("HTTP_COPY", HTTP_COPY
);
126 HTTP_LONG_CONSTANT("HTTP_MOVE", HTTP_MOVE
);
127 HTTP_LONG_CONSTANT("HTTP_LOCK", HTTP_LOCK
);
128 HTTP_LONG_CONSTANT("HTTP_UNLOCK", HTTP_UNLOCK
);
129 /* WebDAV Versioning - RFC 3253 */
130 HTTP_LONG_CONSTANT("HTTP_VERSION_CONTROL", HTTP_VERSION_CONTROL
);
131 HTTP_LONG_CONSTANT("HTTP_REPORT", HTTP_REPORT
);
132 HTTP_LONG_CONSTANT("HTTP_CHECKOUT", HTTP_CHECKOUT
);
133 HTTP_LONG_CONSTANT("HTTP_CHECKIN", HTTP_CHECKIN
);
134 HTTP_LONG_CONSTANT("HTTP_UNCHECKOUT", HTTP_UNCHECKOUT
);
135 HTTP_LONG_CONSTANT("HTTP_MKWORKSPACE", HTTP_MKWORKSPACE
);
136 HTTP_LONG_CONSTANT("HTTP_UPDATE", HTTP_UPDATE
);
137 HTTP_LONG_CONSTANT("HTTP_LABEL", HTTP_LABEL
);
138 HTTP_LONG_CONSTANT("HTTP_MERGE", HTTP_MERGE
);
139 HTTP_LONG_CONSTANT("HTTP_BASELINE_CONTROL", HTTP_BASELINE_CONTROL
);
140 HTTP_LONG_CONSTANT("HTTP_MKACTIVITY", HTTP_MKACTIVITY
);
141 /* WebDAV Access Control - RFC 3744 */
142 HTTP_LONG_CONSTANT("HTTP_ACL", HTTP_ACL
);
145 # if LIBCURL_VERSION_NUM >= 0x070a05
146 HTTP_LONG_CONSTANT("HTTP_AUTH_BASIC", CURLAUTH_BASIC
);
147 HTTP_LONG_CONSTANT("HTTP_AUTH_DIGEST", CURLAUTH_DIGEST
);
148 HTTP_LONG_CONSTANT("HTTP_AUTH_NTLM", CURLAUTH_NTLM
);
149 # endif /* LIBCURL_VERSION_NUM */
152 zend_object_value
_http_request_object_new(zend_class_entry
*ce TSRMLS_DC
)
154 zend_object_value ov
;
155 http_request_object
*o
;
157 o
= ecalloc(1, sizeof(http_request_object
));
159 o
->ch
= curl_easy_init();
162 phpstr_init_ex(&o
->response
, HTTP_CURLBUF_SIZE
, 0);
164 ALLOC_HASHTABLE(OBJ_PROP(o
));
165 zend_hash_init(OBJ_PROP(o
), 0, NULL
, ZVAL_PTR_DTOR
, 0);
166 zend_hash_copy(OBJ_PROP(o
), &ce
->default_properties
, (copy_ctor_func_t
) zval_add_ref
, NULL
, sizeof(zval
*));
168 ov
.handle
= zend_objects_store_put(o
, (zend_objects_store_dtor_t
) zend_objects_destroy_object
, http_request_object_free
, NULL TSRMLS_CC
);
169 ov
.handlers
= &http_request_object_handlers
;
174 static inline void _http_request_object_declare_default_properties(TSRMLS_D
)
176 zend_class_entry
*ce
= http_request_object_ce
;
178 DCL_PROP_N(PROTECTED
, options
);
179 DCL_PROP_N(PROTECTED
, responseInfo
);
180 DCL_PROP_N(PROTECTED
, responseData
);
181 DCL_PROP_N(PROTECTED
, responseCode
);
182 DCL_PROP_N(PROTECTED
, responseMessage
);
183 DCL_PROP_N(PROTECTED
, postFields
);
184 DCL_PROP_N(PROTECTED
, postFiles
);
186 DCL_PROP(PROTECTED
, long, method
, HTTP_GET
);
188 DCL_PROP(PROTECTED
, string
, url
, "");
189 DCL_PROP(PROTECTED
, string
, contentType
, "");
190 DCL_PROP(PROTECTED
, string
, queryData
, "");
191 DCL_PROP(PROTECTED
, string
, putFile
, "");
194 void _http_request_object_free(zend_object
*object TSRMLS_DC
)
196 http_request_object
*o
= (http_request_object
*) object
;
199 zend_hash_destroy(OBJ_PROP(o
));
200 FREE_HASHTABLE(OBJ_PROP(o
));
203 curl_easy_cleanup(o
->ch
);
205 phpstr_dtor(&o
->response
);
209 STATUS
_http_request_object_requesthandler(http_request_object
*obj
, zval
*this_ptr
, http_request_body
*body TSRMLS_DC
)
211 zval
*meth
, *URL
, *qdata
, *opts
;
218 if ((!obj
->ch
) && (!(obj
->ch
= curl_easy_init()))) {
219 http_error(E_WARNING
, HTTP_E_CURL
, "Could not initilaize curl");
223 meth
= GET_PROP(obj
, method
);
224 URL
= GET_PROP(obj
, url
);
225 qdata
= GET_PROP(obj
, queryData
);
226 opts
= GET_PROP(obj
, options
);
228 // HTTP_URI_MAXLEN+1 long char *
229 if (!(request_uri
= http_absolute_uri_ex(Z_STRVAL_P(URL
), Z_STRLEN_P(URL
), NULL
, 0, NULL
, 0, 0))) {
233 if (Z_STRLEN_P(qdata
) && (strlen(request_uri
) < HTTP_URI_MAXLEN
)) {
234 if (!strchr(request_uri
, '?')) {
235 strcat(request_uri
, "?");
237 strcat(request_uri
, "&");
239 strncat(request_uri
, Z_STRVAL_P(qdata
), HTTP_URI_MAXLEN
- strlen(request_uri
));
242 switch (Z_LVAL_P(meth
))
247 status
= http_request_init(obj
->ch
, Z_LVAL_P(meth
), request_uri
, NULL
, Z_ARRVAL_P(opts
), &obj
->response
);
253 php_stream_statbuf ssb
;
254 zval
*file
= GET_PROP(obj
, putFile
);
256 if ( (stream
= php_stream_open_wrapper(Z_STRVAL_P(file
), "rb", REPORT_ERRORS
|ENFORCE_SAFE_MODE
, NULL
)) &&
257 !php_stream_stat(stream
, &ssb
)) {
258 body
->type
= HTTP_REQUEST_BODY_UPLOADFILE
;
260 body
->size
= ssb
.sb
.st_size
;
262 status
= http_request_init(obj
->ch
, HTTP_PUT
, request_uri
, body
, Z_ARRVAL_P(opts
), &obj
->response
);
271 zval
*fields
= GET_PROP(obj
, postFields
), *files
= GET_PROP(obj
, postFiles
);
273 if (SUCCESS
== (status
= http_request_body_fill(body
, Z_ARRVAL_P(fields
), Z_ARRVAL_P(files
)))) {
274 status
= http_request_init(obj
->ch
, HTTP_POST
, request_uri
, body
, Z_ARRVAL_P(opts
), &obj
->response
);
281 zval
*post
= GET_PROP(obj
, postData
);
283 body
->type
= HTTP_REQUEST_BODY_CSTRING
;
284 body
->data
= Z_STRVAL_P(post
);
285 body
->size
= Z_STRLEN_P(post
);
287 status
= http_request_init(obj
->ch
, Z_LVAL_P(meth
), request_uri
, body
, Z_ARRVAL_P(opts
), &obj
->response
);
296 STATUS
_http_request_object_responsehandler(http_request_object
*obj
, zval
*this_ptr TSRMLS_DC
)
300 phpstr_fix(&obj
->response
);
302 if (msg
= http_message_parse(PHPSTR_VAL(&obj
->response
), PHPSTR_LEN(&obj
->response
))) {
305 zval
*headers
, *message
, *resp
= GET_PROP(obj
, responseData
), *info
= GET_PROP(obj
, responseInfo
);
307 UPD_PROP(obj
, long, responseCode
, msg
->info
.response
.code
);
309 MAKE_STD_ZVAL(headers
)
312 zend_hash_copy(Z_ARRVAL_P(headers
), &msg
->hdrs
, (copy_ctor_func_t
) zval_add_ref
, NULL
, sizeof(zval
*));
313 phpstr_data(PHPSTR(msg
), &body
, &body_len
);
315 add_assoc_zval(resp
, "headers", headers
);
316 add_assoc_stringl(resp
, "body", body
, body_len
, 0);
318 MAKE_STD_ZVAL(message
);
319 message
->type
= IS_OBJECT
;
321 message
->value
.obj
= http_message_object_from_msg(msg
);
322 SET_PROP(obj
, responseMessage
, message
);
323 zval_ptr_dtor(&message
);
325 http_request_info(obj
->ch
, Z_ARRVAL_P(info
));
326 SET_PROP(obj
, responseInfo
, info
);
333 #endif /* HTTP_HAVE_CURL */
334 #endif /* ZEND_ENGINE_2 */
341 * vim600: noet sw=4 ts=4 fdm=marker
342 * vim<600: noet sw=4 ts=4