HTTP and HTTPS library for Mbed OS 5

Dependents:   MQTTGateway2 MQTTGatewayK64 http-example-wnc GuardRoom ... more

For the example program, see: sandbox/http-example.

This library is used to make HTTP and HTTPS calls from Mbed OS 5 applications.

HTTP Request API

NetworkInterface* network = /* obtain a NetworkInterface object */

const char body[] = "{\"hello\":\"world\"}";

HttpRequest* request = new HttpRequest(network, HTTP_POST, "http://httpbin.org/post");
request->set_header("Content-Type", "application/json");
HttpResponse* response = request->send(body, strlen(body));
// if response is NULL, check response->get_error()

printf("status is %d - %s\n", response->get_status_code(), response->get_status_message());
printf("body is:\n%s\n", response->get_body_as_string().c_str());

delete request; // also clears out the response

HTTPS Request API

// pass in the root certificates that you trust, there is no central CA registry in Mbed OS
const char SSL_CA_PEM[] = "-----BEGIN CERTIFICATE-----\n"
    /* rest of the CA root certificates */;

NetworkInterface* network = /* obtain a NetworkInterface object */

const char body[] = "{\"hello\":\"world\"}";

HttpsRequest* request = new HttpsRequest(network, SSL_CA_PEM, HTTP_GET "https://httpbin.org/status/418");
HttpResponse* response = request->send();
// if response is NULL, check response->get_error()

printf("status is %d - %s\n", response->get_status_code(), response->get_status_message());
printf("body is:\n%s\n", response->get_body().c_str());

delete request;

Note: You can get the root CA for a domain easily from Firefox. Click on the green padlock, click More information > Security > View certificate > Details. Select the top entry in the 'Certificate Hierarchy' and click Export.... This gives you a PEM file. Add the content of the PEM file to your root CA list (here's an image).

Mbed TLS Entropy configuration

If your target does not have a built-in TRNG, or other entropy sources, add the following macros to your mbed_app.json file to disable entropy:

{
    "macros": [
        "MBEDTLS_TEST_NULL_ENTROPY",
        "MBEDTLS_NO_DEFAULT_ENTROPY_SOURCES"
    ]
}

Note that this is not secure, and you should not deploy this device into production with this configuration.

Memory usage

Small requests where the body of the response is cached by the library (like the one found in main-http.cpp), require 4K of RAM. When the request is finished they require 1.5K of RAM, depending on the size of the response. This applies both to HTTP and HTTPS. If you need to handle requests that return a large response body, see 'Dealing with large body'.

HTTPS requires additional memory: on FRDM-K64F about 50K of heap space (at its peak). This means that you cannot use HTTPS on devices with less than 128K of memory, asyou also need to reserve memory for the stack and network interface.

Dealing with large response body

By default the library will store the full request body on the heap. This works well for small responses, but you'll run out of memory when receiving a large response body. To mitigate this you can pass in a callback as the last argument to the request constructor. This callback will be called whenever a chunk of the body is received. You can set the request chunk size in the HTTP_RECEIVE_BUFFER_SIZE macro (see mbed_lib.json for the definition) although it also depends on the buffer size ofthe underlying network connection.

void body_callback(const char* data, uint32_t data_len) {
    // do something with the data
}

HttpRequest* req = new HttpRequest(network, HTTP_GET, "http://pathtolargefile.com", &body_callback);
req->send(NULL, 0);

Dealing with a large request body

If you cannot load the full request into memory, you can pass a callback into the send function. Through this callback you can feed in chunks of the request body. This is very useful if you want to send files from a file system.

const void * get_chunk(uint32_t* out_size) {
    // set the value of out_size (via *out_size = 10) to the size of the buffer
    // return the buffer

    // if you don't have any more data, set *out_size to 0
}

HttpRequest* req = new HttpRequest(network, HTTP_POST, "http://my_api.com/upload");
req->send(callback(&get_chunk));

Socket re-use

By default the library opens a new socket per request. This is wasteful, especially when dealing with TLS requests. You can re-use sockets like this:

HTTP

TCPSocket* socket = new TCPSocket();

nsapi_error_t open_result = socket->open(network);
// check open_result

nsapi_error_t connect_result = socket->connect("httpbin.org", 80);
// check connect_result

// Pass in `socket`, instead of `network` as first argument
HttpRequest* req = new HttpRequest(socket, HTTP_GET, "http://httpbin.org/status/418");

HTTPS

TLSSocket* socket = new TLSSocket();

nsapi_error_t r;
// make sure to check the return values for the calls below (should return NSAPI_ERROR_OK)
r = socket->open(network);
r = socket->set_root_ca_cert(SSL_CA_PEM);
r = socket->connect("httpbin.org", 443);

// Pass in `socket`, instead of `network` as first argument, and omit the `SSL_CA_PEM` argument
HttpsRequest* get_req = new HttpsRequest(socket, HTTP_GET, "https://httpbin.org/status/418");

Request logging

To make debugging easier you can log the raw request body that goes over the line. This also works with chunked encoding.

uint8_t *request_buffer = (uint8_t*)calloc(2048, 1);
req->set_request_log_buffer(request_buffer, 2048);

// after the request is done:
printf("\n----- Request buffer -----\n");
for (size_t ix = 0; ix < req->get_request_log_buffer_length(); ix++) {
    printf("%02x ", request_buffer[ix]);
}
printf("\n");

Integration tests

Integration tests are located in the TESTS folder and are ran through Greentea. Instructions on how to run the tests are in http-example.

Mbed OS 5.10 or lower

If you want to use this library on Mbed OS 5.10 or lower, you need to add the TLSSocket library to your project. This library is included in Mbed OS 5.11 and up.

Tested on

  • K64F with Ethernet.
  • NUCLEO_F411RE with ESP8266.
  • ODIN-W2 with WiFi.
  • K64F with Atmel 6LoWPAN shield.
  • DISCO-L475VG-IOT01A with WiFi.
  • Mbed Simulator.
Committer:
Jan Jongboom
Date:
Fri Jul 28 14:26:26 2017 +0200
Revision:
15:ffc77f212382
Parent:
11:96e4dcb9c0c2
Child:
17:6e0025e01b98
Add request parsing to prepare for HTTP server example

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 0:910f5949759f 35
Jan Jongboom 0:910f5949759f 36 /**
Jan Jongboom 0:910f5949759f 37 * \brief HttpRequest implements the logic for interacting with HTTPS servers.
Jan Jongboom 0:910f5949759f 38 */
Jan Jongboom 0:910f5949759f 39 class HttpRequest {
Jan Jongboom 0:910f5949759f 40 public:
Jan Jongboom 0:910f5949759f 41 /**
Jan Jongboom 0:910f5949759f 42 * HttpRequest Constructor
Jan Jongboom 0:910f5949759f 43 *
Jan Jongboom 0:910f5949759f 44 * @param[in] aNetwork The network interface
Jan Jongboom 0:910f5949759f 45 * @param[in] aMethod HTTP method to use
Jan Jongboom 0:910f5949759f 46 * @param[in] url URL to the resource
Jan Jongboom 0:910f5949759f 47 * @param[in] aBodyCallback Callback on which to retrieve chunks of the response body.
Jan Jongboom 0:910f5949759f 48 If not set, the complete body will be allocated on the HttpResponse object,
Jan Jongboom 0:910f5949759f 49 which might use lots of memory.
Jan Jongboom 0:910f5949759f 50 */
Jan Jongboom 0:910f5949759f 51 HttpRequest(NetworkInterface* aNetwork, http_method aMethod, const char* url, Callback<void(const char *at, size_t length)> aBodyCallback = 0)
Jan Jongboom 0:910f5949759f 52 : network(aNetwork), method(aMethod), body_callback(aBodyCallback)
Jan Jongboom 0:910f5949759f 53 {
Jan Jongboom 0:910f5949759f 54 error = 0;
Jan Jongboom 0:910f5949759f 55 response = NULL;
Jan Jongboom 0:910f5949759f 56
Jan Jongboom 0:910f5949759f 57 parsed_url = new ParsedUrl(url);
Jan Jongboom 0:910f5949759f 58 request_builder = new HttpRequestBuilder(method, parsed_url);
Jan Jongboom 11:96e4dcb9c0c2 59
Jan Jongboom 11:96e4dcb9c0c2 60 socket = new TCPSocket();
Jan Jongboom 11:96e4dcb9c0c2 61 we_created_socket = true;
Jan Jongboom 11:96e4dcb9c0c2 62 }
Jan Jongboom 11:96e4dcb9c0c2 63
Jan Jongboom 11:96e4dcb9c0c2 64 /**
Jan Jongboom 11:96e4dcb9c0c2 65 * HttpRequest Constructor
Jan Jongboom 11:96e4dcb9c0c2 66 *
Jan Jongboom 11:96e4dcb9c0c2 67 * @param[in] aSocket An open TCPSocket
Jan Jongboom 11:96e4dcb9c0c2 68 * @param[in] aMethod HTTP method to use
Jan Jongboom 11:96e4dcb9c0c2 69 * @param[in] url URL to the resource
Jan Jongboom 11:96e4dcb9c0c2 70 * @param[in] aBodyCallback Callback on which to retrieve chunks of the response body.
Jan Jongboom 11:96e4dcb9c0c2 71 If not set, the complete body will be allocated on the HttpResponse object,
Jan Jongboom 11:96e4dcb9c0c2 72 which might use lots of memory.
Jan Jongboom 11:96e4dcb9c0c2 73 */
Jan Jongboom 11:96e4dcb9c0c2 74 HttpRequest(TCPSocket* aSocket, http_method aMethod, const char* url, Callback<void(const char *at, size_t length)> aBodyCallback = 0)
Jan Jongboom 11:96e4dcb9c0c2 75 : socket(aSocket), method(aMethod), body_callback(aBodyCallback)
Jan Jongboom 11:96e4dcb9c0c2 76 {
Jan Jongboom 11:96e4dcb9c0c2 77 error = 0;
Jan Jongboom 11:96e4dcb9c0c2 78 response = NULL;
Jan Jongboom 11:96e4dcb9c0c2 79 network = NULL;
Jan Jongboom 11:96e4dcb9c0c2 80
Jan Jongboom 11:96e4dcb9c0c2 81 parsed_url = new ParsedUrl(url);
Jan Jongboom 11:96e4dcb9c0c2 82 request_builder = new HttpRequestBuilder(method, parsed_url);
Jan Jongboom 11:96e4dcb9c0c2 83
Jan Jongboom 11:96e4dcb9c0c2 84 we_created_socket = false;
Jan Jongboom 0:910f5949759f 85 }
Jan Jongboom 0:910f5949759f 86
Jan Jongboom 0:910f5949759f 87 /**
Jan Jongboom 0:910f5949759f 88 * HttpRequest Constructor
Jan Jongboom 0:910f5949759f 89 */
Jan Jongboom 0:910f5949759f 90 ~HttpRequest() {
Jan Jongboom 0:910f5949759f 91 // should response be owned by us? Or should user free it?
Jan Jongboom 0:910f5949759f 92 // maybe implement copy constructor on response...
Jan Jongboom 0:910f5949759f 93 if (response) {
Jan Jongboom 0:910f5949759f 94 delete response;
Jan Jongboom 0:910f5949759f 95 }
Jan Jongboom 0:910f5949759f 96
Jan Jongboom 0:910f5949759f 97 if (parsed_url) {
Jan Jongboom 0:910f5949759f 98 delete parsed_url;
Jan Jongboom 0:910f5949759f 99 }
Jan Jongboom 0:910f5949759f 100
Jan Jongboom 0:910f5949759f 101 if (request_builder) {
Jan Jongboom 0:910f5949759f 102 delete request_builder;
Jan Jongboom 0:910f5949759f 103 }
Jan Jongboom 11:96e4dcb9c0c2 104
Jan Jongboom 11:96e4dcb9c0c2 105 if (socket && we_created_socket) {
Jan Jongboom 11:96e4dcb9c0c2 106 delete socket;
Jan Jongboom 11:96e4dcb9c0c2 107 }
Jan Jongboom 0:910f5949759f 108 }
Jan Jongboom 0:910f5949759f 109
Jan Jongboom 0:910f5949759f 110 /**
Jan Jongboom 0:910f5949759f 111 * Execute the request and receive the response.
Jan Jongboom 0:910f5949759f 112 */
Jan Jongboom 0:910f5949759f 113 HttpResponse* send(const void* body = NULL, nsapi_size_t body_size = 0) {
Jan Jongboom 0:910f5949759f 114 if (response != NULL) {
Jan Jongboom 0:910f5949759f 115 // already executed this response
Jan Jongboom 0:910f5949759f 116 error = -2100; // @todo, make a lookup table with errors
Jan Jongboom 0:910f5949759f 117 return NULL;
Jan Jongboom 0:910f5949759f 118 }
Jan Jongboom 0:910f5949759f 119
Jan Jongboom 0:910f5949759f 120 error = 0;
Jan Jongboom 0:910f5949759f 121
Jan Jongboom 11:96e4dcb9c0c2 122 if (we_created_socket) {
Jan Jongboom 11:96e4dcb9c0c2 123 nsapi_error_t open_result = socket->open(network);
Jan Jongboom 11:96e4dcb9c0c2 124 if (open_result != 0) {
Jan Jongboom 11:96e4dcb9c0c2 125 error = open_result;
Jan Jongboom 11:96e4dcb9c0c2 126 return NULL;
Jan Jongboom 11:96e4dcb9c0c2 127 }
Jan Jongboom 0:910f5949759f 128
Jan Jongboom 11:96e4dcb9c0c2 129 nsapi_error_t connection_result = socket->connect(parsed_url->host(), parsed_url->port());
Jan Jongboom 11:96e4dcb9c0c2 130 if (connection_result != 0) {
Jan Jongboom 11:96e4dcb9c0c2 131 error = connection_result;
Jan Jongboom 11:96e4dcb9c0c2 132 return NULL;
Jan Jongboom 11:96e4dcb9c0c2 133 }
Jan Jongboom 0:910f5949759f 134 }
Jan Jongboom 0:910f5949759f 135
Jan Jongboom 10:b017c7d2cf23 136 size_t request_size = 0;
Jan Jongboom 10:b017c7d2cf23 137 char* request = request_builder->build(body, body_size, request_size);
Jan Jongboom 0:910f5949759f 138
Jan Jongboom 11:96e4dcb9c0c2 139 nsapi_size_or_error_t send_result = socket->send(request, request_size);
Jan Jongboom 0:910f5949759f 140
Jan Jongboom 0:910f5949759f 141 free(request);
Jan Jongboom 0:910f5949759f 142
Jan Jongboom 0:910f5949759f 143 if (send_result != request_size) {
Jan Jongboom 0:910f5949759f 144 error = send_result;
Jan Jongboom 0:910f5949759f 145 return NULL;
Jan Jongboom 0:910f5949759f 146 }
Jan Jongboom 0:910f5949759f 147
Jan Jongboom 0:910f5949759f 148 // Create a response object
Jan Jongboom 0:910f5949759f 149 response = new HttpResponse();
Jan Jongboom 0:910f5949759f 150 // And a response parser
Jan Jongboom 15:ffc77f212382 151 HttpParser parser(response, HTTP_RESPONSE, body_callback);
Jan Jongboom 0:910f5949759f 152
Jan Jongboom 0:910f5949759f 153 // Set up a receive buffer (on the heap)
Jan Jongboom 0:910f5949759f 154 uint8_t* recv_buffer = (uint8_t*)malloc(HTTP_RECEIVE_BUFFER_SIZE);
Jan Jongboom 0:910f5949759f 155
Jan Jongboom 0:910f5949759f 156 // TCPSocket::recv is called until we don't have any data anymore
Jan Jongboom 0:910f5949759f 157 nsapi_size_or_error_t recv_ret;
Jan Jongboom 11:96e4dcb9c0c2 158 while ((recv_ret = socket->recv(recv_buffer, HTTP_RECEIVE_BUFFER_SIZE)) > 0) {
Jan Jongboom 3:8a6b003e3874 159
Jan Jongboom 0:910f5949759f 160 // Pass the chunk into the http_parser
Jan Jongboom 0:910f5949759f 161 size_t nparsed = parser.execute((const char*)recv_buffer, recv_ret);
Jan Jongboom 0:910f5949759f 162 if (nparsed != recv_ret) {
Jan Jongboom 0:910f5949759f 163 // printf("Parsing failed... parsed %d bytes, received %d bytes\n", nparsed, recv_ret);
Jan Jongboom 0:910f5949759f 164 error = -2101;
Jan Jongboom 0:910f5949759f 165 free(recv_buffer);
Jan Jongboom 0:910f5949759f 166 return NULL;
Jan Jongboom 0:910f5949759f 167 }
Jan Jongboom 3:8a6b003e3874 168
Jan Jongboom 7:2e3eedb9ca5c 169 if (response->is_message_complete()) {
Jan Jongboom 0:910f5949759f 170 break;
Jan Jongboom 0:910f5949759f 171 }
Jan Jongboom 0:910f5949759f 172 }
Jan Jongboom 0:910f5949759f 173 // error?
Jan Jongboom 0:910f5949759f 174 if (recv_ret < 0) {
Jan Jongboom 0:910f5949759f 175 error = recv_ret;
Jan Jongboom 0:910f5949759f 176 free(recv_buffer);
Jan Jongboom 0:910f5949759f 177 return NULL;
Jan Jongboom 0:910f5949759f 178 }
Jan Jongboom 0:910f5949759f 179
Jan Jongboom 0:910f5949759f 180 // When done, call parser.finish()
Jan Jongboom 0:910f5949759f 181 parser.finish();
Jan Jongboom 0:910f5949759f 182
Jan Jongboom 0:910f5949759f 183 // Free the receive buffer
Jan Jongboom 0:910f5949759f 184 free(recv_buffer);
Jan Jongboom 0:910f5949759f 185
Jan Jongboom 11:96e4dcb9c0c2 186 if (we_created_socket) {
Jan Jongboom 11:96e4dcb9c0c2 187 // Close the socket
Jan Jongboom 11:96e4dcb9c0c2 188 socket->close();
Jan Jongboom 11:96e4dcb9c0c2 189 }
Jan Jongboom 0:910f5949759f 190
Jan Jongboom 0:910f5949759f 191 return response;
Jan Jongboom 0:910f5949759f 192 }
Jan Jongboom 0:910f5949759f 193
Jan Jongboom 0:910f5949759f 194 /**
Jan Jongboom 0:910f5949759f 195 * Set a header for the request.
Jan Jongboom 0:910f5949759f 196 *
Jan Jongboom 0:910f5949759f 197 * The 'Host' and 'Content-Length' headers are set automatically.
Jan Jongboom 0:910f5949759f 198 * Setting the same header twice will overwrite the previous entry.
Jan Jongboom 0:910f5949759f 199 *
Jan Jongboom 0:910f5949759f 200 * @param[in] key Header key
Jan Jongboom 0:910f5949759f 201 * @param[in] value Header value
Jan Jongboom 0:910f5949759f 202 */
Jan Jongboom 0:910f5949759f 203 void set_header(string key, string value) {
Jan Jongboom 0:910f5949759f 204 request_builder->set_header(key, value);
Jan Jongboom 0:910f5949759f 205 }
Jan Jongboom 0:910f5949759f 206
Jan Jongboom 0:910f5949759f 207 /**
Jan Jongboom 0:910f5949759f 208 * Get the error code.
Jan Jongboom 0:910f5949759f 209 *
Jan Jongboom 0:910f5949759f 210 * When send() fails, this error is set.
Jan Jongboom 0:910f5949759f 211 */
Jan Jongboom 0:910f5949759f 212 nsapi_error_t get_error() {
Jan Jongboom 0:910f5949759f 213 return error;
Jan Jongboom 0:910f5949759f 214 }
Jan Jongboom 0:910f5949759f 215
Jan Jongboom 0:910f5949759f 216 private:
Jan Jongboom 0:910f5949759f 217 NetworkInterface* network;
Jan Jongboom 11:96e4dcb9c0c2 218 TCPSocket* socket;
Jan Jongboom 0:910f5949759f 219 http_method method;
Jan Jongboom 0:910f5949759f 220 Callback<void(const char *at, size_t length)> body_callback;
Jan Jongboom 0:910f5949759f 221
Jan Jongboom 0:910f5949759f 222 ParsedUrl* parsed_url;
Jan Jongboom 0:910f5949759f 223
Jan Jongboom 0:910f5949759f 224 HttpRequestBuilder* request_builder;
Jan Jongboom 0:910f5949759f 225 HttpResponse* response;
Jan Jongboom 0:910f5949759f 226
Jan Jongboom 11:96e4dcb9c0c2 227 bool we_created_socket;
Jan Jongboom 11:96e4dcb9c0c2 228
Jan Jongboom 0:910f5949759f 229 nsapi_error_t error;
Jan Jongboom 0:910f5949759f 230 };
Jan Jongboom 0:910f5949759f 231
Jan Jongboom 0:910f5949759f 232 #endif // _HTTP_REQUEST_