58 lines
1.4 KiB
JavaScript
58 lines
1.4 KiB
JavaScript
|
// @flow
|
||
|
|
|
||
|
|
import { connect } from 'react-redux';
|
||
|
|
import eres from 'eres';
|
||
|
|
import { BigNumber } from 'bignumber.js';
|
||
|
|
import { updateNodeSyncStatus } from '../redux/modules/app';
|
||
|
|
|
||
|
|
import { StatusPill } from '../components/status-pill';
|
||
|
|
|
||
|
|
import rpc from '../../services/api';
|
||
|
|
|
||
|
|
import type { Dispatch } from '../types/redux';
|
||
|
|
import type { AppState } from '../types/app-state';
|
||
|
|
|
||
|
|
export type MapStateToProps = {|
|
||
|
|
nodeSyncProgress: number,
|
||
|
|
nodeSyncType: 'ready' | 'syncing' | 'error',
|
||
|
|
|};
|
||
|
|
|
||
|
|
const mapStateToProps = ({ app }: AppState): MapStateToProps => ({
|
||
|
|
nodeSyncProgress: app.nodeSyncProgress,
|
||
|
|
nodeSyncType: app.nodeSyncType,
|
||
|
|
});
|
||
|
|
|
||
|
|
export type MapDispatchToProps = {|
|
||
|
|
getBlockchainStatus: () => Promise<void>,
|
||
|
|
|};
|
||
|
|
|
||
|
|
const mapDispatchToProps = (dispatch: Dispatch): MapDispatchToProps => ({
|
||
|
|
getBlockchainStatus: async () => {
|
||
|
|
const [blockchainErr, blockchaininfo] = await eres(rpc.getblockchaininfo());
|
||
|
|
|
||
|
|
if (blockchainErr || !blockchaininfo) {
|
||
|
|
return dispatch(
|
||
|
|
updateNodeSyncStatus({
|
||
|
|
nodeSyncProgress: 0,
|
||
|
|
nodeSyncType: 'error',
|
||
|
|
}),
|
||
|
|
);
|
||
|
|
}
|
||
|
|
|
||
|
|
const newProgress = blockchaininfo.verificationprogress * 100;
|
||
|
|
|
||
|
|
dispatch(
|
||
|
|
updateNodeSyncStatus({
|
||
|
|
nodeSyncProgress: newProgress,
|
||
|
|
nodeSyncType: new BigNumber(newProgress).gt(99.99) ? 'ready' : 'syncing',
|
||
|
|
}),
|
||
|
|
);
|
||
|
|
},
|
||
|
|
});
|
||
|
|
|
||
|
|
// $FlowFixMe
|
||
|
|
export const StatusPillContainer = connect(
|
||
|
|
mapStateToProps,
|
||
|
|
mapDispatchToProps,
|
||
|
|
)(StatusPill);
|