input_metadata_manager.hpp

Go to the documentation of this file.

#pragma once
 
#include "commrat/module/metadata/input_metadata.hpp"
#include "commrat/messages.hpp"
#include <iostream>
 
namespace commrat {
 
template<typename ModuleType>
class InputMetadataManager {
protected:
    template<typename T>
    void update_input_metadata(std::size_t index, const TimsMessage<T>& received, bool is_new) {
        auto& module = static_cast<ModuleType&>(*this);
        
        if (index >= module.num_inputs) {
            std::cerr << "[Module] ERROR: Invalid metadata index " << index << "\n";
            return;
        }
        
        module.input_metadata_[index].timestamp = received.header.timestamp;
        module.input_metadata_[index].sequence_number = received.header.seq_number;
        module.input_metadata_[index].message_id = received.header.msg_type;
        module.input_metadata_[index].is_new_data = is_new;
        module.input_metadata_[index].is_valid = true;
    }
    
    void mark_input_invalid(std::size_t index) {
        auto& module = static_cast<ModuleType&>(*this);
        
        if (index >= module.num_inputs) {
            return;
        }
        
        module.input_metadata_[index].is_valid = false;
        module.input_metadata_[index].is_new_data = false;
    }
};
 
}  // namespace commrat