Socket.cpp

//
// Created by george on 25.06.26.
//

#include <unistd.h>
#include <iostream>
#include <stdexcept>
#include <string>

#include "Socket.h"

namespace http {
    Socket::Socket():
        mSocket(INVALID_SOCKET),
        mSocketAddress(),
        mSocketAddressLength(0)
    {
        mSocket = ::socket(AF_INET, SOCK_STREAM, 0);
        if (mSocket < 0)
        {
            throw std::runtime_error("Cannot create socket");
        }
    }

    Socket::Socket(Socket&& other) noexcept:
        Socket(other.mSocket, other.mSocketAddress, other.mSocketAddressLength)
    {
        other.mSocket = INVALID_SOCKET;
        other.mSocketAddressLength = 0;
    }

    Socket::Socket(int socket, sockaddr_in const& socketAddress, unsigned int socketAddressLength) noexcept:
        mSocket(socket),
        mSocketAddress(socketAddress),
        mSocketAddressLength(socketAddressLength)
    {
    }

    Socket::operator sockaddr* () {
        return reinterpret_cast<sockaddr*>(&mSocketAddress);
    }

    Socket::~Socket() {
        close();
    }
    void Socket::bindToAddress(std::string const& address, int port) {
        mSocketAddress.sin_family = AF_INET;
        mSocketAddress.sin_addr.s_addr = inet_addr(address.c_str());
        mSocketAddress.sin_port = htons(port);

        if (int err = bind(mSocket, (sockaddr *)&mSocketAddress, sizeof(mSocketAddress)) < 0)
        {
            throw std::runtime_error("Cannot connect socket to address (error " + std::to_string(err) + ")");
        }
        mIPAddress = address;
        mPort = port;
    }

    int Socket::listen(int backlog) {
        if (isValid()) {
            return ::listen(mSocket, backlog);
        }
        return -1;
    }

    Socket Socket::accept() {
        sockaddr_in saddress;
        socklen_t saddress_length = sizeof(saddress);
        int acceptedSocket = ::accept(mSocket, (sockaddr *)&saddress, (socklen_t*)&saddress_length);
        if (acceptedSocket < 0) {
            throw std::runtime_error("Cannot accept connection from socket");
        }
        return Socket(acceptedSocket, saddress, saddress_length);
    }
    ssize_t Socket::receive(std::string& request) {
        if (isValid()) {
            char buffer[kBufferSize];
            ssize_t readBytes = ::recv(mSocket, buffer, kBufferSize, 0);
            buffer[readBytes] = '\0';
            request = buffer;
            return readBytes;
        }
        return -1L;
    }

    ssize_t Socket::send(std::string const& buffer) {
        if (isValid()) {
            return ::send(mSocket, buffer.c_str(), buffer.size(), 0);
        }
        return -1L;
    }

    void Socket::close(void) {
        if (isValid()) {
            ::close(mSocket);
        }
    }

} // http