network/acip/acds.h

Go to the documentation of this file.

 
#pragma once
 
#include <stdint.h>
#include <stdbool.h>
#include "network/packet.h"
#include "network/acip/protocol.h"
#include "network/webrtc/stun.h"
#include "network/webrtc/turn.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
// Pack network protocol structures tightly for wire format
#ifdef _WIN32
#pragma pack(push, 1)
#endif
 
typedef enum {
  SESSION_TYPE_DIRECT_TCP = 0, 
  SESSION_TYPE_WEBRTC = 1      
} acds_session_type_t;
 
typedef struct __attribute__((packed)) {
  uint8_t identity_pubkey[32]; 
  uint8_t signature[64];       
  uint64_t timestamp;          
 
  uint8_t capabilities;     
  uint8_t max_participants; 
  uint8_t session_type;     
 
  uint8_t has_password;       
  uint8_t password_hash[128]; 
  uint8_t expose_ip_publicly; 
 
  uint8_t reserved_string_len; 
  // char  reserved_string[];        ///< Variable length, follows if len > 0
 
  // Server connection information (where clients should connect)
  // For DIRECT_TCP: server_address and server_port specify where to connect
  // For WEBRTC: these fields are ignored, signaling happens through ACDS
  char server_address[64]; 
  uint16_t server_port;    
} acip_session_create_t;
 
typedef struct __attribute__((packed)) {
  uint8_t session_string_len; 
  char session_string[48];    
  uint8_t session_id[16];     
  uint64_t expires_at;        
 
  uint8_t stun_count; 
  uint8_t turn_count; 
  // Followed by: stun_server_t[stun_count], turn_server_t[turn_count]
} acip_session_created_t;
 
typedef struct __attribute__((packed)) {
  uint8_t session_string_len;
  char session_string[48];
} acip_session_lookup_t;
 
typedef struct __attribute__((packed)) {
  uint8_t found;           
  uint8_t session_id[16];  
  uint8_t host_pubkey[32]; 
  uint8_t capabilities;    
  uint8_t max_participants;
  uint8_t current_participants;
  uint8_t session_type; 
  uint8_t has_password; 
  uint64_t created_at;  
  uint64_t expires_at;  
 
  // ACDS Policy Flags (enforced by discovery server)
  uint8_t require_server_verify; 
  uint8_t require_client_verify; 
} acip_session_info_t;
 
typedef struct __attribute__((packed)) {
  uint8_t session_string_len;
  char session_string[48];
  uint8_t identity_pubkey[32]; 
  uint8_t signature[64];       
  uint64_t timestamp;          
 
  uint8_t has_password;
  char password[128]; 
} acip_session_join_t;
 
typedef struct __attribute__((packed)) {
  uint8_t success;         
  uint8_t error_code;      
  char error_message[128]; 
 
  uint8_t participant_id[16]; 
  uint8_t session_id[16];     
 
  // Server connection information (ONLY if success == 1)
  uint8_t session_type;    
  char server_address[64]; 
  uint16_t server_port;    
 
  // TURN credentials for WebRTC NAT traversal (ONLY if session_type == SESSION_TYPE_WEBRTC)
  // Generated by ACDS server using HMAC-SHA1 with shared secret
  // Format follows RFC 5766 time-limited TURN authentication
  char turn_username[128]; 
  char turn_password[128]; 
} acip_session_joined_t;
 
typedef struct __attribute__((packed)) {
  uint8_t session_id[16];
  uint8_t participant_id[16];
} acip_session_leave_t;
 
typedef struct __attribute__((packed)) {
  uint8_t session_id[16];
  uint8_t signature[64]; 
} acip_session_end_t;
 
typedef struct __attribute__((packed)) {
  uint8_t session_id[16];
  uint8_t participant_id[16];
  uint8_t signature[64]; 
} acip_session_reconnect_t;
 
typedef struct __attribute__((packed)) {
  uint8_t session_id[16];   
  uint8_t sender_id[16];    
  uint8_t recipient_id[16]; 
  uint8_t sdp_type;         
  uint16_t sdp_len;         
  // char  sdp_data[];               ///< Variable length SDP string
} acip_webrtc_sdp_t;
 
typedef struct __attribute__((packed)) {
  uint8_t session_id[16];
  uint8_t sender_id[16];
  uint8_t recipient_id[16];
  uint16_t candidate_len;
  // char  candidate[];              ///< Variable length ICE candidate
} acip_webrtc_ice_t;
 
typedef struct __attribute__((packed)) {
  uint8_t identity_pubkey[32];
  uint8_t signature[64];
  uint64_t timestamp;
  uint8_t string_len;
  char string[48];
  uint32_t duration_days; 
} acip_string_reserve_t;
 
typedef struct __attribute__((packed)) {
  uint8_t success;
  uint8_t error_code;
  char error_message[128];
  uint64_t expires_at; 
} acip_string_reserved_t;
 
typedef struct __attribute__((packed)) {
  uint8_t identity_pubkey[32];
  uint8_t signature[64];
  uint64_t timestamp;
  uint8_t string_len;
  char string[48];
  uint32_t duration_days;
} acip_string_renew_t;
 
typedef struct __attribute__((packed)) {
  uint8_t identity_pubkey[32];
  uint8_t signature[64];
  uint64_t timestamp;
  uint8_t string_len;
  char string[48];
} acip_string_release_t;
 
typedef struct __attribute__((packed)) {
  uint8_t error_code;      
  char error_message[256]; 
} acip_error_t;
 
typedef enum {
  ACIP_ERROR_NONE = 0,              
  ACIP_ERROR_SESSION_NOT_FOUND = 1, 
  ACIP_ERROR_SESSION_FULL = 2,      
  ACIP_ERROR_INVALID_PASSWORD = 3,  
  ACIP_ERROR_INVALID_SIGNATURE = 4, 
  ACIP_ERROR_RATE_LIMITED = 5,      
  ACIP_ERROR_STRING_TAKEN = 6,      
  ACIP_ERROR_STRING_INVALID = 7,    
  ACIP_ERROR_INTERNAL = 255         
} acip_error_code_t;
 
#define ACIP_MAX_SESSION_STRING_LEN 48
 
#define ACIP_SESSION_EXPIRATION_MS (24ULL * 60 * 60 * 1000)
 
#define ACIP_DISCOVERY_DEFAULT_PORT 27225
 
#ifdef _WIN32
#pragma pack(pop)
#endif
 
#ifdef __cplusplus
}
#endif