sync_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/client/sync_types.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 sync_repository {
public:
    // =========================================================================
    // Construction / Destruction
    // =========================================================================
 
    explicit sync_repository(std::shared_ptr<pacs_database_adapter> db);
 
    ~sync_repository();
 
    // Non-copyable, movable
    sync_repository(const sync_repository&) = delete;
    auto operator=(const sync_repository&) -> sync_repository& = delete;
    sync_repository(sync_repository&&) noexcept;
    auto operator=(sync_repository&&) noexcept -> sync_repository&;
 
    // =========================================================================
    // Config Operations
    // =========================================================================
 
    [[nodiscard]] auto save_config(const client::sync_config& config) -> VoidResult;
 
    [[nodiscard]] auto find_config(std::string_view config_id) const
        -> std::optional<client::sync_config>;
 
    [[nodiscard]] auto list_configs() const -> std::vector<client::sync_config>;
 
    [[nodiscard]] auto list_enabled_configs() const -> std::vector<client::sync_config>;
 
    [[nodiscard]] auto remove_config(std::string_view config_id) -> VoidResult;
 
    [[nodiscard]] auto update_config_stats(
        std::string_view config_id,
        bool success,
        size_t studies_synced) -> VoidResult;
 
    // =========================================================================
    // Conflict Operations
    // =========================================================================
 
    [[nodiscard]] auto save_conflict(const client::sync_conflict& conflict) -> VoidResult;
 
    [[nodiscard]] auto find_conflict(std::string_view study_uid) const
        -> std::optional<client::sync_conflict>;
 
    [[nodiscard]] auto list_conflicts(std::string_view config_id) const
        -> std::vector<client::sync_conflict>;
 
    [[nodiscard]] auto list_unresolved_conflicts() const
        -> std::vector<client::sync_conflict>;
 
    [[nodiscard]] auto resolve_conflict(
        std::string_view study_uid,
        client::conflict_resolution resolution) -> VoidResult;
 
    [[nodiscard]] auto cleanup_old_conflicts(std::chrono::hours max_age)
        -> Result<size_t>;
 
    // =========================================================================
    // History Operations
    // =========================================================================
 
    [[nodiscard]] auto save_history(const client::sync_history& history) -> VoidResult;
 
    [[nodiscard]] auto list_history(std::string_view config_id, size_t limit = 100) const
        -> std::vector<client::sync_history>;
 
    [[nodiscard]] auto get_last_history(std::string_view config_id) const
        -> std::optional<client::sync_history>;
 
    [[nodiscard]] auto cleanup_old_history(std::chrono::hours max_age)
        -> Result<size_t>;
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] auto count_configs() const -> size_t;
 
    [[nodiscard]] auto count_unresolved_conflicts() const -> size_t;
 
    [[nodiscard]] auto count_syncs_today() const -> size_t;
 
    // =========================================================================
    // Database Information
    // =========================================================================
 
    [[nodiscard]] auto is_valid() const noexcept -> bool;
 
private:
    // =========================================================================
    // Private Implementation
    // =========================================================================
 
    [[nodiscard]] auto map_row_to_config(const database_row& row) const
        -> client::sync_config;
 
    [[nodiscard]] auto map_row_to_conflict(const database_row& row) const
        -> client::sync_conflict;
 
    [[nodiscard]] auto map_row_to_history(const database_row& row) const
        -> client::sync_history;
 
    [[nodiscard]] static auto serialize_vector(
        const std::vector<std::string>& vec) -> std::string;
 
    [[nodiscard]] static auto deserialize_vector(
        std::string_view json) -> std::vector<std::string>;
 
    [[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 sync_repository {
public:
    explicit sync_repository(sqlite3* db);
    ~sync_repository();
 
    sync_repository(const sync_repository&) = delete;
    auto operator=(const sync_repository&) -> sync_repository& = delete;
    sync_repository(sync_repository&&) noexcept;
    auto operator=(sync_repository&&) noexcept -> sync_repository&;
 
    // Config Operations
    [[nodiscard]] auto save_config(const client::sync_config& config) -> VoidResult;
    [[nodiscard]] auto find_config(std::string_view config_id) const
        -> std::optional<client::sync_config>;
    [[nodiscard]] auto list_configs() const -> std::vector<client::sync_config>;
    [[nodiscard]] auto list_enabled_configs() const -> std::vector<client::sync_config>;
    [[nodiscard]] auto remove_config(std::string_view config_id) -> VoidResult;
    [[nodiscard]] auto update_config_stats(
        std::string_view config_id, bool success, size_t studies_synced) -> VoidResult;
 
    // Conflict Operations
    [[nodiscard]] auto save_conflict(const client::sync_conflict& conflict) -> VoidResult;
    [[nodiscard]] auto find_conflict(std::string_view study_uid) const
        -> std::optional<client::sync_conflict>;
    [[nodiscard]] auto list_conflicts(std::string_view config_id) const
        -> std::vector<client::sync_conflict>;
    [[nodiscard]] auto list_unresolved_conflicts() const
        -> std::vector<client::sync_conflict>;
    [[nodiscard]] auto resolve_conflict(
        std::string_view study_uid, client::conflict_resolution resolution) -> VoidResult;
    [[nodiscard]] auto cleanup_old_conflicts(std::chrono::hours max_age)
        -> Result<size_t>;
 
    // History Operations
    [[nodiscard]] auto save_history(const client::sync_history& history) -> VoidResult;
    [[nodiscard]] auto list_history(std::string_view config_id, size_t limit = 100) const
        -> std::vector<client::sync_history>;
    [[nodiscard]] auto get_last_history(std::string_view config_id) const
        -> std::optional<client::sync_history>;
    [[nodiscard]] auto cleanup_old_history(std::chrono::hours max_age)
        -> Result<size_t>;
 
    // Statistics
    [[nodiscard]] auto count_configs() const -> size_t;
    [[nodiscard]] auto count_unresolved_conflicts() const -> size_t;
    [[nodiscard]] auto count_syncs_today() const -> size_t;
 
    // Database Information
    [[nodiscard]] auto is_valid() const noexcept -> bool;
 
private:
    [[nodiscard]] auto parse_config_row(void* stmt) const -> client::sync_config;
    [[nodiscard]] auto parse_conflict_row(void* stmt) const -> client::sync_conflict;
    [[nodiscard]] auto parse_history_row(void* stmt) const -> client::sync_history;
    [[nodiscard]] static auto serialize_vector(
        const std::vector<std::string>& vec) -> std::string;
    [[nodiscard]] static auto deserialize_vector(
        std::string_view json) -> std::vector<std::string>;
 
    sqlite3* db_{nullptr};
};
 
}  // namespace kcenon::pacs::storage
 
#endif  // PACS_WITH_DATABASE_SYSTEM