mirror of https://github.com/hyperledger/besu
Karim TAAM
11 months ago
committed by
GitHub
commit
61e985b77d
@ -0,0 +1,40 @@ |
|||||||
|
/* |
||||||
|
* Copyright Hyperledger Besu Contributors. |
||||||
|
* |
||||||
|
* 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.tests.acceptance.dsl.condition.eth; |
||||||
|
|
||||||
|
import static org.assertj.core.api.Assertions.assertThat; |
||||||
|
|
||||||
|
import org.hyperledger.besu.tests.acceptance.dsl.WaitUtils; |
||||||
|
import org.hyperledger.besu.tests.acceptance.dsl.condition.Condition; |
||||||
|
import org.hyperledger.besu.tests.acceptance.dsl.node.Node; |
||||||
|
import org.hyperledger.besu.tests.acceptance.dsl.transaction.eth.EthSyncingTransaction; |
||||||
|
|
||||||
|
public class SyncingStatusCondition implements Condition { |
||||||
|
|
||||||
|
private final EthSyncingTransaction transaction; |
||||||
|
private final boolean syncingMiningStatus; |
||||||
|
|
||||||
|
public SyncingStatusCondition( |
||||||
|
final EthSyncingTransaction transaction, final boolean syncingStatus) { |
||||||
|
this.transaction = transaction; |
||||||
|
this.syncingMiningStatus = syncingStatus; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void verify(final Node node) { |
||||||
|
WaitUtils.waitFor( |
||||||
|
10, () -> assertThat(node.execute(transaction)).isEqualTo(syncingMiningStatus)); |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,40 @@ |
|||||||
|
/* |
||||||
|
* Copyright Hyperledger Besu Contributors. |
||||||
|
* |
||||||
|
* 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.tests.acceptance.dsl.transaction.eth; |
||||||
|
|
||||||
|
import static org.assertj.core.api.Assertions.assertThat; |
||||||
|
|
||||||
|
import org.hyperledger.besu.tests.acceptance.dsl.transaction.NodeRequests; |
||||||
|
import org.hyperledger.besu.tests.acceptance.dsl.transaction.Transaction; |
||||||
|
|
||||||
|
import java.io.IOException; |
||||||
|
|
||||||
|
import org.web3j.protocol.core.methods.response.EthSyncing; |
||||||
|
|
||||||
|
public class EthSyncingTransaction implements Transaction<Boolean> { |
||||||
|
|
||||||
|
EthSyncingTransaction() {} |
||||||
|
|
||||||
|
@Override |
||||||
|
public Boolean execute(final NodeRequests node) { |
||||||
|
try { |
||||||
|
EthSyncing response = node.eth().ethSyncing().send(); |
||||||
|
assertThat(response).isNotNull(); |
||||||
|
return response.isSyncing(); |
||||||
|
} catch (final IOException e) { |
||||||
|
throw new RuntimeException(e); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,66 @@ |
|||||||
|
/* |
||||||
|
* Copyright Hyperledger Besu Contributors. |
||||||
|
* |
||||||
|
* 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.blockcreation.txselection; |
||||||
|
|
||||||
|
import org.hyperledger.besu.datatypes.Wei; |
||||||
|
import org.hyperledger.besu.ethereum.core.Transaction; |
||||||
|
import org.hyperledger.besu.ethereum.eth.transactions.PendingTransaction; |
||||||
|
|
||||||
|
import com.google.common.base.Stopwatch; |
||||||
|
|
||||||
|
public class TransactionEvaluationContext |
||||||
|
implements org.hyperledger.besu.plugin.services.txselection.TransactionEvaluationContext< |
||||||
|
PendingTransaction> { |
||||||
|
private final org.hyperledger.besu.ethereum.eth.transactions.PendingTransaction |
||||||
|
pendingTransaction; |
||||||
|
private final Stopwatch evaluationTimer; |
||||||
|
private final Wei transactionGasPrice; |
||||||
|
private final Wei minGasPrice; |
||||||
|
|
||||||
|
public TransactionEvaluationContext( |
||||||
|
final PendingTransaction pendingTransaction, |
||||||
|
final Stopwatch evaluationTimer, |
||||||
|
final Wei transactionGasPrice, |
||||||
|
final Wei minGasPrice) { |
||||||
|
this.pendingTransaction = pendingTransaction; |
||||||
|
this.evaluationTimer = evaluationTimer; |
||||||
|
this.transactionGasPrice = transactionGasPrice; |
||||||
|
this.minGasPrice = minGasPrice; |
||||||
|
} |
||||||
|
|
||||||
|
public Transaction getTransaction() { |
||||||
|
return pendingTransaction.getTransaction(); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public PendingTransaction getPendingTransaction() { |
||||||
|
return pendingTransaction; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public Stopwatch getEvaluationTimer() { |
||||||
|
return evaluationTimer; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public Wei getTransactionGasPrice() { |
||||||
|
return transactionGasPrice; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public Wei getMinGasPrice() { |
||||||
|
return minGasPrice; |
||||||
|
} |
||||||
|
} |
||||||
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,57 @@ |
|||||||
|
/* |
||||||
|
* Copyright Hyperledger Besu Contributors. |
||||||
|
* |
||||||
|
* 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.plugin.services.txselection; |
||||||
|
|
||||||
|
import org.hyperledger.besu.datatypes.PendingTransaction; |
||||||
|
import org.hyperledger.besu.datatypes.Wei; |
||||||
|
|
||||||
|
import com.google.common.base.Stopwatch; |
||||||
|
|
||||||
|
/** |
||||||
|
* This interface defines the context for evaluating a transaction. It provides methods to get the |
||||||
|
* pending transaction, the evaluation timer, and the transaction gas price. |
||||||
|
* |
||||||
|
* @param <PT> the type of the pending transaction |
||||||
|
*/ |
||||||
|
public interface TransactionEvaluationContext<PT extends PendingTransaction> { |
||||||
|
|
||||||
|
/** |
||||||
|
* Gets the pending transaction. |
||||||
|
* |
||||||
|
* @return the pending transaction |
||||||
|
*/ |
||||||
|
PT getPendingTransaction(); |
||||||
|
|
||||||
|
/** |
||||||
|
* Gets the stopwatch used for timing the evaluation. |
||||||
|
* |
||||||
|
* @return the evaluation timer |
||||||
|
*/ |
||||||
|
Stopwatch getEvaluationTimer(); |
||||||
|
|
||||||
|
/** |
||||||
|
* Gets the gas price of the transaction. |
||||||
|
* |
||||||
|
* @return the transaction gas price |
||||||
|
*/ |
||||||
|
Wei getTransactionGasPrice(); |
||||||
|
|
||||||
|
/** |
||||||
|
* Gets the min gas price for block inclusion |
||||||
|
* |
||||||
|
* @return the min gas price |
||||||
|
*/ |
||||||
|
Wei getMinGasPrice(); |
||||||
|
} |
||||||
Loading…
Reference in new issue