viewer_state_repository.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include "kcenon/pacs/storage/viewer_state_record.h"
 
#include <kcenon/common/patterns/result.h>
 
#include <memory>
#include <optional>
#include <string>
#include <string_view>
#include <vector>
 
#ifdef PACS_WITH_DATABASE_SYSTEM
 
#include "kcenon/pacs/storage/pacs_database_adapter.h"
 
namespace kcenon::pacs::storage {
 
template <typename T>
using Result = kcenon::common::Result<T>;
 
using VoidResult = kcenon::common::VoidResult;
 
class viewer_state_repository {
public:
    explicit viewer_state_repository(std::shared_ptr<pacs_database_adapter> db);
    ~viewer_state_repository();
 
    viewer_state_repository(const viewer_state_repository&) = delete;
    auto operator=(const viewer_state_repository&) -> viewer_state_repository& = delete;
    viewer_state_repository(viewer_state_repository&&) noexcept;
    auto operator=(viewer_state_repository&&) noexcept -> viewer_state_repository&;
 
    // =========================================================================
    // Viewer State Operations
    // =========================================================================
 
    [[nodiscard]] auto save_state(const viewer_state_record& record) -> VoidResult;
 
    [[nodiscard]] auto find_state_by_id(std::string_view state_id) const
        -> std::optional<viewer_state_record>;
 
    [[nodiscard]] auto find_states_by_study(std::string_view study_uid) const
        -> std::vector<viewer_state_record>;
 
    [[nodiscard]] auto search_states(const viewer_state_query& query) const
        -> std::vector<viewer_state_record>;
 
    [[nodiscard]] auto remove_state(std::string_view state_id) -> VoidResult;
 
    [[nodiscard]] auto count_states() const -> size_t;
 
    // =========================================================================
    // Recent Studies Operations
    // =========================================================================
 
    [[nodiscard]] auto record_study_access(
        std::string_view user_id,
        std::string_view study_uid) -> VoidResult;
 
    [[nodiscard]] auto get_recent_studies(
        std::string_view user_id,
        size_t limit = 20) const -> std::vector<recent_study_record>;
 
    [[nodiscard]] auto clear_recent_studies(std::string_view user_id) -> VoidResult;
 
    [[nodiscard]] auto count_recent_studies(std::string_view user_id) const -> size_t;
 
    // =========================================================================
    // Database Information
    // =========================================================================
 
    [[nodiscard]] auto is_valid() const noexcept -> bool;
 
private:
    [[nodiscard]] auto map_row_to_state(const database_row& row) const
        -> viewer_state_record;
    [[nodiscard]] auto map_row_to_recent_study(const database_row& row) const
        -> recent_study_record;
    [[nodiscard]] auto parse_timestamp(const std::string& str) const
        -> std::chrono::system_clock::time_point;
    [[nodiscard]] auto format_timestamp(
        std::chrono::system_clock::time_point tp) const -> std::string;
 
    std::shared_ptr<pacs_database_adapter> db_;
};
 
}  // namespace kcenon::pacs::storage
 
#else  // !PACS_WITH_DATABASE_SYSTEM
 
// =============================================================================
// Legacy SQLite Interface
// =============================================================================
 
struct sqlite3;
 
namespace kcenon::pacs::storage {
 
template <typename T>
using Result = kcenon::common::Result<T>;
 
using VoidResult = kcenon::common::VoidResult;
 
class viewer_state_repository {
public:
    explicit viewer_state_repository(sqlite3* db);
    ~viewer_state_repository();
 
    viewer_state_repository(const viewer_state_repository&) = delete;
    auto operator=(const viewer_state_repository&) -> viewer_state_repository& = delete;
    viewer_state_repository(viewer_state_repository&&) noexcept;
    auto operator=(viewer_state_repository&&) noexcept -> viewer_state_repository&;
 
    // Viewer State Operations
    [[nodiscard]] auto save_state(const viewer_state_record& record) -> VoidResult;
    [[nodiscard]] auto find_state_by_id(std::string_view state_id) const
        -> std::optional<viewer_state_record>;
    [[nodiscard]] auto find_states_by_study(std::string_view study_uid) const
        -> std::vector<viewer_state_record>;
    [[nodiscard]] auto search_states(const viewer_state_query& query) const
        -> std::vector<viewer_state_record>;
    [[nodiscard]] auto remove_state(std::string_view state_id) -> VoidResult;
    [[nodiscard]] auto count_states() const -> size_t;
 
    // Recent Studies Operations
    [[nodiscard]] auto record_study_access(
        std::string_view user_id, std::string_view study_uid) -> VoidResult;
    [[nodiscard]] auto get_recent_studies(
        std::string_view user_id, size_t limit = 20) const
        -> std::vector<recent_study_record>;
    [[nodiscard]] auto clear_recent_studies(std::string_view user_id) -> VoidResult;
    [[nodiscard]] auto count_recent_studies(std::string_view user_id) const -> size_t;
 
    // Database Information
    [[nodiscard]] auto is_valid() const noexcept -> bool;
 
private:
    [[nodiscard]] auto parse_state_row(void* stmt) const -> viewer_state_record;
    [[nodiscard]] auto parse_recent_study_row(void* stmt) const -> recent_study_record;
 
    sqlite3* db_{nullptr};
};
 
}  // namespace kcenon::pacs::storage
 
#endif  // PACS_WITH_DATABASE_SYSTEM