include/ascii-chat/network/webrtc/webrtc.h

Go to the documentation of this file.

 
#pragma once
 
#include <stdint.h>
#include <stdbool.h>
#include <stddef.h>
#include "../../common.h"
#include "../../network/webrtc/stun.h"
#include "../../network/webrtc/turn.h"
 
#ifdef __cplusplus
extern "C" {
#endif

 
// Forward declarations
typedef struct webrtc_peer_connection webrtc_peer_connection_t;
typedef struct webrtc_data_channel webrtc_data_channel_t;

typedef enum {
  WEBRTC_STATE_NEW = 0,      
  WEBRTC_STATE_CONNECTING,   
  WEBRTC_STATE_CONNECTED,    
  WEBRTC_STATE_DISCONNECTED, 
  WEBRTC_STATE_FAILED,       
  WEBRTC_STATE_CLOSED        
} webrtc_state_t;

typedef enum {
  WEBRTC_GATHERING_NEW = 0,   
  WEBRTC_GATHERING_GATHERING, 
  WEBRTC_GATHERING_COMPLETE   
} webrtc_gathering_state_t;

typedef void (*webrtc_state_callback_t)(webrtc_peer_connection_t *pc, webrtc_state_t state, void *user_data);

typedef void (*webrtc_local_description_callback_t)(webrtc_peer_connection_t *pc, const char *sdp, const char *type,
                                                    void *user_data);

typedef void (*webrtc_local_candidate_callback_t)(webrtc_peer_connection_t *pc, const char *candidate, const char *mid,
                                                  void *user_data);

typedef void (*webrtc_gathering_state_callback_t)(webrtc_peer_connection_t *pc, webrtc_gathering_state_t state,
                                                  void *user_data);

typedef void (*webrtc_datachannel_open_callback_t)(webrtc_data_channel_t *dc, void *user_data);

typedef void (*webrtc_datachannel_message_callback_t)(webrtc_data_channel_t *dc, const uint8_t *data, size_t size,
                                                      void *user_data);

typedef void (*webrtc_datachannel_error_callback_t)(webrtc_data_channel_t *dc, const char *error, void *user_data);

typedef struct {
  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; 
 
  // Callbacks
  webrtc_state_callback_t on_state_change;
  webrtc_gathering_state_callback_t on_gathering_state_change;
  webrtc_local_description_callback_t on_local_description;
  webrtc_local_candidate_callback_t on_local_candidate;
  webrtc_datachannel_open_callback_t on_datachannel_open;
  webrtc_datachannel_message_callback_t on_datachannel_message;
  webrtc_datachannel_error_callback_t on_datachannel_error;
 
  void *user_data;      
  bool port_forwarding; 
} webrtc_config_t;
 
// ============================================================================
// Initialization and Cleanup
// ============================================================================

asciichat_error_t webrtc_init(void);

void webrtc_destroy(void);
 
// ============================================================================
// Peer Connection Management
// ============================================================================

asciichat_error_t webrtc_create_peer_connection(const webrtc_config_t *config, webrtc_peer_connection_t **pc_out);

void webrtc_close_peer_connection(webrtc_peer_connection_t *pc);

webrtc_state_t webrtc_get_state(webrtc_peer_connection_t *pc);

webrtc_gathering_state_t webrtc_get_gathering_state(webrtc_peer_connection_t *pc);

bool webrtc_is_gathering_timed_out(webrtc_peer_connection_t *pc, uint32_t timeout_ms);

void *webrtc_get_user_data(webrtc_peer_connection_t *pc);
 
// ============================================================================
// SDP Offer/Answer Exchange
// ============================================================================

asciichat_error_t webrtc_create_offer(webrtc_peer_connection_t *pc);

asciichat_error_t webrtc_set_remote_description(webrtc_peer_connection_t *pc, const char *sdp, const char *type);
 
// ============================================================================
// ICE Candidate Exchange
// ============================================================================

asciichat_error_t webrtc_add_remote_candidate(webrtc_peer_connection_t *pc, const char *candidate, const char *mid);
 
// ============================================================================
// DataChannel Management
// ============================================================================

asciichat_error_t webrtc_create_datachannel(webrtc_peer_connection_t *pc, const char *label,
                                            webrtc_data_channel_t **dc_out);

asciichat_error_t webrtc_datachannel_send(webrtc_data_channel_t *dc, const uint8_t *data, size_t size);
asciichat_error_t webrtc_datachannel_get_buffered_amount(webrtc_data_channel_t *dc, size_t *amount);
asciichat_error_t webrtc_datachannel_get_max_message_size(webrtc_data_channel_t *dc, size_t *size);

bool webrtc_datachannel_is_open(webrtc_data_channel_t *dc);

void webrtc_datachannel_set_open_state(webrtc_data_channel_t *dc, bool is_open);

const char *webrtc_datachannel_get_label(webrtc_data_channel_t *dc);

typedef struct {
  void (*on_open)(webrtc_data_channel_t *dc, void *user_data);                                     
  void (*on_close)(webrtc_data_channel_t *dc, void *user_data);                                    
  void (*on_error)(webrtc_data_channel_t *dc, const char *error, void *user_data);                 
  void (*on_message)(webrtc_data_channel_t *dc, const uint8_t *data, size_t len, void *user_data); 
  void *user_data; 
} webrtc_datachannel_callbacks_t;

asciichat_error_t webrtc_datachannel_set_callbacks(webrtc_data_channel_t *dc,
                                                   const webrtc_datachannel_callbacks_t *callbacks);

void webrtc_close_datachannel(webrtc_data_channel_t *dc);

static inline void webrtc_datachannel_close(webrtc_data_channel_t *dc) {
  webrtc_close_datachannel(dc);
}

void webrtc_datachannel_destroy(webrtc_data_channel_t *dc);

void webrtc_peer_connection_close(webrtc_peer_connection_t *pc);

void webrtc_peer_connection_destroy(webrtc_peer_connection_t *pc);

int webrtc_get_rtc_id(webrtc_peer_connection_t *pc);
 // end of webrtc group
 
#ifdef __cplusplus
}
#endif