HistoryService.h

Go to the documentation of this file.

#include "lintel/core/services/PropertyRegistration.h"
#include "lintel/features/base/models/HistoryEntry.h"
#include "lintel/features/base/repositories/HistoryRepository.h"
#include "lintel/features/base/services/IHistoryService.h"
#include "lintel/features/base/services/MessageQueueService.h"
#include "lintel/features/base/services/SchedulerService.h"
 
#include <ctime>
#include <memory>
 
#ifndef LINTEL_HISTORYSERVICE_H
#define LINTEL_HISTORYSERVICE_H
 
namespace lintel {
class HistoryService
  : public PropertyRegistration<HistoryService>
  , public IHistoryService
  , public std::enable_shared_from_this<HistoryService>
{
private:
  // properties
  std::shared_ptr<Property<std::chrono::seconds>> m_duration;
  std::shared_ptr<Property<std::chrono::seconds>> m_period;
  std::shared_ptr<Property<bool>> m_forceQueue;
  std::shared_ptr<Property<std::size_t>> m_commitRate;
  std::shared_ptr<Property<std::chrono::milliseconds>> m_sendTimeout;
  // injections
  std::shared_ptr<SchedulerService> m_schedulerService;
  std::shared_ptr<HistoryRepository> m_historyRepository;
  std::shared_ptr<MessageQueueService> m_messageQueueSerivice;
  std::string m_ownProcessName;
  std::shared_ptr<ProcessName> m_processName;
  // variables
  std::vector<HistoryEntry> m_historyEntries;
  std::mutex m_historyEntriesMutex;
  std::atomic_bool m_running = true;
  std::unique_ptr<MessageQueue<Message>> m_historyMessageQueue;
  std::unique_ptr<MessageQueue<Message>> m_historyMessageQueueReceive;
 
  void run();
 
  struct HistoryMessage
  {
    char processName[100];
    char serviceName[100];
    char label[100];
    char text[300];
    std::time_t createdTimestamp;
    int64_t createdTimestampMics;
  };
 
public:
  HistoryService(std::shared_ptr<ProcessName> processName,
    std::shared_ptr<SchedulerService> schedulerService,
    std::shared_ptr<HistoryRepository> historyRepository,
    std::shared_ptr<MessageQueueService> messageQueueService);
 
  ~HistoryService() override;
 
  void onInitialize() override;
 
  void onShutdown() override;
 
  void historizeOf(std::vector<HistoryEntry> entries) override;
 
  [[nodiscard]] const std::string &getProcessName() const override;
 
  [[nodiscard]] std::vector<HistoryEntry> allOf() const override;
 
  [[nodiscard]] std::vector<HistoryEntry> allOf(const std::string &label) const override;
 
  [[nodiscard]] std::vector<HistoryEntry> allOf(const std::string &processName,
    const std::string &serviceName) const override;
 
  [[nodiscard]] std::vector<HistoryEntry> allOfProcess(const std::string &processName) const override;
 
  [[nodiscard]] std::vector<HistoryEntry> allOfService(const std::string &serviceName) const override;
};
 
}// namespace lintel
#endif// LINTEL_HISTORYSERVICE_H