socket.h

Go to the documentation of this file.

#pragma once
 
#include <string>
#include <functional>
#include <vector>
#include <cstdint>
 
#ifdef _WIN32
    #include <winsock2.h>
    #include <ws2tcpip.h>
    #ifdef _MSC_VER
        #pragma comment(lib, "ws2_32.lib")
    #endif
    typedef SOCKET socket_t;
    #define INVALID_SOCKET_VALUE INVALID_SOCKET
    #define SOCKET_ERROR_VALUE SOCKET_ERROR
#else
    #include <sys/socket.h>
    #include <arpa/inet.h>
    #include <netinet/in.h>
    #include <unistd.h>
    typedef int socket_t;
    #define INVALID_SOCKET_VALUE -1
    #define SOCKET_ERROR_VALUE -1
    #define closesocket close
#endif
 
namespace librats {
 
struct Peer {
    std::string ip;
    uint16_t port;
    
    Peer() : port(0) {}
    Peer(const std::string& ip, uint16_t port) : ip(ip), port(port) {}
    
    bool operator==(const Peer& other) const {
        return ip == other.ip && port == other.port;
    }
    
    bool operator!=(const Peer& other) const {
        return !(*this == other);
    }
};
 
// Socket Library Initialization
bool init_socket_library();
 
void cleanup_socket_library();
 
// TCP Socket Functions
socket_t create_tcp_client(const std::string& host, int port, int timeout_ms = 0);
 
socket_t create_tcp_client_v4(const std::string& host, int port, int timeout_ms = 0);
 
socket_t create_tcp_client_v6(const std::string& host, int port, int timeout_ms = 0);
 
socket_t create_tcp_server(int port, int backlog = 5, const std::string& bind_address = "");
 
socket_t create_tcp_server_v4(int port, int backlog = 5, const std::string& bind_address = "");
 
socket_t create_tcp_server_v6(int port, int backlog = 5, const std::string& bind_address = "");
 
socket_t accept_client(socket_t server_socket);
 
std::string get_peer_address(socket_t socket);
 
int send_tcp_data(socket_t socket, const std::vector<uint8_t>& data);
 
std::vector<uint8_t> receive_tcp_data(socket_t socket, size_t buffer_size = 1024);
 
int send_tcp_message_framed(socket_t socket, const std::vector<uint8_t>& message);
 
std::vector<uint8_t> receive_exact_bytes(socket_t socket, size_t num_bytes);
 
std::vector<uint8_t> receive_tcp_message_framed(socket_t socket);
 
// Convenience functions for string compatibility
int send_tcp_string(socket_t socket, const std::string& data);
 
std::string receive_tcp_string(socket_t socket, size_t buffer_size = 1024);
 
int send_tcp_string_framed(socket_t socket, const std::string& message);
 
std::string receive_tcp_string_framed(socket_t socket);
 
// UDP Socket Functions
socket_t create_udp_socket(int port = 0, const std::string& bind_address = "");
 
socket_t create_udp_socket_v4(int port = 0, const std::string& bind_address = "");
 
socket_t create_udp_socket_v6(int port = 0, const std::string& bind_address = "");
 
int send_udp_data(socket_t socket, const std::vector<uint8_t>& data, const Peer& peer);
 
int send_udp_data_to(socket_t socket, const std::vector<uint8_t>& data, const std::string& hostname, int port);
 
std::vector<uint8_t> receive_udp_data(socket_t socket, size_t buffer_size, Peer& sender_peer);
 
std::vector<uint8_t> receive_udp_data_with_timeout(socket_t socket, size_t buffer_size, int timeout_ms, 
                                                   std::string* sender_ip = nullptr, int* sender_port = nullptr);
 
// Common Socket Functions
void close_socket(socket_t socket, bool force = false);
 
bool is_valid_socket(socket_t socket);
 
bool set_socket_nonblocking(socket_t socket);
 
bool set_socket_blocking(socket_t socket);
 
bool is_tcp_socket(socket_t socket);
 
bool connect_with_timeout(socket_t socket, struct sockaddr* addr, socklen_t addr_len, int timeout_ms);
 
int get_ephemeral_port(socket_t socket);
 
} // namespace librats