#include <production_pacs.h>

Collaboration diagram for kcenon::pacs::samples::production_pacs:

Public Member Functions
	production_pacs (const production_config &config)
	Construct Production PACS with configuration.

	~production_pacs ()
	Destructor - ensures clean shutdown.

	production_pacs (const production_pacs &)=delete

production_pacs &	operator= (const production_pacs &)=delete

	production_pacs (production_pacs &&)=delete

production_pacs &	operator= (production_pacs &&)=delete

bool	start ()
	Start the production PACS server.

void	stop ()
	Stop the production PACS server.

void	wait ()
	Block until server shutdown.

bool	is_running () const noexcept
	Check if server is running.

void	on_image_received (std::function< void(const events::image_received_event &)> handler)
	Register handler for image received events.

void	on_query_executed (std::function< void(const events::query_executed_event &)> handler)
	Register handler for query executed events.

void	on_association_event (std::function< void(const events::association_event &)> handler)
	Register handler for association events.

void	on_access_denied (std::function< void(const events::access_denied_event &)> handler)
	Register handler for access denied events.

void	print_status () const
	Print server status to stdout.

const production_statistics &	statistics () const noexcept
	Get current statistics.

monitoring::health_status	get_health () const
	Get health status.

void	export_statistics (const std::filesystem::path &path) const
	Export statistics to JSON file.

const production_config &	config () const noexcept
	Get the configuration.

Private Member Functions
void	setup_mini_pacs ()

void	setup_security ()

void	setup_anonymization ()

void	setup_rest_api ()

void	setup_monitoring ()

void	setup_event_handlers ()

void	dispatch_image_received (const events::image_received_event &event)

void	dispatch_query_executed (const events::query_executed_event &event)

void	dispatch_association_event (const events::association_event &event)

void	dispatch_access_denied (const events::access_denied_event &event)

Private Attributes
production_config	config_

production_statistics	stats_

std::unique_ptr< mini_pacs >	pacs_

std::shared_ptr< security::access_control_manager >	access_control_

std::unique_ptr< security::anonymizer >	anonymizer_

std::unique_ptr< web::rest_server >	rest_server_

std::shared_ptr< monitoring::health_checker >	health_checker_

std::shared_ptr< monitoring::pacs_metrics >	metrics_

std::vector< std::function< void(const events::image_received_event &)> >	image_handlers_

std::vector< std::function< void(const events::query_executed_event &)> >	query_handlers_

std::vector< std::function< void(const events::association_event &)> >	association_handlers_

std::vector< std::function< void(const events::access_denied_event &)> >	access_denied_handlers_

std::mutex	handlers_mutex_

std::mutex	shutdown_mutex_

std::condition_variable	shutdown_cv_

std::atomic< bool >	running_ {false}

Detailed Description

Definition at line 195 of file production_pacs.h.

Constructor & Destructor Documentation

◆ production_pacs() [1/3]

kcenon::pacs::samples::production_pacs::production_pacs ( const production_config & config )

explicit

Construct Production PACS with configuration.

Parameters

config Production configuration

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 22 of file production_pacs.cpp.

    : config_(config) {
    stats_.start_time = std::chrono::system_clock::now();
}

References kcenon::pacs::samples::production_statistics::start_time, and stats_.

◆ ~production_pacs()

kcenon::pacs::samples::production_pacs::~production_pacs ( )

Destructor - ensures clean shutdown.

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 27 of file production_pacs.cpp.

                                  {
    if (running_) {
        stop();
    }
}

References running_, and stop().

Here is the call graph for this function:

◆ production_pacs() [2/3]

kcenon::pacs::samples::production_pacs::production_pacs ( const production_pacs & )

delete

◆ production_pacs() [3/3]

kcenon::pacs::samples::production_pacs::production_pacs ( production_pacs && )

delete

Member Function Documentation

◆ config()

const production_config & kcenon::pacs::samples::production_pacs::config ( ) const

nodiscardnoexcept

Get the configuration.

Returns: Reference to configuration

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 225 of file production_pacs.cpp.

                                                                {
    return config_;
}

References config_.

◆ dispatch_access_denied()

void kcenon::pacs::samples::production_pacs::dispatch_access_denied ( const events::access_denied_event & event )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 353 of file production_pacs.cpp.

                                                                                   {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    stats_.access_denied_count++;
    for (const auto& handler : access_denied_handlers_) {
        try {
            handler(event);
        } catch (const std::exception& e) {
            std::cerr << "Error in access denied handler: " << e.what() << "\n";
        }
    }
}

References kcenon::pacs::samples::production_statistics::access_denied_count, access_denied_handlers_, handlers_mutex_, and stats_.

◆ dispatch_association_event()

void kcenon::pacs::samples::production_pacs::dispatch_association_event ( const events::association_event & event )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 342 of file production_pacs.cpp.

                                                                                     {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    for (const auto& handler : association_handlers_) {
        try {
            handler(event);
        } catch (const std::exception& e) {
            std::cerr << "Error in association event handler: " << e.what() << "\n";
        }
    }
}

References association_handlers_, and handlers_mutex_.

◆ dispatch_image_received()

void kcenon::pacs::samples::production_pacs::dispatch_image_received ( const events::image_received_event & event )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 320 of file production_pacs.cpp.

                                                                                     {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    for (const auto& handler : image_handlers_) {
        try {
            handler(event);
        } catch (const std::exception& e) {
            std::cerr << "Error in image received handler: " << e.what() << "\n";
        }
    }
}

References handlers_mutex_, and image_handlers_.

◆ dispatch_query_executed()

void kcenon::pacs::samples::production_pacs::dispatch_query_executed ( const events::query_executed_event & event )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 331 of file production_pacs.cpp.

                                                                                     {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    for (const auto& handler : query_handlers_) {
        try {
            handler(event);
        } catch (const std::exception& e) {
            std::cerr << "Error in query executed handler: " << e.what() << "\n";
        }
    }
}

References handlers_mutex_, and query_handlers_.

◆ export_statistics()

void kcenon::pacs::samples::production_pacs::export_statistics ( const std::filesystem::path & path ) const

Export statistics to JSON file.

Parameters

path	Output file path

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 196 of file production_pacs.cpp.

                                                                           {
    std::ofstream file(path);
    if (!file.is_open()) {
        std::cerr << "Failed to open statistics file: " << path << "\n";
        return;
    }
 
    auto uptime = stats_.uptime();
 
    file << "{\n";
    file << "  \"uptime_seconds\": " << uptime.count() << ",\n";
    file << "  \"images_stored\": " << stats_.images_stored.load() << ",\n";
    file << "  \"images_anonymized\": " << stats_.images_anonymized.load() << ",\n";
    file << "  \"queries_executed\": " << stats_.queries_executed.load() << ",\n";
    file << "  \"access_denied_count\": " << stats_.access_denied_count.load() << ",\n";
    file << "  \"rest_requests\": " << stats_.rest_requests.load() << ",\n";
    file << "  \"active_associations\": " << stats_.active_associations.load() << ",\n";
    file << "  \"server\": {\n";
    file << "    \"ae_title\": \"" << config_.server.ae_title << "\",\n";
    file << "    \"port\": " << config_.server.port << ",\n";
    file << "    \"tls_enabled\": " << (config_.server.tls.enabled ? "true" : "false") << "\n";
    file << "  },\n";
    file << "  \"rest_api\": {\n";
    file << "    \"enabled\": " << (config_.rest_api.enabled ? "true" : "false") << ",\n";
    file << "    \"port\": " << config_.rest_api.port << "\n";
    file << "  }\n";
    file << "}\n";
}

Here is the call graph for this function:

◆ get_health()

monitoring::health_status kcenon::pacs::samples::production_pacs::get_health ( ) const

nodiscard

Get health status.

Returns: Current health status

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 189 of file production_pacs.cpp.

                                                          {
    if (health_checker_) {
        return health_checker_->get_cached_status();
    }
    return monitoring::health_status{};
}

References health_checker_.

◆ is_running()

bool kcenon::pacs::samples::production_pacs::is_running ( ) const

nodiscardnoexcept

Check if server is running.

Returns: true if running

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 101 of file production_pacs.cpp.

                                                {
    return running_;
}

References running_.

◆ on_access_denied()

void kcenon::pacs::samples::production_pacs::on_access_denied ( std::function< void(const events::access_denied_event &)> handler )

Register handler for access denied events.

Parameters

handler Callback function

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 127 of file production_pacs.cpp.

                                                                 {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    access_denied_handlers_.push_back(std::move(handler));
}

References access_denied_handlers_, and handlers_mutex_.

◆ on_association_event()

void kcenon::pacs::samples::production_pacs::on_association_event ( std::function< void(const events::association_event &)> handler )

Register handler for association events.

Parameters

handler Callback function

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 121 of file production_pacs.cpp.

                                                               {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    association_handlers_.push_back(std::move(handler));
}

References association_handlers_, and handlers_mutex_.

◆ on_image_received()

void kcenon::pacs::samples::production_pacs::on_image_received ( std::function< void(const events::image_received_event &)> handler )

Register handler for image received events.

Parameters

handler Callback function

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 109 of file production_pacs.cpp.

                                                                  {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    image_handlers_.push_back(std::move(handler));
}

References handlers_mutex_, and image_handlers_.

◆ on_query_executed()

void kcenon::pacs::samples::production_pacs::on_query_executed ( std::function< void(const events::query_executed_event &)> handler )

Register handler for query executed events.

Parameters

handler Callback function

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 115 of file production_pacs.cpp.

                                                                  {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    query_handlers_.push_back(std::move(handler));
}

References handlers_mutex_, and query_handlers_.

◆ operator=() [1/2]

production_pacs & kcenon::pacs::samples::production_pacs::operator= ( const production_pacs & )

delete

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

◆ operator=() [2/2]

production_pacs & kcenon::pacs::samples::production_pacs::operator= ( production_pacs && )

delete

◆ print_status()

void kcenon::pacs::samples::production_pacs::print_status ( ) const

Print server status to stdout.

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 137 of file production_pacs.cpp.

                                         {
    auto uptime = stats_.uptime();
    auto hours = std::chrono::duration_cast<std::chrono::hours>(uptime);
    auto minutes = std::chrono::duration_cast<std::chrono::minutes>(uptime) % 60;
    auto seconds = uptime.count() % 60;
 
    std::ostringstream uptime_str;
    uptime_str << hours.count() << "h " << minutes.count() << "m " << seconds << "s";
 
    std::cout << "\n";
    std::cout << "╔══════════════════════════════════════════════════════════════════╗\n";
    std::cout << "║                  Production PACS Server Status                   ║\n";
    std::cout << "╠══════════════════════════════════════════════════════════════════╣\n";
    std::cout << "║  Server:                                                         ║\n";
    std::cout << "║    AE Title:    " << std::setw(48) << std::left
              << config_.server.ae_title << "║\n";
    std::cout << "║    DICOM Port:  " << std::setw(48) << std::left
              << config_.server.port << "║\n";
    std::cout << "║    TLS:         " << std::setw(48) << std::left
              << (config_.server.tls.enabled ? "Enabled" : "Disabled") << "║\n";
    std::cout << "╠══════════════════════════════════════════════════════════════════╣\n";
    std::cout << "║  REST API:                                                       ║\n";
    std::cout << "║    Status:      " << std::setw(48) << std::left
              << (config_.rest_api.enabled ? "Enabled" : "Disabled") << "║\n";
    if (config_.rest_api.enabled) {
        std::cout << "║    Port:        " << std::setw(48) << std::left
                  << config_.rest_api.port << "║\n";
    }
    std::cout << "╠══════════════════════════════════════════════════════════════════╣\n";
    std::cout << "║  Security:                                                       ║\n";
    std::cout << "║    RBAC:        " << std::setw(48) << std::left
              << (config_.security.access_control.enabled ? "Enabled" : "Disabled") << "║\n";
    std::cout << "║    Auto-Anon:   " << std::setw(48) << std::left
              << (config_.security.anonymization.auto_anonymize ? "Enabled" : "Disabled")
              << "║\n";
    std::cout << "╠══════════════════════════════════════════════════════════════════╣\n";
    std::cout << "║  Statistics:                                                     ║\n";
    std::cout << "║    Uptime:      " << std::setw(48) << std::left
              << uptime_str.str() << "║\n";
    std::cout << "║    Images:      " << std::setw(48) << std::left
              << stats_.images_stored.load() << "║\n";
    std::cout << "║    Queries:     " << std::setw(48) << std::left
              << stats_.queries_executed.load() << "║\n";
    std::cout << "║    Associations:" << std::setw(48) << std::left
              << stats_.active_associations.load() << "║\n";
    std::cout << "╚══════════════════════════════════════════════════════════════════╝\n\n";
}

Here is the call graph for this function:

◆ setup_anonymization()

void kcenon::pacs::samples::production_pacs::setup_anonymization ( )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 260 of file production_pacs.cpp.

                                          {
    if (!config_.security.anonymization.auto_anonymize) {
        return;
    }
 
    anonymizer_ = std::make_unique<security::anonymizer>(
        config_.security.anonymization.profile);
}

References kcenon::pacs::samples::security_config::anonymization, anonymizer_, kcenon::pacs::samples::anonymization_config::auto_anonymize, config_, kcenon::pacs::samples::anonymization_config::profile, and kcenon::pacs::samples::production_config::security.

Referenced by start().

Here is the caller graph for this function:

◆ setup_event_handlers()

void kcenon::pacs::samples::production_pacs::setup_event_handlers ( )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 310 of file production_pacs.cpp.

                                           {
    // Note: In a real implementation, we would hook into the Mini PACS
    // event system. For this sample, we demonstrate the event architecture
    // without full integration to keep the sample focused.
}

Referenced by start().

Here is the caller graph for this function:

◆ setup_mini_pacs()

void kcenon::pacs::samples::production_pacs::setup_mini_pacs ( )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 233 of file production_pacs.cpp.

                                      {
    mini_pacs_config pacs_config;
    pacs_config.ae_title = config_.server.ae_title;
    pacs_config.port = config_.server.port;
    pacs_config.storage_path = config_.storage.root_path;
    pacs_config.max_associations = config_.server.max_associations;
    pacs_config.enable_worklist = true;
    pacs_config.enable_mpps = true;
    pacs_config.verbose_logging = (config_.logging.level == "debug");
 
    pacs_ = std::make_unique<mini_pacs>(pacs_config);
}

Referenced by start().

Here is the caller graph for this function:

◆ setup_monitoring()

void kcenon::pacs::samples::production_pacs::setup_monitoring ( )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 293 of file production_pacs.cpp.

                                       {
    // Setup health checker
    monitoring::health_checker_config health_config;
    health_config.check_interval = config_.monitoring.health_check_interval;
    health_config.cache_duration = std::chrono::seconds{5};
    health_config.storage_warning_threshold = 80.0;
    health_config.storage_critical_threshold = 95.0;
 
    health_checker_ = std::make_shared<monitoring::health_checker>(health_config);
    health_checker_->set_version(0, 1, 0, "production_pacs");
 
    // Setup metrics
    if (config_.monitoring.metrics_enabled) {
        metrics_ = std::make_shared<monitoring::pacs_metrics>();
    }
}

References kcenon::pacs::monitoring::health_checker_config::cache_duration, kcenon::pacs::monitoring::health_checker_config::check_interval, config_, kcenon::pacs::samples::monitoring_config::health_check_interval, health_checker_, metrics_, kcenon::pacs::samples::monitoring_config::metrics_enabled, kcenon::pacs::samples::production_config::monitoring, kcenon::pacs::monitoring::health_checker_config::storage_critical_threshold, and kcenon::pacs::monitoring::health_checker_config::storage_warning_threshold.

Referenced by start().

Here is the caller graph for this function:

◆ setup_rest_api()

void kcenon::pacs::samples::production_pacs::setup_rest_api ( )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 269 of file production_pacs.cpp.

                                     {
    if (!config_.rest_api.enabled) {
        return;
    }
 
    web::rest_server_config rest_config;
    rest_config.port = config_.rest_api.port;
    rest_config.enable_cors = config_.rest_api.cors_enabled;
    rest_config.concurrency = 4;
 
    rest_server_ = std::make_unique<web::rest_server>(rest_config);
 
    // Integrate with monitoring
    if (health_checker_) {
        rest_server_->set_health_checker(health_checker_);
    }
    if (metrics_) {
        rest_server_->set_metrics_provider(metrics_);
    }
    if (access_control_) {
        rest_server_->set_access_control_manager(access_control_);
    }
}

References access_control_, kcenon::pacs::web::rest_server_config::concurrency, config_, kcenon::pacs::samples::rest_api_config::cors_enabled, kcenon::pacs::web::rest_server_config::enable_cors, kcenon::pacs::samples::rest_api_config::enabled, health_checker_, metrics_, kcenon::pacs::samples::rest_api_config::port, kcenon::pacs::web::rest_server_config::port, kcenon::pacs::samples::production_config::rest_api, and rest_server_.

Referenced by start().

Here is the caller graph for this function:

◆ setup_security()

void kcenon::pacs::samples::production_pacs::setup_security ( )

private

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 246 of file production_pacs.cpp.

                                     {
    if (!config_.security.access_control.enabled) {
        return;
    }
 
    access_control_ = std::make_shared<security::access_control_manager>();
 
    // Register allowed AE titles
    for (const auto& ae_title : config_.security.allowed_ae_titles) {
        // For simplicity, map AE titles to users with viewer role
        access_control_->register_ae_title(ae_title, ae_title);
    }
}

References kcenon::pacs::samples::security_config::access_control, access_control_, kcenon::pacs::samples::security_config::allowed_ae_titles, config_, kcenon::pacs::samples::access_control_config::enabled, and kcenon::pacs::samples::production_config::security.

Referenced by start().

Here is the caller graph for this function:

◆ start()

bool kcenon::pacs::samples::production_pacs::start ( )

nodiscard

Start the production PACS server.

Returns: true if started successfully

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 37 of file production_pacs.cpp.

                            {
    if (running_) {
        return true;
    }
 
    try {
        // Initialize components in order
        setup_mini_pacs();
        setup_security();
        setup_anonymization();
        setup_monitoring();
        setup_rest_api();
        setup_event_handlers();
 
        // Start Mini PACS
        if (!pacs_->start()) {
            std::cerr << "Failed to start Mini PACS\n";
            return false;
        }
 
        // Start REST API if enabled
        if (config_.rest_api.enabled && rest_server_) {
            rest_server_->start_async();
        }
 
        running_ = true;
        return true;
 
    } catch (const std::exception& e) {
        std::cerr << "Failed to start Production PACS: " << e.what() << "\n";
        return false;
    }
}

References config_, kcenon::pacs::samples::rest_api_config::enabled, pacs_, kcenon::pacs::samples::production_config::rest_api, rest_server_, running_, setup_anonymization(), setup_event_handlers(), setup_mini_pacs(), setup_monitoring(), setup_rest_api(), and setup_security().

Here is the call graph for this function:

◆ statistics()

const production_statistics & kcenon::pacs::samples::production_pacs::statistics ( ) const

nodiscardnoexcept

Get current statistics.

Returns: Reference to statistics structure

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 185 of file production_pacs.cpp.

                                                                        {
    return stats_;
}

References stats_.

◆ stop()

void kcenon::pacs::samples::production_pacs::stop ( )

Stop the production PACS server.

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 71 of file production_pacs.cpp.

                           {
    if (!running_) {
        return;
    }
 
    running_ = false;
 
    // Stop REST API
    if (rest_server_) {
        rest_server_->stop();
    }
 
    // Stop Mini PACS
    if (pacs_) {
        pacs_->stop();
    }
 
    // Notify waiting threads
    shutdown_cv_.notify_all();
}

References pacs_, rest_server_, running_, and shutdown_cv_.

Referenced by ~production_pacs().

Here is the caller graph for this function:

◆ wait()

void kcenon::pacs::samples::production_pacs::wait ( )

Block until server shutdown.

Examples: /home/runner/work/pacs_system/pacs_system/examples/tutorials/05_production_pacs/production_pacs.h.

Definition at line 92 of file production_pacs.cpp.

                           {
    if (!running_) {
        return;
    }
 
    std::unique_lock<std::mutex> lock(shutdown_mutex_);
    shutdown_cv_.wait(lock, [this] { return !running_.load(); });
}