prefetch_types.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 <chrono>
#include <cstddef>
#include <string>
#include <vector>
 
namespace kcenon::pacs::client {
 
// =============================================================================
// Prefetch Trigger
// =============================================================================
 
enum class prefetch_trigger {
    worklist_match,  
    prior_studies,   
    scheduled_exam,  
    manual           
};
 
[[nodiscard]] constexpr const char* to_string(prefetch_trigger trigger) noexcept {
    switch (trigger) {
        case prefetch_trigger::worklist_match: return "worklist_match";
        case prefetch_trigger::prior_studies: return "prior_studies";
        case prefetch_trigger::scheduled_exam: return "scheduled_exam";
        case prefetch_trigger::manual: return "manual";
        default: return "unknown";
    }
}
 
[[nodiscard]] inline prefetch_trigger prefetch_trigger_from_string(
    std::string_view str) noexcept {
    if (str == "worklist_match") return prefetch_trigger::worklist_match;
    if (str == "prior_studies") return prefetch_trigger::prior_studies;
    if (str == "scheduled_exam") return prefetch_trigger::scheduled_exam;
    if (str == "manual") return prefetch_trigger::manual;
    return prefetch_trigger::manual;
}
 
// =============================================================================
// Prefetch Rule
// =============================================================================
 
struct prefetch_rule {
    // =========================================================================
    // Identification
    // =========================================================================
 
    std::string rule_id;        
    std::string name;           
    bool enabled{true};         
 
    prefetch_trigger trigger;   
 
    // =========================================================================
    // Filters
    // =========================================================================
 
    std::string modality_filter;     
    std::string body_part_filter;    
    std::string station_ae_filter;   
 
    // =========================================================================
    // Prior Study Settings
    // =========================================================================
 
    std::chrono::hours prior_lookback{8760};     
    size_t max_prior_studies{3};                 
    std::vector<std::string> prior_modalities;   
 
    // =========================================================================
    // Source Nodes
    // =========================================================================
 
    std::vector<std::string> source_node_ids;    
 
    // =========================================================================
    // Schedule Settings
    // =========================================================================
 
    std::string schedule_cron;                   
    std::chrono::minutes advance_time{60};       
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    size_t triggered_count{0};                   
    size_t studies_prefetched{0};                
    std::chrono::system_clock::time_point last_triggered;  
 
    // =========================================================================
    // Database Fields
    // =========================================================================
 
    int64_t pk{0};  
};
 
// =============================================================================
// Prefetch Result
// =============================================================================
 
struct prefetch_result {
    std::string patient_id;           
    std::string patient_name;         
    size_t studies_found{0};          
    size_t studies_prefetched{0};     
    size_t studies_already_local{0};  
    std::vector<std::string> job_ids; 
    std::chrono::milliseconds elapsed{0};  
 
    [[nodiscard]] bool is_success() const noexcept {
        return studies_prefetched > 0 || studies_already_local > 0;
    }
};
 
// =============================================================================
// Prefetch History
// =============================================================================
 
struct prefetch_history {
    std::string patient_id;           
    std::string study_uid;            
    std::string rule_id;              
    std::string source_node_id;       
    std::string job_id;               
    std::string status;               
    std::chrono::system_clock::time_point prefetched_at;  
 
    int64_t pk{0};  
};
 
// =============================================================================
// Prefetch Manager Configuration
// =============================================================================
 
struct prefetch_manager_config {
    bool enabled{true};                             
    std::chrono::seconds worklist_check_interval{300};  
    size_t max_concurrent_prefetch{4};              
    bool deduplicate_requests{true};                
};
 
// =============================================================================
// Rule Statistics
// =============================================================================
 
struct prefetch_rule_statistics {
    size_t triggered_count{0};      
    size_t studies_prefetched{0};   
    size_t bytes_prefetched{0};     
};
 
}  // namespace kcenon::pacs::client