http_server.h

/*
 * MIT License
 * 
 * Copyright (c) 2024 Lorenzo Chesi
 * 
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 * 
 * The above copyright notice and this permission notice shall be included in all
 * copies or substantial portions of the Software.
 * 
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */
 
#ifndef _HTTP_SERVER_H_
#define _HTTP_SERVER_H_
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include <http_parser.h>
 
#ifdef __linux__
#include <sys/socket.h>
#include <sys/select.h>
#else
#include <sockLib.h>
#include <hostLib.h>
#include <selectLib.h>
#endif
#include <arpa/inet.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdbool.h>
#include <pthread.h>
 
/* GLOBAL DEFINITION *****************************************************************/
 
#ifndef HTTP_MAX_HANDLERS
#define HTTP_MAX_HANDLERS 128
#endif
 
#ifndef HTTP_MAX_WORKERS
#define HTTP_MAX_WORKERS 4
#endif
 
/* UTILITY FUNCTIONS ************************************************************************/
 
#define IMPORT_FILE(file, sym) \
__asm__( \
    ".section \".rodata\" \n" \
    ".global " #sym "\n" \
    ".balign 16\n" \
    #sym":\n"  \
    ".incbin \"" file "\"\n" \
    #sym "_end:\n" \
    ".balign 16\n" \
    ".global _sizeof_" #sym "\n" \
    "_sizeof_" #sym":\n"  \
    ".long " #sym "_end - " #sym "\n" \
    ".section \".text\" \n" \
); \
extern __attribute__((aligned(16))) const size_t _sizeof_ ## sym; \
extern __attribute__((aligned(16))) __attribute__((nonstring)) const char sym[]
 
int send_http_response(int socket, enum http_status status, const char* header, const char* content, size_t content_lenght);
 
/* HTTP SERVER TYPES ***************************************************************************/
 
typedef int(*HttpCallback)(int socket, void* data);
 
struct HttpHandler {
    enum http_method method;
    const char* url; 
    HttpCallback callback;
    void* data; 
};
 
enum HttpRequestState {
    HTTP_WORKER_REQUEST_EMPTY,
    HTTP_WORKER_REQUEST_READY,
    HTTP_WORKER_REQUEST_RUNNING
};
 
enum HttpServerState {
    HTTP_SERVER_STOPPED,
    HTTP_SERVER_INITIALIZED,
    HTTP_SERVER_RUNNING,
    HTTP_SERVER_STOPPING
};
 
struct HttpRequest {
    int socket; 
    enum HttpRequestState state;
    union {
        const struct HttpHandler* handlers; 
        const struct HttpHandler* handler; 
    } ptr;
};
 
 
/* HTTP SERVER FUNCTIONS ***********************************************************************************/
 
struct HttpServer {
    /* READ-ONLY */
 
    enum HttpServerState state; 
 
    /* PRIVATE */
 
    pthread_t _thread;
    int _listener;
    struct sockaddr_in _addr; 
    fd_set _master_set; 
    struct HttpHandler _handlers[HTTP_MAX_HANDLERS]; 
    pthread_t _workers[HTTP_MAX_WORKERS]; 
    struct HttpRequest _requests[HTTP_MAX_WORKERS]; 
    pthread_mutex_t _mutex_sync; 
    pthread_cond_t _cond_sync; 
};
 
int http_server_init(struct HttpServer* this, const char address[], uint16_t port);
 
int http_server_add_handler(struct HttpServer* this, enum http_method method, const char* url, HttpCallback callback, void* data);
 
int http_server_start(struct HttpServer* this);
 
int http_server_stop(struct HttpServer* this);
 
int http_server_join(struct HttpServer* this);
 
#ifdef __cplusplus
}
#endif
#endif