const { ethers } = require("ethers");
const NODE_URL = "CHAINSTACK_WSS_URL";
const provider = new ethers.WebSocketProvider(NODE_URL);
async function subscribeToNewBlocks() {
try {
// Subscribe to new blocks by listening for the 'block' event
provider.on("block", handleNewBlock);
console.log("New subscription: block");
// Attach a listener that logs any provider errors
provider.on("error", handleError);
} catch (error) {
console.error(`Error subscribing to new blocks: ${error}`);
}
}
/* Fallback functions to react to the different events */
// Event listener that logs the received block number
async function handleNewBlock(blockNumber) {
const block = await provider.getBlock(blockNumber);
console.log(block);
}
// Event listener that logs any errors that occur
function handleError(error) {
console.error(`Error receiving new blocks: ${error}`);
}
async function clearSubscriptions() {
try {
await provider.removeAllListeners();
console.log("Subscriptions were canceled successfully");
return process.exit(1)
} catch (error) {
console.error("Failed to cancel subscriptions:", error);
return process.exit(1)
}
}
async function main() {
subscribeToNewBlocks();
// Run clearSubscriptions() once after 60 seconds
setTimeout(clearSubscriptions, 60000);
}
main()
