src/client/server.h

Go to the documentation of this file.

 
#pragma once
 
#include <ascii-chat/platform/socket.h>
#include <ascii-chat/network/packet/packet.h>
#include <ascii-chat/log/log.h>
#include <stdint.h>
#include <stdbool.h>
 
/* ============================================================================
 * Connection Error Codes
 * ============================================================================ */
 
typedef enum {
  CONNECTION_SUCCESS = 0,                
  CONNECTION_WARNING_NO_CLIENT_AUTH = 1, 
  CONNECTION_ERROR_GENERIC = -1,         
  CONNECTION_ERROR_AUTH_FAILED = -2,     
  CONNECTION_ERROR_HOST_KEY_FAILED = -3  
} connection_error_t;
 
/* ============================================================================
 * Connection Management Functions
 * ============================================================================ */
 
int server_connection_init();
 
int server_connection_establish(const char *address, int port, int reconnect_attempt, bool first_connection,
                                bool has_ever_connected);
 
bool server_connection_is_active();
 
socket_t server_connection_get_socket();
 
struct acip_transport *server_connection_get_transport(void);
 
void server_connection_set_transport(struct acip_transport *transport);
 
uint32_t server_connection_get_client_id();
 
const char *server_connection_get_ip();
 
void server_connection_set_ip(const char *ip);
 
void server_connection_set_port(int port);
 
int server_connection_get_port(void);
 
void server_connection_close();
 
void server_connection_shutdown();
 
void server_connection_lost();
 
bool server_connection_is_lost();
 
void server_connection_cleanup();
 
asciichat_error_t threaded_send_packet(packet_type_t type, const void *data, size_t len);
 
int threaded_send_audio_batch_packet(const float *samples, int num_samples, int batch_count);
 
asciichat_error_t threaded_send_audio_opus(const uint8_t *opus_data, size_t opus_size, int sample_rate,
                                           int frame_duration);
 
asciichat_error_t threaded_send_audio_opus_batch(const uint8_t *opus_data, size_t opus_size,
                                                 const uint16_t *frame_sizes, int frame_count);
 
asciichat_error_t threaded_send_image_frame(const void *pixel_data, uint32_t width, uint32_t height,
                                            uint32_t pixel_format);
 
asciichat_error_t threaded_send_image_frame_h265(const void *pixel_data, uint32_t width, uint32_t height);
 
int threaded_send_ping_packet(void);
 
int threaded_send_pong_packet(void);
 
asciichat_error_t threaded_send_stream_start_packet(uint32_t stream_type);
 
asciichat_error_t threaded_send_terminal_size_with_auto_detect(unsigned short width, unsigned short height);
 
int threaded_send_client_join_packet(const char *display_name, uint32_t capabilities);
 
/* ============================================================================
 * Thread-Safe Packet Sending Functions
 * ============================================================================ */
 
int server_send_packet(packet_type_t type, const void *data, size_t len);
 
int server_send_audio(const float *samples, int num_samples);
 
int server_send_audio_batch(const float *samples, int num_samples, int batch_count);
 
int server_send_terminal_capabilities(unsigned short width, unsigned short height);
 
int server_send_ping();
 
int server_send_pong();
 
int server_send_stream_start(uint32_t stream_type);
 
int server_send_stream_stop(uint32_t stream_type);