server_app.h

Go to the documentation of this file.

 
#ifndef PACS_EXAMPLE_PACS_SERVER_SERVER_APP_HPP
#define PACS_EXAMPLE_PACS_SERVER_SERVER_APP_HPP
 
#include "config.h"
 
#include "kcenon/pacs/core/dicom_dataset.h"
#include "kcenon/pacs/core/dicom_file.h"
#include "kcenon/pacs/network/dicom_server.h"
#include "kcenon/pacs/network/server_config.h"
#include "kcenon/pacs/services/mpps_scp.h"
#include "kcenon/pacs/services/query_scp.h"
#include "kcenon/pacs/services/retrieve_scp.h"
#include "kcenon/pacs/services/storage_scp.h"
#include "kcenon/pacs/services/verification_scp.h"
#include "kcenon/pacs/services/worklist_scp.h"
#include "kcenon/pacs/storage/file_storage.h"
#include "kcenon/pacs/storage/index_database.h"
 
#include <atomic>
#include <memory>
#include <string>
 
namespace kcenon::pacs::example {
 
class pacs_server_app {
public:
    // =========================================================================
    // Construction / Destruction
    // =========================================================================
 
    explicit pacs_server_app(const pacs_server_config& config);
 
    ~pacs_server_app();
 
    // Non-copyable, non-movable
    pacs_server_app(const pacs_server_app&) = delete;
    pacs_server_app& operator=(const pacs_server_app&) = delete;
    pacs_server_app(pacs_server_app&&) = delete;
    pacs_server_app& operator=(pacs_server_app&&) = delete;
 
    // =========================================================================
    // Lifecycle Management
    // =========================================================================
 
    [[nodiscard]] bool initialize();
 
    [[nodiscard]] bool start();
 
    void stop();
 
    void wait_for_shutdown();
 
    void request_shutdown();
 
    // =========================================================================
    // Status Queries
    // =========================================================================
 
    [[nodiscard]] bool is_running() const noexcept;
 
    void print_statistics() const;
 
private:
    // =========================================================================
    // Private Methods
    // =========================================================================
 
    [[nodiscard]] bool setup_storage();
 
    [[nodiscard]] bool setup_database();
 
    [[nodiscard]] bool setup_services();
 
    [[nodiscard]] bool setup_server();
 
    // =========================================================================
    // Service Handlers
    // =========================================================================
 
    services::storage_status handle_store(
        const core::dicom_dataset& dataset,
        const std::string& calling_ae,
        const std::string& sop_class_uid,
        const std::string& sop_instance_uid);
 
    std::vector<core::dicom_dataset> handle_query(
        services::query_level level,
        const core::dicom_dataset& query_keys,
        const std::string& calling_ae);
 
    std::vector<core::dicom_file> handle_retrieve(
        const core::dicom_dataset& query_keys);
 
    std::vector<core::dicom_dataset> handle_worklist_query(
        const core::dicom_dataset& query_keys,
        const std::string& calling_ae);
 
    network::Result<std::monostate> handle_mpps_create(
        const services::mpps_instance& instance);
 
    network::Result<std::monostate> handle_mpps_set(
        const std::string& sop_instance_uid,
        const core::dicom_dataset& modifications,
        services::mpps_status new_status);
 
    // =========================================================================
    // Member Variables
    // =========================================================================
 
    pacs_server_config config_;
 
    std::unique_ptr<network::dicom_server> server_;
 
    std::unique_ptr<storage::file_storage> file_storage_;
 
    std::unique_ptr<storage::index_database> database_;
 
    std::atomic<bool> shutdown_requested_{false};
 
    bool initialized_{false};
};
 
}  // namespace kcenon::pacs::example
 
#endif  // PACS_EXAMPLE_PACS_SERVER_SERVER_APP_HPP