vsf_linux_httpd.h

Go to the documentation of this file.

/*****************************************************************************
 *   Copyright(C)2009-2022 by VSF Team                                       *
 *                                                                           *
 *  Licensed under the Apache License, Version 2.0 (the "License");          *
 *  you may not use this file except in compliance with the License.         *
 *  You may obtain a copy of the License at                                  *
 *                                                                           *
 *     http://www.apache.org/licenses/LICENSE-2.0                            *
 *                                                                           *
 *  Unless required by applicable law or agreed to in writing, software      *
 *  distributed under the License is distributed on an "AS IS" BASIS,        *
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. *
 *  See the License for the specific language governing permissions and      *
 *  limitations under the License.                                           *
 *                                                                           *
 ****************************************************************************/
 
#ifndef __VSF_LINUX_HTTPD_H__
#define __VSF_LINUX_HTTPD_H__
 
/*============================ INCLUDES ======================================*/
 
#include "shell/sys/linux/vsf_linux_cfg.h"
#include "service/vsf_service.h"
 
#if VSF_LINUX_CFG_RELATIVE_PATH == ENABLED
#   include "../../include/sys/socket.h"
#   include "../../include/netinet/in.h"
#else
#   include <sys/socket.h>
#   include <netinet/in.h>
#endif
 
#undef __VSF_LINUX_HTTPD_PUBLIC_CONST__
#if     defined(__VSF_LINUX_HTTPD_CLASS_IMPLEMENT)
#   define __VSF_CLASS_IMPLEMENT__
#   define __VSF_LINUX_HTTPD_PUBLIC_CONST__
#elif   defined(__VSF_LINUX_HTTPD_CLASS_INHERIT__)
#   define __VSF_CLASS_INHERIT__
#   define __VSF_LINUX_HTTPD_PUBLIC_CONST__
#else
#   define __VSF_LINUX_HTTPD_PUBLIC_CONST__             const
#endif
 
#include "utilities/ooc_class.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
/*============================ MACROS ========================================*/
 
#ifndef VSF_LINUX_HTTPD_CFG_REQUEST_BUFSIZE
#   define VSF_LINUX_HTTPD_CFG_REQUEST_BUFSIZE          1024
#endif
#ifndef VSF_LINUX_HTTPD_CFG_PRIV_SIZE
#   define VSF_LINUX_HTTPD_CFG_PRIV_SIZE                256
#endif
 
#ifndef VSF_LINUX_HTTPD_CFG_FILESYSTEM
#   define VSF_LINUX_HTTPD_CFG_FILESYSTEM               ENABLED
#endif
#ifndef VSF_LINUX_HTTPD_CFG_WEBSOCKET
// websocket depends on mbedtls for sha1 and base64
#   define VSF_LINUX_HTTPD_CFG_WEBSOCKET                VSF_USE_MBEDTLS
#endif
 
/*============================ MACROFIED FUNCTIONS ===========================*/
/*============================ TYPES =========================================*/
 
vsf_dcl_class(vsf_linux_httpd_request_t)
vsf_dcl_class(vsf_linux_httpd_t)
 
typedef enum vsf_linux_httpd_request_method_t {
    VSF_LINUX_HTTPD_GET,
    VSF_LINUX_HTTPD_POST,
    VSF_LINUX_HTTPD_METHOD_NUM,
 
    // not supported below, DO NOT USE
    VSF_LINUX_HTTPD_HEAD,
    VSF_LINUX_HTTPD_PUT,
    VSF_LINUX_HTTPD_DELETE,
    VSF_LINUX_HTTPD_CONNECT,
    VSF_LINUX_HTTPD_OPTIONS,
    VSF_LINUX_HTTPD_TRACE,
    VSF_LINUX_HTTPD_PATCH,
} vsf_linux_httpd_request_method_t;
 
typedef enum vsf_linux_httpd_mime_t {
    VSF_LINUX_HTTPD_MIME_INVALID = 0,
    VSF_LINUX_HTTPD_MIME_TEXT_HTML,
    VSF_LINUX_HTTPD_MIME_TEXT_XML,
    VSF_LINUX_HTTPD_MIME_TEXT_CSS,
    VSF_LINUX_HTTPD_MIME_TEXT_PLAIN,
    VSF_LINUX_HTTPD_MIME_IMAGE_GIF,
    VSF_LINUX_HTTPD_MIME_IMAGE_PNG,
    VSF_LINUX_HTTPD_MIME_IMAGE_JPEG,
    VSF_LINUX_HTTPD_MIME_IMAGE_SVG,
    VSF_LINUX_HTTPD_MIME_IMAGE_ICON,
    VSF_LINUX_HTTPD_MIME_VIDEO_AVI,
    VSF_LINUX_HTTPD_MIME_AUDIO_MPEG,
    VSF_LINUX_HTTPD_MIME_AUDIO_WAV,
    VSF_LINUX_HTTPD_MIME_AUDIO_OGG,
    VSF_LINUX_HTTPD_MIME_APP_PDF,
    VSF_LINUX_HTTPD_MIME_APP_JS,
    VSF_LINUX_HTTPD_MIME_APP_TAR,
    VSF_LINUX_HTTPD_MIME_APP_ZIP,
    VSF_LINUX_HTTPD_MIME_APP_JSON,
    VSF_LINUX_HTTPD_MIME_APP_WASM,
    VSF_LINUX_HTTPD_MIME_ANY,
    VSF_LINUX_HTTPD_MIME_NUM = VSF_LINUX_HTTPD_MIME_ANY,
} vsf_linux_httpd_mime_t;
 
dcl_vsf_bitmap(vsf_linux_httpd_mime_map_t, VSF_LINUX_HTTPD_MIME_NUM)
 
typedef enum vsf_linux_httpd_encoding_t {
    VSF_LINUX_HTTPD_ENCODING_INVALID = 0,
    VSF_LINUX_HTTPD_ENCODING_IDENTITY = VSF_LINUX_HTTPD_ENCODING_INVALID,
    VSF_LINUX_HTTPD_ENCODING_GZIP,
    VSF_LINUX_HTTPD_ENCODING_NUM = VSF_LINUX_HTTPD_ENCODING_GZIP,
} vsf_linux_httpd_encoding_t;
 
dcl_vsf_bitmap(vsf_linux_httpd_encoding_map_t, VSF_LINUX_HTTPD_ENCODING_NUM)
 
typedef enum vsf_linux_httpd_charset_t {
    VSF_LINUX_HTTPD_CHARSET_INVALID = 0,
    VSF_LINUX_HTTPD_CHARSET_UTF8,
    VSF_LINUX_HTTPD_CHARSET_NUM = VSF_LINUX_HTTPD_CHARSET_UTF8,
} vsf_linux_httpd_charset_t;
 
typedef enum vsf_linux_httpd_language_t {
    VSF_LINUX_HTTPD_LANGUAGE_INVALID = 0,
    VSF_LINUX_HTTPD_ENGLISH,
} vsf_linux_httpd_language_t;
 
typedef enum vsf_linux_httpd_response_t {
    VSF_LINUX_HTTPD_CONTINUE = 100,
 
    VSF_LINUX_HTTPD_OK = 200,
 
    VSF_LINUX_HTTPD_MULTIPLE_CHOICES = 300,
 
    VSF_LINUX_HTTPD_BAD_REQUEST = 400,
    VSF_LINUX_HTTPD_UNAUTHORIZED,
    VSF_LINUX_HTTPD_PAYMENT_REQUIRED,
    VSF_LINUX_HTTPD_FORBIDDEN,
    VSF_LINUX_HTTPD_NOT_FOUND,
    VSF_LINUX_HTTPD_METHOD_NOT_ALLOWED,
    VSF_LINUX_HTTPD_NOT_ACCEPTABLE,
    VSF_LINUX_HTTPD_PROXY_AUTHENTICATION_REQUIRED,
    VSF_LINUX_HTTPD_REQUEST_TIME_OUT,
    VSF_LINUX_HTTPD_CONFLICT,
    VSF_LINUX_HTTPD_GONE,
    VSF_LINUX_HTTPD_LENGTH_REQUIRED,
    VSF_LINUX_HTTPD_PRECONDITION_FAILED,
    VSF_LINUX_HTTPD_REQUEST_ENITIY_TOO_LARGE,
    VSF_LINUX_HTTPD_REQUEST_URI_TOO_LARGE,
    VSF_LINUX_HTTPD_UNSUPPORTED_MEDIA_TYPE,
    VSF_LINUX_HTTPD_REQUESTED_RANGE_NOT_SATISFIABLE,
    VSF_LINUX_HTTPD_EXPECTATION_FAILED,
 
    VSF_LINUX_HTTPD_INTERNAL_SERVER_ERROR = 500,
    VSF_LINUX_HTTPD_NOT_IMPLEMENT,
    VSF_LINUX_HTTPD_BAD_GATEWAY,
    VSF_LINUX_HTTPD_SERVICE_UNAVAILABLE,
    VSF_LINUX_HTTPD_GATEWAY_TIME_OUT,
    VSF_LINUX_HTTPD_HTTP_VERSION_NOT_SUPPORTED,
} vsf_linux_httpd_response_t;
 
typedef struct vsf_linux_httpd_urihandler_op_t {
    vsf_err_t (*init_fn)(vsf_linux_httpd_request_t *req, uint8_t *data, uint_fast32_t size);
    vsf_err_t (*fini_fn)(vsf_linux_httpd_request_t *req);
    vsf_err_t (*serve_fn)(vsf_linux_httpd_request_t *req);
 
    void (*stream_evthandler_fn)(vsf_stream_t *stream, void *param, vsf_stream_evt_t evt);
} vsf_linux_httpd_urihandler_op_t;
 
typedef enum vsf_linux_httpd_urihandler_match_t {
    VSF_LINUX_HTTPD_URI_MATCH_EXT = 1 << 0,
    VSF_LINUX_HTTPD_URI_MATCH_URI = 1 << 1,
    VSF_LINUX_HTTPD_URI_MATCH_ANY = 1 << 2,
} vsf_linux_httpd_urihandler_match_t;
 
typedef enum vsf_linux_httpd_urihandler_type_t {
    VSF_LINUX_HTTPD_URI_OP = 0,
    VSF_LINUX_HTTPD_URI_REMAP,
} vsf_linux_httpd_urihandler_type_t;
 
/*============================ INCLUDES ======================================*/
 
#ifdef __cplusplus
}
#endif
 
#if VSF_LINUX_HTTPD_CFG_FILESYSTEM == ENABLED
#   include "./urihandler/file/__vsf_linux_urihandler_file.h"
#endif
#if VSF_LINUX_HTTPD_CFG_WEBSOCKET == ENABLED
#   include "./urihandler/websocket/__vsf_linux_urihandler_websocket.h"
#endif
 
#ifdef __cplusplus
extern "C" {
#endif
 
/*============================ TYPES =========================================*/
 
typedef struct vsf_linux_httpd_urihandler_t {
    // ored value of vsf_linux_httpd_urihandler_match_t
    vsf_linux_httpd_urihandler_match_t match;
    vsf_linux_httpd_urihandler_type_t type;
 
    char *ext;
    char *uri;
 
    union {
        const vsf_linux_httpd_urihandler_op_t *op;
        // for remap urihandler
        char *target_uri;
    };
 
    union {
        // parameters for specified urihandler_op
 
        // for buffer_urihandler
        struct {
            uint8_t *ptr;
            uint32_t size;
        } buffer;
 
#if VSF_LINUX_HTTPD_CFG_WEBSOCKET == ENABLED
        struct {
            void *param;
            vsf_linux_httpd_websocket_onopen_t on_open;
            vsf_linux_httpd_websocket_onclose_t on_close;
            vsf_linux_httpd_websocket_onerror_t on_error;
            vsf_linux_httpd_websocket_onmessage_t on_message;
        } websocket;
#endif
    };
 
    int (*poll_fn)(vsf_linux_httpd_request_t *req, fd_set *rset, fd_set *wset, bool prepare);
} vsf_linux_httpd_urihandler_t;
 
typedef struct vsf_linux_httpd_urihandler_header_t {
    vsf_mem_stream_t stream;
} vsf_linux_httpd_urihandler_header_t;
 
typedef struct vsf_linux_httpd_urihandler_header_t vsf_linux_httpd_urihandler_buffer_t;
 
vsf_class(vsf_linux_httpd_request_t) {
    protected_member(
        vsf_linux_httpd_request_method_t method;
        vsf_linux_httpd_mime_t mime;
        vsf_linux_httpd_charset_t charset;
        vsf_linux_httpd_encoding_t encoding;
        vsf_linux_httpd_language_t language;
        vsf_bitmap(vsf_linux_httpd_mime_map_t) mime_map;
        vsf_bitmap(vsf_linux_httpd_encoding_map_t) encoding_map;
        uint32_t content_length;
        char *uri;
        char *query;
        bool keep_alive;
        bool is_stream_out_started;
        bool upgrade;
 
#if VSF_LINUX_HTTPD_CFG_WEBSOCKET == ENABLED
        bool websocket;
        char *websocket_key;
#endif
 
        const vsf_linux_httpd_urihandler_t *urihandler;
        vsf_stream_t *stream_in, *stream_out;
        vsf_linux_httpd_response_t response;
 
        uint8_t buffer[VSF_LINUX_HTTPD_CFG_REQUEST_BUFSIZE];
        uint16_t buffer_pos;
        uint16_t buffer_length;
 
        union {
#if VSF_LINUX_HTTPD_CFG_FILESYSTEM == ENABLED
            vsf_linux_httpd_urihandler_file_t file;
#endif
#if VSF_LINUX_HTTPD_CFG_WEBSOCKET == ENABLED
            vsf_linux_httpd_urihandler_websocket_t websocket;
#endif
            vsf_linux_httpd_urihandler_buffer_t buffer;
            vsf_linux_httpd_urihandler_header_t header;
            uint8_t priv[VSF_LINUX_HTTPD_CFG_PRIV_SIZE];
        } urihandler_ctx;
    )
    public_member(
        void *target;
    )
};
 
vsf_class(vsf_linux_httpd_session_t) {
    private_member(
        vsf_dlist_node_t session_node;
        vsf_linux_httpd_request_t request;
 
        int fd_socket;
        int fd_stream_out, fd_stream_in;
 
        bool wait_stream_out, wait_stream_in;
        bool fatal_error;
 
        struct sockaddr_in client_addr;
        vsf_linux_httpd_t *httpd;
    )
};
 
#if defined(VSF_LINUX_HTTPD_CFG_SESSION_POOL_SIZE) && (VSF_LINUX_HTTPD_CFG_SESSION_POOL_SIZE > 0)
dcl_vsf_pool(vsf_linux_httpd_session_pool)
def_vsf_pool(vsf_linux_httpd_session_pool, vsf_linux_httpd_session_t)
#endif
 
vsf_class(vsf_linux_httpd_t) {
    public_member(
        __VSF_LINUX_HTTPD_PUBLIC_CONST__ char *root_path;
        __VSF_LINUX_HTTPD_PUBLIC_CONST__ uint16_t port;
        __VSF_LINUX_HTTPD_PUBLIC_CONST__ uint8_t backlog;
 
        __VSF_LINUX_HTTPD_PUBLIC_CONST__ uint16_t num_of_urihandler;
        __VSF_LINUX_HTTPD_PUBLIC_CONST__ vsf_linux_httpd_urihandler_t *urihandler;
    )
    private_member(
        vsf_dlist_t session_list;
#if defined(VSF_LINUX_HTTPD_CFG_SESSION_POOL_SIZE) && (VSF_LINUX_HTTPD_CFG_SESSION_POOL_SIZE > 0)
        vsf_pool(vsf_linux_httpd_session_pool) session_pool;
        vsf_pool_item(vsf_linux_httpd_session_pool) sessions[VSF_LINUX_HTTPD_CFG_SESSION_POOL_SIZE];
#endif
    )
};
 
#undef PUBLIC_CONST
 
/*============================ GLOBAL VARIABLES ==============================*/
 
extern const vsf_linux_httpd_urihandler_op_t vsf_linux_httpd_urihandler_buffer_op;
 
/*============================ PROTOTYPES ====================================*/
 
// httpd thread
extern void * vsf_linux_httpd_thread(void *param);
// vsf_linux_httpd_start will call pthread_create to run vsf_linux_httpd_thread
extern vsf_err_t vsf_linux_httpd_start(vsf_linux_httpd_t *httpd);
 
#ifdef __cplusplus
}
#endif
 
#undef __VSF_LINUX_HTTPD_CLASS_IMPLEMENT
#undef __VSF_LINUX_HTTPD_CLASS_INHERIT__
 
#endif
/* EOF */