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:
Mon Aug 12 11:45:31 2019 +0200
Revision:
39:a8d157986ad8
Parent:
29:383e9bfbfbed
Fix parsed url leaking memory if path is empty

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Jan Jongboom 15:ffc77f212382 1 /*
Jan Jongboom 15:ffc77f212382 2 * PackageLicenseDeclared: Apache-2.0
Jan Jongboom 15:ffc77f212382 3 * Copyright (c) 2017 ARM Limited
Jan Jongboom 15:ffc77f212382 4 *
Jan Jongboom 15:ffc77f212382 5 * Licensed under the Apache License, Version 2.0 (the "License");
Jan Jongboom 15:ffc77f212382 6 * you may not use this file except in compliance with the License.
Jan Jongboom 15:ffc77f212382 7 * You may obtain a copy of the License at
Jan Jongboom 15:ffc77f212382 8 *
Jan Jongboom 15:ffc77f212382 9 * http://www.apache.org/licenses/LICENSE-2.0
Jan Jongboom 15:ffc77f212382 10 *
Jan Jongboom 15:ffc77f212382 11 * Unless required by applicable law or agreed to in writing, software
Jan Jongboom 15:ffc77f212382 12 * distributed under the License is distributed on an "AS IS" BASIS,
Jan Jongboom 15:ffc77f212382 13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
Jan Jongboom 15:ffc77f212382 14 * See the License for the specific language governing permissions and
Jan Jongboom 15:ffc77f212382 15 * limitations under the License.
Jan Jongboom 15:ffc77f212382 16 */
Jan Jongboom 15:ffc77f212382 17
Jan Jongboom 15:ffc77f212382 18 #ifndef _HTTP_RESPONSE_PARSER_H_
Jan Jongboom 15:ffc77f212382 19 #define _HTTP_RESPONSE_PARSER_H_
Jan Jongboom 15:ffc77f212382 20
Jan Jongboom 15:ffc77f212382 21 #include "http_parser.h"
Jan Jongboom 15:ffc77f212382 22 #include "http_response.h"
Jan Jongboom 15:ffc77f212382 23
Jan Jongboom 15:ffc77f212382 24 class HttpParser {
Jan Jongboom 15:ffc77f212382 25 public:
Jan Jongboom 15:ffc77f212382 26
Jan Jongboom 29:383e9bfbfbed 27 HttpParser(HttpResponse* a_response, http_parser_type parser_type, Callback<void(const char *at, uint32_t length)> a_body_callback = 0)
Jan Jongboom 15:ffc77f212382 28 : response(a_response), body_callback(a_body_callback)
Jan Jongboom 15:ffc77f212382 29 {
Jan Jongboom 15:ffc77f212382 30 settings = new http_parser_settings();
Jan Jongboom 15:ffc77f212382 31
Jan Jongboom 15:ffc77f212382 32 settings->on_message_begin = &HttpParser::on_message_begin_callback;
Jan Jongboom 15:ffc77f212382 33 settings->on_url = &HttpParser::on_url_callback;
Jan Jongboom 15:ffc77f212382 34 settings->on_status = &HttpParser::on_status_callback;
Jan Jongboom 15:ffc77f212382 35 settings->on_header_field = &HttpParser::on_header_field_callback;
Jan Jongboom 15:ffc77f212382 36 settings->on_header_value = &HttpParser::on_header_value_callback;
Jan Jongboom 15:ffc77f212382 37 settings->on_headers_complete = &HttpParser::on_headers_complete_callback;
Jan Jongboom 15:ffc77f212382 38 settings->on_chunk_header = &HttpParser::on_chunk_header_callback;
Jan Jongboom 15:ffc77f212382 39 settings->on_chunk_complete = &HttpParser::on_chunk_complete_callback;
Jan Jongboom 15:ffc77f212382 40 settings->on_body = &HttpParser::on_body_callback;
Jan Jongboom 15:ffc77f212382 41 settings->on_message_complete = &HttpParser::on_message_complete_callback;
Jan Jongboom 15:ffc77f212382 42
Jan Jongboom 15:ffc77f212382 43 // Construct the http_parser object
Jan Jongboom 15:ffc77f212382 44 parser = new http_parser();
Jan Jongboom 15:ffc77f212382 45 http_parser_init(parser, parser_type);
Jan Jongboom 15:ffc77f212382 46 parser->data = (void*)this;
Jan Jongboom 15:ffc77f212382 47 }
Jan Jongboom 15:ffc77f212382 48
Jan Jongboom 15:ffc77f212382 49 ~HttpParser() {
Jan Jongboom 15:ffc77f212382 50 if (parser) {
Jan Jongboom 15:ffc77f212382 51 delete parser;
Jan Jongboom 15:ffc77f212382 52 }
Jan Jongboom 15:ffc77f212382 53 if (settings) {
Jan Jongboom 15:ffc77f212382 54 delete settings;
Jan Jongboom 15:ffc77f212382 55 }
Jan Jongboom 15:ffc77f212382 56 }
Jan Jongboom 15:ffc77f212382 57
Jan Jongboom 29:383e9bfbfbed 58 uint32_t execute(const char* buffer, uint32_t buffer_size) {
Jan Jongboom 15:ffc77f212382 59 return http_parser_execute(parser, settings, buffer, buffer_size);
Jan Jongboom 15:ffc77f212382 60 }
Jan Jongboom 15:ffc77f212382 61
Jan Jongboom 15:ffc77f212382 62 void finish() {
Jan Jongboom 15:ffc77f212382 63 http_parser_execute(parser, settings, NULL, 0);
Jan Jongboom 15:ffc77f212382 64 }
Jan Jongboom 15:ffc77f212382 65
Jan Jongboom 15:ffc77f212382 66 private:
Jan Jongboom 15:ffc77f212382 67 // Member functions
Jan Jongboom 15:ffc77f212382 68 int on_message_begin(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 69 return 0;
Jan Jongboom 15:ffc77f212382 70 }
Jan Jongboom 15:ffc77f212382 71
Jan Jongboom 29:383e9bfbfbed 72 int on_url(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 73 string s(at, length);
Jan Jongboom 15:ffc77f212382 74 response->set_url(s);
Jan Jongboom 15:ffc77f212382 75 return 0;
Jan Jongboom 15:ffc77f212382 76 }
Jan Jongboom 15:ffc77f212382 77
Jan Jongboom 29:383e9bfbfbed 78 int on_status(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 79 string s(at, length);
Jan Jongboom 15:ffc77f212382 80 response->set_status(parser->status_code, s);
Jan Jongboom 15:ffc77f212382 81 return 0;
Jan Jongboom 15:ffc77f212382 82 }
Jan Jongboom 15:ffc77f212382 83
Jan Jongboom 29:383e9bfbfbed 84 int on_header_field(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 85 string s(at, length);
Jan Jongboom 15:ffc77f212382 86 response->set_header_field(s);
Jan Jongboom 15:ffc77f212382 87 return 0;
Jan Jongboom 15:ffc77f212382 88 }
Jan Jongboom 15:ffc77f212382 89
Jan Jongboom 29:383e9bfbfbed 90 int on_header_value(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 91 string s(at, length);
Jan Jongboom 15:ffc77f212382 92 response->set_header_value(s);
Jan Jongboom 15:ffc77f212382 93 return 0;
Jan Jongboom 15:ffc77f212382 94 }
Jan Jongboom 15:ffc77f212382 95
Jan Jongboom 15:ffc77f212382 96 int on_headers_complete(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 97 response->set_headers_complete();
Jan Jongboom 15:ffc77f212382 98 response->set_method((http_method)parser->method);
Jan Jongboom 15:ffc77f212382 99 return 0;
Jan Jongboom 15:ffc77f212382 100 }
Jan Jongboom 15:ffc77f212382 101
Jan Jongboom 29:383e9bfbfbed 102 int on_body(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 103 response->increase_body_length(length);
Jan Jongboom 15:ffc77f212382 104
Jan Jongboom 15:ffc77f212382 105 if (body_callback) {
Jan Jongboom 15:ffc77f212382 106 body_callback(at, length);
Jan Jongboom 15:ffc77f212382 107 return 0;
Jan Jongboom 15:ffc77f212382 108 }
Jan Jongboom 15:ffc77f212382 109
Jan Jongboom 15:ffc77f212382 110 response->set_body(at, length);
Jan Jongboom 15:ffc77f212382 111 return 0;
Jan Jongboom 15:ffc77f212382 112 }
Jan Jongboom 15:ffc77f212382 113
Jan Jongboom 15:ffc77f212382 114 int on_message_complete(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 115 response->set_message_complete();
Jan Jongboom 15:ffc77f212382 116
Jan Jongboom 15:ffc77f212382 117 return 0;
Jan Jongboom 15:ffc77f212382 118 }
Jan Jongboom 15:ffc77f212382 119
Jan Jongboom 15:ffc77f212382 120 int on_chunk_header(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 121 response->set_chunked();
Jan Jongboom 15:ffc77f212382 122
Jan Jongboom 15:ffc77f212382 123 return 0;
Jan Jongboom 15:ffc77f212382 124 }
Jan Jongboom 15:ffc77f212382 125
Jan Jongboom 15:ffc77f212382 126 int on_chunk_complete(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 127 return 0;
Jan Jongboom 15:ffc77f212382 128 }
Jan Jongboom 15:ffc77f212382 129
Jan Jongboom 15:ffc77f212382 130 // Static http_parser callback functions
Jan Jongboom 15:ffc77f212382 131 static int on_message_begin_callback(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 132 return ((HttpParser*)parser->data)->on_message_begin(parser);
Jan Jongboom 15:ffc77f212382 133 }
Jan Jongboom 15:ffc77f212382 134
Jan Jongboom 29:383e9bfbfbed 135 static int on_url_callback(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 136 return ((HttpParser*)parser->data)->on_url(parser, at, length);
Jan Jongboom 15:ffc77f212382 137 }
Jan Jongboom 15:ffc77f212382 138
Jan Jongboom 29:383e9bfbfbed 139 static int on_status_callback(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 140 return ((HttpParser*)parser->data)->on_status(parser, at, length);
Jan Jongboom 15:ffc77f212382 141 }
Jan Jongboom 15:ffc77f212382 142
Jan Jongboom 29:383e9bfbfbed 143 static int on_header_field_callback(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 144 return ((HttpParser*)parser->data)->on_header_field(parser, at, length);
Jan Jongboom 15:ffc77f212382 145 }
Jan Jongboom 15:ffc77f212382 146
Jan Jongboom 29:383e9bfbfbed 147 static int on_header_value_callback(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 148 return ((HttpParser*)parser->data)->on_header_value(parser, at, length);
Jan Jongboom 15:ffc77f212382 149 }
Jan Jongboom 15:ffc77f212382 150
Jan Jongboom 15:ffc77f212382 151 static int on_headers_complete_callback(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 152 return ((HttpParser*)parser->data)->on_headers_complete(parser);
Jan Jongboom 15:ffc77f212382 153 }
Jan Jongboom 15:ffc77f212382 154
Jan Jongboom 29:383e9bfbfbed 155 static int on_body_callback(http_parser* parser, const char *at, uint32_t length) {
Jan Jongboom 15:ffc77f212382 156 return ((HttpParser*)parser->data)->on_body(parser, at, length);
Jan Jongboom 15:ffc77f212382 157 }
Jan Jongboom 15:ffc77f212382 158
Jan Jongboom 15:ffc77f212382 159 static int on_message_complete_callback(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 160 return ((HttpParser*)parser->data)->on_message_complete(parser);
Jan Jongboom 15:ffc77f212382 161 }
Jan Jongboom 15:ffc77f212382 162
Jan Jongboom 15:ffc77f212382 163 static int on_chunk_header_callback(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 164 return ((HttpParser*)parser->data)->on_chunk_header(parser);
Jan Jongboom 15:ffc77f212382 165 }
Jan Jongboom 15:ffc77f212382 166
Jan Jongboom 15:ffc77f212382 167 static int on_chunk_complete_callback(http_parser* parser) {
Jan Jongboom 15:ffc77f212382 168 return ((HttpParser*)parser->data)->on_chunk_complete(parser);
Jan Jongboom 15:ffc77f212382 169 }
Jan Jongboom 15:ffc77f212382 170
Jan Jongboom 15:ffc77f212382 171 HttpResponse* response;
Jan Jongboom 29:383e9bfbfbed 172 Callback<void(const char *at, uint32_t length)> body_callback;
Jan Jongboom 15:ffc77f212382 173 http_parser* parser;
Jan Jongboom 15:ffc77f212382 174 http_parser_settings* settings;
Jan Jongboom 15:ffc77f212382 175 };
Jan Jongboom 15:ffc77f212382 176
Jan Jongboom 15:ffc77f212382 177 #endif // _HTTP_RESPONSE_PARSER_H_