remove php_http_request_method.[ch]; add support for CURL_LOCK_DATA_SSL_SESSION,...
[m6w6/ext-http] / php_http_misc.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 #include <zend_exceptions.h>
17
18 /* SLEEP */
19
20 PHP_HTTP_API void php_http_sleep(double s)
21 {
22 #if defined(PHP_WIN32)
23 Sleep((DWORD) PHP_HTTP_MSEC(s));
24 #elif defined(HAVE_USLEEP)
25 usleep(PHP_HTTP_USEC(s));
26 #elif defined(HAVE_NANOSLEEP)
27 struct timespec req, rem;
28
29 req.tv_sec = (time_t) s;
30 req.tv_nsec = PHP_HTTP_NSEC(s) % PHP_HTTP_NANOSEC;
31
32 while (nanosleep(&req, &rem) && (errno == EINTR) && (PHP_HTTP_NSEC(rem.tv_sec) + rem.tv_nsec) > PHP_HTTP_NSEC(PHP_HTTP_DIFFSEC))) {
33 req.tv_sec = rem.tv_sec;
34 req.tv_nsec = rem.tv_nsec;
35 }
36 #else
37 struct timeval timeout;
38
39 timeout.tv_sec = (time_t) s;
40 timeout.tv_usec = PHP_HTTP_USEC(s) % PHP_HTTP_MCROSEC;
41
42 select(0, NULL, NULL, NULL, &timeout);
43 #endif
44 }
45
46
47 /* STRING UTILITIES */
48
49 int php_http_match(const char *haystack_str, const char *needle_str, int flags)
50 {
51 int result = 0;
52
53 if (!haystack_str || !needle_str) {
54 return result;
55 }
56
57 if (flags & PHP_HTTP_MATCH_FULL) {
58 if (flags & PHP_HTTP_MATCH_CASE) {
59 result = !strcmp(haystack_str, needle_str);
60 } else {
61 result = !strcasecmp(haystack_str, needle_str);
62 }
63 } else {
64 char *found, *haystack = estrdup(haystack_str), *needle = estrdup(needle_str);
65
66 if (flags & PHP_HTTP_MATCH_CASE) {
67 found = zend_memnstr(haystack, needle, strlen(needle), haystack+strlen(haystack));
68 } else {
69 found = php_stristr(haystack, needle, strlen(haystack), strlen(needle));
70 }
71
72 if (found) {
73 if (!(flags & PHP_HTTP_MATCH_WORD)
74 || ( (found == haystack || !PHP_HTTP_IS_CTYPE(alnum, *(found - 1)))
75 && (!*(found + strlen(needle)) || !PHP_HTTP_IS_CTYPE(alnum, *(found + strlen(needle))))
76 )
77 ) {
78 result = 1;
79 }
80 }
81
82 STR_FREE(haystack);
83 STR_FREE(needle);
84 }
85
86 return result;
87 }
88
89 char *php_http_pretty_key(char *key, size_t key_len, zend_bool uctitle, zend_bool xhyphen)
90 {
91 size_t i;
92 int wasalpha;
93
94 if (key && key_len) {
95 if ((wasalpha = PHP_HTTP_IS_CTYPE(alpha, key[0]))) {
96 key[0] = (char) (uctitle ? PHP_HTTP_TO_CTYPE(upper, key[0]) : PHP_HTTP_TO_CTYPE(lower, key[0]));
97 }
98 for (i = 1; i < key_len; i++) {
99 if (PHP_HTTP_IS_CTYPE(alpha, key[i])) {
100 key[i] = (char) (((!wasalpha) && uctitle) ? PHP_HTTP_TO_CTYPE(upper, key[i]) : PHP_HTTP_TO_CTYPE(lower, key[i]));
101 wasalpha = 1;
102 } else {
103 if (xhyphen && (key[i] == '_')) {
104 key[i] = '-';
105 }
106 wasalpha = 0;
107 }
108 }
109 }
110 return key;
111 }
112
113
114 size_t php_http_boundary(char *buf, size_t buf_len TSRMLS_DC)
115 {
116 return snprintf(buf, buf_len, "%15.15F", PHP_HTTP_G->env.request.time * php_combined_lcg(TSRMLS_C));
117 }
118
119 int php_http_select_str(const char *cmp, int argc, ...)
120 {
121 va_list argv;
122 int match = -1;
123
124 if (cmp && argc > 0) {
125 int i;
126
127 va_start(argv, argc);
128 for (i = 0; i < argc; ++i) {
129 const char *test = va_arg(argv, const char *);
130
131 if (!strcasecmp(cmp, test)) {
132 match = i;
133 break;
134 }
135 }
136 va_end(argv);
137 }
138
139 return match;
140 }
141
142
143 /* ARRAYS */
144
145 int php_http_array_apply_append_func(void *pDest TSRMLS_DC, int num_args, va_list args, zend_hash_key *hash_key)
146 {
147 int flags;
148 char *key = NULL;
149 HashTable *dst;
150 zval **data = NULL, **value = (zval **) pDest;
151
152 dst = va_arg(args, HashTable *);
153 flags = va_arg(args, int);
154
155 if ((!(flags & ARRAY_JOIN_STRONLY)) || hash_key->nKeyLength) {
156 if ((flags & ARRAY_JOIN_PRETTIFY) && hash_key->nKeyLength) {
157 key = php_http_pretty_key(estrndup(hash_key->arKey, hash_key->nKeyLength - 1), hash_key->nKeyLength - 1, 1, 1);
158 zend_hash_find(dst, key, hash_key->nKeyLength, (void *) &data);
159 } else {
160 zend_hash_quick_find(dst, hash_key->arKey, hash_key->nKeyLength, hash_key->h, (void *) &data);
161 }
162
163 Z_ADDREF_P(*value);
164 if (data) {
165 if (Z_TYPE_PP(data) != IS_ARRAY) {
166 convert_to_array(*data);
167 }
168 add_next_index_zval(*data, *value);
169 } else if (key) {
170 zend_symtable_update(dst, key, hash_key->nKeyLength, value, sizeof(zval *), NULL);
171 } else {
172 zend_hash_quick_add(dst, hash_key->arKey, hash_key->nKeyLength, hash_key->h, value, sizeof(zval *), NULL);
173 }
174
175 if (key) {
176 efree(key);
177 }
178 }
179
180 return ZEND_HASH_APPLY_KEEP;
181 }
182
183 int php_http_array_apply_merge_func(void *pDest TSRMLS_DC, int num_args, va_list args, zend_hash_key *hash_key)
184 {
185 int flags;
186 char *key = NULL;
187 HashTable *dst;
188 zval **value = (zval **) pDest;
189
190 dst = va_arg(args, HashTable *);
191 flags = va_arg(args, int);
192
193 if ((!(flags & ARRAY_JOIN_STRONLY)) || hash_key->nKeyLength) {
194 Z_ADDREF_P(*value);
195 if ((flags & ARRAY_JOIN_PRETTIFY) && hash_key->nKeyLength) {
196 key = php_http_pretty_key(estrndup(hash_key->arKey, hash_key->nKeyLength - 1), hash_key->nKeyLength - 1, 1, 1);
197 zend_hash_update(dst, key, hash_key->nKeyLength, (void *) value, sizeof(zval *), NULL);
198 efree(key);
199 } else {
200 zend_hash_quick_update(dst, hash_key->arKey, hash_key->nKeyLength, hash_key->h, (void *) value, sizeof(zval *), NULL);
201 }
202 }
203
204 return ZEND_HASH_APPLY_KEEP;
205 }
206
207 /* PASS CALLBACK */
208
209 PHP_HTTP_API size_t php_http_pass_wrapper(php_http_pass_callback_arg_t *cb, const char *str, size_t len)
210 {
211 TSRMLS_FETCH();
212 return cb->cb_zts(cb->cb_arg, str, len TSRMLS_CC);
213 }
214
215 /* ERROR */
216
217 static inline int scope_error_handling(long type TSRMLS_DC)
218 {
219 if ((type == E_THROW) || (EG(error_handling) == EH_THROW)) {
220 return EH_THROW;
221 }
222
223 if (EG(This) && instanceof_function(Z_OBJCE_P(EG(This)), php_http_object_class_entry TSRMLS_CC)) {
224 return php_http_object_get_error_handling(EG(This) TSRMLS_CC);
225 }
226
227 return EH_NORMAL;
228 }
229
230 void php_http_error(long type TSRMLS_DC, long code, const char *format, ...)
231 {
232 va_list args;
233
234 va_start(args, format);
235 switch (scope_error_handling(type TSRMLS_CC)) {
236 case EH_THROW: {
237 char *message;
238 zend_class_entry *ce = php_http_exception_class_entry;
239
240 if (0&& EG(exception_class) && instanceof_function(EG(exception_class), php_http_exception_class_entry TSRMLS_CC)) {
241 ce = EG(exception_class);
242 }
243
244 vspprintf(&message, 0, format, args);
245 zend_throw_exception(ce, message, code TSRMLS_CC);
246 efree(message);
247 break;
248 }
249 case EH_NORMAL:
250 php_verror(NULL, "", type, format, args TSRMLS_CC);
251 break;
252 case EH_SUPPRESS:
253 break;
254 }
255 va_end(args);
256 }
257
258 /*
259 * Local variables:
260 * tab-width: 4
261 * c-basic-offset: 4
262 * End:
263 * vim600: noet sw=4 ts=4 fdm=marker
264 * vim<600: noet sw=4 ts=4
265 */