LiveQuery.hpp

#ifndef _DITTO_LIVE_QUERY_
#define _DITTO_LIVE_QUERY_
 
#include "Document.hpp"
#include "Helpers.hpp"
#include "LiveQueryEvent.hpp"
#include "LiveQueryMove.hpp"
#include "Observer.hpp"
#include "SingleDocumentLiveQueryEvent.hpp"
#include "Subscription.hpp"
#include "json.hpp"
 
#include <functional>
#include <memory>
#include <string>
#include <vector>
 
namespace ditto {
class DittoHandleWrapper;
class OrderBy;
 
typedef std::function<void(std::shared_ptr<Document>,
                           SingleDocumentLiveQueryEvent)>
    SingleDocumentLiveQueryEventCallback;
 
struct SingleDocumentLiveQueryEventHandler {
  std::function<void(std::shared_ptr<Document>, SingleDocumentLiveQueryEvent)>
      fn;
};
 
typedef std::function<void(std::shared_ptr<Document>,
                           SingleDocumentLiveQueryEvent,
                           std::function<void()> &)>
    SingleDocumentLiveQueryEventWithNextSignalCallback;
 
struct SingleDocumentLiveQueryWithNextSignalEventHandler {
  std::function<void(std::shared_ptr<Document>, SingleDocumentLiveQueryEvent,
                     std::function<void()> &)>
      fn;
};
 
typedef std::function<void(std::vector<Document>, LiveQueryEvent)>
    LiveQueryEventCallback;
 
struct LiveQueryEventHandler {
  std::function<void(std::vector<Document>, LiveQueryEvent)> fn;
};
 
typedef std::function<void(std::vector<Document>, LiveQueryEvent,
                           std::function<void()> &)>
    LiveQueryEventWithNextSignalCallback;
 
struct LiveQueryWithNextSignalEventHandler {
  std::function<void(std::vector<Document>, LiveQueryEvent,
                     std::function<void()> &)>
      fn;
};
 
class LiveQuery : public Observer {
  friend class PendingCursorOperation;
  friend class PendingIDSpecificOperation;
 
public:
  ~LiveQuery();
 
private:
  void on_stop() override;
  LiveQuery(std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper,
            std::string query, nlohmann::json query_args, std::string coll_name,
            std::shared_ptr<OrderBy> &order_by, int32_t limit, uint32_t offset,
            LiveQueryAvailability_t availability, Subscription *subscription,
            LiveQueryEventWithNextSignalCallback event_callback);
 
  class LiveQueryCtx;
  LiveQueryCtx *ctx;
  bool stopped;
};
 
} // namespace ditto
 
#endif