curl_range_reader.hpp

Go to the documentation of this file.

#pragma once
 
#ifdef FCB_WITH_CURL
 
#    include <fcb/error.hpp>
#    include <fcb/range_reader.hpp>
 
#    include <cstdint>
#    include <memory>
#    include <string>
#    include <vector>
 
namespace fcb {
 
struct CurlOptions {
    long timeout_ms = 30000;
    long connect_timeout_ms = 10000;
    bool follow_redirects = true;
    std::string user_agent = "flatcitybuf-cpp/0.8";
 
    bool require_stable_representation = true;
};
 
class CurlRangeReader : public RangeReader {
  public:
    explicit CurlRangeReader(const std::string& url, CurlOptions options = {});
    ~CurlRangeReader() override;
 
    CurlRangeReader(const CurlRangeReader&) = delete;
    CurlRangeReader& operator=(const CurlRangeReader&) = delete;
 
    std::uint64_t total_size() override;
    std::vector<std::uint8_t> read(std::uint64_t offset, std::uint64_t length) override;
 
    std::uint64_t request_count() const { return request_count_; }
    void reset_request_count() { request_count_ = 0; }
 
  private:
    struct Impl;
    std::unique_ptr<Impl> impl_;
    std::uint64_t request_count_ = 0;
};
 
}  // namespace fcb
 
#endif  // FCB_WITH_CURL