Collection.hpp

#ifndef _DITTO_COLLECTION_
#define _DITTO_COLLECTION_
 
#include "Attachment.hpp"
#include "AttachmentFetchEvent.hpp"
#include "AttachmentFetcher.hpp"
#include "AttachmentToken.hpp"
#include "DocumentId.hpp"
#include "Helpers.hpp"
#include "PendingCursorOperation.hpp"
#include "PendingIDSpecificOperation.hpp"
#include "WriteStrategy.hpp"
 
#include "json.hpp"
 
#include <map>
#include <memory>
#include <string>
 
namespace ditto {
class DittoHandleWrapper;
 
class Collection {
private:
  friend class DocumentHelpers;
  friend class ScopedWriteTransaction;
  friend class Store;
 
  std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper;
 
  struct private_ctor {};
 
  Collection(std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper,
             std::string name);
 
  DocumentId upsert(nlohmann::json content, DocumentId id,
                    WriteStrategy write_strategy, CWriteTransaction *txn) const;
 
public:
  // Indirect (because of `private_ctor`) private constructor
  Collection(std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper,
             std::string name, private_ctor &&);
 
  std::string name;
 
  DocumentId upsert(nlohmann::json content,
                    WriteStrategy write_strategy = WriteStrategy::merge) const;
 
  PendingIDSpecificOperation find_by_id(DocumentId id) const;
 
  PendingCursorOperation find_all() const;
 
  PendingCursorOperation find(std::string query) const;
 
  PendingCursorOperation find(std::string query,
                              nlohmann::json query_args) const;
 
  Attachment new_attachment(std::string path,
                            std::map<std::string, std::string> metadata =
                                std::map<std::string, std::string>()) const;
 
  std::shared_ptr<AttachmentFetcher>
  fetch_attachment(std::shared_ptr<AttachmentToken> token,
                   AttachmentFetcherEventHandler event_handler) const;
};
} // namespace ditto
#endif