working benchmarks

src/benchmarks/bls.js

@@ -0,0 +1,149 @@
+// 100,000 transfers
+const { test, utils } = require('@fuel-js/environment');
+const { chunk, pack, combine } = require('@fuel-js/struct');
+const { bytecode, abi, errors } = require('../builds/Fuel.json');
+const Proxy = require('../builds/Proxy.json');
+const ERC20 = require('../builds/ERC20.json');
+const { BlockHeader, RootHeader, Leaf,
+    merkleTreeRoot, transactions, hashes } = require('../protocol/src/block');
+const tx = require('../protocol/src/transaction');
+const { Deposit } = require('../protocol/src/deposit');
+const { defaults } = require('../tests/harness');
+const ethers = require('ethers');
+const gasPrice = require('@fuel-js/gasprice');
+const rootDeployment = require('./produce');
+const mcl = require('../bls/mcl');
+
+module.exports = test('100k transactions using BLS', async t => { try {
+  // attempt actual deployment
+  if (process.env['fuel_v1_network']) {
+    console.error('Benchmarking on network: ' + process.env['fuel_v1_network']);
+    t.setProvider(ethers.getDefaultProvider(process.env['fuel_v1_network'], {
+      infrua: process.env['fuel_v1_default_infura'],
+    }));
+    t.setPrivateKey(process.env['fuel_v1_default_operators'].split(',')[0]);
+  }
+
+  // set tx overrides object
+  t.setOverrides({
+    gasLimit: 6000000,
+    gasPrice: (await gasPrice(t.getProvider())).safe,
+  });
+
+  // simulate 100k tx's
+  const transactionsToSimulate = 100000;
+  const ethereumBlockSize = 8000000;
+  let cumulativeGasUsed = utils.bigNumberify(0);
+
+  const producer = t.getWallets()[0].address;
+  const contract = await t.deploy(abi, bytecode,
+      defaults(producer, utils.parseEther('.01')), t.getWallets()[0], t.getOverrides());
+
+  let tokenId = '0x00';
+  let ownerId = '0xdeadbe';
+
+  const maxRootSize = 32000;
+  const chunkSize = 32;
+  const transactionSize = 24;
+
+  let transaction = await tx.PackedTransfer({
+    metadata: tx.Metadata().encodePacked(),
+    to: ownerId,
+    from: ownerId,
+    transferAmount: '0xaabbccdd',
+    changeAmount: '0xaabbccdd',
+  });
+
+  // init MCL for BLS aggregate signatures
+  await mcl.init();
+  const keypair = await mcl.newKeyPair();
+  const message1 = transaction.encodePacked();
+  const signedPayload = mcl.sign(message1, keypair.secret);
+
+  const keypair2 = await mcl.newKeyPair();
+  const message2 = transaction.encodePacked();
+  const signedPayload2 = mcl.sign(message2, keypair2.secret);
+  const aggregated = mcl.g1ToHex(mcl.aggreagate(signedPayload.signature, signedPayload2.signature));
+
+  const numberOfAggragatedSignatures = transactionsToSimulate / chunkSize;
+  const signaturesPerRoot = Math.round((transactionsToSimulate * transactionSize) / chunkSize / maxRootSize);
+  const signature = '0x' + (new Array(signaturesPerRoot))
+    .fill(aggregated[0].slice(2) + aggregated[1].slice(2))
+    .join('');
+
+  /*
+  let transaction = await tx.Transaction({
+    override: true,
+    witnesses: [ t.wallets[0] ],
+    metadata: [ tx.Metadata() ],
+    data: [ tx.UTXO() ],
+    inputs: [ tx.Input() ],
+    outputs: [tx.OutputTransfer({
+      amount: '0xaabbccdd',
+      token: tokenId,
+      owner: [ownerId],
+    }), tx.OutputTransfer({
+      amount: '0xaabbccdd',
+      token: tokenId,
+      owner: [ownerId],
+    })],
+    contract,
+  });
+  */
+
+  const transactions = (new Array(transactionsToSimulate))
+    .fill(0)
+    .map(() => transaction);
+
+  const { rootHashes, gasUsed } = await rootDeployment(transactions, {
+    provider: t.getProvider(),
+    wallet: t.getWallets()[0],
+    tokenId,
+    signature,
+    operators: process.env['fuel_v1_default_seed']
+      || ethers.Wallet.createRandom().signingKey.mnemonic,
+    contract,
+  });
+  cumulativeGasUsed = cumulativeGasUsed.add(gasUsed);
+
+
+  const _testReduction = (await t.getProvider().getNetwork()).name === 'unknown'
+    ? 0
+    : 7; // 7 blocks back
+  const currentBlock = utils.bigNumberify(await t.getProvider().getBlockNumber()).sub(_testReduction);
+  const currentBlockHash = (await t.getProvider().getBlock(currentBlock.toNumber())).hash;
+
+  console.log('submitting at current block', currentBlock, currentBlockHash, _testReduction);
+
+  let block = await contract.commitBlock(currentBlock, currentBlockHash, 1, rootHashes.slice(0, 128), {
+    ...t.getOverrides(),
+    value: await contract.BOND_SIZE(),
+  });
+  block = await block.wait();
+
+  /*
+  let block2 = await contract.commitBlock(currentBlock, currentBlockHash, 2, rootHashes.slice(128, 128 + 128), {
+    ...t.getOverrides(),
+    value: await contract.BOND_SIZE(),
+  });
+  block2 = await block2.wait();
+  let block3 = await contract.commitBlock(currentBlock, currentBlockHash, 3, rootHashes.slice(256, 256 + 128), {
+    ...t.getOverrides(),
+    value: await contract.BOND_SIZE(),
+  });
+  block3 = await block3.wait();
+  */
+
+  cumulativeGasUsed = cumulativeGasUsed.add(block.cumulativeGasUsed);
+  // cumulativeGasUsed = cumulativeGasUsed.add(block2.cumulativeGasUsed);
+  // cumulativeGasUsed = cumulativeGasUsed.add(block3.cumulativeGasUsed);
+
+  t.ok(1, `Transactions Submitted: ${transactionsToSimulate}`);
+  t.ok(1, `Roots committed: ${rootHashes.length}`);
+  t.ok(1, `Blocks committed: 1`);
+  t.ok(1, `Cumulative gas used: ${cumulativeGasUsed.toString(rootHashes)}`);
+  t.ok(1, `Ethereum blocks used: ${cumulativeGasUsed.div(ethereumBlockSize)}`);
+  t.ok(1, `@$100 USD per Block: $${cumulativeGasUsed.div(ethereumBlockSize).mul(100)} USD`);
+  t.ok(1, `@$50 USD per Block: $${cumulativeGasUsed.div(ethereumBlockSize).mul(50)} USD`);
+
+} catch (error) { t.error(error, errors); } });

src/benchmarks/burning.js

@@ -5,9 +5,9 @@ const { bytecode, abi, errors } = require('../builds/Fuel.json');
 const Proxy = require('../builds/Proxy.json');
 const ERC20 = require('../builds/ERC20.json');
 const { BlockHeader, RootHeader, Leaf,
-    merkleTreeRoot, transactions, hashes } = require('@fuel-js/protocol/src/block');
-const tx = require('@fuel-js/protocol/src/transaction');
-const { Deposit } = require('@fuel-js/protocol/src/deposit');
+    merkleTreeRoot, transactions, hashes } = require('../protocol/src/block');
+const tx = require('../protocol/src/transaction');
+const { Deposit } = require('../protocol/src/deposit');
 const { defaults } = require('../tests/harness');
 const ethers = require('ethers');
 const gasPrice = require('@fuel-js/gasprice');

src/benchmarks/get.js

@@ -5,9 +5,9 @@ const { bytecode, abi, errors } = require('../builds/Fuel.json');
 const Proxy = require('../builds/Proxy.json');
 const ERC20 = require('../builds/ERC20.json');
 const { BlockHeader, RootHeader, Leaf,
-    merkleTreeRoot, transactions, hashes } = require('@fuel-js/protocol/src/block');
-const tx = require('@fuel-js/protocol/src/transaction');
-const { Deposit } = require('@fuel-js/protocol/src/deposit');
+    merkleTreeRoot, transactions, hashes } = require('../protocol/src/block');
+const tx = require('../protocol/src/transaction');
+const { Deposit } = require('../protocol/src/deposit');
 const { defaults } = require('../tests/harness');
 const ethers = require('ethers');
 const gasPrice = require('@fuel-js/gasprice');

src/benchmarks/index.js

@@ -1,5 +1,6 @@
 (async () => {
 
+  await require('./bls');
   await require('./subscriptions');
   await require('./transactions');
   await require('./minting');

src/benchmarks/minting.js

@@ -5,9 +5,9 @@ const { bytecode, abi, errors } = require('../builds/Fuel.json');
 const Proxy = require('../builds/Proxy.json');
 const ERC20 = require('../builds/ERC20.json');
 const { BlockHeader, RootHeader, Leaf,
-    merkleTreeRoot, transactions, hashes } = require('@fuel-js/protocol/src/block');
-const tx = require('@fuel-js/protocol/src/transaction');
-const { Deposit } = require('@fuel-js/protocol/src/deposit');
+    merkleTreeRoot, transactions, hashes } = require('../protocol/src/block');
+const tx = require('../protocol/src/transaction');
+const { Deposit } = require('../protocol/src/deposit');
 const { defaults } = require('../tests/harness');
 const ethers = require('ethers');
 const gasPrice = require('@fuel-js/gasprice');

src/benchmarks/produce-old.js

@@ -2,7 +2,7 @@
 const utils = require('@fuel-js/utils');
 const { chunk, pack, combine } = require('@fuel-js/struct');
 const ethers = require('ethers');
-const { RootHeader, merkleTreeRoot } = require('@fuel-js/protocol/src/block');
+const { RootHeader, merkleTreeRoot } = require('../protocol/src/block');
 const gasPrice = require('@fuel-js/gasprice');
 const refill = require('@fuel-js/refill');
 

src/benchmarks/produce.js

@@ -2,7 +2,7 @@
 const utils = require('@fuel-js/utils');
 const { chunk, pack, combine } = require('@fuel-js/struct');
 const ethers = require('ethers');
-const { RootHeader, merkleTreeRoot } = require('@fuel-js/protocol/src/block');
+const { RootHeader, merkleTreeRoot, EMPTY_SIGNATURE_HASH } = require('../protocol/src/block');
 const gasPrice = require('@fuel-js/gasprice');
 const refill = require('@fuel-js/refill');
 
@@ -141,6 +141,10 @@ async function rootDeployment(transactions = [], config = {}) {
               rootLength: utils.hexDataLength(combine(root)),
               fee: utils.bigNumberify(_wallet.address).add(_rootIndex),
               feeToken: config.tokenId,
+              transactionType: config.signature ? 1 : 0,
+              signatureHash: config.signature
+                ? utils.keccak256(config.signature)
+                : EMPTY_SIGNATURE_HASH,
             });
 
             // Root hash
@@ -180,6 +184,8 @@ async function rootDeployment(transactions = [], config = {}) {
                   config.tokenId,
                   header.properties.fee().get(),
                   combine(root),
+                  config.signature ? 1 : 0,
+                  config.signature ? config.signature : [],
                   rootTxOptions,
                 );
 

src/benchmarks/subscriptions.js

@@ -5,9 +5,9 @@ const { bytecode, abi, errors } = require('../builds/Fuel.json');
 const Proxy = require('../builds/Proxy.json');
 const ERC20 = require('../builds/ERC20.json');
 const { BlockHeader, RootHeader, Leaf,
-    merkleTreeRoot, transactions, hashes } = require('@fuel-js/protocol/src/block');
-const tx = require('@fuel-js/protocol/src/transaction');
-const { Deposit } = require('@fuel-js/protocol/src/deposit');
+    merkleTreeRoot, transactions, hashes } = require('../protocol/src/block');
+const tx = require('../protocol/src/transaction');
+const { Deposit } = require('../protocol/src/deposit');
 const { defaults } = require('../tests/harness');
 const ethers = require('ethers');
 const gasPrice = require('@fuel-js/gasprice');
@@ -39,7 +39,7 @@ module.exports = test('25k Subscription Transactions', async t => { try {
   const contract = await t.deploy(abi, bytecode,
       defaults(producer, utils.parseEther('.01')), t.getWallets()[0], t.getOverrides());
   let tokenId = '0x01';
-  const commitTx = await contract.commitAddress(producer, t.getOverrides());
+  const commitTx = await contract.commitAddress(producer, 0, 0, 0, 0, t.getOverrides());
   await commitTx.wait();
   const ownerId = await contract.addressId(producer);
 

src/benchmarks/transactions.js

@@ -5,9 +5,9 @@ const { bytecode, abi, errors } = require('../builds/Fuel.json');
 const Proxy = require('../builds/Proxy.json');
 const ERC20 = require('../builds/ERC20.json');
 const { BlockHeader, RootHeader, Leaf,
-    merkleTreeRoot, transactions, hashes } = require('@fuel-js/protocol/src/block');
-const tx = require('@fuel-js/protocol/src/transaction');
-const { Deposit } = require('@fuel-js/protocol/src/deposit');
+    merkleTreeRoot, transactions, hashes } = require('../protocol/src/block');
+const tx = require('../protocol/src/transaction');
+const { Deposit } = require('../protocol/src/deposit');
 const { defaults } = require('../tests/harness');
 const ethers = require('ethers');
 const gasPrice = require('@fuel-js/gasprice');