Experimental HTTP and HTTPS library for mbed OS 5

Committer:
Jan Jongboom
Date:
Thu Jan 11 13:49:06 2018 +0100
Revision:
23:15fa2726f793
Parent:
22:71fc1b1894f8
Child:
29:383e9bfbfbed
Child:
31:b3730a2c4f39
Implement Transfer-Encoding: chunked on HTTP and HTTPS requests, allows streaming large blocks of data over HTTP

Who changed what in which revision?

UserRevisionLine numberNew 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 0:910f5949759f 54 HttpRequest(NetworkInterface* aNetwork, http_method aMethod, const char* url, Callback<void(const char *at, size_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 11:96e4dcb9c0c2 77 HttpRequest(TCPSocket* aSocket, http_method aMethod, const char* url, Callback<void(const char *at, size_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 10:b017c7d2cf23 129 size_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 23:15fa2726f793 151 HttpResponse* send(Callback<const void*(size_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 23:15fa2726f793 162 size_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 23:15fa2726f793 176 size_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 23:15fa2726f793 183 size_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 23:15fa2726f793 265 nsapi_size_or_error_t send_buffer(char* buffer, size_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 0:910f5949759f 299 size_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 0:910f5949759f 336 Callback<void(const char *at, size_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_