-
Notifications
You must be signed in to change notification settings - Fork 763
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add standard trace bad block to file JSON RPC method (#1403)
Signed-off-by: Karim TAAM <karim.t2am@gmail.com>
- Loading branch information
Showing
10 changed files
with
232 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
78 changes: 78 additions & 0 deletions
78
...erledger/besu/ethereum/api/jsonrpc/internal/methods/DebugStandardTraceBadBlockToFile.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,78 @@ | ||
| /* | ||
| * Copyright ConsenSys AG. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with | ||
| * the License. You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on | ||
| * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the | ||
| * specific language governing permissions and limitations under the License. | ||
| * | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| */ | ||
| package org.hyperledger.besu.ethereum.api.jsonrpc.internal.methods; | ||
|
|
||
| import org.hyperledger.besu.ethereum.api.jsonrpc.RpcMethod; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.JsonRpcRequestContext; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.parameters.TransactionTraceParams; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.processor.TransactionTracer; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.response.JsonRpcError; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.response.JsonRpcErrorResponse; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.response.JsonRpcResponse; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.response.JsonRpcSuccessResponse; | ||
| import org.hyperledger.besu.ethereum.api.query.BlockchainQueries; | ||
| import org.hyperledger.besu.ethereum.chain.BadBlockManager; | ||
| import org.hyperledger.besu.ethereum.chain.Blockchain; | ||
| import org.hyperledger.besu.ethereum.core.Hash; | ||
| import org.hyperledger.besu.ethereum.mainnet.ProtocolSchedule; | ||
| import org.hyperledger.besu.ethereum.mainnet.ProtocolSpec; | ||
|
|
||
| import java.nio.file.Path; | ||
| import java.util.Optional; | ||
| import java.util.function.Supplier; | ||
|
|
||
| public class DebugStandardTraceBadBlockToFile extends DebugStandardTraceBlockToFile | ||
| implements JsonRpcMethod { | ||
|
|
||
| private final ProtocolSchedule protocolSchedule; | ||
|
|
||
| public DebugStandardTraceBadBlockToFile( | ||
| final Supplier<TransactionTracer> transactionTracerSupplier, | ||
| final BlockchainQueries blockchainQueries, | ||
| final ProtocolSchedule protocolSchedule, | ||
| final Path dataDir) { | ||
| super(transactionTracerSupplier, blockchainQueries, dataDir); | ||
| this.protocolSchedule = protocolSchedule; | ||
| } | ||
|
|
||
| @Override | ||
| public String getName() { | ||
| return RpcMethod.DEBUG_STANDARD_TRACE_BAD_BLOCK_TO_FILE.getMethodName(); | ||
| } | ||
|
|
||
| @Override | ||
| public JsonRpcResponse response(final JsonRpcRequestContext requestContext) { | ||
| final Hash blockHash = requestContext.getRequiredParameter(0, Hash.class); | ||
| final Optional<TransactionTraceParams> transactionTraceParams = | ||
| requestContext.getOptionalParameter(1, TransactionTraceParams.class); | ||
|
|
||
| final Blockchain blockchain = blockchainQueries.get().getBlockchain(); | ||
| final ProtocolSpec protocolSpec = | ||
| protocolSchedule.getByBlockNumber(blockchain.getChainHeadHeader().getNumber()); | ||
| final BadBlockManager badBlockManager = protocolSpec.getBadBlocksManager(); | ||
|
|
||
| return badBlockManager | ||
| .getBadBlock(blockHash) | ||
| .map( | ||
| block -> | ||
| (JsonRpcResponse) | ||
| new JsonRpcSuccessResponse( | ||
| requestContext.getRequest().getId(), | ||
| traceBlock(block, transactionTraceParams))) | ||
| .orElse( | ||
| new JsonRpcErrorResponse( | ||
| requestContext.getRequest().getId(), JsonRpcError.BLOCK_NOT_FOUND)); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
99 changes: 99 additions & 0 deletions
99
...dger/besu/ethereum/api/jsonrpc/internal/methods/DebugStandardTraceBadBlockToFileTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,99 @@ | ||
| /* | ||
| * Copyright ConsenSys AG. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with | ||
| * the License. You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on | ||
| * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the | ||
| * specific language governing permissions and limitations under the License. | ||
| * | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| */ | ||
| package org.hyperledger.besu.ethereum.api.jsonrpc.internal.methods; | ||
|
|
||
| import static org.assertj.core.api.Assertions.assertThat; | ||
| import static org.mockito.ArgumentMatchers.any; | ||
| import static org.mockito.ArgumentMatchers.eq; | ||
| import static org.mockito.Mockito.mock; | ||
| import static org.mockito.Mockito.when; | ||
|
|
||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.JsonRpcRequest; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.JsonRpcRequestContext; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.processor.TransactionTracer; | ||
| import org.hyperledger.besu.ethereum.api.jsonrpc.internal.response.JsonRpcSuccessResponse; | ||
| import org.hyperledger.besu.ethereum.api.query.BlockchainQueries; | ||
| import org.hyperledger.besu.ethereum.chain.BadBlockManager; | ||
| import org.hyperledger.besu.ethereum.chain.Blockchain; | ||
| import org.hyperledger.besu.ethereum.core.Block; | ||
| import org.hyperledger.besu.ethereum.core.BlockDataGenerator; | ||
| import org.hyperledger.besu.ethereum.core.BlockHeader; | ||
| import org.hyperledger.besu.ethereum.core.BlockHeaderTestFixture; | ||
| import org.hyperledger.besu.ethereum.mainnet.ProtocolSchedule; | ||
| import org.hyperledger.besu.ethereum.mainnet.ProtocolSpec; | ||
|
|
||
| import java.util.ArrayList; | ||
| import java.util.HashMap; | ||
| import java.util.List; | ||
|
|
||
| import org.junit.ClassRule; | ||
| import org.junit.Test; | ||
| import org.junit.rules.TemporaryFolder; | ||
|
|
||
| public class DebugStandardTraceBadBlockToFileTest { | ||
|
|
||
| @ClassRule public static final TemporaryFolder folder = new TemporaryFolder(); | ||
|
|
||
| private final BlockchainQueries blockchainQueries = mock(BlockchainQueries.class); | ||
| private final Blockchain blockchain = mock(Blockchain.class); | ||
| private final ProtocolSchedule protocolSchedule = mock(ProtocolSchedule.class); | ||
| private final TransactionTracer transactionTracer = mock(TransactionTracer.class); | ||
| private final ProtocolSpec protocolSpec = mock(ProtocolSpec.class); | ||
|
|
||
| private final DebugStandardTraceBadBlockToFile debugStandardTraceBadBlockToFile = | ||
| new DebugStandardTraceBadBlockToFile( | ||
| () -> transactionTracer, blockchainQueries, protocolSchedule, folder.getRoot().toPath()); | ||
|
|
||
| @Test | ||
| public void nameShouldBeDebugTraceTransaction() { | ||
| assertThat(debugStandardTraceBadBlockToFile.getName()) | ||
| .isEqualTo("debug_standardTraceBadBlockToFile"); | ||
| } | ||
|
|
||
| @SuppressWarnings("rawtypes") | ||
| @Test | ||
| public void shouldTraceTheTransactionUsingTheTransactionTracer() { | ||
|
|
||
| final BlockDataGenerator blockGenerator = new BlockDataGenerator(); | ||
| final Block genesis = blockGenerator.genesisBlock(); | ||
| final Block block = | ||
| blockGenerator.block( | ||
| new BlockDataGenerator.BlockOptions().setParentHash(genesis.getHeader().getHash())); | ||
|
|
||
| final Object[] params = new Object[] {block.getHash(), new HashMap<>()}; | ||
| final JsonRpcRequestContext request = | ||
| new JsonRpcRequestContext( | ||
| new JsonRpcRequest("2.0", "debug_standardTraceBadBlockToFile", params)); | ||
|
|
||
| final List<String> paths = new ArrayList<>(); | ||
| paths.add("path-1"); | ||
|
|
||
| final BadBlockManager badBlockManager = new BadBlockManager(); | ||
| badBlockManager.addBadBlock(block); | ||
|
|
||
| final BlockHeader blockHeader = new BlockHeaderTestFixture().buildHeader(); | ||
| when(protocolSpec.getBadBlocksManager()).thenReturn(badBlockManager); | ||
| when(blockchainQueries.getBlockchain()).thenReturn(blockchain); | ||
| when(blockchain.getChainHeadHeader()).thenReturn(new BlockHeaderTestFixture().buildHeader()); | ||
| when(protocolSchedule.getByBlockNumber(blockHeader.getNumber())).thenReturn(protocolSpec); | ||
| when(transactionTracer.traceTransactionToFile(eq(block.getHash()), any(), any(), any())) | ||
| .thenReturn(paths); | ||
| final JsonRpcSuccessResponse response = | ||
| (JsonRpcSuccessResponse) debugStandardTraceBadBlockToFile.response(request); | ||
| final List result = (ArrayList) response.getResult(); | ||
|
|
||
| assertThat(result.size()).isEqualTo(1); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters