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 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?

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 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_