streaming_query_handler.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 "query_result_stream.h"
 
#include <kcenon/pacs/core/dicom_dataset.h>
#include <kcenon/pacs/services/query_scp.h>
 
#include <functional>
#include <memory>
#include <string>
 
namespace kcenon::pacs::storage {
class index_database;
}  // namespace kcenon::pacs::storage
 
namespace kcenon::pacs::services {
 
#ifdef PACS_WITH_DATABASE_SYSTEM
 
class streaming_query_handler {
public:
    using StreamResult = Result<std::unique_ptr<query_result_stream>>;
 
    explicit streaming_query_handler(storage::index_database* db);
 
    ~streaming_query_handler() = default;
 
    // Non-copyable
    streaming_query_handler(const streaming_query_handler&) = delete;
    auto operator=(const streaming_query_handler&) -> streaming_query_handler& = delete;
 
    // Movable
    streaming_query_handler(streaming_query_handler&&) noexcept = default;
    auto operator=(streaming_query_handler&&) noexcept -> streaming_query_handler& = default;
 
    // =========================================================================
    // Configuration
    // =========================================================================
 
    void set_page_size(size_t size) noexcept;
 
    [[nodiscard]] auto page_size() const noexcept -> size_t;
 
    void set_max_results(size_t max) noexcept;
 
    [[nodiscard]] auto max_results() const noexcept -> size_t;
 
    // =========================================================================
    // Stream Operations
    // =========================================================================
 
    [[nodiscard]] auto create_stream(query_level level,
                                     const core::dicom_dataset& query_keys,
                                     const std::string& calling_ae) -> StreamResult;
 
    [[nodiscard]] auto resume_stream(const std::string& cursor_state, query_level level,
                                     const core::dicom_dataset& query_keys) -> StreamResult;
 
    // =========================================================================
    // Compatibility Adapter
    // =========================================================================
 
    [[nodiscard]] auto as_query_handler() -> query_handler;
 
private:
    storage::index_database* db_;
 
    size_t page_size_{100};
 
    size_t max_results_{0};
};
 
#endif  // PACS_WITH_DATABASE_SYSTEM
 
}  // namespace kcenon::pacs::services