-
Notifications
You must be signed in to change notification settings - Fork 123
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Re-new MantaPay precomputed coins and re-enable tests (#1015)
* Update precomputed coins and re-enable disabled tests Signed-off-by: Georgi Zlatarev <[email protected]> * Add the script for inserting the coins into a network Signed-off-by: Georgi Zlatarev <[email protected]> * Update start_iterations to 14000 Signed-off-by: Georgi Zlatarev <[email protected]> * Update the data folder Signed-off-by: Georgi Zlatarev <[email protected]> * Clean up Signed-off-by: Georgi Zlatarev <[email protected]> * Clean up insert_coins script Signed-off-by: Georgi Zlatarev <[email protected]> * Fix logging in insert_coins.js Signed-off-by: Georgi Zlatarev <[email protected]> --------- Signed-off-by: Georgi Zlatarev <[email protected]>
- Loading branch information
1 parent
ceba9fc
commit 6719c8a
Showing
7 changed files
with
172 additions
and
81 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
Binary file not shown.
Binary file not shown.
Binary file not shown.
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,97 @@ | ||
| const fs = require('fs').promises; | ||
|
|
||
| const keyring = new Keyring({ | ||
| type: 'sr25519' | ||
| }); | ||
| const nodeAddress = "ws://127.0.0.1:9801"; | ||
|
|
||
| async function createPromiseApi(nodeAddress) { | ||
| const wsProvider = new WsProvider(nodeAddress); | ||
| const api = await ApiPromise.create({ | ||
| provider: wsProvider | ||
| }); | ||
| await api.isReady; | ||
| return api; | ||
| } | ||
|
|
||
| async function main() { | ||
| const api = await createPromiseApi(nodeAddress); | ||
| const sender = keyring.addFromMnemonic("bottom drive obey lake curtain smoke basket hold race lonely fit walk//Alice"); | ||
|
|
||
| const mints_file = '/home/georgi/Desktop/workspace/Manta/precomputed-15k-iterations/precomputed_mints_v3-5'; | ||
| const transfers_file = '/home/georgi/Desktop/workspace/Manta/precomputed-15k-iterations/precomputed_transfers_v3-5'; | ||
| const reclaims_file = '/home/georgi/Desktop/workspace/Manta/precomputed-15k-iterations/precomputed_reclaims_v3-5'; | ||
|
|
||
| const mints_buffer = await fs.readFile(mints_file); | ||
| const transfers_buffer = await fs.readFile(transfers_file); | ||
| const reclaims_buffer = await fs.readFile(reclaims_file); | ||
|
|
||
| const mints_offset = 2; | ||
| const transfers_offset = 4; | ||
| const reclaims_offset = 4; | ||
| const total_iterations = 15000; | ||
| const mint_size = 552; | ||
| const transfer_size = 100; | ||
|
|
||
| let batches_sent = 0; | ||
| const transactions = []; | ||
|
|
||
| for (let i = 0; i < total_iterations; i++) { | ||
| const mints_start = mints_offset + i * mint_size; | ||
| const mint = api.tx.mantaPay.toPrivate(mints_buffer.subarray(mints_start, mint_size + mints_start)); | ||
| transactions.push(mint); | ||
|
|
||
| const transfers_start = transfers_offset + i * (2 * mint_size + transfer_size); | ||
| const transfer_mint_1 = api.tx.mantaPay.toPrivate(transfers_buffer.subarray(transfers_start, transfers_start + mint_size)); | ||
| const transfer_mint_2 = api.tx.mantaPay.toPrivate(transfers_buffer.subarray(transfers_start + mint_size, transfers_start + 2 * mint_size)); | ||
| const transfer = api.tx.mantaPay.privateTransfer(transfers_buffer.subarray(transfers_start + 2 * mint_size, transfers_start + 2 * mint_size + transfer_size)); | ||
| transactions.push(transfer_mint_1); | ||
| transactions.push(transfer_mint_2); | ||
| transactions.push(transfer); | ||
|
|
||
| await api.tx.utility.forceBatch(transactions).signAndSend(sender, { | ||
| nonce: -1 | ||
| }, ({ | ||
| events = [], | ||
| status | ||
| }) => { | ||
| if (status.isFinalized) { | ||
| console.log("tx %i success.", status.nonce); | ||
| } | ||
| if (status.isDropped || status.isUsurped || status.isFinalityTimeout || status.isRetracted) { | ||
| console.err(`tx %i ${status.type}.`, status.nonce); | ||
| } | ||
| }); | ||
|
|
||
| await new Promise(resolve => setTimeout(resolve, 10000)); | ||
| transactions.length = 0; | ||
|
|
||
| const reclaims_start = reclaims_offset + i * (2 * mint_size + transfer_size); | ||
| const reclaim_mint_1 = api.tx.mantaPay.toPrivate(reclaims_buffer.subarray(reclaims_start, reclaims_start + mint_size)); | ||
| const reclaim_mint_2 = api.tx.mantaPay.toPrivate(reclaims_buffer.subarray(reclaims_start, reclaims_start + mint_size)); | ||
| const reclaim = api.tx.mantaPay.toPrivate(reclaims_buffer.subarray(reclaims_start, reclaims_start + mint_size)); | ||
| transactions.push(reclaim_mint_1); | ||
| transactions.push(reclaim_mint_2); | ||
| transactions.push(reclaim); | ||
|
|
||
| await api.tx.utility.forceBatch(transactions).signAndSend(sender, { | ||
| nonce: -1 | ||
| }, ({ | ||
| events = [], | ||
| status | ||
| }) => { | ||
| if (status.isFinalized) { | ||
| console.log("tx %i success.", status.nonce); | ||
| } | ||
| if (status.isDropped || status.isUsurped || status.isFinalityTimeout || status.isRetracted) { | ||
| console.err(`tx %i ${status.type}.`, status.nonce); | ||
| } | ||
| }); | ||
|
|
||
| await new Promise(resolve => setTimeout(resolve, 10000)); | ||
| transactions.length = 0; | ||
|
|
||
| } | ||
| } | ||
|
|
||
| main().catch(console.error); |
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