ConfigurationManagerRW.h

#ifndef _ots_ConfigurationManagerRW_h_
#define _ots_ConfigurationManagerRW_h_
 
#include "otsdaq/ConfigurationInterface/ConfigurationManager.h"
 
namespace ots
{
struct TableInfo
{
    TableInfo()
        :  // constructor
        tablePtr_(0)
    {
    }
 
    std::set<TableVersion> versions_;
    TableBase*             tablePtr_;
    std::string            accumulatedWarnings_;
};
 
struct GroupInfo
{
    GroupInfo()
        :  //constructor
        latestKeyGroupAuthor_(ConfigurationManager::UNKNOWN_INFO)
        , latestKeyGroupComment_(ConfigurationManager::UNKNOWN_INFO)
        , latestKeyGroupCreationTime_(ConfigurationManager::UNKNOWN_TIME)
        , latestKeyGroupTypeString_(ConfigurationManager::GROUP_TYPE_NAME_UNKNOWN)
    {
    }
 
    std::set<TableGroupKey> keys_;
    std::string             latestKeyGroupAuthor_, latestKeyGroupComment_,
        latestKeyGroupCreationTime_, latestKeyGroupTypeString_;
    std::map<std::string /*name*/, TableVersion /*version*/> latestKeyMemberMap_;
 
    TableGroupKey getLatestKey()
    {
        if(keys_.size())
            return *(keys_.rbegin());
        else
            return TableGroupKey();
    }
};
 
#define __GETCFG_RW__(X) getConfigurationRW<X>(QUOTE(X))
 
//==============================================================================
class ConfigurationManagerRW : public ConfigurationManager
{
    // clang-format off
  public:
    ConfigurationManagerRW(const std::string& username);
 
 
    //==============================================================================
    const std::string&                          getUsername                     (void) const { return username_; }
    ConfigurationInterface*                     getConfigurationInterface       (void) const { return theInterface_; }
 
    const std::map<std::string, TableInfo>&     getAllTableInfo                 (bool refresh = false, 
                                                                                std::string* accumulatedWarnings = 0, 
                                                                                const std::string& errorFilterName = "", 
                                                                                bool getGroupKeys = false,
                                                                                bool getGroupInfo = false,
                                                                                bool initializeActiveGroups = false);
    std::map<std::string /*tableName*/,
             std::map<std::string /*aliasName*/, 
             TableVersion /*version*/> >        getVersionAliases               (void) const;
 
    template<class T>
    T*                                          getConfigurationRW              (std::string name) { return (T*)getTableByName(name); }
    TableBase*                                  getVersionedTableByName         (const std::string& tableName, TableVersion version, bool looseColumnMatching = false, std::string* accumulatedErrors = 0, bool getRawData = false);
    TableBase*                                  getTableByName                  (const std::string& tableName);
    TableGroupKey                               findTableGroup                  (const std::string& groupName,  const std::map<std::string, TableVersion>&                      groupMembers,
                                                                                                                const std::map<std::string /*name*/, std::string /*alias*/>&    groupAliases =  std::map<std::string /*name*/, std::string /*alias*/>());
    TableBase*                                  getMetadataTable                (void) { return &groupMetadataTable_; /* created for use in otsdaq_flatten_system_aliases, e.g. */ }
 
    //==============================================================================
    TableVersion                                saveNewTable                    (const std::string& tableName, TableVersion temporaryVersion = TableVersion(), bool makeTemporary = false);  
    TableVersion                                saveModifiedVersion             (
                                                                                const std::string&      tableName,
                                                                                TableVersion            originalVersion,
                                                                                bool                    makeTemporary,
                                                                                TableBase*              config,
                                                                                TableVersion            temporaryModifiedVersion,
                                                                                bool                    ignoreDuplicates = false,
                                                                                bool                    lookForEquivalent = false,
                                                                                bool*                   foundEquivalent = nullptr);
 
    TableVersion                                copyViewToCurrentColumns        (const std::string& tableName, TableVersion sourceVersion);
    void                                        eraseTemporaryVersion           (const std::string& tableName, TableVersion targetVersion = TableVersion());
    void                                        clearCachedVersions             (const std::string& tableName);
    void                                        clearAllCachedVersions          (void);
 
    //==============================================================================
    void                                        activateTableGroup              (const std::string& tableGroupName, TableGroupKey tableGroupKey, std::string* accumulatedTreeErrors = 0, std::string* groupTypeString = 0);
 
    TableVersion                                createTemporaryBackboneView     (TableVersion sourceViewVersion = TableVersion());  
    TableVersion                                saveNewBackbone                 (TableVersion temporaryVersion  = TableVersion());
 
    //==============================================================================
    TableGroupKey                               saveNewTableGroup               (const std::string& groupName,  std::map<std::string, TableVersion>&                    groupMembers, 
                                                                                                                const std::string&                                      groupComment = TableViewColumnInfo::DATATYPE_COMMENT_DEFAULT,
                                                                                                                std::map<std::string /*table*/, std::string /*alias*/>* groupAliases = 0);
 
    //==============================================================================
    const GroupInfo&                            getGroupInfo                    (const std::string& groupName);
    const std::map<std::string, GroupInfo>&     getAllGroupInfo                 (void) { return allGroupInfo_; }
 
    void                                        testXDAQContext                 (void);  
 
  public:
    static void                                 loadTableInfoThread             (ConfigurationManagerRW*            cfgMgr,
                                                                                std::string                         tableName, 
                                                                                TableBase*                          existingTable,
                                                                                std::shared_ptr<ots::TableInfo>     tableInfo, 
                                                                                std::shared_ptr<std::atomic<bool>>  threadDone);
    static void                                 loadTableGroupThread            (ConfigurationManagerRW*            cfgMgr,
                                                                                std::string                         groupName, 
                                                                                ots::TableGroupKey                  groupKey,
                                                                                std::shared_ptr<ots::GroupInfo>     theGroupInfo, 
                                                                                std::shared_ptr<std::atomic<bool>>  theThreadDone);
    static void                                 compareTableGroupThread         (ConfigurationManagerRW*            cfgMgr, 
                                                                                std::string                         groupName, 
                                                                                ots::TableGroupKey                  groupKeyToCompare, 
                                                                                const std::map<std::string, TableVersion>& groupMemberMap, 
                                                                                const std::map<std::string /*name*/, std::string /*alias*/>& memberTableAliases,            
                                                                                std::atomic<bool>*                  theFoundIdentical,
                                                                                ots::TableGroupKey*                 theIdenticalKey,            
                                                                                std::mutex*                         theThreadMutex, 
                                                                                std::shared_ptr<std::atomic<bool>>  theThreadDone);
  private:
 
    //==============================================================================
    void                                        cacheGroupKey                   (const std::string& groupName, TableGroupKey key);
 
    //==============================================================================
    std::map<std::string, TableInfo>                                allTableInfo_;
    std::map<std::string, GroupInfo>                                allGroupInfo_;
 
    static std::atomic<bool>                                        firstTimeConstructed_;
};
 
//==============================================================================
struct TableEditStruct
{
    TableBase*   table_;
    TableView*   tableView_;
    TableVersion temporaryVersion_, originalVersion_;
    bool         createdTemporaryVersion_;  
    bool         modified_;                 
    std::string  tableName_;
    const std::string mfSubject_;
 
    TableEditStruct()
    {
        __SS__ << "impossible!" << std::endl;
        ss << StringMacros::stackTrace();
        __SS_THROW__;
    }
    TableEditStruct(const std::string& tableName, ConfigurationManagerRW* cfgMgr, bool markModified = false)
        : createdTemporaryVersion_(false), modified_(markModified), tableName_(tableName)
        , mfSubject_(cfgMgr->getUsername())
    {
        //__COUT__ << "Creating Table-Edit Struct for " << tableName_ << std::endl;
        table_ = cfgMgr->getTableByName(tableName_);
 
        //if no active version or if not temporary, setup new temporary version
        if(!table_->isActive() ||
                !(originalVersion_ = table_->getView().getVersion()).isTemporaryVersion())
        {
            //__COUT__ << "Original '" << tableName_ << "' version is v" << originalVersion_ << std::endl;
 
            // create temporary version for editing
            temporaryVersion_ = table_->createTemporaryView(originalVersion_);
            cfgMgr->saveNewTable(
                tableName_,
                temporaryVersion_,
                true);  
 
            __COUT__ << "Created '" << tableName_ << "' temporary version " << temporaryVersion_ << std::endl;
            createdTemporaryVersion_ = true;
        }
        //else  // else table is already temporary version
            //__COUT__ << "Using '" << tableName_ << "' temporary version " << temporaryVersion_ << std::endl;
 
        tableView_ = table_->getViewP();
    }
};  // end TableEditStruct declaration
 
 
//==============================================================================
struct GroupEditStruct
{
private:
    std::map<std::string, TableVersion>     groupMembers_;
    std::map<std::string, TableEditStruct>  groupTables_;
public:
    const ConfigurationManager::GroupType   groupType_;
    const std::string                       originalGroupName_;
    const TableGroupKey                     originalGroupKey_;
private:
    ConfigurationManagerRW*                 cfgMgr_;
    const std::string                       mfSubject_;
                
public:
    GroupEditStruct()
        : groupType_(ConfigurationManager::GroupType::CONFIGURATION_TYPE) {__SS__ << "impossible!" << __E__; __SS_THROW__;}
    GroupEditStruct(const ConfigurationManager::GroupType& groupType, ConfigurationManagerRW* cfgMgr);
 
    ~GroupEditStruct();
 
    void                dropChanges             (void);
    void                saveChanges             (
                                                const std::string&  groupNameToSave,
                                                TableGroupKey&      newGroupKey,
                                                bool*               foundEquivalentGroupKey     = nullptr,
                                                bool                activateNewGroup            = false,
                                                bool                updateGroupAliases          = false,
                                                bool                updateTableAliases          = false,
                                                TableGroupKey*      newBackboneKey              = nullptr,
                                                bool*               foundEquivalentBackboneKey  = nullptr,
                                                std::string*        accumulatedWarnings         = nullptr);
 
    TableEditStruct&    getTableEditStruct      (const std::string& tableName, bool markModified = false);
 
};  // end GroupEditStruct declaration
 
// clang-format on
}  // namespace ots
 
#endif