ScopedWriteTransaction.hpp

#ifndef _DITTO_SCOPED_WRITE_TRANSACTION_
#define _DITTO_SCOPED_WRITE_TRANSACTION_
 
#include "DocumentId.hpp"
#include "Helpers.hpp"
#include "WriteStrategy.hpp"
#include "WriteTransaction.hpp"
#include "WriteTransactionPendingCursorOperation.hpp"
#include "WriteTransactionPendingIDSpecificOperation.hpp"
 
#include "json.hpp"
#include "safer_ffi_utils.hpp"
 
#include <string>
 
namespace ditto {
class DittoHandleWrapper;

class ScopedWriteTransaction {
  friend class WriteTransaction;
  friend class WriteTransactionPendingCursorOperation;
  friend class WriteTransactionPendingIDSpecificOperation;
 
  WriteTransaction &base_transaction;
 
  ScopedWriteTransaction(std::string collection_name,
                         WriteTransaction &base_transaction);
 
public:
  std::string collection_name;

  DocumentId upsert(nlohmann::json content,
                    WriteStrategy write_strategy = WriteStrategy::merge) const;

  WriteTransactionPendingIDSpecificOperation find_by_id(DocumentId id) const;

  WriteTransactionPendingCursorOperation find_all() const;

  WriteTransactionPendingCursorOperation find(std::string query) const;

  WriteTransactionPendingCursorOperation find(std::string query,
                                              nlohmann::json query_args) const;
};
} // namespace ditto
#endif