log_merger.h

#pragma once
#include <chrono>
#include <g3log/logmessage.hpp>
#include <list>
#include <string>
#include <unordered_map>
 
 
class LogMerger
{
   public:
    explicit LogMerger(bool enable_merging = true);
 
    std::list<g3::LogMessage> log(g3::LogMessage &log);
 
    void pastime();
 
    g3::LogMessage _addRepeats(g3::LogMessage &log, int repeats);
 
    std::list<g3::LogMessage> _getOldMessages(
        std::chrono::_V2::system_clock::time_point current_time);
 
    const std::chrono::_V2::system_clock::duration LOG_MERGE_DURATION =
        std::chrono::seconds(2);
 
   private:
    struct Message
    {
        g3::LogMessage log;
        std::string msg;
        std::chrono::_V2::system_clock::time_point timestamp;
 
        Message(g3::LogMessage &log, std::string msg,
                std::chrono::_V2::system_clock::time_point timestamp)
            : log(log), msg(msg), timestamp(timestamp)
        {
        }
    };
 
    std::unordered_map<std::string, int>
        repeat_map;  // maps string messages to their number of repeats for fast access
    std::list<Message> message_list;  // used to keep track of time order for messages
 
    std::chrono::_V2::system_clock::duration
        passed_time;  // for testing, time passed manually
 
    bool enable_merging;
};