|
@@ -17,12 +17,7 @@ function txHandler(tx: any) {
|
|
|
logger.info(tx)
|
|
logger.info(tx)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-async function onTick() {
|
|
|
|
|
- // block没变就不获取
|
|
|
|
|
- const blockNumber = await web3.eth.getBlockNumber()
|
|
|
|
|
- if (blockNumber === lastBlockNumber) return
|
|
|
|
|
- lastBlockNumber = blockNumber
|
|
|
|
|
-
|
|
|
|
|
|
|
+async function onTick(blockNumber: any) {
|
|
|
// block变了就拿block中的所有hash
|
|
// block变了就拿block中的所有hash
|
|
|
const block = await web3.eth.getBlock(blockNumber)
|
|
const block = await web3.eth.getBlock(blockNumber)
|
|
|
const txHashList = block.transactions
|
|
const txHashList = block.transactions
|
|
@@ -35,11 +30,13 @@ async function onTick() {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
async function main() {
|
|
async function main() {
|
|
|
- // await onTick()
|
|
|
|
|
|
|
+ let blockNumber = await web3.eth.getBlockNumber()
|
|
|
|
|
|
|
|
while (true) {
|
|
while (true) {
|
|
|
|
|
+ blockNumber -= 1
|
|
|
|
|
+
|
|
|
try {
|
|
try {
|
|
|
- await onTick()
|
|
|
|
|
|
|
+ await onTick(blockNumber)
|
|
|
} catch (error) {
|
|
} catch (error) {
|
|
|
console.error(error)
|
|
console.error(error)
|
|
|
}
|
|
}
|