Inheritance diagram for audacity::cloud::audiocom::sync::DataUploader::UploadOperation:

Collaboration diagram for audacity::cloud::audiocom::sync::DataUploader::UploadOperation:

Public Member Functions
	UploadOperation (DataUploader &uploader, CancellationContextPtr cancellationContex, const UploadUrls &target, UploadData data, std::string mimeType, std::function< void(ResponseResult)> callback, std::function< void(double)> progressCallback)

void	PerformUpload (int retriesLeft)

void	ConfirmUpload (int retriesLeft)

void	FailUpload (int retriesLeft)

void	CleanUp ()

Public Attributes
DataUploader &	Uploader

UploadUrls	Target

std::function< void(ResponseResult)>	Callback

std::function< void(double)>	ProgressCallback

std::string	MimeType

UploadData	Data

ResponseResult	CurrentResult

CancellationContextPtr	CancelContext

std::atomic< bool >	UploadFailed { false }

Detailed Description

Definition at line 36 of file DataUploader.cpp.

Constructor & Destructor Documentation

◆ UploadOperation()

audacity::cloud::audiocom::sync::DataUploader::UploadOperation::UploadOperation	(	DataUploader &	uploader,
		CancellationContextPtr	cancellationContex,
		const UploadUrls &	target,
		UploadData	data,
		std::string	mimeType,
		std::function< void(ResponseResult)>	callback,
		std::function< void(double)>	progressCallback
	)

inline

Definition at line 52 of file DataUploader.cpp.

       : Uploader { uploader }
       , Target { target }
       , Callback { std::move(callback) }
       , ProgressCallback { std::move(progressCallback) }
       , MimeType { std::move(mimeType) }
       , Data { std::move(data) }
       , CancelContext { std::move(cancellationContex) }
   {
   }

Member Function Documentation

◆ CleanUp()

void audacity::cloud::audiocom::sync::DataUploader::UploadOperation::CleanUp ( )

inline

Definition at line 199 of file DataUploader.cpp.

   {
      BasicUI::CallAfter([this]() { Uploader.RemoveResponse(*this); });
   }

References BasicUI::CallAfter(), audacity::cloud::audiocom::sync::DataUploader::RemoveResponse(), and Uploader.

Referenced by ConfirmUpload(), and FailUpload().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ConfirmUpload()

void audacity::cloud::audiocom::sync::DataUploader::UploadOperation::ConfirmUpload ( int retriesLeft )

inline

Definition at line 128 of file DataUploader.cpp.

   {
      Data = {};
      Request request { Target.SuccessUrl };
 
      auto networkResponse =
         NetworkManager::GetInstance().doPost(request, nullptr, 0);
      CancelContext->OnCancelled(networkResponse);
 
      networkResponse->setRequestFinishedCallback(
         [this, retriesLeft, networkResponse, operation = weak_from_this()](auto)
         {
            auto strongThis = operation.lock();
            if (!strongThis)
               return;
 
            CurrentResult = GetResponseResult(*networkResponse, false);
 
            if (CurrentResult.Code == SyncResultCode::Success)
            {
               Callback(ResponseResult { SyncResultCode::Success, {} });
               CleanUp();
            }
            else if (
               CurrentResult.Code == SyncResultCode::ConnectionFailed &&
               retriesLeft > 0)
            {
               ConfirmUpload(retriesLeft - 1);
            }
            else
            {
               FailUpload(RetriesCount);
            }
         });
   }

References Callback, CancelContext, CleanUp(), audacity::cloud::audiocom::ResponseResult::Code, ConfirmUpload(), audacity::cloud::audiocom::ConnectionFailed, CurrentResult, Data, audacity::network_manager::NetworkManager::doPost(), FailUpload(), audacity::network_manager::NetworkManager::GetInstance(), audacity::cloud::audiocom::GetResponseResult(), audacity::cloud::audiocom::sync::RetriesCount, audacity::cloud::audiocom::Success, audacity::cloud::audiocom::sync::UploadUrls::SuccessUrl, and Target.

Referenced by ConfirmUpload(), and PerformUpload().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ FailUpload()

void audacity::cloud::audiocom::sync::DataUploader::UploadOperation::FailUpload ( int retriesLeft )

inline

Definition at line 164 of file DataUploader.cpp.

   {
      if (!UploadFailed.exchange(true))
      {
         Data = {};
         Callback(CurrentResult);
      }
 
      Request request { Target.FailUrl };
 
      auto networkResponse =
         NetworkManager::GetInstance().doPost(request, nullptr, 0);
      CancelContext->OnCancelled(networkResponse);
 
      networkResponse->setRequestFinishedCallback(
         [this, retriesLeft, networkResponse, operation = weak_from_this()](auto)
         {
            auto strongThis = operation.lock();
            if (!strongThis)
               return;
 
            const auto result = GetResponseResult(*networkResponse, false);
 
            if (
               result.Code == SyncResultCode::ConnectionFailed &&
               retriesLeft > 0)
               FailUpload(retriesLeft - 1);
            else
               CleanUp();
 
            // Ignore other errors, server will collect garbage
            // and delete the file eventually
         });
   }

References Callback, CancelContext, CleanUp(), audacity::cloud::audiocom::ConnectionFailed, CurrentResult, Data, audacity::network_manager::NetworkManager::doPost(), FailUpload(), audacity::cloud::audiocom::sync::UploadUrls::FailUrl, audacity::network_manager::NetworkManager::GetInstance(), audacity::cloud::audiocom::GetResponseResult(), Target, and UploadFailed.

Referenced by ConfirmUpload(), FailUpload(), and PerformUpload().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ PerformUpload()

void audacity::cloud::audiocom::sync::DataUploader::UploadOperation::PerformUpload ( int retriesLeft )

inline

Definition at line 67 of file DataUploader.cpp.

   {
      Request request { Target.UploadUrl };
      request.setHeader(common_headers::ContentType, MimeType);
 
      ResponsePtr networkResponse;
 
      if (std::holds_alternative<std::vector<uint8_t>>(Data))
      {
         auto data = *std::get_if<std::vector<uint8_t>>(&Data);
 
         networkResponse = NetworkManager::GetInstance().doPut(
            request, data.data(), data.size());
      }
      else
      {
         auto filePath = *std::get_if<std::string>(&Data);
 
         networkResponse = NetworkManager::GetInstance().doPut(
            request, CreateRequestPayloadStream(filePath));
      }
 
      CancelContext->OnCancelled(networkResponse);
 
      networkResponse->setRequestFinishedCallback(
         [this, retriesLeft, networkResponse, operation = weak_from_this()](auto)
         {
            auto strongThis = operation.lock();
            if (!strongThis)
               return;
 
            CurrentResult = GetResponseResult(*networkResponse, false);
 
            if (CurrentResult.Code == SyncResultCode::Success)
               ConfirmUpload(RetriesCount);
            else if (
               CurrentResult.Code == SyncResultCode::ConnectionFailed &&
               retriesLeft > 0)
               PerformUpload(retriesLeft - 1);
            else
               FailUpload(RetriesCount);
         });
 
      networkResponse->setUploadProgressCallback(
         [this, operation = weak_from_this()](
            int64_t current, int64_t total)
         {
            auto strongThis = operation.lock();
            if (!strongThis)
               return;
 
            if (total <= 0)
            {
               total   = 1;
               current = 0;
            }
 
            ProgressCallback(static_cast<double>(current) / total);
         });
   }