git.m6w6.name Git - m6w6/ext-http/blob - http_request_body_api.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-2005, Michael Wallner <mike@php.net>            |
  10     +--------------------------------------------------------------------+
  11 */
  12
  13 /* $Id$ */
  14
  15 #ifdef HAVE_CONFIG_H
  16 #       include "config.h"
  17 #endif
  18
  19 #define HTTP_WANT_CURL
  20 #include "php_http.h"
  21
  22 #ifdef HTTP_HAVE_CURL
  23
  24 #include "php_http_api.h"
  25 #include "php_http_url_api.h"
  26 #include "php_http_request_body_api.h"
  27
  28 ZEND_EXTERN_MODULE_GLOBALS(http);
  29
  30 /* {{{ http_request_body *http_request_body_new() */
  31 PHP_HTTP_API http_request_body *_http_request_body_init_ex(http_request_body *body, int type, void *data, size_t size, zend_bool free ZEND_FILE_LINE_DC ZEND_FILE_LINE_ORIG_DC TSRMLS_DC)
  32 {
  33         if (!body) {
  34                 body = emalloc_rel(sizeof(http_request_body));
  35         }
  36
  37         body->type = type;
  38         body->free = free;
  39         body->data = data;
  40         body->size = size;
  41
  42         return body;
  43 }
  44 /* }}} */
  45
  46 /* {{{ http_request_body *http_request_body_fill(http_request_body *body, HashTable *, HashTable *) */
  47 PHP_HTTP_API http_request_body *_http_request_body_fill(http_request_body *body, HashTable *fields, HashTable *files ZEND_FILE_LINE_DC ZEND_FILE_LINE_ORIG_DC TSRMLS_DC)
  48 {
  49         if (files && (zend_hash_num_elements(files) > 0)) {
  50                 char *key = NULL;
  51                 ulong idx;
  52                 zval **data;
  53                 HashPosition pos;
  54                 struct curl_httppost *http_post_data[2] = {NULL, NULL};
  55
  56                 /* normal data */
  57                 FOREACH_HASH_KEYVAL(pos, fields, key, idx, data) {
  58                         if (key) {
  59                                 CURLcode err;
  60                                 zval *orig = *data;
  61
  62                                 convert_to_string_ex(data);
  63                                 err = curl_formadd(&http_post_data[0], &http_post_data[1],
  64                                         CURLFORM_COPYNAME,                      key,
  65                                         CURLFORM_COPYCONTENTS,          Z_STRVAL_PP(data),
  66                                         CURLFORM_CONTENTSLENGTH,        (long) Z_STRLEN_PP(data),
  67                                         CURLFORM_END
  68                                 );
  69
  70                                 if (orig != *data) {
  71                                         zval_ptr_dtor(data);
  72                                 }
  73
  74                                 if (CURLE_OK != err) {
  75                                         http_error_ex(HE_WARNING, HTTP_E_ENCODING, "Could not encode post fields: %s", curl_easy_strerror(err));
  76                                         curl_formfree(http_post_data[0]);
  77                                         return NULL;
  78                                 }
  79
  80                                 /* reset */
  81                                 key = NULL;
  82                         }
  83                 }
  84
  85                 /* file data */
  86                 FOREACH_HASH_VAL(pos, files, data) {
  87                         zval **file, **type, **name;
  88
  89                         if (Z_TYPE_PP(data) != IS_ARRAY) {
  90                                 http_error(HE_NOTICE, HTTP_E_INVALID_PARAM, "Unrecognized type of post file array entry");
  91                         } else if (     SUCCESS != zend_hash_find(Z_ARRVAL_PP(data), "name", sizeof("name"), (void **) &name) ||
  92                                                 SUCCESS != zend_hash_find(Z_ARRVAL_PP(data), "type", sizeof("type"), (void **) &type) ||
  93                                                 SUCCESS != zend_hash_find(Z_ARRVAL_PP(data), "file", sizeof("file"), (void **) &file)) {
  94                                 http_error(HE_NOTICE, HTTP_E_INVALID_PARAM, "Post file array entry misses either 'name', 'type' or 'file' entry");
  95                         } else {
  96                                 CURLcode err;
  97                                 const char *path;
  98                                 zval *ofile = *file, *otype = *type, *oname = *name;
  99
 100                                 convert_to_string_ex(file);
 101                                 convert_to_string_ex(type);
 102                                 convert_to_string_ex(name);
 103
 104                                 HTTP_CHECK_OPEN_BASEDIR(Z_STRVAL_PP(file), curl_formfree(http_post_data[0]); return NULL);
 105
 106                                 /* this is blatant but should be sufficient for most cases */
 107                                 if (strncasecmp(Z_STRVAL_PP(file), "file://", lenof("file://"))) {
 108                                         path = Z_STRVAL_PP(file);
 109                                 } else {
 110                                         path = Z_STRVAL_PP(file) + lenof("file://");
 111                                 }
 112
 113                                 err = curl_formadd(&http_post_data[0], &http_post_data[1],
 114                                         CURLFORM_COPYNAME,              Z_STRVAL_PP(name),
 115                                         CURLFORM_FILE,                  path,
 116                                         CURLFORM_CONTENTTYPE,   Z_STRVAL_PP(type),
 117                                         CURLFORM_END
 118                                 );
 119
 120                                 if (ofile != *file) zval_ptr_dtor(file);
 121                                 if (otype != *type) zval_ptr_dtor(type);
 122                                 if (oname != *name) zval_ptr_dtor(name);
 123
 124                                 if (CURLE_OK != err) {
 125                                         http_error_ex(HE_WARNING, HTTP_E_ENCODING, "Could not encode post files: %s", curl_easy_strerror(err));
 126                                         curl_formfree(http_post_data[0]);
 127                                         return NULL;
 128                                 }
 129                         }
 130                 }
 131
 132                 return http_request_body_init_rel(body, HTTP_REQUEST_BODY_CURLPOST, http_post_data[0], 0, 1);
 133
 134         } else {
 135                 char *encoded;
 136                 size_t encoded_len;
 137
 138                 if (SUCCESS != http_urlencode_hash_ex(fields, 1, NULL, 0, &encoded, &encoded_len)) {
 139                         http_error(HE_WARNING, HTTP_E_ENCODING, "Could not encode post data");
 140                         return NULL;
 141                 }
 142
 143                 return http_request_body_init_rel(body, HTTP_REQUEST_BODY_CSTRING, encoded, encoded_len, 1);
 144         }
 145 }
 146
 147
 148 /* {{{ void http_request_body_dtor(http_request_body *) */
 149 PHP_HTTP_API void _http_request_body_dtor(http_request_body *body TSRMLS_DC)
 150 {
 151         if (body) {
 152                 if (body->free) {
 153                         switch (body->type)
 154                         {
 155                                 case HTTP_REQUEST_BODY_CSTRING:
 156                                         if (body->data) {
 157                                                 efree(body->data);
 158                                         }
 159                                 break;
 160
 161                                 case HTTP_REQUEST_BODY_CURLPOST:
 162                                         curl_formfree(body->data);
 163                                 break;
 164
 165                                 case HTTP_REQUEST_BODY_UPLOADFILE:
 166                                         php_stream_close(body->data);
 167                                 break;
 168                         }
 169                 }
 170                 memset(body, 0, sizeof(http_request_body));
 171         }
 172 }
 173 /* }}} */
 174
 175 /* {{{ void http_request_body_free(http_request_body *) */
 176 PHP_HTTP_API void _http_request_body_free(http_request_body **body TSRMLS_DC)
 177 {
 178         if (*body) {
 179                 http_request_body_dtor(*body);
 180                 efree(*body);
 181                 *body = NULL;
 182         }
 183 }
 184 /* }}} */
 185
 186 #endif /* HTTP_HAVE_CURL */
 187
 188 /*
 189  * Local variables:
 190  * tab-width: 4
 191  * c-basic-offset: 4
 192  * End:
 193  * vim600: noet sw=4 ts=4 fdm=marker
 194  * vim<600: noet sw=4 ts=4
 195  */