Blockchain filter in real time

var asciichart = require('asciichart');
var clear = require('clear');
const readline = require('readline');
const { ethers } = require('ethers');
require('dotenv').config();

// Connection for the blockchain node
const URL_NODE = `wss://bsc.getblock.io/${process.env.API_KEY}/mainnet/`;
const provider = new ethers.providers.WebSocketProvider(URL_NODE);

// Data handle
const rl = readline.createInterface({
    input: process.stdin,
    output: process.stdout
});

// Data output
const data = [0];
const history = [];
let lastBlock = 0;
let lastTransaction = '';
let lastGreaterThanEther = '';
let valueToFilter = 0;
let seconds = 0;

function refresh() {
    try {
        if (data.length >= 100) {
            data.shift();
        }
    } catch (error) {
        console.log('error on refresh');
    }
}

function comparation(valuePrice) {
    try {
        const oneEther = ethers.utils.parseUnits(valueToFilter, 'ether');
        const oneEtherinWei = ethers.utils.parseUnits(oneEther.toString(), 'wei');
        const bnValue = ethers.BigNumber.from(valuePrice);
        return bnValue.gt(ethers.BigNumber.from(oneEtherinWei));
    } catch (error) {
        console.log('error on comparation');
    }
}

function captureData() {
    provider.on('pending', async (transactionHash) => {
        const tx = await provider.getTransaction(transactionHash);
        if (tx && tx.value) {
            const valuePrice = tx.value.toString();
            const isAcutalPriceGreaterThanOneEther = comparation(valuePrice);
            if (isAcutalPriceGreaterThanOneEther) {
                lastGreaterThanEther = ethers.utils.formatEther(valuePrice);
                lastTransaction = `https://www.bscscan.com/tx/${transactionHash}`;
                history.push({ tx : lastTransaction, amount : ethers.utils.formatUnits(valuePrice.toString(), 'ether') });
            }
            refresh();
            data.push(Number(valuePrice));
        } else {
            refresh();
            data.push(0);
        }
    });

    provider.on('block', (blockNumber) => {
        lastBlock = blockNumber;
    });
}

function settingValueToFilter() {
    return new Promise((resolve) => {
        rl.question('Enter the value of BNB to filter => ', (inputValue) => {
            valueToFilter = inputValue;
            rl.close();
            resolve();
        });
    })
}

function renderChart() {
    const padding = '';
    const minLength = 12;
    const config = {
        offset: 3,
        height: 15,
        colors: [asciichart.green],
        format: function (x) {
            let inEther = ethers.utils.formatUnits(x.toString(), 'ether');
            if (inEther.length < minLength) {
                while (inEther.length < minLength) {
                    inEther += '0';
                }
            }
            return (padding + inEther).substring(0, minLength)
        }
    }
    const chartString = asciichart.plot(data, config);
    console.log(chartString);
}

function renderMessages() {
    console.log('------------------ About --------------------------------');
    console.log('[ Created by ] => kypanz');
    console.log('Happy hacking :)');
    console.log('------------------ Filter status ------------------------');
    console.log(`[ Greater than ] => ${valueToFilter} BNB`);
    console.log(`[ Actual block ] => ${lastBlock}`);
    console.log(`[ Live seconds ] => ${seconds}`);
    console.log('------------------ Last Capture -------------------------');
    console.log(`[ Pending transaction ] => ${lastTransaction}`);
    console.log(`[ Value ] ${lastGreaterThanEther} BNB`);
    console.log('------------------ History --------------------------------');
    for (let index = 0; index < history.length; index++) {
        console.log(`[ tx ] => ${history[index].tx} | [ amount ] => ${history[index].amount}`);
    }
}


async function main() {
    await settingValueToFilter();
    captureData();
    setInterval(() => {
        seconds++;
        clear();
        renderChart();
        renderMessages();
    }, 1000 * 1);
}

main();