CatalogManager.cpp

Go to the documentation of this file.

// Mantid Repository : https://github.com/mantidproject/mantid
//
// Copyright © 2018 ISIS Rutherford Appleton Laboratory UKRI,
//   NScD Oak Ridge National Laboratory, European Spallation Source,
//   Institut Laue - Langevin & CSNS, Institute of High Energy Physics, CAS
// SPDX - License - Identifier: GPL - 3.0 +
#include "MantidAPI/CatalogManager.h"
#include "MantidAPI/CatalogFactory.h"
#include "MantidAPI/CompositeCatalog.h"
#include "MantidAPI/FunctionFactory.h"
#include "MantidKernel/ConfigService.h"
#include "MantidKernel/FacilityInfo.h"
 
#include <map>
#include <memory>
 
namespace Mantid::API {
CatalogSession_sptr CatalogManagerImpl::login(const std::string &username, const std::string &password,
                                              const std::string &endpoint, const std::string &facility) {
  std::string className = Kernel::ConfigService::Instance().getFacility(facility).catalogInfo().catalogName();
  auto catalog = CatalogFactory::Instance().create(className);
  CatalogSession_sptr session = catalog->login(username, password, endpoint, facility);
  // Creates a new catalog and adds it to the compositeCatalog and activeCatalog
  // list.
  m_activeCatalogs.emplace(session, catalog);
  return session;
}
 
ICatalog_sptr CatalogManagerImpl::getCatalog(const std::string &sessionID) {
  // Checks if a user is logged into the catalog. Inform the user if they are
  // not.
  if (m_activeCatalogs.empty())
    throw std::runtime_error("You are not currently logged into a catalog.");
 
  if (sessionID.empty()) {
    auto composite = std::make_shared<CompositeCatalog>();
    for (auto &activeCatalog : m_activeCatalogs) {
      composite->add(activeCatalog.second);
    }
    return composite;
  }
 
  const auto found =
      std::find_if(m_activeCatalogs.cbegin(), m_activeCatalogs.cend(),
                   [&sessionID](const auto &catalog) { return catalog.first->getSessionId() == sessionID; });
  if (found == m_activeCatalogs.cend()) {
    throw std::runtime_error("The session ID you have provided is invalid.");
  }
  return found->second;
}
 
void CatalogManagerImpl::destroyCatalog(const std::string &sessionID) {
  if (sessionID.empty()) {
    for (auto &activeCatalog : m_activeCatalogs) {
      activeCatalog.second->logout();
    }
    m_activeCatalogs.clear();
  }
 
  for (auto iter = m_activeCatalogs.begin(); iter != m_activeCatalogs.end();) {
    if (sessionID == iter->first->getSessionId()) {
      iter->second->logout();
      m_activeCatalogs.erase(iter);
      return;
    }
  }
}
 
std::vector<CatalogSession_sptr> CatalogManagerImpl::getActiveSessions() {
  std::vector<CatalogSession_sptr> sessions;
  sessions.reserve(m_activeCatalogs.size());
 
  std::transform(m_activeCatalogs.begin(), m_activeCatalogs.end(), std::back_inserter(sessions),
                 [](const auto &activeCatalog) { return activeCatalog.first; });
  return sessions;
}
 
size_t CatalogManagerImpl::numberActiveSessions() const { return m_activeCatalogs.size(); }
} // namespace Mantid::API