#include <aws/core/Aws.h>
#include <aws/core/utils/threading/PooledThreadExecutor.h>
#include <aws/transfer/TransferManager.h>

using namespace Aws;
using namespace Aws::S3;
using namespace Aws::Transfer;
using namespace Aws::Utils;
using namespace Aws::Utils::Threading;
namespace {
const char * LOG_TAG = "test-app";
const char * BUCKET_NAME = "somebucket";
const char * KEY_NAME = "somekey";
}

auto main() -> int {
  SDKOptions options{};
  options.loggingOptions.logLevel = Logging::LogLevel::Debug;
  InitAPI(options);
  {
    const auto executor = Aws::MakeUnique<PooledThreadExecutor>(LOG_TAG, std::thread::hardware_concurrency());
    TransferManagerConfiguration configuration{executor.get()};
    configuration.s3Client = Aws::MakeShared<S3Client>(LOG_TAG);
    configuration.transferInitiatedCallback = [](const TransferManager*, const std::shared_ptr<const TransferHandle>&) {
      std::cout << "started transfer\n";
    };

    configuration.errorCallback = [](const TransferManager*, const std::shared_ptr<const TransferHandle>&, const Aws::Client::AWSError<Aws::S3::S3Errors>& error) {
      std::cout << "error: " << error.GetMessage() << "\n";
    };

    configuration.transferStatusUpdatedCallback = [](const TransferManager*, const std::shared_ptr<const TransferHandle>& handle) {
      if (handle->GetStatus() == TransferStatus::COMPLETED) {
        std::cout << "completed transfer\n";
      } else if (handle->GetStatus() == TransferStatus::FAILED) {
        std::cout << "failed\n";
      }
    };

    const auto transferManager = TransferManager::Create(configuration);

    const auto handle = transferManager->DownloadFile(BUCKET_NAME, KEY_NAME, KEY_NAME);

    transferManager->WaitUntilAllFinished();
  }
  ShutdownAPI(options);
  return 0;
}