http_client.h

Go to the documentation of this file.

// Copyright (C) 2013-2020 iFunFactory Inc. All Rights Reserved.
//
// This work is confidential and proprietary to iFunFactory Inc. and
// must not be used, disclosed, copied, or distributed without the prior
// consent of iFunFactory Inc.

#ifndef INCLUDE_FUNAPI_NETWORK_HTTP_CLIENT_H_
#define INCLUDE_FUNAPI_NETWORK_HTTP_CLIENT_H_

#include <boost/enable_shared_from_this.hpp>
#include <boost/function.hpp>
#include <funapi/common/json.h>
#include <funapi/network/curl.h>
#include <funapi/network/http_util.h>
#include <funapi/types.h>

#include <deque>


namespace fun {

class FUNAPI_DLL_VISIBILITY HttpClient
    : public boost::enable_shared_from_this<HttpClient>,
      private boost::noncopyable {
 public:
  class Impl;

  DECLARE_CLASS_PTR(HttpClient);

  typedef function<void(const CURLcode, const http::Response &)> Handler;
  typedef function<void(const CURLcode, const string &error_desc,
                        const http::Response &)> Handler2;

  HttpClient();

  ~HttpClient();

  void SetHeader(const string &key, const string &value);

  void UnsetHeader(const string &key);

  void ResetHeader();

  CURLcode Get(const string &url, size_t timeout_in_ms = 0);

  //  Content type is not set by this function.
  CURLcode Post(const string &url, const Ptr<const string> &data,
                size_t timeout_in_ms = 0);

  CURLcode Post(const string &url, const Json &data, size_t timeout_in_ms = 0);

  //  Content type is not set by this function.
  //              the callee takes the ownership of the pointer.
  CURLcode Post(const string &url, const curl_httppost *data,
                size_t timeout_in_ms = 0);

  //  Content type is not set by this function.
  CURLcode Put(const string &url, const Ptr<const string> &data,
               size_t timeout_in_ms = 0);

  CURLcode Put(const string &url, const Json &data, size_t timeout_in_ms = 0);

  //  Content type is not set by this function.
  CURLcode Delete(const string &url, const Ptr<const string> &data,
                  size_t timeout_in_ms = 0);

  CURLcode Delete(const string &url, const Json &data,
                  size_t timeout_in_ms = 0);

  void GetAsync(const string &url, const Handler &handler,
                size_t timeout_in_ms = 0);

  void PostAsync(const string &url, const Ptr<const string> &data,
                 const Handler &handler, size_t timeout_in_ms = 0);

  void PostAsync(const string &url, const Json &data,
                 const Handler &handler, size_t timeout_in_ms = 0);

  //              the callee takes the ownership of the pointer.
  void PostAsync(const string &url, const curl_httppost *data,
                 const Handler &handler, size_t timeout_in_ms = 0);

  void PutAsync(const string &url, const Ptr<const string> &data,
                const Handler &handler, size_t timeout_in_ms = 0);

  void PutAsync(const string &url, const Json &data,
                const Handler &handler, size_t timeout_in_ms = 0);

  void DeleteAsync(const string &url, const Ptr<const string> &data,
                   const Handler &handler, size_t timeout_in_ms = 0);

  void DeleteAsync(const string &url, const Json &data,
                   const Handler &handler, size_t timeout_in_ms = 0);

  void GetAsync2(const string &url, const Handler2 &handler,
                 size_t timeout_in_ms = 0);

  void PostAsync2(const string &url, const Ptr<const string> &data,
                  const Handler2 &handler, size_t timeout_in_ms = 0);

  void PostAsync2(const string &url, const Json &data,
                  const Handler2 &handler, size_t timeout_in_ms = 0);

  //              the callee takes the ownership of the pointer.
  void PostAsync2(const string &url, const curl_httppost *data,
                  const Handler2 &handler, size_t timeout_in_ms = 0);

  void PutAsync2(const string &url, const Ptr<const string> &data,
                 const Handler2 &handler, size_t timeout_in_ms = 0);

  void PutAsync2(const string &url, const Json &data,
                 const Handler2 &handler, size_t timeout_in_ms = 0);

  void DeleteAsync2(const string &url, const Ptr<const string> &data,
                    const Handler2 &handler, size_t timeout_in_ms = 0);

  void DeleteAsync2(const string &url, const Json &data,
                    const Handler2 &handler, size_t timeout_in_ms = 0);

  const http::Response &response() const;

  const string &error_message() const;

  CURL *handle();

  void set_verbose(bool on);

 private:
  Ptr<Impl> impl_;
};

}  // namespace fun


#endif  // INCLUDE_FUNAPI_NETWORK_HTTP_CLIENT_H_