#include <catch.hpp>

#include "etcd/Watcher.hpp"
#include "etcd/SyncClient.hpp"

static std::string etcd_uri("http://127.0.0.1:2379");
static int watcher_called = 0;

void printResponse(etcd::Response const & resp)
{
  ++watcher_called;
  std::cout << "print response called" << std::endl;
  if (resp.error_code())
    std::cout << resp.error_code() << ": " << resp.error_message() << std::endl;
  else
  {
    std::cout << resp.action() << " " << resp.value().as_string() << std::endl;
  }
}

TEST_CASE("create watcher with cancel")
{
  
  etcd::SyncClient etcd(etcd_uri);
  etcd.rmdir("/test", true);

  watcher_called = 0;
  etcd::Watcher watcher(etcd_uri, "/test", printResponse);
  sleep(1);
  etcd.set("/test/key", "42");
  etcd.set("/test/key", "43");
  sleep(1);
  CHECK(2 == watcher_called);
  watcher.Cancel();
  etcd.set("/test/key", "50");
  etcd.set("/test/key", "51");
  sleep(1);
  CHECK(2 == watcher_called);

  etcd.rmdir("/test", true);

}

TEST_CASE("create watcher")
{
  
  etcd::SyncClient etcd(etcd_uri);
  etcd.rmdir("/test", true);

  watcher_called = 0;
  {
    etcd::Watcher watcher(etcd_uri, "/test", printResponse);
    sleep(1);
    etcd.set("/test/key", "42");
    etcd.set("/test/key", "43");
  }
  
  CHECK(2 == watcher_called);
// TEST_CASE("wait for a value change")
// {
//   etcd::Client etcd(etcd_uri);
//   etcd.set("/test/key1", "42").wait();

//   pplx::task<etcd::Response> res = etcd.watch("/test/key1");
//   CHECK(!res.is_done());

//   etcd.set("/test/key1", "43").get();
//   sleep(1);

//   REQUIRE(res.is_done());
//   REQUIRE("set" == res.get().action());
//   CHECK("43" == res.get().value().as_string());
// }

// TEST_CASE("wait for a directory change")
// {
//   etcd::Client etcd(etcd_uri);

//   pplx::task<etcd::Response> res = etcd.watch("/test", true);

//   etcd.add("/test/key4", "44").wait();
//   REQUIRE(res.is_done());
//   CHECK("create" == res.get().action());
//   CHECK("44" == res.get().value().as_string());

//   pplx::task<etcd::Response> res2 = etcd.watch("/test", true);

//   etcd.set("/test/key4", "45").wait();
//   sleep(1);
//   REQUIRE(res2.is_done());
//   CHECK("set" == res2.get().action());
//   CHECK("45" == res2.get().value().as_string());
// }

// TEST_CASE("watch changes in the past")
// {
//   etcd::Client etcd(etcd_uri);

//   int index = etcd.set("/test/key1", "42").get().index();

//   etcd.set("/test/key1", "43").wait();
//   etcd.set("/test/key1", "44").wait();
//   etcd.set("/test/key1", "45").wait();

//   etcd::Response res = etcd.watch("/test/key1", ++index).get();
//   CHECK("set" == res.action());
//   CHECK("43" == res.value().as_string());

//   res = etcd.watch("/test/key1", ++index).get();
//   CHECK("set" == res.action());
//   CHECK("44" == res.value().as_string());

//   res = etcd.watch("/test", ++index, true).get();
//   CHECK("set" == res.action());
//   CHECK("45" == res.value().as_string());
// }

// TEST_CASE("request cancellation")
// {
//   etcd::Client etcd(etcd_uri);
//   etcd.set("/test/key1", "42").wait();

//   pplx::task<etcd::Response> res = etcd.watch("/test/key1");
//   CHECK(!res.is_done());

//   etcd.cancel_operations();

//   sleep(1);
//   REQUIRE(res.is_done());
//   try
//   {
//     res.wait();
//   }
//   catch(pplx::task_canceled const & ex)
//   {
//     std::cout << "pplx::task_canceled: " << ex.what() << "\n";
//   }
//   catch(std::exception const & ex)
//   {
//     std::cout << "std::exception: " << ex.what() << "\n";
//   }
// }
  etcd.rmdir("/test", true).error_code();
}