#include <grpc/support/log.h>
#include "etcd/v3/Action.hpp"

etcdv3::Action::Action(etcdv3::ActionParameters params)
{
  parameters = params;
  if (!parameters.auth_token.empty()) {
    // use `token` as the key, see:
    //
    //  etcd/etcdserver/api/v3rpc/rpctypes/metadatafields.go
    context.AddMetadata("token", parameters.auth_token);
  }
  start_timepoint = std::chrono::high_resolution_clock::now();
}

etcdv3::ActionParameters::ActionParameters()
{
  withPrefix = false;
  revision = 0;
  old_revision = 0;
  lease_id = 0;
  ttl = 0;
  kv_stub = NULL;
  watch_stub = NULL;
  lease_stub = NULL;
}

void etcdv3::Action::waitForResponse() 
{
  void* got_tag;
  bool ok = false;    

  cq_.Next(&got_tag, &ok);
  GPR_ASSERT(got_tag == (void*)this);
}

const std::chrono::high_resolution_clock::time_point etcdv3::Action::startTimepoint() {
  return this->start_timepoint;
}

std::string etcdv3::detail::string_plus_one(std::string const &value) {
  // referred from the Go implementation in etcd.
  char *s = static_cast<char *>(calloc(value.size() + 1, sizeof(char)));
  std::memcpy(s, value.c_str(), value.size());
  for (int i = value.size() - 1; i >= 0; --i) {
    if (static_cast<unsigned char>(s[i]) < 0xff) {
      s[i] = s[i] + 1;
      std::string ret = std::string(s, i + 1);
      free(s);
      return ret;
    }
  }
  // see: noPrefixEnd in etcd
  return {"\0"};
}