CoralCrestManager.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/

 
#ifndef IOVDBSVC_CORALCRESTMANAGER_H
#define IOVDBSVC_CORALCRESTMANAGER_H
#include <string>
#include <iostream>
#include <map>
#include <list>
#include <regex>
#include <iosfwd>
#include <cstdint>
#include "CrestApi/CrestApiBase.h"
#include "CrestApi/CrestRequest.h"
#include "FolderTypes.h"
#include "CoolKernel/ChannelSelection.h"
#include "CoolKernel/ValidityKey.h"
#include "CoolKernel/IFolder.h"
#include <chai/Container.h>
#include <chai/VectorContainer.h>
#include <chai/ContainerMap.h>
 
namespace Crest {
  enum class ModeId{
    Standard, DCS, DCS_FULL, DCS_FULL_SPARSE
  };
}
 
class CoralCrestManager {
public:
  static inline const std::string prefix1{"http://"};
  static inline const std::string prefix2 {"https://"};
 
  CoralCrestManager(const std::string & crest_path, const std::string & crestTag);
 
  static std::map<std::string, std::string> getGlobalTagMap(const std::string & crest_path, const std::string& globaltag);
 
  void loadTagInfo();
 
  std::string getFolderDescription();
 
  Crest::TagDto& getTagDto();
 
  std::string getPayloadSpec();
 
  IOVDbNamespace::FolderType determineFolderType();
 
  std::pair<std::vector<cool::ChannelId> , std::vector<std::string>> getChannelList();
 
  Crest::TagInfoDto getTagInfoDto();
 
  bool isVectorPayload();
 
  coral::AttributeListSpecification* getAttributeListSpec();
  std::vector<std::pair<cool::ValidityKey,std::string>> getIovsForTag(uint64_t since, uint64_t until);
  std::vector<uint64_t> loadPayloadForHash(uint64_t since,const std::string & hash);
  std::vector<coral::AttributeList> getVectorPayload(coral::AttributeListSpecification*  pSpec,const std::string & chId);
  std::string dumpPayload(cool::ValidityKey since);
  coral::AttributeList getPayload(coral::AttributeListSpecification*  pSpec,const std::string & chId);
  void selectIov(cool::ValidityKey since);
  std::vector<std::string> channelIds(cool::ValidityKey since);
 
private:
  std::unique_ptr<Crest::CrestApiBase> m_crestCl;
  const std::string m_crestTag;
  std::optional<Crest::TagMetaDto> m_TagMeta;
  std::optional<Crest::TagDto> m_Tag;
  std::optional<bool> m_isVectorPayload;
  std::string parseTypeName(const std::string & description);
  coral::AttributeList createAttributeList(coral::AttributeListSpecification * pSpec, chai::Values& row);
  std::pair<uint64_t,uint64_t> getIovInterval(const std::string&  tag, const uint64_t since, const uint64_t until);
  std::pair<uint64_t,uint64_t> getSinceUntilPair(std::vector<uint64_t>& v, const uint64_t since, const uint64_t until);
  void initChaiContainer();
  std::optional<std::map<uint64_t,chai::ContainerBasePtr> > m_chai_cont;
  //std::unique_ptr<chai::ContainerMap> m_chai_cont;
  cool::ValidityKey m_since;
  Crest::ModeId m_id;
};
#endif