Subscription.hpp

#ifndef DITTO_SUBSCRIPTION_H
#define DITTO_SUBSCRIPTION_H
 
#include "Helpers.hpp"
#include "Observer.hpp"
#include "json.hpp"
 
#include <memory>
#include <string>
 
namespace ditto {
class DittoHandleWrapper;
class OrderBy;

class DITTO_DEPRECATED_BECAUSE(
    "Use DQL (Ditto Query Language) instead. For more information see: "
    "https://ditto.com/link/legacy-to-dql-guide") Subscription
    : public Observer {
  DITTO_DISABLE_DEPRECATED_WARNINGS("The legacy query API is deprecated")
 
  friend class PendingIDSpecificOperation;
  friend class PendingCursorOperation;
 
  std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper;
  nlohmann::json query_args;
  std::shared_ptr<OrderBy> order_by;
  int32_t limit = -1;
  uint32_t offset = 0;
 
  Subscription(std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper,
               std::string query, nlohmann::json query_args,
               std::shared_ptr<OrderBy> order_by, int32_t limit,
               uint32_t offset, std::string collection_name);
 
  void on_stop() override;
 
public:
  // TODO(v5): make query private and provide a getter
  std::string query; // NOLINT

  // TODO(v5): make collection_name private and provide a getter
  std::string collection_name; // NOLINT
 
  ~Subscription();
 
  DITTO_REENABLE_WARNINGS
};
} // namespace ditto
#endif