Method SendRPCMessage

src/jsonrpccpp/client/connectors/httpclient.cpp:60–107

HttpClient::~HttpClient() { curl_easy_cleanup(curl); }

void HttpClient::SendRPCMessage(const std::string &message, std::string &result) {

  curl_easy_setopt(curl, CURLOPT_NOSIGNAL, 1);
  curl_easy_setopt(curl, CURLOPT_URL, this->url.c_str());
  curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, writefunc);

  CURLcode res;

  struct string s;
  init_string(&s);

  struct curl_slist *headers = NULL;

  for (std::map<std::string, std::string>::iterator header = this->headers.begin(); header != this->headers.end(); ++header) {
    headers = curl_slist_append(headers, (header->first + ": " + header->second).c_str());
  }

  headers = curl_slist_append(headers, "Content-Type: application/json");
  headers = curl_slist_append(headers, "charsets: utf-8");

  curl_easy_setopt(curl, CURLOPT_POSTFIELDS, message.c_str());
  curl_easy_setopt(curl, CURLOPT_WRITEDATA, &s);
  curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
  curl_easy_setopt(curl, CURLOPT_TIMEOUT_MS, timeout);

  res = curl_easy_perform(curl);

  result = s.ptr;
  free(s.ptr);
  curl_slist_free_all(headers);
  if (res != CURLE_OK) {
    std::stringstream str;
    str << "libcurl error: " << res;

    if (res == 7)
      str << " -> Could not connect to " << this->url;
    else if (res == 28)
      str << " -> Operation timed out";
    throw JsonRpcException(Errors::ERROR_CLIENT_CONNECTOR, str.str());
  }

  long http_code = 0;
  curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &http_code);

  if (http_code / 100 != 2) {
    throw JsonRpcException(Errors::ERROR_RPC_INTERNAL_ERROR, result);
  }
}

void HttpClient::SetUrl(const std::string &url) { this->url = url; }