区块管理最佳实践

import Web3 from 'web3';
const web3 = new Web3('YOUR_ETHEREUM_NODE_URL');

// Robust block fetching with retries
const fetchBlockWithRetry = async (blockNumber, maxRetries = 3) => {
	for (let i = 0; i < maxRetries; i++) {
		try {
			const block = await web3.eth.getBlock(blockNumber);
			if (block) return block;
			throw new Error('Block not found');
		} catch (error) {
			if (i === maxRetries - 1) throw error;
			await new Promise((resolve) => setTimeout(resolve, 1000 * (i + 1)));
		}
	}
};

// Efficient block monitoring
const createBlockMonitor = (callback, errorHandler) => {
	let lastProcessedBlock = 0;

	return web3.eth
		.subscribe('newBlockHeaders')
		.on('data', async (blockHeader) => {
			try {
				if (blockHeader.number <= lastProcessedBlock) return;
				await callback(blockHeader);
				lastProcessedBlock = blockHeader.number;
			} catch (error) {
				errorHandler(error);
			}
		})
		.on('error', errorHandler);
};

// Memory-efficient block processing
const processBlockRange = async (startBlock, endBlock, processor) => {
	const batchSize = 10;
	for (let i = startBlock; i <= endBlock; i += batchSize) {
		const batch = await Promise.all(
			Array.from({ length: Math.min(batchSize, endBlock - i + 1) }, (_, index) => fetchBlockWithRetry(i + index)),
		);
		await processor(batch);
	}
};

// Handle block reorgs
const monitorReorgs = async (callback) => {
	let lastBlock = await web3.eth.getBlock('latest');

	return web3.eth.subscribe('newBlockHeaders').on('data', async (block) => {
		if (block.parentHash !== lastBlock.hash) {
			await callback({
				oldBlock: lastBlock,
				newBlock: block,
			});
		}
		lastBlock = block;
	});
};