session_manager.h

Go to the documentation of this file.

/*****************************************************************************
BSD 3-Clause License
 
Copyright (c) 2025, kcenon
All rights reserved.
*****************************************************************************/
 
#pragma once
 
#include "internal/core/session_manager_base.h"
#include "kcenon/network/detail/session/messaging_session.h"
 
namespace kcenon::network::core {
 
struct session_info {
    std::shared_ptr<kcenon::network::session::messaging_session> session;
    std::chrono::steady_clock::time_point created_at;
    std::chrono::steady_clock::time_point last_activity;
 
    explicit session_info(
        std::shared_ptr<kcenon::network::session::messaging_session> sess)
        : session(std::move(sess))
        , created_at(std::chrono::steady_clock::now())
        , last_activity(created_at) {}
};
 
class session_manager : public session_manager_base<session::messaging_session> {
public:
    using session_ptr = std::shared_ptr<session::messaging_session>;
    using base_type = session_manager_base<session::messaging_session>;
 
    explicit session_manager(const session_config& config = session_config())
        : base_type(config) {}
 
    [[nodiscard]] auto get_session_info(const std::string& session_id) const
        -> std::optional<session_info> {
        std::shared_lock lock(sessions_mutex_);
        auto it = active_sessions_.find(session_id);
        if (it != active_sessions_.end()) {
            session_info info(it->second.session);
            info.created_at = it->second.created_at;
            info.last_activity = it->second.last_activity;
            return info;
        }
        return std::nullopt;
    }
 
};
 
} // namespace kcenon::network::core