TestHelpers.hpp

#include "Ditto.h"
#include "gtest/gtest.h"
#include <filesystem.hpp>
 
#include <algorithm>
#include <chrono>
#include <climits>
#include <functional>
#include <future>
#include <random>
#include <vector>
 
using random_bytes_engine =
    std::independent_bits_engine<std::default_random_engine, 16,
                                 unsigned short>;
 
#define ASSERT_RESOLVES(future, timeout)                                       \
  ASSERT_TRUE(future.wait_for(timeout) == std::future_status::ready)           \
      << "Future timed out";
 
#define ASSERT_NOT_RESOLVES(future, timeout)                                   \
  ASSERT_NE(future.wait_for(timeout), std::future_status::ready)               \
      << "Future was resolved";
 
class TempPersistenceDir {
public:
  TempPersistenceDir();
  ~TempPersistenceDir();
  std::string path();
 
private:
  std::string ditto_dir;
};
 
namespace TestHelpers {
extern const std::string test_license;
ditto::Ditto get_unlicensed_ditto(TempPersistenceDir &temp_dir);
ditto::Ditto get_ditto(TempPersistenceDir &temp_dir);
std::vector<nlohmann::json>
map_doc_value(std::vector<ditto::Document> const &documents);
std::vector<nlohmann::json>
map_doc_value_without_id(std::vector<ditto::Document> const &documents);
std::vector<ditto::DocumentId>
map_doc_id(std::vector<ditto::Document> documents);
nlohmann::json doc_value_without_id(std::shared_ptr<ditto::Document> document);
nlohmann::json json_without_id(nlohmann::json j);
std::string
get_ditto_repo_directory_from_child(ghc::filesystem::path child_path);
std::vector<uint8_t> get_random_bytes(uint32_t num_bytes);
std::string get_random_string(std::size_t length);
 
template <class T> nlohmann::json register_json(T value) {
  return nlohmann::json({{"_value", value},
                         {"_ditto_internal_type_jkb12973t4b",
                          DittoCrdtType::DITTO_CRDT_TYPE_REGISTER}});
}
 
nlohmann::json counter_json(double value);
} // namespace TestHelpers