isyslogserver.h

Go to the documentation of this file.

/*
 * Copyright 2022 Ingemar Hedvall
 * SPDX-License-Identifier: MIT
 */

 
#pragma once
#include <atomic>
#include <cstdint>
#include <memory>
#include <optional>
 
#include "util/syslogmessage.h"
#include "util/threadsafequeue.h"
 
namespace util::syslog {

enum class SyslogServerType : uint8_t {
  UdpServer = 0,     
  TlsServer = 1,     
  TcpServer = 2,     
  TcpPublisher = 3,  
  TcpSubscriber = 4  
};

class ISyslogServer {
 public:
  ISyslogServer(const ISyslogServer&) = delete;
  virtual ~ISyslogServer() = default;

  [[nodiscard]] SyslogServerType Type() const { return type_; }

  void Address(const std::string& address);
 
  [[nodiscard]] const std::string& Address()
      const {  
    return address_;
  }
 
  void Name(
      const std::string& name) {  
    name_ = name;
  }
 
  const std::string& Name() const {  
    return name_;
  }
 
  void Port(uint16_t port) {  
    port_ = port;
  }
 
  [[nodiscard]] uint16_t Port() const {  
    return port_;
  }
 
  virtual void AddMsg(
      const SyslogMessage& msg);  

  std::optional<SyslogMessage> GetMsg(bool block);
 
  virtual void Start();  
  virtual void Stop();   
 
  [[nodiscard]] size_t NofMessages()
      const {  
    return msg_queue_ ? msg_queue_->Size() : 0;
  }

  [[nodiscard]] bool IsOperable() const { return operable_; }

  [[nodiscard]] virtual size_t NofConnections() const;
 
 protected:
  ISyslogServer() = default;           
  std::atomic<bool> operable_ = true;  
  SyslogServerType type_ = SyslogServerType::UdpServer;  
 
 private:
  std::string address_ = "0.0.0.0";  
  std::string name_;                 
  uint16_t port_ = 0;                
  std::unique_ptr<log::ThreadSafeQueue<SyslogMessage>>
      msg_queue_;                    
};
 
}  // namespace util::syslog