sync_manager.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/pacs/core/result.h"
#include "kcenon/pacs/di/ilogger.h"
 
#include <atomic>
#include <future>
#include <memory>
#include <shared_mutex>
#include <string>
#include <string_view>
#include <vector>
 
// Forward declarations
namespace kcenon::pacs::storage {
class sync_repository;
class sync_config_repository;
class sync_conflict_repository;
class sync_history_repository;
}
 
namespace kcenon::pacs::services {
class query_scu;
}
 
namespace kcenon::pacs::client {
 
// Forward declarations
class remote_node_manager;
class job_manager;
 
struct sync_repositories {
    std::shared_ptr<storage::sync_config_repository> configs;
    std::shared_ptr<storage::sync_conflict_repository> conflicts;
    std::shared_ptr<storage::sync_history_repository> history;
};
 
// =============================================================================
// Sync Manager
// =============================================================================
 
class sync_manager {
public:
    // =========================================================================
    // Construction / Destruction
    // =========================================================================
 
    explicit sync_manager(
        sync_repositories repositories,
        std::shared_ptr<remote_node_manager> node_manager,
        std::shared_ptr<job_manager> job_manager,
        std::shared_ptr<services::query_scu> query_scu,
        std::shared_ptr<di::ILogger> logger = nullptr);
 
    explicit sync_manager(
        const sync_manager_config& config,
        sync_repositories repositories,
        std::shared_ptr<remote_node_manager> node_manager,
        std::shared_ptr<job_manager> job_manager,
        std::shared_ptr<services::query_scu> query_scu,
        std::shared_ptr<di::ILogger> logger = nullptr);
 
    explicit sync_manager(
        std::shared_ptr<storage::sync_repository> repo,
        std::shared_ptr<remote_node_manager> node_manager,
        std::shared_ptr<job_manager> job_manager,
        std::shared_ptr<services::query_scu> query_scu,
        std::shared_ptr<di::ILogger> logger = nullptr);
 
    explicit sync_manager(
        const sync_manager_config& config,
        std::shared_ptr<storage::sync_repository> repo,
        std::shared_ptr<remote_node_manager> node_manager,
        std::shared_ptr<job_manager> job_manager,
        std::shared_ptr<services::query_scu> query_scu,
        std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~sync_manager();
 
    // Non-copyable, non-movable
    sync_manager(const sync_manager&) = delete;
    auto operator=(const sync_manager&) -> sync_manager& = delete;
    sync_manager(sync_manager&&) = delete;
    auto operator=(sync_manager&&) -> sync_manager& = delete;
 
    // =========================================================================
    // Config CRUD
    // =========================================================================
 
    [[nodiscard]] auto add_config(const sync_config& config) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto update_config(const sync_config& config) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto remove_config(std::string_view config_id) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto get_config(std::string_view config_id) const
        -> std::optional<sync_config>;
 
    [[nodiscard]] auto list_configs() const -> std::vector<sync_config>;
 
    // =========================================================================
    // Manual Sync Operations
    // =========================================================================
 
    [[nodiscard]] auto sync_now(std::string_view config_id) -> std::string;
 
    [[nodiscard]] auto full_sync(std::string_view config_id) -> std::string;
 
    [[nodiscard]] auto incremental_sync(std::string_view config_id) -> std::string;
 
    [[nodiscard]] auto wait_for_sync(std::string_view job_id)
        -> std::future<sync_result>;
 
    // =========================================================================
    // Comparison (Dry Run)
    // =========================================================================
 
    [[nodiscard]] auto compare(std::string_view config_id) -> sync_result;
 
    [[nodiscard]] auto compare_async(std::string_view config_id)
        -> std::future<sync_result>;
 
    // =========================================================================
    // Conflict Management
    // =========================================================================
 
    [[nodiscard]] auto get_conflicts() const -> std::vector<sync_conflict>;
 
    [[nodiscard]] auto get_conflicts(std::string_view config_id) const
        -> std::vector<sync_conflict>;
 
    [[nodiscard]] auto resolve_conflict(
        std::string_view study_uid,
        conflict_resolution resolution) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto resolve_all_conflicts(
        std::string_view config_id,
        conflict_resolution resolution) -> kcenon::pacs::VoidResult;
 
    // =========================================================================
    // Scheduler
    // =========================================================================
 
    void start_scheduler();
 
    void stop_scheduler();
 
    [[nodiscard]] auto is_scheduler_running() const noexcept -> bool;
 
    // =========================================================================
    // Status
    // =========================================================================
 
    [[nodiscard]] auto is_syncing(std::string_view config_id) const -> bool;
 
    [[nodiscard]] auto get_last_result(std::string_view config_id) const
        -> sync_result;
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] auto get_statistics() const -> sync_statistics;
 
    [[nodiscard]] auto get_statistics(std::string_view config_id) const
        -> sync_statistics;
 
    // =========================================================================
    // Callbacks
    // =========================================================================
 
    void set_progress_callback(sync_progress_callback callback);
 
    void set_completion_callback(sync_completion_callback callback);
 
    void set_conflict_callback(sync_conflict_callback callback);
 
    // =========================================================================
    // Configuration
    // =========================================================================
 
    [[nodiscard]] auto config() const noexcept -> const sync_manager_config&;
 
private:
    // =========================================================================
    // Private Implementation (Pimpl)
    // =========================================================================
 
    struct impl;
    std::unique_ptr<impl> impl_;
};
 
}  // namespace kcenon::pacs::client