-PHP_HTTP_API void _http_message_parse_headers_callback(void **message, char *http_line, size_t line_length, HashTable **headers TSRMLS_DC)
-{
- http_message *old = (http_message *) *message;
- http_message *new;
-
- if (old->type || zend_hash_num_elements(&old->hdrs) || PHPSTR_LEN(old)) {
- new = http_message_new();
-
- new->nested = old;
- *message = new;
- *headers = &new->hdrs;
- } else {
- new = old;
- }
-
- // response
- if (!strncmp(http_line, "HTTP/1.", lenof("HTTP/1."))) {
- new->type = HTTP_MSG_RESPONSE;
- new->info.response.http_version = atof(http_line + lenof("HTTP/"));
- new->info.response.status = atoi(http_line + lenof("HTTP/1.1 "));
- } else
- // request
- if (!strncmp(http_line + line_length - lenof("HTTP/1.1"), "HTTP/1.", lenof("HTTP/1."))) {
- const char *method_sep_uri = strchr(http_line, ' ');
-
- new->type = HTTP_MSG_REQUEST;
- new->info.request.http_version = atof(http_line + line_length - lenof("1.1"));
- new->info.request.method = estrndup(http_line, method_sep_uri - http_line);
- new->info.request.URI = estrndup(method_sep_uri + 1, http_line + line_length - method_sep_uri - 1 - lenof(" HTTP/1.1"));
+ /* header parsing stops at (CR)LF (CR)LF */
+ if (body = http_locate_body(message)) {
+ zval *c;
+ const char *continue_at = NULL;
+
+ /* message has chunked transfer encoding */
+ if (c = http_message_header(msg, "Transfer-Encoding")) {
+ if (!strcasecmp("chunked", Z_STRVAL_P(c))) {
+ char *decoded;
+ size_t decoded_len;
+
+ /* decode and replace Transfer-Encoding with Content-Length header */
+ if (continue_at = http_chunked_decode(body, message + message_length - body, &decoded, &decoded_len)) {
+ phpstr_from_string_ex(PHPSTR(msg), decoded, decoded_len);
+ efree(decoded);
+ {
+ zval *len;
+ char *tmp;
+
+ spprintf(&tmp, 0, "%lu", (ulong) decoded_len);
+ MAKE_STD_ZVAL(len);
+ ZVAL_STRING(len, tmp, 0);
+
+ zend_hash_del(&msg->hdrs, "Transfer-Encoding", sizeof("Transfer-Encoding"));
+ zend_hash_add(&msg->hdrs, "Content-Length", sizeof("Content-Length"), (void *) &len, sizeof(zval *), NULL);
+ }
+ }
+ }
+ } else
+
+ /* message has content-length header */
+ if (c = http_message_header(msg, "Content-Length")) {
+ long len = atol(Z_STRVAL_P(c));
+ phpstr_from_string_ex(PHPSTR(msg), body, len);
+ continue_at = body + len;
+ } else
+
+ /* message has content-range header */
+ if (c = http_message_header(msg, "Content-Range")) {
+ ulong start = 0, end = 0;
+
+ sscanf(Z_STRVAL_P(c), "bytes=%lu-%lu", &start, &end);
+ if (end > start) {
+ phpstr_from_string_ex(PHPSTR(msg), body, (size_t) (end - start));
+ continue_at = body + (end - start);
+ }
+ } else
+
+ /* no headers that indicate content length */
+ if (HTTP_MSG_TYPE(RESPONSE, msg)) {
+ phpstr_from_string_ex(PHPSTR(msg), body, message + message_length - body);
+ } else {
+ continue_at = body;
+ }
+
+ /* check for following messages */
+ if (continue_at) {
+ while (isspace(*continue_at)) ++continue_at;
+ if (continue_at < (message + message_length)) {
+ http_message *next = NULL, *most = NULL;
+
+ /* set current message to parent of most parent following messages and return deepest */
+ if (most = next = http_message_parse(continue_at, message + message_length - continue_at)) {
+ while (most->parent) most = most->parent;
+ most->parent = msg;
+ msg = next;
+ }
+ }
+ }