QueryResult.h

/*
     Copyright © CloudBackend AB 2020-2023.
*/
 
 
#ifndef INCLUDE_CBE_QUERY_RESULT_H_
#define INCLUDE_CBE_QUERY_RESULT_H_
 
#include "cbe/Types.h"
 
#include <vector>
 
namespace CBI {
class QueryResult;
using QueryResultPtr = std::shared_ptr<CBI::QueryResult>;
class ItemEventProtocol;
using ItemDelegatePtr = std::shared_ptr<ItemEventProtocol>;
class PublishEventProtocol;
using PublishDelegatePtr = std::shared_ptr<PublishEventProtocol>;
class ShareEventProtocol;
using ShareDelegatePtr = std::shared_ptr<ShareEventProtocol>;
class SubscribeEventProtocol;
using SubscribeDelegatePtr = std::shared_ptr<SubscribeEventProtocol>;
} // namespace CBI
 
namespace cbe {
 
class Filter;
  namespace util {
class Context;
  } // namespace util
  namespace delegate {
class QueryDelegate;
using QueryDelegatePtr = std::shared_ptr<QueryDelegate>;
CBI::ItemDelegatePtr createCbiQueryDelegate(QueryDelegatePtr,
                                            cbe::util::Context&&);
class QueryJoinDelegate;
using QueryJoinDelegatePtr = std::shared_ptr<QueryJoinDelegate>;
CBI::ItemDelegatePtr createCbiQueryDelegate(QueryJoinDelegatePtr,
                                            cbe::util::Context&&);
class JoinDelegate;
using JoinDelegatePtr = std::shared_ptr<JoinDelegate>;
CBI::ItemDelegatePtr createCbiJoinDelegate(JoinDelegatePtr,
                                           cbe::util::Context&&);
  } // namespace delegate
 
class QueryResult {
public:
  Filter filter() const;
 
  using ItemsSnapshot = std::vector<Item>;
  ItemsSnapshot getItemsSnapshot() const;
 
  std::uint64_t itemsLoaded() const;
 
  std::uint64_t totalCount() const;
 
  std::uint64_t objectsLoaded() const;
 
  std::uint64_t containersLoaded() const;
 
  bool containsItem(ItemId itemId) const;
 
  friend std::ostream& operator<<(std::ostream&       os,
                                  const QueryResult&  queryResult);
 
  QueryResult(cbe::DefaultCtor);
  ~QueryResult();
 
  explicit operator bool() const;
private:
  struct Impl;
  std::shared_ptr<Impl> pImpl{};
 
  friend class CloudBackend;
  friend class Container;
  friend class QueryChain;
  friend class QueryChainSync;
  friend class ShareManager;
  friend class SubscribeManager;
  friend CBI::ItemDelegatePtr delegate::createCbiQueryDelegate(
                                                         delegate::QueryDelegatePtr,
                                                         cbe::util::Context&&);
  friend CBI::ItemDelegatePtr delegate::createCbiQueryDelegate(
                                                         delegate::QueryJoinDelegatePtr,
                                                         cbe::util::Context&&);
  friend CBI::ItemDelegatePtr delegate::createCbiJoinDelegate(
                                                         delegate::JoinDelegatePtr,
                                                         cbe::util::Context&&);
  QueryResult(CBI::QueryResultPtr cbiPeerPtr);
  CBI::QueryResult& getCbiPeer() const;
}; // class QueryResult
 
}
// namespace cbe
 
#endif // INCLUDE_CBE_DIRECTORY_H_