src/server/client.h

Go to the documentation of this file.

 
#pragma once
 
#include <ascii-chat/network/client.h>
 
// Forward declaration to avoid circular dependency with main.h
// Files that need the full definition should include main.h themselves
typedef struct server_context_t server_context_t;
 
typedef struct {
  client_info_t clients[MAX_CLIENTS];
  client_info_t *clients_by_id;
  int client_count;
  mutex_t mutex;
} client_manager_t;
 
// Global client manager
extern client_manager_t g_client_manager;
extern rwlock_t g_client_manager_rwlock;
extern bool g_client_manager_rwlock_initialized;
 
// Client management functions
client_info_t *add_client(server_context_t *server_ctx, socket_t socket, const char *client_ip, int port);
client_info_t *add_webrtc_client(server_context_t *server_ctx, acip_transport_t *transport, const char *client_ip,
                                 bool start_threads);
int start_webrtc_client_threads(server_context_t *server_ctx, const char *client_id);
int remove_client(server_context_t *server_ctx, const char *client_id);
client_info_t *find_client_by_id(const char *client_id);
client_info_t *find_client_by_socket(socket_t socket);
void cleanup_client_media_buffers(client_info_t *client);
void cleanup_client_packet_queues(client_info_t *client);
 
// Client thread functions
void *client_receive_thread(void *arg);
void stop_client_threads(client_info_t *client);
 
// Packet processing functions
int process_encrypted_packet(client_info_t *client, packet_type_t *type, void **data, size_t *len, uint32_t *sender_id);
void process_decrypted_packet(client_info_t *client, packet_type_t type, void *data, size_t len);
 
// Client initialization
void initialize_client_info(client_info_t *client);