atna_service_auditor.h

Go to the documentation of this file.

 
#ifndef PACS_SECURITY_ATNA_SERVICE_AUDITOR_HPP
#define PACS_SECURITY_ATNA_SERVICE_AUDITOR_HPP
 
#include "atna_audit_logger.h"
#include "atna_syslog_transport.h"
 
#include <atomic>
#include <cstdint>
#include <memory>
#include <string>
#include <vector>
 
namespace kcenon::pacs::security {
 
class atna_service_auditor {
public:
    // =========================================================================
    // Construction
    // =========================================================================
 
    atna_service_auditor(const syslog_transport_config& config,
                         std::string audit_source_id);
 
    virtual ~atna_service_auditor() = default;
 
    // Non-copyable, movable
    atna_service_auditor(const atna_service_auditor&) = delete;
    atna_service_auditor& operator=(const atna_service_auditor&) = delete;
    atna_service_auditor(atna_service_auditor&&) noexcept;
    atna_service_auditor& operator=(atna_service_auditor&&) noexcept;
 
    // =========================================================================
    // DICOM Service Audit Methods
    // =========================================================================
 
    void audit_instance_stored(const std::string& source_ae,
                               const std::string& dest_ae,
                               const std::string& study_uid,
                               const std::string& patient_id,
                               bool success);
 
    void audit_query(const std::string& calling_ae,
                     const std::string& called_ae,
                     const std::string& query_level,
                     bool success);
 
    void audit_authentication(const std::string& user_id,
                              bool is_login,
                              bool success);
 
    void audit_security_alert(const std::string& user_id,
                              const std::string& alert_description);
 
    // =========================================================================
    // IHE XDS-I.b Transaction Audit Methods
    // =========================================================================
 
    enum class xds_source_transaction : uint8_t {
        iti_41,   
        rad_68    
    };
 
    enum class xds_consumer_transaction : uint8_t {
        iti_43,   
        rad_69    
    };
 
    virtual void audit_xds_provide_and_register(
        xds_source_transaction transaction,
        const std::string& source_ae,
        const std::string& dest_ae,
        const std::string& study_uid,
        const std::string& patient_id,
        const std::vector<std::string>& sop_instance_uids,
        bool success);
 
    virtual void audit_xds_retrieve(
        xds_consumer_transaction transaction,
        const std::string& source_ae,
        const std::string& dest_ae,
        const std::string& study_uid,
        const std::string& patient_id,
        const std::vector<std::string>& sop_instance_uids,
        bool success);
 
    // =========================================================================
    // Enable / Disable
    // =========================================================================
 
    void set_enabled(bool enabled) noexcept;
 
    [[nodiscard]] bool is_enabled() const noexcept;
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] size_t events_sent() const noexcept;
 
    [[nodiscard]] size_t events_failed() const noexcept;
 
    void reset_statistics() noexcept;
 
    // =========================================================================
    // Configuration Access
    // =========================================================================
 
    [[nodiscard]] const std::string& audit_source_id() const noexcept;
 
    [[nodiscard]] const atna_syslog_transport& transport() const noexcept;
 
    // =========================================================================
    // Pre-built Message Emission
    // =========================================================================
 
    void submit_audit_message(const atna_audit_message& message);
 
private:
    // =========================================================================
    // Private Helpers
    // =========================================================================
 
    void send_audit(const atna_audit_message& message);
 
    // =========================================================================
    // Private Members
    // =========================================================================
 
    std::string audit_source_id_;
 
    atna_syslog_transport transport_;
 
    std::atomic<bool> enabled_{true};
 
    std::atomic<size_t> events_sent_{0};
    std::atomic<size_t> events_failed_{0};
};
 
}  // namespace kcenon::pacs::security
 
#endif  // PACS_SECURITY_ATNA_SERVICE_AUDITOR_HPP