s3.h

// Copyright 2020, Beeri 15.  All rights reserved.
// Author: Roman Gershman (romange@gmail.com)
//

#include <functional>
#include "file/file.h"
#include "util/status.h"

#pragma once

namespace util {

namespace http {

class HttpsClient;
class HttpsClientPool;

}  // namespace http

class AWS;

class S3Bucket {
 public:
  using ListObjectResult = util::Status;

  static const char* kRootDomain;

  using ListObjectCb = std::function<void(size_t, absl::string_view)>;

  S3Bucket(const AWS& aws, http::HttpsClientPool* pool);

  ListObjectResult List(absl::string_view glob, bool fs_mode, ListObjectCb cb);

  static bool SplitToBucketPath(absl::string_view input, absl::string_view* bucket,
                                absl::string_view* path);

  static std::string ToFullPath(absl::string_view bucket, absl::string_view key_path);

 private:
  const AWS& aws_;
  http::HttpsClientPool* pool_;
};

using ListS3BucketResult = util::StatusObject<std::vector<std::string>>;

ListS3BucketResult ListS3Buckets(const AWS& aws, http::HttpsClientPool* pool);

StatusObject<file::ReadonlyFile*> OpenS3ReadFile(
    absl::string_view key_path, const AWS& aws, http::HttpsClientPool* pool,
    const file::ReadonlyFile::Options& opts = file::ReadonlyFile::Options{});

StatusObject<file::WriteFile*> OpenS3WriteFile(
    absl::string_view key_path, const AWS& aws, http::HttpsClientPool* pool);


bool IsS3Path(absl::string_view path);

namespace detail {

std::vector<std::string> ParseXmlListBuckets(absl::string_view xml_obj);
void ParseXmlListObj(absl::string_view xml_obj, S3Bucket::ListObjectCb cb);

}  // namespace detail

}  // namespace util