connection_state.h

Go to the documentation of this file.

 
#pragma once
 
#include <stdint.h>
#include <stdbool.h>
#include <time.h>
#include <ascii-chat/common.h>
#include <ascii-chat/network/acip/transport.h>
#include <ascii-chat/platform/abstraction.h>
 
/* ============================================================================
 * Forward Declarations
 * ============================================================================ */
 
struct tcp_client;       // Forward declaration for TCP client instance
struct websocket_client; // Forward declaration for WebSocket client instance
 
/* ============================================================================
 * Connection State Enumeration
 * ============================================================================ */
 
typedef enum {
  CONN_STATE_IDLE = 0,         
  CONN_STATE_ATTEMPTING = 1,   
  CONN_STATE_CONNECTED = 2,    
  CONN_STATE_DISCONNECTED = 3, 
  CONN_STATE_FAILED = 4,       
} connection_state_t;
 
/* ============================================================================
 * Timeout Constants (in nanoseconds)
 * ============================================================================ */
 
#define CONN_TIMEOUT_TCP (3LL * NS_PER_SEC_INT) 
 
/* ============================================================================
 * Connection Attempt Context
 * ============================================================================ */
 
typedef struct {
  // State Machine
  connection_state_t current_state;  
  connection_state_t previous_state; 
 
  // Timeout Tracking (in nanoseconds)
  uint64_t attempt_start_time_ns; 
  uint64_t timeout_ns;            
 
  // Transport Instances (one will be non-NULL at a time)
  acip_transport_t *active_transport;          
  struct tcp_client *tcp_client_instance;      
  struct websocket_client *ws_client_instance; 
 
  // Statistics
  uint32_t reconnect_attempt; 
  uint32_t total_transitions; 
 
  // Reconnection Strategy
  bool is_reconnection; 
 
} connection_attempt_context_t;
 
/* ============================================================================
 * Function Declarations
 * ============================================================================ */
 
asciichat_error_t connection_context_init(connection_attempt_context_t *ctx);
 
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);
 
void connection_context_cleanup(connection_attempt_context_t *ctx);
 
asciichat_error_t connection_attempt_tcp(connection_attempt_context_t *ctx, const char *server_address,
                                         uint16_t server_port, struct tcp_client *pre_created_tcp_client);
 
asciichat_error_t connection_attempt_websocket(connection_attempt_context_t *ctx, const char *ws_url);