curl.h

Go to the documentation of this file.

// uvco (c) 2024 Lewin Bormann. See LICENSE for specific terms.
 
#pragma once
 
#include <curl/curl.h>
#include <curl/multi.h>
 
#include "uvco/promise/multipromise.h"
#include "uvco/promise/promise.h"
 
#include <exception>
#include <memory>
#include <optional>
#include <span>
#include <string>
#include <utility>
 
namespace uvco {
 
class Loop;
 
class UvCurlContext_;
class CurlRequestCore_;
class Curl;
 
class CurlException : public std::exception {
public:
  CurlException(CURLcode code, std::string url)
      : url_{std::move(url)}, code_{code} {}
 
  [[nodiscard]] const char *what() const noexcept override {
    return curl_easy_strerror(code_);
  }
 
private:
  std::string url_;
  CURLcode code_;
};
 
class CurlRequest {
public:
  enum class Method { GET, POST };
 
  CurlRequest(const CurlRequest &) = delete;
  CurlRequest(CurlRequest &&) = delete;
  CurlRequest &operator=(const CurlRequest &) = delete;
  CurlRequest &operator=(CurlRequest &&) = delete;
  ~CurlRequest();
 
  void setTimeoutMs(long timeoutMs);
 
  MultiPromise<std::string> start();
 
  [[nodiscard]] std::optional<long> statusCode() const;
 
private:
  friend class Curl;
  CurlRequest(std::weak_ptr<UvCurlContext_> context, Method method,
              std::string url);
  CurlRequest(std::weak_ptr<UvCurlContext_> context, Method method,
              std::string url,
              std::span<const std::pair<std::string, std::string>> fields);
 
  // Core must be pinned in memory.
  std::unique_ptr<CurlRequestCore_> core_;
};
 
class Curl {
public:
  explicit Curl(const Loop &loop);
 
  // Pinned in memory due to uv fields. Hide behind unique_ptr if moving
  // is required.
  Curl(const Curl &) = delete;
  Curl(Curl &&other) = delete;
  Curl &operator=(const Curl &) = delete;
  Curl &operator=(Curl &&other) = delete;
  ~Curl();
 
  CurlRequest get(std::string url);
 
  CurlRequest post(std::string url,
                   std::span<const std::pair<std::string, std::string>> fields);
 
  Promise<void> close();
 
private:
  std::shared_ptr<UvCurlContext_> context_;
};
 
} // namespace uvco