PendingCollectionsOperation.hpp

#ifndef _DITTO_PENDING_COLLECTIONS_OPERATION_
#define _DITTO_PENDING_COLLECTIONS_OPERATION_
 
#include "Collection.hpp"
#include "CollectionsEvent.hpp"
#include "LiveQuery.hpp"
#include "PendingCursorOperation.hpp"
#include "SortDirection.hpp"
#include "Subscription.hpp"
 
#include <functional>
#include <memory>
#include <string>
#include <vector>
 
namespace ditto {
class DittoHandleWrapper;
 
struct CollectionsEventHandler {
  std::function<void(CollectionsEvent)> fn;
};
 
struct CollectionsEventWithNextSignalHandler {
  std::function<void(CollectionsEvent, std::function<void()> &)> fn;
};
 
class PendingCollectionsOperation {
  friend class Store;
 
  std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper;
  uint64_t site_id;
  PendingCursorOperation pending_cursor_operation;
 
  PendingCollectionsOperation(
      std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper,
      uint64_t site_id);
 
public:
  ~PendingCollectionsOperation();
 
  PendingCollectionsOperation &limit(uint32_t limit);
 
  PendingCollectionsOperation &offset(uint32_t offset);
 
  PendingCollectionsOperation &sort(std::string query, SortDirection direction);
 
  std::vector<Collection> exec() const;
 
  Subscription subscribe() const;
 
  std::shared_ptr<LiveQuery> observe(CollectionsEventHandler handler) const;
 
  std::shared_ptr<LiveQuery>
  observe_local(CollectionsEventHandler handler) const;
 
  std::shared_ptr<LiveQuery>
  observe_with_next_signal(CollectionsEventWithNextSignalHandler handler) const;
 
  std::shared_ptr<LiveQuery> observe_local_with_next_signal(
      CollectionsEventWithNextSignalHandler handler) const;
};
} // namespace ditto
#endif