audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp} Namespace Reference

Functions
std::mutex &	GetResponsesMutex ()
std::vector< std::shared_ptr< audacity::network_manager::IResponse > > &	GetPendingRequests ()
void	RemovePendingRequest (audacity::network_manager::IResponse *request)
void	PerformProjectGetRequest (OAuthService &oAuthService, std::string url, std::function< void(ResponseResult)> dataCallback)
void	GetProjectInfo (OAuthService &oAuthService, const ServiceConfig &serviceConfig, std::string projectId, std::function< void(sync::ProjectInfo, ResponseResult)> callback)
void	GetSnapshotInfo (OAuthService &oAuthService, const ServiceConfig &serviceConfig, std::string projectId, std::string snapshotId, std::function< void(sync::SnapshotInfo, ResponseResult result)> callback)
void	GetSnapshotInfo (OAuthService &oAuthService, const ServiceConfig &serviceConfig, std::string projectId, std::string snapshotId, std::function< void(sync::ProjectInfo, sync::SnapshotInfo, ResponseResult result)> callback)
bool	HasAutosave (const std::string &path)
bool	DropAutosave (const std::string &path)

Function Documentation

DropAutosave()

bool audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp}::DropAutosave

(

const std::string &

path

)

Definition at line 257 of file CloudSyncService.cpp.

{
   auto connection =
      sqlite::Connection::Open(path, sqlite::OpenMode::ReadWrite);
 
   if (!connection)
      return false;
 
   if (!connection->CheckTableExists("autosave"))
      return false;
 
   auto statement = connection->CreateStatement("DELETE FROM autosave");
 
   if (!statement)
      return false;
 
   auto result = statement->Prepare().Run();
 
   return result.IsOk();
}

Referenced by audacity::cloud::audiocom::CloudSyncService::SyncCloudSnapshot().

Here is the caller graph for this function:

GetPendingRequests()

std::vector< std::shared_ptr< audacity::network_manager::IResponse > > & audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp}::GetPendingRequests

(

)

Definition at line 53 of file CloudSyncService.cpp.

{
   static std::vector<std::shared_ptr<audacity::network_manager::IResponse>>
      requests;
 
   return requests;
}

Referenced by PerformProjectGetRequest(), and RemovePendingRequest().

Here is the caller graph for this function:

GetProjectInfo()

void audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp}::GetProjectInfo	(	OAuthService &	oAuthService,
		const ServiceConfig &	serviceConfig,
		std::string	projectId,
		std::function< void(sync::ProjectInfo, ResponseResult)>	callback
	)

Definition at line 117 of file CloudSyncService.cpp.

{
   assert(callback);
 
   PerformProjectGetRequest(
      oAuthService, serviceConfig.GetProjectInfoUrl(projectId),
      [callback = std::move(callback)](ResponseResult result)
      {
         if (result.Code != SyncResultCode::Success)
         {
            callback(sync::ProjectInfo {}, std::move(result));
            return;
         }
 
         auto projectInfo = sync::DeserializeProjectInfo(result.Content);
 
         if (!projectInfo)
         {
            callback(
               {}, { SyncResultCode::UnexpectedResponse,
                     std::move(result.Content) });
            return;
         }
 
         callback(std::move(*projectInfo), std::move(result));
      });
}

References audacity::cloud::audiocom::ResponseResult::Content, audacity::cloud::audiocom::sync::DeserializeProjectInfo(), audacity::cloud::audiocom::ServiceConfig::GetProjectInfoUrl(), PerformProjectGetRequest(), and audacity::cloud::audiocom::UnexpectedResponse.

Referenced by audacity::cloud::audiocom::CloudSyncService::GetHeadSnapshotID(), GetSnapshotInfo(), and audacity::cloud::audiocom::CloudSyncService::SyncProject().

Here is the call graph for this function:

Here is the caller graph for this function:

GetResponsesMutex()

std::mutex & audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp}::GetResponsesMutex

(

)

Definition at line 46 of file CloudSyncService.cpp.

{
   static std::mutex mutex;
   return mutex;
}

Referenced by PerformProjectGetRequest(), and RemovePendingRequest().

Here is the caller graph for this function:

GetSnapshotInfo() [1/2]

void audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp}::GetSnapshotInfo	(	OAuthService &	oAuthService,
		const ServiceConfig &	serviceConfig,
		std::string	projectId,
		std::string	snapshotId,
		std::function< void(sync::ProjectInfo, sync::SnapshotInfo, ResponseResult result)>	callback
	)

Definition at line 179 of file CloudSyncService.cpp.

{
   assert(callback);
 
   GetProjectInfo(
      oAuthService, serviceConfig, projectId,
      [callback   = std::move(callback), projectId,
       snapshotId = std::move(snapshotId), &oAuthService,
       &serviceConfig](sync::ProjectInfo projectInfo, ResponseResult result)
      {
         if (result.Code != SyncResultCode::Success)
         {
            callback({}, {}, std::move(result));
            return;
         }
 
         const auto id = !snapshotId.empty() ?
                            snapshotId :
                            (projectInfo.HeadSnapshot.Synced > 0 ?
                                projectInfo.HeadSnapshot.Id :
                                projectInfo.LastSyncedSnapshotId);
 
         if (id.empty())
         {
            callback(
               std::move(projectInfo), sync::SnapshotInfo {},
               { SyncResultCode::Success });
            return;
         }
 
         GetSnapshotInfo(
            oAuthService, serviceConfig, projectId, id,
            [callback    = std::move(callback),
             projectInfo = std::move(projectInfo)](
               sync::SnapshotInfo snapshotInfo, ResponseResult result)
            {
               callback(
                  std::move(projectInfo), std::move(snapshotInfo),
                  std::move(result));
            });
      });
}

References audacity::cloud::audiocom::ResponseResult::Code, GetProjectInfo(), GetSnapshotInfo(), audacity::cloud::audiocom::sync::ProjectInfo::HeadSnapshot, audacity::cloud::audiocom::sync::SnapshotInfo::Id, audacity::cloud::audiocom::sync::ProjectInfo::LastSyncedSnapshotId, and audacity::cloud::audiocom::sync::SnapshotInfo::Synced.

Referenced by GetSnapshotInfo(), and audacity::cloud::audiocom::CloudSyncService::OpenFromCloud().

Here is the call graph for this function:

Here is the caller graph for this function:

GetSnapshotInfo() [2/2]

void audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp}::GetSnapshotInfo	(	OAuthService &	oAuthService,
		const ServiceConfig &	serviceConfig,
		std::string	projectId,
		std::string	snapshotId,
		std::function< void(sync::SnapshotInfo, ResponseResult result)>	callback
	)

Definition at line 148 of file CloudSyncService.cpp.

{
   assert(callback);
 
   PerformProjectGetRequest(
      oAuthService, serviceConfig.GetSnapshotInfoUrl(projectId, snapshotId),
      [callback = std::move(callback)](ResponseResult result)
      {
         if (result.Code != SyncResultCode::Success)
         {
            callback({}, std::move(result));
            return;
         }
 
         auto snapshotInfo = sync::DeserializeSnapshotInfo(result.Content);
 
         if (!snapshotInfo)
         {
            callback(
               {}, { SyncResultCode::UnexpectedResponse,
                     std::move(result.Content) });
            return;
         }
 
         callback(std::move(*snapshotInfo), std::move(result));
      });
}

References audacity::cloud::audiocom::ResponseResult::Content, audacity::cloud::audiocom::sync::DeserializeSnapshotInfo(), audacity::cloud::audiocom::ServiceConfig::GetSnapshotInfoUrl(), PerformProjectGetRequest(), and audacity::cloud::audiocom::UnexpectedResponse.

Here is the call graph for this function:

HasAutosave()

bool audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp}::HasAutosave

(

const std::string &

path

)

Definition at line 227 of file CloudSyncService.cpp.

{
   auto connection = sqlite::Connection::Open(path, sqlite::OpenMode::ReadOnly);
 
   if (!connection)
      return false;
 
   if (!connection->CheckTableExists("autosave"))
      return false;
 
   auto statement =
      connection->CreateStatement("SELECT COUNT(1) FROM autosave");
 
   if (!statement)
      return false;
 
   auto result = statement->Prepare().Run();
 
   if (!result.IsOk())
      return false;
 
   for (const auto& row : result)
   {
      if (row.GetOr(0, 0) > 0)
         return true;
   }
 
   return false;
}

Referenced by audacity::cloud::audiocom::CloudSyncService::SyncCloudSnapshot().

Here is the caller graph for this function:

PerformProjectGetRequest()

void audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp}::PerformProjectGetRequest	(	OAuthService &	oAuthService,
		std::string	url,
		std::function< void(ResponseResult)>	dataCallback
	)

Definition at line 74 of file CloudSyncService.cpp.

{
   assert(oAuthService.HasAccessToken());
 
   if (!oAuthService.HasAccessToken())
   {
      dataCallback({ SyncResultCode::Unauthorized });
      return;
   }
 
   using namespace audacity::network_manager;
 
   auto request = Request(std::move(url));
 
   request.setHeader(
      common_headers::ContentType, common_content_types::ApplicationJson);
 
   request.setHeader(
      common_headers::Accept, common_content_types::ApplicationJson);
 
   SetCommonHeaders(request);
 
   auto response = NetworkManager::GetInstance().doGet(request);
 
   response->setRequestFinishedCallback(
      [dataCallback = std::move(dataCallback)](auto response)
      {
         BasicUI::CallAfter(
            [dataCallback = std::move(dataCallback), response]
            {
               auto removeRequest =
                  finally([response] { RemovePendingRequest(response); });
 
               dataCallback(GetResponseResult(*response, true));
            });
      });
 
   std::lock_guard lock { GetResponsesMutex() };
   GetPendingRequests().emplace_back(std::move(response));
}

References audacity::network_manager::common_headers::Accept, audacity::network_manager::common_content_types::ApplicationJson, BasicUI::CallAfter(), audacity::network_manager::common_headers::ContentType, audacity::network_manager::NetworkManager::doGet(), audacity::network_manager::NetworkManager::GetInstance(), GetPendingRequests(), audacity::cloud::audiocom::GetResponseResult(), GetResponsesMutex(), audacity::cloud::audiocom::OAuthService::HasAccessToken(), RemovePendingRequest(), audacity::cloud::audiocom::SetCommonHeaders(), and audacity::cloud::audiocom::Unauthorized.

Referenced by GetProjectInfo(), and GetSnapshotInfo().

Here is the call graph for this function:

Here is the caller graph for this function:

RemovePendingRequest()

void audacity::cloud::audiocom::anonymous_namespace{CloudSyncService.cpp}::RemovePendingRequest

(

audacity::network_manager::IResponse *

request

)

Definition at line 61 of file CloudSyncService.cpp.

{
   std::lock_guard lock { GetResponsesMutex() };
 
   auto& requests = GetPendingRequests();
 
   requests.erase(
      std::remove_if(
         requests.begin(), requests.end(),
         [request](const auto& r) { return r.get() == request; }),
      requests.end());
}

References GetPendingRequests(), and GetResponsesMutex().

Referenced by PerformProjectGetRequest().

Here is the call graph for this function:

Here is the caller graph for this function: