EventMessageAggregator.h

Go to the documentation of this file.

// SPDX-FileCopyrightText: Deutsches Elektronen-Synchrotron DESY, MSK
// SPDX-License-Identifier: LGPL-3.0-or-later
#pragma once
 
#include "ConfigReader.h"
#include "PeriodicTrigger.h"
#include "StatusWithMessage.h"
#include "VoidAccessor.h"
 
#include <ChimeraTK/ScalarRegisterAccessor.h>
 
namespace ChimeraTK {
 
  /********************************************************************************************************************/
 
  class AggregatableMessage : public ScalarOutput<std::string> {
   public:
    AggregatableMessage(Module* owner, const std::string& name, std::string unit, const std::string& description,
        const std::unordered_set<std::string>& tags = {});
 
    using ScalarOutput::ScalarOutput;
    using ScalarOutput::operator=;
 
    static constexpr std::string_view aggregatableMessageTag{"_ChimeraTK_AggregatableMessage"};
  };
 
  /********************************************************************************************************************/
 
  class EventMessageAggregator : public ModuleGroup {
   public:
    using ModuleGroup::ModuleGroup;
 
    EventMessageAggregator() : _impl() {}
 
   private:
    class Impl : public ApplicationModule {
     public:
      Impl(ModuleGroup* owner, const std::string& name, const std::string& description,
          const std::unordered_set<std::string>& tags = {});
 
      using ApplicationModule::ApplicationModule;
 
      void mainLoop() override;
 
     protected:
      std::vector<ScalarPushInput<std::string>> _inputs;
 
      StatusWithMessage _output{this, "event", ""};
 
      VoidInput _clear{this, "clear", ""};
      ScalarPushInput<uint64_t> _autoClearTimer{this, "AutoClearTimer/tick", "", ""};
 
      uint32_t _autoClearSeconds{appConfig().get<uint32_t>("Configuration/autoClearEventMessage", 300)};
    };
 
    Impl _impl{this, ".", ""};
 
    PeriodicTrigger _autoClearTimer{this, "AutoClearTimer", "1 Hz trigger for the auto clear timer"};
  };
 
  /********************************************************************************************************************/
 
} // namespace ChimeraTK