Sync.hpp

#ifndef _DITTO_SYNC_
#define _DITTO_SYNC_
 
#include "Ditto.hpp"
 
#include "json.hpp"
#include <mutex>
#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;
 
  // This mutex synchronizes access to the `subscriptions` set.
  std::shared_ptr<std::mutex> synchronized;
 
  friend class SyncSubscription;
  bool unregister_subscription(std::shared_ptr<SyncSubscription> subscription);
 
  void remove_subscription(std::shared_ptr<SyncSubscription> subscription);
 
public:
  DITTO_DEPRECATED std::set<std::shared_ptr<SyncSubscription>> subscriptions;

  std::shared_ptr<SyncSubscription>
  register_subscription(std::string query, nlohmann::json query_args = nullptr);

  std::set<std::shared_ptr<SyncSubscription>> get_subscriptions() const;
};
 
} // namespace ditto
 
#endif // !_DITTO_SYNC_