PendingIDSpecificOperation.hpp

#ifndef _DITTO_PENDING_ID_SPECIFIC_OPERATION_
#define _DITTO_PENDING_ID_SPECIFIC_OPERATION_
 
#include "Document.hpp"
#include "DocumentId.hpp"
#include "Helpers.hpp"
#include "LiveQuery.hpp"
#include "MutableDocument.hpp"
#include "Subscription.hpp"
#include "UpdateResult.hpp"
 
#include "json.hpp"
 
#include <functional>
#include <memory>
#include <string>
#include <vector>
 
namespace ditto {
 
class PendingIDSpecificOperation {
  friend class Collection;
 
  std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper;
  std::string query;
 
  PendingIDSpecificOperation(
      std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper,
      std::string collection_name, DocumentId id);
 
  std::shared_ptr<LiveQuery> observe_internal(
      Subscription *subscription, LiveQueryAvailability_t availability,
      SingleDocumentLiveQueryWithNextSignalEventHandler handler) const;
 
  std::shared_ptr<LiveQuery> observe_internal(
      Subscription *subscription, LiveQueryAvailability_t availability,
      SingleDocumentLiveQueryEventWithNextSignalCallback event_callback) const;
 
public:
  std::string collection_name;
 
  DocumentId id;
 
  std::shared_ptr<Document> exec() const;
 
  std::vector<std::unique_ptr<UpdateResult>>
  update(std::function<void(MutableDocument &)> fn);
 
  bool remove() const;
 
  bool evict() const;
 
  Subscription subscribe() const;
 
  std::shared_ptr<LiveQuery> observe(
      SingleDocumentLiveQueryEventHandler event_handler) const DITTO_DEPRECATED;
 
  std::shared_ptr<LiveQuery>
  observe(SingleDocumentLiveQueryEventCallback event_callback) const;
 
  std::shared_ptr<LiveQuery> observe_local(
      SingleDocumentLiveQueryEventHandler event_handler) const DITTO_DEPRECATED;
 
  std::shared_ptr<LiveQuery>
  observe_local(SingleDocumentLiveQueryEventCallback event_callback) const;
 
  std::shared_ptr<LiveQuery> observe_with_next_signal(
      SingleDocumentLiveQueryWithNextSignalEventHandler event_handler) const
      DITTO_DEPRECATED;
 
  std::shared_ptr<LiveQuery> observe_with_next_signal(
      SingleDocumentLiveQueryEventWithNextSignalCallback event_callback) const;
 
  std::shared_ptr<LiveQuery> observe_local_with_next_signal(
      SingleDocumentLiveQueryWithNextSignalEventHandler event_handler) const
      DITTO_DEPRECATED;
 
  std::shared_ptr<LiveQuery> observe_local_with_next_signal(
      SingleDocumentLiveQueryEventWithNextSignalCallback event_callback) const;
};
} // namespace ditto
#endif