Skip to content
Snippets Groups Projects

F files

Merged F files
f-files into dev
Merged Timm Fitschen requested to merge f-files into dev
Compare
and
Show latest version
1 file
+ 0
− 170
Compare changes
  • Side-by-side
  • Inline
src/caosdb/transaction.cpp
+ 0
− 170
@@ -391,55 +391,6 @@ auto Transaction::ExecuteAsynchronously() noexcept -> StatusCode {
}
auto Transaction::WaitForIt() const noexcept -> TransactionStatus {
// if (this->response->responses_size() == 1) {
// auto *responses = this->response->mutable_responses(0);
// switch (responses->wrapped_response_case()) {
// case WrappedResponseCase::kRetrieveResponse: {
// auto *retrieve_response = responses->mutable_retrieve_response();
// switch (retrieve_response->query_response_case()) {
// case QueryResponseCase::kEntity: {
// auto *entity = retrieve_response->release_entity();
// if (!entity->errors().empty()) {
// this->status = TransactionStatus::TRANSACTION_ERROR(
//"The request returned with errors.");
//}
// this->result_set = std::make_unique<UniqueResult>(entity);
//} break;
// case QueryResponseCase::kSelectResult: {
//// TODO(tf) Select queries
//} break;
// case QueryResponseCase::kCountResult: {
// this->query_count = retrieve_response->count_result();
// std::vector<std::unique_ptr<Entity>> entities;
// this->result_set =
// std::make_unique<MultiResultSet>(std::move(entities));
//} break;
// default:
//// TODO(tf) Error
// break;
//}
//} break;
// case WrappedResponseCase::kUpdateResponse: {
// auto *updatedIdResponse = responses->mutable_update_response();
// if (!updatedIdResponse->entity_errors().empty()) {
// this->status = TransactionStatus::TRANSACTION_ERROR(
//"The request returned with errors.");
//}
// this->result_set = std::make_unique<UniqueResult>(updatedIdResponse);
//} break;
// case WrappedResponseCase::kInsertResponse: {
// auto *insertedIdResponse = responses->mutable_insert_response();
// if (!insertedIdResponse->entity_errors().empty()) {
// this->status = TransactionStatus::TRANSACTION_ERROR(
//"The request returned with errors.");
//}
// this->result_set = std::make_unique<UniqueResult>(insertedIdResponse);
//} break;
// default:
//// TODO(tf) Error and Update
// break;
//}
//} else {
bool set_error = false;
auto *responses = this->response->mutable_responses();
std::vector<std::unique_ptr<Entity>> entities;
@@ -479,73 +430,6 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus {
CAOSDB_LOG_FATAL(logger_name) << "Received invalid QueryResponseCase.";
break;
}
//<<<<<<< HEAD
//} break;
// case WrappedResponseCase::kUpdateResponse: {
// auto *updatedIdResponse = responses->mutable_update_response();
// if (!updatedIdResponse->id_response().errors().empty()) {
// this->status = TransactionStatus::TRANSACTION_ERROR(
//"The request returned with errors.");
//}
// this->result_set = std::make_unique<UniqueResult>(
// updatedIdResponse->release_id_response());
//} break;
// case WrappedResponseCase::kInsertResponse: {
// auto *insertedIdResponse = responses->mutable_insert_response();
// if (!insertedIdResponse->id_response().errors().empty()) {
// this->status = TransactionStatus::TRANSACTION_ERROR(
//"The request returned with errors.");
//}
// this->result_set = std::make_unique<UniqueResult>(
// insertedIdResponse->release_id_response());
//} break;
// case WrappedResponseCase::kDeleteResponse: {
// auto *deletedIdResponse = responses->mutable_delete_response();
// if (!deletedIdResponse->id_response().errors().empty()) {
// this->status = TransactionStatus::TRANSACTION_ERROR(
//"The request returned with errors.");
//}
// this->result_set = std::make_unique<UniqueResult>(
// deletedIdResponse->release_id_response());
//} break;
// default:
// CAOSDB_LOG_FATAL(logger_name) << "Received invalid
// WrappedResponseCase."; break;
//}
//} else {
// auto *responses = this->response->mutable_responses();
// std::vector<std::unique_ptr<Entity>> entities;
// CAOSDB_LOG_DEBUG(logger_name)
//<< "Number of subresponses: " << responses->size();
// for (auto sub_response : *responses) {
// switch (sub_response.wrapped_response_case()) {
// case TransactionResponseCase::kRetrieveResponse:
// entities.push_back(std::make_unique<Entity>(
// sub_response.mutable_retrieve_response()->release_entity_response()));
// break;
// case TransactionResponseCase::kInsertResponse:
// entities.push_back(std::make_unique<Entity>(
// sub_response.mutable_insert_response()->release_id_response()));
// break;
// case TransactionResponseCase::kDeleteResponse:
// entities.push_back(std::make_unique<Entity>(
// sub_response.mutable_delete_response()->release_id_response()));
// break;
// case TransactionResponseCase::kUpdateResponse:
// entities.push_back(std::make_unique<Entity>(
// sub_response.mutable_update_response()->release_id_response()));
// break;
// default:
// CAOSDB_LOG_FATAL(logger_name)
//<< "Received invalid TransactionResponseCase.";
// break;
//}
//}
// this->result_set =
// std::make_unique<MultiResultSet>(std::move(entities));
//=======
break;
}
case TransactionResponseCase::kInsertResponse: {
@@ -621,58 +505,4 @@ auto Transaction::RegisterUploadFile(RegisterFileUploadResponse *response)
assert(ok);
}
// auto Transaction::UploadFile(FileUploadResponse *response,
// const FileDescriptor &file_descriptor,
// const std::string &registration_id) -> void {
// grpc::Status grpc_status;
// CompletionQueue cq;
// grpc::ClientContext context;
// FileUploadRequest request;
// auto *chunk = request.mutable_chunk();
// auto *file_transmission_id = chunk->mutable_file_transmission_id();
// file_transmission_id->set_registration_id(registration_id);
// file_transmission_id->set_file_id("test.txt");
// chunk->set_data("this is some data");
// std::unique_ptr<ClientAsyncResponseReader<FileUploadResponse>> rpc(
// this->file_service->PrepareAsyncFileUpload(&context, request, &cq));
// rpc->StartCall();
// int tag = 1;
// void *send_tag = static_cast<void *>(&tag);
// rpc->Finish(response, &grpc_status, send_tag);
// void *recv_tag = nullptr;
// bool ok = false;
// cq.Next(&recv_tag, &ok);
// assert(recv_tag == send_tag);
// assert(ok);
//}
// auto Transaction::DownloadFile(FileDownloadResponse *response,
// const FileTransmissionId &file_transmission_id)
//-> void {
// FileDownloadRequest request;
// request.mutable_file_transmission_id()->CopyFrom(file_transmission_id);
// grpc::Status grpc_status;
// CompletionQueue cq;
// grpc::ClientContext context;
// std::unique_ptr<ClientAsyncResponseReader<FileDownloadResponse>> rpc(
// this->file_service->PrepareAsyncFileDownload(&context, request, &cq));
// rpc->StartCall();
// int tag = 1;
// void *send_tag = static_cast<void *>(&tag);
// rpc->Finish(response, &grpc_status, send_tag);
// void *recv_tag = nullptr;
// bool ok = false;
// cq.Next(&recv_tag, &ok);
//}
} // namespace caosdb::transaction