http.h

Go to the documentation of this file.

 
#ifdef FLECS_HTTP
 
#if !defined(FLECS_OS_API_IMPL) && !defined(FLECS_NO_OS_API_IMPL)
#define FLECS_OS_API_IMPL
#endif
 
#ifndef FLECS_HTTP_H
#define FLECS_HTTP_H
 
/* Maximum number of headers in request */
#define ECS_HTTP_HEADER_COUNT_MAX (32)
 
/* Maximum number of query parameters in request */
#define ECS_HTTP_QUERY_PARAM_COUNT_MAX (32)
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct ecs_http_server_t ecs_http_server_t;
 
typedef struct {
    uint64_t id;
    ecs_http_server_t *server;
 
    char host[128];
    char port[16];
} ecs_http_connection_t;
 
typedef struct {
    const char *key;
    const char *value;
} ecs_http_key_value_t;
 
typedef enum {
    EcsHttpGet,
    EcsHttpPost,
    EcsHttpPut,
    EcsHttpDelete,
    EcsHttpOptions,
    EcsHttpMethodUnsupported
} ecs_http_method_t;
 
typedef struct {
    uint64_t id;
 
    ecs_http_method_t method;
    char *path;
    char *body;
    ecs_http_key_value_t headers[ECS_HTTP_HEADER_COUNT_MAX];
    ecs_http_key_value_t params[ECS_HTTP_HEADER_COUNT_MAX];
    int32_t header_count;
    int32_t param_count;
 
    ecs_http_connection_t *conn;
} ecs_http_request_t;
 
typedef struct {
    int code;                   
    ecs_strbuf_t body;          
    const char* status;         
    const char* content_type;   
    ecs_strbuf_t headers;       
} ecs_http_reply_t;
 
#define ECS_HTTP_REPLY_INIT \
    (ecs_http_reply_t){200, ECS_STRBUF_INIT, "OK", "application/json", ECS_STRBUF_INIT}
 
/* Global statistics. */
extern int64_t ecs_http_request_received_count;
extern int64_t ecs_http_request_invalid_count;
extern int64_t ecs_http_request_handled_ok_count;
extern int64_t ecs_http_request_handled_error_count;
extern int64_t ecs_http_request_not_handled_count;
extern int64_t ecs_http_request_preflight_count;
extern int64_t ecs_http_send_ok_count;
extern int64_t ecs_http_send_error_count;
extern int64_t ecs_http_busy_count;
 
typedef bool (*ecs_http_reply_action_t)(
    const ecs_http_request_t* request, 
    ecs_http_reply_t *reply,
    void *ctx);
 
typedef struct {
    ecs_http_reply_action_t callback; 
    void *ctx;                        
    uint16_t port;                    
    const char *ipaddr;               
    int32_t send_queue_wait_ms;       
} ecs_http_server_desc_t;
 
FLECS_API
ecs_http_server_t* ecs_http_server_init(
    const ecs_http_server_desc_t *desc);
 
FLECS_API
void ecs_http_server_fini(
    ecs_http_server_t* server);
 
FLECS_API
int ecs_http_server_start(
    ecs_http_server_t* server);
 
FLECS_API
void ecs_http_server_dequeue(
    ecs_http_server_t* server,
    ecs_ftime_t delta_time);
 
FLECS_API
void ecs_http_server_stop(
    ecs_http_server_t* server);
 
FLECS_API
int ecs_http_server_http_request(
    ecs_http_server_t* srv,
    const char *req,
    ecs_size_t len,
    ecs_http_reply_t *reply_out);
 
FLECS_API
int ecs_http_server_request(
    ecs_http_server_t* srv,
    const char *method,
    const char *req,
    ecs_http_reply_t *reply_out);
 
FLECS_API
void* ecs_http_server_ctx(
    ecs_http_server_t* srv);
 
FLECS_API
const char* ecs_http_get_header(
    const ecs_http_request_t* req,
    const char* name);
 
FLECS_API
const char* ecs_http_get_param(
    const ecs_http_request_t* req,
    const char* name);
 
#ifdef __cplusplus
}
#endif
 
#endif // FLECS_HTTP_H
 
#endif // FLECS_HTTP