Block Management Best Practices

1import Web3 from 'web3';
2const web3 = new Web3('YOUR_ETHEREUM_NODE_URL');
3 
4// Robust block fetching with retries
5const fetchBlockWithRetry = async (blockNumber, maxRetries = 3) => {
6	for (let i = 0; i < maxRetries; i++) {
7		try {
8			const block = await web3.eth.getBlock(blockNumber);
9			if (block) return block;
10			throw new Error('Block not found');
11		} catch (error) {
12			if (i === maxRetries - 1) throw error;
13			await new Promise((resolve) => setTimeout(resolve, 1000 * (i + 1)));
14		}
15	}
16};
17 
18// Efficient block monitoring
19const createBlockMonitor = (callback, errorHandler) => {
20	let lastProcessedBlock = 0;
21 
22	return web3.eth
23		.subscribe('newBlockHeaders')
24		.on('data', async (blockHeader) => {
25			try {
26				if (blockHeader.number <= lastProcessedBlock) return;
27				await callback(blockHeader);
28				lastProcessedBlock = blockHeader.number;
29			} catch (error) {
30				errorHandler(error);
31			}
32		})
33		.on('error', errorHandler);
34};
35 
36// Memory-efficient block processing
37const processBlockRange = async (startBlock, endBlock, processor) => {
38	const batchSize = 10;
39	for (let i = startBlock; i <= endBlock; i += batchSize) {
40		const batch = await Promise.all(
41			Array.from({ length: Math.min(batchSize, endBlock - i + 1) }, (_, index) => fetchBlockWithRetry(i + index)),
42		);
43		await processor(batch);
44	}
45};
46 
47// Handle block reorgs
48const monitorReorgs = async (callback) => {
49	let lastBlock = await web3.eth.getBlock('latest');
50 
51	return web3.eth.subscribe('newBlockHeaders').on('data', async (block) => {
52		if (block.parentHash !== lastBlock.hash) {
53			await callback({
54				oldBlock: lastBlock,
55				newBlock: block,
56			});
57		}
58		lastBlock = block;
59	});
60};