Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Fix/6790 return accepted for rejected tx added to broadcast #6889

Merged
merged 22 commits into from
May 13, 2024
Merged

Fix/6790 return accepted for rejected tx added to broadcast #6889

Changes from 1 commit
Commits
Show all changes
22 commits
Select commit Hold shift + click to select a range
ca922d9
update tx response for persistent broadcast
pxyxyrus Apr 1, 2024
1e4670a
added own test
pxyxyrus Apr 1, 2024
401e318
Fix TxPool test cases to expect result according to the changes made
pxyxyrus Apr 2, 2024
13a767a
update: persistent tx with low fees broadcasts and returns accepted
pxyxyrus Apr 2, 2024
919bd2d
revert test changes
pxyxyrus Apr 6, 2024
14e8b79
update broadcaster and underpaid tx broadcast logic
pxyxyrus Apr 9, 2024
7936a1e
TxBroadcaster code refactor
pxyxyrus Apr 10, 2024
ca67a97
TxPoolTest update
pxyxyrus Apr 10, 2024
6d0a22c
TxPoolTest update
pxyxyrus Apr 10, 2024
7dfbdb6
fix white space formatting
pxyxyrus Apr 12, 2024
4757f6f
fix startBroadcast
pxyxyrus Apr 12, 2024
018afc9
fix StartBroadcast
pxyxyrus Apr 12, 2024
be126f5
TxPoolTest update
pxyxyrus Apr 12, 2024
b64dd50
add test to test the updated broadcaster/txpool functionality
pxyxyrus Apr 13, 2024
3c19462
test fixed
pxyxyrus Apr 23, 2024
926c381
remove invalid import
pxyxyrus Apr 23, 2024
f8546dd
remove invalid import
pxyxyrus Apr 23, 2024
c695cc5
revert commit 926c38177f1e9e2b8eb709bacc177d9c91535798
pxyxyrus Apr 23, 2024
8360abc
Merge branch 'master' into fix/6790_return_accepted_for_rejected_tx_a…
pxyxyrus Apr 23, 2024
031d15e
add another test case for TxType AccessList
pxyxyrus Apr 25, 2024
f97394e
change test to check all possible txtype cases and open to extension …
pxyxyrus Apr 25, 2024
a6150f1
fix linting error
pxyxyrus Apr 25, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
65 changes: 20 additions & 45 deletions src/Nethermind/Nethermind.TxPool.Test/TxPoolTests.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@
using Nethermind.Crypto;
using Nethermind.Db;
using Nethermind.Evm;
using Nethermind.Evm.Tracing.GethStyle.JavaScript;

Check failure on line 24 in src/Nethermind/Nethermind.TxPool.Test/TxPoolTests.cs

View workflow job for this annotation

GitHub Actions / Build (release, Nethermind) 

The type or namespace name 'JavaScript' does not exist in the namespace 'Nethermind.Evm.Tracing.GethStyle' (are you missing an assembly reference?)

Check failure on line 24 in src/Nethermind/Nethermind.TxPool.Test/TxPoolTests.cs

View workflow job for this annotation

GitHub Actions / Build (release, Nethermind) 

The type or namespace name 'JavaScript' does not exist in the namespace 'Nethermind.Evm.Tracing.GethStyle' (are you missing an assembly reference?)

Check failure on line 24 in src/Nethermind/Nethermind.TxPool.Test/TxPoolTests.cs

View workflow job for this annotation

GitHub Actions / Build (debug, Nethermind) 

The type or namespace name 'JavaScript' does not exist in the namespace 'Nethermind.Evm.Tracing.GethStyle' (are you missing an assembly reference?)

Check failure on line 24 in src/Nethermind/Nethermind.TxPool.Test/TxPoolTests.cs

View workflow job for this annotation

GitHub Actions / Build (debug, Nethermind) 

The type or namespace name 'JavaScript' does not exist in the namespace 'Nethermind.Evm.Tracing.GethStyle' (are you missing an assembly reference?)
using Nethermind.Int256;
using Nethermind.Logging;
using Nethermind.Specs;
Expand Down Expand Up @@ -1638,11 +1639,14 @@
result.Should().Be(expectedResult ? AcceptTxResult.Accepted : AcceptTxResult.FeeTooLowToCompete);
}

[TestCase]
public void Should_only_add_legacy_and_1559_local_transactions_to_local_pool_when_underpaid()
[TestCase(TxType.Legacy, true)]
[TestCase(TxType.EIP1559, true)]
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

and [TestCase(TxType.AccessList, true)] to have all types

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Maybe better to have TestCaseSource and generate test cases for all enum items, by default with true and just have exception for blobs. In that case if we add new tx type we will by default have a test that expects true here.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I've changed the test accordingly to check all the values of TxType.

[TestCase(TxType.Blob, false)]
public void Should_correctly_add_tx_to_local_pool_when_underpaid(TxType txType, bool expectedResult)
{
ISpecProvider specProvider = GetLondonSpecProvider();
TxPoolConfig txPoolConfig = new TxPoolConfig { Size = 30 };
// Should only add legacy and 1559 local transactions to local pool when underpaid
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

access list type too and probably all future ones. The best is to write sth like Should only add local transactions other than blob-type to local pool when underpaid

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

applied

ISpecProvider specProvider = GetCancunSpecProvider();
TxPoolConfig txPoolConfig = new TxPoolConfig { Size = 30, PersistentBlobStorageSize = 0 };
_txPool = CreatePool(txPoolConfig, specProvider);

Transaction[] transactions = GetTransactions(GetPeers(3), true, false);
Expand All @@ -1652,6 +1656,7 @@
EnsureSenderBalance(address, UInt256.MaxValue);
}

// setup full tx pool
foreach (Transaction transaction in transactions)
{
transaction.GasPrice = 10.GWei();
Expand All @@ -1660,52 +1665,22 @@

_txPool.GetPendingTransactionsCount().Should().Be(30);


// send legacy tx (gasPrice 9 gwei)
Transaction firstTx = Build.A.Transaction
Transaction testTx = Build.A.Transaction
.WithNonce(0)
.WithValue(0)
.WithType(TxType.Legacy)
.WithGasPrice(9.GWei())
.WithTo(TestItem.AddressD)
.WithType(txType)
.WithShardBlobTxTypeAndFieldsIfBlobTx()
.WithMaxFeePerGas(9.GWei())
.WithMaxPriorityFeePerGas(9.GWei())
.WithTo(TestItem.AddressB)
.SignedAndResolved(_ethereumEcdsa, TestItem.PrivateKeyA).TestObject;

EnsureSenderBalance(TestItem.PrivateKeyA.Address, UInt256.MaxValue);
_txPool.SubmitTx(firstTx, TxHandlingOptions.PersistentBroadcast).Should().Be(AcceptTxResult.Accepted);
_txPool.GetOwnPendingTransactions().Length.Should().Be(1);
_txPool.GetPendingTransactions().Should().NotContain(firstTx);



// send eip1559 tx (gasPrice 9 gwei)
Transaction secondTx = Build.A.Transaction
.WithNonce(0)
.WithValue(0)
.WithType(TxType.EIP1559)
.WithTo(TestItem.AddressD)
.WithMaxFeePerGas(9.GWei())
.SignedAndResolved(_ethereumEcdsa, TestItem.PrivateKeyB).TestObject;

EnsureSenderBalance(TestItem.PrivateKeyB.Address, UInt256.MaxValue);
_txPool.SubmitTx(secondTx, TxHandlingOptions.PersistentBroadcast).Should().Be(AcceptTxResult.Accepted);
_txPool.GetOwnPendingTransactions().Length.Should().Be(2);
_txPool.GetPendingTransactions().Should().NotContain(secondTx);


// send blop tx (gasPrice 9 gwei)
Transaction thirdTx = Build.A.Transaction
.WithNonce(0)
.WithValue(0)
.WithType(TxType.Blob)
.WithTo(TestItem.AddressD)
.WithBlobVersionedHashes(new byte[1][])
.WithMaxFeePerBlobGas(9.GWei())
.SignedAndResolved(_ethereumEcdsa, TestItem.PrivateKeyC).TestObject;

EnsureSenderBalance(TestItem.PrivateKeyC.Address, UInt256.MaxValue);
_txPool.SubmitTx(thirdTx, TxHandlingOptions.PersistentBroadcast).Should().Be(AcceptTxResult.FeeTooLow);
_txPool.GetOwnPendingTransactions().Length.Should().Be(2);
_txPool.GetPendingTransactions().Should().NotContain(thirdTx);
AcceptTxResult result = _txPool.SubmitTx(testTx, TxHandlingOptions.PersistentBroadcast);
result.Should().Be(expectedResult ? AcceptTxResult.Accepted : AcceptTxResult.FeeTooLowToCompete);
_txPool.GetOwnPendingTransactions().Length.Should().Be(expectedResult ? 1 : 0);
_txPool.GetPendingBlobTransactionsCount().Should().Be(0);
_txPool.GetPendingTransactions().Should().NotContain(testTx);
}

private IDictionary<ITxPoolPeer, PrivateKey> GetPeers(int limit = 100)
Expand Down
Loading