objectuploader.h

 
#ifndef IMAGE_UPLOADER_H
#define IMAGE_UPLOADER_H
 
#ifdef AWS
#include <aws/core/utils/threading/Executor.h>
#include <aws/transfer/TransferManager.h>
#include <aws/core/auth/AWSCredentials.h>
#endif
 
#include <chrono>
#include <mutex>
#include <atomic>
 
#include "http_uploader.h"
 
typedef struct {
#ifdef AWS
    Aws::Auth::AWSCredentials credentials;  
    Aws::String region;                    
#else
    int dummy;
#endif  
}s3_client_config_t;
 
class ImageUploader {
public:
  ImageUploader(int uploadtype, const std::string& endpointUrl, const std::string& token,
                s3_client_config_t &s3_client_config);
  bool startUploadThread(const std::string& imagePath, const std::string& bucketName,
                         const std::string& objectKey, const std::chrono::milliseconds& interval);
 
  void stopUploadThread();
 
private:
  int type;
    s3_client_config_t s3_client_config_;
  std::atomic<bool> stopFlag_;             
  std::mutex uploadMutex_;                 
    HttpUploader * _HttpUploader;
  // Function to run the upload thread (implementation in ImageUploader.cpp)
  void uploadThread(const std::string& imagePath, const std::string& bucketName,
                    const std::string& objectKey, const std::chrono::milliseconds& interval);
};
 
#endif // IMAGE_UPLOADER_H