#include <CloudProjectsDatabase.h>

Collaboration diagram for audacity::cloud::audiocom::sync::CloudProjectsDatabase:

Public Member Functions
sqlite::SafeConnection::Lock	GetConnection ()

const sqlite::SafeConnection::Lock	GetConnection () const

std::optional< DBProjectData >	GetProjectData (std::string_view projectId) const

std::optional< DBProjectData >	GetProjectDataForPath (const std::string &projectPath) const

std::vector< DBProjectData >	GetCloudProjects () const

void	DeleteProject (std::string_view projectId)

bool	MarkProjectAsSynced (std::string_view projectId, std::string_view snapshotId)

void	UpdateProjectBlockList (std::string_view projectId, const SampleBlockIDSet &blockSet)

std::optional< std::string >	GetBlockHash (std::string_view projectId, int64_t blockId) const

void	UpdateBlockHashes (std::string_view projectId, const std::vector< std::pair< int64_t, std::string > > &hashes)

bool	UpdateProjectData (const DBProjectData &projectData)

bool	IsFirstSyncDialogShown (std::string_view projectId) const

void	SetFirstSyncDialogShown (std::string_view projectId, bool shown=true)

std::string	GetProjectUserSlug (std::string_view projectId)

void	SetProjectUserSlug (std::string_view projectId, std::string_view slug)

bool	IsProjectBlockLocked (std::string_view projectId, int64_t blockId) const

void	AddPendingSnapshot (const PendingSnapshotData &snapshotData)

void	RemovePendingSnapshot (std::string_view projectId, std::string_view snapshotId)

std::vector< PendingSnapshotData >	GetPendingSnapshots (std::string_view projectId) const

void	AddPendingProjectBlob (const PendingProjectBlobData &blobData)

void	RemovePendingProjectBlob (std::string_view projectId, std::string_view snapshotId)

std::optional< PendingProjectBlobData >	GetPendingProjectBlob (std::string_view projectId, std::string_view snapshotId) const

void	AddPendingProjectBlocks (const std::vector< PendingProjectBlockData > &blockData)

void	RemovePendingProjectBlock (std::string_view projectId, int64_t blockId)

void	RemovePendingProjectBlocks (std::string_view projectId, std::string_view snapshotId)

std::vector< PendingProjectBlockData >	GetPendingProjectBlocks (std::string_view projectId, std::string_view snapshotId)

Static Public Member Functions
static CloudProjectsDatabase &	Get ()

Private Member Functions
	CloudProjectsDatabase ()=default

	~CloudProjectsDatabase ()=default

std::optional< DBProjectData >	DoGetProjectData (const sqlite::Row &result) const

std::optional< DBProjectData >	DoGetProjectData (sqlite::RunResult result) const

bool	OpenConnection ()

bool	RunMigrations ()

bool	DeleteProject (sqlite::SafeConnection::Lock &connection, std::string_view projectId)

Private Attributes
std::mutex	mConnectionMutex

std::shared_ptr< sqlite::SafeConnection >	mConnection

Detailed Description

Definition at line 78 of file CloudProjectsDatabase.h.

Constructor & Destructor Documentation

◆ CloudProjectsDatabase()

audacity::cloud::audiocom::sync::CloudProjectsDatabase::CloudProjectsDatabase ( )

privatedefault

◆ ~CloudProjectsDatabase()

audacity::cloud::audiocom::sync::CloudProjectsDatabase::~CloudProjectsDatabase ( )

privatedefault

Member Function Documentation

◆ AddPendingProjectBlob()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::AddPendingProjectBlob ( const PendingProjectBlobData & blobData )

Definition at line 561 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto statement = connection->CreateStatement(
      "INSERT OR REPLACE INTO pending_project_blobs (project_id, snapshot_id, upload_url, confirm_url, fail_url, blob) VALUES (?, ?, ?, ?, ?, ?)");
 
   if (!statement)
      return;
 
   statement->Prepare()
      .Bind(1, blobData.ProjectId)
      .Bind(2, blobData.SnapshotId)
      .Bind(3, blobData.UploadUrl)
      .Bind(4, blobData.ConfirmUrl)
      .Bind(5, blobData.FailUrl)
      .Bind(6, blobData.BlobData.data(), blobData.BlobData.size(), false)
      .Run();
}

References audacity::cloud::audiocom::sync::PendingProjectBlobData::BlobData, audacity::cloud::audiocom::sync::PendingProjectBlobData::ConfirmUrl, audacity::cloud::audiocom::sync::PendingProjectBlobData::FailUrl, GetConnection(), audacity::cloud::audiocom::sync::PendingProjectBlobData::ProjectId, audacity::cloud::audiocom::sync::PendingProjectBlobData::SnapshotId, and audacity::cloud::audiocom::sync::PendingProjectBlobData::UploadUrl.

Referenced by audacity::cloud::audiocom::sync::LocalProjectSnapshot::StorePendingSnapshot().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddPendingProjectBlocks()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::AddPendingProjectBlocks ( const std::vector< PendingProjectBlockData > & blockData )

Definition at line 650 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto tx = connection->BeginTransaction("AddPendingProjectBlocks");
 
   auto statement = connection->CreateStatement(
      "INSERT OR REPLACE INTO pending_project_blocks (project_id, snapshot_id, upload_url, confirm_url, fail_url, block_id, block_sample_format, block_hash) VALUES (?, ?, ?, ?, ?, ?, ?, ?)");
 
   if (!statement)
      return;
 
   for (const auto& data : blockData)
      statement->Prepare()
         .Bind(1, data.ProjectId)
         .Bind(2, data.SnapshotId)
         .Bind(3, data.UploadUrl)
         .Bind(4, data.ConfirmUrl)
         .Bind(5, data.FailUrl)
         .Bind(6, data.BlockId)
         .Bind(7, data.BlockSampleFormat)
         .Bind(8, data.BlockHash)
         .Run();
 
   tx.Commit();
}

References GetConnection().

Referenced by audacity::cloud::audiocom::sync::LocalProjectSnapshot::StorePendingSnapshot().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ AddPendingSnapshot()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::AddPendingSnapshot ( const PendingSnapshotData & snapshotData )

Definition at line 473 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto statement = connection->CreateStatement(
      "INSERT OR REPLACE INTO pending_snapshots (project_id, snapshot_id, confirm_url) VALUES (?, ?, ?)");
 
   if (!statement)
      return;
 
   statement
      ->Prepare(
         snapshotData.ProjectId, snapshotData.SnapshotId,
         snapshotData.ConfirmUrl)
      .Run();
}

References audacity::cloud::audiocom::sync::PendingSnapshotData::ConfirmUrl, GetConnection(), audacity::cloud::audiocom::sync::PendingSnapshotData::ProjectId, and audacity::cloud::audiocom::sync::PendingSnapshotData::SnapshotId.

Referenced by audacity::cloud::audiocom::sync::LocalProjectSnapshot::StorePendingSnapshot().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DeleteProject() [1/2]

bool audacity::cloud::audiocom::sync::CloudProjectsDatabase::DeleteProject	(	sqlite::SafeConnection::Lock &	connection,
		std::string_view	projectId
	)

private

Definition at line 896 of file CloudProjectsDatabase.cpp.

{
   static const char* queries[] = {
      "DELETE FROM projects WHERE project_id = ?",
      "DELETE FROM block_hashes WHERE project_id = ?",
      "DELETE FROM pending_snapshots WHERE project_id = ?",
      "DELETE FROM pending_project_blobs WHERE project_id = ?",
      "DELETE FROM pending_project_blocks WHERE project_id = ?",
      "DELETE FROM project_users WHERE project_id = ?",
   };
 
   for (auto query : queries)
   {
      auto statement = connection->CreateStatement(query);
 
      if (!statement)
         return false;
 
      if (!statement->Prepare(projectId).Run().IsOk())
         return false;
   }
 
   return true;
}

References audacity::sqlite::Connection::CreateStatement().

Here is the call graph for this function:

◆ DeleteProject() [2/2]

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::DeleteProject ( std::string_view projectId )

Definition at line 195 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto tx = connection->BeginTransaction("DeleteProject");
   if (DeleteProject(connection, projectId))
      tx.Commit();
}

Referenced by UpdateProjectData().

Here is the caller graph for this function:

◆ DoGetProjectData() [1/2]

std::optional< DBProjectData > audacity::cloud::audiocom::sync::CloudProjectsDatabase::DoGetProjectData ( const sqlite::Row & result ) const

private

Definition at line 769 of file CloudProjectsDatabase.cpp.

{
   DBProjectData data;
 
   if (!row.Get(0, data.ProjectId))
      return {};
 
   if (!row.Get(1, data.SnapshotId))
      return {};
 
   if (!row.Get(2, data.SavesCount))
      return {};
 
   if (!row.Get(3, data.LastAudioPreview))
      return {};
 
   if (!row.Get(4, data.LocalPath))
      return {};
 
   if (!row.Get(5, data.LastModified))
      return {};
 
   if (!row.Get(6, data.LastRead))
      return {};
 
   int status;
   if (!row.Get(7, status))
      return {};
 
   data.SyncStatus = static_cast<DBProjectData::SyncStatusType>(status);
 
   if (!row.Get(8, data.FirstSyncDialogShown))
      return {};
 
   return data;
}

Referenced by GetProjectData(), and GetProjectDataForPath().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DoGetProjectData() [2/2]

std::optional< DBProjectData > audacity::cloud::audiocom::sync::CloudProjectsDatabase::DoGetProjectData ( sqlite::RunResult result ) const

private

Definition at line 807 of file CloudProjectsDatabase.cpp.

{
   for (auto row : result)
   {
      if (auto data = DoGetProjectData(row))
         return data;
   }
 
   return {};
}

◆ Get()

CloudProjectsDatabase & audacity::cloud::audiocom::sync::CloudProjectsDatabase::Get ( )

static

Definition at line 110 of file CloudProjectsDatabase.cpp.

{
   static CloudProjectsDatabase instance;
   return instance;
}

Here is the caller graph for this function:

◆ GetBlockHash()

std::optional< std::string > audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetBlockHash	(	std::string_view	projectId,
		int64_t	blockId
	)		const

Definition at line 257 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return {};
 
   auto statement = connection->CreateStatement(
      "SELECT hash FROM block_hashes WHERE project_id = ? AND block_id = ? LIMIT 1");
 
   if (!statement)
      return {};
 
   auto result = statement->Prepare(projectId, blockId).Run();
 
   for (auto row : result)
   {
      std::string hash;
 
      if (!row.Get(0, hash))
         return {};
 
      return hash;
   }
 
   return {};
}

References GetConnection().

Referenced by audacity::cloud::audiocom::sync::LocalProjectSnapshot::ProjectBlocksLock::GetHash().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetCloudProjects()

std::vector< DBProjectData > audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetCloudProjects ( ) const

Definition at line 167 of file CloudProjectsDatabase.cpp.

{
   std::vector<DBProjectData> result;
 
   auto connection = GetConnection();
 
   if (!connection)
      return result;
 
   auto statement = connection->CreateStatement(
      "SELECT project_id, snapshot_id, saves_count, last_audio_preview_save, local_path, last_modified, last_read, sync_status, synced_dialog_shown FROM projects");
 
   if (!statement)
      return result;
 
   auto runResult = statement->Prepare().Run();
 
   for (auto row : runResult)
   {
      auto data = DoGetProjectData(row);
 
      if (data)
         result.push_back(*data);
   }
 
   return result;
}

◆ GetConnection() [1/2]

sqlite::SafeConnection::Lock audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetConnection ( )

Definition at line 116 of file CloudProjectsDatabase.cpp.

{
   auto lock = std::lock_guard { mConnectionMutex };
 
   if (!mConnection)
      OpenConnection();
 
   // It is safe to call lock on a null connection
   return sqlite::SafeConnection::Lock { mConnection };
}

References mConnection, mConnectionMutex, and OpenConnection().

Referenced by AddPendingProjectBlob(), AddPendingProjectBlocks(), AddPendingSnapshot(), audacity::cloud::audiocom::sync::RemoteProjectSnapshot::AttachOriginalDB(), audacity::cloud::audiocom::sync::RemoteProjectSnapshot::CalculateKnownBlocks(), GetBlockHash(), GetConnection(), GetPendingProjectBlob(), GetPendingProjectBlocks(), GetPendingSnapshots(), GetProjectData(), GetProjectDataForPath(), GetProjectUserSlug(), IsProjectBlockLocked(), audacity::cloud::audiocom::sync::anonymous_namespace{RemoteProjectSnapshot.cpp}::ListAttachedDatabases(), MarkProjectAsSynced(), audacity::cloud::audiocom::sync::RemoteProjectSnapshot::RemoteProjectSnapshot(), RemovePendingProjectBlob(), RemovePendingProjectBlock(), RemovePendingProjectBlocks(), RemovePendingSnapshot(), SetProjectUserSlug(), audacity::cloud::audiocom::sync::RemoteProjectSnapshot::SetupBlocksCopy(), UpdateBlockHashes(), UpdateProjectBlockList(), UpdateProjectData(), and audacity::cloud::audiocom::sync::RemoteProjectSnapshot::~RemoteProjectSnapshot().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetConnection() [2/2]

const sqlite::SafeConnection::Lock audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetConnection ( ) const

Definition at line 127 of file CloudProjectsDatabase.cpp.

{
   return const_cast<CloudProjectsDatabase*>(this)->GetConnection();
}

References GetConnection().

Here is the call graph for this function:

◆ GetPendingProjectBlob()

std::optional< PendingProjectBlobData > audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetPendingProjectBlob	(	std::string_view	projectId,
		std::string_view	snapshotId
	)		const

Definition at line 603 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return {};
 
   auto statement = connection->CreateStatement(
      "SELECT project_id, snapshot_id, upload_url, confirm_url, fail_url, blob FROM pending_project_blobs WHERE project_id = ? AND snapshot_id = ?");
 
   if (!statement)
      return {};
 
   auto result = statement->Prepare(projectId, snapshotId).Run();
 
   for (auto row : result)
   {
      PendingProjectBlobData data;
 
      if (!row.Get(0, data.ProjectId))
         return {};
 
      if (!row.Get(1, data.SnapshotId))
         return {};
 
      if (!row.Get(2, data.UploadUrl))
         return {};
 
      if (!row.Get(3, data.ConfirmUrl))
         return {};
 
      if (!row.Get(4, data.FailUrl))
         return {};
 
      const auto size = row.GetColumnBytes(6);
      data.BlobData.resize(size);
 
      if (size != row.ReadData(6, data.BlobData.data(), size))
         return {};
 
      return data;
   }
 
   return {};
}

References audacity::cloud::audiocom::sync::PendingProjectBlobData::BlobData, audacity::cloud::audiocom::sync::PendingProjectBlobData::ConfirmUrl, audacity::cloud::audiocom::sync::PendingProjectBlobData::FailUrl, GetConnection(), audacity::cloud::audiocom::sync::PendingProjectBlobData::ProjectId, size, audacity::cloud::audiocom::sync::PendingProjectBlobData::SnapshotId, and audacity::cloud::audiocom::sync::PendingProjectBlobData::UploadUrl.

Here is the call graph for this function:

◆ GetPendingProjectBlocks()

std::vector< PendingProjectBlockData > audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetPendingProjectBlocks	(	std::string_view	projectId,
		std::string_view	snapshotId
	)

Definition at line 716 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return {};
 
   auto statement = connection->CreateStatement(
      "SELECT project_id, snapshot_id, upload_url, confirm_url, fail_url, block_id, block_sample_format, block_hash FROM pending_project_blocks WHERE project_id = ? AND snapshot_id = ?");
 
   if (!statement)
      return {};
 
   auto result = statement->Prepare(projectId, snapshotId).Run();
 
   std::vector<PendingProjectBlockData> blocks;
 
   for (auto row : result)
   {
      PendingProjectBlockData data;
 
      if (!row.Get(0, data.ProjectId))
         return {};
 
      if (!row.Get(1, data.SnapshotId))
         return {};
 
      if (!row.Get(2, data.UploadUrl))
         return {};
 
      if (!row.Get(3, data.ConfirmUrl))
         return {};
 
      if (!row.Get(4, data.FailUrl))
         return {};
 
      if (!row.Get(5, data.BlockId))
         return {};
 
      if (!row.Get(6, data.BlockSampleFormat))
         return {};
 
      if (!row.Get(7, data.BlockHash))
         return {};
 
      blocks.push_back(data);
   }
 
   return blocks;
}

Here is the call graph for this function:

◆ GetPendingSnapshots()

std::vector< PendingSnapshotData > audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetPendingSnapshots ( std::string_view projectId ) const

Definition at line 525 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return {};
 
   auto statement = connection->CreateStatement(
      "SELECT project_id, snapshot_id, confirm_url FROM pending_snapshots WHERE project_id = ?");
 
   if (!statement)
      return {};
 
   auto result = statement->Prepare(projectId).Run();
 
   std::vector<PendingSnapshotData> snapshots;
 
   for (auto row : result)
   {
      PendingSnapshotData data;
 
      if (!row.Get(0, data.ProjectId))
         return {};
 
      if (!row.Get(1, data.SnapshotId))
         return {};
 
      if (!row.Get(2, data.ConfirmUrl))
         return {};
 
      snapshots.push_back(data);
   }
 
   return snapshots;
}

References audacity::cloud::audiocom::sync::PendingSnapshotData::ConfirmUrl, GetConnection(), audacity::cloud::audiocom::sync::PendingSnapshotData::ProjectId, and audacity::cloud::audiocom::sync::PendingSnapshotData::SnapshotId.

Here is the call graph for this function:

◆ GetProjectData()

std::optional< DBProjectData > audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetProjectData ( std::string_view projectId ) const

Definition at line 133 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return {};
 
   auto statement = connection->CreateStatement(
      "SELECT project_id, snapshot_id, saves_count, last_audio_preview_save, local_path, last_modified, last_read, sync_status, synced_dialog_shown FROM projects WHERE project_id = ? LIMIT 1");
 
   if (!statement)
      return {};
 
   return DoGetProjectData(statement->Prepare(projectId).Run());
}

References DoGetProjectData(), and GetConnection().

Referenced by audacity::cloud::audiocom::sync::RemoteProjectSnapshot::AttachOriginalDB(), and audacity::cloud::audiocom::sync::RemoteProjectSnapshot::RemoteProjectSnapshot().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetProjectDataForPath()

std::optional< DBProjectData > audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetProjectDataForPath ( const std::string & projectPath ) const

Definition at line 149 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return {};
 
   auto statement = connection->CreateStatement(
      "SELECT project_id, snapshot_id, saves_count, last_audio_preview_save, local_path, last_modified, last_read, sync_status, synced_dialog_shown FROM projects WHERE local_path = ? LIMIT 1");
 
   if (!statement)
      return {};
 
   return DoGetProjectData(statement->Prepare(projectFilePath).Run());
}

References DoGetProjectData(), and GetConnection().

Here is the call graph for this function:

◆ GetProjectUserSlug()

std::string audacity::cloud::audiocom::sync::CloudProjectsDatabase::GetProjectUserSlug ( std::string_view projectId )

Definition at line 406 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return {};
 
   auto statement = connection->CreateStatement(
      "SELECT user_name FROM project_users WHERE project_id = ? LIMIT 1");
 
   if (!statement)
      return {};
 
   auto result = statement->Prepare(projectId).Run();
 
   for (auto row : result)
   {
      std::string slug;
 
      if (!row.Get(0, slug))
         return {};
 
      return slug;
   }
 
   return {};
}

References GetConnection().

Here is the call graph for this function:

◆ IsFirstSyncDialogShown()

bool audacity::cloud::audiocom::sync::CloudProjectsDatabase::IsFirstSyncDialogShown ( std::string_view projectId ) const

Definition at line 359 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return false;
 
   auto statement = connection->CreateStatement (
      "SELECT synced_dialog_shown FROM projects WHERE project_id = ? LIMIT 1");
 
   if (!statement)
      return false;
 
   auto result = statement->Prepare(projectId).Run();
 
   for (auto row : result)
   {
      bool shown;
 
      if (!row.Get(0, shown))
         return false;
 
      return shown;
   }
 
   return false;
}

◆ IsProjectBlockLocked()

bool audacity::cloud::audiocom::sync::CloudProjectsDatabase::IsProjectBlockLocked	(	std::string_view	projectId,
		int64_t	blockId
	)		const

Definition at line 451 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return false;
 
   auto statement = connection->CreateStatement(
      "SELECT 1 FROM pending_project_blocks WHERE project_id = ? AND block_id = ? LIMIT 1");
 
   if (!statement)
      return false;
 
   auto result = statement->Prepare(projectId, blockId).Run();
 
   for (auto row : result)
      return true;
 
   return false;
}

References GetConnection().

Here is the call graph for this function:

◆ MarkProjectAsSynced()

bool audacity::cloud::audiocom::sync::CloudProjectsDatabase::MarkProjectAsSynced	(	std::string_view	projectId,
		std::string_view	snapshotId
	)

Definition at line 208 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return false;
 
   auto statement = connection->CreateStatement(
      "UPDATE projects SET sync_status = ? WHERE project_id = ? AND snapshot_id = ?");
 
   if (!statement)
      return false;
 
   auto result = statement
                    ->Prepare(
                       static_cast<int>(DBProjectData::SyncStatusSynced),
                       projectId, snapshotId)
                    .Run();
 
   if (!result.IsOk())
      return false;
 
   return result.GetModifiedRowsCount() > 0;
}

References GetConnection(), and audacity::cloud::audiocom::sync::DBProjectData::SyncStatusSynced.

Here is the call graph for this function:

◆ OpenConnection()

bool audacity::cloud::audiocom::sync::CloudProjectsDatabase::OpenConnection ( )

private

Definition at line 819 of file CloudProjectsDatabase.cpp.

{
   if (mConnection)
      return true;
 
   const auto configDir  = FileNames::ConfigDir();
   const auto configPath = configDir + "/audiocom_sync.db";
 
   mConnection = sqlite::SafeConnection::Open(audacity::ToUTF8(configPath));
 
   if (!mConnection)
      return false;
 
   auto connection = mConnection->Acquire();
 
   auto result = connection->Execute(createTableQuery);
 
   if (!result)
   {
      mConnection = {};
      return false;
   }
 
   return RunMigrations();
}

References FileNames::ConfigDir(), audacity::cloud::audiocom::sync::anonymous_namespace{CloudProjectsDatabase.cpp}::createTableQuery, mConnection, audacity::sqlite::SafeConnection::Open(), RunMigrations(), and audacity::ToUTF8().

Referenced by GetConnection().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RemovePendingProjectBlob()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::RemovePendingProjectBlob	(	std::string_view	projectId,
		std::string_view	snapshotId
	)

Definition at line 585 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto statement = connection->CreateStatement(
      "DELETE FROM pending_project_blobs WHERE project_id = ? AND snapshot_id = ?");
 
   if (!statement)
      return;
 
   statement->Prepare(projectId, snapshotId).Run();
}

References GetConnection().

Referenced by audacity::cloud::audiocom::sync::anonymous_namespace{ResumedSnaphotUploadOperation.cpp}::ResumedSnaphotUploadOperation::UpdateUrls(), and audacity::cloud::audiocom::sync::anonymous_namespace{ResumedSnaphotUploadOperation.cpp}::ResumedSnaphotUploadOperation::UploadSnapshot().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RemovePendingProjectBlock()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::RemovePendingProjectBlock	(	std::string_view	projectId,
		int64_t	blockId
	)

Definition at line 681 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto statement = connection->CreateStatement(
      "DELETE FROM pending_project_blocks WHERE project_id = ? AND block_id = ?");
 
   if (!statement)
      return;
 
   statement->Prepare(projectId, blockId).Run();
}

References GetConnection().

Referenced by audacity::cloud::audiocom::sync::LocalProjectSnapshot::OnSnapshotCreated(), audacity::cloud::audiocom::sync::anonymous_namespace{ResumedSnaphotUploadOperation.cpp}::ResumedSnaphotUploadOperation::UpdateUrls(), and audacity::cloud::audiocom::sync::anonymous_namespace{ResumedSnaphotUploadOperation.cpp}::ResumedSnaphotUploadOperation::UploadBlocks().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RemovePendingProjectBlocks()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::RemovePendingProjectBlocks	(	std::string_view	projectId,
		std::string_view	snapshotId
	)

Definition at line 698 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto statement = connection->CreateStatement(
      "DELETE FROM pending_project_blocks WHERE project_id = ? AND snapshot_id = ?");
 
   if (!statement)
      return;
 
   statement->Prepare(projectId, snapshotId).Run();
}

References GetConnection().

Here is the call graph for this function:

◆ RemovePendingSnapshot()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::RemovePendingSnapshot	(	std::string_view	projectId,
		std::string_view	snapshotId
	)

Definition at line 494 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   static const char* queries[] = {
      "DELETE FROM pending_snapshots WHERE project_id = ? AND snapshot_id = ?",
      "DELETE FROM pending_project_blobs WHERE project_id = ? AND snapshot_id = ?",
      "DELETE FROM pending_project_blocks WHERE project_id = ? AND snapshot_id = ?",
   };
 
   auto tx = connection->BeginTransaction("RemovePendingSnapshot");
 
   for (auto query : queries)
   {
      auto statement = connection->CreateStatement(query);
 
      if (!statement)
         return;
 
      if (!statement->Prepare(projectId, snapshotId).Run().IsOk())
         return;
   }
 
   tx.Commit();
}

References GetConnection().

Referenced by audacity::cloud::audiocom::sync::LocalProjectSnapshot::DeleteSnapshot(), audacity::cloud::audiocom::sync::LocalProjectSnapshot::MarkSnapshotSynced(), audacity::cloud::audiocom::sync::anonymous_namespace{ResumedSnaphotUploadOperation.cpp}::ResumedSnaphotUploadOperation::MarkSnapshotSynced(), and audacity::cloud::audiocom::sync::anonymous_namespace{ResumedSnaphotUploadOperation.cpp}::ResumedSnaphotUploadOperation::UploadBlocks().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ RunMigrations()

bool audacity::cloud::audiocom::sync::CloudProjectsDatabase::RunMigrations ( )

private

Definition at line 845 of file CloudProjectsDatabase.cpp.

{
   auto connection = mConnection->Acquire();
 
   auto getMigrationVersion =
      connection->CreateStatement("SELECT version FROM migration LIMIT 1");
 
   if (!getMigrationVersion)
      return false;
 
   auto versionResult = getMigrationVersion->Prepare().Run();
 
   if (!versionResult.IsOk())
      return false;
 
   int version = 0;
 
   for (auto row : versionResult)
   {
      if (!row.Get(0, version))
         return false;
      break;
   }
 
   const auto migrationsCount = std::size(migrations);
 
   if (version >= migrationsCount)
      return true;
 
   auto tx = connection->BeginTransaction("RunMigrations");
 
   for (int i = version; i < migrationsCount; ++i)
   {
      auto result = connection->Execute(migrations[i]);
 
      if (!result)
         return false;
   }
 
   auto updateVersion =
      connection->CreateStatement("UPDATE migration SET version = ?");
 
   if (!updateVersion)
      return false;
 
   if (!updateVersion->Prepare(migrationsCount).Run().IsOk())
      return false;
 
   return tx.Commit().IsOk();
}

References mConnection, audacity::cloud::audiocom::sync::anonymous_namespace{CloudProjectsDatabase.cpp}::migrations, and size.

Referenced by OpenConnection().

Here is the caller graph for this function:

◆ SetFirstSyncDialogShown()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::SetFirstSyncDialogShown	(	std::string_view	projectId,
		bool	shown = `true`
	)

Definition at line 388 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto statement = connection->CreateStatement (
      "UPDATE projects SET synced_dialog_shown = ? WHERE project_id = ?");
 
   if (!statement)
      return;
 
   statement->Prepare(shown, projectId).Run();
}

◆ SetProjectUserSlug()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::SetProjectUserSlug	(	std::string_view	projectId,
		std::string_view	slug
	)

Definition at line 434 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto statement = connection->CreateStatement(
      "INSERT OR REPLACE INTO project_users (project_id, user_name) VALUES (?, ?)");
 
   if (!statement)
      return;
 
   statement->Prepare(projectId, slug).Run();
}

References GetConnection().

Here is the call graph for this function:

◆ UpdateBlockHashes()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::UpdateBlockHashes	(	std::string_view	projectId,
		const std::vector< std::pair< int64_t, std::string > > &	hashes
	)

Definition at line 286 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   const int localVar {};
   auto transaction = connection->BeginTransaction(
      std::string("UpdateBlockHashes_") +
      std::to_string(reinterpret_cast<size_t>(&localVar)));
 
   auto statement = connection->CreateStatement(
      "INSERT OR REPLACE INTO block_hashes (project_id, block_id, hash) VALUES (?, ?, ?)");
 
   for (const auto& [blockId, hash] : hashes)
      statement->Prepare(projectId, blockId, hash).Run();
 
   transaction.Commit();
}

References GetConnection().

Referenced by audacity::cloud::audiocom::sync::LocalProjectSnapshot::ProjectBlocksLock::UpdateProjectHashesInCache().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ UpdateProjectBlockList()

void audacity::cloud::audiocom::sync::CloudProjectsDatabase::UpdateProjectBlockList	(	std::string_view	projectId,
		const SampleBlockIDSet &	blockSet
	)

Definition at line 234 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return;
 
   auto inProjectSet = connection->CreateScalarFunction(
      "inProjectSet", [&blockSet](int64_t blockIndex)
      { return blockSet.find(blockIndex) != blockSet.end(); });
 
   auto statement = connection->CreateStatement(
      "DELETE FROM block_hashes WHERE project_id = ? AND NOT inProjectSet(block_id)");
 
   auto result = statement->Prepare(projectId).Run();
 
   if (!result.IsOk())
   {
      assert(false);
   }
}

References GetConnection().

Referenced by audacity::cloud::audiocom::sync::LocalProjectSnapshot::ProjectBlocksLock::ProjectBlocksLock().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ UpdateProjectData()

bool audacity::cloud::audiocom::sync::CloudProjectsDatabase::UpdateProjectData ( const DBProjectData & projectData )

Definition at line 309 of file CloudProjectsDatabase.cpp.

{
   auto connection = GetConnection();
 
   if (!connection)
      return false;
 
   auto tx = connection->BeginTransaction("UpdateProjectData");
 
   auto updateProjectData = connection->CreateStatement(
      "INSERT OR REPLACE INTO projects (project_id, snapshot_id, saves_count, last_audio_preview_save, local_path, last_modified, last_read, sync_status, synced_dialog_shown) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)");
 
   if (!updateProjectData)
      return false;
 
   auto result = updateProjectData
                    ->Prepare(
                       projectData.ProjectId, projectData.SnapshotId,
                       projectData.SavesCount, projectData.LastAudioPreview,
                       projectData.LocalPath, projectData.LastModified,
                       projectData.LastRead, projectData.SyncStatus,
                       projectData.FirstSyncDialogShown)
                    .Run();
 
   if (!result.IsOk())
      return false;
 
   auto listMissingProjects = connection->CreateStatement (
      "SELECT project_id FROM projects WHERE project_id != ? AND local_path = ?");
 
   if (!listMissingProjects)
      return false;
 
   auto missingProjects = listMissingProjects->Prepare(
      projectData.ProjectId, projectData.LocalPath).Run();
 
   for (auto row : missingProjects)
   {
      std::string missingProjectId;
 
      if (!row.Get(0, missingProjectId))
         return false;
 
      if (!DeleteProject(connection, missingProjectId))
         return false;
   }
 
   return tx.Commit().IsOk();
}

Here is the call graph for this function:

Member Data Documentation

◆ mConnection

std::shared_ptr<sqlite::SafeConnection> audacity::cloud::audiocom::sync::CloudProjectsDatabase::mConnection

private

Definition at line 155 of file CloudProjectsDatabase.h.

Referenced by GetConnection(), OpenConnection(), and RunMigrations().

◆ mConnectionMutex

std::mutex audacity::cloud::audiocom::sync::CloudProjectsDatabase::mConnectionMutex

private

Definition at line 154 of file CloudProjectsDatabase.h.

Referenced by GetConnection().

The documentation for this class was generated from the following files:

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ CloudProjectsDatabase()

◆ ~CloudProjectsDatabase()

Member Function Documentation

◆ AddPendingProjectBlob()

◆ AddPendingProjectBlocks()

◆ AddPendingSnapshot()

◆ DeleteProject() [1/2]

◆ DeleteProject() [2/2]

◆ DoGetProjectData() [1/2]

◆ DoGetProjectData() [2/2]

◆ Get()

◆ GetBlockHash()

◆ GetCloudProjects()

◆ GetConnection() [1/2]

◆ GetConnection() [2/2]

◆ GetPendingProjectBlob()

◆ GetPendingProjectBlocks()

◆ GetPendingSnapshots()

◆ GetProjectData()

◆ GetProjectDataForPath()

◆ GetProjectUserSlug()

◆ IsFirstSyncDialogShown()

◆ IsProjectBlockLocked()

◆ MarkProjectAsSynced()

◆ OpenConnection()

◆ RemovePendingProjectBlob()

◆ RemovePendingProjectBlock()

◆ RemovePendingProjectBlocks()

◆ RemovePendingSnapshot()

◆ RunMigrations()

◆ SetFirstSyncDialogShown()

◆ SetProjectUserSlug()

◆ UpdateBlockHashes()

◆ UpdateProjectBlockList()

◆ UpdateProjectData()

Member Data Documentation

◆ mConnection

◆ mConnectionMutex