script to fetch xc transaction histroy

Author: aalavandhan

contracts/_utilities/ChainBridgeBatchRebaseReport.sol

@@ -33,7 +33,7 @@ contract ChainBridgeBatchRebaseReport {
             (epoch, totalSupply) = IPolicy(policy).globalAmpleforthEpochAndAMPLSupply();
 
             uint256 dataLen = 64;
-            IBridge(bridge).deposit{value:bridgeFee}(
+            IBridge(bridge).deposit{value: bridgeFee}(
                 destinationChainID,
                 resourceID,
                 abi.encode(dataLen, epoch, totalSupply)

hardhat.config.js

@@ -16,6 +16,7 @@ require('./tasks/ops/xc_transfer');
 require('./tasks/info/config');
 require('./tasks/info/ampl');
 require('./tasks/info/chain_bridge');
+require('./tasks/info/cb_ampl_tx');
 
 module.exports = {
   solidity: {
@@ -90,6 +91,6 @@ module.exports = {
     },
     prodBscSatChain: {
       url: 'https://bsc-dataseed.binance.org/'
-    },
+    }
   }
 };

helpers/contracts.js

@@ -4,6 +4,8 @@ const { getAdminAddress } = require('@openzeppelin/upgrades-core');
 const DEPLOYMENT_CONFIG_PATH = __dirname + '/../sdk/deployments';
 const { getEthersProvider } = require('./utils');
 
+const BLOCKS_PER_SEC = 1 / 15;
+
 const ContractABIPaths = {
   // Openzepppelin
   ProxyAdmin: '@openzeppelin/upgrades/contracts/upgradeability',
@@ -157,6 +159,43 @@ const writeProxyDeploymentData = async (network, contractRef, contract) => {
   fs.writeFileSync(addressFile, JSON.stringify(chainAddresses, null, 2));
 };
 
+const filterContractEvents = async (
+  ethers,
+  provider,
+  address,
+  abi,
+  event,
+  startBlock,
+  endBlock,
+  timeFrameSec = 7 * 24 * 3600,
+) => {
+  endBlock = endBlock || (await provider.getBlockNumber());
+  const freq = timeFrameSec * BLOCKS_PER_SEC;
+
+  let logs = [];
+  for (let i = startBlock; i <= endBlock; i += freq) {
+    // console.log(i, startBlock, endBlock)
+    const _logs = await provider.getLogs({
+      address: address,
+      fromBlock: ethers.utils.hexlify(i),
+      toBlock: ethers.utils.hexlify(i + freq > endBlock ? endBlock : i + freq),
+    });
+    logs = logs.concat(_logs);
+  }
+
+  const contractInterface = new ethers.utils.Interface(abi);
+  const decodedEvents = logs.reduce((m, log) => {
+    try {
+      log.parsed = contractInterface.parseLog(log);
+      log.parsed.name == event ? m.push(log) : m;
+      return m;
+    } catch (e) {
+      return m;
+    }
+  }, []);
+  return decodedEvents;
+};
+
 module.exports = {
   readDeploymentData,
   readContractDeploymentData,
@@ -169,4 +208,6 @@ module.exports = {
   deployContract,
   deployProxyAdminContract,
   deployProxyContract,
+
+  filterContractEvents,
 };

helpers/tasks.js

@@ -4,12 +4,7 @@ const { task } = require('hardhat/config');
 
 function txTask(name, desc) {
   return task(name, desc)
-    .addParam(
-      'gasPrice',
-      'Gas price for the transaction',
-      0,
-      types.int,
-    )
+    .addParam('gasPrice', 'Gas price for the transaction', 0, types.int)
     .addParam('gasLimit', 'Gas limit for the transaction', 7000000, types.int)
     .addParam('txSleepSec', 'Time to wait between transactions', 2, types.int)
     .addParam('keyfile', 'The path to signer keyfile')

package.json

@@ -21,7 +21,7 @@
     "@openzeppelin/contracts": "^3.2.0",
     "@openzeppelin/contracts-upgradeable": "^3.3.0",
     "@openzeppelin/upgrades": "^2.8.0",
-    "chainbridge-solidity": "https://github.com/ChainSafe/chainbridge-solidity#a15727ad30bb359b4dfd0fb155f338d11ea80753",
+    "chainbridge-solidity": "https://github.com/meterio/chainbridge-solidity-v1.0.0-eth#master",
     "market-oracle": "https://github.com/ampleforth/market-oracle#v1.0.1",
     "uFragments": "https://github.com/ampleforth/uFragments#v1.1.0"
   },
@@ -38,6 +38,7 @@
     "bignumber.js": "^9.0.1",
     "chai": "^4.2.0",
     "commander": "^6.2.1",
+    "csv-writer": "^1.6.0",
     "eslint": "^4.19.1",
     "eslint-config-google": "^0.9.1",
     "eslint-config-mocha": "^0.0.0",
@@ -66,6 +67,7 @@
     "stochasm": "^0.5.0",
     "ts-node": "^9.0.0",
     "typechain": "^4.0.3",
-    "typescript": "^4.0.2"
+    "typescript": "^4.0.2",
+    "underscore": "^1.13.1"
   }
 }

sdk/ampleforth.js

@@ -4,10 +4,16 @@ const BigNumber = require('bignumber.js');
 const AMPL_DECIMALS = 9;
 
 const toAmplFloatingPt = (ample) =>
-  ethers.utils.formatUnits(`${ample.toFixed ? ample.toFixed(AMPL_DECIMALS) : ample}`, AMPL_DECIMALS);
+  ethers.utils.formatUnits(
+    `${ample.toFixed ? ample.toFixed(AMPL_DECIMALS) : ample}`,
+    AMPL_DECIMALS,
+  );
 
 const toAmplFixedPt = (ample) =>
-  ethers.utils.parseUnits(`${ample.toFixed ? ample.toFixed(AMPL_DECIMALS) : ample}`, AMPL_DECIMALS);
+  ethers.utils.parseUnits(
+    `${ample.toFixed ? ample.toFixed(AMPL_DECIMALS) : ample}`,
+    AMPL_DECIMALS,
+  );
 
 const INITIAL_SUPPLY = ethers.utils.parseUnits('50', 6 + AMPL_DECIMALS);
 const AMPL_ORACLE_DECIMALS = 18;

tasks/deploy/ampleforth.js

@@ -90,7 +90,7 @@ txTask('testnet:deploy:ampleforth', 'Deploy ampleforth contract suite')
   .addParam('amount', 'Amount of ampl to transfer', 0, types.float)
   .setAction(async (args, hre) => {
     const txParams = { gasPrice: args.gasPrice, gasLimit: args.gasLimit };
-    if(txParams.gasPrice == 0){
+    if (txParams.gasPrice == 0) {
       txParams.gasPrice = await hre.ethers.provider.getGasPrice();
     }
 
@@ -153,7 +153,7 @@ txTask('deploy:ampleforth_xc', 'Deploy cross chain ampleforth contract suite')
   .addParam('tokenName', 'The symbol of the cross-chain ample ERC-20 token')
   .setAction(async (args, hre) => {
     const txParams = { gasPrice: args.gasPrice, gasLimit: args.gasLimit };
-    if(txParams.gasPrice == 0){
+    if (txParams.gasPrice == 0) {
       txParams.gasPrice = await hre.ethers.provider.getGasPrice();
     }
 

tasks/deploy/chain_bridge.js

@@ -59,7 +59,7 @@ cbDeployTask(
   .addParam('useDeployed', 'Use deployed bridge', false, types.boolean)
   .setAction(async (args, hre) => {
     const txParams = { gasPrice: args.gasPrice, gasLimit: args.gasLimit };
-    if(txParams.gasPrice == 0){
+    if (txParams.gasPrice == 0) {
       txParams.gasPrice = await hre.ethers.provider.getGasPrice();
     }
     const deployer = loadSignerSync(args, hre.ethers.provider);
@@ -206,7 +206,7 @@ cbDeployTask(
   .addParam('useDeployed', 'Use deployed bridge', false, types.boolean)
   .setAction(async (args, hre) => {
     const txParams = { gasPrice: args.gasPrice, gasLimit: args.gasLimit };
-    if(txParams.gasPrice == 0){
+    if (txParams.gasPrice == 0) {
       txParams.gasPrice = await hre.ethers.provider.getGasPrice();
     }
     const deployer = loadSignerSync(args, hre.ethers.provider);