diff --git a/node-it/src/test/scala/com/wavesplatform/it/sync/AssetDistributionSuite.scala b/node-it/src/test/scala/com/wavesplatform/it/sync/AssetDistributionSuite.scala index 39cd533c6b..d8c99c2c07 100644 --- a/node-it/src/test/scala/com/wavesplatform/it/sync/AssetDistributionSuite.scala +++ b/node-it/src/test/scala/com/wavesplatform/it/sync/AssetDistributionSuite.scala @@ -25,7 +25,7 @@ class AssetDistributionSuite extends BaseTransactionSuite with CancelAfterFailur nodes.waitForHeightArise() - val issueTx = node.issue(issuer, "TestCoin", "no description", issueAmount, 8, false, issueFee, waitForTx = true).id + val issueTx = node.issue(issuer, "TestCoin", "no description", issueAmount, 8, reissuable = false, issueFee, waitForTx = true).id node.massTransfer( issuer, @@ -75,7 +75,7 @@ class AssetDistributionSuite extends BaseTransactionSuite with CancelAfterFailur test("'Asset distribution' works properly") { val receivers = for (i <- 0 until 10) yield KeyPair(s"receiver#$i".getBytes("UTF-8")) - val issueTx = node.issue(issuer, "TestCoin#2", "no description", issueAmount, 8, false, issueFee, waitForTx = true).id + val issueTx = node.issue(issuer, "TestCoin#2", "no description", issueAmount, 8, reissuable = false, issueFee, waitForTx = true).id node .massTransfer( @@ -99,7 +99,7 @@ class AssetDistributionSuite extends BaseTransactionSuite with CancelAfterFailur test("Correct last page and entry count") { val receivers = for (i <- 0 until 50) yield KeyPair(s"receiver#$i".getBytes("UTF-8")) - val issueTx = node.issue(issuer, "TestCoin#2", "no description", issueAmount, 8, false, issueFee, waitForTx = true).id + val issueTx = node.issue(issuer, "TestCoin#2", "no description", issueAmount, 8, reissuable = false, issueFee, waitForTx = true).id node .massTransfer( @@ -125,12 +125,14 @@ class AssetDistributionSuite extends BaseTransactionSuite with CancelAfterFailur } test("Unlimited list") { + val assetId = node.issue(issuer, "TestCoin#2", "no description", issueAmount, 8, reissuable = false, issueFee, waitForTx = true).id + val receivers = for (i <- 0 until 2000) yield KeyPair(s"receiver#$i".getBytes("UTF-8")) - val assetId = node.issue(issuer, "TestCoin#2", "no description", issueAmount, 8, false, issueFee, waitForTx = true).id + val transfers = receivers.map { r => MassTransferTransaction.Transfer(r.toAddress.toString, 10L) }.toList - receivers.foreach { receiver => - node.transfer(issuer, receiver.toAddress.toString, 10, assetId = Some(assetId)) + transfers.grouped(100).foreach { t => + node.massTransfer(issuer, t, minFee + t.length * minFee, assetId = Some(assetId)) } node.waitFor("empty utx")(_.utxSize, (_: Int) == 0, 1 second)