peer_manager.h

Go to the documentation of this file.

 
#pragma once
 
#include <ascii-chat/crypto/sizes.h>
#include <stdint.h>
#include <stdbool.h>
#include "../../common.h"
#include "../../network/webrtc/webrtc.h"
#include "../../network/acip/transport.h"
#include "../../network/acip/messages.h"
 
#ifdef __cplusplus
extern "C" {
#endif

 
// Forward declarations
typedef struct webrtc_peer_manager webrtc_peer_manager_t;

typedef enum {
  WEBRTC_ROLE_CREATOR = 0, 
  WEBRTC_ROLE_JOINER = 1,  
} webrtc_peer_role_t;

typedef void (*webrtc_transport_ready_callback_t)(acip_transport_t *transport,
                                                  const uint8_t participant_id[SESSION_ID_SIZE], void *user_data);

typedef void (*webrtc_gathering_timeout_callback_t)(const uint8_t participant_id[SESSION_ID_SIZE], uint32_t timeout_ms,
                                                    uint64_t elapsed_ms, void *user_data);

typedef struct {
  webrtc_peer_role_t role;                                  
  const char *bind_address;                                 
  stun_server_t *stun_servers;                              
  size_t stun_count;                                        
  turn_server_t *turn_servers;                              
  size_t turn_count;                                        
  bool relay_only;                                          
  const char *turn_username;                                
  const char *turn_credential;                              
  webrtc_transport_ready_callback_t on_transport_ready;     
  webrtc_gathering_timeout_callback_t on_gathering_timeout; 
  void *user_data;                                          
} webrtc_peer_manager_config_t;

typedef asciichat_error_t (*webrtc_send_sdp_callback_t)(const uint8_t session_id[SESSION_ID_SIZE],
                                                        const uint8_t recipient_id[SESSION_ID_SIZE],
                                                        const char *sdp_type, const char *sdp, void *user_data);

typedef asciichat_error_t (*webrtc_send_ice_callback_t)(const uint8_t session_id[SESSION_ID_SIZE],
                                                        const uint8_t recipient_id[SESSION_ID_SIZE],
                                                        const char *candidate, const char *mid, void *user_data);

typedef struct {
  webrtc_send_sdp_callback_t send_sdp; 
  webrtc_send_ice_callback_t send_ice; 
  void *user_data;                     
} webrtc_signaling_callbacks_t;
 
// ============================================================================
// Peer Manager Lifecycle
// ============================================================================

asciichat_error_t webrtc_peer_manager_create(const webrtc_peer_manager_config_t *config,
                                             const webrtc_signaling_callbacks_t *signaling_callbacks,
                                             webrtc_peer_manager_t **manager_out);

void webrtc_peer_manager_destroy(webrtc_peer_manager_t *manager);
 
// ============================================================================
// Signaling Message Processing
// ============================================================================

asciichat_error_t webrtc_peer_manager_handle_sdp(webrtc_peer_manager_t *manager, const acip_webrtc_sdp_t *sdp);

asciichat_error_t webrtc_peer_manager_handle_ice(webrtc_peer_manager_t *manager, const acip_webrtc_ice_t *ice);
 
// ============================================================================
// Connection Initiation (Joiner Role)
// ============================================================================

asciichat_error_t webrtc_peer_manager_connect(webrtc_peer_manager_t *manager, const uint8_t session_id[SESSION_ID_SIZE],
                                              const uint8_t participant_id[SESSION_ID_SIZE]);

bool webrtc_peer_manager_get_state(webrtc_peer_manager_t *manager, const uint8_t participant_id[SESSION_ID_SIZE],
                                   webrtc_state_t *state_out);
asciichat_error_t webrtc_peer_manager_remove_peer(webrtc_peer_manager_t *manager,
                                                  const uint8_t participant_id[SESSION_ID_SIZE]);
 
// ============================================================================
// Connection Health Monitoring
// ============================================================================

int webrtc_peer_manager_check_gathering_timeouts(webrtc_peer_manager_t *manager, uint32_t timeout_ms);

asciichat_error_t webrtc_peer_manager_dispatch_ready(webrtc_peer_manager_t *manager);
 // end of webrtc_peer_manager group
 
#ifdef __cplusplus
}
#endif