acds_client.h

Go to the documentation of this file.

 
 
/* Storage capacities in elements; text buffers include the terminating NUL. */
 
#include <ascii-chat/common/limits.h>
#include <ascii-chat/network/acip/acds_sizes.h>
#include <ascii-chat/crypto/sizes.h>
#include <ascii-chat/network/connection.h>
#include <ascii-chat/common.h>
#pragma once

 
#include <stdint.h>
#include <stdbool.h>
#include "../../asciichat_errno.h"
#include "../../os/socket.h"
#include "../../network/acip/acds.h"
#include "../../crypto/handshake/common.h"
#include "../../crypto/policy.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[HOSTNAME_BUFFER_SIZE]; 
  uint16_t server_port;                      
  uint32_t timeout_ms;                       
  crypto_policy_t security_policy;           
  const char *identity_key;                  
 
  // 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;
  bool connected;              
  acip_transport_t *transport; 
  network_connection_t *connection;
  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[ED25519_PUBLIC_KEY_SIZE];  
  uint8_t identity_seckey[ED25519_PRIVATE_KEY_SIZE]; 
  uint8_t capabilities;                              
  uint8_t max_participants;                          
  bool has_password;                                 
  char password[ACIP_PASSWORD_SIZE];                 
  bool acds_expose_ip;                    
  uint8_t session_type;                   
  const char *reserved_string;            
  char server_address[ACIP_ADDRESS_SIZE]; 
  uint16_t server_port;                   
  uint16_t quic_port;
  char webtransport_url[512];
} acds_session_create_params_t;

typedef struct {
  char session_string[ACIP_MAX_SESSION_STRING_LEN + 1]; 
  uint8_t session_id[SESSION_ID_SIZE];                  
  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[SESSION_ID_SIZE];          
  uint8_t host_pubkey[ED25519_PUBLIC_KEY_SIZE]; 
  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[ED25519_PUBLIC_KEY_SIZE];  
  uint8_t identity_seckey[ED25519_PRIVATE_KEY_SIZE]; 
  bool has_password;                                 
  char password[ACIP_PASSWORD_SIZE];                 
} acds_session_join_params_t;

typedef struct {
  bool success;                                    
  uint8_t participant_id[SESSION_ID_SIZE];         
  uint8_t session_id[SESSION_ID_SIZE];             
  uint8_t error_code;                              
  char error_message[ACIP_ERROR_MESSAGE_SIZE + 1]; 
  uint8_t session_type;                            
  char server_address[ACIP_ADDRESS_SIZE + 1];      
  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[ED25519_PRIVATE_KEY_SIZE], uint64_t timestamp,
                                           uint8_t capabilities, uint8_t max_participants,
                                           uint8_t signature_out[ED25519_SIGNATURE_SIZE]);

asciichat_error_t acds_verify_session_create(const uint8_t identity_pubkey[ED25519_PUBLIC_KEY_SIZE], uint64_t timestamp,
                                             uint8_t capabilities, uint8_t max_participants,
                                             const uint8_t signature[ED25519_SIGNATURE_SIZE]);

asciichat_error_t acds_sign_session_join(const uint8_t identity_seckey[ED25519_PRIVATE_KEY_SIZE], uint64_t timestamp,
                                         const char *session_string, uint8_t signature_out[ED25519_SIGNATURE_SIZE]);

asciichat_error_t acds_verify_session_join(const uint8_t identity_pubkey[ED25519_PUBLIC_KEY_SIZE], uint64_t timestamp,
                                           const char *session_string, const uint8_t signature[ED25519_SIGNATURE_SIZE]);

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);
 
#define ACDS_TRANSPORT_METADATA_MAX 521
/* ACQT v1 is optional. An absent extension decodes to no advertised endpoints. */
asciichat_error_t acds_transport_metadata_encode(uint16_t quic_port, const char *url, void *output, size_t capacity,
                                                 size_t *length);
asciichat_error_t acds_transport_metadata_decode(const void *bytes, size_t length, uint16_t *quic_port, char *url,
                                                 size_t capacity);