Method SyncProject

libraries/lib-cloud-audiocom/CloudSyncService.cpp:384–451

}

CloudSyncService::SyncFuture CloudSyncService::SyncProject(
   AudacityProject& project, const std::string& path, bool forceSync,
   sync::ProgressCallback callback)
{
   ASSERT_MAIN_THREAD();

   // Reset promise
   mSyncPromise = {};

   if (mSyncInProcess.exchange(true))
   {
      CompleteSync({ sync::ProjectSyncResult::StatusCode::Blocked });
      return mSyncPromise.get_future();
   }

   if (!callback)
      mProgressCallback = [](auto...) { return true; };
   else
      mProgressCallback = std::move(callback);

   auto& cloudDatabase = sync::CloudProjectsDatabase::Get();

   auto projectInfo = cloudDatabase.GetProjectDataForPath(path);

   if (!projectInfo)
   {
      // We assume, that the project is local
      CompleteSync(path);
      return mSyncPromise.get_future();
   }

   GetProjectInfo(
      GetOAuthService(), GetServiceConfig(), projectInfo->ProjectId,
      [projectInfo = *projectInfo, &project, path,
       mode        = forceSync ? SyncMode::ForceOverwrite : SyncMode::Normal,
       this](sync::ProjectInfo remoteInfo, ResponseResult result)
      {
         if (result.Code != SyncResultCode::Success)
         {
            FailSync(std::move(result));
            return;
         }

         // Do not perform the snapshot request if the project is up to date
         if (remoteInfo.HeadSnapshot.Id == projectInfo.SnapshotId)
         {
            CompleteSync({ sync::ProjectSyncResult::StatusCode::Succeeded });
            return;
         }

         const auto snapshotId = remoteInfo.HeadSnapshot.Synced > 0 ?
                                    remoteInfo.HeadSnapshot.Id :
                                    remoteInfo.LastSyncedSnapshotId;

         GetSnapshotInfo(
            GetOAuthService(), GetServiceConfig(), remoteInfo.Id, snapshotId,
            [this, &project, mode,
             remoteInfo](sync::SnapshotInfo snapshotInfo, ResponseResult result)