peer_manager.h

Go to the documentation of this file.

 
#pragma once
 
#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[16],
                                                  void *user_data);
 
typedef struct {
  webrtc_peer_role_t role;                              
  stun_server_t *stun_servers;                          
  size_t stun_count;                                    
  turn_server_t *turn_servers;                          
  size_t turn_count;                                    
  webrtc_transport_ready_callback_t on_transport_ready; 
  void *user_data;                                      
  crypto_context_t *crypto_ctx;                         
} webrtc_peer_manager_config_t;
 
typedef asciichat_error_t (*webrtc_send_sdp_callback_t)(const uint8_t session_id[16], const uint8_t recipient_id[16],
                                                        const char *sdp_type, const char *sdp, void *user_data);
 
typedef asciichat_error_t (*webrtc_send_ice_callback_t)(const uint8_t session_id[16], const uint8_t recipient_id[16],
                                                        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[16],
                                              const uint8_t participant_id[16]);
 
 
#ifdef __cplusplus
}
#endif