59 lines
2.0 KiB
C++
59 lines
2.0 KiB
C++
#define CATCH_CONFIG_MAIN
|
|
#include <catch.hpp>
|
|
|
|
#include <iostream>
|
|
|
|
#include "etcd/Client.hpp"
|
|
|
|
static std::string ca = "security-config/certs/ca.crt";
|
|
static std::string cert = "security-config/certs/etcd0.example.com.crt";
|
|
static std::string key = "security-config/private/etcd0.example.com.key";
|
|
|
|
static const std::string etcd_url =
|
|
etcdv3::detail::resolve_etcd_endpoints("https://127.0.0.1:2379");
|
|
|
|
TEST_CASE("setup with auth") {
|
|
etcd::Client* etcd = etcd::Client::WithSSL(etcd_url, ca, cert, key);
|
|
etcd->rmdir("/test", true).wait();
|
|
}
|
|
|
|
TEST_CASE("add a new key after authenticate") {
|
|
etcd::Client* etcd = etcd::Client::WithSSL(etcd_url, ca, cert, key);
|
|
etcd->rmdir("/test", true).wait();
|
|
etcd::Response resp = etcd->add("/test/key1", "42").get();
|
|
REQUIRE(0 == resp.error_code());
|
|
CHECK("create" == resp.action());
|
|
etcd::Value const& val = resp.value();
|
|
CHECK("42" == val.as_string());
|
|
CHECK("/test/key1" == val.key());
|
|
CHECK(!val.is_dir());
|
|
CHECK(0 < val.created_index());
|
|
CHECK(0 < val.modified_index());
|
|
CHECK(1 == val.version());
|
|
CHECK(0 < resp.index());
|
|
CHECK(
|
|
etcd::ERROR_KEY_ALREADY_EXISTS ==
|
|
etcd->add("/test/key1", "43").get().error_code()); // Key already exists
|
|
CHECK(
|
|
etcd::ERROR_KEY_ALREADY_EXISTS ==
|
|
etcd->add("/test/key1", "42").get().error_code()); // Key already exists
|
|
CHECK("etcd-cpp-apiv3: key already exists" ==
|
|
etcd->add("/test/key1", "42").get().error_message());
|
|
}
|
|
|
|
TEST_CASE("read a value from etcd") {
|
|
etcd::Client* etcd = etcd::Client::WithSSL(etcd_url, ca, cert, key);
|
|
etcd::Response resp = etcd->get("/test/key1").get();
|
|
CHECK("get" == resp.action());
|
|
REQUIRE(resp.is_ok());
|
|
REQUIRE(0 == resp.error_code());
|
|
CHECK("42" == resp.value().as_string());
|
|
CHECK("" == etcd->get("/test").get().value().as_string()); // key points to a
|
|
// directory
|
|
}
|
|
|
|
TEST_CASE("cleanup") {
|
|
etcd::Client* etcd = etcd::Client::WithSSL(etcd_url, ca, cert, key);
|
|
REQUIRE(0 == etcd->rmdir("/test", true).get().error_code());
|
|
}
|