acds_client.h

Go to the documentation of this file.

#pragma once
 
#include <stdint.h>
#include <stdbool.h>
#include "../../asciichat_errno.h"
#include "../../platform/socket.h"
#include "../../network/acip/acds.h"
#include "../../crypto/handshake/common.h"
#include "../../network/acip/transport.h"
 
// ============================================================================
// ACDS Client Configuration
// ============================================================================
 
// Forward declaration of callback type from parallel_connect.h
typedef bool (*parallel_connect_should_exit_fn)(void *user_data);
 
typedef struct {
  char server_address[256]; 
  uint16_t server_port;     
  uint32_t timeout_ms;      
 
  // Optional: callback to check if connection should be abandoned (e.g., shutdown signal)
  parallel_connect_should_exit_fn should_exit_callback;
  void *callback_data;
} acds_client_config_t;
 
typedef struct {
  acds_client_config_t config;
  socket_t socket;                          
  bool connected;                           
  acip_transport_t *transport;              
  crypto_handshake_context_t handshake_ctx; 
} acds_client_t;
 
// ============================================================================
// Connection Management
// ============================================================================
 
asciichat_error_t acds_client_connect(acds_client_t *client, const acds_client_config_t *config);
 
void acds_client_disconnect(acds_client_t *client);
 
// ============================================================================
// Session Management
// ============================================================================
 
typedef struct {
  uint8_t identity_pubkey[32]; 
  uint8_t identity_seckey[64]; 
  uint8_t capabilities;        
  uint8_t max_participants;    
  bool has_password;           
  char password[128];          
  bool acds_expose_ip;         
  uint8_t session_type;        
  const char *reserved_string; 
  char server_address[64];     
  uint16_t server_port;        
} acds_session_create_params_t;
 
typedef struct {
  char session_string[49]; 
  uint8_t session_id[16];  
  uint64_t expires_at;     
} acds_session_create_result_t;
 
asciichat_error_t acds_session_create(acds_client_t *client, const acds_session_create_params_t *params,
                                      acds_session_create_result_t *result);
 
typedef struct {
  bool found;                   
  uint8_t session_id[16];       
  uint8_t host_pubkey[32];      
  uint8_t capabilities;         
  uint8_t max_participants;     
  uint8_t current_participants; 
  bool has_password;            
  uint64_t created_at;          
  uint64_t expires_at;          
  bool require_server_verify;   
  bool require_client_verify;   
} acds_session_lookup_result_t;
 
asciichat_error_t acds_session_lookup(acds_client_t *client, const char *session_string,
                                      acds_session_lookup_result_t *result);
 
typedef struct {
  const char *session_string;  
  uint8_t identity_pubkey[32]; 
  uint8_t identity_seckey[64]; 
  bool has_password;           
  char password[128];          
} acds_session_join_params_t;
 
typedef struct {
  bool success;               
  uint8_t participant_id[16]; 
  uint8_t session_id[16];     
  uint8_t error_code;         
  char error_message[129];    
  uint8_t session_type;       
  char server_address[65];    
  uint16_t server_port;       
} acds_session_join_result_t;
 
asciichat_error_t acds_session_join(acds_client_t *client, const acds_session_join_params_t *params,
                                    acds_session_join_result_t *result);
 
// ============================================================================
// Cryptographic Signature Helpers
// ============================================================================
 
asciichat_error_t acds_sign_session_create(const uint8_t identity_seckey[64], uint64_t timestamp, uint8_t capabilities,
                                           uint8_t max_participants, uint8_t signature_out[64]);
 
asciichat_error_t acds_verify_session_create(const uint8_t identity_pubkey[32], uint64_t timestamp,
                                             uint8_t capabilities, uint8_t max_participants,
                                             const uint8_t signature[64]);
 
asciichat_error_t acds_sign_session_join(const uint8_t identity_seckey[64], uint64_t timestamp,
                                         const char *session_string, uint8_t signature_out[64]);
 
asciichat_error_t acds_verify_session_join(const uint8_t identity_pubkey[32], uint64_t timestamp,
                                           const char *session_string, const uint8_t signature[64]);
 
bool acds_validate_timestamp(uint64_t timestamp_ms, uint32_t window_seconds);
 
// ============================================================================
// Helper Functions
// ============================================================================
 
void acds_client_config_init_defaults(acds_client_config_t *config);