Fork of SandBox's original mbed-http (https://os.mbed.com/teams/sandbox/code/mbed-http/) and update for MbedOS6+ Content of TESTS folder was replaced with basic examples form original SandBox's HelloWorld
source/http_request.h@29:383e9bfbfbed, 2018-08-10 (annotated)
- Committer:
- Jan Jongboom
- Date:
- Fri Aug 10 11:30:37 2018 +0100
- Revision:
- 29:383e9bfbfbed
- Parent:
- 23:15fa2726f793
- Child:
- 32:fa4d71265625
Force usage of uint32_t instead of size_t - required for compilation on 64-bit systems
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
Jan Jongboom |
0:910f5949759f | 1 | /* |
Jan Jongboom |
0:910f5949759f | 2 | * PackageLicenseDeclared: Apache-2.0 |
Jan Jongboom |
0:910f5949759f | 3 | * Copyright (c) 2017 ARM Limited |
Jan Jongboom |
0:910f5949759f | 4 | * |
Jan Jongboom |
0:910f5949759f | 5 | * Licensed under the Apache License, Version 2.0 (the "License"); |
Jan Jongboom |
0:910f5949759f | 6 | * you may not use this file except in compliance with the License. |
Jan Jongboom |
0:910f5949759f | 7 | * You may obtain a copy of the License at |
Jan Jongboom |
0:910f5949759f | 8 | * |
Jan Jongboom |
0:910f5949759f | 9 | * http://www.apache.org/licenses/LICENSE-2.0 |
Jan Jongboom |
0:910f5949759f | 10 | * |
Jan Jongboom |
0:910f5949759f | 11 | * Unless required by applicable law or agreed to in writing, software |
Jan Jongboom |
0:910f5949759f | 12 | * distributed under the License is distributed on an "AS IS" BASIS, |
Jan Jongboom |
0:910f5949759f | 13 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
Jan Jongboom |
0:910f5949759f | 14 | * See the License for the specific language governing permissions and |
Jan Jongboom |
0:910f5949759f | 15 | * limitations under the License. |
Jan Jongboom |
0:910f5949759f | 16 | */ |
Jan Jongboom |
0:910f5949759f | 17 | |
Jan Jongboom |
0:910f5949759f | 18 | #ifndef _HTTP_REQUEST_ |
Jan Jongboom |
0:910f5949759f | 19 | #define _HTTP_REQUEST_ |
Jan Jongboom |
0:910f5949759f | 20 | |
Jan Jongboom |
0:910f5949759f | 21 | #include <string> |
Jan Jongboom |
0:910f5949759f | 22 | #include <vector> |
Jan Jongboom |
0:910f5949759f | 23 | #include <map> |
Jan Jongboom |
0:910f5949759f | 24 | #include "http_parser.h" |
Jan Jongboom |
0:910f5949759f | 25 | #include "http_response.h" |
Jan Jongboom |
0:910f5949759f | 26 | #include "http_request_builder.h" |
Jan Jongboom |
15:ffc77f212382 | 27 | #include "http_request_parser.h" |
Jan Jongboom |
0:910f5949759f | 28 | #include "http_parsed_url.h" |
Jan Jongboom |
0:910f5949759f | 29 | |
Jan Jongboom |
0:910f5949759f | 30 | /** |
Jan Jongboom |
0:910f5949759f | 31 | * @todo: |
Jan Jongboom |
0:910f5949759f | 32 | * - Userinfo parameter is not handled |
Jan Jongboom |
0:910f5949759f | 33 | */ |
Jan Jongboom |
0:910f5949759f | 34 | |
Jan Jongboom |
20:0e63d6a93c02 | 35 | #ifndef HTTP_RECEIVE_BUFFER_SIZE |
Jan Jongboom |
20:0e63d6a93c02 | 36 | #define HTTP_RECEIVE_BUFFER_SIZE 8 * 1024 |
Jan Jongboom |
20:0e63d6a93c02 | 37 | #endif |
Jan Jongboom |
0:910f5949759f | 38 | |
Jan Jongboom |
0:910f5949759f | 39 | /** |
Jan Jongboom |
17:6e0025e01b98 | 40 | * \brief HttpRequest implements the logic for interacting with HTTP servers. |
Jan Jongboom |
0:910f5949759f | 41 | */ |
Jan Jongboom |
0:910f5949759f | 42 | class HttpRequest { |
Jan Jongboom |
0:910f5949759f | 43 | public: |
Jan Jongboom |
0:910f5949759f | 44 | /** |
Jan Jongboom |
0:910f5949759f | 45 | * HttpRequest Constructor |
Jan Jongboom |
0:910f5949759f | 46 | * |
Jan Jongboom |
0:910f5949759f | 47 | * @param[in] aNetwork The network interface |
Jan Jongboom |
0:910f5949759f | 48 | * @param[in] aMethod HTTP method to use |
Jan Jongboom |
0:910f5949759f | 49 | * @param[in] url URL to the resource |
Jan Jongboom |
0:910f5949759f | 50 | * @param[in] aBodyCallback Callback on which to retrieve chunks of the response body. |
Jan Jongboom |
0:910f5949759f | 51 | If not set, the complete body will be allocated on the HttpResponse object, |
Jan Jongboom |
0:910f5949759f | 52 | which might use lots of memory. |
Jan Jongboom |
0:910f5949759f | 53 | */ |
Jan Jongboom |
29:383e9bfbfbed | 54 | HttpRequest(NetworkInterface* aNetwork, http_method aMethod, const char* url, Callback<void(const char *at, uint32_t length)> aBodyCallback = 0) |
Jan Jongboom |
0:910f5949759f | 55 | : network(aNetwork), method(aMethod), body_callback(aBodyCallback) |
Jan Jongboom |
0:910f5949759f | 56 | { |
Jan Jongboom |
0:910f5949759f | 57 | error = 0; |
Jan Jongboom |
0:910f5949759f | 58 | response = NULL; |
Jan Jongboom |
0:910f5949759f | 59 | |
Jan Jongboom |
0:910f5949759f | 60 | parsed_url = new ParsedUrl(url); |
Jan Jongboom |
0:910f5949759f | 61 | request_builder = new HttpRequestBuilder(method, parsed_url); |
Jan Jongboom |
11:96e4dcb9c0c2 | 62 | |
Jan Jongboom |
11:96e4dcb9c0c2 | 63 | socket = new TCPSocket(); |
Jan Jongboom |
11:96e4dcb9c0c2 | 64 | we_created_socket = true; |
Jan Jongboom |
11:96e4dcb9c0c2 | 65 | } |
Jan Jongboom |
11:96e4dcb9c0c2 | 66 | |
Jan Jongboom |
11:96e4dcb9c0c2 | 67 | /** |
Jan Jongboom |
11:96e4dcb9c0c2 | 68 | * HttpRequest Constructor |
Jan Jongboom |
11:96e4dcb9c0c2 | 69 | * |
Jan Jongboom |
11:96e4dcb9c0c2 | 70 | * @param[in] aSocket An open TCPSocket |
Jan Jongboom |
11:96e4dcb9c0c2 | 71 | * @param[in] aMethod HTTP method to use |
Jan Jongboom |
11:96e4dcb9c0c2 | 72 | * @param[in] url URL to the resource |
Jan Jongboom |
11:96e4dcb9c0c2 | 73 | * @param[in] aBodyCallback Callback on which to retrieve chunks of the response body. |
Jan Jongboom |
11:96e4dcb9c0c2 | 74 | If not set, the complete body will be allocated on the HttpResponse object, |
Jan Jongboom |
11:96e4dcb9c0c2 | 75 | which might use lots of memory. |
Jan Jongboom |
11:96e4dcb9c0c2 | 76 | */ |
Jan Jongboom |
29:383e9bfbfbed | 77 | HttpRequest(TCPSocket* aSocket, http_method aMethod, const char* url, Callback<void(const char *at, uint32_t length)> aBodyCallback = 0) |
Jan Jongboom |
11:96e4dcb9c0c2 | 78 | : socket(aSocket), method(aMethod), body_callback(aBodyCallback) |
Jan Jongboom |
11:96e4dcb9c0c2 | 79 | { |
Jan Jongboom |
11:96e4dcb9c0c2 | 80 | error = 0; |
Jan Jongboom |
11:96e4dcb9c0c2 | 81 | response = NULL; |
Jan Jongboom |
11:96e4dcb9c0c2 | 82 | network = NULL; |
Jan Jongboom |
11:96e4dcb9c0c2 | 83 | |
Jan Jongboom |
11:96e4dcb9c0c2 | 84 | parsed_url = new ParsedUrl(url); |
Jan Jongboom |
11:96e4dcb9c0c2 | 85 | request_builder = new HttpRequestBuilder(method, parsed_url); |
Jan Jongboom |
11:96e4dcb9c0c2 | 86 | |
Jan Jongboom |
11:96e4dcb9c0c2 | 87 | we_created_socket = false; |
Jan Jongboom |
0:910f5949759f | 88 | } |
Jan Jongboom |
0:910f5949759f | 89 | |
Jan Jongboom |
0:910f5949759f | 90 | /** |
Jan Jongboom |
0:910f5949759f | 91 | * HttpRequest Constructor |
Jan Jongboom |
0:910f5949759f | 92 | */ |
Jan Jongboom |
0:910f5949759f | 93 | ~HttpRequest() { |
Jan Jongboom |
0:910f5949759f | 94 | // should response be owned by us? Or should user free it? |
Jan Jongboom |
0:910f5949759f | 95 | // maybe implement copy constructor on response... |
Jan Jongboom |
0:910f5949759f | 96 | if (response) { |
Jan Jongboom |
0:910f5949759f | 97 | delete response; |
Jan Jongboom |
0:910f5949759f | 98 | } |
Jan Jongboom |
0:910f5949759f | 99 | |
Jan Jongboom |
0:910f5949759f | 100 | if (parsed_url) { |
Jan Jongboom |
0:910f5949759f | 101 | delete parsed_url; |
Jan Jongboom |
0:910f5949759f | 102 | } |
Jan Jongboom |
0:910f5949759f | 103 | |
Jan Jongboom |
0:910f5949759f | 104 | if (request_builder) { |
Jan Jongboom |
0:910f5949759f | 105 | delete request_builder; |
Jan Jongboom |
0:910f5949759f | 106 | } |
Jan Jongboom |
11:96e4dcb9c0c2 | 107 | |
Jan Jongboom |
11:96e4dcb9c0c2 | 108 | if (socket && we_created_socket) { |
Jan Jongboom |
11:96e4dcb9c0c2 | 109 | delete socket; |
Jan Jongboom |
11:96e4dcb9c0c2 | 110 | } |
Jan Jongboom |
0:910f5949759f | 111 | } |
Jan Jongboom |
0:910f5949759f | 112 | |
Jan Jongboom |
0:910f5949759f | 113 | /** |
Jan Jongboom |
0:910f5949759f | 114 | * Execute the request and receive the response. |
Jan Jongboom |
23:15fa2726f793 | 115 | * This adds a Content-Length header to the request (when body_size is set), and sends the data to the server. |
Jan Jongboom |
23:15fa2726f793 | 116 | * @param body Pointer to the body to be sent |
Jan Jongboom |
23:15fa2726f793 | 117 | * @param body_size Size of the body to be sent |
Jan Jongboom |
23:15fa2726f793 | 118 | * @return An HttpResponse pointer on success, or NULL on failure. |
Jan Jongboom |
23:15fa2726f793 | 119 | * See get_error() for the error code. |
Jan Jongboom |
0:910f5949759f | 120 | */ |
Jan Jongboom |
0:910f5949759f | 121 | HttpResponse* send(const void* body = NULL, nsapi_size_t body_size = 0) { |
Jan Jongboom |
23:15fa2726f793 | 122 | nsapi_size_or_error_t ret = open_socket(); |
Jan Jongboom |
0:910f5949759f | 123 | |
Jan Jongboom |
23:15fa2726f793 | 124 | if (ret != NSAPI_ERROR_OK) { |
Jan Jongboom |
23:15fa2726f793 | 125 | error = ret; |
Jan Jongboom |
23:15fa2726f793 | 126 | return NULL; |
Jan Jongboom |
0:910f5949759f | 127 | } |
Jan Jongboom |
0:910f5949759f | 128 | |
Jan Jongboom |
29:383e9bfbfbed | 129 | uint32_t request_size = 0; |
Jan Jongboom |
10:b017c7d2cf23 | 130 | char* request = request_builder->build(body, body_size, request_size); |
Jan Jongboom |
0:910f5949759f | 131 | |
Jan Jongboom |
23:15fa2726f793 | 132 | ret = send_buffer(request, request_size); |
Jan Jongboom |
23:15fa2726f793 | 133 | |
Jan Jongboom |
23:15fa2726f793 | 134 | free(request); |
Jan Jongboom |
23:15fa2726f793 | 135 | |
Jan Jongboom |
23:15fa2726f793 | 136 | if (ret < 0) { |
Jan Jongboom |
23:15fa2726f793 | 137 | error = ret; |
Jan Jongboom |
23:15fa2726f793 | 138 | return NULL; |
Jan Jongboom |
23:15fa2726f793 | 139 | } |
Jan Jongboom |
23:15fa2726f793 | 140 | |
Jan Jongboom |
23:15fa2726f793 | 141 | return create_http_response(); |
Jan Jongboom |
23:15fa2726f793 | 142 | } |
Jan Jongboom |
23:15fa2726f793 | 143 | |
Jan Jongboom |
23:15fa2726f793 | 144 | /** |
Jan Jongboom |
23:15fa2726f793 | 145 | * Execute the request and receive the response. |
Jan Jongboom |
23:15fa2726f793 | 146 | * This sends the request through chunked-encoding. |
Jan Jongboom |
23:15fa2726f793 | 147 | * @param body_cb Callback which generates the next chunk of the request |
Jan Jongboom |
23:15fa2726f793 | 148 | * @return An HttpResponse pointer on success, or NULL on failure. |
Jan Jongboom |
23:15fa2726f793 | 149 | * See get_error() for the error code. |
Jan Jongboom |
23:15fa2726f793 | 150 | */ |
Jan Jongboom |
29:383e9bfbfbed | 151 | HttpResponse* send(Callback<const void*(uint32_t*)> body_cb) { |
Jan Jongboom |
23:15fa2726f793 | 152 | |
Jan Jongboom |
23:15fa2726f793 | 153 | nsapi_error_t ret; |
Jan Jongboom |
23:15fa2726f793 | 154 | |
Jan Jongboom |
23:15fa2726f793 | 155 | if ((ret = open_socket()) != NSAPI_ERROR_OK) { |
Jan Jongboom |
23:15fa2726f793 | 156 | error = ret; |
Jan Jongboom |
23:15fa2726f793 | 157 | return NULL; |
Jan Jongboom |
23:15fa2726f793 | 158 | } |
Jan Jongboom |
23:15fa2726f793 | 159 | |
Jan Jongboom |
23:15fa2726f793 | 160 | set_header("Transfer-Encoding", "chunked"); |
Jan Jongboom |
23:15fa2726f793 | 161 | |
Jan Jongboom |
29:383e9bfbfbed | 162 | uint32_t request_size = 0; |
Jan Jongboom |
23:15fa2726f793 | 163 | char* request = request_builder->build(NULL, 0, request_size); |
Jan Jongboom |
23:15fa2726f793 | 164 | |
Jan Jongboom |
23:15fa2726f793 | 165 | // first... send this request headers without the body |
Jan Jongboom |
23:15fa2726f793 | 166 | nsapi_size_or_error_t total_send_count = send_buffer(request, request_size); |
Jan Jongboom |
23:15fa2726f793 | 167 | |
Jan Jongboom |
23:15fa2726f793 | 168 | if (total_send_count < 0) { |
Jan Jongboom |
23:15fa2726f793 | 169 | free(request); |
Jan Jongboom |
23:15fa2726f793 | 170 | error = total_send_count; |
Jan Jongboom |
23:15fa2726f793 | 171 | return NULL; |
Jan Jongboom |
23:15fa2726f793 | 172 | } |
Jan Jongboom |
23:15fa2726f793 | 173 | |
Jan Jongboom |
23:15fa2726f793 | 174 | // ok... now it's time to start sending chunks... |
Jan Jongboom |
23:15fa2726f793 | 175 | while (1) { |
Jan Jongboom |
29:383e9bfbfbed | 176 | uint32_t size; |
Jan Jongboom |
23:15fa2726f793 | 177 | const void *buffer = body_cb(&size); |
Jan Jongboom |
23:15fa2726f793 | 178 | |
Jan Jongboom |
23:15fa2726f793 | 179 | if (size == 0) break; |
Jan Jongboom |
23:15fa2726f793 | 180 | |
Jan Jongboom |
23:15fa2726f793 | 181 | // so... size in HEX, \r\n, data, \r\n again |
Jan Jongboom |
23:15fa2726f793 | 182 | char size_buff[10]; // if sending length of more than 8 digits, you have another problem on a microcontroller... |
Jan Jongboom |
29:383e9bfbfbed | 183 | uint32_t size_buff_size = sprintf(size_buff, "%X\r\n", size); |
Jan Jongboom |
23:15fa2726f793 | 184 | if ((total_send_count = send_buffer(size_buff, size_buff_size)) < 0) { |
Jan Jongboom |
23:15fa2726f793 | 185 | free(request); |
Jan Jongboom |
23:15fa2726f793 | 186 | error = total_send_count; |
Jan Jongboom |
23:15fa2726f793 | 187 | return NULL; |
Jan Jongboom |
23:15fa2726f793 | 188 | } |
Jan Jongboom |
23:15fa2726f793 | 189 | |
Jan Jongboom |
23:15fa2726f793 | 190 | // now send the normal buffer... and then \r\n at the end |
Jan Jongboom |
23:15fa2726f793 | 191 | total_send_count = send_buffer((char*)buffer, size); |
Jan Jongboom |
23:15fa2726f793 | 192 | if (total_send_count < 0) { |
Jan Jongboom |
23:15fa2726f793 | 193 | free(request); |
Jan Jongboom |
23:15fa2726f793 | 194 | error = total_send_count; |
Jan Jongboom |
23:15fa2726f793 | 195 | return NULL; |
Jan Jongboom |
23:15fa2726f793 | 196 | } |
Jan Jongboom |
23:15fa2726f793 | 197 | |
Jan Jongboom |
23:15fa2726f793 | 198 | // and... \r\n |
Jan Jongboom |
23:15fa2726f793 | 199 | const char* rn = "\r\n"; |
Jan Jongboom |
23:15fa2726f793 | 200 | if ((total_send_count = send_buffer((char*)rn, 2)) < 0) { |
Jan Jongboom |
23:15fa2726f793 | 201 | free(request); |
Jan Jongboom |
23:15fa2726f793 | 202 | error = total_send_count; |
Jan Jongboom |
23:15fa2726f793 | 203 | return NULL; |
Jan Jongboom |
23:15fa2726f793 | 204 | } |
Jan Jongboom |
23:15fa2726f793 | 205 | } |
Jan Jongboom |
23:15fa2726f793 | 206 | |
Jan Jongboom |
23:15fa2726f793 | 207 | // finalize...? |
Jan Jongboom |
23:15fa2726f793 | 208 | const char* fin = "0\r\n\r\n"; |
Jan Jongboom |
23:15fa2726f793 | 209 | if ((total_send_count = send_buffer((char*)fin, strlen(fin))) < 0) { |
Jan Jongboom |
23:15fa2726f793 | 210 | free(request); |
Jan Jongboom |
23:15fa2726f793 | 211 | error = total_send_count; |
Jan Jongboom |
23:15fa2726f793 | 212 | return NULL; |
Jan Jongboom |
23:15fa2726f793 | 213 | } |
Jan Jongboom |
23:15fa2726f793 | 214 | |
Jan Jongboom |
23:15fa2726f793 | 215 | free(request); |
Jan Jongboom |
23:15fa2726f793 | 216 | |
Jan Jongboom |
23:15fa2726f793 | 217 | return create_http_response(); |
Jan Jongboom |
23:15fa2726f793 | 218 | } |
Jan Jongboom |
23:15fa2726f793 | 219 | |
Jan Jongboom |
23:15fa2726f793 | 220 | /** |
Jan Jongboom |
23:15fa2726f793 | 221 | * Set a header for the request. |
Jan Jongboom |
23:15fa2726f793 | 222 | * |
Jan Jongboom |
23:15fa2726f793 | 223 | * The 'Host' and 'Content-Length' headers are set automatically. |
Jan Jongboom |
23:15fa2726f793 | 224 | * Setting the same header twice will overwrite the previous entry. |
Jan Jongboom |
23:15fa2726f793 | 225 | * |
Jan Jongboom |
23:15fa2726f793 | 226 | * @param[in] key Header key |
Jan Jongboom |
23:15fa2726f793 | 227 | * @param[in] value Header value |
Jan Jongboom |
23:15fa2726f793 | 228 | */ |
Jan Jongboom |
23:15fa2726f793 | 229 | void set_header(string key, string value) { |
Jan Jongboom |
23:15fa2726f793 | 230 | request_builder->set_header(key, value); |
Jan Jongboom |
23:15fa2726f793 | 231 | } |
Jan Jongboom |
23:15fa2726f793 | 232 | |
Jan Jongboom |
23:15fa2726f793 | 233 | /** |
Jan Jongboom |
23:15fa2726f793 | 234 | * Get the error code. |
Jan Jongboom |
23:15fa2726f793 | 235 | * |
Jan Jongboom |
23:15fa2726f793 | 236 | * When send() fails, this error is set. |
Jan Jongboom |
23:15fa2726f793 | 237 | */ |
Jan Jongboom |
23:15fa2726f793 | 238 | nsapi_error_t get_error() { |
Jan Jongboom |
23:15fa2726f793 | 239 | return error; |
Jan Jongboom |
23:15fa2726f793 | 240 | } |
Jan Jongboom |
23:15fa2726f793 | 241 | |
Jan Jongboom |
23:15fa2726f793 | 242 | private: |
Jan Jongboom |
23:15fa2726f793 | 243 | nsapi_error_t open_socket() { |
Jan Jongboom |
23:15fa2726f793 | 244 | if (response != NULL) { |
Jan Jongboom |
23:15fa2726f793 | 245 | // already executed this response |
Jan Jongboom |
23:15fa2726f793 | 246 | return -2100; // @todo, make a lookup table with errors |
Jan Jongboom |
23:15fa2726f793 | 247 | } |
Jan Jongboom |
23:15fa2726f793 | 248 | |
Jan Jongboom |
23:15fa2726f793 | 249 | |
Jan Jongboom |
23:15fa2726f793 | 250 | if (we_created_socket) { |
Jan Jongboom |
23:15fa2726f793 | 251 | nsapi_error_t open_result = socket->open(network); |
Jan Jongboom |
23:15fa2726f793 | 252 | if (open_result != NSAPI_ERROR_OK) { |
Jan Jongboom |
23:15fa2726f793 | 253 | return open_result; |
Jan Jongboom |
23:15fa2726f793 | 254 | } |
Jan Jongboom |
23:15fa2726f793 | 255 | |
Jan Jongboom |
23:15fa2726f793 | 256 | nsapi_error_t connection_result = socket->connect(parsed_url->host(), parsed_url->port()); |
Jan Jongboom |
23:15fa2726f793 | 257 | if (connection_result != NSAPI_ERROR_OK) { |
Jan Jongboom |
23:15fa2726f793 | 258 | return connection_result; |
Jan Jongboom |
23:15fa2726f793 | 259 | } |
Jan Jongboom |
23:15fa2726f793 | 260 | } |
Jan Jongboom |
23:15fa2726f793 | 261 | |
Jan Jongboom |
23:15fa2726f793 | 262 | return NSAPI_ERROR_OK; |
Jan Jongboom |
23:15fa2726f793 | 263 | } |
Jan Jongboom |
23:15fa2726f793 | 264 | |
Jan Jongboom |
29:383e9bfbfbed | 265 | nsapi_size_or_error_t send_buffer(char* buffer, uint32_t buffer_size) { |
Jan Jongboom |
22:71fc1b1894f8 | 266 | nsapi_size_or_error_t total_send_count = 0; |
Jan Jongboom |
23:15fa2726f793 | 267 | while (total_send_count < buffer_size) { |
Jan Jongboom |
23:15fa2726f793 | 268 | nsapi_size_or_error_t send_result = socket->send(buffer + total_send_count, buffer_size - total_send_count); |
Jan Jongboom |
22:71fc1b1894f8 | 269 | |
Jan Jongboom |
22:71fc1b1894f8 | 270 | if (send_result < 0) { |
Jan Jongboom |
22:71fc1b1894f8 | 271 | total_send_count = send_result; |
Jan Jongboom |
22:71fc1b1894f8 | 272 | break; |
Jan Jongboom |
22:71fc1b1894f8 | 273 | } |
Jan Jongboom |
22:71fc1b1894f8 | 274 | |
Jan Jongboom |
22:71fc1b1894f8 | 275 | if (send_result == 0) { |
Jan Jongboom |
22:71fc1b1894f8 | 276 | break; |
Jan Jongboom |
22:71fc1b1894f8 | 277 | } |
Jan Jongboom |
22:71fc1b1894f8 | 278 | |
Jan Jongboom |
22:71fc1b1894f8 | 279 | total_send_count += send_result; |
Jan Jongboom |
22:71fc1b1894f8 | 280 | } |
Jan Jongboom |
22:71fc1b1894f8 | 281 | |
Jan Jongboom |
23:15fa2726f793 | 282 | return total_send_count; |
Jan Jongboom |
23:15fa2726f793 | 283 | } |
Jan Jongboom |
0:910f5949759f | 284 | |
Jan Jongboom |
23:15fa2726f793 | 285 | HttpResponse* create_http_response() { |
Jan Jongboom |
0:910f5949759f | 286 | // Create a response object |
Jan Jongboom |
0:910f5949759f | 287 | response = new HttpResponse(); |
Jan Jongboom |
0:910f5949759f | 288 | // And a response parser |
Jan Jongboom |
15:ffc77f212382 | 289 | HttpParser parser(response, HTTP_RESPONSE, body_callback); |
Jan Jongboom |
0:910f5949759f | 290 | |
Jan Jongboom |
0:910f5949759f | 291 | // Set up a receive buffer (on the heap) |
Jan Jongboom |
0:910f5949759f | 292 | uint8_t* recv_buffer = (uint8_t*)malloc(HTTP_RECEIVE_BUFFER_SIZE); |
Jan Jongboom |
0:910f5949759f | 293 | |
Jan Jongboom |
0:910f5949759f | 294 | // TCPSocket::recv is called until we don't have any data anymore |
Jan Jongboom |
0:910f5949759f | 295 | nsapi_size_or_error_t recv_ret; |
Jan Jongboom |
11:96e4dcb9c0c2 | 296 | while ((recv_ret = socket->recv(recv_buffer, HTTP_RECEIVE_BUFFER_SIZE)) > 0) { |
Jan Jongboom |
3:8a6b003e3874 | 297 | |
Jan Jongboom |
0:910f5949759f | 298 | // Pass the chunk into the http_parser |
Jan Jongboom |
29:383e9bfbfbed | 299 | uint32_t nparsed = parser.execute((const char*)recv_buffer, recv_ret); |
Jan Jongboom |
0:910f5949759f | 300 | if (nparsed != recv_ret) { |
Jan Jongboom |
0:910f5949759f | 301 | // printf("Parsing failed... parsed %d bytes, received %d bytes\n", nparsed, recv_ret); |
Jan Jongboom |
0:910f5949759f | 302 | error = -2101; |
Jan Jongboom |
0:910f5949759f | 303 | free(recv_buffer); |
Jan Jongboom |
0:910f5949759f | 304 | return NULL; |
Jan Jongboom |
0:910f5949759f | 305 | } |
Jan Jongboom |
3:8a6b003e3874 | 306 | |
Jan Jongboom |
7:2e3eedb9ca5c | 307 | if (response->is_message_complete()) { |
Jan Jongboom |
0:910f5949759f | 308 | break; |
Jan Jongboom |
0:910f5949759f | 309 | } |
Jan Jongboom |
0:910f5949759f | 310 | } |
Jan Jongboom |
0:910f5949759f | 311 | // error? |
Jan Jongboom |
0:910f5949759f | 312 | if (recv_ret < 0) { |
Jan Jongboom |
0:910f5949759f | 313 | error = recv_ret; |
Jan Jongboom |
0:910f5949759f | 314 | free(recv_buffer); |
Jan Jongboom |
0:910f5949759f | 315 | return NULL; |
Jan Jongboom |
0:910f5949759f | 316 | } |
Jan Jongboom |
0:910f5949759f | 317 | |
Jan Jongboom |
0:910f5949759f | 318 | // When done, call parser.finish() |
Jan Jongboom |
0:910f5949759f | 319 | parser.finish(); |
Jan Jongboom |
0:910f5949759f | 320 | |
Jan Jongboom |
0:910f5949759f | 321 | // Free the receive buffer |
Jan Jongboom |
0:910f5949759f | 322 | free(recv_buffer); |
Jan Jongboom |
0:910f5949759f | 323 | |
Jan Jongboom |
11:96e4dcb9c0c2 | 324 | if (we_created_socket) { |
Jan Jongboom |
11:96e4dcb9c0c2 | 325 | // Close the socket |
Jan Jongboom |
11:96e4dcb9c0c2 | 326 | socket->close(); |
Jan Jongboom |
11:96e4dcb9c0c2 | 327 | } |
Jan Jongboom |
0:910f5949759f | 328 | |
Jan Jongboom |
0:910f5949759f | 329 | return response; |
Jan Jongboom |
0:910f5949759f | 330 | } |
Jan Jongboom |
0:910f5949759f | 331 | |
Jan Jongboom |
0:910f5949759f | 332 | |
Jan Jongboom |
0:910f5949759f | 333 | NetworkInterface* network; |
Jan Jongboom |
11:96e4dcb9c0c2 | 334 | TCPSocket* socket; |
Jan Jongboom |
0:910f5949759f | 335 | http_method method; |
Jan Jongboom |
29:383e9bfbfbed | 336 | Callback<void(const char *at, uint32_t length)> body_callback; |
Jan Jongboom |
0:910f5949759f | 337 | |
Jan Jongboom |
0:910f5949759f | 338 | ParsedUrl* parsed_url; |
Jan Jongboom |
0:910f5949759f | 339 | |
Jan Jongboom |
0:910f5949759f | 340 | HttpRequestBuilder* request_builder; |
Jan Jongboom |
0:910f5949759f | 341 | HttpResponse* response; |
Jan Jongboom |
0:910f5949759f | 342 | |
Jan Jongboom |
11:96e4dcb9c0c2 | 343 | bool we_created_socket; |
Jan Jongboom |
11:96e4dcb9c0c2 | 344 | |
Jan Jongboom |
0:910f5949759f | 345 | nsapi_error_t error; |
Jan Jongboom |
0:910f5949759f | 346 | }; |
Jan Jongboom |
0:910f5949759f | 347 | |
Jan Jongboom |
0:910f5949759f | 348 | #endif // _HTTP_REQUEST_ |