[web-db] add unit tests for draft store queries
ClosedPublic
Actions

Show All 28 Lines	class CreateNewBackupReactor : public ServerBidiReactorBase<

State state = State::USER_ID;		State state = State::USER_ID;
std::string userID;		std::string userID;
std::string keyEntropy;		std::string keyEntropy;
std::string dataHash;		std::string dataHash;
std::string holder;		std::string holder;
std::string backupID;		std::string backupID;
std::shared_ptr<reactor::BlobPutClientReactor> putReactor;		std::shared_ptr<reactor::BlobPutClientReactor> putReactor;

ServiceBlobClient blobClient;		ServiceBlobClient blobClient;
std::mutex reactorStateMutex;		std::mutex reactorStateMutex;
std::condition_variable blobDoneCV;
std::mutex blobDoneCVMutex;		std::condition_variable blobPutDoneCV;
		std::mutex blobPutDoneCVMutex;

std::string generateBackupID();		std::string generateBackupID();

public:		public:
std::unique_ptr<ServerBidiReactorStatus> handleRequest(		std::unique_ptr<ServerBidiReactorStatus> handleRequest(
backup::CreateNewBackupRequest request,		backup::CreateNewBackupRequest request,
backup::CreateNewBackupResponse *response) override;		backup::CreateNewBackupResponse *response) override;
void terminateCallback() override;		void terminateCallback() override;
Show All 35 Lines	case State::DATA_HASH: {
this->dataHash = request.newcompactionhash();		this->dataHash = request.newcompactionhash();
this->state = State::DATA_CHUNKS;		this->state = State::DATA_CHUNKS;

// TODO confirm - holder may be a backup id		// TODO confirm - holder may be a backup id
this->backupID = this->generateBackupID();		this->backupID = this->generateBackupID();
response->set_backupid(this->backupID);		response->set_backupid(this->backupID);
this->holder = this->backupID;		this->holder = this->backupID;
this->putReactor = std::make_shared<reactor::BlobPutClientReactor>(		this->putReactor = std::make_shared<reactor::BlobPutClientReactor>(
this->holder, this->dataHash, &this->blobDoneCV);		this->holder, this->dataHash, &this->blobPutDoneCV);
this->blobClient.put(this->putReactor);		this->blobClient.put(this->putReactor);
return nullptr;		return nullptr;
}		}
case State::DATA_CHUNKS: {		case State::DATA_CHUNKS: {
this->putReactor->scheduleSendingDataChunk(std::make_unique<std::string>(		this->putReactor->scheduleSendingDataChunk(std::make_unique<std::string>(
std::move(*request.mutable_newcompactionchunk())));		std::move(*request.mutable_newcompactionchunk())));
return nullptr;		return nullptr;
}		}
}		}
throw std::runtime_error("new backup - invalid state");		throw std::runtime_error("new backup - invalid state");
}		}

void CreateNewBackupReactor::terminateCallback() {		void CreateNewBackupReactor::terminateCallback() {
const std::lock_guard<std::mutex> lock(this->reactorStateMutex);		const std::lock_guard<std::mutex> lock(this->reactorStateMutex);
if (this->putReactor == nullptr) {		if (this->putReactor == nullptr) {
return;		return;
}		}
this->putReactor->scheduleSendingDataChunk(std::make_unique<std::string>(""));		this->putReactor->scheduleSendingDataChunk(std::make_unique<std::string>(""));
std::unique_lock<std::mutex> lock2(this->blobDoneCVMutex);		std::unique_lock<std::mutex> lock2(this->blobPutDoneCVMutex);
if (!this->putReactor->isDone()) {		if (this->putReactor->isDone() && !this->putReactor->getStatus().ok()) {
this->blobDoneCV.wait(lock2);
} else if (!this->putReactor->getStatus().ok()) {
throw std::runtime_error(this->putReactor->getStatus().error_message());		throw std::runtime_error(this->putReactor->getStatus().error_message());
}		}
		if (!this->putReactor->isDone()) {
		this->blobPutDoneCV.wait(lock2);
		}
try {		try {
// TODO add recovery data		// TODO add recovery data
// TODO handle attachments holders		// TODO handle attachments holders
database::BackupItem backupItem(		database::BackupItem backupItem(
this->userID,		this->userID,
this->backupID,		this->backupID,
getCurrentTimestamp(),		getCurrentTimestamp(),
generateRandomString(),		generateRandomString(),
Show All 11 Lines

[web-db] add unit tests for draft store queriesClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 24359

web/database/queries/draft-queries.test.js

[web-db] add unit tests for draft store queries
ClosedPublic
Actions

Revision Contents
Changeset List