cloud::audiocom::anonymous_namespace{UploadService.cpp} Namespace Reference

Classes
struct	AudiocomUploadOperation

Functions
std::string_view	DeduceMimeType (const wxString &ext)
std::string	GetUploadRequestPayload (const wxString &filePath, const wxString &projectName, bool isPublic)
std::string	GetProgressPayload (uint64_t current, uint64_t total)
UploadFailedPayload	ParseUploadFailedMessage (const std::string &payloadText)

Variables
const auto	tempChangedSubscription

Function Documentation

DeduceMimeType()

std::string_view cloud::audiocom::anonymous_namespace{UploadService.cpp}::DeduceMimeType

(

const wxString &

ext

)

Definition at line 42 of file UploadService.cpp.

{
   if (ext == "wv")
      return "audio/x-wavpack";
   else if (ext == "flac")
      return "audio/x-flac";
   else if (ext == "mp3")
      return "audio/mpeg";
   else
      return "audio/x-wav";
}

Referenced by GetUploadRequestPayload(), and cloud::audiocom::anonymous_namespace{UploadService.cpp}::AudiocomUploadOperation::HandleUploadPolicy().

Here is the caller graph for this function:

GetProgressPayload()

std::string cloud::audiocom::anonymous_namespace{UploadService.cpp}::GetProgressPayload	(	uint64_t	current,
		uint64_t	total
	)

Definition at line 103 of file UploadService.cpp.

{
   rapidjson::Document document;
   document.SetObject();
 
   document.AddMember(
      "progress", rapidjson::Value(current / static_cast<double>(total) * 100.0),
      document.GetAllocator());
 
   rapidjson::StringBuffer buffer;
   rapidjson::Writer<rapidjson::StringBuffer> writer(buffer);
   document.Accept(writer);
 
   return std::string(buffer.GetString());
}

Referenced by cloud::audiocom::anonymous_namespace{UploadService.cpp}::AudiocomUploadOperation::HandleUploadProgress().

Here is the caller graph for this function:

GetUploadRequestPayload()

std::string cloud::audiocom::anonymous_namespace{UploadService.cpp}::GetUploadRequestPayload	(	const wxString &	filePath,
		const wxString &	projectName,
		bool	isPublic
	)

Definition at line 54 of file UploadService.cpp.

{
   rapidjson::Document document;
   document.SetObject();
 
   const wxFileName fileName(filePath);
   const auto mimeType = DeduceMimeType(fileName.GetExt());
 
   document.AddMember(
      "mime",
      rapidjson::Value(
         mimeType.data(), mimeType.length(), document.GetAllocator()),
      document.GetAllocator());
 
   const auto downloadMime = GetServiceConfig().GetDownloadMime();
 
   if (!downloadMime.empty())
   {
      document.AddMember(
         "download_mime",
         rapidjson::Value(
            downloadMime.data(), downloadMime.length(),
            document.GetAllocator()),
         document.GetAllocator());
   }
 
   const auto name = audacity::ToUTF8(projectName.empty() ? fileName.GetFullName() : projectName);
 
   document.AddMember(
      "name",
      rapidjson::Value(name.data(), name.length(), document.GetAllocator()),
      document.GetAllocator());
 
   document.AddMember(
      "size",
      rapidjson::Value(static_cast<int64_t>(fileName.GetSize().GetValue())),
      document.GetAllocator());
 
   document.AddMember(
      "public", rapidjson::Value(isPublic), document.GetAllocator());
 
   rapidjson::StringBuffer buffer;
   rapidjson::Writer<rapidjson::StringBuffer> writer(buffer);
   document.Accept(writer);
 
   return std::string(buffer.GetString());
}

References DeduceMimeType(), cloud::audiocom::ServiceConfig::GetDownloadMime(), cloud::audiocom::GetServiceConfig(), name, and audacity::ToUTF8().

Referenced by cloud::audiocom::anonymous_namespace{UploadService.cpp}::AudiocomUploadOperation::InitiateUpload().

Here is the call graph for this function:

Here is the caller graph for this function:

ParseUploadFailedMessage()

UploadFailedPayload cloud::audiocom::anonymous_namespace{UploadService.cpp}::ParseUploadFailedMessage

(

const std::string &

payloadText

)

Definition at line 119 of file UploadService.cpp.

{
   rapidjson::StringStream stream(payloadText.c_str());
   rapidjson::Document document;
 
   document.ParseStream(stream);
 
   if (!document.IsObject())
   {
      // This is unexpected, just return an empty object
      assert(document.IsObject());
      return {};
   }
 
   UploadFailedPayload payload;
 
   auto readInt = [&document](const char* name) {
      return document.HasMember(name) && document[name].IsInt() ?
                document[name].GetInt() :
                0;
   };
 
   auto readString = [&document](const char* name) -> const char*
   {
      return document.HasMember(name) && document[name].IsString() ?
                document[name].GetString() :
                "";
   };
 
   payload.code = readInt("code");
   payload.status = readInt("status");
 
   payload.name = readString("name");
   payload.message = readString("message");
 
   if (document.HasMember("errors") && document["errors"].IsObject())
   {
      for (auto& err : document["errors"].GetObject ())
      {
         if (!err.value.IsString())
            continue;
         
         payload.additionalErrors.emplace_back(
            err.name.GetString(), err.value.GetString());
      }
   }
 
   return payload;
}

References cloud::audiocom::UploadFailedPayload::additionalErrors, cloud::audiocom::UploadFailedPayload::code, cloud::audiocom::UploadFailedPayload::message, cloud::audiocom::UploadFailedPayload::name, name, and cloud::audiocom::UploadFailedPayload::status.

Referenced by cloud::audiocom::anonymous_namespace{UploadService.cpp}::AudiocomUploadOperation::FailPromise().

Here is the caller graph for this function:

Variable Documentation

tempChangedSubscription

const auto cloud::audiocom::anonymous_namespace{UploadService.cpp}::tempChangedSubscription

Initial value:

= TempDirectory::GetTempPathObserver().Subscribe([](const auto&) {
   const auto tempPath = GetUploadTempPath();
 
   if (!wxDirExists(tempPath))
      return;
 
   wxArrayString files;
 
   wxDir::GetAllFiles(tempPath, &files, {}, wxDIR_FILES);
 
   for (const auto& file : files)
      wxRemoveFile(file);
 
   return;
})

Definition at line 641 of file UploadService.cpp.