Sync.hpp

#ifndef DITTO_SYNC_H
#define DITTO_SYNC_H
 
#include "Ditto.hpp"
 
#include "json.hpp"
#include <mutex>
#include <set>
 
namespace ditto {
 
class DittoHandleWrapper;
class SyncSubscription;
 
class Sync {
  friend class Ditto;
 
  explicit 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:
  // Disable the deprecation warnings for the special member functions which
  // implicitly copy or move deprecated members.
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wdeprecated-declarations"
  Sync(const Sync &other) = default;
  Sync(Sync &&other) = default;
  Sync &operator=(const Sync &other) = default;
  Sync &operator=(Sync &&other) = default;
  ~Sync() = default;
#pragma GCC diagnostic pop

  // NOLINTNEXTLINE
  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