api.hxx

 
#ifndef __FDP_API_HXX__
#define __FDP_API_HXX__
 
#include <algorithm>
#include <curl/curl.h>
#include <ghc/filesystem.hpp>
#include <iostream>
#include <iterator>
#include <json/reader.h>
#include <map>
#include <regex>
#include <string>
#include <vector>
 
#include "fdp/exceptions.hxx"
#include "fdp/objects/api_object.hxx"
#include "fdp/utilities/json.hxx"
#include "fdp/utilities/logging.hxx"
 
namespace FairDataPipeline {
enum class RESTAPI {
  REMOTE, 
  LOCAL   
};
 
#if 0
size_t write_func_(void *ptr, size_t size, size_t nmemb, std::string *data);
#endif 
 
class API {
public:
    typedef std::shared_ptr< API > sptr;
 
    static sptr construct( const std::string& url_root );
 
 
  Json::Value get_request(const std::string &addr_path,
                      long expected_response = 200, std::string token = "");
 
  Json::Value patch(const std::string addr_path, Json::Value &post_data,
                      const std::string &token, long expected_response = 200);
  Json::Value post(const std::string addr_path, Json::Value &post_data,
                   const std::string &token, long expected_response = 201);
 
  Json::Value post_storage_root(Json::Value &post_data, const std::string &token);
 
  Json::Value post_file_type(Json::Value &post_data, const std::string &token);
 
  Json::Value get_by_json_query(const std::string &addr_path,
                                  Json::Value &query_data,
                                  long expected_response = 200,
                                  std::string token = "");
 
  Json::Value get_by_id(const std::string &table, int const &id,
                      long expected_response = 200, std::string token = "");
 
  std::string get_url_root() const { return url_root_; }
 
  std::string json_to_query_string(Json::Value &json_value);
 
  std::string escape_space(std::string &str);
 
  static std::string append_with_forward_slash(std::string string);
 
  static std::string remove_leading_forward_slash(std::string str);
 
private:
  API( const std::string& url_root)
      : url_root_(API::append_with_forward_slash(url_root)) {}
 
  std::string url_root_;
  CURL *setup_json_session_(std::string &addr_path, std::string *response,
                            long &http_code, std::string token = "");
  CURL *setup_download_session_(const ghc::filesystem::path &addr_path,
                                FILE *file);  
                      
  Json::Value post_patch_request(const std::string addr_path, Json::Value &post_data,
                      const std::string &token, long expected_response, bool PATCH = false);
 
  // Legacy Method
  Json::Value get_request(const ghc::filesystem::path &addr_path,
                      long expected_response = 200, std::string token = "");
 
  void download_file(const ghc::filesystem::path &url,
                     ghc::filesystem::path out_path);
};
 
std::string url_encode(const std::string& url);
 
}; // namespace FairDataPipeline
 
#endif