Store.hpp

#ifndef _DITTO_STORE_
#define _DITTO_STORE_
 
#include "Ditto.hpp"
 
#include "Collection.hpp"
#include "DiskUsage.hpp"
#include "PendingCollectionsOperation.hpp"
#include "QueryResult.hpp"
#include "StoreObserver.hpp"
#include "WriteTransaction.hpp"
#include "WriteTransactionResult.hpp"
 
#include <functional>
#include <memory>
#include <set>
#include <string>
#include <vector>
 
namespace ditto {
class DittoHandleWrapper;
class Store {
  friend class Ditto;
  friend class StoreObserver;
 
  std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper;
  DiskUsage disk_usage;
  Store(std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper);
  void set_weak_ditto_fields(std::weak_ptr<Ditto::Fields> weak_ditto_fields);
  std::weak_ptr<Ditto::Fields> weak_ditto_fields;
 
  bool unregister_observer(std::shared_ptr<StoreObserver>);
 
public:
  std::set<std::shared_ptr<StoreObserver>> observers;
  Store();
 
  Collection collection(std::string name) const;
 
  std::vector<std::unique_ptr<WriteTransactionResult>>
  write(std::function<void(WriteTransaction &)> fn) const;
 
  PendingCollectionsOperation collections() const;
 
  DiskUsage get_disk_usage() const;
 
  QueryResult execute(std::string query, nlohmann::json query_args = nullptr);
 
  std::shared_ptr<StoreObserver>
  register_observer(std::string query, StoreObservationHandler change_handler);
 
  std::shared_ptr<StoreObserver>
  register_observer(std::string query, nlohmann::json query_args,
                    StoreObservationHandler change_handler);
 
  std::shared_ptr<StoreObserver>
  register_observer(std::string query,
                    StoreObservationHandlerWithNextSignal change_handler);
 
  std::shared_ptr<StoreObserver>
  register_observer(std::string query, nlohmann::json query_args,
                    StoreObservationHandlerWithNextSignal change_handler);
};
} // namespace ditto
#endif