connection_state.h

Go to the documentation of this file.

 
#pragma once
 
#include <stdint.h>
#include <stdbool.h>
#include <time.h>
#include "common.h"
#include "network/acip/transport.h"
#include "network/webrtc/peer_manager.h"
#include "platform/abstraction.h"
 
/* ============================================================================
 * Forward Declarations
 * ============================================================================ */
 
struct tcp_client; // Forward declaration for TCP client instance
 
/* ============================================================================
 * Connection State Enumeration
 * ============================================================================ */
 
typedef enum {
  // Initial and terminal states
  CONN_STATE_IDLE = 0,          
  CONN_STATE_CONNECTED = 20,    
  CONN_STATE_DISCONNECTED = 21, 
  CONN_STATE_FAILED = 22,       
 
  // Stage 1: Direct TCP (3s timeout)
  CONN_STATE_ATTEMPTING_DIRECT_TCP = 1, 
  CONN_STATE_DIRECT_TCP_CONNECTED = 2,  
  CONN_STATE_DIRECT_TCP_FAILED = 3,     
 
  // Stage 2: WebRTC + STUN (8s timeout)
  CONN_STATE_ATTEMPTING_WEBRTC_STUN = 4, 
  CONN_STATE_WEBRTC_STUN_SIGNALING = 5,  
  CONN_STATE_WEBRTC_STUN_CONNECTED = 6,  
  CONN_STATE_WEBRTC_STUN_FAILED = 7,     
 
  // Stage 3: WebRTC + TURN (15s timeout)
  CONN_STATE_ATTEMPTING_WEBRTC_TURN = 8, 
  CONN_STATE_WEBRTC_TURN_SIGNALING = 9,  
  CONN_STATE_WEBRTC_TURN_CONNECTED = 10, 
  CONN_STATE_WEBRTC_TURN_FAILED = 11,    
} connection_state_t;
 
/* ============================================================================
 * Timeout Constants (in seconds)
 * ============================================================================ */
 
#define CONN_TIMEOUT_DIRECT_TCP 3   
#define CONN_TIMEOUT_WEBRTC_STUN 8  
#define CONN_TIMEOUT_WEBRTC_TURN 15 
 
/* ============================================================================
 * Session Context (for WebRTC connections)
 * ============================================================================ */
 
typedef struct {
  char session_string[128];   
  uint8_t session_id[16];     
  uint8_t participant_id[16]; 
  uint16_t server_port;       
  char server_address[64];    
} connection_session_context_t;
 
/* ============================================================================
 * STUN/TURN Configuration
 * ============================================================================ */
 
typedef struct {
  char stun_server[256]; 
  uint16_t stun_port;    
 
  char turn_server[256];   
  uint16_t turn_port;      
  char turn_username[128]; 
  char turn_password[256]; 
} connection_stun_turn_config_t;
 
/* ============================================================================
 * Connection Attempt Context
 * ============================================================================ */
 
typedef struct {
  // ─────────────────────────────────────────────────────────────
  // State Machine
  // ─────────────────────────────────────────────────────────────
 
  connection_state_t current_state;  
  connection_state_t previous_state; 
 
  // ─────────────────────────────────────────────────────────────
  // Timeout Tracking
  // ─────────────────────────────────────────────────────────────
 
  time_t stage_start_time;                
  uint32_t current_stage_timeout_seconds; 
 
  // ─────────────────────────────────────────────────────────────
  // Active Transports
  // ─────────────────────────────────────────────────────────────
 
  acip_transport_t *tcp_transport;    
  acip_transport_t *acds_transport;   
  acip_transport_t *webrtc_transport; 
  acip_transport_t *active_transport; 
 
  struct tcp_client *tcp_client_instance; 
 
  // ─────────────────────────────────────────────────────────────
  // WebRTC Session Context
  // ─────────────────────────────────────────────────────────────
 
  connection_session_context_t session_ctx; 
  webrtc_peer_manager_t *peer_manager;      
 
  // ─────────────────────────────────────────────────────────────
  // WebRTC Connection Synchronization
  // ─────────────────────────────────────────────────────────────
 
  mutex_t webrtc_mutex;           
  cond_t webrtc_ready_cond;       
  bool webrtc_transport_received; 
 
  // ─────────────────────────────────────────────────────────────
  // STUN/TURN Configuration
  // ─────────────────────────────────────────────────────────────
 
  connection_stun_turn_config_t stun_turn_cfg; 
 
  // ─────────────────────────────────────────────────────────────
  // Connection Preferences (from CLI flags)
  // ─────────────────────────────────────────────────────────────
 
  bool prefer_webrtc;       
  bool no_webrtc;           
  bool webrtc_skip_stun;    
  bool webrtc_disable_turn; 
 
  // ─────────────────────────────────────────────────────────────
  // Statistics
  // ─────────────────────────────────────────────────────────────
 
  uint32_t reconnect_attempt; 
  uint32_t stage_failures;    
  uint32_t total_transitions; 
 
} connection_attempt_context_t;
 
/* ============================================================================
 * Function Declarations
 * ============================================================================ */
 
asciichat_error_t connection_context_init(connection_attempt_context_t *ctx, bool prefer_webrtc, bool no_webrtc,
                                          bool webrtc_skip_stun, bool webrtc_disable_turn);
 
asciichat_error_t connection_state_transition(connection_attempt_context_t *ctx, connection_state_t new_state);
 
bool connection_check_timeout(const connection_attempt_context_t *ctx);
 
const char *connection_state_name(connection_state_t state);
 
uint32_t connection_get_stage(connection_state_t state);
 
void connection_context_cleanup(connection_attempt_context_t *ctx);
 
asciichat_error_t connection_attempt_with_fallback(connection_attempt_context_t *ctx, const char *server_address,
                                                   uint16_t server_port, const char *acds_server, uint16_t acds_port);