QueryResult.hpp

#ifndef _DITTO_DQL_QUERY_RESULT_
#define _DITTO_DQL_QUERY_RESULT_
 
#include "DocumentId.hpp"
#include "json.hpp"
 
#include <memory>
#include <mutex>
#include <vector>
 
#include "any.hpp"
#include <unordered_map>
 
/* Forward declaration with typedef */
typedef struct dittoffi_query_result dittoffi_query_result_t;
typedef struct dittoffi_query_result_item dittoffi_query_result_item_t;
 
namespace ditto {
using ValueMap = std::unordered_map<std::string, any>;
 
class StoreObserver;
 
class QueryResultItem {
  friend class QueryResult;
 
private:
  QueryResultItem(dittoffi_query_result_item_t *raw);
 
  std::shared_ptr<dittoffi_query_result_item> raw;
  mutable std::shared_ptr<ValueMap> materialized_value;
  mutable std::unique_ptr<std::mutex> synchronized;
 
public:
  std::shared_ptr<ValueMap> value() const;
 
  bool is_materialized() const;
 
  void materialize();
 
  void dematerialize();
 
  std::vector<uint8_t> cbor_data() const;
 
  std::string json_string() const;
};
 
class QueryResult {
private:
  friend class Store;
  friend class StoreObserver;
  QueryResult(dittoffi_query_result_t *raw);
  std::shared_ptr<dittoffi_query_result_t> raw;
 
public:
  size_t item_count() const;
  QueryResultItem get_item(size_t index) const;
 
  std::vector<QueryResultItem> items() const;
 
  std::vector<DocumentId> mutated_document_ids() const;
};
 
};     // namespace ditto
#endif // !_DITTO_DQL_QUERY_RESULT_