Sync.hpp

#ifndef _DITTO_SYNC_
#define _DITTO_SYNC_
 
#include "Ditto.hpp"
 
#include "json.hpp"
#include <set>
 
namespace ditto {
 
class DittoHandleWrapper;
class SyncSubscription;
 
class Sync {
  friend class Ditto;
  Sync(std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper);
  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;
 
  friend class SyncSubscription;
  bool unregister_subscription(std::shared_ptr<SyncSubscription> subscription);
 
  void remove_subscription(std::shared_ptr<SyncSubscription> subscription);
 
public:
  std::set<std::shared_ptr<SyncSubscription>> subscriptions;
  std::shared_ptr<SyncSubscription>
  register_subscription(std::string query, nlohmann::json query_args = nullptr);
};
 
} // namespace ditto
 
#endif // !_DITTO_SYNC_