WriteTransactionPendingCursorOperation.hpp

#ifndef _DITTO_WRITE_TRANSACTION_PENDING_CURSOR_OPERATION_
#define _DITTO_WRITE_TRANSACTION_PENDING_CURSOR_OPERATION_
 
#include "Document.hpp"
#include "DocumentId.hpp"
#include "MutableDocument.hpp"
#include "SortDirection.hpp"
#include "UpdateResult.hpp"
#include "WriteTransaction.hpp"
 
#include <functional>
#include <memory>
#include <string>
#include <unordered_map>
#include <vector>
 
namespace ditto {
using nlohmann::json;
 
class DittoHandleWrapper;
 
class WriteTransactionPendingCursorOperation {
  friend class ScopedWriteTransaction;
 
  json query_args;
  WriteTransaction &base_transaction;
  uint32_t _offset = 0;
  int32_t _limit = -1;
 
  WriteTransactionPendingCursorOperation(
      std::string collection_name, std::string query, json query_args,
      std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper,
      WriteTransaction &base_transaction);
 
  WriteTransactionPendingCursorOperation(
      WriteTransactionPendingCursorOperation &&other) noexcept;
  WriteTransactionPendingCursorOperation &
  operator=(WriteTransactionPendingCursorOperation &&other) noexcept;
 
  class Impl;
  std::unique_ptr<Impl> impl_;
 
public:
  ~WriteTransactionPendingCursorOperation();
 
  std::string collection_name;
 
  std::string query;
 
  WriteTransactionPendingCursorOperation &limit(uint32_t limit);
 
  WriteTransactionPendingCursorOperation &offset(uint32_t offset);
 
  WriteTransactionPendingCursorOperation &sort(std::string query,
                                               SortDirection direction);
 
  std::vector<Document> exec() const;
 
  std::unordered_map<DocumentId, std::vector<std::unique_ptr<UpdateResult>>,
                     DocumentIdHasher>
  update(std::function<void(std::vector<MutableDocument> &)> fn) const;
 
  std::vector<DocumentId> remove() const;
 
  std::vector<DocumentId> evict() const;
};
} // namespace ditto
#endif