avalon-watcher.js

var {spawn} = require('child_process');
var javalon = require('javalon')
javalon.init({api: 'https://avalon.d.tube'})
let delay = 2800
let txQueue = []
let isTransactioning = false
setInterval(function() {
    if (!isTransactioning && txQueue && txQueue.length > 0) {
        try {
            isTransactioning = true
            updateGasPrice(function() {
                console.log('=== BEGIN SEND-TX ===')
                let gasPrice = Math.round(ethGasPrice*(1+config.gasBoost))
                console.log('Gas Price Used: '+gasPrice+' wei')
                let cmd = txQueue[0] + " --price "+gasPrice
                txQueue.splice(0,1)
                let mintWdtc = spawn('npx', cmd.split(' '));     
                mintWdtc.stderr.on('data', (data) => {
                    console.error(data.toString());
                });
                mintWdtc.on('close', (code) => {
                    isTransactioning = false
                    console.log(`=== END SEND-TX: ${code} ===`);
                });
            })
        } catch (error) {
            throw err
        }
    }
}, 5000)

class AvalonWatcher {
    constructor(address) {
        console.log('Watching '+address+'@avalon')
        this.address = address
    }

    checkBlock(number) {
        javalon.getBlock(number, function(err, block) {
            // if (err) console.log(err)
            if (err || !block) {
                setTimeout(function() {DTCWatcher.checkBlock(number)}, delay)
                return
            }

            headblocks.avalon = number
            fs.writeFileSync('./headblocks.js', "module.exports={eth:"+headblocks.eth+",avalon:"+headblocks.avalon+"}")            

            let secondsAgo = Math.round((new Date().getTime() - block.timestamp)/1000)
            let transactions = block.txs;
            if (number%config.blocksDisplay === 0)
                console.log('Avalon Block #'+number+' '+secondsAgo+'s ago');
            if (block.txs != null && block.txs.length > 0) {
                for (let i = 0; i < block.txs.length; i++) {
                    let tx = block.txs[i]
                    if (tx.type === 3 && tx.data.receiver === DTCWatcher.address) {
                        let amount = tx.data.amount
                        let memo = tx.data.memo
                        console.log('transfer', tx.sender, amount, memo)
                        if (!memo) {
                            console.log('Error, tx without memo')
                            continue
                        }
                        let memoParsed = memo.split('@')
                        if (memoParsed.length !== 2) {
                            console.log('Error, memo invalid')
                            continue
                        }
                        let destinationNetwork = memoParsed[1].toLowerCase()
                        let destinationAddress = memoParsed[0]

                        if (destinationNetwork !== 'eth') {
                            console.log('Error, network is not ethereum')
                            continue
                        }

                        // take fees
                        if (amount <= txFeeDtc) {
                            console.log('Error, amount is <= fee')
                            continue
                        }
                        amount -= txFeeDtc
                        var cmd = "oz send-tx --to "+config.ethContractAddress
                        cmd += " --method transfer --args "+destinationAddress+","+amount
                        cmd += " -n mainnet --no-interactive"
                        txQueue.push(cmd)
                    }
                }
            }
            setTimeout(function() {DTCWatcher.checkBlock(1+number)}, 1)
        })
    }
}

module.exports = AvalonWatcher