AugurProject/augur-ui

View on GitHub
src/modules/app/actions/sync-blockchain.js

Summary

Maintainability
A
1 hr
Test Coverage
import { augur } from "services/augurjs";
import { updateBlockchain } from "modules/app/actions/update-blockchain";
import { updateAssets } from "modules/auth/actions/update-assets";
import { createBigNumber } from "utils/create-big-number";
import { loadGasPriceInfo } from "modules/app/actions/load-gas-price-info";
import { isPastV2Cutoff } from "modules/markets/helpers/is-market-past-v2-cutoff";

const GET_GAS_BLOCK_LIMIT = 100;

export const syncBlockchain = () => (dispatch, getState) => {
  const { gasPriceInfo } = getState();
  const blockNumber = parseInt(augur.rpc.getCurrentBlock().number, 16);
  augur.api.Controller.getTimestamp((err, augurTimestamp) => {
    if (err) console.error(err);
    const currentAugurTimestamp = parseInt(augurTimestamp, 10);
    dispatch(
      updateBlockchain({
        currentBlockNumber: blockNumber,
        currentBlockTimestamp: parseInt(
          augur.rpc.getCurrentBlock().timestamp,
          16
        ),
        currentAugurTimestamp,
        pastCutoff: isPastV2Cutoff(currentAugurTimestamp)
      })
    );

    const BNblockNumber = createBigNumber(blockNumber);
    const BNGasBlockNumberLimit = createBigNumber(
      gasPriceInfo.blockNumber || "0"
    ).plus(GET_GAS_BLOCK_LIMIT);

    if (!gasPriceInfo.blockNumber || BNblockNumber.gte(BNGasBlockNumberLimit)) {
      dispatch(loadGasPriceInfo());
    }
  });

  augur.augurNode.getSyncData((err, res) => {
    if (!err && res) {
      dispatch(
        updateBlockchain({
          highestBlock: res.highestBlock.number,
          lastProcessedBlock: res.lastProcessedBlock.number
        })
      );
    }
  });
  dispatch(updateAssets());
};