include/ascii-chat/network/websocket/server.h

Go to the documentation of this file.

#pragma once
 
#include <stdint.h>
#include <stdbool.h>
#include <ascii-chat/atomic.h>
#include "../../common.h"
#include "../../platform/abstraction.h"
#include "../../thread_pool.h"
#include <libwebsockets.h>
 
// Forward declarations
typedef struct websocket_server websocket_server_t;
typedef struct acip_transport acip_transport_t;
typedef struct thread_pool thread_pool_t;
 
typedef void *(*websocket_client_handler_fn)(void *arg);
 
typedef struct {
  acip_transport_t *transport;   
  char client_ip[64];            
  int client_port;               
  void *user_data;               
  bool is_secure;                
  bool auth_required;            
} websocket_client_context_t;
 
typedef struct {
  int port;                                   
  websocket_client_handler_fn client_handler; 
  void *user_data;                            
  const char *tls_cert_path;                  
  const char *tls_key_path;                   
} websocket_server_config_t;
 
struct websocket_server {
  struct lws_context *context;         
  websocket_client_handler_fn handler; 
  void *user_data;                     
  atomic_t running;                 
  int port;                            
  struct thread_pool *handler_pool;    
};
 
asciichat_error_t websocket_server_init(websocket_server_t *server, const websocket_server_config_t *config);
 
asciichat_error_t websocket_server_run(websocket_server_t *server);
 
void websocket_server_destroy(websocket_server_t *server);
 
void websocket_server_cancel_service(websocket_server_t *server);