118 lines
3.1 KiB
JavaScript
118 lines
3.1 KiB
JavaScript
const ethers = require('ethers')
|
|
|
|
const {
|
|
HOME_PRIVATE_KEY, HOME_RPC_URL, HOME_BRIDGE_ADDRESS, SIDE_RPC_URL, SIDE_SHARED_DB_ADDRESS
|
|
} = process.env
|
|
const SIDE_MAX_FETCH_RANGE_SIZE = parseInt(process.env.SIDE_MAX_FETCH_RANGE_SIZE, 10)
|
|
|
|
const bridgeAbi = [
|
|
'function applyMessage(bytes message, bytes signatures)',
|
|
'function getThreshold(uint16 epoch) view returns (uint16)',
|
|
'function getValidators(uint16 epoch) view returns (address[])'
|
|
]
|
|
const sharedDbAbi = [
|
|
'event NewMessage(bytes32 msgHash)',
|
|
'function signedMessages(bytes32 hash) view returns (bytes)',
|
|
'function getSignatures(bytes32 msgHash, address[] validators) view returns (bytes)'
|
|
]
|
|
|
|
let homeProvider
|
|
let sideProvider
|
|
let bridge
|
|
let sharedDb
|
|
let homeWallet
|
|
let nonce
|
|
let blockNumber = 0
|
|
|
|
async function delay(ms) {
|
|
await new Promise((res) => setTimeout(res, ms))
|
|
}
|
|
|
|
async function handleNewMessage(event) {
|
|
const { msgHash } = event.values
|
|
const message = await sharedDb.signedMessages(msgHash)
|
|
const epoch = parseInt(message.slice(4, 8), 16)
|
|
const [threshold, validators] = await Promise.all([
|
|
bridge.getThreshold(epoch),
|
|
bridge.getValidators(epoch)
|
|
])
|
|
|
|
while (true) {
|
|
const signatures = await sharedDb.getSignatures(msgHash, validators)
|
|
if (signatures.length === 2) {
|
|
console.log('Skipping event')
|
|
break
|
|
}
|
|
if ((signatures.length - 2) / 130 >= threshold) {
|
|
console.log('Sending applyMessage request')
|
|
const tx = await bridge.applyMessage(message, signatures, {
|
|
gasLimit: 1000000,
|
|
nonce
|
|
})
|
|
const receipt = await tx.wait()
|
|
console.log(`Used gas: ${receipt.gasUsed.toNumber()}`)
|
|
nonce += 1
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
async function initialize() {
|
|
while (true) {
|
|
try {
|
|
sideProvider = new ethers.providers.JsonRpcProvider(SIDE_RPC_URL)
|
|
homeProvider = new ethers.providers.JsonRpcProvider(HOME_RPC_URL)
|
|
|
|
homeWallet = new ethers.Wallet(HOME_PRIVATE_KEY, homeProvider)
|
|
bridge = new ethers.Contract(HOME_BRIDGE_ADDRESS, bridgeAbi, homeWallet)
|
|
sharedDb = new ethers.Contract(SIDE_SHARED_DB_ADDRESS, sharedDbAbi, sideProvider)
|
|
|
|
nonce = await homeWallet.getTransactionCount()
|
|
break
|
|
} catch (e) {
|
|
console.log('Cannot create providers')
|
|
await delay(1000)
|
|
}
|
|
}
|
|
}
|
|
|
|
async function loop() {
|
|
const latestBlockNumber = await sideProvider.getBlockNumber()
|
|
if (latestBlockNumber < blockNumber) {
|
|
console.log(`No block after ${latestBlockNumber}`)
|
|
return
|
|
}
|
|
|
|
const endBlock = Math.min(latestBlockNumber, blockNumber + SIDE_MAX_FETCH_RANGE_SIZE - 1)
|
|
|
|
console.log(`Watching events in blocks #${blockNumber}-${endBlock}`)
|
|
|
|
const bridgeEvents = (await sideProvider.getLogs({
|
|
address: SIDE_SHARED_DB_ADDRESS,
|
|
fromBlock: blockNumber,
|
|
toBlock: endBlock,
|
|
topics: [
|
|
sharedDb.interface.events.NewMessage.topic
|
|
]
|
|
}))
|
|
|
|
for (let i = 0; i < bridgeEvents.length; i += 1) {
|
|
const event = sharedDb.interface.parseLog(bridgeEvents[i])
|
|
console.log('Consumed event', event)
|
|
await handleNewMessage(event)
|
|
}
|
|
|
|
blockNumber = endBlock + 1
|
|
}
|
|
|
|
async function main() {
|
|
await initialize()
|
|
|
|
while (true) {
|
|
await delay(2000)
|
|
await loop()
|
|
}
|
|
}
|
|
|
|
main()
|