git.m6w6.name Git - m6w6/ext-http/blob - http_message_api.c

   1 /*
   2    +----------------------------------------------------------------------+
   3    | PECL :: http                                                         |
   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    +----------------------------------------------------------------------+
  14 */
  15
  16 /* $Id$ */
  17
  18 #ifdef HAVE_CONFIG_H
  19 #       include "config.h"
  20 #endif
  21
  22 #include "php.h"
  23 #include "php_http.h"
  24 #include "php_http_std_defs.h"
  25 #include "php_http_message_api.h"
  26 #include "php_http_headers_api.h"
  27
  28 #include "phpstr/phpstr.h"
  29
  30 PHP_HTTP_API void _http_message_dtor(http_message *message)
  31 {
  32         if (message) {
  33                 zend_hash_destroy(&message->hdrs);
  34                 phpstr_dtor(PHPSTR(message));
  35                 if (message->raw) {
  36                         efree(message->raw);
  37                 }
  38                 if (message->type == HTTP_MSG_REQUEST) {
  39                         if (message->info.request.method) {
  40                                 efree(message->info.request.method);
  41                         }
  42                         if (message->info.request.URI) {
  43                                 efree(message->info.request.URI);
  44                         }
  45                 }
  46         }
  47 }
  48
  49 PHP_HTTP_API void _http_message_free(http_message *message)
  50 {
  51         if (message) {
  52                 if (message->nested) {
  53                         http_message_free(message->nested);
  54                 }
  55                 http_message_dtor(message);
  56                 efree(message);
  57         }
  58 }
  59
  60 PHP_HTTP_API http_message *_http_message_init_ex(http_message *message, http_message_type type)
  61 {
  62         if (!message) {
  63                 message = ecalloc(1, sizeof(http_message));
  64         }
  65
  66         message->type = type;
  67         message->nested = NULL;
  68         phpstr_init(&message->body);
  69         zend_hash_init(&message->hdrs, 0, NULL, ZVAL_PTR_DTOR, 0);
  70
  71         return message;
  72 }
  73
  74 PHP_HTTP_API http_message *_http_message_parse_ex(char *message, size_t length, zend_bool dup TSRMLS_DC)
  75 {
  76         char *message_start = message, *body = NULL;
  77         size_t message_length = length, header_length = 0;
  78         http_message *msg;
  79
  80         if (length < HTTP_MSG_MIN_SIZE) {
  81                 return NULL;
  82         }
  83         if (!message) {
  84                 return NULL;
  85         }
  86
  87         if (!(message_start = strstr(message, HTTP_CRLF))) {
  88                 return NULL;
  89         }
  90
  91         msg = http_message_init();
  92
  93         msg->len = length;
  94         msg->raw = dup ? estrndup(message, length) : message;
  95
  96         // response
  97         if (!strncmp(message, "HTTP/1.", lenof("HTTP/1."))) {
  98                 msg->type = HTTP_MSG_RESPONSE;
  99                 msg->info.response.http_version = atof(message + lenof("HTTP/"));
 100                 msg->info.response.status = atoi(message + lenof("HTTP/1.1 "));
 101         } else
 102         // request
 103         if (!strncmp(message_start - lenof("HTTP/1.1"), "HTTP/1.", lenof("HTTP/1."))) {
 104                 const char *method_sep_uri = strchr(message, ' ');
 105
 106                 msg->type = HTTP_MSG_REQUEST;
 107                 msg->info.request.http_version = atof(message_start - lenof("1.1"));
 108                 msg->info.request.method = estrndup(message, method_sep_uri - message);
 109                 msg->info.request.URI = estrndup(method_sep_uri + 1, message_start - method_sep_uri - 1 - lenof(" HTTP/1.1"));
 110         } else {
 111                 http_message_free(msg);
 112                 return NULL;
 113         }
 114
 115         message_start += lenof(HTTP_CRLF);
 116         message_length -= message_start - message;
 117
 118         if (body = strstr(message_start, HTTP_CRLF HTTP_CRLF)) {
 119                 body += lenof(HTTP_CRLF HTTP_CRLF);
 120                 header_length = body - message_start;
 121                 phpstr_from_string_ex(PHPSTR(msg), body, message_length - header_length);
 122         } else {
 123                 header_length = message_length;
 124         }
 125
 126         if (SUCCESS != http_parse_headers_ex(message_start, header_length, &msg->hdrs, 1)) {
 127                 http_message_free(msg);
 128                 return NULL;
 129         }
 130         return msg;
 131 }
 132
 133 PHP_HTTP_API void _http_message_tostring(http_message *msg, char **string, size_t *length)
 134 {
 135         phpstr str;
 136         char *key, *data;
 137         ulong idx;
 138         zval **header;
 139
 140         phpstr_init_ex(&str, msg->len, 1);
 141
 142         switch (msg->type)
 143         {
 144                 case HTTP_MSG_REQUEST:
 145                         phpstr_appendf(&str, "%s %s HTTP/%1.1f" HTTP_CRLF,
 146                                 msg->info.request.method,
 147                                 msg->info.request.URI,
 148                                 msg->info.request.http_version);
 149                 break;
 150
 151                 case HTTP_MSG_RESPONSE:
 152                         phpstr_appendf(&str, "HTTP/%1.1f %d" HTTP_CRLF,
 153                                 msg->info.response.http_version,
 154                                 msg->info.response.status);
 155                 break;
 156         }
 157
 158         FOREACH_HASH_KEYVAL(&msg->hdrs, key, idx, header) {
 159                 if (key) {
 160                         phpstr_appendf(&str, "%s: %s" HTTP_CRLF, key, Z_STRVAL_PP(header));
 161                         key = NULL;
 162                 }
 163         }
 164
 165         phpstr_appends(&str, HTTP_CRLF);
 166         phpstr_append(&str, msg->body.data, msg->body.used);
 167         phpstr_fix(&str);
 168
 169         data = phpstr_data(&str, string, length);
 170         if (!string) {
 171                 efree(data);
 172         }
 173
 174         phpstr_dtor(&str);
 175 }