diff --git a/include/caosdb/transaction.h b/include/caosdb/transaction.h index b25cd41c3412109c887739d095c17a1c6746c1b8..a873a93bec97e0a47d87692327e0d23662b5a1e7 100644 --- a/include/caosdb/transaction.h +++ b/include/caosdb/transaction.h @@ -176,7 +176,8 @@ using caosdb::entity::v1alpha1::MultiTransactionResponse; using caosdb::entity::v1alpha1::RegisterFileUploadRequest; using caosdb::entity::v1alpha1::RegisterFileUploadResponse; using caosdb::transaction::TransactionStatus; -using TransactionResponseCase = caosdb::entity::v1alpha1::TransactionResponse::TransactionResponseCase; +using TransactionResponseCase = + caosdb::entity::v1alpha1::TransactionResponse::TransactionResponseCase; class Transaction; diff --git a/src/caosdb/transaction.cpp b/src/caosdb/transaction.cpp index 06fc46af3019eb406db16d6f7e82e415541c8122..af6c0f7dcc4be48a6d399cdc0eb62af82da4fd75 100644 --- a/src/caosdb/transaction.cpp +++ b/src/caosdb/transaction.cpp @@ -452,7 +452,8 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus { switch (retrieve_response->retrieve_response_case()) { case RetrieveResponseCase::kEntityResponse: { - auto *retrieve_entity_response = retrieve_response->release_entity_response(); + auto *retrieve_entity_response = + retrieve_response->release_entity_response(); result = std::make_unique<Entity>(retrieve_entity_response); } break; case RetrieveResponseCase::kSelectResult: { @@ -464,14 +465,15 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus { this->query_count = retrieve_response->count_result(); } break; case RetrieveResponseCase::kFindResult: { - for (auto &entity_response : *retrieve_response->mutable_find_result()->mutable_result_set()) { + for (auto &entity_response : + *retrieve_response->mutable_find_result()->mutable_result_set()) { result = std::make_unique<Entity>(&entity_response); if (result->HasErrors()) { set_error = true; } entities.push_back(std::move(result)); } - } break; + } break; default: CAOSDB_LOG_FATAL(logger_name) << "Received invalid QueryResponseCase."; break; @@ -546,17 +548,20 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus { } case TransactionResponseCase::kInsertResponse: { - auto *inserted_id_response = sub_response.mutable_insert_response()->release_id_response(); + auto *inserted_id_response = + sub_response.mutable_insert_response()->release_id_response(); result = std::make_unique<Entity>(inserted_id_response); break; } case TransactionResponseCase::kDeleteResponse: { - auto *deleted_id_response = sub_response.mutable_delete_response()->release_id_response(); + auto *deleted_id_response = + sub_response.mutable_delete_response()->release_id_response(); result = std::make_unique<Entity>(deleted_id_response); break; } case TransactionResponseCase::kUpdateResponse: { - auto *updated_id_response = sub_response.mutable_update_response()->release_id_response(); + auto *updated_id_response = + sub_response.mutable_update_response()->release_id_response(); result = std::make_unique<Entity>(updated_id_response); break; } @@ -565,7 +570,7 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus { << "Received invalid TransactionResponseCase."; break; } - if(result != nullptr) { + if (result != nullptr) { if (result->HasErrors()) { set_error = true; }