ClickHouseTagsConfig.h

// --------------------------------------------------------------------------
#ifndef ClickHouseTagsConfig_H_
#define ClickHouseTagsConfig_H_
// --------------------------------------------------------------------------
#include <memory>
#include <unordered_map>
#include <string>
#include "Configuration.h"
//------------------------------------------------------------------------------------------
namespace uniset
{
    //------------------------------------------------------------------------------------------
    class ClickHouseTagsConfig
    {
 
        public:
            ClickHouseTagsConfig();
            ~ClickHouseTagsConfig();
 
            // init all tags from configure
            void load( const std::shared_ptr<uniset::Configuration> conf
                       , const std::string& filter_field = ""
                       , const std::string& filter_value = "" );
 
 
            // init tags map from section <cnodename>
            void loadTagsMap( uniset::UniXML::iterator it );
 
            // init tags for sensor
            void initFromItem( const std::shared_ptr<uniset::Configuration> conf
                               , const uniset::UniXML::iterator& it );
 
            struct Tag
            {
                std::string key;
                std::string value;
                const std::string orig_key;
                const std::string orig_value;
 
                Tag( const std::string& _key
                     , const std::string& _val
                     , const std::string& _orig_key
                     , const std::string& _orig_val):
                    key(_key),
                    value(_val),
                    orig_key(_orig_key),
                    orig_value(_orig_val)
                {}
            };
 
            // parse string "key1=val1 key2=val2 key3=val3"
            static std::vector<Tag> parseTags( const std::string& s_tags, const char sep = ' ');
 
            std::vector<Tag> getTags( uniset::ObjectId id );
 
            bool updateTags( uniset::ObjectId id, long value );
 
            size_t getTagsCount() const;
            size_t getSensorsCount() const;
 
            using StateMap = std::unordered_map<uniset::ObjectId, long>;
 
            std::vector<uniset::ObjectId> getAskedSensors() const;
 
        protected:
 
            // текущее значение датчиков по которым формируются теги (map<id,value>)
            StateMap::iterator addState( uniset::ObjectId sid, long defval );
 
            StateMap smap;
 
            struct Range
            {
                long vmin;
                long vmax;
                bool checkInRange( long value ) const;
                void updateText( long value );
                std::vector<Tag> tags;
 
                bool needReplaceKey = {true};
                bool needReplaceVal = {true};
            };
 
            // value --> tags
            using RangeList = std::list<Range>;
 
            RangeList initRangeList( uniset::UniXML::iterator it );
 
            // name --> range list
            using TagsMap  = std::unordered_map<std::string, RangeList>;
            TagsMap tagsmap; // список тегов
            TagsMap initTagsMap( uniset::UniXML::iterator it );
 
            struct TagsInfo
            {
                std::vector<Tag> any_tags; // if not empty, work for any value
                TagsMap::iterator vit;
                StateMap::iterator it;
                long prev_value = { 0 };
                bool initOk = { false };
                uniset::ObjectId sid = { uniset::DefaultObjectId };
            };
 
            using TagList = std::list<TagsInfo>;
            TagList::iterator addTagsInfo( TagList& lst, uniset::ObjectId sid );
            std::vector<Tag> makeTags( TagList& lst );
 
            // map<sensorID,TagList>
            std::unordered_map<uniset::ObjectId, TagList> tags;
 
            void initDynamicTags();
            void initFromTags( const std::shared_ptr<uniset::Configuration>& conf, uniset::UniXML::iterator it, const std::string& s_tags );
            void initFromValues( const std::shared_ptr<uniset::Configuration>& conf, uniset::UniXML::iterator it, const std::string& s_values );
            void initFromTagsList( const std::shared_ptr<uniset::Configuration>& conf, uniset::UniXML::iterator it, uniset::UniXML::iterator itList );
    };
    //------------------------------------------------------------------------------------------
} // end of namespace Theatre
//------------------------------------------------------------------------------------------
#endif