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;
 
  DocumentId insert(nlohmann::json content, DocumentId id = DocumentId(),
                    bool is_default = false) const DITTO_DEPRECATED;
 
  DocumentId
  insert_with_strategy(nlohmann::json content, DocumentId id = DocumentId(),
                       WriteStrategy write_strategy =
                           WriteStrategy::overwrite) const DITTO_DEPRECATED;
 
  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