host.h

Go to the documentation of this file.

 
#pragma once
 
#include <ascii-chat/common/limits.h>
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
#include <ascii-chat/asciichat_errno.h>
#include <ascii-chat/network/acip/transport.h>
#include <libplatform/terminal.h>
#include <ascii-chat/network/packet/packet.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[IP_ADDRESS_BUFFER_SIZE];

  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;

  bool configured_quic_listeners;

  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);

asciichat_error_t session_host_destroy(session_host_t *host);

 
/* ============================================================================
 * Session Host Server Control Functions
 * @{
 */

asciichat_error_t session_host_start(session_host_t *host);

asciichat_error_t 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, acip_transport_t *transport,
                                 acip_transport_ownership_t ownership, 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);

typedef struct {
  terminal_capabilities_t caps;
  const char *palette;
  int width;
  int height;
} session_host_render_config_t;

typedef struct {
  uint32_t client_id;
  asciichat_error_t (*get_config)(void *context, session_host_render_config_t *config);
  void (*render_frame)(void *context, const char *frame, size_t size, int width, int height);
  void *context;
} session_host_render_target_t;

asciichat_error_t session_host_set_render_target(session_host_t *host, const session_host_render_target_t *target);

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_ownership_t ownership);

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);



asciichat_error_t session_host_receive_packet(session_host_t *host, uint32_t client_id, packet_type_t type,
                                              const void *data, size_t len);
asciichat_error_t session_host_render_video(session_host_t *host);
 
asciichat_error_t session_host_accept_peer(session_host_t *, acip_transport_t *);
asciichat_error_t session_host_render_audio(session_host_t *host);