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

Go to the documentation of this file.

#pragma once

 
#include <ascii-chat/common/limits.h>
#include <stdint.h>
#include <stdbool.h>
#include <libplatform/atomic.h>
#include "../../common.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[IP_ADDRESS_BUFFER_SIZE]; 
  int client_port;                        
  void *user_data;                        
  bool is_secure;                         
  bool auth_required;                     
} websocket_client_context_t;

typedef struct {
  int port;                                   
  const char *bind_address;                   
  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;                            
  bool tls_enabled;                    
  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);