QueryResult.hpp

#ifndef DITTO_DQL_QUERY_RESULT_H
#define DITTO_DQL_QUERY_RESULT_H
 
#include "DocumentId.hpp"
#include "json.hpp"
 
#include <memory>
#include <mutex>
#include <vector>
 
#include "any.hpp"
#include <unordered_map>
 
/* Forward declaration with typedef */
using dittoffi_query_result_t = struct dittoffi_query_result;
using dittoffi_query_result_item_t = struct dittoffi_query_result_item;
 
namespace ditto {
using ValueMap = std::unordered_map<std::string, any>;
 
class StoreObserver;

class QueryResultItem {
  friend class QueryResult;
  friend class Differ;
 
private:
  explicit QueryResultItem(dittoffi_query_result_item_t *raw);
 
  explicit QueryResultItem(const nlohmann::json &json_dict);
 
  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;


  static QueryResultItem from_json(const nlohmann::json &json_dict);
};

class QueryResult {
private:
  friend class Store;
  friend class StoreObserver;
  friend class Transaction;
  explicit 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;
 
  // TODO(c++17): change the result type to std::optional<uint64_t>
  std::unique_ptr<uint64_t> get_commit_id() const;
};
 
}; // namespace ditto
#endif