Skip to content

Commit

Permalink
execution: rename BlockNumAndHash to BlockId (#2344)
Browse files Browse the repository at this point in the history
  • Loading branch information
battlmonstr committed Sep 13, 2024
1 parent 34e8ecd commit 7d7e70f
Show file tree
Hide file tree
Showing 16 changed files with 19 additions and 22 deletions.
1 change: 0 additions & 1 deletion silkworm/core/types/block_id.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@

namespace silkworm {

// TODO(canepat) rename BlockNumberAndHash
struct BlockId {
BlockNum number{};
Hash hash;
Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/api/active_direct_service.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ Task<InsertionResult> ActiveDirectService::insert_blocks(const Blocks& blocks) {
/** Chain Validation and ForkChoice **/

// rpc ValidateChain(ValidationRequest) returns(ValidationReceipt);
Task<ValidationResult> ActiveDirectService::validate_chain(BlockNumAndHash number_and_hash) {
Task<ValidationResult> ActiveDirectService::validate_chain(BlockId number_and_hash) {
return concurrency::spawn_task(executor_, [](auto* self, auto num_and_hash) {
return self->DirectService::validate_chain(num_and_hash);
}(this, number_and_hash));
Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/api/active_direct_service.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ class ActiveDirectService : public DirectService, public ActiveComponent {
/** Chain Validation and ForkChoice **/

// rpc ValidateChain(ValidationRequest) returns(ValidationReceipt);
Task<ValidationResult> validate_chain(BlockNumAndHash number_and_hash) override;
Task<ValidationResult> validate_chain(BlockId number_and_hash) override;

// rpc UpdateForkChoice(ForkChoice) returns(ForkChoiceReceipt);
Task<ForkChoiceResult> update_fork_choice(const ForkChoice& fork_choice) override;
Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/api/direct_service.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ Task<InsertionResult> DirectService::insert_blocks(const Blocks& blocks) {
/** Chain Validation and ForkChoice **/

// rpc ValidateChain(ValidationRequest) returns(ValidationReceipt);
Task<ValidationResult> DirectService::validate_chain(BlockNumAndHash number_and_hash) {
Task<ValidationResult> DirectService::validate_chain(BlockId number_and_hash) {
const auto verification = co_await exec_engine_.verify_chain(number_and_hash.hash);
co_return verification;
}
Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/api/direct_service.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ class DirectService : public Service {
/** Chain Validation and ForkChoice **/

// rpc ValidateChain(ValidationRequest) returns(ValidationReceipt);
Task<ValidationResult> validate_chain(BlockNumAndHash number_and_hash) override;
Task<ValidationResult> validate_chain(BlockId number_and_hash) override;

// rpc UpdateForkChoice(ForkChoice) returns(ForkChoiceReceipt);
Task<ForkChoiceResult> update_fork_choice(const ForkChoice& fork_choice) override;
Expand Down
8 changes: 3 additions & 5 deletions silkworm/execution/api/endpoint/validation.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -26,20 +26,18 @@

namespace silkworm::execution::api {

using BlockNumAndHash = BlockId;

struct ValidChain {
BlockNumAndHash current_head;
BlockId current_head;
};

struct InvalidChain {
BlockNumAndHash unwind_point;
BlockId unwind_point;
std::optional<Hash> bad_block;
std::set<Hash> bad_headers;
};

struct ValidationError {
BlockNumAndHash latest_valid_head;
BlockId latest_valid_head;
std::string error;
};

Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/api/service.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ struct Service {
/** Chain Validation and ForkChoice **/

// rpc ValidateChain(ValidationRequest) returns(ValidationReceipt);
virtual Task<ValidationResult> validate_chain(BlockNumAndHash) = 0;
virtual Task<ValidationResult> validate_chain(BlockId) = 0;

// rpc UpdateForkChoice(ForkChoice) returns(ForkChoiceReceipt);
virtual Task<ForkChoiceResult> update_fork_choice(const ForkChoice&) = 0;
Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/grpc/client/endpoint/validation.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ namespace silkworm::execution::grpc::client {

namespace proto = ::execution;

proto::ValidationRequest request_from_block_num_and_hash(const api::BlockNumAndHash& number_and_hash) {
proto::ValidationRequest request_from_block_num_and_hash(const BlockId& number_and_hash) {
proto::ValidationRequest request;
request.set_number(number_and_hash.number);
request.set_allocated_hash(rpc::H256_from_bytes32(number_and_hash.hash).release());
Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/grpc/client/endpoint/validation.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@

namespace silkworm::execution::grpc::client {

::execution::ValidationRequest request_from_block_num_and_hash(const api::BlockNumAndHash&);
::execution::ValidationRequest request_from_block_num_and_hash(const BlockId&);
api::ValidationResult validation_result_from_response(const ::execution::ValidationReceipt&);

::execution::ForkChoice request_from_fork_choice(const api::ForkChoice&);
Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/grpc/client/remote_client.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ class RemoteClientImpl final : public api::Service {
/** Chain Validation and ForkChoice **/

// rpc ValidateChain(ValidationRequest) returns(ValidationReceipt);
Task<api::ValidationResult> validate_chain(api::BlockNumAndHash number_and_hash) override {
Task<api::ValidationResult> validate_chain(BlockId number_and_hash) override {
auto request = request_from_block_num_and_hash(number_and_hash);
const auto reply = co_await rpc::unary_rpc(&Stub::AsyncValidateChain, *stub_, std::move(request), grpc_context_);
co_return validation_result_from_response(reply);
Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/grpc/server/endpoint/validation.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ namespace silkworm::execution::grpc::server {

namespace proto = ::execution;

api::BlockNumAndHash block_num_and_hash_from_request(const proto::ValidationRequest& request) {
BlockId block_num_and_hash_from_request(const proto::ValidationRequest& request) {
return {
.number = request.number(),
.hash = rpc::bytes32_from_H256(request.hash()),
Expand Down
2 changes: 1 addition & 1 deletion silkworm/execution/grpc/server/endpoint/validation.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ namespace silkworm::execution::grpc::server {

api::ExecutionStatus execution_status_from_proto(const ::execution::ExecutionStatus&);

api::BlockNumAndHash block_num_and_hash_from_request(const ::execution::ValidationRequest&);
BlockId block_num_and_hash_from_request(const ::execution::ValidationRequest&);
::execution::ValidationReceipt response_from_validation_result(const api::ValidationResult&);

api::ForkChoice fork_choice_from_request(const ::execution::ForkChoice&);
Expand Down
4 changes: 2 additions & 2 deletions silkworm/node/execution/active_direct_service_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -95,11 +95,11 @@ TEST_CASE_METHOD(ActiveDirectServiceTest, "ActiveDirectServiceTest::insert_block
TEST_CASE_METHOD(ActiveDirectServiceTest, "ActiveDirectServiceTest::verify_chain", "[node][execution][api]") {
const Hash latest_valid_hash{0x000000000000000000000000000000000000000000000000000000000000000A_bytes32};
const Hash new_hash{0x000000000000000000000000000000000000000000000000000000000000000B_bytes32};
const BlockNumAndHash latest_valid_head{
const BlockId latest_valid_head{
.number = 1,
.hash = latest_valid_hash,
};
const BlockNumAndHash new_head{
const BlockId new_head{
.number = 2,
.hash = new_hash,
};
Expand Down
4 changes: 2 additions & 2 deletions silkworm/node/execution/direct_service_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -77,11 +77,11 @@ TEST_CASE_METHOD(DirectServiceTest, "DirectService::insert_blocks", "[node][exec
TEST_CASE_METHOD(DirectServiceTest, "DirectService::verify_chain", "[node][execution][api]") {
const Hash latest_valid_hash{0x000000000000000000000000000000000000000000000000000000000000000A_bytes32};
const Hash new_hash{0x000000000000000000000000000000000000000000000000000000000000000B_bytes32};
const BlockNumAndHash latest_valid_head{
const BlockId latest_valid_head{
.number = 1,
.hash = latest_valid_hash,
};
const BlockNumAndHash new_head{
const BlockId new_head{
.number = 2,
.hash = new_hash,
};
Expand Down
2 changes: 1 addition & 1 deletion silkworm/sync/sync_pos_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ TEST_CASE_METHOD(PoSSyncTest, "PoSSync::new_payload timeout") {
for (size_t i{0}; i < requests.size(); ++i) {
const auto& request{requests[i]};
const auto& payload{request.execution_payload};
execution::api::BlockNumAndHash block_number_or_hash{payload.number, payload.block_hash};
BlockId block_number_or_hash{payload.number, payload.block_hash};
execution::api::BlockNumberOrHash parent_number_or_hash{payload.parent_hash};
SECTION("payload version: v" + std::to_string(payload.version) + " i=" + std::to_string(i)) {
EXPECT_CALL(*execution_service, get_header(parent_number_or_hash))
Expand Down
2 changes: 1 addition & 1 deletion silkworm/sync/test_util/mock_execution_client.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ class MockExecutionService : public execution::api::Service {
public:
MOCK_METHOD((Task<api::InsertionResult>), insert_blocks, (const api::Blocks&), (override));

MOCK_METHOD((Task<api::ValidationResult>), validate_chain, (api::BlockNumAndHash), (override));
MOCK_METHOD((Task<api::ValidationResult>), validate_chain, (BlockId), (override));
MOCK_METHOD((Task<api::ForkChoiceResult>), update_fork_choice, (const api::ForkChoice&), (override));

MOCK_METHOD((Task<api::AssembleBlockResult>), assemble_block, (const api::BlockUnderConstruction&), (override));
Expand Down

0 comments on commit 7d7e70f

Please sign in to comment.