connection.hpp

Go to the documentation of this file.

#pragma once
 
#include <string>
#include <cstdint>
#include <memory>
#include <functional>
#include <sockpp/tcp_socket.h>
 
class GameServer;
 
class Connection : public std::enable_shared_from_this<Connection>
{
public:
    using MessageCallback = std::function<void(const std::string &)>;
    using DisconnectCallback = std::function<void()>;
 
    explicit Connection(sockpp::tcp_socket socket, uint32_t id);
    ~Connection();
 
    void start();
 
    bool send(const std::string &message);
 
    void close();
 
    bool isOpen() const { return socket_.is_open(); }
 
    uint32_t getId() const { return id_; }
 
    void setMessageCallback(MessageCallback callback)
    {
        message_callback_ = callback;
    }
 
    void setDisconnectCallback(DisconnectCallback callback)
    {
        disconnect_callback_ = callback;
    }
 
private:
    std::string readMessage();
 
    bool writeMessage(const std::string &message);
 
    sockpp::tcp_socket socket_;
    uint32_t id_;
    MessageCallback message_callback_;
    DisconnectCallback disconnect_callback_;
    bool running_;
};