session.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "irsol/protocol.hpp"
#include "irsol/server/client/state.hpp"
#include "irsol/types.hpp"
 
#include <atomic>
#include <memory>
#include <mutex>
#include <string>
 
namespace irsol {
namespace server {
 
// Forward declaration
class App;
 
class ClientSession
{
public:
  ClientSession(const irsol::types::client_id_t& id, irsol::types::socket_t&& sock, App& app);
 
  void run();
 
  void handleOutMessages(std::vector<protocol::OutMessage>&& messages);
 
  void handleOutMessage(protocol::OutMessage&& message);
 
  void handleSerializedMessage(const protocol::internal::SerializedMessage& serializedMessage);
 
  const App& app() const
  {
    return m_app;
  }
 
  App& app()
  {
    return m_app;
  }
 
  const irsol::types::client_id_t& id() const
  {
    return m_id;
  }
 
  const irsol::types::socket_t& socket() const
  {
    return m_socket;
  }
 
  irsol::types::socket_t& socket()
  {
    return m_socket;
  }
 
  std::mutex& socketMutex()
  {
    return m_socketMutex;
  }
 
  const irsol::server::internal::UserSessionData& userData() const
  {
    return m_sessionData;
  }
 
  irsol::server::internal::UserSessionData& userData()
  {
    return m_sessionData;
  }
 
private:
  void processInMessageBuffer(std::string& messageBuffer);
 
  void processInRawMessage(const std::string& rawMessage);
 
  void send(const std::string& message);
 
  void send(const irsol::types::byte_t* const data, size_t size);
 
  irsol::types::client_id_t m_id;
 
  irsol::types::socket_t m_socket;
 
  std::mutex m_socketMutex{};
 
  irsol::server::internal::UserSessionData m_sessionData{};
 
  App& m_app;
};
 
}  // namespace server
}  // namespace irsol