host.h

Go to the documentation of this file.

 
#pragma once
 
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
#include <ascii-chat/asciichat_errno.h>
#include <ascii-chat/platform/socket.h>
#include <ascii-chat/video/rgba/image.h>
 
/* ============================================================================
 * Session Host Types
 * ============================================================================ */
 
typedef struct session_host session_host_t;
 
typedef struct {
  uint32_t client_id;
 
  char ip_address[64];
 
  int port;
 
  bool video_active;
 
  bool audio_active;
 
  uint64_t connected_at;
} session_host_client_info_t;
 
typedef struct {
  void (*on_client_join)(session_host_t *h, uint32_t client_id, void *user_data);
 
  void (*on_client_leave)(session_host_t *h, uint32_t client_id, void *user_data);
 
  void (*on_frame_received)(session_host_t *h, uint32_t client_id, const image_t *frame, void *user_data);
 
  void (*on_audio_received)(session_host_t *h, uint32_t client_id, const float *samples, size_t count, void *user_data);
 
  void (*on_error)(session_host_t *h, asciichat_error_t error, const char *message, void *user_data);
} session_host_callbacks_t;
 
typedef struct {
  int port;
 
  const char *ipv4_address;
 
  const char *ipv6_address;
 
  int max_clients;
 
  bool encryption_enabled;
 
  const char *key_path;
 
  const char *password;
 
  session_host_callbacks_t callbacks;
 
  void *user_data;
 
  struct session_display_ctx *display_context;
} session_host_config_t;
 
/* ============================================================================
 * Session Host Lifecycle Functions
 * @{
 */
 
session_host_t *session_host_create(const session_host_config_t *config);
 
void session_host_destroy(session_host_t *host);
 
/* ============================================================================
 * Session Host Server Control Functions
 * @{
 */
 
asciichat_error_t session_host_start(session_host_t *host);
 
void session_host_stop(session_host_t *host);
 
bool session_host_is_running(session_host_t *host);
 
/* ============================================================================
 * Session Host Client Management Functions
 * @{
 */
 
uint32_t session_host_add_client(session_host_t *host, socket_t socket, const char *ip, int port);
 
uint32_t session_host_add_memory_participant(session_host_t *host);
 
asciichat_error_t session_host_inject_frame(session_host_t *host, uint32_t participant_id, const image_t *frame);
 
asciichat_error_t session_host_inject_audio(session_host_t *host, uint32_t participant_id, const float *samples,
                                            size_t count);
 
asciichat_error_t session_host_remove_client(session_host_t *host, uint32_t client_id);
 
asciichat_error_t session_host_find_client(session_host_t *host, uint32_t client_id, session_host_client_info_t *info);
 
int session_host_get_client_count(session_host_t *host);
 
int session_host_get_client_ids(session_host_t *host, uint32_t *ids, int max_ids);
 
/* ============================================================================
 * Session Host Broadcast Functions
 * @{
 */
 
asciichat_error_t session_host_broadcast_frame(session_host_t *host, const char *frame);
 
asciichat_error_t session_host_send_frame(session_host_t *host, uint32_t client_id, const char *frame);
 
/* ============================================================================
 * Session Host Render Thread Functions
 * @{
 */
 
asciichat_error_t session_host_set_display(session_host_t *host, struct session_display_ctx *display);
 
asciichat_error_t session_host_start_render(session_host_t *host);
 
void session_host_stop_render(session_host_t *host);
 
/* ============================================================================
 * Session Host Transport Functions (WebRTC Integration)
 * @{
 */
 
typedef struct acip_transport acip_transport_t;
 
asciichat_error_t session_host_set_client_transport(session_host_t *host, uint32_t client_id,
                                                    acip_transport_t *transport);
 
acip_transport_t *session_host_get_client_transport(session_host_t *host, uint32_t client_id);
 
bool session_host_client_has_transport(session_host_t *host, uint32_t client_id);