const ethers = require("ethers");
const NODE_URL = "CHAINSTACK_WSS_URL";
const provider = new ethers.WebSocketProvider(NODE_URL);
async function subscribeToNewBlocks() {
try {
// Attach event listeners for new blocks and errors
provider.on('block', handleNewBlock);
provider.on('error', handleError);
console.log("Subscribed to new blocks");
} 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
function handleNewBlock(blockNumber) {
console.log(blockNumber);
}
// 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()
