repository_factory.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 <memory>
 
#ifdef PACS_WITH_DATABASE_SYSTEM
 
namespace kcenon::pacs::storage {
 
// Forward declarations
class pacs_database_adapter;
class patient_repository;
class study_repository;
class series_repository;
class instance_repository;
class mpps_repository;
class worklist_repository;
class ups_repository;
class audit_repository;
class job_repository;
class annotation_repository;
class routing_repository;
class node_repository;
class sync_repository;
class sync_config_repository;
class sync_conflict_repository;
class sync_history_repository;
class key_image_repository;
class measurement_repository;
class viewer_state_repository;
class viewer_state_record_repository;
class recent_study_repository;
class prefetch_repository;
class prefetch_rule_repository;
class prefetch_history_repository;
class commitment_repository;
 
struct sync_repository_set {
    std::shared_ptr<sync_config_repository> configs;
    std::shared_ptr<sync_conflict_repository> conflicts;
    std::shared_ptr<sync_history_repository> history;
};
 
struct viewer_state_repository_set {
    std::shared_ptr<viewer_state_record_repository> records;
    std::shared_ptr<recent_study_repository> recent_studies;
};
 
struct prefetch_repository_set {
    std::shared_ptr<prefetch_rule_repository> rules;
    std::shared_ptr<prefetch_history_repository> history;
};
 
struct canonical_repository_set {
    std::shared_ptr<patient_repository> patients;
    std::shared_ptr<study_repository> studies;
    std::shared_ptr<series_repository> series;
    std::shared_ptr<instance_repository> instances;
    std::shared_ptr<mpps_repository> mpps;
    std::shared_ptr<worklist_repository> worklist;
    std::shared_ptr<ups_repository> ups;
    std::shared_ptr<audit_repository> audit;
    std::shared_ptr<job_repository> jobs;
    std::shared_ptr<annotation_repository> annotations;
    std::shared_ptr<routing_repository> routing_rules;
    std::shared_ptr<node_repository> nodes;
    sync_repository_set sync;
    std::shared_ptr<key_image_repository> key_images;
    std::shared_ptr<measurement_repository> measurements;
    viewer_state_repository_set viewer_state;
    prefetch_repository_set prefetch;
    std::shared_ptr<commitment_repository> commitments;
};
 
struct compatibility_repository_set {
    std::shared_ptr<sync_repository> sync_states;
    std::shared_ptr<viewer_state_repository> viewer_states;
    std::shared_ptr<prefetch_repository> prefetch_queue;
};
 
class repository_factory {
public:
    explicit repository_factory(std::shared_ptr<pacs_database_adapter> db);
 
    ~repository_factory() = default;
 
    // Non-copyable
    repository_factory(const repository_factory&) = delete;
    auto operator=(const repository_factory&) -> repository_factory& = delete;
 
    // Movable
    repository_factory(repository_factory&&) noexcept = default;
    auto operator=(repository_factory&&) noexcept
        -> repository_factory& = default;
 
    [[nodiscard]] auto patients() -> std::shared_ptr<patient_repository>;
 
    [[nodiscard]] auto studies() -> std::shared_ptr<study_repository>;
 
    [[nodiscard]] auto series() -> std::shared_ptr<series_repository>;
 
    [[nodiscard]] auto instances() -> std::shared_ptr<instance_repository>;
 
    [[nodiscard]] auto mpps() -> std::shared_ptr<mpps_repository>;
 
    [[nodiscard]] auto worklist() -> std::shared_ptr<worklist_repository>;
 
    [[nodiscard]] auto ups() -> std::shared_ptr<ups_repository>;
 
    [[nodiscard]] auto audit() -> std::shared_ptr<audit_repository>;
 
    [[nodiscard]] auto jobs() -> std::shared_ptr<job_repository>;
 
    [[nodiscard]] auto annotations() -> std::shared_ptr<annotation_repository>;
 
    [[nodiscard]] auto routing_rules() -> std::shared_ptr<routing_repository>;
 
    [[nodiscard]] auto nodes() -> std::shared_ptr<node_repository>;
 
    [[nodiscard]] auto sync_states() -> std::shared_ptr<sync_repository>;
 
    [[nodiscard]] auto sync_configs()
        -> std::shared_ptr<sync_config_repository>;
 
    [[nodiscard]] auto sync_conflicts()
        -> std::shared_ptr<sync_conflict_repository>;
 
    [[nodiscard]] auto sync_history()
        -> std::shared_ptr<sync_history_repository>;
 
    [[nodiscard]] auto key_images() -> std::shared_ptr<key_image_repository>;
 
    [[nodiscard]] auto measurements()
        -> std::shared_ptr<measurement_repository>;
 
    [[nodiscard]] auto viewer_states()
        -> std::shared_ptr<viewer_state_repository>;
 
    [[nodiscard]] auto viewer_state_records()
        -> std::shared_ptr<viewer_state_record_repository>;
 
    [[nodiscard]] auto recent_studies()
        -> std::shared_ptr<recent_study_repository>;
 
    [[nodiscard]] auto prefetch_queue()
        -> std::shared_ptr<prefetch_repository>;
 
    [[nodiscard]] auto prefetch_rules()
        -> std::shared_ptr<prefetch_rule_repository>;
 
    [[nodiscard]] auto prefetch_history()
        -> std::shared_ptr<prefetch_history_repository>;
 
    [[nodiscard]] auto commitments()
        -> std::shared_ptr<commitment_repository>;
 
    [[nodiscard]] auto canonical_repositories() -> canonical_repository_set;
 
    [[nodiscard]] auto compatibility_repositories()
        -> compatibility_repository_set;
 
    [[nodiscard]] auto db() const -> std::shared_ptr<pacs_database_adapter>;
 
private:
    std::shared_ptr<pacs_database_adapter> db_;
 
    std::shared_ptr<patient_repository> patients_;
    std::shared_ptr<study_repository> studies_;
    std::shared_ptr<series_repository> series_;
    std::shared_ptr<instance_repository> instances_;
    std::shared_ptr<mpps_repository> mpps_;
    std::shared_ptr<worklist_repository> worklist_;
    std::shared_ptr<ups_repository> ups_;
    std::shared_ptr<audit_repository> audit_;
    std::shared_ptr<job_repository> jobs_;
    std::shared_ptr<annotation_repository> annotations_;
    std::shared_ptr<routing_repository> routing_rules_;
    std::shared_ptr<node_repository> nodes_;
    std::shared_ptr<sync_repository> sync_states_;
    std::shared_ptr<sync_config_repository> sync_configs_;
    std::shared_ptr<sync_conflict_repository> sync_conflicts_;
    std::shared_ptr<sync_history_repository> sync_history_;
    std::shared_ptr<key_image_repository> key_images_;
    std::shared_ptr<measurement_repository> measurements_;
    std::shared_ptr<viewer_state_repository> viewer_states_;
    std::shared_ptr<viewer_state_record_repository> viewer_state_records_;
    std::shared_ptr<recent_study_repository> recent_studies_;
    std::shared_ptr<prefetch_repository> prefetch_queue_;
    std::shared_ptr<prefetch_rule_repository> prefetch_rules_;
    std::shared_ptr<prefetch_history_repository> prefetch_history_;
    std::shared_ptr<commitment_repository> commitments_;
};
 
}  // namespace kcenon::pacs::storage
 
#endif  // PACS_WITH_DATABASE_SYSTEM