server.h

Go to the documentation of this file.

/*
 * Copyright (c) 2023, Emna Rekik
 * Copyright (c) 2024 Nordic Semiconductor ASA
 *
 * SPDX-License-Identifier: Apache-2.0
 */
 
#ifndef ZEPHYR_INCLUDE_NET_HTTP_SERVER_H_
#define ZEPHYR_INCLUDE_NET_HTTP_SERVER_H_
 
#include <stdint.h>
 
#include <zephyr/kernel.h>
#include <zephyr/net/http/parser.h>
#include <zephyr/net/http/hpack.h>
#include <zephyr/net/socket.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
#if defined(CONFIG_HTTP_SERVER)
#define HTTP_SERVER_CLIENT_BUFFER_SIZE   CONFIG_HTTP_SERVER_CLIENT_BUFFER_SIZE
#define HTTP_SERVER_MAX_STREAMS          CONFIG_HTTP_SERVER_MAX_STREAMS
#define HTTP_SERVER_MAX_CONTENT_TYPE_LEN CONFIG_HTTP_SERVER_MAX_CONTENT_TYPE_LENGTH
#define HTTP_SERVER_MAX_URL_LENGTH       CONFIG_HTTP_SERVER_MAX_URL_LENGTH
#else
#define HTTP_SERVER_CLIENT_BUFFER_SIZE   0
#define HTTP_SERVER_MAX_STREAMS          0
#define HTTP_SERVER_MAX_CONTENT_TYPE_LEN 0
#define HTTP_SERVER_MAX_URL_LENGTH       0
#endif
 
/* Maximum header field name / value length. This is only used to detect Upgrade and
 * websocket header fields and values in the http1 server so the value is quite short.
 */
#define HTTP_SERVER_MAX_HEADER_LEN 32
 
#define HTTP2_PREFACE "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n"
 
enum http_resource_type {
        HTTP_RESOURCE_TYPE_STATIC,
 
        HTTP_RESOURCE_TYPE_DYNAMIC,
 
        HTTP_RESOURCE_TYPE_WEBSOCKET,
};
 
struct http_resource_detail {
        uint32_t bitmask_of_supported_http_methods;
 
        enum http_resource_type type;
 
        int path_len;
 
        const char *content_encoding;
 
        const char *content_type;
};
 
BUILD_ASSERT(NUM_BITS(
             sizeof(((struct http_resource_detail *)0)->bitmask_of_supported_http_methods))
             >= (HTTP_METHOD_END_VALUE - 1));
struct http_resource_detail_static {
        struct http_resource_detail common;
 
        const void *static_data;
 
        size_t static_data_len;
};
 
/* Make sure that the common is the first in the struct. */
BUILD_ASSERT(offsetof(struct http_resource_detail_static, common) == 0);
struct http_client_ctx;
 
enum http_data_status {
        HTTP_SERVER_DATA_ABORTED = -1,
        HTTP_SERVER_DATA_MORE = 0,
        HTTP_SERVER_DATA_FINAL = 1,
};
 
typedef int (*http_resource_dynamic_cb_t)(struct http_client_ctx *client,
                                          enum http_data_status status,
                                          uint8_t *data_buffer,
                                          size_t data_len,
                                          void *user_data);
 
struct http_resource_detail_dynamic {
        struct http_resource_detail common;
 
        http_resource_dynamic_cb_t cb;
 
        uint8_t *data_buffer;
 
        size_t data_buffer_len;
 
        struct http_client_ctx *holder;
 
        void *user_data;
};
 
BUILD_ASSERT(offsetof(struct http_resource_detail_dynamic, common) == 0);
typedef int (*http_resource_websocket_cb_t)(int ws_socket,
                                            void *user_data);
 
struct http_resource_detail_websocket {
        struct http_resource_detail common;
 
        int ws_sock;
 
        http_resource_websocket_cb_t cb;
 
        uint8_t *data_buffer;
 
        size_t data_buffer_len;
 
        void *user_data;
};
 
BUILD_ASSERT(offsetof(struct http_resource_detail_websocket, common) == 0);
enum http_stream_state {
        HTTP_SERVER_STREAM_IDLE,
        HTTP_SERVER_STREAM_RESERVED_LOCAL,
        HTTP_SERVER_STREAM_RESERVED_REMOTE,
        HTTP_SERVER_STREAM_OPEN,
        HTTP_SERVER_STREAM_HALF_CLOSED_LOCAL,
        HTTP_SERVER_STREAM_HALF_CLOSED_REMOTE,
        HTTP_SERVER_STREAM_CLOSED
};
 
enum http_server_state {
        HTTP_SERVER_FRAME_HEADER_STATE,
        HTTP_SERVER_PREFACE_STATE,
        HTTP_SERVER_REQUEST_STATE,
        HTTP_SERVER_FRAME_DATA_STATE,
        HTTP_SERVER_FRAME_HEADERS_STATE,
        HTTP_SERVER_FRAME_SETTINGS_STATE,
        HTTP_SERVER_FRAME_PRIORITY_STATE,
        HTTP_SERVER_FRAME_WINDOW_UPDATE_STATE,
        HTTP_SERVER_FRAME_CONTINUATION_STATE,
        HTTP_SERVER_FRAME_PING_STATE,
        HTTP_SERVER_FRAME_RST_STREAM_STATE,
        HTTP_SERVER_FRAME_GOAWAY_STATE,
        HTTP_SERVER_DONE_STATE,
};
 
enum http1_parser_state {
        HTTP1_INIT_HEADER_STATE,
        HTTP1_WAITING_HEADER_STATE,
        HTTP1_RECEIVING_HEADER_STATE,
        HTTP1_RECEIVED_HEADER_STATE,
        HTTP1_RECEIVING_DATA_STATE,
        HTTP1_MESSAGE_COMPLETE_STATE,
};
 
#define HTTP_SERVER_INITIAL_WINDOW_SIZE 65536
#define HTTP_SERVER_WS_MAX_SEC_KEY_LEN 32
 
struct http_stream_ctx {
        int stream_id; 
        enum http_stream_state stream_state; 
        int window_size; 
};
 
struct http_frame {
        uint32_t length; 
        uint32_t stream_identifier; 
        uint8_t type; 
        uint8_t flags; 
        uint8_t *payload; 
};
 
struct http_client_ctx {
        int fd;
 
        unsigned char buffer[HTTP_SERVER_CLIENT_BUFFER_SIZE];
 
        unsigned char *cursor;
 
        size_t data_len;
 
        int window_size;
 
        enum http_server_state server_state;
 
        struct http_frame current_frame;
 
        struct http_resource_detail *current_detail;
 
        struct http_hpack_header_buf header_field;
 
        struct http_stream_ctx streams[HTTP_SERVER_MAX_STREAMS];
 
        struct http_parser_settings parser_settings;
 
        struct http_parser parser;
 
        unsigned char url_buffer[HTTP_SERVER_MAX_URL_LENGTH];
 
        unsigned char content_type[HTTP_SERVER_MAX_CONTENT_TYPE_LEN];
 
        unsigned char header_buffer[HTTP_SERVER_MAX_HEADER_LEN];
 
        size_t content_len;
 
        enum http_method method;
 
        enum http1_parser_state parser_state;
 
        int http1_frag_data_len;
 
        struct k_work_delayable inactivity_timer;
 
        IF_ENABLED(CONFIG_WEBSOCKET, (uint8_t ws_sec_key[HTTP_SERVER_WS_MAX_SEC_KEY_LEN]));
        bool headers_sent : 1;
 
        bool preface_sent : 1;
 
        bool has_upgrade_header : 1;
 
        bool http2_upgrade : 1;
 
        bool websocket_upgrade : 1;
 
        bool websocket_sec_key_next : 1;
};
 
int http_server_start(void);
 
int http_server_stop(void);
 
#ifdef __cplusplus
}
#endif
 
#endif