PrefixIntConvert.h

Go to the documentation of this file.

 
 
#ifndef _MADARA_FILTERS_PREFIX_INTCONVERT_H_
#define _MADARA_FILTERS_PREFIX_INTCONVERT_H_
 
#include <sstream>
 
#include "AggregateFilter.h"
#include "madara/knowledge/containers/StringVector.h"
#include "madara/utility/Utility.h"
 
namespace madara
{
namespace filters
{
class PrefixIntConvert : public AggregateFilter
{
public:
  PrefixIntConvert(const std::vector<std::string>& source_prefixes = {},
      knowledge::KnowledgeRecord::Integer new_value = 0)
    : value(new_value), prefixes(source_prefixes)
  {
  }
 
  virtual ~PrefixIntConvert() = default;
 
  inline virtual void filter(knowledge::KnowledgeMap& records,
      const transport::TransportContext&, knowledge::Variables&)
  {
    // because of the usage of erase, don't auto inc record in for loop
    for (auto record : records)
    {
      // check for valid prefix
      bool accepted_prefix = false;
 
      if (prefixes.size() > 0)
      {
        for (auto prefix : prefixes)
        {
          if (utility::begins_with(record.first, prefix))
          {
            accepted_prefix = true;
          }
        }
      }
      else
      {
        accepted_prefix = true;
      }
 
      // if not valid, remove the record and update iterator
      if (!accepted_prefix)
      {
        madara_logger_ptr_log(madara::logger::global_logger.get(),
            logger::LOG_MAJOR,
            "PrefixIntConvert::filter: "
            "not integerizing variable %s\n",
            record.first.c_str())
      }  // end not valid prefix
      else
      {
        // valid prefix so set the value
        record.second = value;
      }  // end valid prefix
    }    // end iteration over all filter records
  }      // end filter function
 
  knowledge::KnowledgeRecord::Integer value;
 
  std::vector<std::string> prefixes;
};
}
}
 
#endif  // _MADARA_FILTERS_PREFIX_INTCONVERT_H_