atna_syslog_transport.h

Go to the documentation of this file.

 
#ifndef PACS_SECURITY_ATNA_SYSLOG_TRANSPORT_HPP
#define PACS_SECURITY_ATNA_SYSLOG_TRANSPORT_HPP
 
#include "kcenon/pacs/core/result.h"
 
#include <atomic>
#include <cstdint>
#include <string>
 
namespace kcenon::pacs::security {
 
// =============================================================================
// Syslog Facility Codes (RFC 5424 Section 6.2.1)
// =============================================================================
 
enum class syslog_facility : uint8_t {
    kern = 0,
    user = 1,
    mail = 2,
    daemon = 3,
    auth = 4,
    syslog = 5,
    lpr = 6,
    news = 7,
    uucp = 8,
    cron = 9,
    authpriv = 10,   
    ftp = 11,
    ntp = 12,
    log_audit = 13,  
    log_alert = 14,
    clock = 15,
    local0 = 16,
    local1 = 17,
    local2 = 18,
    local3 = 19,
    local4 = 20,
    local5 = 21,
    local6 = 22,
    local7 = 23
};
 
// =============================================================================
// Syslog Severity (RFC 5424 Section 6.2.1)
// =============================================================================
 
enum class syslog_severity : uint8_t {
    emergency = 0,
    alert = 1,
    critical = 2,
    error = 3,
    warning = 4,
    notice = 5,
    informational = 6,  
    debug = 7
};
 
// =============================================================================
// Transport Protocol
// =============================================================================
 
enum class syslog_transport_protocol : uint8_t {
    udp,  
    tls   
};
 
// =============================================================================
// Configuration
// =============================================================================
 
struct syslog_transport_config {
    syslog_transport_protocol protocol{syslog_transport_protocol::udp};
 
    std::string host{"localhost"};
 
    uint16_t port{514};
 
    std::string app_name{"pacs_system"};
 
    std::string hostname;
 
    syslog_facility facility{syslog_facility::authpriv};
 
    syslog_severity severity{syslog_severity::informational};
 
    // -- TLS-specific options (RFC 5425) --
 
    std::string ca_cert_path;
 
    std::string client_cert_path;
 
    std::string client_key_path;
 
    bool verify_server{true};
};
 
// =============================================================================
// ATNA Syslog Transport
// =============================================================================
 
class atna_syslog_transport {
public:
    // =========================================================================
    // Construction
    // =========================================================================
 
    explicit atna_syslog_transport(const syslog_transport_config& config);
 
    ~atna_syslog_transport();
 
    // Non-copyable
    atna_syslog_transport(const atna_syslog_transport&) = delete;
    atna_syslog_transport& operator=(const atna_syslog_transport&) = delete;
 
    // Movable
    atna_syslog_transport(atna_syslog_transport&& other) noexcept;
    atna_syslog_transport& operator=(atna_syslog_transport&& other) noexcept;
 
    // =========================================================================
    // Send Operations
    // =========================================================================
 
    [[nodiscard]] kcenon::pacs::VoidResult send(const std::string& xml_message);
 
    // =========================================================================
    // RFC 5424 Message Formatting
    // =========================================================================
 
    [[nodiscard]] std::string format_syslog_message(
        const std::string& xml_message) const;
 
    // =========================================================================
    // Connection Management
    // =========================================================================
 
    [[nodiscard]] bool is_connected() const noexcept;
 
    void close();
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] size_t messages_sent() const noexcept;
    [[nodiscard]] size_t send_errors() const noexcept;
    void reset_statistics() noexcept;
 
    // =========================================================================
    // Configuration Access
    // =========================================================================
 
    [[nodiscard]] const syslog_transport_config& config() const noexcept;
 
private:
    // =========================================================================
    // Private Implementation
    // =========================================================================
 
    [[nodiscard]] kcenon::pacs::VoidResult send_udp(const std::string& syslog_message);
    [[nodiscard]] kcenon::pacs::VoidResult send_tls(const std::string& syslog_message);
    [[nodiscard]] kcenon::pacs::VoidResult ensure_tls_connected();
 
    [[nodiscard]] static std::string get_local_hostname();
    [[nodiscard]] static std::string get_timestamp();
    [[nodiscard]] static uint8_t compute_priority(
        syslog_facility facility, syslog_severity severity);
 
    // =========================================================================
    // Private Members
    // =========================================================================
 
    syslog_transport_config config_;
 
    // Socket handle (-1 = not connected)
#ifdef _WIN32
    using socket_type = unsigned long long;  // SOCKET
    static constexpr socket_type invalid_socket = ~static_cast<socket_type>(0);
#else
    using socket_type = int;
    static constexpr socket_type invalid_socket = -1;
#endif
    socket_type socket_{invalid_socket};
 
    // Opaque TLS context (avoids OpenSSL includes in header)
    struct tls_context;
    tls_context* tls_{nullptr};
 
    std::atomic<size_t> messages_sent_{0};
    std::atomic<size_t> send_errors_{0};
};
 
}  // namespace kcenon::pacs::security
 
#endif  // PACS_SECURITY_ATNA_SYSLOG_TRANSPORT_HPP