SyncSubscription.hpp

#ifndef DITTO_SYNC_SUBSCRIPTION_H
#define DITTO_SYNC_SUBSCRIPTION_H
 
#include "Ditto.hpp"
#include "Observer.hpp"
#include "Sync.hpp"
 
#include "json.hpp"
 
#include <memory>
#include <vector>
 
namespace ditto {

class SyncSubscription : Observer,
                         public std::enable_shared_from_this<SyncSubscription> {
  friend class Sync;
 
private:
  SyncSubscription(std::weak_ptr<Ditto::Fields> weak_ditto_fields,
                   std::string query, nlohmann::json args);
  /* Pointer to the ditto instance */
  std::weak_ptr<Ditto::Fields> weak_ditto_fields;
  /* Corresponding query */
  std::string query;
  /* Query args stored in cbor format */
  std::vector<uint8_t> cbor_query_args;
  /* `Observer` callback */
  void on_stop() override;
 
public:
  void cancel();
  bool is_cancelled();
};
 
}; // namespace ditto
#endif